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 // deleteSecretHandler handles deleting a secret by given domain name and secret name
 119 func (h handler) deleteSecretHandler(w http.ResponseWriter, r *http.Request) {
 120         vars := mux.Vars(r)
 121         domName := vars["domName"]
 122         secName := vars["secretName"]
 123
 124         h.secretBackend.DeleteSecret(domName, secName)
 125 }
 126
 127 // struct that tracks various status items for SMS and backend
 128 type backendStatus struct {
 129         Seal bool `json:"sealstatus"`
 130 }
 131
 132 // statusHandler returns information related to SMS and SMS backend services
 133 func (h handler) statusHandler(w http.ResponseWriter, r *http.Request) {
 134         s, err := h.secretBackend.GetStatus()
 135         if err != nil {
 136                 http.Error(w, err.Error(), 500)
 137                 return
 138         }
 139
 140         status := backendStatus{Seal: s}
 141         err = json.NewEncoder(w).Encode(status)
 142         if err != nil {
 143                 http.Error(w, err.Error(), 500)
 144                 return
 145         }
 146 }
 147
 148 // loginHandler handles login via password and username
 149 func (h handler) loginHandler(w http.ResponseWriter, r *http.Request) {
 150
 151 }
 152
 153 // initSMSHandler
 154 func (h handler) initSMSHandler(w http.ResponseWriter, r *http.Request) {
 155
 156 }
 157
 158 // unsealHandler
 159 func (h handler) unsealHandler(w http.ResponseWriter, r *http.Request) {
 160
 161 }
 162
 163 // CreateRouter returns an http.Handler for the registered URLs
 164 // Takes an interface implementation as input
 165 func CreateRouter(b smsbackend.SecretBackend) http.Handler {
 166         h := handler{secretBackend: b}
 167
 168         // Create a new mux to handle URL endpoints
 169         router := mux.NewRouter()
 170
 171         router.HandleFunc("/v1/sms/login", h.loginHandler).Methods("POST")
 172
 173         // Initialization APIs which will be used by quorum client
 174         // to unseal and to provide root token to sms service
 175         router.HandleFunc("/v1/sms/status", h.statusHandler).Methods("GET")
 176         router.HandleFunc("/v1/sms/unseal", h.unsealHandler).Methods("POST")
 177         router.HandleFunc("/v1/sms/init", h.initSMSHandler).Methods("POST")
 178
 179         router.HandleFunc("/v1/sms/domain", h.createSecretDomainHandler).Methods("POST")
 180         router.HandleFunc("/v1/sms/domain/{domName}", h.getSecretDomainHandler).Methods("GET")
 181         router.HandleFunc("/v1/sms/domain/{domName}", h.deleteSecretDomainHandler).Methods("DELETE")
 182
 183         router.HandleFunc("/v1/sms/domain/{domName}/secret", h.createSecretHandler).Methods("POST")
 184         router.HandleFunc("/v1/sms/domain/{domName}/secret/{secretName}", h.getSecretHandler).Methods("GET")
 185         router.HandleFunc("/v1/sms/domain/{domName}/secret/{secretName}", h.deleteSecretHandler).Methods("DELETE")
 186
 187         return router
 188 }