feat: log node connects

QuokkaStake · Sep 21, 2023 · 0462416 · 0462416
1 parent 0664e08
commit 0462416
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/tendermint/ws/websocket_client.go b/pkg/tendermint/ws/websocket_client.go
@@ -90,7 +90,7 @@ func (t *TendermintWebsocketClient) Listen() {
 		t.Logger.Error().Err(err).Msg("Failed to create a client")
 		t.Error = err
 		t.Channel <- t.MakeReport(&types.NodeConnectError{Error: err, URL: t.URL, Chain: t.Chain.GetName()})
-		t.MetricsManager.LogNodeReconnect(t.Chain.Name, t.URL)
+		t.MetricsManager.LogNodeConnection(t.Chain.Name, t.URL, false)
 		return
 	}
 
@@ -108,9 +108,11 @@ func (t *TendermintWebsocketClient) Listen() {
 		t.Error = err
 		t.Channel <- t.MakeReport(&types.NodeConnectError{Error: err, URL: t.URL, Chain: t.Chain.GetName()})
 		t.Logger.Warn().Err(err).Msg("Error connecting to node")
+		t.MetricsManager.LogNodeConnection(t.Chain.Name, t.URL, false)
 	} else {
 		t.Logger.Debug().Msg("Connected to a node")
 		t.Active = true
+		t.MetricsManager.LogNodeConnection(t.Chain.Name, t.URL, true)
 	}
 
 	t.SubscribeToUpdates()