mirror of
https://github.com/gravitl/netmaker.git
synced 2025-10-05 08:47:35 +08:00
refactored clients
This commit is contained in:
@@ -629,13 +629,14 @@ func runUpdates(node *models.Node, ifaceDelta bool) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Log(3, "error occurred on timer,", err.Error())
|
logger.Log(3, "error occurred on timer,", err.Error())
|
||||||
}
|
}
|
||||||
if err := runServerUpdate(node, ifaceDelta); err != nil {
|
|
||||||
logger.Log(1, "error running server update", err.Error())
|
|
||||||
}
|
|
||||||
// publish node update if not server
|
// publish node update if not server
|
||||||
if err := mq.NodeUpdate(node); err != nil {
|
if err := mq.NodeUpdate(node); err != nil {
|
||||||
logger.Log(1, "error publishing node update to node", node.Name, node.ID, err.Error())
|
logger.Log(1, "error publishing node update to node", node.Name, node.ID, err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := runServerUpdate(node, ifaceDelta); err != nil {
|
||||||
|
logger.Log(1, "error running server update", err.Error())
|
||||||
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -648,8 +649,8 @@ func runServerUpdate(node *models.Node, ifaceDelta bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !isServer(node) && ifaceDelta {
|
if !isServer(node) {
|
||||||
ifaceDelta = false
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
currentServerNode, err := logic.GetNetworkServerLocal(node.Network)
|
currentServerNode, err := logic.GetNetworkServerLocal(node.Network)
|
||||||
|
@@ -199,6 +199,12 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
if ifaceDelta { // if a change caused an ifacedelta we need to notify the server to update the peers
|
if ifaceDelta { // if a change caused an ifacedelta we need to notify the server to update the peers
|
||||||
|
pubErr := publishClientPeers(&cfg)
|
||||||
|
if pubErr != nil {
|
||||||
|
ncutils.Log("could not notify server to update peers after interface change")
|
||||||
|
} else {
|
||||||
|
ncutils.Log("signalled peer update to server")
|
||||||
|
}
|
||||||
ncutils.Log("applying WG conf to " + file)
|
ncutils.Log("applying WG conf to " + file)
|
||||||
err = wireguard.ApplyConf(&cfg.Node, cfg.Node.Interface, file)
|
err = wireguard.ApplyConf(&cfg.Node, cfg.Node.Interface, file)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -215,12 +221,6 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
pubErr := publishClientPeers(&cfg)
|
|
||||||
if pubErr != nil {
|
|
||||||
ncutils.Log("could not notify server to update peers after interface change")
|
|
||||||
} else {
|
|
||||||
ncutils.Log("signalled peer update to server")
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
//deal with DNS
|
//deal with DNS
|
||||||
if newNode.DNSOn != "yes" && shouldDNSChange && cfg.Node.Interface != "" {
|
if newNode.DNSOn != "yes" && shouldDNSChange && cfg.Node.Interface != "" {
|
||||||
|
@@ -131,10 +131,6 @@ func InitWireguard(node *models.Node, privkey string, peers []wgtypes.PeerConfig
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
nodecfg := modcfg.Node
|
nodecfg := modcfg.Node
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
log.Fatalf("failed to open client: %v", err)
|
|
||||||
}
|
|
||||||
var ifacename string
|
var ifacename string
|
||||||
if nodecfg.Interface != "" {
|
if nodecfg.Interface != "" {
|
||||||
ifacename = nodecfg.Interface
|
ifacename = nodecfg.Interface
|
||||||
|
Reference in New Issue
Block a user