Browse Source

changing peer set

0xdcarns 3 years ago
parent
commit
b91c90b106
2 changed files with 5 additions and 4 deletions
  1. 1 1
      controllers/node.go
  2. 4 3
      mq/mq.go

+ 1 - 1
controllers/node.go

@@ -616,7 +616,7 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
 		if err := mq.NodeUpdate(&newNode); err != nil {
 		if err := mq.NodeUpdate(&newNode); err != nil {
 			logger.Log(1, "error publishing node update", err.Error())
 			logger.Log(1, "error publishing node update", err.Error())
 		}
 		}
-		if logic.ShouldPeersUpdate(&node, &newNode) {
+		if shouldPeersUpdate {
 			if err := mq.PublishPeerUpdate(&newNode); err != nil {
 			if err := mq.PublishPeerUpdate(&newNode); err != nil {
 				logger.Log(1, "error publishing peer update after node update", err.Error())
 				logger.Log(1, "error publishing peer update after node update", err.Error())
 			}
 			}

+ 4 - 3
mq/mq.go

@@ -111,14 +111,15 @@ func PublishPeerUpdate(newNode *models.Node) error {
 		return err
 		return err
 	}
 	}
 	for _, node := range networkNodes {
 	for _, node := range networkNodes {
+
+		if node.IsServer == "yes" {
+			continue
+		}
 		peerUpdate, err := logic.GetPeerUpdate(&node)
 		peerUpdate, err := logic.GetPeerUpdate(&node)
 		if err != nil {
 		if err != nil {
 			logger.Log(1, "error getting peer update for node", node.ID, err.Error())
 			logger.Log(1, "error getting peer update for node", node.ID, err.Error())
 			continue
 			continue
 		}
 		}
-		if node.IsServer == "yes" {
-			continue
-		}
 		data, err := json.Marshal(&peerUpdate)
 		data, err := json.Marshal(&peerUpdate)
 		if err != nil {
 		if err != nil {
 			logger.Log(2, "error marshaling peer update for node", node.ID, err.Error())
 			logger.Log(2, "error marshaling peer update for node", node.ID, err.Error())