tracker

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

type BlockCompletionTrackerConfig struct {
	// StaleThreshold is the time after which a block is considered stale.
	StaleThreshold time.Duration

	// AutoRetryStale enables automatic retry of stale blocks.
	AutoRetryStale bool
}

type BlockProcessor interface {
	Processor

	// ProcessNextBlock discovers and enqueues tasks for the next block.
	// Returns an error if no block is available or processing fails.
	ProcessNextBlock(ctx context.Context) error

	// GetQueues returns the Asynq queues used by this processor.
	// Queues have priorities to control processing order.
	GetQueues() []QueueInfo

	// GetHandlers returns task handlers for Asynq worker registration.
	// These handlers process the distributed tasks.
	GetHandlers() map[string]asynq.HandlerFunc

	// EnqueueTask adds a task to the distributed queue.
	// Uses infinite retries to ensure eventual processing.
	EnqueueTask(ctx context.Context, task *asynq.Task, opts ...asynq.Option) error

	// SetProcessingMode configures forwards or backwards processing.
	SetProcessingMode(mode string)

	// ReprocessBlock re-enqueues tasks for an orphaned block.
	// Used when a block is in ClickHouse (complete=0) but has no Redis tracking.
	// This can happen due to Redis TTL expiry, Redis restart, or crashes.
	ReprocessBlock(ctx context.Context, blockNum uint64) error

	// ProcessBlock processes a single block - fetches, marks enqueued, and enqueues tasks.
	// This is used for gap filling of missing blocks (blocks with no row in DB).
	ProcessBlock(ctx context.Context, block execution.Block) error

	// GetCompletionTracker returns the block completion tracker for checking tracking status.
	GetCompletionTracker() *BlockCompletionTracker
}

type GapResult struct {
	Incomplete   []uint64      // Blocks with row but complete=0
	Missing      []uint64      // Blocks with no row at all
	ScanDuration time.Duration // Time taken to perform the scan
}

type GapStateProvider interface {
	StateProvider
	GetIncompleteBlocksInRange(ctx context.Context, network, processor string, minBlock, maxBlock uint64, limit int) ([]uint64, error)
	GetMissingBlocksInRange(ctx context.Context, network, processor string, minBlock, maxBlock uint64, limit int) ([]uint64, error)
	GetMinMaxStoredBlocks(ctx context.Context, network, processor string) (*big.Int, *big.Int, error)
}

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

type LimiterConfig struct {
	MaxPendingBlockRange int
}

type LimiterDeps struct {
	Log           logrus.FieldLogger
	StateProvider StateProvider
	Network       string
	Processor     string
}

type Processor interface {
	// Start initializes the processor and its dependencies (e.g., ClickHouse).
	Start(ctx context.Context) error

	// Stop gracefully shuts down the processor.
	Stop(ctx context.Context) error

	// Name returns the unique identifier for this processor.
	Name() string
}

type QueueInfo struct {
	Name     string
	Priority int
}

type StateProvider interface {
	GetOldestIncompleteBlock(ctx context.Context, network, processor string, minBlockNumber uint64) (*uint64, error)
	GetNewestIncompleteBlock(ctx context.Context, network, processor string, maxBlockNumber uint64) (*uint64, error)
	MarkBlockComplete(ctx context.Context, blockNumber uint64, network, processor string) error
}