From ba84cd7384229d5e6398bcea96aad6d8902d3688 Mon Sep 17 00:00:00 2001 From: Techno Freak Date: Tue, 18 Jul 2023 16:19:23 +0300 Subject: [PATCH] feat: log node connects --- pkg/tendermint/ws/websocket_client.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/tendermint/ws/websocket_client.go b/pkg/tendermint/ws/websocket_client.go index f31a6c7..9a3f9d9 100644 --- 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()