controller.go 1.6 KB

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