| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 | package controllerimport (    "github.com/gravitl/netmaker/mongoconn"    "github.com/gravitl/netmaker/servercfg"    "os/signal"    "os"    "log"    "context"    "net/http"    "github.com/gorilla/mux"    "github.com/gorilla/handlers"    "sync")func HandleRESTRequests(wg *sync.WaitGroup) {    defer wg.Done()    r := mux.NewRouter()    // Currently allowed dev origin is all. Should change in prod    // should consider analyzing the allowed methods further    headersOk := handlers.AllowedHeaders([]string{"Access-Control-Allow-Origin", "X-Requested-With", "Content-Type", "authorization"})    originsOk := handlers.AllowedOrigins([]string{servercfg.GetAllowedOrigin()})    methodsOk := handlers.AllowedMethods([]string{"GET", "PUT", "POST", "DELETE"})    nodeHandlers(r)    userHandlers(r)    networkHandlers(r)    dnsHandlers(r)    fileHandlers(r)    serverHandlers(r)    extClientHandlers(r)    intClientHandlers(r)		port := servercfg.GetAPIPort()		srv := &http.Server{Addr: ":" + port, Handler: handlers.CORS(originsOk, headersOk, methodsOk)(r)}		go func(){		err := srv.ListenAndServe()		if err != nil {			log.Println(err)		}		}()		log.Println("REST Server succesfully started on port " + port + " (REST)")		c := make(chan os.Signal)		// Relay os.Interrupt to our channel (os.Interrupt = CTRL+C)		// Ignore other incoming signals		signal.Notify(c, os.Interrupt)		// Block main routine until a signal is received		// As long as user doesn't press CTRL+C a message is not passed and our main routine keeps running		<-c		// After receiving CTRL+C Properly stop the server		log.Println("Stopping the REST server...")		srv.Shutdown(context.TODO())                log.Println("REST Server closed.")		mongoconn.Client.Disconnect(context.TODO())}
 |