From 218ea1b5a9d23aaf1df764a9a35a2ff708bf7eb2 Mon Sep 17 00:00:00 2001
From: Kunal Gupta <39487888+iamKunalGupta@users.noreply.github.com>
Date: Fri, 26 Apr 2024 02:19:56 +0530
Subject: [PATCH] feat: add error for peer invalidation

---
 flow/cmd/validate_peer.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/flow/cmd/validate_peer.go b/flow/cmd/validate_peer.go
index e83fbf305f..647c86c07a 100644
--- 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
 	}