healthy

client/eth/client.go

@@ -20,6 +20,7 @@ const (
 type Client interface {
 	DialContext(ctx context.Context, rawurl string) error
 	Close() error
+	Health() bool
 	Reader
 	Writer
 }
@@ -87,6 +88,11 @@ func (c *ExtendedEthClient) Close() error {
 	return nil
 }
 
+func (c *ExtendedEthClient) Health() bool {
+	_, err := c.ChainID(context.TODO())
+	return err == nil
+}
+
 // ==================================================================
 // Client Usage Methods
 // ==================================================================

client/eth/client_provider.go

@@ -16,13 +16,6 @@ var (
 	ErrClientNotFound = errors.New("client not found")
 )
 
-// ChainProvider is an interface that groups the Reader, Writer, and ConnectionPool interfaces.
-type ChainProvider interface {
-	Reader
-	Writer
-	ConnectionPool
-}
-
 // ChainProviderImpl is an implementation of the ChainProvider interface.
 type ChainProviderImpl struct {
 	ConnectionPool
@@ -234,3 +227,14 @@ func (c *ChainProviderImpl) TxPoolContent(ctx context.Context) (
 	}
 	return nil, ErrClientNotFound
 }
+
+func (c *ChainProviderImpl) Health() bool {
+	httpOk, wsOk := false, false
+	if client, ok := c.GetHTTP(); ok {
+		httpOk = client.Healthy()
+	}
+	if client, ok := c.GetWS(); ok {
+		wsOk = client.Healthy()
+	}
+	return httpOk && wsOk
+}

types/context.go

@@ -15,9 +15,10 @@ type CancellableContext interface {
 
 type Context struct {
 	context.Context
-	chain  eth.Client
-	logger log.Logger
-	db     ethdb.KeyValueStore
+	chain    eth.Client
+	logger   log.Logger
+	db       ethdb.KeyValueStore
+	connPool eth.ConnectionPool
 }
 
 // UnwrapContext unwraps the sdk context.
@@ -60,3 +61,7 @@ func (c *Context) Logger() log.Logger {
 func (c *Context) DB() ethdb.KeyValueStore {
 	return c.db
 }
+
+func (c *Context) ConnectionPool() eth.ConnectionPool {
+	return c.connPool
+}