Browse Source

Merge pull request #1886 from gravitl/netclient_refactor_fixes

Netclient refactor fixes
dcarns 2 years ago
parent
commit
f382fd3bf9
3 changed files with 10 additions and 3 deletions
  1. 7 0
      controllers/node.go
  2. 1 1
      logic/nodes.go
  3. 2 2
      models/api_node.go

+ 7 - 0
controllers/node.go

@@ -1089,7 +1089,14 @@ func deleteNode(w http.ResponseWriter, r *http.Request) {
 	logger.Log(1, r.Header.Get("user"), "Deleted node", nodeid, "from network", params["network"])
 	logger.Log(1, r.Header.Get("user"), "Deleted node", nodeid, "from network", params["network"])
 	if !fromNode {
 	if !fromNode {
 		runUpdates(&node, false)
 		runUpdates(&node, false)
+		return
 	}
 	}
+	go func() {
+		if err := mq.PublishPeerUpdate(node.Network, false); err != nil {
+			logger.Log(1, "error publishing peer update ", err.Error())
+			return
+		}
+	}()
 
 
 }
 }
 
 

+ 1 - 1
logic/nodes.go

@@ -243,7 +243,7 @@ func SetNodeDefaults(node *models.Node) {
 	}
 	}
 
 
 	if node.PersistentKeepalive == 0 {
 	if node.PersistentKeepalive == 0 {
-		node.PersistentKeepalive = time.Duration(parentNetwork.DefaultKeepalive)
+		node.PersistentKeepalive = time.Second * time.Duration(parentNetwork.DefaultKeepalive)
 	}
 	}
 	if node.PostUp == "" {
 	if node.PostUp == "" {
 		postup := parentNetwork.DefaultPostUp
 		postup := parentNetwork.DefaultPostUp

+ 2 - 2
models/api_node.go

@@ -69,7 +69,7 @@ func (a *ApiNode) ConvertToServerNode(currentNode *Node) *Node {
 	convertedNode.DNSOn = a.DNSOn
 	convertedNode.DNSOn = a.DNSOn
 	convertedNode.EgressGatewayRequest = currentNode.EgressGatewayRequest
 	convertedNode.EgressGatewayRequest = currentNode.EgressGatewayRequest
 	convertedNode.EgressGatewayNatEnabled = currentNode.EgressGatewayNatEnabled
 	convertedNode.EgressGatewayNatEnabled = currentNode.EgressGatewayNatEnabled
-	convertedNode.PersistentKeepalive = time.Duration(a.PersistentKeepalive)
+	convertedNode.PersistentKeepalive = time.Second * time.Duration(a.PersistentKeepalive)
 	convertedNode.RelayAddrs = a.RelayAddrs
 	convertedNode.RelayAddrs = a.RelayAddrs
 	convertedNode.DefaultACL = a.DefaultACL
 	convertedNode.DefaultACL = a.DefaultACL
 	convertedNode.OwnerID = currentNode.OwnerID
 	convertedNode.OwnerID = currentNode.OwnerID
@@ -128,7 +128,7 @@ func (nm *Node) ConvertToAPINode() *ApiNode {
 	}
 	}
 	apiNode.PostDown = nm.PostDown
 	apiNode.PostDown = nm.PostDown
 	apiNode.PostUp = nm.PostUp
 	apiNode.PostUp = nm.PostUp
-	apiNode.PersistentKeepalive = int32(nm.PersistentKeepalive)
+	apiNode.PersistentKeepalive = int32(nm.PersistentKeepalive.Seconds())
 	apiNode.LastModified = nm.LastModified.Unix()
 	apiNode.LastModified = nm.LastModified.Unix()
 	apiNode.LastCheckIn = nm.LastCheckIn.Unix()
 	apiNode.LastCheckIn = nm.LastCheckIn.Unix()
 	apiNode.LastPeerUpdate = nm.LastPeerUpdate.Unix()
 	apiNode.LastPeerUpdate = nm.LastPeerUpdate.Unix()