diff --git a/controllers/node.go b/controllers/node.go index 5181ef72..e121979a 100644 --- a/controllers/node.go +++ b/controllers/node.go @@ -467,7 +467,7 @@ func getNode(w http.ResponseWriter, r *http.Request) { } if servercfg.Is_EE && nodeRequest { - if err = logic.EnterpriseResetAllPeersFailovers(node.ID.String(), node.Network); err != nil { + if err = logic.EnterpriseResetAllPeersFailovers(node.ID, node.Network); err != nil { logger.Log(1, "failed to reset failover list during node config pull", node.ID.String(), node.Network) } } @@ -952,7 +952,7 @@ func updateNode(w http.ResponseWriter, r *http.Request) { ifaceDelta := logic.IfaceDelta(¤tNode, newNode) if ifaceDelta && servercfg.Is_EE { - if err = logic.EnterpriseResetAllPeersFailovers(currentNode.ID.String(), currentNode.Network); err != nil { + if err = logic.EnterpriseResetAllPeersFailovers(currentNode.ID, currentNode.Network); err != nil { logger.Log(0, "failed to reset failover lists during node update for node", currentNode.ID.String(), currentNode.Network) } } diff --git a/logic/nodes.go b/logic/nodes.go index 5edf6ca6..9891f73e 100644 --- a/logic/nodes.go +++ b/logic/nodes.go @@ -101,7 +101,7 @@ func DeleteNode(node *models.Node, purge bool) error { return err } if servercfg.Is_EE { - if err := EnterpriseResetAllPeersFailovers(node.ID.String(), node.Network); err != nil { + if err := EnterpriseResetAllPeersFailovers(node.ID, node.Network); err != nil { logger.Log(0, "failed to reset failover lists during node delete for node", host.Name, node.Network) } } diff --git a/logic/server.go b/logic/server.go index 5aaedbc2..14320541 100644 --- a/logic/server.go +++ b/logic/server.go @@ -3,6 +3,7 @@ package logic import ( "strings" + "github.com/google/uuid" "github.com/gravitl/netmaker/models" ) @@ -16,7 +17,7 @@ var EnterpriseFailoverFunc func(node *models.Node) error var EnterpriseResetFailoverFunc func(network string) error // EnterpriseResetAllPeersFailovers - resets all nodes that are considering a node to be failover worthy (inclusive) -var EnterpriseResetAllPeersFailovers func(nodeid, network string) error +var EnterpriseResetAllPeersFailovers func(nodeid uuid.UUID, network string) error // == Join, Checkin, and Leave for Server == diff --git a/mq/handlers.go b/mq/handlers.go index 47fb7983..1faeeb72 100644 --- a/mq/handlers.go +++ b/mq/handlers.go @@ -98,7 +98,7 @@ func UpdateNode(client mqtt.Client, msg mqtt.Message) { ifaceDelta := logic.IfaceDelta(¤tNode, &newNode) if servercfg.Is_EE && ifaceDelta { - if err = logic.EnterpriseResetAllPeersFailovers(currentNode.ID.String(), currentNode.Network); err != nil { + if err = logic.EnterpriseResetAllPeersFailovers(currentNode.ID, currentNode.Network); err != nil { logger.Log(1, "failed to reset failover list during node update", currentNode.ID.String(), currentNode.Network) } }