2 * Copyright 2020 Huawei Technologies Co., Ltd.
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
22 "github.com/gorilla/mux"
23 "github.com/sirupsen/logrus"
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}"
39 PackageFolderPath = os.Getenv("PACKAGE_PATH")
40 PackageArtifactPath = os.Getenv("PACKAGE_ARTIFACT_PATH")
43 // Handler of REST APIs
44 type Handlers struct {
50 // Initialize initializes the handler
51 func (hdlr *Handlers) Initialize(logger *logrus.Logger) {
52 hdlr.router = mux.NewRouter()
55 hdlr.impl = newHandlerImpl(hdlr.logger)
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)
63 hdlr.logger.Fatalf("Server couldn't run on port %s", host)
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))
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")
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")
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")
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")
101 type RequestHandlerFunction func(w http.ResponseWriter, r *http.Request)
103 func (hdlr *Handlers) handleRequest(handler RequestHandlerFunction) http.HandlerFunc {
104 return func(w http.ResponseWriter, r *http.Request) {