From d56bdc1ca19ec6d67d25cb1f9b3ec44ef8f9a66b Mon Sep 17 00:00:00 2001 From: 0xdcarns Date: Sun, 30 Jan 2022 20:52:56 -0500 Subject: [PATCH] peers try 2 --- mq/mq.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/mq/mq.go b/mq/mq.go index e93b516f..bce9d834 100644 --- a/mq/mq.go +++ b/mq/mq.go @@ -85,15 +85,12 @@ var UpdateNode mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) logger.Log(1, "error unmarshaling payload ", err.Error()) return } - var shouldUpdatePeers = logic.IfaceDelta(¤tNode, &newNode) if err := logic.UpdateNode(¤tNode, &newNode); err != nil { logger.Log(1, "error saving node", err.Error()) } - if shouldUpdatePeers { - if err := PublishPeerUpdate(&newNode); err != nil { - logger.Log(1, "error publishing peer update ", err.Error()) - return - } + if err := PublishPeerUpdate(&newNode); err != nil { + logger.Log(1, "error publishing peer update ", err.Error()) + return } logger.Log(1, "no need to update peers") }()