zishuo/netmaker
1
0
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-05 08:47:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

commas, amiright?

Browse Source
This commit is contained in:
Christopher Blaha
2022-07-22 23:24:10 -04:00
parent cb8958e927
commit b5be396f87
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
netclient/functions/mqhandlers.go
View File

@@ -53,7 +53,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
return return
} }
insert(newNode.Network, lastNodeUpdate, string(data)) // store new message in cache insert(newNode.Network, lastNodeUpdate, string(data)) // store new message in cache
logger.Log(0,"Network: ", newNode.Network, "received message to update node "+newNode.Name) logger.Log(0, "Network: ", newNode.Network, "received message to update node "+newNode.Name)
// ensure that OS never changes // ensure that OS never changes
newNode.OS = runtime.GOOS newNode.OS = runtime.GOOS
@@ -98,7 +98,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
// Save new config // Save new config
nodeCfg.Node.Action = models.NODE_NOOP nodeCfg.Node.Action = models.NODE_NOOP
if err := config.Write(&nodeCfg, nodeCfg.Network); err != nil { if err := config.Write(&nodeCfg, nodeCfg.Network); err != nil {
logger.Log(0, nodeCfg.Node.Network "error updating node configuration: ", err.Error()) logger.Log(0, nodeCfg.Node.Network, " error updating node configuration: ", err.Error())
} }
nameserver := nodeCfg.Server.CoreDNSAddr nameserver := nodeCfg.Server.CoreDNSAddr
privateKey, err := wireguard.RetrievePrivKey(newNode.Network) privateKey, err := wireguard.RetrievePrivKey(newNode.Network)
@@ -115,7 +115,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
} }
err = ncutils.ModPort(&newNode) err = ncutils.ModPort(&newNode)
if err != nil { if err != nil {
logger.Log(0,"Network: ", nodeCfg.Node.Network, " error modifying node port on", newNode.Name, "-", err.Error()) logger.Log(0, "Network: ", nodeCfg.Node.Network, " error modifying node port on", newNode.Name, "-", err.Error())
return return
} }
informPortChange(&newNode) informPortChange(&newNode)
@@ -150,7 +150,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
if doneErr != nil { if doneErr != nil {
logger.Log(0, "Network: ", nodeCfg.Node.Network, " could not notify server to update peers after interface change") logger.Log(0, "Network: ", nodeCfg.Node.Network, " could not notify server to update peers after interface change")
} else { } else {
logger.Log(0,"Network: ", nodeCfg.Node.Network " signalled finished interface update to server") logger.Log(0, "Network: ", nodeCfg.Node.Network, " signalled finished interface update to server")
} }
} else if hubChange { } else if hubChange {
doneErr := publishSignal(&nodeCfg, ncutils.DONE) doneErr := publishSignal(&nodeCfg, ncutils.DONE)
@@ -162,7 +162,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
} }
//deal with DNS //deal with DNS
if newNode.DNSOn != "yes" && shouldDNSChange && nodeCfg.Node.Interface != "" { if newNode.DNSOn != "yes" && shouldDNSChange && nodeCfg.Node.Interface != "" {
logger.Log(0, "Network: ", nodeCfg.Node>network, " settng DNS off") logger.Log(0, "Network: ", nodeCfg.Node > network, " settng DNS off")
if err := removeHostDNS(nodeCfg.Node.Interface, ncutils.IsWindows()); err != nil { if err := removeHostDNS(nodeCfg.Node.Interface, ncutils.IsWindows()); err != nil {
logger.Log(0, "Network: ", nodeCfg.Node.Network, " error removing netmaker profile from /etc/hosts "+err.Error()) logger.Log(0, "Network: ", nodeCfg.Node.Network, " error removing netmaker profile from /etc/hosts "+err.Error())
} }