package controller
import (
"fmt"
"net/http"
"github.com/goodrain/rainbond/api/handler"
api_model "github.com/goodrain/rainbond/api/model"
"github.com/goodrain/rainbond/mq/client"
httputil "github.com/goodrain/rainbond/util/http"
)
type RegistryAuthSecretStruct struct {
MQClient client.MQClient
}
func (g *RegistryAuthSecretStruct) RegistryAuthSecret(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "POST", "PUT":
g.addOrUpdateRegistryAuthSecret(w, r)
case "DELETE":
g.deleteRegistryAuthSecret(w, r)
}
}
func (g *RegistryAuthSecretStruct) addOrUpdateRegistryAuthSecret(w http.ResponseWriter, r *http.Request) {
var req api_model.AddOrUpdateRegistryAuthSecretStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetRegistryAuthSecretHandler()
err := h.AddOrUpdateRegistryAuthSecret(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while adding auth secret: %v", err))
return
}
httputil.ReturnSuccess(r, w, req)
}
func (g *RegistryAuthSecretStruct) deleteRegistryAuthSecret(w http.ResponseWriter, r *http.Request) {
var req api_model.DeleteRegistryAuthSecretStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetRegistryAuthSecretHandler()
err := h.DeleteRegistryAuthSecret(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while delete registry auth secret: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}