noder

type MultiChainNodesStorage interface {
	GetByChainId(chainId int64) (*Node, error)
	GetNextByChainId(chainId int64) (*Node, error)
	GetHistoryByChainId(chainId int64) (*Node, error)
	GetNextHistoryByChainId(chainId int64) (*Node, error)
	ToSingleChain(chainId int64) (NodesStorage, error)
}

type Node struct {
	Rpc    *ethclient.Client `fig:"rpc,required"`
	RpcUrl string            `fig:"rpc,required"`

	Ws    *ethclient.Client `fig:"ws"`
	WsUrl string            `fig:"ws"`

	ChainId int64 `fig:"chain_id,required"`

	History bool `fig:"history"`
}

type Noder interface {
	NodesConfig() NodesConfig
	MultiChainNodesStorage() MultiChainNodesStorage
	NodesStorage() NodesStorage
}

type NodesConfig struct {
	Nodes             []Node        `fig:"nodes,required"`
	HealthCheckPeriod time.Duration `fig:"health_check_period,required"`
}

type NodesStorage interface {
	Get() (*Node, error)
	GetNext() (*Node, error)
	GetHistory() (*Node, error)
	GetNextHistory() (*Node, error)
}