da

type AsyncBlockRetriever interface {
	Start(ctx context.Context)
	Stop()
	GetCachedBlock(ctx context.Context, daHeight uint64) (*BlockData, error)
	UpdateCurrentHeight(height uint64)
}

type BlockData struct {
	Height    uint64
	Timestamp time.Time
	Blobs     [][]byte
}

type Client interface {
	// Submit submits blobs to the DA layer.
	Submit(ctx context.Context, data [][]byte, gasPrice float64, namespace []byte, options []byte) datypes.ResultSubmit

	// Retrieve retrieves blobs from the DA layer at the specified height and namespace.
	Retrieve(ctx context.Context, height uint64, namespace []byte) datypes.ResultRetrieve

	// RetrieveBlobs retrieves blobs from the DA layer at the specified height and namespace
	// without requiring a DA header timestamp. Callers that need deterministic DA time should
	// use Retrieve instead.
	RetrieveBlobs(ctx context.Context, height uint64, namespace []byte) datypes.ResultRetrieve

	// Get retrieves blobs by their IDs. Used for visualization and fetching specific blobs.
	Get(ctx context.Context, ids []datypes.ID, namespace []byte) ([]datypes.Blob, error)

	// Subscribe returns a channel that emits one SubscriptionEvent per DA block
	// that contains a blob in the given namespace. The channel is closed when ctx
	// is cancelled. Callers MUST drain the channel after cancellation.
	// The fetchTimestamp param is going to be removed with https://github.com/evstack/ev-node/issues/3142 as the timestamp is going to be included by default
	Subscribe(ctx context.Context, namespace []byte, fetchTimestamp bool) (<-chan datypes.SubscriptionEvent, error)

	// GetLatestDAHeight returns the latest height available on the DA layer.
	GetLatestDAHeight(ctx context.Context) (uint64, error)

	// Namespace accessors.
	GetHeaderNamespace() []byte
	GetDataNamespace() []byte
	GetForcedInclusionNamespace() []byte
	HasForcedInclusionNamespace() bool
}

type Config struct {
	DA                       *blobrpc.Client
	Logger                   zerolog.Logger
	DefaultTimeout           time.Duration
	Namespace                string
	DataNamespace            string
	ForcedInclusionNamespace string
}

type ForcedInclusionEvent struct {
	Timestamp     time.Time
	StartDaHeight uint64
	EndDaHeight   uint64
	Txs           [][]byte
}

type ForcedInclusionRetriever interface {
	RetrieveForcedIncludedTxs(ctx context.Context, daHeight uint64) (*ForcedInclusionEvent, error)
	Start(ctx context.Context)
	Stop()
}

type FullClient interface {
	Client
	Verifier
}

type Subscriber struct {
	// contains filtered or unexported fields
}

type SubscriberConfig struct {
	Client      Client
	Logger      zerolog.Logger
	Namespaces  [][]byte // subscribe to all, merge into one channel
	DABlockTime time.Duration
	Handler     SubscriberHandler
	// Deprecated: Remove with https://github.com/evstack/ev-node/issues/3142
	FetchBlockTimestamp bool // the timestamp comes with an extra api call before Celestia v0.29.1-mocha.

	StartHeight uint64 // initial localDAHeight
}

type SubscriberHandler interface {
	// HandleEvent processes a subscription event.
	// isInline is true if the subscriber successfully claimed this height (via CAS).
	// Returning an error when isInline is true instructs the Subscriber to roll back the localDAHeight.
	HandleEvent(ctx context.Context, ev datypes.SubscriptionEvent, isInline bool) error

	// HandleCatchup is called for each height during sequential catchup.
	// The subscriber advances localDAHeight only after this returns (true, nil).
	// Returning an error rolls back localDAHeight and triggers a backoff retry.
	HandleCatchup(ctx context.Context, height uint64) error
}

type Verifier interface {
	// GetProofs returns inclusion Proofs for Blobs specified by their IDs.
	GetProofs(ctx context.Context, ids []datypes.ID, namespace []byte) ([]datypes.Proof, error)

	// Validate validates Commitments against the corresponding Proofs.
	Validate(ctx context.Context, ids []datypes.ID, proofs []datypes.Proof, namespace []byte) ([]bool, error)
}