Browse Source

write node to database when localAddress update received.

Matthew R Kasun 3 years ago
parent
commit
b28e1de50f
1 changed files with 3 additions and 0 deletions
  1. 3 0
      mq/mq.go

+ 3 - 0
mq/mq.go

@@ -266,6 +266,9 @@ var LocalAddressUpdate mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.M
 		}
 		}
 		node.LocalAddress = string(msg.Payload())
 		node.LocalAddress = string(msg.Payload())
 		node.SetLastCheckIn()
 		node.SetLastCheckIn()
+		if err := logic.UpdateNode(&node, &node); err != nil {
+			logger.Log(0, "error updating node "+err.Error())
+		}
 		if err := UpdatePeers(client, node); err != nil {
 		if err := UpdatePeers(client, node); err != nil {
 			logger.Log(0, "error updating peers "+err.Error())
 			logger.Log(0, "error updating peers "+err.Error())
 		}
 		}