poll

type Adapter[T any] interface {

	// GetFinalizedBlockNumber returns the finalized block number, which will no longer be reverted.
	GetFinalizedBlockNumber(ctx context.Context) (uint64, error)

	// GetLatestBlockNumber returns the latest block number, which may be reverted later.
	//
	// E.g. "safe", "latest" or "latest - N" block that not finalized yet.
	GetLatestBlockNumber(ctx context.Context) (uint64, error)

	// GetBlockData returns the whole blockchain data of the given block number. Typically, it includes
	// block, transactions, receipts and traces.
	//
	// The implementation should be responsible for chain reorg detection if the given block number is
	// not finalized yet.
	GetBlockData(ctx context.Context, blockNumber uint64) (T, error)

	// GetBlockHash returns the block hash of given blockchain data.
	GetBlockHash(data T) string
	// GetParentBlockHash returns the parent block hash of given blockchain data.
	GetParentBlockHash(data T) string
}

type CatchUpOption struct {
	Parallel ParallelOption

	Buffer struct {
		Capacity int `default:"1024"`
		MaxBytes int `default:"256000000"` // 256M
	}
}

type CatchUpPoller[T channel.Sizable] struct {
	// contains filtered or unexported fields
}

type FinalizedPoller[T any] struct {
	// contains filtered or unexported fields
}

type LatestPoller[T any] struct {
	// contains filtered or unexported fields
}

type Option struct {
	IdleInterval  time.Duration `default:"1s"`
	RetryInterval time.Duration `default:"5s"`
	BufferSize    int           `default:"32"`
	Health        health.TimedCounterConfig
}

type ParallelOption struct {
	parallel.SerialOption `mapstructure:",squash"`

	RetryInterval time.Duration `default:"1s"`

	Health health.TimedCounterConfig
}

type ParallelWorker[T any] struct {
	// contains filtered or unexported fields
}

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

type ReorgWindowParams struct {
	FinalizedBlockNumber uint64
	FinalizedBlockHash   string
	LatestBlocks         map[uint64]string
}

type Revertable[T any] struct {
	Data     T
	Reverted bool // indicates whether chain reorg happened
}