diff options
author | 2019-07-16 00:52:24 +0000 | |
---|---|---|
committer | 2019-07-16 00:52:24 +0000 | |
commit | ba4a7991e10172a31cec65ae5c9ad11cbb1b806b (patch) | |
tree | c4e14b0cc27dece033e672833ec2040120ef77cb /src/k8splugin/internal | |
parent | 70f54e61d7081507760a8d876e13b2088f9ff58f (diff) | |
parent | 6b911a5168a72e8659309db7349750cdec6eb8d2 (diff) |
Merge "Move connectionhandler.go into api package"
Diffstat (limited to 'src/k8splugin/internal')
-rw-r--r-- | src/k8splugin/internal/connection/connectionhandler.go | 144 |
1 files changed, 0 insertions, 144 deletions
diff --git a/src/k8splugin/internal/connection/connectionhandler.go b/src/k8splugin/internal/connection/connectionhandler.go deleted file mode 100644 index 8c860d31..00000000 --- a/src/k8splugin/internal/connection/connectionhandler.go +++ /dev/null @@ -1,144 +0,0 @@ -/* - * Copyright 2018 Intel Corporation, Inc - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package connection - -import ( - "bytes" - "encoding/base64" - "encoding/json" - "io" - "io/ioutil" - "net/http" - - "github.com/gorilla/mux" -) - -// ConnectionHandler is used to store backend implementations objects -// Also simplifies mocking for unit testing purposes -type ConnectionHandler struct { - // Interface that implements Connectivity operations - // We will set this variable with a mock interface for testing - Client ConnectionManager -} - -// CreateHandler handles creation of the connectivity entry in the database -// This is a multipart handler. See following example curl request -// curl -i -F "metadata={\"cloud-region\":\"kud\",\"cloud-owner\":\"me\"};type=application/json" \ -// -F file=@/home/user/.kube/config \ -// -X POST http://localhost:8081/v1/connectivity-info -func (h ConnectionHandler) CreateHandler(w http.ResponseWriter, r *http.Request) { - var v Connection - - // Implemenation using multipart form - // Review and enable/remove at a later date - // Set Max size to 16mb here - err := r.ParseMultipartForm(16777216) - if err != nil { - http.Error(w, err.Error(), http.StatusUnprocessableEntity) - return - } - - jsn := bytes.NewBuffer([]byte(r.FormValue("metadata"))) - err = json.NewDecoder(jsn).Decode(&v) - switch { - case err == io.EOF: - http.Error(w, "Empty body", http.StatusBadRequest) - return - case err != nil: - http.Error(w, err.Error(), http.StatusUnprocessableEntity) - return - } - - // Name is required. - if v.CloudRegion == "" { - http.Error(w, "Missing name in POST request", http.StatusBadRequest) - return - } - - // Cloudowner is required. - if v.CloudOwner == "" { - http.Error(w, "Missing cloudowner in POST request", http.StatusBadRequest) - return - } - - //Read the file section and ignore the header - file, _, err := r.FormFile("file") - if err != nil { - http.Error(w, "Unable to process file", http.StatusUnprocessableEntity) - return - } - - defer file.Close() - - //Convert the file content to base64 for storage - content, err := ioutil.ReadAll(file) - if err != nil { - http.Error(w, "Unable to read file", http.StatusUnprocessableEntity) - return - } - - v.Kubeconfig = base64.StdEncoding.EncodeToString(content) - - ret, err := h.Client.Create(v) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - - w.Header().Set("Content-Type", "application/json") - w.WriteHeader(http.StatusCreated) - err = json.NewEncoder(w).Encode(ret) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } -} - -// getHandler handles GET operations on a particular name -// Returns a Connectivity instance -func (h ConnectionHandler) GetHandler(w http.ResponseWriter, r *http.Request) { - vars := mux.Vars(r) - name := vars["connname"] - - ret, err := h.Client.Get(name) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - - w.Header().Set("Content-Type", "application/json") - w.WriteHeader(http.StatusOK) - err = json.NewEncoder(w).Encode(ret) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } -} - -// deleteHandler handles DELETE operations on a particular record -func (h ConnectionHandler) DeleteHandler(w http.ResponseWriter, r *http.Request) { - vars := mux.Vars(r) - name := vars["connname"] - - err := h.Client.Delete(name) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - - w.WriteHeader(http.StatusNoContent) -} |