controller.go 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. package controller
  2. import (
  3. "context"
  4. "log"
  5. "net/http"
  6. "os"
  7. "os/signal"
  8. "sync"
  9. "github.com/gorilla/handlers"
  10. "github.com/gorilla/mux"
  11. "github.com/gravitl/netmaker/servercfg"
  12. )
  13. // HandleRESTRequests - handles the rest requests
  14. func HandleRESTRequests(wg *sync.WaitGroup) {
  15. defer wg.Done()
  16. r := mux.NewRouter()
  17. // Currently allowed dev origin is all. Should change in prod
  18. // should consider analyzing the allowed methods further
  19. headersOk := handlers.AllowedHeaders([]string{"Access-Control-Allow-Origin", "X-Requested-With", "Content-Type", "authorization"})
  20. originsOk := handlers.AllowedOrigins([]string{servercfg.GetAllowedOrigin()})
  21. methodsOk := handlers.AllowedMethods([]string{"GET", "PUT", "POST", "DELETE"})
  22. nodeHandlers(r)
  23. userHandlers(r)
  24. networkHandlers(r)
  25. dnsHandlers(r)
  26. fileHandlers(r)
  27. serverHandlers(r)
  28. extClientHandlers(r)
  29. port := servercfg.GetAPIPort()
  30. srv := &http.Server{Addr: ":" + port, Handler: handlers.CORS(originsOk, headersOk, methodsOk)(r)}
  31. go func() {
  32. err := srv.ListenAndServe()
  33. if err != nil {
  34. log.Println(err)
  35. }
  36. }()
  37. log.Println("REST Server successfully started on port " + port + " (REST)")
  38. c := make(chan os.Signal)
  39. // Relay os.Interrupt to our channel (os.Interrupt = CTRL+C)
  40. // Ignore other incoming signals
  41. signal.Notify(c, os.Interrupt)
  42. // Block main routine until a signal is received
  43. // As long as user doesn't press CTRL+C a message is not passed and our main routine keeps running
  44. <-c
  45. // After receiving CTRL+C Properly stop the server
  46. log.Println("Stopping the REST server...")
  47. srv.Shutdown(context.TODO())
  48. log.Println("REST Server closed.")
  49. }