Rainbond/api/controller/volume.go
2021-06-17 22:59:05 +08:00

482 lines
14 KiB
Go

// Copyright (C) 2014-2018 Goodrain Co., Ltd.
// RAINBOND, Application Management Platform
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version. For any non-GPL usage of Rainbond,
// one or multiple Commercial Licenses authorized by Goodrain Co., Ltd.
// must be obtained first.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package controller
import (
"net/http"
"strings"
"github.com/go-chi/chi"
"github.com/goodrain/rainbond/api/handler"
api_model "github.com/goodrain/rainbond/api/model"
ctxutil "github.com/goodrain/rainbond/api/util/ctx"
dbmodel "github.com/goodrain/rainbond/db/model"
httputil "github.com/goodrain/rainbond/util/http"
"github.com/sirupsen/logrus"
)
//VolumeDependency VolumeDependency
func (t *TenantStruct) VolumeDependency(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "DELETE":
t.DeleteVolumeDependency(w, r)
case "POST":
t.AddVolumeDependency(w, r)
}
}
//AddVolumeDependency add volume dependency
func (t *TenantStruct) AddVolumeDependency(w http.ResponseWriter, r *http.Request) {
// swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/volume-dependency v2 addVolumeDependency
//
// 增加应用持久化依赖
//
// add volume dependency
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
logrus.Debugf("trans add volumn dependency service ")
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
var tsr api_model.V2AddVolumeDependencyStruct
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &tsr.Body, nil); !ok {
return
}
vd := &dbmodel.TenantServiceMountRelation{
TenantID: tenantID,
ServiceID: serviceID,
DependServiceID: tsr.Body.DependServiceID,
HostPath: tsr.Body.MntDir,
VolumePath: tsr.Body.MntName,
}
if err := handler.GetServiceManager().VolumeDependency(vd, "add"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//DeleteVolumeDependency delete volume dependency
func (t *TenantStruct) DeleteVolumeDependency(w http.ResponseWriter, r *http.Request) {
// swagger:operation DELETE /v2/tenants/{tenant_name}/services/{service_alias}/volume-dependency v2 deleteVolumeDependency
//
// 删除应用持久化依赖
//
// delete volume dependency
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
var tsr api_model.V2DelVolumeDependencyStruct
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &tsr.Body, nil); !ok {
return
}
vd := &dbmodel.TenantServiceMountRelation{
TenantID: tenantID,
ServiceID: serviceID,
DependServiceID: tsr.Body.DependServiceID,
}
if err := handler.GetServiceManager().VolumeDependency(vd, "delete"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//AddVolume AddVolume
func (t *TenantStruct) AddVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/volume v2 addVolume
//
// 增加应用持久化信息
//
// add volume
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
avs := &api_model.V2AddVolumeStruct{}
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &avs.Body, nil); !ok {
return
}
tsv := &dbmodel.TenantServiceVolume{
ServiceID: serviceID,
VolumePath: avs.Body.VolumePath,
HostPath: avs.Body.HostPath,
Category: avs.Body.Category,
VolumeCapacity: avs.Body.VolumeCapacity,
VolumeType: dbmodel.ShareFileVolumeType.String(),
VolumeProviderName: avs.Body.VolumeProviderName,
AccessMode: avs.Body.AccessMode,
SharePolicy: avs.Body.SharePolicy,
BackupPolicy: avs.Body.BackupPolicy,
ReclaimPolicy: avs.Body.ReclaimPolicy,
}
if !strings.HasPrefix(tsv.VolumePath, "/") {
httputil.ReturnError(r, w, 400, "volume path is invalid,must begin with /")
return
}
if err := handler.GetServiceManager().VolumnVar(tsv, tenantID, "", "add"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
// UpdVolume updates service volume.
func (t *TenantStruct) UpdVolume(w http.ResponseWriter, r *http.Request) {
var req api_model.UpdVolumeReq
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil); !ok {
return
}
sid := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
if err := handler.GetServiceManager().UpdVolume(sid, &req); err != nil {
httputil.ReturnError(r, w, 500, err.Error())
}
httputil.ReturnSuccess(r, w, "success")
}
//DeleteVolume DeleteVolume
func (t *TenantStruct) DeleteVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation DELETE /v2/tenants/{tenant_name}/services/{service_alias}/volume v2 deleteVolume
//
// 删除应用持久化信息
//
// delete volume
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
avs := &api_model.V2DelVolumeStruct{}
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &avs.Body, nil); !ok {
return
}
tsv := &dbmodel.TenantServiceVolume{
ServiceID: serviceID,
VolumePath: avs.Body.VolumePath,
Category: avs.Body.Category,
}
if err := handler.GetServiceManager().VolumnVar(tsv, tenantID, "", "delete"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//以下为V2.1版本持久化API,支持多种持久化模式
//AddVolumeDependency add volume dependency
func AddVolumeDependency(w http.ResponseWriter, r *http.Request) {
// swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/depvolumes v2 addDepVolume
//
// 增加应用持久化依赖(V2.1支持多种类型存储)
//
// add volume dependency
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
logrus.Debugf("trans add volumn dependency service ")
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
var tsr api_model.AddVolumeDependencyStruct
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &tsr.Body, nil); !ok {
return
}
vd := &dbmodel.TenantServiceMountRelation{
TenantID: tenantID,
ServiceID: serviceID,
DependServiceID: tsr.Body.DependServiceID,
VolumeName: tsr.Body.VolumeName,
VolumePath: tsr.Body.VolumePath,
VolumeType: tsr.Body.VolumeType,
}
if err := handler.GetServiceManager().VolumeDependency(vd, "add"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//DeleteVolumeDependency delete volume dependency
func DeleteVolumeDependency(w http.ResponseWriter, r *http.Request) {
// swagger:operation DELETE /v2/tenants/{tenant_name}/services/{service_alias}/depvolumes v2 delDepVolume
//
// 删除应用持久化依赖(V2.1支持多种类型存储)
//
// delete volume dependency
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
var tsr api_model.DeleteVolumeDependencyStruct
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &tsr.Body, nil); !ok {
return
}
vd := &dbmodel.TenantServiceMountRelation{
TenantID: tenantID,
ServiceID: serviceID,
DependServiceID: tsr.Body.DependServiceID,
VolumeName: tsr.Body.VolumeName,
}
if err := handler.GetServiceManager().VolumeDependency(vd, "delete"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//AddVolume AddVolume
func AddVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/volumes v2 addVolumes
//
// 增加应用持久化信息(V2.1支持多种类型存储)
//
// add volume
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
avs := &api_model.AddVolumeStruct{}
if ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &avs.Body, nil); !ok {
return
}
tsv := &dbmodel.TenantServiceVolume{
ServiceID: serviceID,
VolumeName: avs.Body.VolumeName,
VolumePath: avs.Body.VolumePath,
VolumeType: avs.Body.VolumeType,
Category: avs.Body.Category,
VolumeProviderName: avs.Body.VolumeProviderName,
IsReadOnly: avs.Body.IsReadOnly,
VolumeCapacity: avs.Body.VolumeCapacity,
AccessMode: avs.Body.AccessMode,
SharePolicy: avs.Body.SharePolicy,
BackupPolicy: avs.Body.BackupPolicy,
ReclaimPolicy: avs.Body.ReclaimPolicy,
AllowExpansion: avs.Body.AllowExpansion,
}
// TODO fanyangyang validate VolumeCapacity AccessMode SharePolicy BackupPolicy ReclaimPolicy AllowExpansion
if !strings.HasPrefix(avs.Body.VolumePath, "/") {
httputil.ReturnError(r, w, 400, "volume path is invalid,must begin with /")
return
}
if err := handler.GetServiceManager().VolumnVar(tsv, tenantID, avs.Body.FileContent, "add"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//DeleteVolume DeleteVolume
func DeleteVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation DELETE /v2/tenants/{tenant_name}/services/{service_alias}/volumes/{volume_name} v2 deleteVolumes
//
// 删除应用持久化信息(V2.1支持多种类型存储)
//
// delete volume
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
tenantID := r.Context().Value(ctxutil.ContextKey("tenant_id")).(string)
tsv := &dbmodel.TenantServiceVolume{}
tsv.ServiceID = serviceID
tsv.VolumeName = chi.URLParam(r, "volume_name")
if err := handler.GetServiceManager().VolumnVar(tsv, tenantID, "", "delete"); err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, nil)
}
//GetVolume 获取应用全部存储,包括依赖的存储
func GetVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation GET /v2/tenants/{tenant_name}/services/{service_alias}/volumes v2 getVolumes
//
// 获取应用全部存储,包括依赖的存储(V2.1支持多种类型存储)
//
// get volumes
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
volumes, err := handler.GetServiceManager().GetVolumes(serviceID)
if err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, volumes)
}
//GetDepVolume 获取应用所有依赖的存储
func GetDepVolume(w http.ResponseWriter, r *http.Request) {
// swagger:operation GET /v2/tenants/{tenant_name}/services/{service_alias}/depvolumes v2 getDepVolumes
//
// 获取应用依赖的存储(V2.1支持多种类型存储)
//
// get depvolumes
//
// ---
// consumes:
// - application/json
// - application/x-protobuf
//
// produces:
// - application/json
// - application/xml
//
// responses:
// default:
// schema:
// "$ref": "#/responses/commandResponse"
// description: 统一返回格式
serviceID := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
volumes, err := handler.GetServiceManager().GetDepVolumes(serviceID)
if err != nil {
err.Handle(r, w)
return
}
httputil.ReturnSuccess(r, w, volumes)
}