From b91c90b10659edc60734c3eebfd669ff95be48cf Mon Sep 17 00:00:00 2001 From: 0xdcarns Date: Sun, 30 Jan 2022 19:58:20 -0500 Subject: [PATCH] changing peer set --- controllers/node.go | 2 +- mq/mq.go | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/controllers/node.go b/controllers/node.go index d92a08c4..38a43dfc 100644 --- a/controllers/node.go +++ b/controllers/node.go @@ -616,7 +616,7 @@ func updateNode(w http.ResponseWriter, r *http.Request) { if err := mq.NodeUpdate(&newNode); err != nil { logger.Log(1, "error publishing node update", err.Error()) } - if logic.ShouldPeersUpdate(&node, &newNode) { + if shouldPeersUpdate { if err := mq.PublishPeerUpdate(&newNode); err != nil { logger.Log(1, "error publishing peer update after node update", err.Error()) } diff --git a/mq/mq.go b/mq/mq.go index 9543e909..e6e20b6b 100644 --- a/mq/mq.go +++ b/mq/mq.go @@ -111,14 +111,15 @@ func PublishPeerUpdate(newNode *models.Node) error { return err } for _, node := range networkNodes { + + if node.IsServer == "yes" { + continue + } peerUpdate, err := logic.GetPeerUpdate(&node) if err != nil { logger.Log(1, "error getting peer update for node", node.ID, err.Error()) continue } - if node.IsServer == "yes" { - continue - } data, err := json.Marshal(&peerUpdate) if err != nil { logger.Log(2, "error marshaling peer update for node", node.ID, err.Error())