feat: add ChainID() method for getting the chain ID from node status (#…

…69)

## Description


For getting `chain ID`, replace `querying genesis` with `querying status` as `querying genesis` is heavy and may put much load on the node which is unnecessary, especially when the app crashed and restarted. 

## Checklist
- [ ] Targeted PR against correct branch.
- [ ] Linked to Github issue with discussion and accepted design OR link to spec that describes this work.
- [ ] Wrote unit tests.  
- [ ] Re-reviewed `Files changed` in the Github PR explorer.

node/local/node.go

@@ -322,6 +322,11 @@ func (cp *Node) LatestHeight() (int64, error) {
 	return cp.blockStore.Height(), nil
 }
 
+// ChainID implements node.Node
+func (cp *Node) ChainID() (string, error) {
+	return cp.genesisDoc.ChainID, nil
+}
+
 // Validators implements node.Node
 func (cp *Node) Validators(height int64) (*tmctypes.ResultValidators, error) {
 	height, err := cp.getHeight(cp.blockStore.Height(), &height)

node/node.go

@@ -20,6 +20,9 @@ type Node interface {
 	// is returned if the query fails.
 	LatestHeight() (int64, error)
 
+	// ChainID returns the network ID
+	ChainID() (string, error)
+
 	// Validators returns all the known Tendermint validators for a given block
 	// height. An error is returned if the query fails.
 	Validators(height int64) (*tmctypes.ResultValidators, error)

node/remote/node.go

@@ -156,6 +156,17 @@ func (cp *Node) LatestHeight() (int64, error) {
 	return height, nil
 }
 
+// ChainID implements node.Node
+func (cp *Node) ChainID() (string, error) {
+	status, err := cp.client.Status(cp.ctx)
+	if err != nil {
+		return "", err
+	}
+
+	chainID := status.NodeInfo.Network
+	return chainID, err
+}
+
 // Validators implements node.Node
 func (cp *Node) Validators(height int64) (*tmctypes.ResultValidators, error) {
 	vals := &tmctypes.ResultValidators{

parser/worker.go

@@ -53,9 +53,9 @@ func NewWorker(ctx *Context, queue types.HeightQueue, index int) Worker {
 // given worker queue. Any failed job is logged and re-enqueued.
 func (w Worker) Start() {
 	logging.WorkerCount.Inc()
-	nodeInfo, err := w.node.Genesis()
+	chainID, err := w.node.ChainID()
 	if err != nil {
-		w.logger.Error("error while getting genesis info from the node ", "err", err)
+		w.logger.Error("error while getting chain ID from the node ", "err", err)
 	}
 
 	for i := range w.queue {
@@ -68,7 +68,7 @@ func (w Worker) Start() {
 			}()
 		}
 
-		logging.WorkerHeight.WithLabelValues(fmt.Sprintf("%d", w.index), nodeInfo.Genesis.ChainID).Set(float64(i))
+		logging.WorkerHeight.WithLabelValues(fmt.Sprintf("%d", w.index), chainID).Set(float64(i))
 	}
 }