Browse Source

unsubscribe from node topic on node delete

Matthew R Kasun 3 years ago
parent
commit
8aee75d32b
1 changed files with 3 additions and 0 deletions
  1. 3 0
      netclient/functions/daemon.go

+ 3 - 0
netclient/functions/daemon.go

@@ -119,6 +119,9 @@ var NodeUpdate mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message)
 				ncutils.PrintLog("error deleting local instance: "+err.Error(), 1)
 				ncutils.PrintLog("error deleting local instance: "+err.Error(), 1)
 				return
 				return
 			}
 			}
+			if token := client.Unsubscribe("update/"+newNode.ID, "update/peers/"+newNode.ID); token.Wait() && token.Error() != nil {
+				ncutils.PrintLog("error unsubscribing during node deletion", 1)
+			}
 			return
 			return
 		case models.NODE_UPDATE_KEY:
 		case models.NODE_UPDATE_KEY:
 			if err := UpdateKeys(&cfg, client); err != nil {
 			if err := UpdateKeys(&cfg, client); err != nil {