From b77d4082354142f3cc627cc6bb0471bcd460ac94 Mon Sep 17 00:00:00 2001
From: Leo <leo@certus.one>
Date: Mon, 2 Aug 2021 14:30:16 +0200
Subject: [PATCH] node/pkg/ethereum: readiness status for bsc

Bug: certusone/wormhole#292
Change-Id: Ibb176dc70beeb2c00c7faf7d85395e93d53e9e4c
---
 bridge/cmd/guardiand/bridge.go | 4 ++--
 bridge/pkg/common/readiness.go | 1 +
 bridge/pkg/ethereum/watcher.go | 6 +++++-
 3 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/bridge/cmd/guardiand/bridge.go b/bridge/cmd/guardiand/bridge.go
index 2ac224e56..693f172bb 100644
--- a/bridge/cmd/guardiand/bridge.go
+++ b/bridge/cmd/guardiand/bridge.go
@@ -418,12 +418,12 @@ func runBridge(cmd *cobra.Command, args []string) {
 		}
 
 		if err := supervisor.Run(ctx, "ethwatch",
-			ethereum.NewEthBridgeWatcher(*ethRPC, ethContractAddr, "eth", vaa.ChainIDEthereum, lockC, setC).Run); err != nil {
+			ethereum.NewEthBridgeWatcher(*ethRPC, ethContractAddr, "eth", common.ReadinessEthSyncing, vaa.ChainIDEthereum, lockC, setC).Run); err != nil {
 			return err
 		}
 
 		if err := supervisor.Run(ctx, "bscwatch",
-			ethereum.NewEthBridgeWatcher(*bscRPC, bscContractAddr, "bsc", vaa.ChainIDBSC, lockC, nil).Run); err != nil {
+			ethereum.NewEthBridgeWatcher(*bscRPC, bscContractAddr, "bsc", common.ReadinessBSCSyncing, vaa.ChainIDBSC, lockC, nil).Run); err != nil {
 			return err
 		}
 
diff --git a/bridge/pkg/common/readiness.go b/bridge/pkg/common/readiness.go
index a18d49101..77b95ff18 100644
--- a/bridge/pkg/common/readiness.go
+++ b/bridge/pkg/common/readiness.go
@@ -6,4 +6,5 @@ const (
 	ReadinessEthSyncing    readiness.Component = "ethSyncing"
 	ReadinessSolanaSyncing readiness.Component = "solanaSyncing"
 	ReadinessTerraSyncing  readiness.Component = "terraSyncing"
+	ReadinessBSCSyncing    readiness.Component = "bscSyncing"
 )
diff --git a/bridge/pkg/ethereum/watcher.go b/bridge/pkg/ethereum/watcher.go
index 73bcc4758..d9aa1145f 100644
--- a/bridge/pkg/ethereum/watcher.go
+++ b/bridge/pkg/ethereum/watcher.go
@@ -67,6 +67,8 @@ type (
 		bridge eth_common.Address
 		// Human-readable name of the Eth network, for logging and monitoring.
 		networkName string
+		// Readiness component
+		readiness readiness.Component
 		// VAA ChainID of the network we're connecting to.
 		chainID vaa.ChainID
 
@@ -98,6 +100,7 @@ func NewEthBridgeWatcher(
 	url string,
 	bridge eth_common.Address,
 	networkName string,
+	readiness readiness.Component,
 	chainID vaa.ChainID,
 	messageEvents chan *common.MessagePublication,
 	setEvents chan *common.GuardianSet) *EthBridgeWatcher {
@@ -105,6 +108,7 @@ func NewEthBridgeWatcher(
 		url:         url,
 		bridge:      bridge,
 		networkName: networkName,
+		readiness:   readiness,
 		chainID:     chainID,
 		msgChan:     messageEvents,
 		setChan:     setEvents,
@@ -278,7 +282,7 @@ func (e *EthBridgeWatcher) Run(ctx context.Context) error {
 				logger.Info("processing new header", zap.Stringer("block", ev.Number),
 					zap.String("eth_network", e.networkName))
 				currentEthHeight.WithLabelValues(e.networkName).Set(float64(ev.Number.Int64()))
-				readiness.SetReady(common.ReadinessEthSyncing)
+				readiness.SetReady(e.readiness)
 				p2p.DefaultRegistry.SetNetworkStats(e.chainID, &gossipv1.Heartbeat_Network{
 					Height:        ev.Number.Int64(),
 					BridgeAddress: e.bridge.Hex(),