|
@@ -36,6 +36,14 @@ func nodeHandlers(r *mux.Router) {
|
|
r.HandleFunc("/api/nodes/adm/{network}/authenticate", authenticate).Methods("POST")
|
|
r.HandleFunc("/api/nodes/adm/{network}/authenticate", authenticate).Methods("POST")
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route POST /api/nodes/adm/{network}/authenticate nodes authenticate
|
|
|
|
+//
|
|
|
|
+// Authenticate to make further API calls related to a network.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
func authenticate(response http.ResponseWriter, request *http.Request) {
|
|
|
|
|
|
var authRequest models.AuthParams
|
|
var authRequest models.AuthParams
|
|
@@ -302,7 +310,14 @@ func authorize(nodesAllowed, networkCheck bool, authNetwork string, next http.Ha
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-// Gets all nodes associated with network, including pending nodes
|
|
|
|
|
|
+// swagger:route GET /api/nodes/{network} nodes getNetworkNodes
|
|
|
|
+//
|
|
|
|
+// Gets all nodes associated with network including pending nodes
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
|
|
func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
@@ -325,7 +340,14 @@ func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
|
|
json.NewEncoder(w).Encode(nodes)
|
|
json.NewEncoder(w).Encode(nodes)
|
|
}
|
|
}
|
|
|
|
|
|
-// A separate function to get all nodes, not just nodes for a particular network.
|
|
|
|
|
|
+// swagger:route GET /api/nodes nodes getAllNodes
|
|
|
|
+//
|
|
|
|
+// Get all nodes across all networks.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
// Not quite sure if this is necessary. Probably necessary based on front end but may want to review after iteration 1 if it's being used or not
|
|
// Not quite sure if this is necessary. Probably necessary based on front end but may want to review after iteration 1 if it's being used or not
|
|
func getAllNodes(w http.ResponseWriter, r *http.Request) {
|
|
func getAllNodes(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
@@ -372,7 +394,14 @@ func getUsersNodes(user models.User) ([]models.Node, error) {
|
|
return nodes, err
|
|
return nodes, err
|
|
}
|
|
}
|
|
|
|
|
|
-// Get an individual node. Nothin fancy here folks.
|
|
|
|
|
|
+// swagger:route GET /api/nodes/{network}/{nodeid} nodes getNode
|
|
|
|
+//
|
|
|
|
+// Get an individual node.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
func getNode(w http.ResponseWriter, r *http.Request) {
|
|
func getNode(w http.ResponseWriter, r *http.Request) {
|
|
// set header.
|
|
// set header.
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
@@ -406,7 +435,14 @@ func getNode(w http.ResponseWriter, r *http.Request) {
|
|
json.NewEncoder(w).Encode(response)
|
|
json.NewEncoder(w).Encode(response)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route GET /api/nodes/adm/{network}/lastmodified nodes getLastModified
|
|
|
|
+//
|
|
// Get the time that a network of nodes was last modified.
|
|
// Get the time that a network of nodes was last modified.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
// TODO: This needs to be refactored
|
|
// TODO: This needs to be refactored
|
|
// Potential way to do this: On UpdateNode, set a new field for "LastModified"
|
|
// Potential way to do this: On UpdateNode, set a new field for "LastModified"
|
|
// If we go with the existing way, we need to at least set network.NodesLastModified on UpdateNode
|
|
// If we go with the existing way, we need to at least set network.NodesLastModified on UpdateNode
|
|
@@ -428,6 +464,14 @@ func getLastModified(w http.ResponseWriter, r *http.Request) {
|
|
json.NewEncoder(w).Encode(network.NodesLastModified)
|
|
json.NewEncoder(w).Encode(network.NodesLastModified)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route POST /api/nodes/{network} nodes createNode
|
|
|
|
+//
|
|
|
|
+// Create a node on a network.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
func createNode(w http.ResponseWriter, r *http.Request) {
|
|
func createNode(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
|
|
|
@@ -547,6 +591,14 @@ func createNode(w http.ResponseWriter, r *http.Request) {
|
|
runForceServerUpdate(&node, true)
|
|
runForceServerUpdate(&node, true)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route POST /api/nodes/{network}/{nodeid}/approve nodes uncordonNode
|
|
|
|
+//
|
|
|
|
+// Takes a node out of pending state.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
// Takes node out of pending state
|
|
// Takes node out of pending state
|
|
// TODO: May want to use cordon/uncordon terminology instead of "ispending".
|
|
// TODO: May want to use cordon/uncordon terminology instead of "ispending".
|
|
func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
@@ -569,6 +621,14 @@ func uncordonNode(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
// == EGRESS ==
|
|
// == EGRESS ==
|
|
|
|
|
|
|
|
+// swagger:route POST /api/nodes/{network}/{nodeid}/creategateway nodes createEgressGateway
|
|
|
|
+//
|
|
|
|
+// Create an egress gateway.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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)
|
|
@@ -597,6 +657,14 @@ func createEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
runUpdates(&node, true)
|
|
runUpdates(&node, true)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route DELETE /api/nodes/{network}/{nodeid}/deletegateway nodes deleteEgressGateway
|
|
|
|
+//
|
|
|
|
+// Delete an egress gateway.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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)
|
|
@@ -620,6 +688,14 @@ func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
// == INGRESS ==
|
|
// == INGRESS ==
|
|
|
|
|
|
|
|
+// swagger:route POST /api/nodes/{network}/{nodeid}/createingress nodes createIngressGateway
|
|
|
|
+//
|
|
|
|
+// Create an ingress gateway.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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")
|
|
@@ -641,6 +717,14 @@ func createIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
runUpdates(&node, true)
|
|
runUpdates(&node, true)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route DELETE /api/nodes/{network}/{nodeid}/deleteingress nodes deleteIngressGateway
|
|
|
|
+//
|
|
|
|
+// Delete an ingress gateway.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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)
|
|
@@ -662,6 +746,14 @@ func deleteIngressGateway(w http.ResponseWriter, r *http.Request) {
|
|
runUpdates(&node, true)
|
|
runUpdates(&node, true)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route PUT /api/nodes/{network}/{nodeid} nodes updateNode
|
|
|
|
+//
|
|
|
|
+// Update an individual node.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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")
|
|
|
|
|
|
@@ -756,6 +848,14 @@ func updateNode(w http.ResponseWriter, r *http.Request) {
|
|
runUpdates(&newNode, ifaceDelta)
|
|
runUpdates(&newNode, ifaceDelta)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+// swagger:route DELETE /api/nodes/{network}/{nodeid} nodes deleteNode
|
|
|
|
+//
|
|
|
|
+// Delete an individual node.
|
|
|
|
+//
|
|
|
|
+// Schemes: https
|
|
|
|
+//
|
|
|
|
+// Security:
|
|
|
|
+// oauth
|
|
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")
|