watcher

type EthereumAPIClient interface {
	GetTxByBlockNumberAndIndex(ctx context.Context, block *big.Int, index uint) (EthereumTx, error)
	GetBlockByNumber(context.Context, *big.Int) (EthereumBlock, error)
	GetLastBlockNumber(context.Context) (*big.Int, error)
	io.Closer
}

type EthereumBlock interface {
	Txs() []EthereumTx
	Number() *big.Int
}

type EthereumFinEvent interface {
	Event
	WithTx
}

type EthereumTx interface {
	Tx
	Index() uint
	EthereumTx() *types.Transaction
	Gas() *big.Int
	GasPrice() *big.Int
	GasFeeCap() *big.Int
	GasTipCap() *big.Int
}

type EthereumTxEvent interface {
	Event
	WithTx
}

type EthereumWatcher interface {
	Watcher
}

type Event interface {
	Kind() string
	Net() string
	MarshalYAML() []byte
}

type EventLog interface {
	Emit(Event) error
	io.Closer
}

type FinEvent interface {
	Event
	TxID() []byte
}

type Repo interface {
	StoreTxsByBlockID(Tx) error
	FindTxsByBlockID(blockID *big.Int) ([]Tx, error)
	PurgeTxsByBlockID(blockID *big.Int) error
}

type Tx interface {
	Sender() []byte
	Receiver() []byte
	ID() []byte
	Amount() *big.Int
	Net() string
	Kind() string
	Block() *big.Int
}

type Watcher interface {
	Pull(ctx context.Context) ([]Event, error)
	io.Closer
}

type WithTx interface {
	Tx() Tx
}