sms-service/src/sms/handler/handler.go

   1 /*
   2  * Copyright 2018 Intel Corporation, Inc
   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
  17 package handler
  18
  19 import (
  20         "encoding/json"
  21         "fmt"
  22         "github.com/gorilla/mux"
  23         "net/http"
  24
  25         smsbackend "sms/backend"
  26 )
  27
  28 // handler stores two interface implementations that implement
  29 // the backend functionality
  30 type handler struct {
  31         secretBackend smsbackend.SecretBackend
  32         loginBackend  smsbackend.LoginBackend
  33 }
  34
  35 // createSecretDomainHandler creates a secret domain with a name provided
  36 func (h handler) createSecretDomainHandler(w http.ResponseWriter, r *http.Request) {
  37         var d smsbackend.SecretDomain
  38
  39         err := json.NewDecoder(r.Body).Decode(&d)
  40         if err != nil {
  41                 http.Error(w, err.Error(), 400)
  42                 return
  43         }
  44
  45         dom, err := h.secretBackend.CreateSecretDomain(d.Name)
  46         if err != nil {
  47                 http.Error(w, err.Error(), 500)
  48                 return
  49         }
  50
  51         err = json.NewEncoder(w).Encode(dom)
  52         if err != nil {
  53                 http.Error(w, err.Error(), 400)
  54                 return
  55         }
  56 }
  57
  58 // getSecretDomainHandler returns list of secret domains
  59 func (h handler) getSecretDomainHandler(w http.ResponseWriter, r *http.Request) {
  60         vars := mux.Vars(r)
  61         domName := vars["domName"]
  62
  63         fmt.Fprintf(w, "Got req %s", domName)
  64         //h.secretBackend.GetSecretDomain(domName)
  65         //encode data into json and return
  66 }
  67
  68 // deleteSecretDomainHandler deletes a secret domain with the name provided
  69 func (h handler) deleteSecretDomainHandler(w http.ResponseWriter, r *http.Request) {
  70         vars := mux.Vars(r)
  71         domName := vars["domName"]
  72
  73         h.secretBackend.DeleteSecretDomain(domName)
  74 }
  75
  76 // createSecretHandler handles creation of secrets on a given domain name
  77 func (h handler) createSecretHandler(w http.ResponseWriter, r *http.Request) {
  78         // Get domain name from URL
  79         vars := mux.Vars(r)
  80         domName := vars["domName"]
  81
  82         // Get secrets to be stored from body
  83         var b smsbackend.Secret
  84         err := json.NewDecoder(r.Body).Decode(&b)
  85         if err != nil {
  86                 http.Error(w, err.Error(), 400)
  87                 return
  88         }
  89
  90         err = h.secretBackend.CreateSecret(domName, b)
  91         if err != nil {
  92                 http.Error(w, err.Error(), 500)
  93                 return
  94         }
  95
  96         w.WriteHeader(http.StatusCreated)
  97 }
  98
  99 // getSecretHandler handles reading a secret by given domain name and secret name
 100 func (h handler) getSecretHandler(w http.ResponseWriter, r *http.Request) {
 101         vars := mux.Vars(r)
 102         domName := vars["domName"]
 103         secName := vars["secretName"]
 104
 105         sec, err := h.secretBackend.GetSecret(domName, secName)
 106         if err != nil {
 107                 http.Error(w, err.Error(), 500)
 108                 return
 109         }
 110
 111         err = json.NewEncoder(w).Encode(sec)
 112         if err != nil {
 113                 http.Error(w, err.Error(), 400)
 114                 return
 115         }
 116 }
 117
 118 // listSecretHandler handles listing all secrets under a particular domain name
 119 func (h handler) listSecretHandler(w http.ResponseWriter, r *http.Request) {
 120         vars := mux.Vars(r)
 121         domName := vars["domName"]
 122
 123         sec, err := h.secretBackend.ListSecret(domName)
 124         if err != nil {
 125                 http.Error(w, err.Error(), http.StatusInternalServerError)
 126                 return
 127         }
 128
 129         err = json.NewEncoder(w).Encode(sec)
 130         if err != nil {
 131                 http.Error(w, err.Error(), http.StatusInternalServerError)
 132                 return
 133         }
 134 }
 135
 136 // deleteSecretHandler handles deleting a secret by given domain name and secret name
 137 func (h handler) deleteSecretHandler(w http.ResponseWriter, r *http.Request) {
 138         vars := mux.Vars(r)
 139         domName := vars["domName"]
 140         secName := vars["secretName"]
 141
 142         h.secretBackend.DeleteSecret(domName, secName)
 143 }
 144
 145 // struct that tracks various status items for SMS and backend
 146 type backendStatus struct {
 147         Seal bool `json:"sealstatus"`
 148 }
 149
 150 // statusHandler returns information related to SMS and SMS backend services
 151 func (h handler) statusHandler(w http.ResponseWriter, r *http.Request) {
 152         s, err := h.secretBackend.GetStatus()
 153         if err != nil {
 154                 http.Error(w, err.Error(), 500)
 155                 return
 156         }
 157
 158         status := backendStatus{Seal: s}
 159         err = json.NewEncoder(w).Encode(status)
 160         if err != nil {
 161                 http.Error(w, err.Error(), 500)
 162                 return
 163         }
 164 }
 165
 166 // loginHandler handles login via password and username
 167 func (h handler) loginHandler(w http.ResponseWriter, r *http.Request) {
 168
 169 }
 170
 171 // initSMSHandler
 172 func (h handler) initSMSHandler(w http.ResponseWriter, r *http.Request) {
 173
 174 }
 175
 176 // unsealHandler
 177 func (h handler) unsealHandler(w http.ResponseWriter, r *http.Request) {
 178
 179 }
 180
 181 // CreateRouter returns an http.Handler for the registered URLs
 182 // Takes an interface implementation as input
 183 func CreateRouter(b smsbackend.SecretBackend) http.Handler {
 184         h := handler{secretBackend: b}
 185
 186         // Create a new mux to handle URL endpoints
 187         router := mux.NewRouter()
 188
 189         router.HandleFunc("/v1/sms/login", h.loginHandler).Methods("POST")
 190
 191         // Initialization APIs which will be used by quorum client
 192         // to unseal and to provide root token to sms service
 193         router.HandleFunc("/v1/sms/status", h.statusHandler).Methods("GET")
 194         router.HandleFunc("/v1/sms/unseal", h.unsealHandler).Methods("POST")
 195         router.HandleFunc("/v1/sms/init", h.initSMSHandler).Methods("POST")
 196
 197         router.HandleFunc("/v1/sms/domain", h.createSecretDomainHandler).Methods("POST")
 198         router.HandleFunc("/v1/sms/domain/{domName}", h.getSecretDomainHandler).Methods("GET")
 199         router.HandleFunc("/v1/sms/domain/{domName}", h.deleteSecretDomainHandler).Methods("DELETE")
 200
 201         router.HandleFunc("/v1/sms/domain/{domName}/secret", h.createSecretHandler).Methods("POST")
 202         router.HandleFunc("/v1/sms/domain/{domName}/secret", h.listSecretHandler).Methods("GET")
 203         router.HandleFunc("/v1/sms/domain/{domName}/secret/{secretName}", h.getSecretHandler).Methods("GET")
 204         router.HandleFunc("/v1/sms/domain/{domName}/secret/{secretName}", h.deleteSecretHandler).Methods("DELETE")
 205
 206         return router
 207 }