add debug trace

controllers/hosts.go

@@ -391,6 +391,9 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 	switch hostUpdate.Action {
 	case models.CheckIn:
 		sendPeerUpdate = mq.HandleHostCheckin(&hostUpdate.Host, currentHost)
+		if sendPeerUpdate {
+			fmt.Println("====> hostUpdateFallback", hostUpdate.Action, hostUpdate.Host.Name)
+		}
 		changed := logic.CheckHostPorts(currentHost)
 		if changed {
 			mq.HostUpdate(&models.HostUpdate{Action: models.UpdateHost, Host: *currentHost})
@@ -401,6 +404,9 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 			replacePeers = true
 		}
 		sendPeerUpdate = logic.UpdateHostFromClient(&hostUpdate.Host, currentHost)
+		if sendPeerUpdate {
+			fmt.Println("====> hostUpdateFallback", hostUpdate.Action, hostUpdate.Host.Name)
+		}
 		err := logic.UpsertHost(currentHost)
 		if err != nil {
 			slog.Error("failed to update host", "id", currentHost.ID, "error", err)
@@ -409,6 +415,9 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 		}
 	case models.UpdateNode:
 		sendDeletedNodeUpdate, sendPeerUpdate = logic.UpdateHostNode(&hostUpdate.Host, &hostUpdate.Node)
+		if sendPeerUpdate {
+			fmt.Println("====> hostUpdateFallback", hostUpdate.Action, hostUpdate.Host.Name)
+		}
 	case models.UpdateMetrics:
 		mq.UpdateMetricsFallBack(hostUpdate.Node.ID.String(), hostUpdate.NewMetrics)
 	case models.EgressUpdate:
@@ -423,6 +432,9 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 			e.Update(db.WithContext(r.Context()))
 		}
 		sendPeerUpdate = true
+		if sendPeerUpdate {
+			fmt.Println("====> hostUpdateFallback", hostUpdate.Action, hostUpdate.Host.Name)
+		}
 	case models.SignalHost:
 		mq.SignalPeer(hostUpdate.Signal)
 	case models.DeleteHost:
@@ -433,6 +445,7 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 			mq.PublishDeletedNodePeerUpdate(&hostUpdate.Node)
 		}
 		if sendPeerUpdate {
+			fmt.Println("======> Sending Peer update: hostUpdateFallback")
 			err := mq.PublishPeerUpdate(replacePeers)
 			if err != nil {
 				slog.Error("failed to publish peer update", "error", err)

mq/publishers.go

@@ -12,11 +12,13 @@ import (
 	"github.com/gravitl/netmaker/logic"
 	"github.com/gravitl/netmaker/models"
 	"github.com/gravitl/netmaker/servercfg"
+	"github.com/gravitl/netmaker/utils"
 	"golang.org/x/exp/slog"
 )
 
 // PublishPeerUpdate --- determines and publishes a peer update to all the hosts
 func PublishPeerUpdate(replacePeers bool) error {
+	utils.TraceCaller()
 	if !servercfg.IsMessageQueueBackend() {
 		return nil
 	}
@@ -55,6 +57,7 @@ func PublishPeerUpdate(replacePeers bool) error {
 // PublishDeletedNodePeerUpdate --- determines and publishes a peer update
 // to all the hosts with a deleted node to account for
 func PublishDeletedNodePeerUpdate(delNode *models.Node) error {
+	utils.TraceCaller()
 	if !servercfg.IsMessageQueueBackend() {
 		return nil
 	}

mq/util.go

@@ -134,7 +134,6 @@ func encryptMsg(host *models.Host, msg []byte) ([]byte, error) {
 }
 
 func publish(host *models.Host, dest string, msg []byte) error {
-
 	var encrypted []byte
 	var encryptErr error
 	vlt, err := logic.VersionLessThan(host.Version, "v0.30.0")

utils/utils.go

@@ -67,8 +67,8 @@ func TraceCaller() {
 	funcName := runtime.FuncForPC(pc).Name()
 
 	// Print trace details
-	slog.Debug("## TRACE -> Called from function: ", "tracing-func-name", traceFuncName, "caller-func-name", funcName)
-	slog.Debug("## TRACE -> Caller File Info", "file", file, "line-no", line)
+	fmt.Println("## TRACE -> Called from function: ", "tracing-func-name", traceFuncName, "caller-func-name", funcName)
+	fmt.Println("## TRACE -> Caller File Info", "file", file, "line-no", line)
 }
 
 // NoEmptyStringToCsv takes a bunch of strings, filters out empty ones and returns a csv version of the string