Uniform formatting and volume as hostpath
[ealt-edge.git] / mecm / mepm / applcm / broker / pkg / handlers / handlers.go
1 /*
2  * Copyright 2020 Huawei Technologies Co., Ltd.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package handlers
17
18 import (
19         "net/http"
20         "os"
21
22         "github.com/gorilla/mux"
23         "github.com/sirupsen/logrus"
24 )
25
26 // URLS
27 const (
28         CreateAppInstance           = "/ealtedge/mepm/app_lcm/v1/app_instances"
29         InstantiateAppInstance      = "/ealtedge/mepm/app_lcm/v1/app_instances/{appInstanceId}/instantiate"
30         QueryAppInstanceInfo        = "/ealtedge/mepm/app_lcm/v1/app_instances/{appInstanceId}"
31         QueryAppLcmOperationStatus  = "/ealtedge/mepm/app_lcm/v1/app_lcm_op_occs"
32         TerminateAppIns             = "/ealtedge/mepm/app_lcm/v1/app_instances/{appInstanceId}/terminate"
33         DeleteAppInstanceIdentifier = "/ealtedge/mepm/app_lcm/v1/app_instances/{appInstanceId}"
34         OnboardPackage              = "/ealtedge/mepm/app_pkgm/v1/app_packages"
35         QueryOnboardPackage         = "/ealtedge/mepm/app_pkgm/v1/app_packages/{appPkgId}"
36 )
37
38 var (
39         PackageFolderPath   = os.Getenv("PACKAGE_PATH")
40         PackageArtifactPath = os.Getenv("PACKAGE_ARTIFACT_PATH")
41 )
42
43 // Handler of REST APIs
44 type Handlers struct {
45         router *mux.Router
46         logger *logrus.Logger
47         impl   HandlerImpl
48 }
49
50 // Initialize initializes the handler
51 func (hdlr *Handlers) Initialize(logger *logrus.Logger) {
52         hdlr.router = mux.NewRouter()
53         hdlr.logger = logger
54         hdlr.setRouters()
55         hdlr.impl = newHandlerImpl(hdlr.logger)
56 }
57
58 // Run on it's router
59 func (hdlr *Handlers) Run(host string) {
60         hdlr.logger.Infof("Server is running on port %s", host)
61         err := http.ListenAndServe(host, hdlr.router)
62         if err != nil {
63                 hdlr.logger.Fatalf("Server couldn't run on port %s", host)
64         }
65 }
66
67 // SetRouters sets the all required routers
68 func (hdlr *Handlers) setRouters() {
69         // Routing for handling the requests
70         hdlr.Post(OnboardPackage, hdlr.handleRequest(hdlr.impl.UploadPackage))
71         hdlr.Get(QueryOnboardPackage, hdlr.handleRequest(hdlr.impl.QueryAppPackageInfo))
72         hdlr.Post(CreateAppInstance, hdlr.handleRequest(hdlr.impl.CreateAppInstance))
73         hdlr.Delete(QueryOnboardPackage, hdlr.handleRequest(hdlr.impl.DeleteAppPackage))
74         hdlr.Post(InstantiateAppInstance, hdlr.handleRequest(hdlr.impl.InstantiateAppInstance))
75         hdlr.Get(QueryAppInstanceInfo, hdlr.handleRequest(hdlr.impl.QueryAppInstanceInfo))
76         hdlr.Get(QueryAppLcmOperationStatus, hdlr.handleRequest(hdlr.impl.QueryAppLcmOperationStatus))
77         hdlr.Post(TerminateAppIns, hdlr.handleRequest(hdlr.impl.TerminateAppInstance))
78         hdlr.Delete(DeleteAppInstanceIdentifier, hdlr.handleRequest(hdlr.impl.DeleteAppInstanceIdentifier))
79 }
80
81 // Get wraps the router for GET method
82 func (hdlr *Handlers) Get(path string, f func(w http.ResponseWriter, r *http.Request)) {
83         hdlr.router.HandleFunc(path, f).Methods("GET")
84 }
85
86 // Post wraps the router for POST method
87 func (hdlr *Handlers) Post(path string, f func(w http.ResponseWriter, r *http.Request)) {
88         hdlr.router.HandleFunc(path, f).Methods("POST")
89 }
90
91 // Put wraps the router for PUT method
92 func (hdlr *Handlers) Put(path string, f func(w http.ResponseWriter, r *http.Request)) {
93         hdlr.router.HandleFunc(path, f).Methods("PUT")
94 }
95
96 // Delete wraps the router for DELETE method
97 func (hdlr *Handlers) Delete(path string, f func(w http.ResponseWriter, r *http.Request)) {
98         hdlr.router.HandleFunc(path, f).Methods("DELETE")
99 }
100
101 type RequestHandlerFunction func(w http.ResponseWriter, r *http.Request)
102
103 func (hdlr *Handlers) handleRequest(handler RequestHandlerFunction) http.HandlerFunc {
104         return func(w http.ResponseWriter, r *http.Request) {
105                 handler(w, r)
106         }
107 }