From e8bbd8790e9ac61d3418e14ee1a62381ae366a3c Mon Sep 17 00:00:00 2001
From: Matthew R Kasun <mkasun@nusak.ca>
Date: Sun, 30 Jan 2022 18:38:15 -0500
Subject: [PATCH] add serverkeepalive to Resubcribe

---
 netclient/functions/daemon.go | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/netclient/functions/daemon.go b/netclient/functions/daemon.go
index 9f208bd1..27a19aad 100644
--- a/netclient/functions/daemon.go
+++ b/netclient/functions/daemon.go
@@ -328,6 +328,22 @@ func Resubscribe(client mqtt.Client, cfg *config.ClientConfig) error {
 		if token := client.Subscribe("update/peers/"+cfg.Node.ID, 0, UpdatePeers); token.Wait() && token.Error() != nil {
 			log.Fatal(token.Error())
 		}
+		var id string
+		for _, server := range cfg.NetworkSettings.DefaultServerAddrs {
+			if server.IsLeader {
+				id = server.ID
+			}
+			if server.Address != "" {
+				if token := client.Subscribe("serverkeepalive/"+id, 0, mqtt.MessageHandler(ServerKeepAlive)); token.Wait() && token.Error() != nil {
+					log.Fatal(token.Error())
+				}
+				if cfg.DebugOn {
+					ncutils.Log("subscribed to server keepalives for server " + id)
+				}
+			} else {
+				ncutils.Log("leader not defined for network" + cfg.Network)
+			}
+		}
 		ncutils.Log("finished re subbing")
 		return nil
 	} else {