controller.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package controller
  2. import (
  3. "context"
  4. "fmt"
  5. "net/http"
  6. "strings"
  7. "sync"
  8. "time"
  9. "github.com/gorilla/handlers"
  10. "github.com/gorilla/mux"
  11. "github.com/gravitl/netmaker/logger"
  12. "github.com/gravitl/netmaker/servercfg"
  13. )
  14. // HttpHandlers - handler functions for REST interactions
  15. var HttpHandlers = []interface{}{
  16. nodeHandlers,
  17. userHandlers,
  18. networkHandlers,
  19. dnsHandlers,
  20. fileHandlers,
  21. serverHandlers,
  22. extClientHandlers,
  23. ipHandlers,
  24. loggerHandlers,
  25. hostHandlers,
  26. enrollmentKeyHandlers,
  27. }
  28. // HandleRESTRequests - handles the rest requests
  29. func HandleRESTRequests(wg *sync.WaitGroup, ctx context.Context) {
  30. defer wg.Done()
  31. r := mux.NewRouter()
  32. // Currently allowed dev origin is all. Should change in prod
  33. // should consider analyzing the allowed methods further
  34. headersOk := handlers.AllowedHeaders([]string{"Access-Control-Allow-Origin", "X-Requested-With", "Content-Type", "authorization"})
  35. originsOk := handlers.AllowedOrigins(strings.Split(servercfg.GetAllowedOrigin(), ","))
  36. methodsOk := handlers.AllowedMethods([]string{http.MethodGet, http.MethodPut, http.MethodPost, http.MethodDelete})
  37. for _, handler := range HttpHandlers {
  38. handler.(func(*mux.Router))(r)
  39. }
  40. port := servercfg.GetAPIPort()
  41. srv := &http.Server{Addr: ":" + port, Handler: handlers.CORS(originsOk, headersOk, methodsOk)(r)}
  42. go func() {
  43. err := srv.ListenAndServe()
  44. if err != nil {
  45. logger.Log(0, err.Error())
  46. }
  47. }()
  48. logger.Log(0, "REST Server successfully started on port ", port, " (REST)")
  49. // Block main routine until a signal is received
  50. // As long as user doesn't press CTRL+C a message is not passed and our main routine keeps running
  51. <-ctx.Done()
  52. // After receiving CTRL+C Properly stop the server
  53. logger.Log(0, "Stopping the REST server...")
  54. if err := srv.Shutdown(context.TODO()); err != nil {
  55. logger.Log(0, "REST shutdown error occurred -", err.Error())
  56. }
  57. logger.Log(0, "REST Server closed.")
  58. logger.DumpFile(fmt.Sprintf("data/netmaker.log.%s", time.Now().Format(logger.TimeFormatDay)))
  59. }