set peer update for disconnected Node

gravitl · Nov 13, 2023 · e30b765 · e30b765
1 parent 595ed5a
commit e30b765
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/mq/handlers.go b/mq/handlers.go
@@ -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 !newNode.Connected {
 			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 {
 			err = PublishPeerUpdate()
 		}