gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-09-13 08:34:44 +08:00
Code Issues Projects Releases Packages Wiki Activity

dont publish to updated node

Browse source
This commit is contained in:
afeiszli 2022-01-31 16:15:10 -05:00
parent 3964d927ea
commit 6f9f97e4b7
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
mq/mq.go
View file

@ -106,7 +106,7 @@ func PublishPeerUpdate(newNode *models.Node) error {
}
for _, node := range networkNodes {
if node.IsServer == "yes" {
if node.IsServer == "yes" || node.ID == newNode.ID {
continue
}
peerUpdate, err := logic.GetPeerUpdate(&node)

11
netclient/functions/daemon.go
View file

@ -228,6 +228,12 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
ncutils.Log("error restarting wg after node update " + err.Error())
return
}
log.Println("DELETE: sleeepy time")
log.Println("DELETE: sleeepy time")
log.Println("DELETE: sleeepy time")
log.Println("DELETE: sleeepy time")
time.Sleep(time.Second * 5)
if err = Resubscribe(client, &cfg); err != nil {
ncutils.Log("error resubscribing after interface change " + err.Error())
return
@ -284,11 +290,6 @@ func UpdatePeers(client mqtt.Client, msg mqtt.Message) {
ncutils.Log("update peer handler")
file := ncutils.GetNetclientPathSpecific() + cfg.Node.Interface + ".conf"
var shouldReSub = shouldResub(cfg.Node.NetworkSettings.DefaultServerAddrs, peerUpdate.ServerAddrs)
if shouldReSub {
Resubscribe(client, &cfg)
cfg.Node.NetworkSettings.DefaultServerAddrs = peerUpdate.ServerAddrs
}
err = wireguard.UpdateWgPeers(file, peerUpdate.Peers)
if err != nil {
ncutils.Log("error updating wireguard peers" + err.Error())