nodeHttpController.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737
  1. package controller
  2. import (
  3. "context"
  4. "encoding/json"
  5. "errors"
  6. "fmt"
  7. "net/http"
  8. "strings"
  9. "time"
  10. "github.com/gorilla/mux"
  11. "github.com/gravitl/netmaker/functions"
  12. "github.com/gravitl/netmaker/models"
  13. "github.com/gravitl/netmaker/mongoconn"
  14. "go.mongodb.org/mongo-driver/bson"
  15. "go.mongodb.org/mongo-driver/mongo/options"
  16. "golang.org/x/crypto/bcrypt"
  17. )
  18. func nodeHandlers(r *mux.Router) {
  19. r.HandleFunc("/api/nodes", authorize(false, "master", http.HandlerFunc(getAllNodes))).Methods("GET")
  20. r.HandleFunc("/api/nodes/{network}", authorize(true, "network", http.HandlerFunc(getNetworkNodes))).Methods("GET")
  21. r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(getNode))).Methods("GET")
  22. r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(updateNode))).Methods("PUT")
  23. r.HandleFunc("/api/nodes/{network}/{macaddress}", authorize(true, "node", http.HandlerFunc(deleteNode))).Methods("DELETE")
  24. r.HandleFunc("/api/nodes/{network}/{macaddress}/checkin", authorize(true, "node", http.HandlerFunc(checkIn))).Methods("POST")
  25. r.HandleFunc("/api/nodes/{network}/{macaddress}/creategateway", authorize(true, "master", http.HandlerFunc(createGateway))).Methods("POST")
  26. r.HandleFunc("/api/nodes/{network}/{macaddress}/deletegateway", authorize(true, "master", http.HandlerFunc(deleteGateway))).Methods("DELETE")
  27. r.HandleFunc("/api/nodes/{network}/{macaddress}/approve", authorize(true, "master", http.HandlerFunc(uncordonNode))).Methods("POST")
  28. r.HandleFunc("/api/nodes/{network}", createNode).Methods("POST")
  29. r.HandleFunc("/api/nodes/adm/{network}/lastmodified", authorize(true, "network", http.HandlerFunc(getLastModified))).Methods("GET")
  30. r.HandleFunc("/api/nodes/adm/{network}/authenticate", authenticate).Methods("POST")
  31. }
  32. //Node authenticates using its password and retrieves a JWT for authorization.
  33. func authenticate(response http.ResponseWriter, request *http.Request) {
  34. //Auth request consists of Mac Address and Password (from node that is authorizing
  35. //in case of Master, auth is ignored and mac is set to "mastermac"
  36. var authRequest models.AuthParams
  37. var result models.Node
  38. var errorResponse = models.ErrorResponse{
  39. Code: http.StatusInternalServerError, Message: "W1R3: It's not you it's me.",
  40. }
  41. //Get password fnd mac rom request
  42. decoder := json.NewDecoder(request.Body)
  43. decoderErr := decoder.Decode(&authRequest)
  44. defer request.Body.Close()
  45. if decoderErr != nil {
  46. errorResponse.Code = http.StatusBadRequest
  47. errorResponse.Message = decoderErr.Error()
  48. returnErrorResponse(response, request, errorResponse)
  49. return
  50. } else {
  51. errorResponse.Code = http.StatusBadRequest
  52. if authRequest.MacAddress == "" {
  53. errorResponse.Message = "W1R3: MacAddress can't be empty"
  54. returnErrorResponse(response, request, errorResponse)
  55. return
  56. } else if authRequest.Password == "" {
  57. errorResponse.Message = "W1R3: Password can't be empty"
  58. returnErrorResponse(response, request, errorResponse)
  59. return
  60. } else {
  61. //Search DB for node with Mac Address. Ignore pending nodes (they should not be able to authenticate with API untill approved).
  62. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  63. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  64. var err = collection.FindOne(ctx, bson.M{"macaddress": authRequest.MacAddress, "ispending": false}).Decode(&result)
  65. defer cancel()
  66. if err != nil {
  67. errorResponse.Code = http.StatusBadRequest
  68. errorResponse.Message = err.Error()
  69. returnErrorResponse(response, request, errorResponse)
  70. return
  71. }
  72. //compare password from request to stored password in database
  73. //might be able to have a common hash (certificates?) and compare those so that a password isn't passed in in plain text...
  74. //TODO: Consider a way of hashing the password client side before sending, or using certificates
  75. err = bcrypt.CompareHashAndPassword([]byte(result.Password), []byte(authRequest.Password))
  76. if err != nil {
  77. errorResponse.Code = http.StatusBadRequest
  78. errorResponse.Message = err.Error()
  79. returnErrorResponse(response, request, errorResponse)
  80. return
  81. } else {
  82. //Create a new JWT for the node
  83. tokenString, _ := functions.CreateJWT(authRequest.MacAddress, result.Network)
  84. if tokenString == "" {
  85. errorResponse.Code = http.StatusBadRequest
  86. errorResponse.Message = "Could not create Token"
  87. returnErrorResponse(response, request, errorResponse)
  88. return
  89. }
  90. var successResponse = models.SuccessResponse{
  91. Code: http.StatusOK,
  92. Message: "W1R3: Device " + authRequest.MacAddress + " Authorized",
  93. Response: models.SuccessfulLoginResponse{
  94. AuthToken: tokenString,
  95. MacAddress: authRequest.MacAddress,
  96. },
  97. }
  98. //Send back the JWT
  99. successJSONResponse, jsonError := json.Marshal(successResponse)
  100. if jsonError != nil {
  101. errorResponse.Code = http.StatusBadRequest
  102. errorResponse.Message = err.Error()
  103. returnErrorResponse(response, request, errorResponse)
  104. return
  105. }
  106. response.WriteHeader(http.StatusOK)
  107. response.Header().Set("Content-Type", "application/json")
  108. response.Write(successJSONResponse)
  109. }
  110. }
  111. }
  112. }
  113. //The middleware for most requests to the API
  114. //They all pass through here first
  115. //This will validate the JWT (or check for master token)
  116. //This will also check against the authNetwork and make sure the node should be accessing that endpoint,
  117. //even if it's technically ok
  118. //This is kind of a poor man's RBAC. There's probably a better/smarter way.
  119. //TODO: Consider better RBAC implementations
  120. func authorize(networkCheck bool, authNetwork string, next http.Handler) http.HandlerFunc {
  121. return func(w http.ResponseWriter, r *http.Request) {
  122. var errorResponse = models.ErrorResponse{
  123. Code: http.StatusInternalServerError, Message: "W1R3: It's not you it's me.",
  124. }
  125. var params = mux.Vars(r)
  126. networkexists, _ := functions.NetworkExists(params["network"])
  127. //check that the request is for a valid network
  128. //if (networkCheck && !networkexists) || err != nil {
  129. if networkCheck && !networkexists {
  130. errorResponse = models.ErrorResponse{
  131. Code: http.StatusNotFound, Message: "W1R3: This network does not exist. ",
  132. }
  133. returnErrorResponse(w, r, errorResponse)
  134. return
  135. } else {
  136. w.Header().Set("Content-Type", "application/json")
  137. //get the auth token
  138. bearerToken := r.Header.Get("Authorization")
  139. var tokenSplit = strings.Split(bearerToken, " ")
  140. //I put this in in case the user doesn't put in a token at all (in which case it's empty)
  141. //There's probably a smarter way of handling this.
  142. var authToken = "928rt238tghgwe@TY@$Y@#WQAEGB2FC#@HG#@$Hddd"
  143. if len(tokenSplit) > 1 {
  144. authToken = tokenSplit[1]
  145. } else {
  146. errorResponse = models.ErrorResponse{
  147. Code: http.StatusUnauthorized, Message: "W1R3: Missing Auth Token.",
  148. }
  149. returnErrorResponse(w, r, errorResponse)
  150. return
  151. }
  152. //This checks if
  153. //A: the token is the master password
  154. //B: the token corresponds to a mac address, and if so, which one
  155. //TODO: There's probably a better way of dealing with the "master token"/master password. Plz Halp.
  156. macaddress, _, err := functions.VerifyToken(authToken)
  157. if err != nil {
  158. errorResponse = models.ErrorResponse{
  159. Code: http.StatusUnauthorized, Message: "W1R3: Error Verifying Auth Token.",
  160. }
  161. returnErrorResponse(w, r, errorResponse)
  162. return
  163. }
  164. var isAuthorized = false
  165. //The mastermac (login with masterkey from config) can do everything!! May be dangerous.
  166. if macaddress == "mastermac" {
  167. isAuthorized = true
  168. //for everyone else, there's poor man's RBAC. The "cases" are defined in the routes in the handlers
  169. //So each route defines which access network should be allowed to access it
  170. } else {
  171. switch authNetwork {
  172. case "all":
  173. isAuthorized = true
  174. case "nodes":
  175. isAuthorized = (macaddress != "")
  176. case "network":
  177. node, err := functions.GetNodeByMacAddress(params["network"], macaddress)
  178. if err != nil {
  179. errorResponse = models.ErrorResponse{
  180. Code: http.StatusUnauthorized, Message: "W1R3: Missing Auth Token.",
  181. }
  182. returnErrorResponse(w, r, errorResponse)
  183. return
  184. }
  185. isAuthorized = (node.Network == params["network"])
  186. case "node":
  187. isAuthorized = (macaddress == params["macaddress"])
  188. case "master":
  189. isAuthorized = (macaddress == "mastermac")
  190. default:
  191. isAuthorized = false
  192. }
  193. }
  194. if !isAuthorized {
  195. errorResponse = models.ErrorResponse{
  196. Code: http.StatusUnauthorized, Message: "W1R3: You are unauthorized to access this endpoint.",
  197. }
  198. returnErrorResponse(w, r, errorResponse)
  199. return
  200. } else {
  201. //If authorized, this function passes along it's request and output to the appropriate route function.
  202. next.ServeHTTP(w, r)
  203. }
  204. }
  205. }
  206. }
  207. //Gets all nodes associated with network, including pending nodes
  208. func getNetworkNodes(w http.ResponseWriter, r *http.Request) {
  209. w.Header().Set("Content-Type", "application/json")
  210. var nodes []models.ReturnNode
  211. var params = mux.Vars(r)
  212. nodes, err := GetNetworkNodes(params["network"])
  213. if err != nil {
  214. returnErrorResponse(w, r, formatError(err, "internal"))
  215. return
  216. }
  217. //Returns all the nodes in JSON format
  218. w.WriteHeader(http.StatusOK)
  219. json.NewEncoder(w).Encode(nodes)
  220. }
  221. func GetNetworkNodes(network string) ([]models.ReturnNode, error) {
  222. var nodes []models.ReturnNode
  223. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  224. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  225. filter := bson.M{"network": network}
  226. //Filtering out the ID field cuz Dillon doesn't like it. May want to filter out other fields in the future
  227. cur, err := collection.Find(ctx, filter, options.Find().SetProjection(bson.M{"_id": 0}))
  228. if err != nil {
  229. return []models.ReturnNode{}, err
  230. }
  231. defer cancel()
  232. for cur.Next(context.TODO()) {
  233. //Using a different model for the ReturnNode (other than regular node).
  234. //Either we should do this for ALL structs (so Networks and Keys)
  235. //OR we should just use the original struct
  236. //My preference is to make some new return structs
  237. //TODO: Think about this. Not an immediate concern. Just need to get some consistency eventually
  238. var node models.ReturnNode
  239. err := cur.Decode(&node)
  240. if err != nil {
  241. return []models.ReturnNode{}, err
  242. }
  243. // add item our array of nodes
  244. nodes = append(nodes, node)
  245. }
  246. //TODO: Another fatal error we should take care of.
  247. if err := cur.Err(); err != nil {
  248. return []models.ReturnNode{}, err
  249. }
  250. return nodes, nil
  251. }
  252. //A separate function to get all nodes, not just nodes for a particular network.
  253. //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
  254. func getAllNodes(w http.ResponseWriter, r *http.Request) {
  255. w.Header().Set("Content-Type", "application/json")
  256. nodes, err := functions.GetAllNodes()
  257. if err != nil {
  258. returnErrorResponse(w, r, formatError(err, "internal"))
  259. return
  260. }
  261. //Return all the nodes in JSON format
  262. w.WriteHeader(http.StatusOK)
  263. json.NewEncoder(w).Encode(nodes)
  264. }
  265. //This function get's called when a node "checks in" at check in interval
  266. //Honestly I'm not sure what all it should be doing
  267. //TODO: Implement the necessary stuff, including the below
  268. //Check the last modified of the network
  269. //Check the last modified of the nodes
  270. //Write functions for responding to these two thingies
  271. func checkIn(w http.ResponseWriter, r *http.Request) {
  272. //TODO: Current thoughts:
  273. //Dont bother with a networklastmodified
  274. //Instead, implement a "configupdate" boolean on nodes
  275. //when there is a network update that requrires a config update, then the node will pull its new config
  276. // set header.
  277. w.Header().Set("Content-Type", "application/json")
  278. var params = mux.Vars(r)
  279. node, err := CheckIn(params["network"], params["macaddress"])
  280. if err != nil {
  281. returnErrorResponse(w, r, formatError(err, "internal"))
  282. return
  283. }
  284. w.WriteHeader(http.StatusOK)
  285. json.NewEncoder(w).Encode(node)
  286. }
  287. func CheckIn(network, macaddress string) (models.Node, error) {
  288. var node models.Node
  289. //Retrieves node with DB Call which is inefficient. Let's just get the time and set it.
  290. //node = functions.GetNodeByMacAddress(params["network"], params["macaddress"])
  291. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  292. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  293. filter := bson.M{"macaddress": macaddress, "network": network}
  294. //old code was inefficient, this is all we need.
  295. time := time.Now().Unix()
  296. //node.SetLastCheckIn()
  297. // prepare update model with new time
  298. update := bson.D{
  299. {"$set", bson.D{
  300. {"lastcheckin", time},
  301. }},
  302. }
  303. err := collection.FindOneAndUpdate(ctx, filter, update).Decode(&node)
  304. defer cancel()
  305. if err != nil {
  306. return models.Node{}, err
  307. }
  308. //TODO: check node last modified vs network last modified
  309. //Get Updated node to return
  310. node, err = GetNode(macaddress, network)
  311. if err != nil {
  312. return models.Node{}, err
  313. }
  314. return node, nil
  315. }
  316. //Get an individual node. Nothin fancy here folks.
  317. func getNode(w http.ResponseWriter, r *http.Request) {
  318. // set header.
  319. w.Header().Set("Content-Type", "application/json")
  320. var params = mux.Vars(r)
  321. node, err := GetNode(params["macaddress"], params["network"])
  322. if err != nil {
  323. returnErrorResponse(w, r, formatError(err, "internal"))
  324. return
  325. }
  326. w.WriteHeader(http.StatusOK)
  327. json.NewEncoder(w).Encode(node)
  328. }
  329. //Get the time that a network of nodes was last modified.
  330. //TODO: This needs to be refactored
  331. //Potential way to do this: On UpdateNode, set a new field for "LastModified"
  332. //If we go with the existing way, we need to at least set network.NodesLastModified on UpdateNode
  333. func getLastModified(w http.ResponseWriter, r *http.Request) {
  334. // set header.
  335. w.Header().Set("Content-Type", "application/json")
  336. var params = mux.Vars(r)
  337. network, err := GetLastModified(params["network"])
  338. if err != nil {
  339. returnErrorResponse(w, r, formatError(err, "internal"))
  340. return
  341. }
  342. w.WriteHeader(http.StatusOK)
  343. json.NewEncoder(w).Encode(network.NodesLastModified)
  344. }
  345. func GetLastModified(network string) (models.Network, error) {
  346. var net models.Network
  347. collection := mongoconn.Client.Database("netmaker").Collection("networks")
  348. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  349. filter := bson.M{"netid": network}
  350. err := collection.FindOne(ctx, filter).Decode(&net)
  351. defer cancel()
  352. if err != nil {
  353. fmt.Println(err)
  354. return models.Network{}, err
  355. }
  356. return net, nil
  357. }
  358. //This one's a doozy
  359. //To create a node
  360. //Must have valid key and be unique
  361. func createNode(w http.ResponseWriter, r *http.Request) {
  362. w.Header().Set("Content-Type", "application/json")
  363. var params = mux.Vars(r)
  364. var errorResponse = models.ErrorResponse{
  365. Code: http.StatusInternalServerError, Message: "W1R3: It's not you it's me.",
  366. }
  367. networkName := params["network"]
  368. //Check if network exists first
  369. //TODO: This is inefficient. Let's find a better way.
  370. //Just a few rows down we grab the network anyway
  371. networkexists, err := functions.NetworkExists(networkName)
  372. if err != nil {
  373. returnErrorResponse(w, r, formatError(err, "internal"))
  374. return
  375. } else if !networkexists {
  376. errorResponse = models.ErrorResponse{
  377. Code: http.StatusNotFound, Message: "W1R3: Network does not exist! ",
  378. }
  379. returnErrorResponse(w, r, errorResponse)
  380. return
  381. }
  382. var node models.Node
  383. //get node from body of request
  384. err = json.NewDecoder(r.Body).Decode(&node)
  385. if err != nil {
  386. returnErrorResponse(w, r, formatError(err, "internal"))
  387. return
  388. }
  389. node.Network = networkName
  390. network, err := node.GetNetwork()
  391. if err != nil {
  392. returnErrorResponse(w, r, formatError(err, "internal"))
  393. return
  394. }
  395. //Check to see if key is valid
  396. //TODO: Triple inefficient!!! This is the third call to the DB we make for networks
  397. validKey := functions.IsKeyValid(networkName, node.AccessKey)
  398. if !validKey {
  399. //Check to see if network will allow manual sign up
  400. //may want to switch this up with the valid key check and avoid a DB call that way.
  401. if *network.AllowManualSignUp {
  402. node.IsPending = true
  403. } else {
  404. errorResponse = models.ErrorResponse{
  405. Code: http.StatusUnauthorized, Message: "W1R3: Key invalid, or none provided.",
  406. }
  407. returnErrorResponse(w, r, errorResponse)
  408. return
  409. }
  410. }
  411. err = ValidateNodeCreate(networkName, node)
  412. if err != nil {
  413. returnErrorResponse(w, r, formatError(err, "badrequest"))
  414. return
  415. }
  416. node, err = CreateNode(node, networkName)
  417. if err != nil {
  418. returnErrorResponse(w, r, formatError(err, "internal"))
  419. return
  420. }
  421. w.WriteHeader(http.StatusOK)
  422. json.NewEncoder(w).Encode(node)
  423. }
  424. //Takes node out of pending state
  425. //TODO: May want to use cordon/uncordon terminology instead of "ispending".
  426. func uncordonNode(w http.ResponseWriter, r *http.Request) {
  427. var params = mux.Vars(r)
  428. w.Header().Set("Content-Type", "application/json")
  429. node, err := UncordonNode(params["network"], params["macaddress"])
  430. if err != nil {
  431. returnErrorResponse(w, r, formatError(err, "internal"))
  432. return
  433. }
  434. fmt.Println("Node " + node.Name + " uncordoned.")
  435. w.WriteHeader(http.StatusOK)
  436. json.NewEncoder(w).Encode("SUCCESS")
  437. }
  438. func UncordonNode(network, macaddress string) (models.Node, error) {
  439. node, err := functions.GetNodeByMacAddress(network, macaddress)
  440. if err != nil {
  441. return models.Node{}, err
  442. }
  443. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  444. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  445. // Create filter
  446. filter := bson.M{"macaddress": macaddress, "network": network}
  447. node.SetLastModified()
  448. fmt.Println("Uncordoning node " + node.Name)
  449. // prepare update model.
  450. update := bson.D{
  451. {"$set", bson.D{
  452. {"ispending", false},
  453. }},
  454. }
  455. err = collection.FindOneAndUpdate(ctx, filter, update).Decode(&node)
  456. defer cancel()
  457. if err != nil {
  458. return models.Node{}, err
  459. }
  460. return node, nil
  461. }
  462. func createGateway(w http.ResponseWriter, r *http.Request) {
  463. var gateway models.GatewayRequest
  464. var params = mux.Vars(r)
  465. w.Header().Set("Content-Type", "application/json")
  466. err := json.NewDecoder(r.Body).Decode(&gateway)
  467. if err != nil {
  468. returnErrorResponse(w, r, formatError(err, "internal"))
  469. return
  470. }
  471. gateway.NetID = params["network"]
  472. gateway.NodeID = params["macaddress"]
  473. node, err := CreateGateway(gateway)
  474. if err != nil {
  475. returnErrorResponse(w, r, formatError(err, "internal"))
  476. return
  477. }
  478. w.WriteHeader(http.StatusOK)
  479. json.NewEncoder(w).Encode(node)
  480. }
  481. func CreateGateway(gateway models.GatewayRequest) (models.Node, error) {
  482. node, err := functions.GetNodeByMacAddress(gateway.NetID, gateway.NodeID)
  483. if err != nil {
  484. return models.Node{}, err
  485. }
  486. err = ValidateGateway(gateway)
  487. if err != nil {
  488. return models.Node{}, err
  489. }
  490. var nodechange models.Node
  491. nodechange.IsGateway = true
  492. nodechange.GatewayRange = gateway.RangeString
  493. if gateway.PostUp == "" {
  494. nodechange.PostUp = "iptables -A FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -A POSTROUTING -o " + gateway.Interface + " -j MASQUERADE"
  495. } else {
  496. nodechange.PostUp = gateway.PostUp
  497. }
  498. if gateway.PostDown == "" {
  499. nodechange.PostDown = "iptables -D FORWARD -i " + node.Interface + " -j ACCEPT; iptables -t nat -D POSTROUTING -o " + gateway.Interface + " -j MASQUERADE"
  500. } else {
  501. nodechange.PostDown = gateway.PostDown
  502. }
  503. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  504. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  505. // Create filter
  506. filter := bson.M{"macaddress": gateway.NodeID, "network": gateway.NetID}
  507. nodechange.SetLastModified()
  508. // prepare update model.
  509. update := bson.D{
  510. {"$set", bson.D{
  511. {"postup", nodechange.PostUp},
  512. {"postdown", nodechange.PostDown},
  513. {"isgateway", nodechange.IsGateway},
  514. {"gatewayrange", nodechange.GatewayRange},
  515. {"lastmodified", nodechange.LastModified},
  516. }},
  517. }
  518. var nodeupdate models.Node
  519. err = collection.FindOneAndUpdate(ctx, filter, update).Decode(&nodeupdate)
  520. defer cancel()
  521. if err != nil {
  522. return models.Node{}, err
  523. }
  524. err = SetNetworkNodesLastModified(gateway.NetID)
  525. if err != nil {
  526. return models.Node{}, err
  527. }
  528. //Get updated values to return
  529. node, err = functions.GetNodeByMacAddress(gateway.NetID, gateway.NodeID)
  530. if err != nil {
  531. return models.Node{}, err
  532. }
  533. return node, nil
  534. }
  535. func ValidateGateway(gateway models.GatewayRequest) error {
  536. var err error
  537. isIp := functions.IsIpCIDR(gateway.RangeString)
  538. empty := gateway.RangeString == ""
  539. if empty || !isIp {
  540. err = errors.New("IP Range Not Valid")
  541. }
  542. empty = gateway.Interface == ""
  543. if empty {
  544. err = errors.New("Interface cannot be empty")
  545. }
  546. return err
  547. }
  548. func deleteGateway(w http.ResponseWriter, r *http.Request) {
  549. w.Header().Set("Content-Type", "application/json")
  550. var params = mux.Vars(r)
  551. node, err := DeleteGateway(params["network"], params["macaddress"])
  552. if err != nil {
  553. returnErrorResponse(w, r, formatError(err, "internal"))
  554. return
  555. }
  556. w.WriteHeader(http.StatusOK)
  557. json.NewEncoder(w).Encode(node)
  558. }
  559. func DeleteGateway(network, macaddress string) (models.Node, error) {
  560. var nodeupdate models.Node
  561. var nodechange models.Node
  562. node, err := functions.GetNodeByMacAddress(network, macaddress)
  563. if err != nil {
  564. return models.Node{}, err
  565. }
  566. nodechange.IsGateway = false
  567. nodechange.GatewayRange = ""
  568. nodechange.PostUp = ""
  569. nodechange.PostDown = ""
  570. collection := mongoconn.Client.Database("netmaker").Collection("nodes")
  571. ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  572. // Create filter
  573. filter := bson.M{"macaddress": macaddress, "network": network}
  574. nodechange.SetLastModified()
  575. // prepare update model.
  576. update := bson.D{
  577. {"$set", bson.D{
  578. {"postup", nodechange.PostUp},
  579. {"postdown", nodechange.PostDown},
  580. {"isgateway", nodechange.IsGateway},
  581. {"gatewayrange", nodechange.GatewayRange},
  582. {"lastmodified", nodechange.LastModified},
  583. }},
  584. }
  585. err = collection.FindOneAndUpdate(ctx, filter, update).Decode(&nodeupdate)
  586. defer cancel()
  587. if err != nil {
  588. return models.Node{}, err
  589. }
  590. err = SetNetworkNodesLastModified(network)
  591. if err != nil {
  592. return models.Node{}, err
  593. }
  594. //Get updated values to return
  595. node, err = functions.GetNodeByMacAddress(network, macaddress)
  596. if err != nil {
  597. return models.Node{}, err
  598. }
  599. return node, nil
  600. }
  601. func updateNode(w http.ResponseWriter, r *http.Request) {
  602. w.Header().Set("Content-Type", "application/json")
  603. var params = mux.Vars(r)
  604. //Get id from parameters
  605. //id, _ := primitive.ObjectIDFromHex(params["id"])
  606. var node models.Node
  607. //start here
  608. node, err := functions.GetNodeByMacAddress(params["network"], params["macaddress"])
  609. if err != nil {
  610. returnErrorResponse(w, r, formatError(err, "internal"))
  611. return
  612. }
  613. var nodechange models.NodeUpdate
  614. // we decode our body request params
  615. _ = json.NewDecoder(r.Body).Decode(&nodechange)
  616. if nodechange.Network == "" {
  617. nodechange.Network = node.Network
  618. }
  619. if nodechange.MacAddress == "" {
  620. nodechange.MacAddress = node.MacAddress
  621. }
  622. err = ValidateNodeUpdate(params["network"], nodechange)
  623. if err != nil {
  624. returnErrorResponse(w, r, formatError(err, "badrequest"))
  625. return
  626. }
  627. node, err = UpdateNode(nodechange, node)
  628. if err != nil {
  629. returnErrorResponse(w, r, formatError(err, "internal"))
  630. return
  631. }
  632. w.WriteHeader(http.StatusOK)
  633. json.NewEncoder(w).Encode(node)
  634. }
  635. //Delete a node
  636. //Pretty straightforward
  637. func deleteNode(w http.ResponseWriter, r *http.Request) {
  638. // Set header
  639. w.Header().Set("Content-Type", "application/json")
  640. // get params
  641. var params = mux.Vars(r)
  642. success, err := DeleteNode(params["macaddress"], params["network"])
  643. if err != nil {
  644. returnErrorResponse(w, r, formatError(err, "internal"))
  645. return
  646. } else if !success {
  647. err = errors.New("Could not delete node " + params["macaddress"])
  648. returnErrorResponse(w, r, formatError(err, "internal"))
  649. return
  650. }
  651. returnSuccessResponse(w, r, params["macaddress"]+" deleted.")
  652. }