From 42b61a166b313a73d53e1371e14508e369b4f9b9 Mon Sep 17 00:00:00 2001
From: "Matthew R. Kasun" <mkasun@nusak.ca>
Date: Wed, 13 Jul 2022 14:07:10 -0400
Subject: [PATCH] debugging logs

---
 netclient/functions/daemon.go    | 14 ++++++++++++--
 netclient/functions/mqpublish.go |  1 +
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/netclient/functions/daemon.go b/netclient/functions/daemon.go
index ba19dde4..3dedc8c5 100644
--- a/netclient/functions/daemon.go
+++ b/netclient/functions/daemon.go
@@ -26,6 +26,7 @@ import (
 	"github.com/gravitl/netmaker/netclient/ncutils"
 	"github.com/gravitl/netmaker/netclient/wireguard"
 	ssl "github.com/gravitl/netmaker/tls"
+	"github.com/kr/pretty"
 	"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
 )
 
@@ -43,6 +44,7 @@ type cachedMessage struct {
 
 // Daemon runs netclient daemon from command line
 func Daemon() error {
+	logger.Log(0, "netclient daemon started -- version:", ncutils.Version)
 	UpdateClientConfig()
 	if err := ncutils.SavePID(); err != nil {
 		return err
@@ -97,6 +99,14 @@ func startGoRoutines(wg *sync.WaitGroup) context.CancelFunc {
 			logger.Log(0, "failed to start ", cfg.Node.Interface, "wg interface", err.Error())
 		}
 		server := cfg.Server.Server
+		pretty.Println(serverSet, server, serverSet[server], !serverSet[server])
+
+		if val, ok := serverSet[server]; ok {
+			pretty.Println(val, ok)
+		} else {
+			pretty.Println("not ok", val, ok)
+		}
+
 		if !serverSet[server] {
 			// == subscribe to all nodes for each on machine ==
 			serverSet[server] = true
@@ -182,7 +192,7 @@ func unsubscribeNode(client mqtt.Client, nodeCfg *config.ClientConfig) {
 // the client should subscribe to ALL nodes that exist on server locally
 func messageQueue(ctx context.Context, wg *sync.WaitGroup, cfg *config.ClientConfig) {
 	defer wg.Done()
-	logger.Log(0, "netclient daemon started for server: ", cfg.Server.Server)
+	logger.Log(0, "netclient message queue started for server: ", cfg.Server.Server)
 	client, err := setupMQTT(cfg, false)
 	if err != nil {
 		logger.Log(0, "unable to connect to broker", cfg.Server.Server, err.Error())
@@ -190,7 +200,7 @@ func messageQueue(ctx context.Context, wg *sync.WaitGroup, cfg *config.ClientCon
 	}
 	defer client.Disconnect(250)
 	<-ctx.Done()
-	logger.Log(0, "shutting down daemon for server ", cfg.Server.Server)
+	logger.Log(0, "shutting down message queue for server ", cfg.Server.Server)
 }
 
 // NewTLSConf sets up tls configuration to connect to broker securely
diff --git a/netclient/functions/mqpublish.go b/netclient/functions/mqpublish.go
index 9b49de2b..64ac0de1 100644
--- a/netclient/functions/mqpublish.go
+++ b/netclient/functions/mqpublish.go
@@ -25,6 +25,7 @@ var pubNetworks []string
 // Checkin  -- go routine that checks for public or local ip changes, publishes changes
 //   if there are no updates, simply "pings" the server as a checkin
 func Checkin(ctx context.Context, wg *sync.WaitGroup) {
+	logger.Log(2, "starting checkin goroutine")
 	defer wg.Done()
 	for {
 		select {