feat: add error for peer invalidation

PeerDB-io · Apr 25, 2024 · 218ea1b · 218ea1b
1 parent ce5ace7
commit 218ea1b
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/flow/cmd/validate_peer.go b/flow/cmd/validate_peer.go
@@ -32,10 +32,11 @@ func (h *FlowRequestHandler) ValidatePeer(
 
 	conn, err := connectors.GetConnector(ctx, req.Peer)
 	if err != nil {
+		displayErr := fmt.Sprintf("%s peer %s was invalidated: %v", req.Peer.Type, req.Peer.Name, err)
+		h.alerter.LogNonFlowWarning(ctx, telemetry.CreatePeer, req.Peer.Name, displayErr)
 		return &protos.ValidatePeerResponse{
-			Status: protos.ValidatePeerStatus_INVALID,
-			Message: fmt.Sprintf("%s peer %s was invalidated: %s",
-				req.Peer.Type, req.Peer.Name, err),
+			Status:  protos.ValidatePeerStatus_INVALID,
+			Message: displayErr,
 		}, nil
 	}