Explorar o código

moved checks around

Matthew R. Kasun %!s(int64=3) %!d(string=hai) anos
pai
achega
20e1156936
Modificáronse 2 ficheiros con 9 adicións e 12 borrados
  1. 8 5
      netclient/functions/mqhandlers.go
  2. 1 7
      netclient/functions/pull.go

+ 8 - 5
netclient/functions/mqhandlers.go

@@ -106,7 +106,6 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
 	file := ncutils.GetNetclientPathSpecific() + nodeCfg.Node.Interface + ".conf"
 
 	if ifaceDelta { // if a change caused an ifacedelta we need to notify the server to update the peers
-<<<<<<< HEAD
 		if newNode.ListenPort != nodeCfg.Node.LocalListenPort {
 			if err := wireguard.RemoveConf(newNode.Interface, false); err != nil {
 				logger.Log(0, "error remove interface", newNode.Interface, err.Error())
@@ -125,13 +124,17 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
 		if keepaliveChange {
 			wireguard.UpdateKeepAlive(file, newNode.PersistentKeepalive)
 		}
-=======
-		err = ncutils.ModPort(&nodeCfg.Node)
 		if err != nil {
-			logger.Log(0, "error modifying node port on", nodeCfg.Node.Name, "-", err.Error())
+			logger.Log(0, "error modifying node port on", newNode.Name, "-", err.Error())
 			return
 		}
->>>>>>> b1b376b0 (moving port check logic)
+		if err := wireguard.UpdateWgInterface(file, privateKey, nameserver, newNode); err != nil {
+			logger.Log(0, "error updating wireguard config "+err.Error())
+			return
+		}
+		if keepaliveChange {
+			wireguard.UpdateKeepAlive(file, newNode.PersistentKeepalive)
+		}
 		logger.Log(0, "applying WG conf to "+file)
 		if ncutils.IsWindows() {
 			wireguard.RemoveConfGraceful(nodeCfg.Node.Interface)

+ 1 - 7
netclient/functions/pull.go

@@ -63,7 +63,6 @@ func Pull(network string, iface bool) (*models.Node, error) {
 			logger.Log(0, "unable to update server config: "+err.Error())
 		}
 	}
-<<<<<<< HEAD
 	if nodeGET.Node.ListenPort != cfg.Node.LocalListenPort {
 		if err := wireguard.RemoveConf(resNode.Interface, false); err != nil {
 			logger.Log(0, "error remove interface", resNode.Interface, err.Error())
@@ -73,12 +72,7 @@ func Pull(network string, iface bool) (*models.Node, error) {
 			return nil, err
 		}
 		informPortChange(&resNode)
-=======
-	err = ncutils.ModPort(&resNode)
-	logger.Log(0, "port is now", strconv.Itoa(int(resNode.ListenPort)))
-	if err != nil {
-		return nil, err
->>>>>>> b1b376b0 (moving port check logic)
+		logger.Log(0, "port is now", strconv.Itoa(int(resNode.ListenPort)))
 	}
 	if err = config.ModNodeConfig(&resNode); err != nil {
 		return nil, err