|
@@ -2,6 +2,7 @@ package controller
|
|
|
|
|
|
import (
|
|
|
"encoding/json"
|
|
|
+ "fmt"
|
|
|
"net/http"
|
|
|
"strings"
|
|
|
|
|
@@ -11,6 +12,7 @@ import (
|
|
|
"github.com/gravitl/netmaker/logger"
|
|
|
"github.com/gravitl/netmaker/logic"
|
|
|
"github.com/gravitl/netmaker/models"
|
|
|
+ "github.com/gravitl/netmaker/mq"
|
|
|
"github.com/gravitl/netmaker/servercfg"
|
|
|
"golang.org/x/crypto/bcrypt"
|
|
|
)
|
|
@@ -19,16 +21,16 @@ func nodeHandlers(r *mux.Router) {
|
|
|
|
|
|
r.HandleFunc("/api/nodes", authorize(false, "user", http.HandlerFunc(getAllNodes))).Methods("GET")
|
|
|
r.HandleFunc("/api/nodes/{network}", authorize(true, "network", http.HandlerFunc(getNetworkNodes))).Methods("GET")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(getNode))).Methods("GET")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(updateNode))).Methods("PUT")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(deleteNode))).Methods("DELETE")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/createrelay", authorize(true, "user", http.HandlerFunc(createRelay))).Methods("POST")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/deleterelay", authorize(true, "user", http.HandlerFunc(deleteRelay))).Methods("DELETE")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/creategateway", authorize(true, "user", http.HandlerFunc(createEgressGateway))).Methods("POST")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/deletegateway", authorize(true, "user", http.HandlerFunc(deleteEgressGateway))).Methods("DELETE")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/createingress", securityCheck(false, http.HandlerFunc(createIngressGateway))).Methods("POST")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/deleteingress", securityCheck(false, http.HandlerFunc(deleteIngressGateway))).Methods("DELETE")
|
|
|
- r.HandleFunc("/api/nodes/{network}/{macaddress}/approve", authorize(true, "user", http.HandlerFunc(uncordonNode))).Methods("POST")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}", authorize(true, "node", http.HandlerFunc(getNode))).Methods("GET")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}", authorize(true, "node", http.HandlerFunc(updateNode))).Methods("PUT")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}", authorize(true, "node", http.HandlerFunc(deleteNode))).Methods("DELETE")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/createrelay", authorize(true, "user", http.HandlerFunc(createRelay))).Methods("POST")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/deleterelay", authorize(true, "user", http.HandlerFunc(deleteRelay))).Methods("DELETE")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/creategateway", authorize(true, "user", http.HandlerFunc(createEgressGateway))).Methods("POST")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/deletegateway", authorize(true, "user", http.HandlerFunc(deleteEgressGateway))).Methods("DELETE")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/createingress", securityCheck(false, http.HandlerFunc(createIngressGateway))).Methods("POST")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/deleteingress", securityCheck(false, http.HandlerFunc(deleteIngressGateway))).Methods("DELETE")
|
|
|
+ r.HandleFunc("/api/nodes/{network}/{nodeid}/approve", authorize(true, "user", http.HandlerFunc(uncordonNode))).Methods("POST")
|
|
|
r.HandleFunc("/api/nodes/{network}", createNode).Methods("POST")
|
|
|
r.HandleFunc("/api/nodes/adm/{network}/lastmodified", authorize(true, "network", http.HandlerFunc(getLastModified))).Methods("GET")
|
|
|
r.HandleFunc("/api/nodes/adm/{network}/authenticate", authenticate).Methods("POST")
|
|
@@ -78,7 +80,7 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
|
if err := json.Unmarshal([]byte(value), &result); err != nil {
|
|
|
continue
|
|
|
}
|
|
|
- if result.MacAddress == authRequest.MacAddress && result.IsPending != "yes" && result.Network == networkname {
|
|
|
+ if (result.ID == authRequest.ID || result.MacAddress == authRequest.MacAddress) && result.IsPending != "yes" && result.Network == networkname {
|
|
|
break
|
|
|
}
|
|
|
}
|
|
@@ -97,7 +99,7 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
|
returnErrorResponse(response, request, errorResponse)
|
|
|
return
|
|
|
} else {
|
|
|
- tokenString, _ := logic.CreateJWT(authRequest.MacAddress, result.Network)
|
|
|
+ tokenString, _ := logic.CreateJWT(authRequest.ID, authRequest.MacAddress, result.Network)
|
|
|
|
|
|
if tokenString == "" {
|
|
|
errorResponse.Code = http.StatusBadRequest
|
|
@@ -177,21 +179,28 @@ func authorize(networkCheck bool, authNetwork string, next http.Handler) http.Ha
|
|
|
}
|
|
|
|
|
|
var isAuthorized = false
|
|
|
- var macaddress = ""
|
|
|
+ var nodeID = ""
|
|
|
username, networks, isadmin, errN := logic.VerifyUserToken(authToken)
|
|
|
+ if errN != nil {
|
|
|
+ errorResponse = models.ErrorResponse{
|
|
|
+ Code: http.StatusUnauthorized, Message: "W1R3: Unauthorized, Invalid Token Processed.",
|
|
|
+ }
|
|
|
+ returnErrorResponse(w, r, errorResponse)
|
|
|
+ return
|
|
|
+ }
|
|
|
isnetadmin := isadmin
|
|
|
if errN == nil && isadmin {
|
|
|
- macaddress = "mastermac"
|
|
|
+ nodeID = "mastermac"
|
|
|
isAuthorized = true
|
|
|
r.Header.Set("ismasterkey", "yes")
|
|
|
}
|
|
|
if !isadmin && params["network"] != "" {
|
|
|
- if functions.SliceContains(networks, params["network"]) {
|
|
|
+ if logic.StringSliceContains(networks, params["network"]) {
|
|
|
isnetadmin = true
|
|
|
}
|
|
|
}
|
|
|
//The mastermac (login with masterkey from config) can do everything!! May be dangerous.
|
|
|
- if macaddress == "mastermac" {
|
|
|
+ if nodeID == "mastermac" {
|
|
|
isAuthorized = true
|
|
|
r.Header.Set("ismasterkey", "yes")
|
|
|
//for everyone else, there's poor man's RBAC. The "cases" are defined in the routes in the handlers
|
|
@@ -201,12 +210,12 @@ func authorize(networkCheck bool, authNetwork string, next http.Handler) http.Ha
|
|
|
case "all":
|
|
|
isAuthorized = true
|
|
|
case "nodes":
|
|
|
- isAuthorized = (macaddress != "") || isnetadmin
|
|
|
+ isAuthorized = (nodeID != "") || isnetadmin
|
|
|
case "network":
|
|
|
if isnetadmin {
|
|
|
isAuthorized = true
|
|
|
} else {
|
|
|
- node, err := logic.GetNodeByMacAddress(params["network"], macaddress)
|
|
|
+ node, err := logic.GetNodeByID(nodeID)
|
|
|
if err != nil {
|
|
|
errorResponse = models.ErrorResponse{
|
|
|
Code: http.StatusUnauthorized, Message: "W1R3: Missing Auth Token.",
|
|
@@ -220,7 +229,7 @@ func authorize(networkCheck bool, authNetwork string, next http.Handler) http.Ha
|
|
|
if isnetadmin {
|
|
|
isAuthorized = true
|
|
|
} else {
|
|
|
- isAuthorized = (macaddress == params["macaddress"])
|
|
|
+ isAuthorized = (nodeID == params["netid"])
|
|
|
}
|
|
|
case "user":
|
|
|
isAuthorized = true
|
|
@@ -254,6 +263,7 @@ func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
|
|
|
var nodes []models.Node
|
|
|
var params = mux.Vars(r)
|
|
|
networkName := params["network"]
|
|
|
+
|
|
|
nodes, err := logic.GetNetworkNodes(networkName)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
@@ -290,9 +300,9 @@ func getAllNodes(w http.ResponseWriter, r *http.Request) {
|
|
|
}
|
|
|
}
|
|
|
//Return all the nodes in JSON format
|
|
|
- logger.Log(2, r.Header.Get("user"), "fetched nodes")
|
|
|
+ logger.Log(3, r.Header.Get("user"), "fetched all nodes they have access to")
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
- json.NewEncoder(w).Encode(nodes)
|
|
|
+ json.NewEncoder(w).Encode(filterCommsNodes(nodes))
|
|
|
}
|
|
|
|
|
|
func getUsersNodes(user models.User) ([]models.Node, error) {
|
|
@@ -315,12 +325,16 @@ func getNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
var params = mux.Vars(r)
|
|
|
|
|
|
- node, err := logic.GetNode(params["macaddress"], params["network"])
|
|
|
+ node, err := logic.GetNodeByID(params["nodeid"])
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
- logger.Log(2, r.Header.Get("user"), "fetched node", params["macaddress"])
|
|
|
+ if logic.IsNodeInComms(&node) {
|
|
|
+ returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ logger.Log(2, r.Header.Get("user"), "fetched node", params["nodeid"])
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
}
|
|
@@ -386,8 +400,8 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
|
validKey := logic.IsKeyValid(networkName, node.AccessKey)
|
|
|
|
|
|
if !validKey {
|
|
|
- //Check to see if network will allow manual sign up
|
|
|
- //may want to switch this up with the valid key check and avoid a DB call that way.
|
|
|
+ // Check to see if network will allow manual sign up
|
|
|
+ // may want to switch this up with the valid key check and avoid a DB call that way.
|
|
|
if network.AllowManualSignUp == "yes" {
|
|
|
node.IsPending = "yes"
|
|
|
} else {
|
|
@@ -404,17 +418,20 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
logger.Log(1, r.Header.Get("user"), "created new node", node.Name, "on network", node.Network)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
+ runForceServerUpdate(&node)
|
|
|
}
|
|
|
|
|
|
-//Takes node out of pending state
|
|
|
-//TODO: May want to use cordon/uncordon terminology instead of "ispending".
|
|
|
+// Takes node out of pending state
|
|
|
+// TODO: May want to use cordon/uncordon terminology instead of "ispending".
|
|
|
func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
|
var params = mux.Vars(r)
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
- node, err := logic.UncordonNode(params["network"], params["macaddress"])
|
|
|
+ var nodeid = params["nodeid"]
|
|
|
+ node, err := logic.UncordonNode(nodeid)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
@@ -422,8 +439,12 @@ func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
|
logger.Log(1, r.Header.Get("user"), "uncordoned node", node.Name)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode("SUCCESS")
|
|
|
+
|
|
|
+ runUpdates(&node, false)
|
|
|
}
|
|
|
|
|
|
+// == EGRESS ==
|
|
|
+
|
|
|
func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
var gateway models.EgressGatewayRequest
|
|
|
var params = mux.Vars(r)
|
|
@@ -434,30 +455,36 @@ func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
return
|
|
|
}
|
|
|
gateway.NetID = params["network"]
|
|
|
- gateway.NodeID = params["macaddress"]
|
|
|
+ gateway.NodeID = params["nodeid"]
|
|
|
node, err := logic.CreateEgressGateway(gateway)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
logger.Log(1, r.Header.Get("user"), "created egress gateway on node", gateway.NodeID, "on network", gateway.NetID)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
+
|
|
|
+ runUpdates(&node, true)
|
|
|
}
|
|
|
|
|
|
func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
var params = mux.Vars(r)
|
|
|
- nodeMac := params["macaddress"]
|
|
|
+ nodeid := params["nodeid"]
|
|
|
netid := params["network"]
|
|
|
- node, err := logic.DeleteEgressGateway(netid, nodeMac)
|
|
|
+ node, err := logic.DeleteEgressGateway(netid, nodeid)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
- logger.Log(1, r.Header.Get("user"), "deleted egress gateway", nodeMac, "on network", netid)
|
|
|
+
|
|
|
+ logger.Log(1, r.Header.Get("user"), "deleted egress gateway", nodeid, "on network", netid)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
+
|
|
|
+ runUpdates(&node, true)
|
|
|
}
|
|
|
|
|
|
// == INGRESS ==
|
|
@@ -465,30 +492,36 @@ func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
func createIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
var params = mux.Vars(r)
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
- nodeMac := params["macaddress"]
|
|
|
+ nodeid := params["nodeid"]
|
|
|
netid := params["network"]
|
|
|
- node, err := logic.CreateIngressGateway(netid, nodeMac)
|
|
|
+ node, err := logic.CreateIngressGateway(netid, nodeid)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
- logger.Log(1, r.Header.Get("user"), "created ingress gateway on node", nodeMac, "on network", netid)
|
|
|
+
|
|
|
+ logger.Log(1, r.Header.Get("user"), "created ingress gateway on node", nodeid, "on network", netid)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
+
|
|
|
+ runUpdates(&node, true)
|
|
|
}
|
|
|
|
|
|
func deleteIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
var params = mux.Vars(r)
|
|
|
- nodeMac := params["macaddress"]
|
|
|
- node, err := logic.DeleteIngressGateway(params["network"], nodeMac)
|
|
|
+ nodeid := params["nodeid"]
|
|
|
+ node, err := logic.DeleteIngressGateway(params["network"], nodeid)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
- logger.Log(1, r.Header.Get("user"), "deleted ingress gateway", nodeMac)
|
|
|
+
|
|
|
+ logger.Log(1, r.Header.Get("user"), "deleted ingress gateway", nodeid)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(node)
|
|
|
+
|
|
|
+ runUpdates(&node, true)
|
|
|
}
|
|
|
|
|
|
func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
@@ -498,7 +531,7 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
var node models.Node
|
|
|
//start here
|
|
|
- node, err := logic.GetNodeByMacAddress(params["network"], params["macaddress"])
|
|
|
+ node, err := logic.GetNodeByID(params["nodeid"])
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
@@ -511,7 +544,6 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
|
returnErrorResponse(w, r, formatError(err, "badrequest"))
|
|
|
return
|
|
|
}
|
|
|
- newNode.PullChanges = "yes"
|
|
|
relayupdate := false
|
|
|
if node.IsRelay == "yes" && len(newNode.RelayAddrs) > 0 {
|
|
|
if len(newNode.RelayAddrs) != len(node.RelayAddrs) {
|
|
@@ -530,28 +562,34 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
|
newNode.PostUp = node.PostUp
|
|
|
}
|
|
|
|
|
|
+ ifaceDelta := logic.IfaceDelta(&node, &newNode)
|
|
|
+
|
|
|
err = logic.UpdateNode(&node, &newNode)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
if relayupdate {
|
|
|
- logic.UpdateRelay(node.Network, node.RelayAddrs, newNode.RelayAddrs)
|
|
|
+ updatenodes := logic.UpdateRelay(node.Network, node.RelayAddrs, newNode.RelayAddrs)
|
|
|
if err = logic.NetworkNodesUpdatePullChanges(node.Network); err != nil {
|
|
|
logger.Log(1, "error setting relay updates:", err.Error())
|
|
|
}
|
|
|
+ if len(updatenodes) > 0 {
|
|
|
+ for _, relayedNode := range updatenodes {
|
|
|
+ runUpdates(&relayedNode, false)
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
if servercfg.IsDNSMode() {
|
|
|
- err = logic.SetDNS()
|
|
|
- }
|
|
|
- if err != nil {
|
|
|
- returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
- return
|
|
|
+ logic.SetDNS()
|
|
|
}
|
|
|
- logger.Log(1, r.Header.Get("user"), "updated node", node.MacAddress, "on network", node.Network)
|
|
|
+
|
|
|
+ logger.Log(1, r.Header.Get("user"), "updated node", node.ID, "on network", node.Network)
|
|
|
w.WriteHeader(http.StatusOK)
|
|
|
json.NewEncoder(w).Encode(newNode)
|
|
|
+
|
|
|
+ runUpdates(&newNode, ifaceDelta)
|
|
|
}
|
|
|
|
|
|
func deleteNode(w http.ResponseWriter, r *http.Request) {
|
|
@@ -560,17 +598,75 @@ func deleteNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
// get params
|
|
|
var params = mux.Vars(r)
|
|
|
- var node, err = logic.GetNode(params["macaddress"], params["network"])
|
|
|
+ var nodeid = params["nodeid"]
|
|
|
+ var node, err = logic.GetNodeByID(nodeid)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "badrequest"))
|
|
|
return
|
|
|
}
|
|
|
- err = logic.DeleteNode(&node, false)
|
|
|
+ if isServer(&node) {
|
|
|
+ returnErrorResponse(w, r, formatError(fmt.Errorf("cannot delete server node"), "badrequest"))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //send update to node to be deleted before deleting on server otherwise message cannot be sent
|
|
|
+ node.Action = models.NODE_DELETE
|
|
|
+
|
|
|
+ err = logic.DeleteNodeByID(&node, false)
|
|
|
if err != nil {
|
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
+ returnSuccessResponse(w, r, nodeid+" deleted.")
|
|
|
+
|
|
|
+ logger.Log(1, r.Header.Get("user"), "Deleted node", nodeid, "from network", params["network"])
|
|
|
+ runUpdates(&node, false)
|
|
|
+ runForceServerUpdate(&node)
|
|
|
+}
|
|
|
+
|
|
|
+func runUpdates(node *models.Node, ifaceDelta bool) {
|
|
|
+ go func() { // don't block http response
|
|
|
+ // publish node update if not server
|
|
|
+ if err := mq.NodeUpdate(node); err != nil {
|
|
|
+ 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())
|
|
|
+ }
|
|
|
+ }()
|
|
|
+}
|
|
|
+
|
|
|
+// updates local peers for a server on a given node's network
|
|
|
+func runServerUpdate(node *models.Node, ifaceDelta bool) error {
|
|
|
|
|
|
- logger.Log(1, r.Header.Get("user"), "Deleted node", params["macaddress"], "from network", params["network"])
|
|
|
- returnSuccessResponse(w, r, params["macaddress"]+" deleted.")
|
|
|
+ if servercfg.IsClientMode() != "on" || !isServer(node) {
|
|
|
+ return nil
|
|
|
+ }
|
|
|
+
|
|
|
+ currentServerNode, err := logic.GetNetworkServerLocal(node.Network)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ if ifaceDelta && logic.IsLeader(¤tServerNode) {
|
|
|
+ if err := mq.PublishPeerUpdate(¤tServerNode); err != nil {
|
|
|
+ logger.Log(1, "failed to publish peer update "+err.Error())
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if err := logic.ServerUpdate(¤tServerNode, ifaceDelta); err != nil {
|
|
|
+ logger.Log(1, "server node:", currentServerNode.ID, "failed update")
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+func filterCommsNodes(nodes []models.Node) []models.Node {
|
|
|
+ var filterdNodes []models.Node
|
|
|
+ for i := range nodes {
|
|
|
+ if !logic.IsNodeInComms(&nodes[i]) {
|
|
|
+ filterdNodes = append(filterdNodes, nodes[i])
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return filterdNodes
|
|
|
}
|