move DNSSync to peerUpdate

mq/mq.go

@@ -131,9 +131,6 @@ func Keepalive(ctx context.Context) {
 		case <-ctx.Done():
 			return
 		case <-time.After(time.Second * KEEPALIVE_TIMEOUT):
-			if servercfg.GetManageDNS() {
-				sendDNSSync()
-			}
 			sendPeers()
 		}
 	}

mq/publishers.go

@@ -16,7 +16,6 @@ import (
 
 var batchSize = servercfg.GetPeerUpdateBatchSize()
 var batchUpdate = servercfg.GetBatchPeerUpdate()
-var manageDNSCache = map[string]int{}
 
 // PublishPeerUpdate --- determines and publishes a peer update to all the hosts
 func PublishPeerUpdate(replacePeers bool) error {
@@ -24,6 +23,10 @@ func PublishPeerUpdate(replacePeers bool) error {
 		return nil
 	}
 
+	if servercfg.GetManageDNS() {
+		sendDNSSync()
+	}
+
 	hosts, err := logic.GetAllHosts()
 	if err != nil {
 		logger.Log(1, "err getting all hosts", err.Error())
@@ -258,13 +261,10 @@ func sendDNSSync() error {
 		for _, v := range networks {
 			k, err := logic.GetDNS(v.NetID)
 			if err == nil && len(k) > 0 {
-				if manageDNSCache[v.NetID] != len(k) {
-					err = PushSyncDNS(k)
-					if err != nil {
-						slog.Warn("error publishing dns entry data for network ", v.NetID, err.Error())
-						continue
-					}
-					manageDNSCache[v.NetID] = len(k)
+				err = PushSyncDNS(k)
+				if err != nil {
+					slog.Warn("error publishing dns entry data for network ", v.NetID, err.Error())
+					continue
 				}
 				continue
 			}