|
@@ -2,14 +2,13 @@ package controller
|
|
|
|
|
|
import (
|
|
import (
|
|
"encoding/json"
|
|
"encoding/json"
|
|
- "errors"
|
|
|
|
"net/http"
|
|
"net/http"
|
|
"strings"
|
|
"strings"
|
|
- "time"
|
|
|
|
|
|
|
|
"github.com/gorilla/mux"
|
|
"github.com/gorilla/mux"
|
|
"github.com/gravitl/netmaker/database"
|
|
"github.com/gravitl/netmaker/database"
|
|
"github.com/gravitl/netmaker/functions"
|
|
"github.com/gravitl/netmaker/functions"
|
|
|
|
+ "github.com/gravitl/netmaker/logger"
|
|
"github.com/gravitl/netmaker/logic"
|
|
"github.com/gravitl/netmaker/logic"
|
|
"github.com/gravitl/netmaker/models"
|
|
"github.com/gravitl/netmaker/models"
|
|
"github.com/gravitl/netmaker/servercfg"
|
|
"github.com/gravitl/netmaker/servercfg"
|
|
@@ -36,20 +35,17 @@ func nodeHandlers(r *mux.Router) {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
-//Node authenticates using its password and retrieves a JWT for authorization.
|
|
|
|
func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
|
|
|
|
var params = mux.Vars(request)
|
|
var params = mux.Vars(request)
|
|
networkname := params["network"]
|
|
networkname := params["network"]
|
|
- //Auth request consists of Mac Address and Password (from node that is authorizing
|
|
|
|
- //in case of Master, auth is ignored and mac is set to "mastermac"
|
|
|
|
|
|
+
|
|
var authRequest models.AuthParams
|
|
var authRequest models.AuthParams
|
|
var result models.Node
|
|
var result models.Node
|
|
var errorResponse = models.ErrorResponse{
|
|
var errorResponse = models.ErrorResponse{
|
|
Code: http.StatusInternalServerError, Message: "W1R3: It's not you it's me.",
|
|
Code: http.StatusInternalServerError, Message: "W1R3: It's not you it's me.",
|
|
}
|
|
}
|
|
|
|
|
|
- //Get password fnd mac rom request
|
|
|
|
decoder := json.NewDecoder(request.Body)
|
|
decoder := json.NewDecoder(request.Body)
|
|
decoderErr := decoder.Decode(&authRequest)
|
|
decoderErr := decoder.Decode(&authRequest)
|
|
defer request.Body.Close()
|
|
defer request.Body.Close()
|
|
@@ -71,7 +67,6 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
return
|
|
return
|
|
} else {
|
|
} else {
|
|
|
|
|
|
- //Search DB for node with Mac Address. Ignore pending nodes (they should not be able to authenticate with API until approved).
|
|
|
|
collection, err := database.FetchRecords(database.NODES_TABLE_NAME)
|
|
collection, err := database.FetchRecords(database.NODES_TABLE_NAME)
|
|
if err != nil {
|
|
if err != nil {
|
|
errorResponse.Code = http.StatusBadRequest
|
|
errorResponse.Code = http.StatusBadRequest
|
|
@@ -95,9 +90,6 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //compare password from request to stored password in database
|
|
|
|
- //might be able to have a common hash (certificates?) and compare those so that a password isn't passed in in plain text...
|
|
|
|
- //TODO: Consider a way of hashing the password client side before sending, or using certificates
|
|
|
|
err = bcrypt.CompareHashAndPassword([]byte(result.Password), []byte(authRequest.Password))
|
|
err = bcrypt.CompareHashAndPassword([]byte(result.Password), []byte(authRequest.Password))
|
|
if err != nil {
|
|
if err != nil {
|
|
errorResponse.Code = http.StatusBadRequest
|
|
errorResponse.Code = http.StatusBadRequest
|
|
@@ -105,7 +97,6 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
returnErrorResponse(response, request, errorResponse)
|
|
returnErrorResponse(response, request, errorResponse)
|
|
return
|
|
return
|
|
} else {
|
|
} else {
|
|
- //Create a new JWT for the node
|
|
|
|
tokenString, _ := logic.CreateJWT(authRequest.MacAddress, result.Network)
|
|
tokenString, _ := logic.CreateJWT(authRequest.MacAddress, result.Network)
|
|
|
|
|
|
if tokenString == "" {
|
|
if tokenString == "" {
|
|
@@ -123,7 +114,6 @@ func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
MacAddress: authRequest.MacAddress,
|
|
MacAddress: authRequest.MacAddress,
|
|
},
|
|
},
|
|
}
|
|
}
|
|
- //Send back the JWT
|
|
|
|
successJSONResponse, jsonError := json.Marshal(successResponse)
|
|
successJSONResponse, jsonError := json.Marshal(successResponse)
|
|
|
|
|
|
if jsonError != nil {
|
|
if jsonError != nil {
|
|
@@ -186,10 +176,6 @@ func authorize(networkCheck bool, authNetwork string, next http.Handler) http.Ha
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //This checks if
|
|
|
|
- //A: the token is the master password
|
|
|
|
- //B: the token corresponds to a mac address, and if so, which one
|
|
|
|
- //TODO: There's probably a better way of dealing with the "master token"/master password. Plz Help.
|
|
|
|
var isAuthorized = false
|
|
var isAuthorized = false
|
|
var macaddress = ""
|
|
var macaddress = ""
|
|
username, networks, isadmin, errN := logic.VerifyUserToken(authToken)
|
|
username, networks, isadmin, errN := logic.VerifyUserToken(authToken)
|
|
@@ -275,7 +261,7 @@ func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
|
|
}
|
|
}
|
|
|
|
|
|
//Returns all the nodes in JSON format
|
|
//Returns all the nodes in JSON format
|
|
- functions.PrintUserLog(r.Header.Get("user"), "fetched nodes on network"+networkName, 2)
|
|
|
|
|
|
+ logger.Log(2, r.Header.Get("user"), "fetched nodes on network", networkName)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(nodes)
|
|
json.NewEncoder(w).Encode(nodes)
|
|
}
|
|
}
|
|
@@ -304,7 +290,7 @@ func getAllNodes(w http.ResponseWriter, r *http.Request) {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//Return all the nodes in JSON format
|
|
//Return all the nodes in JSON format
|
|
- functions.PrintUserLog(r.Header.Get("user"), "fetched nodes", 2)
|
|
|
|
|
|
+ logger.Log(2, r.Header.Get("user"), "fetched nodes")
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(nodes)
|
|
json.NewEncoder(w).Encode(nodes)
|
|
}
|
|
}
|
|
@@ -329,12 +315,12 @@ func getNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
|
|
|
|
- node, err := GetNode(params["macaddress"], params["network"])
|
|
|
|
|
|
+ node, err := logic.GetNode(params["macaddress"], params["network"])
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "fetched node "+params["macaddress"], 2)
|
|
|
|
|
|
+ logger.Log(2, r.Header.Get("user"), "fetched node", params["macaddress"])
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
@@ -348,12 +334,12 @@ func getLastModified(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
|
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
- network, err := GetNetwork(params["network"])
|
|
|
|
|
|
+ network, err := logic.GetNetwork(params["network"])
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "called last modified", 2)
|
|
|
|
|
|
+ logger.Log(2, r.Header.Get("user"), "called last modified")
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(network.NodesLastModified)
|
|
json.NewEncoder(w).Encode(network.NodesLastModified)
|
|
}
|
|
}
|
|
@@ -380,7 +366,7 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- var node models.Node
|
|
|
|
|
|
+ var node = models.Node{}
|
|
|
|
|
|
//get node from body of request
|
|
//get node from body of request
|
|
err = json.NewDecoder(r.Body).Decode(&node)
|
|
err = json.NewDecoder(r.Body).Decode(&node)
|
|
@@ -397,8 +383,6 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //Check to see if key is valid
|
|
|
|
- //TODO: Triple inefficient!!! This is the third call to the DB we make for networks
|
|
|
|
validKey := logic.IsKeyValid(networkName, node.AccessKey)
|
|
validKey := logic.IsKeyValid(networkName, node.AccessKey)
|
|
|
|
|
|
if !validKey {
|
|
if !validKey {
|
|
@@ -415,12 +399,12 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- node, err = logic.CreateNode(node, networkName)
|
|
|
|
|
|
+ err = logic.CreateNode(&node)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "created new node "+node.Name+" on network "+node.Network, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "created new node", node.Name, "on network", node.Network)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
@@ -430,38 +414,16 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
- node, err := UncordonNode(params["network"], params["macaddress"])
|
|
|
|
|
|
+ node, err := logic.UncordonNode(params["network"], params["macaddress"])
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "uncordoned node "+node.Name, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "uncordoned node", node.Name)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode("SUCCESS")
|
|
json.NewEncoder(w).Encode("SUCCESS")
|
|
}
|
|
}
|
|
|
|
|
|
-// UncordonNode - approves a node to join a network
|
|
|
|
-func UncordonNode(network, macaddress string) (models.Node, error) {
|
|
|
|
- node, err := logic.GetNodeByMacAddress(network, macaddress)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- node.SetLastModified()
|
|
|
|
- node.IsPending = "no"
|
|
|
|
- node.PullChanges = "yes"
|
|
|
|
- data, err := json.Marshal(&node)
|
|
|
|
- if err != nil {
|
|
|
|
- return node, err
|
|
|
|
- }
|
|
|
|
- key, err := logic.GetRecordKey(node.MacAddress, node.Network)
|
|
|
|
- if err != nil {
|
|
|
|
- return node, err
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- err = database.Insert(key, string(data), database.NODES_TABLE_NAME)
|
|
|
|
- return node, err
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
var gateway models.EgressGatewayRequest
|
|
var gateway models.EgressGatewayRequest
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
@@ -473,253 +435,62 @@ func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
}
|
|
}
|
|
gateway.NetID = params["network"]
|
|
gateway.NetID = params["network"]
|
|
gateway.NodeID = params["macaddress"]
|
|
gateway.NodeID = params["macaddress"]
|
|
- node, err := CreateEgressGateway(gateway)
|
|
|
|
|
|
+ node, err := logic.CreateEgressGateway(gateway)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "created egress gateway on node "+gateway.NodeID+" on network "+gateway.NetID, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "created egress gateway on node", gateway.NodeID, "on network", gateway.NetID)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
|
|
|
|
-// CreateEgressGateway - creates an egress gateway
|
|
|
|
-func CreateEgressGateway(gateway models.EgressGatewayRequest) (models.Node, error) {
|
|
|
|
- node, err := logic.GetNodeByMacAddress(gateway.NetID, gateway.NodeID)
|
|
|
|
- if node.OS == "windows" || node.OS == "macos" { // add in darwin later
|
|
|
|
- return models.Node{}, errors.New(node.OS + " is unsupported for egress gateways")
|
|
|
|
- }
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- err = ValidateEgressGateway(gateway)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- node.IsEgressGateway = "yes"
|
|
|
|
- node.EgressGatewayRanges = gateway.Ranges
|
|
|
|
- postUpCmd := "iptables -A FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -A POSTROUTING -o " + gateway.Interface + " -j MASQUERADE"
|
|
|
|
- postDownCmd := "iptables -D FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -D POSTROUTING -o " + gateway.Interface + " -j MASQUERADE"
|
|
|
|
- if gateway.PostUp != "" {
|
|
|
|
- postUpCmd = gateway.PostUp
|
|
|
|
- }
|
|
|
|
- if gateway.PostDown != "" {
|
|
|
|
- postDownCmd = gateway.PostDown
|
|
|
|
- }
|
|
|
|
- if node.PostUp != "" {
|
|
|
|
- if !strings.Contains(node.PostUp, postUpCmd) {
|
|
|
|
- postUpCmd = node.PostUp + "; " + postUpCmd
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- if node.PostDown != "" {
|
|
|
|
- if !strings.Contains(node.PostDown, postDownCmd) {
|
|
|
|
- postDownCmd = node.PostDown + "; " + postDownCmd
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- key, err := logic.GetRecordKey(gateway.NodeID, gateway.NetID)
|
|
|
|
- if err != nil {
|
|
|
|
- return node, err
|
|
|
|
- }
|
|
|
|
- node.PostUp = postUpCmd
|
|
|
|
- node.PostDown = postDownCmd
|
|
|
|
- node.SetLastModified()
|
|
|
|
- node.PullChanges = "yes"
|
|
|
|
- nodeData, err := json.Marshal(&node)
|
|
|
|
- if err != nil {
|
|
|
|
- return node, err
|
|
|
|
- }
|
|
|
|
- if err = database.Insert(key, string(nodeData), database.NODES_TABLE_NAME); err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- if err = functions.NetworkNodesUpdatePullChanges(node.Network); err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- return node, nil
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
-func ValidateEgressGateway(gateway models.EgressGatewayRequest) error {
|
|
|
|
- var err error
|
|
|
|
- //isIp := functions.IsIpCIDR(gateway.RangeString)
|
|
|
|
- empty := len(gateway.Ranges) == 0
|
|
|
|
- if empty {
|
|
|
|
- err = errors.New("IP Ranges Cannot Be Empty")
|
|
|
|
- }
|
|
|
|
- empty = gateway.Interface == ""
|
|
|
|
- if empty {
|
|
|
|
- err = errors.New("Interface cannot be empty")
|
|
|
|
- }
|
|
|
|
- return err
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
nodeMac := params["macaddress"]
|
|
nodeMac := params["macaddress"]
|
|
netid := params["network"]
|
|
netid := params["network"]
|
|
- node, err := DeleteEgressGateway(netid, nodeMac)
|
|
|
|
|
|
+ node, err := logic.DeleteEgressGateway(netid, nodeMac)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "deleted egress gateway "+nodeMac+" on network "+netid, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "deleted egress gateway", nodeMac, "on network", netid)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
|
|
|
|
-// DeleteEgressGateway - deletes egress from node
|
|
|
|
-func DeleteEgressGateway(network, macaddress string) (models.Node, error) {
|
|
|
|
-
|
|
|
|
- node, err := logic.GetNodeByMacAddress(network, macaddress)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- node.IsEgressGateway = "no"
|
|
|
|
- node.EgressGatewayRanges = []string{}
|
|
|
|
- node.PostUp = ""
|
|
|
|
- node.PostDown = ""
|
|
|
|
- if node.IsIngressGateway == "yes" { // check if node is still an ingress gateway before completely deleting postdown/up rules
|
|
|
|
- node.PostUp = "iptables -A FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -A POSTROUTING -o " + node.Interface + " -j MASQUERADE"
|
|
|
|
- node.PostDown = "iptables -D FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -D POSTROUTING -o " + node.Interface + " -j MASQUERADE"
|
|
|
|
- }
|
|
|
|
- node.SetLastModified()
|
|
|
|
- node.PullChanges = "yes"
|
|
|
|
- key, err := logic.GetRecordKey(node.MacAddress, node.Network)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- data, err := json.Marshal(&node)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- if err = database.Insert(key, string(data), database.NODES_TABLE_NAME); err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- if err = functions.NetworkNodesUpdatePullChanges(network); err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- return node, nil
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
// == INGRESS ==
|
|
// == INGRESS ==
|
|
|
|
+
|
|
func createIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
func createIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
nodeMac := params["macaddress"]
|
|
nodeMac := params["macaddress"]
|
|
netid := params["network"]
|
|
netid := params["network"]
|
|
- node, err := CreateIngressGateway(netid, nodeMac)
|
|
|
|
|
|
+ node, err := logic.CreateIngressGateway(netid, nodeMac)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "created ingress gateway on node "+nodeMac+" on network "+netid, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "created ingress gateway on node", nodeMac, "on network", netid)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
|
|
|
|
-// CreateIngressGateway - creates an ingress gateway
|
|
|
|
-func CreateIngressGateway(netid string, macaddress string) (models.Node, error) {
|
|
|
|
-
|
|
|
|
- node, err := logic.GetNodeByMacAddress(netid, macaddress)
|
|
|
|
- if node.OS == "windows" || node.OS == "macos" { // add in darwin later
|
|
|
|
- return models.Node{}, errors.New(node.OS + " is unsupported for ingress gateways")
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- network, err := logic.GetParentNetwork(netid)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- node.IsIngressGateway = "yes"
|
|
|
|
- node.IngressGatewayRange = network.AddressRange
|
|
|
|
- postUpCmd := "iptables -A FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -A POSTROUTING -o " + node.Interface + " -j MASQUERADE"
|
|
|
|
- postDownCmd := "iptables -D FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -D POSTROUTING -o " + node.Interface + " -j MASQUERADE"
|
|
|
|
- if node.PostUp != "" {
|
|
|
|
- if !strings.Contains(node.PostUp, postUpCmd) {
|
|
|
|
- postUpCmd = node.PostUp + "; " + postUpCmd
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- if node.PostDown != "" {
|
|
|
|
- if !strings.Contains(node.PostDown, postDownCmd) {
|
|
|
|
- postDownCmd = node.PostDown + "; " + postDownCmd
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- node.SetLastModified()
|
|
|
|
- node.PostUp = postUpCmd
|
|
|
|
- node.PostDown = postDownCmd
|
|
|
|
- node.PullChanges = "yes"
|
|
|
|
- node.UDPHolePunch = "no"
|
|
|
|
- key, err := logic.GetRecordKey(node.MacAddress, node.Network)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- data, err := json.Marshal(&node)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- err = database.Insert(key, string(data), database.NODES_TABLE_NAME)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- err = logic.SetNetworkNodesLastModified(netid)
|
|
|
|
- return node, err
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
func deleteIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
func deleteIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
nodeMac := params["macaddress"]
|
|
nodeMac := params["macaddress"]
|
|
- node, err := DeleteIngressGateway(params["network"], nodeMac)
|
|
|
|
|
|
+ node, err := logic.DeleteIngressGateway(params["network"], nodeMac)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "deleted ingress gateway"+nodeMac, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "deleted ingress gateway", nodeMac)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(node)
|
|
json.NewEncoder(w).Encode(node)
|
|
}
|
|
}
|
|
|
|
|
|
-// DeleteIngressGateway - deletes an ingress gateway
|
|
|
|
-func DeleteIngressGateway(networkName string, macaddress string) (models.Node, error) {
|
|
|
|
-
|
|
|
|
- node, err := logic.GetNodeByMacAddress(networkName, macaddress)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- network, err := logic.GetParentNetwork(networkName)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- // delete ext clients belonging to ingress gateway
|
|
|
|
- if err = DeleteGatewayExtClients(macaddress, networkName); err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- node.UDPHolePunch = network.DefaultUDPHolePunch
|
|
|
|
- node.LastModified = time.Now().Unix()
|
|
|
|
- node.IsIngressGateway = "no"
|
|
|
|
- node.IngressGatewayRange = ""
|
|
|
|
- node.PullChanges = "yes"
|
|
|
|
-
|
|
|
|
- key, err := logic.GetRecordKey(node.MacAddress, node.Network)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- data, err := json.Marshal(&node)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- err = database.Insert(key, string(data), database.NODES_TABLE_NAME)
|
|
|
|
- if err != nil {
|
|
|
|
- return models.Node{}, err
|
|
|
|
- }
|
|
|
|
- err = logic.SetNetworkNodesLastModified(networkName)
|
|
|
|
- return node, err
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
|
|
|
@@ -759,9 +530,9 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
if relayupdate {
|
|
if relayupdate {
|
|
- UpdateRelay(node.Network, node.RelayAddrs, newNode.RelayAddrs)
|
|
|
|
- if err = functions.NetworkNodesUpdatePullChanges(node.Network); err != nil {
|
|
|
|
- functions.PrintUserLog("netmaker", "error setting relay updates: "+err.Error(), 1)
|
|
|
|
|
|
+ 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())
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -772,26 +543,28 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "updated node "+node.MacAddress+" on network "+node.Network, 1)
|
|
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "updated node", node.MacAddress, "on network", node.Network)
|
|
w.WriteHeader(http.StatusOK)
|
|
w.WriteHeader(http.StatusOK)
|
|
json.NewEncoder(w).Encode(newNode)
|
|
json.NewEncoder(w).Encode(newNode)
|
|
}
|
|
}
|
|
|
|
|
|
-//Delete a node
|
|
|
|
-//Pretty straightforward
|
|
|
|
func deleteNode(w http.ResponseWriter, r *http.Request) {
|
|
func deleteNode(w http.ResponseWriter, r *http.Request) {
|
|
// Set header
|
|
// Set header
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
|
|
|
// get params
|
|
// get params
|
|
var params = mux.Vars(r)
|
|
var params = mux.Vars(r)
|
|
-
|
|
|
|
- err := DeleteNode(params["macaddress"]+"###"+params["network"], false)
|
|
|
|
-
|
|
|
|
|
|
+ var node, err = logic.GetNode(params["macaddress"], params["network"])
|
|
|
|
+ if err != nil {
|
|
|
|
+ returnErrorResponse(w, r, formatError(err, "badrequest"))
|
|
|
|
+ return
|
|
|
|
+ }
|
|
|
|
+ err = logic.DeleteNode(&node, false)
|
|
if err != nil {
|
|
if err != nil {
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
returnErrorResponse(w, r, formatError(err, "internal"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- functions.PrintUserLog(r.Header.Get("user"), "Deleted node "+params["macaddress"]+" from network "+params["network"], 1)
|
|
|
|
|
|
+
|
|
|
|
+ logger.Log(1, r.Header.Get("user"), "Deleted node", params["macaddress"], "from network", params["network"])
|
|
returnSuccessResponse(w, r, params["macaddress"]+" deleted.")
|
|
returnSuccessResponse(w, r, params["macaddress"]+" deleted.")
|
|
}
|
|
}
|