log

type Broadcast interface {
	DecodedLog() interface{}
	RawLog() types.Log
	SetDecodedLog(interface{})
	String() string
	LatestBlockNumber() uint64
	LatestBlockHash() common.Hash
	JobID() interface{}
}

type Broadcaster interface {
	utils.DependentAwaiter
	service.Service
	httypes.HeadTrackable
	IsConnected() bool
	Register(listener Listener, opts ListenerOpts) (unsubscribe func())
	LatestHead() *models.Head
	TrackedAddressesCount() uint32
	// DB interactions
	WasAlreadyConsumed(db *gorm.DB, lb Broadcast) (bool, error)
	MarkConsumed(db *gorm.DB, lb Broadcast) error
}

type Config interface {
	BlockBackfillDepth() uint64
	EthFinalityDepth() uint
	EthLogBackfillBatchSize() uint32
}

type Listener interface {
	HandleLog(b Broadcast)
	JobID() models.JobID
	JobIDV2() int32
	IsV2Job() bool
}

type ListenerOpts struct {
	Contract common.Address

	// Event types to receive, with value filter for each field in the event
	// No filter or an empty filter for a given field position mean: all values allowed
	// the key should be a result of AbigenLog.Topic() call
	LogsWithTopics map[common.Hash][][]Topic

	ParseLog ParseLogFunc

	// Minimum number of block confirmations before the log is received
	NumConfirmations uint64
}

type NullBroadcaster struct{ ErrMsg string }

type ORM interface {
	WasBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, logIndex uint, jobID interface{}) (bool, error)
	MarkBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, blockNumber uint64, logIndex uint, jobID interface{}) error
}

type ParseLogFunc func(log types.Log) (generated.AbigenLog, error)

type Topic common.Hash