poll: Change log message on incompatible peer

ElementsProject · Oct 15, 2022 · fd1b430 · fd1b430
1 parent c9fefe8
commit fd1b430
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/poll/service.go b/poll/service.go
@@ -193,7 +193,11 @@ func (s *Service) MessageHandler(peerId string, msgType string, payload []byte)
 				return nil
 			}
 		}
-		log.Debugf("Received poll from peer %s: %s", peerId, string(payload))
+		if msg.Version != swap.PEERSWAP_PROTOCOL_VERSION {
+			log.Debugf("Received poll from INCOMPATIBLE peer %s: %s", peerId, string(payload))
+		} else {
+			log.Debugf("Received poll from peer %s: %s", peerId, string(payload))
+		}
 		s.tmpStore[peerId] = string(payload)
 		return nil
 	case messages.MESSAGETYPE_REQUEST_POLL:
@@ -215,7 +219,11 @@ func (s *Service) MessageHandler(peerId string, msgType string, payload []byte)
 				return nil
 			}
 		}
-		log.Debugf("Received poll from peer %s: %s", peerId, string(payload))
+		if msg.Version != swap.PEERSWAP_PROTOCOL_VERSION {
+			log.Debugf("Received poll from INCOMPATIBLE peer %s: %s", peerId, string(payload))
+		} else {
+			log.Debugf("Received poll from peer %s: %s", peerId, string(payload))
+		}
 		s.tmpStore[peerId] = string(payload)
 		return nil
 	default: