зеркало из https://github.com/Azure/ARO-RP.git
105 строки
3.2 KiB
Go
105 строки
3.2 KiB
Go
package frontend
|
|
|
|
// Copyright (c) Microsoft Corporation.
|
|
// Licensed under the Apache License 2.0.
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"path/filepath"
|
|
|
|
"github.com/sirupsen/logrus"
|
|
|
|
"github.com/Azure/ARO-RP/pkg/api"
|
|
"github.com/Azure/ARO-RP/pkg/api/admin"
|
|
"github.com/Azure/ARO-RP/pkg/frontend/middleware"
|
|
)
|
|
|
|
func (f *frontend) putAdminOpenShiftVersion(w http.ResponseWriter, r *http.Request) {
|
|
ctx := r.Context()
|
|
log := ctx.Value(middleware.ContextKeyLog).(*logrus.Entry)
|
|
r.URL.Path = filepath.Dir(r.URL.Path)
|
|
|
|
converter := f.apis[admin.APIVersion].OpenShiftVersionConverter
|
|
staticValidator := f.apis[admin.APIVersion].OpenShiftVersionStaticValidator
|
|
|
|
body := r.Context().Value(middleware.ContextKeyBody).([]byte)
|
|
if len(body) == 0 || !json.Valid(body) {
|
|
api.WriteError(w, http.StatusBadRequest, api.CloudErrorCodeInvalidRequestContent, "", "The request content was invalid and could not be deserialized.")
|
|
return
|
|
}
|
|
|
|
var ext *admin.OpenShiftVersion
|
|
err := json.Unmarshal(body, &ext)
|
|
if err != nil {
|
|
api.WriteError(w, http.StatusBadRequest, api.CloudErrorCodeInvalidRequestContent, "", "The request content could not be deserialized: "+err.Error())
|
|
return
|
|
}
|
|
|
|
dbOpenShiftVersions, err := f.dbGroup.OpenShiftVersions()
|
|
if err != nil {
|
|
api.WriteError(w, http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", err.Error())
|
|
return
|
|
}
|
|
|
|
docs, err := dbOpenShiftVersions.ListAll(ctx)
|
|
if err != nil {
|
|
api.WriteError(w, http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", "Internal server error.")
|
|
return
|
|
}
|
|
|
|
var versionDoc *api.OpenShiftVersionDocument
|
|
if docs != nil {
|
|
for _, doc := range docs.OpenShiftVersionDocuments {
|
|
if doc.OpenShiftVersion.Properties.Version == ext.Properties.Version {
|
|
// prevent disabling of the default installation version
|
|
if doc.OpenShiftVersion.Properties.Default && !ext.Properties.Enabled {
|
|
api.WriteError(w, http.StatusBadRequest, api.CloudErrorCodeInvalidParameter, "properties.enabled", "You cannot disable the default installation version.")
|
|
return
|
|
}
|
|
versionDoc = doc
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
isCreate := versionDoc == nil
|
|
if isCreate {
|
|
err = staticValidator.Static(ext, nil)
|
|
versionDoc = &api.OpenShiftVersionDocument{
|
|
ID: dbOpenShiftVersions.NewUUID(),
|
|
OpenShiftVersion: &api.OpenShiftVersion{},
|
|
}
|
|
} else {
|
|
err = staticValidator.Static(ext, versionDoc.OpenShiftVersion)
|
|
}
|
|
if err != nil {
|
|
adminReply(log, w, nil, []byte{}, err)
|
|
return
|
|
}
|
|
|
|
converter.ToInternal(ext, versionDoc.OpenShiftVersion)
|
|
|
|
if isCreate {
|
|
versionDoc, err = dbOpenShiftVersions.Create(ctx, versionDoc)
|
|
if err != nil {
|
|
api.WriteError(w, http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", "Internal server error.")
|
|
return
|
|
}
|
|
} else {
|
|
versionDoc, err = dbOpenShiftVersions.Update(ctx, versionDoc)
|
|
if err != nil {
|
|
api.WriteError(w, http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", "Internal server error.")
|
|
return
|
|
}
|
|
}
|
|
|
|
b, err := json.MarshalIndent(converter.ToExternal(versionDoc.OpenShiftVersion), "", " ")
|
|
if err == nil {
|
|
if isCreate {
|
|
err = statusCodeError(http.StatusCreated)
|
|
}
|
|
}
|
|
adminReply(log, w, nil, b, err)
|
|
}
|