common

type BlockOptions struct {
	AggregatorNodeSignatureBytesProvider types.AggregatorNodeSignatureBytesProvider
	SyncNodeSignatureBytesProvider       types.SyncNodeSignatureBytesProvider
	ValidatorHasherProvider              types.ValidatorHasherProvider
}

type Broadcaster[H header.Header[H]] interface {
	WriteToStoreAndBroadcast(ctx context.Context, payload H, opts ...pubsub.PubOpt) error
	Store() header.Store[H]
	Height() uint64
}

type DAHeightEvent struct {
	Header *types.SignedHeader
	Data   *types.Data
	// DaHeight corresponds to the highest DA included height between the Header and Data.
	DaHeight uint64
	// Source indicates where this event originated from (DA or P2P)
	Source EventSource

	// Optional DA height hints from P2P. first is the DA height hint for the header, second is the DA height hint for the data
	DaHeightHints [2]uint64
}

type DASubmitterFailureReason string

type DataP2PBroadcaster = Broadcaster[*types.P2PData]

type EventSink interface {
	PipeEvent(ctx context.Context, event DAHeightEvent) error
}

type EventSinkFunc func(ctx context.Context, event DAHeightEvent) error

type EventSource string

type HeaderP2PBroadcaster = Broadcaster[*types.P2PSignedHeader]

type Metrics struct {
	// Original metrics
	Height          metrics.Gauge // Height of the chain
	NumTxs          metrics.Gauge // Number of transactions in the latest block
	BlockSizeBytes  metrics.Gauge // Size of the latest block
	TotalTxs        metrics.Gauge // Total number of transactions
	CommittedHeight metrics.Gauge `metrics_name:"latest_block_height"` // The latest block height
	TxsPerBlock     metrics.Histogram

	// Performance metrics
	OperationDuration map[string]metrics.Histogram

	// DA metrics
	DASubmitterFailures     map[DASubmitterFailureReason]metrics.Counter // Counter with reason label
	DASubmitterLastFailure  map[DASubmitterFailureReason]metrics.Gauge   // Timestamp gauge with reason label
	DASubmitterPendingBlobs metrics.Gauge                                // Total number of blobs awaiting submission (backlog)
	DASubmitterResends      metrics.Counter                              // Number of resend attempts
	DARetrievalAttempts     metrics.Counter
	DARetrievalSuccesses    metrics.Counter
	DARetrievalFailures     metrics.Counter
	DAInclusionHeight       metrics.Gauge

	// Forced inclusion metrics
	ForcedInclusionTxsInGracePeriod metrics.Gauge   // Number of forced inclusion txs currently in grace period
	ForcedInclusionTxsMalicious     metrics.Counter // Total number of forced inclusion txs marked as malicious

	// Syncer metrics
	BlocksSynchronized map[EventSource]metrics.Counter // Blocks synchronized by source (P2P or DA)
}

type MockBroadcaster[H header.Header[H]] struct {
	mock.Mock
}

type MockBroadcaster_Expecter[H header.Header[H]] struct {
	// contains filtered or unexported fields
}

type MockBroadcaster_Height_Call[H header.Header[H]] struct {
	*mock.Call
}

type MockBroadcaster_Store_Call[H header.Header[H]] struct {
	*mock.Call
}

type MockBroadcaster_WriteToStoreAndBroadcast_Call[H header.Header[H]] struct {
	*mock.Call
}

type RaftNode interface {
	IsLeader() bool
	HasQuorum() bool
	GetState() *raft.RaftBlockState

	Broadcast(ctx context.Context, state *raft.RaftBlockState) error

	SetApplyCallback(ch chan<- raft.RaftApplyMsg)
}

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