From c9a0b0a691645b604d964f9d3acf70f2c4e283e5 Mon Sep 17 00:00:00 2001
From: bruce-riley <96066700+bruce-riley@users.noreply.github.com>
Date: Fri, 17 Nov 2023 10:59:06 -0600
Subject: [PATCH] CCQ/Node: P2P message filter is wrong (#3547)

---
 node/pkg/p2p/ccq_p2p.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/node/pkg/p2p/ccq_p2p.go b/node/pkg/p2p/ccq_p2p.go
index d4706a420..7e94849e3 100644
--- a/node/pkg/p2p/ccq_p2p.go
+++ b/node/pkg/p2p/ccq_p2p.go
@@ -137,10 +137,10 @@ func (ccq *ccqP2p) run(
 		if len(ccq.allowedPeers) == 0 {
 			return true
 		}
-		if _, found := ccq.allowedPeers[from.String()]; found {
+		if _, found := ccq.allowedPeers[msg.GetFrom().String()]; found {
 			return true
 		}
-		ccq.logger.Info("Dropping message from unknown peer", zap.String("fromPeerID", from.String()))
+		ccq.logger.Info("Dropping message from unknown peer", zap.String("fromPeerID", from.String()), zap.String("msgPeerID", msg.ReceivedFrom.String()), zap.String("msgFrom", msg.GetFrom().String()))
 		return false
 	})
 	if err != nil {