feat: enable metrics collecting on eth rpc calls (#108)

* enable metrics collecting on eth rpc calls

* add testing

* fix lint

baseapp/builder.go

@@ -51,7 +51,16 @@ func (ab *AppBuilder) RegisterDB(db ethdb.KeyValueStore) {
 func (ab *AppBuilder) RegisterMetrics(cfg *telemetry.Config) error {
 	var err error
 	ab.metrics, err = telemetry.NewMetrics(cfg)
-	return err
+	if err != nil {
+		return err
+	}
+
+	// Enable metrics on eth client only if it is an instance of ChainProviderImpl.
+	chainProvider, ok := ab.ethClient.(*eth.ChainProviderImpl)
+	if ok {
+		chainProvider.EnableMetrics(ab.metrics)
+	}
+	return nil
 }
 
 // RegisterHTTPServer registers the http server.

client/eth/client.go

@@ -12,10 +12,12 @@ import (
 	"github.com/ethereum/go-ethereum/rpc"
 )
 
+//go:generate mockery --name Client
 type Client interface {
 	DialContext(ctx context.Context, rawurl string) error
 	Close() error
 	Health() bool
+	ClientID() string
 	Reader
 	Writer
 }
@@ -99,6 +101,7 @@ type Writer interface {
 type ExtendedEthClient struct {
 	*ethclient.Client
 	rpcTimeout time.Duration
+	clientID   string
 }
 
 func NewExtendedEthClient(c *ethclient.Client, rpcTimeout time.Duration) *ExtendedEthClient {
@@ -120,6 +123,7 @@ func (c *ExtendedEthClient) DialContext(ctx context.Context, rawurl string) erro
 	var err error
 	ctxWithTimeout, cancel := context.WithTimeout(ctx, c.rpcTimeout)
 	c.Client, err = ethclient.DialContext(ctxWithTimeout, rawurl)
+	c.clientID = trimProtocolAndPort(rawurl)
 	cancel()
 	return err
 }
@@ -140,6 +144,10 @@ func (c *ExtendedEthClient) Health() bool {
 	return err == nil
 }
 
+func (c *ExtendedEthClient) ClientID() string {
+	return c.clientID
+}
+
 // ==================================================================
 // Client Usage Methods
 // ==================================================================