publish deleted node update on disconnect

gravitl · Nov 11, 2023 · 6c15fd6 · 6c15fd6
1 parent 83e83f8
commit 6c15fd6
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/mq/handlers.go b/mq/handlers.go
@@ -60,7 +60,12 @@ func UpdateNode(client mqtt.Client, msg mqtt.Message) {
 		return
 	}
 	if ifaceDelta { // reduce number of unneeded updates, by only sending on iface changes
-		if err = PublishPeerUpdate(); err != nil {
+		if !newNode.Connected {
+			err = PublishDeletedNodePeerUpdate(&newNode)
+		} else {
+			err = PublishPeerUpdate()
+		}
+		if err != nil {
 			slog.Warn("error updating peers when node informed the server of an interface change", "nodeid", currentNode.ID, "error", err)
 		}
 	}