refactor: eth client and logger

chainio/clients/avsregistry/bindings.go

@@ -41,7 +41,7 @@ type ContractBindings struct {
 func NewAVSRegistryContractBindings(
 	registryCoordinatorAddr gethcommon.Address,
 	operatorStateRetrieverAddr gethcommon.Address,
-	ethclient eth.Client,
+	ethclient eth.HttpBackend,
 	logger logging.Logger,
 ) (*ContractBindings, error) {
 	contractBlsRegistryCoordinator, err := regcoordinator.NewContractRegistryCoordinator(
@@ -124,7 +124,7 @@ func NewAVSRegistryContractBindings(
 // NewBindingsFromConfig creates a new instance of ContractBindings
 func NewBindingsFromConfig(
 	cfg Config,
-	client eth.Client,
+	client eth.HttpBackend,
 	logger logging.Logger,
 ) (*ContractBindings, error) {
 	var (

chainio/clients/avsregistry/builder.go

@@ -9,8 +9,8 @@ import (
 
 func BuildClients(
 	config Config,
-	client eth.Client,
-	wsClient eth.Client,
+	client eth.HttpBackend,
+	wsClient eth.WsBackend,
 	txMgr txmgr.TxManager,
 	logger logging.Logger,
 ) (*ChainReader, *ChainSubscriber, *ChainWriter, *ContractBindings, error) {

chainio/clients/avsregistry/reader.go

@@ -37,7 +37,7 @@ type ChainReader struct {
 	registryCoordinator     *regcoord.ContractRegistryCoordinator
 	operatorStateRetriever  *opstateretriever.ContractOperatorStateRetriever
 	stakeRegistry           *stakeregistry.ContractStakeRegistry
-	ethClient               eth.Client
+	ethClient               eth.HttpBackend
 }
 
 func NewChainReader(
@@ -47,7 +47,7 @@ func NewChainReader(
 	operatorStateRetriever *opstateretriever.ContractOperatorStateRetriever,
 	stakeRegistry *stakeregistry.ContractStakeRegistry,
 	logger logging.Logger,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 ) *ChainReader {
 	logger = logger.With(logging.ComponentKey, "avsregistry/ChainReader")
 
@@ -65,7 +65,7 @@ func NewChainReader(
 // NewReaderFromConfig creates a new ChainReader
 func NewReaderFromConfig(
 	cfg Config,
-	client eth.Client,
+	client eth.HttpBackend,
 	logger logging.Logger,
 ) (*ChainReader, error) {
 	bindings, err := NewBindingsFromConfig(cfg, client, logger)
@@ -89,7 +89,7 @@ func NewReaderFromConfig(
 func BuildAvsRegistryChainReader(
 	registryCoordinatorAddr common.Address,
 	operatorStateRetrieverAddr common.Address,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 ) (*ChainReader, error) {
 	contractRegistryCoordinator, err := regcoord.NewContractRegistryCoordinator(registryCoordinatorAddr, ethClient)

chainio/clients/avsregistry/subscriber.go

@@ -38,7 +38,7 @@ func NewChainSubscriber(
 // Deprecated: Use NewSubscriberFromConfig instead
 func BuildAvsRegistryChainSubscriber(
 	regCoordAddr common.Address,
-	ethWsClient eth.Client,
+	ethWsClient eth.WsBackend,
 	logger logging.Logger,
 ) (*ChainSubscriber, error) {
 	regCoord, err := regcoord.NewContractRegistryCoordinator(regCoordAddr, ethWsClient)
@@ -60,7 +60,7 @@ func BuildAvsRegistryChainSubscriber(
 // A websocket ETH Client must be provided
 func NewSubscriberFromConfig(
 	cfg Config,
-	wsClient eth.Client,
+	wsClient eth.WsBackend,
 	logger logging.Logger,
 ) (*ChainSubscriber, error) {
 	bindings, err := NewBindingsFromConfig(cfg, wsClient, logger)

chainio/clients/avsregistry/writer.go

@@ -45,7 +45,7 @@ type ChainWriter struct {
 	blsApkRegistry         *blsapkregistry.ContractBLSApkRegistry
 	elReader               eLReader
 	logger                 logging.Logger
-	ethClient              eth.Client
+	ethClient              eth.HttpBackend
 	txMgr                  txmgr.TxManager
 }
 
@@ -57,7 +57,7 @@ func NewChainWriter(
 	blsApkRegistry *blsapkregistry.ContractBLSApkRegistry,
 	elReader eLReader,
 	logger logging.Logger,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	txMgr txmgr.TxManager,
 ) *ChainWriter {
 	logger = logger.With(logging.ComponentKey, "avsregistry/ChainWriter")
@@ -81,7 +81,7 @@ func BuildAvsRegistryChainWriter(
 	registryCoordinatorAddr gethcommon.Address,
 	operatorStateRetrieverAddr gethcommon.Address,
 	logger logging.Logger,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	txMgr txmgr.TxManager,
 ) (*ChainWriter, error) {
 	registryCoordinator, err := regcoord.NewContractRegistryCoordinator(registryCoordinatorAddr, ethClient)
@@ -147,7 +147,7 @@ func BuildAvsRegistryChainWriter(
 // NewWriterFromConfig creates a new ChainWriter from the provided config
 func NewWriterFromConfig(
 	cfg Config,
-	client eth.Client,
+	client eth.HttpBackend,
 	txMgr txmgr.TxManager,
 	logger logging.Logger,
 ) (*ChainWriter, error) {

chainio/clients/builder.go

@@ -5,6 +5,8 @@ import (
 	"crypto/ecdsa"
 	"time"
 
+	"github.com/ethereum/go-ethereum/ethclient"
+
 	"github.com/Layr-Labs/eigensdk-go/chainio/clients/avsregistry"
 	"github.com/Layr-Labs/eigensdk-go/chainio/clients/elcontracts"
 	"github.com/Layr-Labs/eigensdk-go/chainio/clients/eth"
@@ -39,8 +41,8 @@ type Clients struct {
 	AvsRegistryChainWriter      *avsregistry.ChainWriter
 	ElChainReader               *elcontracts.ChainReader
 	ElChainWriter               *elcontracts.ChainWriter
-	EthHttpClient               eth.Client
-	EthWsClient                 eth.Client
+	EthHttpClient               eth.HttpBackend
+	EthWsClient                 eth.WsBackend
 	Wallet                      wallet.Wallet
 	TxManager                   txmgr.TxManager
 	AvsRegistryContractBindings *avsregistry.ContractBindings
@@ -61,12 +63,12 @@ func BuildAll(
 	eigenMetrics := metrics.NewEigenMetrics(config.AvsName, config.PromMetricsIpPortAddress, promReg, logger)
 
 	// creating two types of Eth clients: HTTP and WS
-	ethHttpClient, err := eth.NewClient(config.EthHttpUrl)
+	ethHttpClient, err := ethclient.Dial(config.EthHttpUrl)
 	if err != nil {
 		return nil, utils.WrapError("Failed to create Eth Http client", err)
 	}
 
-	ethWsClient, err := eth.NewClient(config.EthWsUrl)
+	ethWsClient, err := ethclient.Dial(config.EthWsUrl)
 	if err != nil {
 		return nil, utils.WrapError("Failed to create Eth WS client", err)
 	}

chainio/clients/elcontracts/bindings.go

@@ -35,7 +35,7 @@ type ContractBindings struct {
 
 func NewBindingsFromConfig(
 	cfg Config,
-	client eth.Client,
+	client eth.HttpBackend,
 	logger logging.Logger,
 ) (*ContractBindings, error) {
 	var (
@@ -117,7 +117,7 @@ func isZeroAddress(address gethcommon.Address) bool {
 func NewEigenlayerContractBindings(
 	delegationManagerAddr gethcommon.Address,
 	avsDirectoryAddr gethcommon.Address,
-	ethclient eth.Client,
+	ethclient eth.HttpBackend,
 	logger logging.Logger,
 ) (*ContractBindings, error) {
 	contractDelegationManager, err := delegationmanager.NewContractDelegationManager(delegationManagerAddr, ethclient)

chainio/clients/elcontracts/builder.go

@@ -9,7 +9,7 @@ import (
 
 func BuildClients(
 	config Config,
-	client eth.Client,
+	client eth.HttpBackend,
 	txMgr txmgr.TxManager,
 	logger logging.Logger,
 	eigenMetrics *metrics.EigenMetrics,

chainio/clients/elcontracts/reader.go

@@ -35,7 +35,7 @@ type ChainReader struct {
 	strategyManager    *strategymanager.ContractStrategyManager
 	avsDirectory       *avsdirectory.ContractAVSDirectory
 	rewardsCoordinator *rewardscoordinator.ContractIRewardsCoordinator
-	ethClient          eth.Client
+	ethClient          eth.HttpBackend
 }
 
 func NewChainReader(
@@ -45,7 +45,7 @@ func NewChainReader(
 	avsDirectory *avsdirectory.ContractAVSDirectory,
 	rewardsCoordinator *rewardscoordinator.ContractIRewardsCoordinator,
 	logger logging.Logger,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 ) *ChainReader {
 	logger = logger.With(logging.ComponentKey, "elcontracts/reader")
 
@@ -65,7 +65,7 @@ func NewChainReader(
 func BuildELChainReader(
 	delegationManagerAddr gethcommon.Address,
 	avsDirectoryAddr gethcommon.Address,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 ) (*ChainReader, error) {
 	elContractBindings, err := NewEigenlayerContractBindings(
@@ -90,7 +90,7 @@ func BuildELChainReader(
 
 func NewReaderFromConfig(
 	cfg Config,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 ) (*ChainReader, error) {
 	elContractBindings, err := NewBindingsFromConfig(

chainio/clients/elcontracts/writer.go

@@ -38,7 +38,7 @@ type ChainWriter struct {
 	rewardsCoordinator  *rewardscoordinator.ContractIRewardsCoordinator
 	strategyManagerAddr gethcommon.Address
 	elChainReader       Reader
-	ethClient           eth.Client
+	ethClient           eth.HttpBackend
 	logger              logging.Logger
 	txMgr               txmgr.TxManager
 }
@@ -50,7 +50,7 @@ func NewChainWriter(
 	rewardsCoordinator *rewardscoordinator.ContractIRewardsCoordinator,
 	strategyManagerAddr gethcommon.Address,
 	elChainReader Reader,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 	eigenMetrics metrics.Metrics,
 	txMgr txmgr.TxManager,
@@ -75,7 +75,7 @@ func NewChainWriter(
 func BuildELChainWriter(
 	delegationManagerAddr gethcommon.Address,
 	avsDirectoryAddr gethcommon.Address,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 	eigenMetrics metrics.Metrics,
 	txMgr txmgr.TxManager,
@@ -114,7 +114,7 @@ func BuildELChainWriter(
 
 func NewWriterFromConfig(
 	cfg Config,
-	ethClient eth.Client,
+	ethClient eth.HttpBackend,
 	logger logging.Logger,
 	eigenMetrics metrics.Metrics,
 	txMgr txmgr.TxManager,

chainio/clients/eth/client.go

@@ -4,54 +4,23 @@ import (
 	"context"
 	"math/big"
 
-	"github.com/ethereum/go-ethereum"
-	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
-	"github.com/ethereum/go-ethereum/ethclient"
+
+	"github.com/ethereum/go-ethereum/accounts/abi/bind"
 )
 
-type Client interface {
-	ChainID(ctx context.Context) (*big.Int, error)
-	BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
-	BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
-	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
+// HttpBackend is the HTTP ETH Client interface
+type HttpBackend interface {
+	bind.ContractBackend
+
 	BlockNumber(ctx context.Context) (uint64, error)
-	CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
-	CallContractAtHash(ctx context.Context, msg ethereum.CallMsg, blockHash common.Hash) ([]byte, error)
-	CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
-	EstimateGas(ctx context.Context, msg ethereum.CallMsg) (uint64, error)
-	FeeHistory(
-		ctx context.Context,
-		blockCount uint64,
-		lastBlock *big.Int,
-		rewardPercentiles []float64,
-	) (*ethereum.FeeHistory, error)
-	FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
-	HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
-	HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
-	NetworkID(ctx context.Context) (*big.Int, error)
-	NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
-	PeerCount(ctx context.Context) (uint64, error)
-	PendingBalanceAt(ctx context.Context, account common.Address) (*big.Int, error)
-	PendingCallContract(ctx context.Context, msg ethereum.CallMsg) ([]byte, error)
-	PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
-	PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
-	PendingStorageAt(ctx context.Context, account common.Address, key common.Hash) ([]byte, error)
-	PendingTransactionCount(ctx context.Context) (uint, error)
-	SendTransaction(ctx context.Context, tx *types.Transaction) error
-	StorageAt(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int) ([]byte, error)
-	SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
-	SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)
-	SuggestGasPrice(ctx context.Context) (*big.Int, error)
-	SuggestGasTipCap(ctx context.Context) (*big.Int, error)
-	SyncProgress(ctx context.Context) (*ethereum.SyncProgress, error)
-	TransactionByHash(ctx context.Context, hash common.Hash) (tx *types.Transaction, isPending bool, err error)
-	TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)
-	TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)
-	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
-	TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
+	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
 }
 
-func NewClient(rpcAddress string) (Client, error) {
-	return ethclient.Dial(rpcAddress)
+// WsBackend is the Websocket ETH Client interface
+type WsBackend interface {
+	bind.ContractBackend
+
+	BlockNumber(ctx context.Context) (uint64, error)
+	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
 }

chainio/clients/eth/instrumented_client.go

@@ -12,6 +12,48 @@ import (
 	"github.com/ethereum/go-ethereum/ethclient"
 )
 
+type client interface {
+	ChainID(ctx context.Context) (*big.Int, error)
+	BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
+	BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
+	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
+	BlockNumber(ctx context.Context) (uint64, error)
+	CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
+	CallContractAtHash(ctx context.Context, msg ethereum.CallMsg, blockHash common.Hash) ([]byte, error)
+	CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
+	EstimateGas(ctx context.Context, msg ethereum.CallMsg) (uint64, error)
+	FeeHistory(
+		ctx context.Context,
+		blockCount uint64,
+		lastBlock *big.Int,
+		rewardPercentiles []float64,
+	) (*ethereum.FeeHistory, error)
+	FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
+	HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
+	HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
+	NetworkID(ctx context.Context) (*big.Int, error)
+	NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
+	PeerCount(ctx context.Context) (uint64, error)
+	PendingBalanceAt(ctx context.Context, account common.Address) (*big.Int, error)
+	PendingCallContract(ctx context.Context, msg ethereum.CallMsg) ([]byte, error)
+	PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
+	PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
+	PendingStorageAt(ctx context.Context, account common.Address, key common.Hash) ([]byte, error)
+	PendingTransactionCount(ctx context.Context) (uint, error)
+	SendTransaction(ctx context.Context, tx *types.Transaction) error
+	StorageAt(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int) ([]byte, error)
+	SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
+	SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)
+	SuggestGasPrice(ctx context.Context) (*big.Int, error)
+	SuggestGasTipCap(ctx context.Context) (*big.Int, error)
+	SyncProgress(ctx context.Context) (*ethereum.SyncProgress, error)
+	TransactionByHash(ctx context.Context, hash common.Hash) (tx *types.Transaction, isPending bool, err error)
+	TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)
+	TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)
+	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
+	TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
+}
+
 // InstrumentedClient is a wrapper around the geth ethclient that instruments
 // all the calls made to it. It counts each eth_ call made to it, and records the duration of each call,
 // and exposes these as prometheus metrics
@@ -27,7 +69,7 @@ type InstrumentedClient struct {
 	clientAndVersion string
 }
 
-var _ Client = (*InstrumentedClient)(nil)
+var _ client = (*InstrumentedClient)(nil)
 
 func NewInstrumentedClient(rpcAddress string, rpcCallsCollector *rpccalls.Collector) (*InstrumentedClient, error) {
 	client, err := ethclient.Dial(rpcAddress)