mirror of
https://github.com/gravitl/netmaker.git
synced 2025-02-26 17:15:23 +08:00
sync conf
This commit is contained in:
parent
feb34722c2
commit
3aaf83d04d
2 changed files with 9 additions and 3 deletions
|
@ -5,6 +5,7 @@ import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
|
|
||||||
nodepb "github.com/gravitl/netmaker/grpc"
|
nodepb "github.com/gravitl/netmaker/grpc"
|
||||||
"github.com/gravitl/netmaker/logger"
|
"github.com/gravitl/netmaker/logger"
|
||||||
|
@ -98,6 +99,11 @@ func (s *NodeServiceServer) CreateNode(ctx context.Context, req *nodepb.Object)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
network.NodesLastModified = time.Now().Unix()
|
||||||
|
network.DefaultServerAddrs = node.NetworkSettings.DefaultServerAddrs
|
||||||
|
if err := logic.SaveNetwork(&network); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
err = runServerPeerUpdate(node.Network, isServer(&node), "node_grpc create")
|
err = runServerPeerUpdate(node.Network, isServer(&node), "node_grpc create")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Log(1, "internal error when setting peers after node,", node.ID, "was created (gRPC)")
|
logger.Log(1, "internal error when setting peers after node,", node.ID, "was created (gRPC)")
|
||||||
|
|
|
@ -285,10 +285,10 @@ func UpdatePeers(client mqtt.Client, msg mqtt.Message) {
|
||||||
ncutils.Log("error updating wireguard peers" + err.Error())
|
ncutils.Log("error updating wireguard peers" + err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
ncutils.Log("applyWGQuickConf to " + file)
|
ncutils.Log("syncing conf to " + file)
|
||||||
err = wireguard.ApplyWGQuickConf(file)
|
err = wireguard.SyncWGQuickConf(cfg.Node.Interface, file)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ncutils.Log("error restarting wg after peer update " + err.Error())
|
ncutils.Log("error syncing wg after peer update " + err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue