|
@@ -62,6 +62,15 @@ func UpdateNode(client mqtt.Client, msg mqtt.Message) {
|
|
if ifaceDelta { // reduce number of unneeded updates, by only sending on iface changes
|
|
if ifaceDelta { // reduce number of unneeded updates, by only sending on iface changes
|
|
if !newNode.Connected {
|
|
if !newNode.Connected {
|
|
err = PublishDeletedNodePeerUpdate(&newNode)
|
|
err = PublishDeletedNodePeerUpdate(&newNode)
|
|
|
|
+ host, err := logic.GetHost(newNode.HostID.String())
|
|
|
|
+ if err != nil {
|
|
|
|
+ slog.Error("failed to get host for the node", "nodeid", newNode.ID.String(), "error", err)
|
|
|
|
+ return
|
|
|
|
+ }
|
|
|
|
+ allNodes, err := logic.GetAllNodes()
|
|
|
|
+ if err == nil {
|
|
|
|
+ PublishSingleHostPeerUpdate(host, allNodes, nil, nil)
|
|
|
|
+ }
|
|
} else {
|
|
} else {
|
|
err = PublishPeerUpdate()
|
|
err = PublishPeerUpdate()
|
|
}
|
|
}
|