mirror of
https://github.com/kubevela/kubevela.git
synced 2026-08-27 16:17:34 +00:00
github-actions[bot]andyueyongyue
1c2df10299
Signed-off-by: yueyongyue <yueyongyue@sina.cn>
(cherry picked from commit a4a4d64729)
Co-authored-by: yueyongyue <yueyongyue@sina.cn>
651 lines
25 KiB
Go
651 lines
25 KiB
Go
/*
|
|
Copyright 2021 The KubeVela Authors.
|
|
|
|
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 api
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
|
|
restfulspec "github.com/emicklei/go-restful-openapi/v2"
|
|
"github.com/emicklei/go-restful/v3"
|
|
"github.com/kubevela/workflow/api/v1alpha1"
|
|
"github.com/pkg/errors"
|
|
"k8s.io/klog/v2"
|
|
|
|
"github.com/oam-dev/kubevela/pkg/apiserver/domain/model"
|
|
"github.com/oam-dev/kubevela/pkg/apiserver/domain/service"
|
|
apis "github.com/oam-dev/kubevela/pkg/apiserver/interfaces/api/dto/v1"
|
|
"github.com/oam-dev/kubevela/pkg/apiserver/utils/bcode"
|
|
)
|
|
|
|
const (
|
|
// Project is the project name key of query param
|
|
Project string = "projectName"
|
|
// Pipeline is the pipeline name of query param
|
|
Pipeline string = "pipelineName"
|
|
// PipelineRun is the pipeline run name of query param
|
|
PipelineRun string = "runName"
|
|
// ContextName is the context name of query param
|
|
ContextName string = "contextName"
|
|
)
|
|
|
|
func initPipelineRoutes(ws *restful.WebService, n *project) {
|
|
tags := []string{"pipeline"}
|
|
projParam := func(builder *restful.RouteBuilder) {
|
|
builder.Param(ws.PathParameter(Project, "project name").Required(true))
|
|
builder.Filter(n.projectCheckFilter)
|
|
}
|
|
pipelineParam := func(builder *restful.RouteBuilder) {
|
|
builder.Param(ws.PathParameter(Pipeline, "pipeline name").Required(true))
|
|
builder.Filter(n.pipelineCheckFilter)
|
|
}
|
|
ctxParam := func(builder *restful.RouteBuilder) {
|
|
builder.Param(ws.PathParameter(ContextName, "pipeline context name").Required(true))
|
|
builder.Filter(n.pipelineContextCheckFilter)
|
|
}
|
|
runParam := func(builder *restful.RouteBuilder) {
|
|
builder.Param(ws.PathParameter(PipelineRun, "pipeline run name").Required(true))
|
|
builder.Filter(n.pipelineRunCheckFilter)
|
|
}
|
|
meta := func(builder *restful.RouteBuilder) {
|
|
builder.Metadata(restfulspec.KeyOpenAPITags, tags)
|
|
}
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines").To(n.createPipeline).
|
|
Doc("create pipeline").
|
|
Reads(apis.CreatePipelineRequest{}).
|
|
Returns(200, "OK", apis.PipelineBase{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline", "create")).
|
|
Writes(apis.PipelineBase{}).Do(meta, projParam))
|
|
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}").To(n.getPipeline).
|
|
Doc("get pipeline").
|
|
Returns(200, "OK", apis.GetPipelineResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
// use Param instead of pipelineParam to get pipeline information
|
|
Param(ws.PathParameter(Pipeline, "pipeline name").Required(true)).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline", "detail")).
|
|
Writes(apis.GetPipelineResponse{}).Do(meta, projParam))
|
|
|
|
ws.Route(ws.PUT("/{projectName}/pipelines/{pipelineName}").To(n.updatePipeline).
|
|
Doc("update pipeline").
|
|
Reads(apis.UpdatePipelineRequest{}).
|
|
Returns(200, "OK", apis.PipelineBase{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline", "update")).
|
|
Writes(apis.PipelineBase{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.DELETE("/{projectName}/pipelines/{pipelineName}").To(n.deletePipeline).
|
|
Doc("delete pipeline").
|
|
Returns(200, "OK", apis.PipelineMetaResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline", "delete")).
|
|
Writes(apis.PipelineMetaResponse{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines/{pipelineName}/contexts").To(n.createContextValue).
|
|
Doc("create pipeline context values").
|
|
Reads(apis.CreateContextValuesRequest{}).
|
|
Returns(200, "OK", apis.Context{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/context", "create")).
|
|
Writes(apis.Context{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/contexts").To(n.listContextValues).
|
|
Doc("list pipeline context values").
|
|
Returns(200, "OK", apis.ListContextValueResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/context", "list")).
|
|
Writes(apis.ListContextValueResponse{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.PUT("/{projectName}/pipelines/{pipelineName}/contexts/{contextName}").To(n.updateContextValue).
|
|
Doc("update pipeline context value").
|
|
Reads(apis.UpdateContextValuesRequest{}).
|
|
Returns(200, "OK", apis.Context{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/context", "update")).
|
|
Writes(apis.Context{}).Do(meta, projParam, pipelineParam, ctxParam))
|
|
|
|
ws.Route(ws.DELETE("/{projectName}/pipelines/{pipelineName}/contexts/{contextName}").To(n.deleteContextValue).
|
|
Doc("delete pipeline context value").
|
|
Returns(200, "OK", apis.ContextNameResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/context", "delete")).
|
|
Writes(apis.ContextNameResponse{}).Do(meta, projParam, pipelineParam, ctxParam))
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines/{pipelineName}/run").To(n.runPipeline).
|
|
Doc("run pipeline").
|
|
Reads(apis.RunPipelineRequest{}).
|
|
Returns(200, "OK", apis.PipelineRun{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline", "run")).
|
|
Writes(apis.PipelineRunMeta{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs").To(n.listPipelineRuns).
|
|
Doc("list pipeline runs").
|
|
Param(ws.QueryParameter("status", "query identifier of the status").DataType("string")).
|
|
Returns(200, "OK", apis.ListPipelineRunResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "list")).
|
|
Writes(apis.ListPipelineRunResponse{}).Do(meta, projParam, pipelineParam))
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines/{pipelineName}/runs/{runName}/stop").To(n.stopPipeline).
|
|
Doc("stop pipeline run").
|
|
Returns(200, "OK", apis.PipelineRunMeta{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "stop")).
|
|
Writes(apis.PipelineRunMeta{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs/{runName}").To(n.getPipelineRun).
|
|
Doc("get pipeline run").
|
|
Returns(200, "OK", apis.PipelineRunBase{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "detail")).
|
|
Writes(apis.PipelineRunBase{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
ws.Route(ws.DELETE("/{projectName}/pipelines/{pipelineName}/runs/{runName}").To(n.deletePipelineRun).
|
|
Doc("delete pipeline run").
|
|
Returns(200, "OK", apis.PipelineRunMeta{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "delete")).
|
|
Writes(apis.PipelineRunMeta{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
// get pipeline run status
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs/{runName}/status").To(n.getPipelineRunStatus).
|
|
Doc("get pipeline run status").
|
|
Returns(200, "OK", v1alpha1.WorkflowRunStatus{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "detail")).
|
|
Writes(v1alpha1.WorkflowRunStatus{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
// get pipeline run log
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs/{runName}/log").To(n.getPipelineRunLog).
|
|
Doc("get pipeline run log").
|
|
Param(ws.QueryParameter("step", "query by specific step name").DataType("string")).
|
|
Returns(200, "OK", apis.GetPipelineRunLogResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "detail")).
|
|
Writes(apis.GetPipelineRunLogResponse{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
// get pipeline run output
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs/{runName}/output").To(n.getPipelineRunOutput).
|
|
Doc("get pipeline run output").
|
|
Param(ws.QueryParameter("step", "query by specific step name").DataType("string").Required(true)).
|
|
Returns(200, "OK", apis.GetPipelineRunOutputResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "detail")).
|
|
Writes(apis.GetPipelineRunOutputResponse{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
// get pipeline run input
|
|
ws.Route(ws.GET("/{projectName}/pipelines/{pipelineName}/runs/{runName}/input").To(n.getPipelineRunInput).
|
|
Doc("get pipeline run input").
|
|
Param(ws.QueryParameter("step", "query by specific step name").DataType("string").Required(true)).
|
|
Returns(200, "OK", apis.GetPipelineRunInputResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "detail")).
|
|
Writes(apis.GetPipelineRunInputResponse{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines/{pipelineName}/runs/{runName}/resume").To(n.resumePipelineRun).
|
|
Doc("resume suspend pipeline run").
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "resume")).
|
|
Returns(200, "OK", apis.EmptyResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Writes(apis.EmptyResponse{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
ws.Route(ws.POST("/{projectName}/pipelines/{pipelineName}/runs/{runName}/terminate").To(n.terminatePipelineRun).
|
|
Doc("resume suspend pipeline run").
|
|
Filter(n.RBACService.CheckPerm("project/pipeline/pipelineRun", "terminate")).
|
|
Returns(200, "OK", apis.EmptyResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Writes(apis.EmptyResponse{}).Do(meta, projParam, pipelineParam, runParam))
|
|
|
|
ws.Filter(authCheckFilter)
|
|
}
|
|
|
|
// GetWebServiceRoute is the implementation of pipeline Interface
|
|
func (n *pipeline) GetWebServiceRoute() *restful.WebService {
|
|
tags := []string{"pipeline"}
|
|
meta := func(builder *restful.RouteBuilder) {
|
|
builder.Metadata(restfulspec.KeyOpenAPITags, tags)
|
|
}
|
|
|
|
ws := new(restful.WebService)
|
|
|
|
ws.Path(versionPrefix+"/pipelines").
|
|
Consumes(restful.MIME_XML, restful.MIME_JSON).
|
|
Produces(restful.MIME_JSON, restful.MIME_XML).
|
|
Doc("api for project manage")
|
|
|
|
ws.Route(ws.GET("").To(n.listPipelines).
|
|
Doc("list pipelines").
|
|
Param(ws.QueryParameter("query", "Fuzzy search based on name or description").DataType("string")).
|
|
Param(ws.QueryParameter("projectName", "query pipelines within a project").DataType("string")).
|
|
Param(ws.QueryParameter("detailed", "query pipelines with detail").DataType("boolean").DefaultValue("true")).
|
|
Returns(200, "OK", apis.ListPipelineResponse{}).
|
|
Returns(400, "Bad Request", bcode.Bcode{}).
|
|
Writes(apis.ListPipelineResponse{}).Do(meta))
|
|
|
|
ws.Filter(authCheckFilter)
|
|
return ws
|
|
}
|
|
|
|
type pipeline struct {
|
|
PipelineService service.PipelineService `inject:""`
|
|
}
|
|
|
|
// NewPipeline new pipeline manage
|
|
func NewPipeline() Interface {
|
|
return &pipeline{}
|
|
}
|
|
|
|
func (n *pipeline) listPipelines(req *restful.Request, res *restful.Response) {
|
|
var projectNames []string
|
|
if req.QueryParameter(Project) != "" {
|
|
projectNames = append(projectNames, req.QueryParameter(Project))
|
|
}
|
|
_detailed := req.QueryParameter("detailed")
|
|
if _detailed == "" {
|
|
_detailed = "true"
|
|
}
|
|
detailed, err := strconv.ParseBool(_detailed)
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, errors.Wrap(err, "invalid detailed param"))
|
|
}
|
|
pipelines, err := n.PipelineService.ListPipelines(req.Request.Context(), apis.ListPipelineRequest{
|
|
Projects: projectNames,
|
|
Query: req.QueryParameter("query"),
|
|
Detailed: detailed,
|
|
})
|
|
if err != nil {
|
|
klog.Errorf("list pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelines); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipeline(req *restful.Request, res *restful.Response) {
|
|
pipeline, err := n.PipelineService.GetPipeline(req.Request.Context(), req.PathParameter(Pipeline), true)
|
|
if err != nil {
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipeline); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) createPipeline(req *restful.Request, res *restful.Response) {
|
|
var createReq apis.CreatePipelineRequest
|
|
if err := req.ReadEntity(&createReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := validate.Struct(&createReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
pipelineBase, err := n.PipelineService.CreatePipeline(req.Request.Context(), createReq)
|
|
if err != nil {
|
|
klog.Errorf("create pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
_, err = n.ContextService.InitContext(req.Request.Context(), pipelineBase.Project.Name, pipelineBase.Name)
|
|
if err != nil {
|
|
klog.Errorf("init pipeline context failure: %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineBase); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) updatePipeline(req *restful.Request, res *restful.Response) {
|
|
var updateReq apis.UpdatePipelineRequest
|
|
if err := req.ReadEntity(&updateReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := validate.Struct(&updateReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
pipelineBase, err := n.PipelineService.UpdatePipeline(req.Request.Context(), pipeline.Name, updateReq)
|
|
if err != nil {
|
|
klog.Errorf("update pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineBase); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) deletePipeline(req *restful.Request, res *restful.Response) {
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
err := n.PipelineService.DeletePipeline(req.Request.Context(), pipeline)
|
|
if err != nil {
|
|
klog.Errorf("delete pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(apis.EmptyResponse{}); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) runPipeline(req *restful.Request, res *restful.Response) {
|
|
var runReq apis.RunPipelineRequest
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
if err := req.ReadEntity(&runReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
|
|
run, err := n.PipelineService.RunPipeline(req.Request.Context(), pipeline, runReq)
|
|
if err != nil {
|
|
klog.Errorf("run pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(run); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) stopPipeline(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
err := n.PipelineRunService.StopPipelineRun(req.Request.Context(), pipelineRun.PipelineRunBase)
|
|
if err != nil {
|
|
klog.Errorf("stop pipeline failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineRun.PipelineRunMeta); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) listPipelineRuns(req *restful.Request, res *restful.Response) {
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
pipelineRuns, err := n.PipelineRunService.ListPipelineRuns(req.Request.Context(), pipeline)
|
|
if err != nil {
|
|
klog.Errorf("list pipeline runs failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineRuns); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipelineRun(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
if err := res.WriteEntity(pipelineRun.PipelineRunBase); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipelineRunStatus(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
if err := res.WriteEntity(pipelineRun.Status); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipelineRunLog(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
logs, err := n.PipelineRunService.GetPipelineRunLog(req.Request.Context(), *pipelineRun, req.QueryParameter("step"))
|
|
if err != nil {
|
|
klog.Errorf("get pipeline run log failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(logs); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipelineRunOutput(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
output, err := n.PipelineRunService.GetPipelineRunOutput(req.Request.Context(), *pipelineRun, req.QueryParameter("step"))
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(output); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) getPipelineRunInput(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
input, err := n.PipelineRunService.GetPipelineRunInput(req.Request.Context(), *pipelineRun, req.QueryParameter("step"))
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(input); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) resumePipelineRun(req *restful.Request, res *restful.Response) {
|
|
project := req.Request.Context().Value(&apis.CtxKeyProject).(*model.Project)
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
run := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
err := n.PipelineRunService.ResumePipelineRun(req.Request.Context(), apis.PipelineRunMeta{
|
|
PipelineName: pipeline.Name,
|
|
Project: apis.NameAlias{Name: project.Name, Alias: project.Alias},
|
|
PipelineRunName: run.PipelineRunName,
|
|
})
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(apis.EmptyResponse{}); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) terminatePipelineRun(req *restful.Request, res *restful.Response) {
|
|
project := req.Request.Context().Value(&apis.CtxKeyProject).(*model.Project)
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
run := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
err := n.PipelineRunService.TerminatePipelineRun(req.Request.Context(), apis.PipelineRunMeta{
|
|
PipelineName: pipeline.Name,
|
|
Project: apis.NameAlias{Name: project.Name, Alias: project.Alias},
|
|
PipelineRunName: run.PipelineRunName,
|
|
})
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(apis.EmptyResponse{}); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) deletePipelineRun(req *restful.Request, res *restful.Response) {
|
|
pipelineRun := req.Request.Context().Value(&apis.CtxKeyPipelineRun).(*apis.PipelineRun)
|
|
err := n.PipelineRunService.DeletePipelineRun(req.Request.Context(), pipelineRun.PipelineRunMeta)
|
|
if err != nil {
|
|
klog.Errorf("delete pipeline run failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineRun.PipelineRunMeta); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) listContextValues(req *restful.Request, res *restful.Response) {
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
contextValues, err := n.ContextService.ListContexts(req.Request.Context(), pipeline.Project.Name, pipeline.Name)
|
|
if err != nil {
|
|
klog.Errorf("list context values failure: %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(contextValues); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) createContextValue(req *restful.Request, res *restful.Response) {
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
var createReq apis.CreateContextValuesRequest
|
|
if err := req.ReadEntity(&createReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := validate.Struct(&createReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
|
|
pipelineCtx := apis.Context(createReq)
|
|
_, err := n.ContextService.CreateContext(req.Request.Context(), pipeline.Project.Name, pipeline.Name, pipelineCtx)
|
|
if err != nil {
|
|
klog.Errorf("create context failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineCtx); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) updateContextValue(req *restful.Request, res *restful.Response) {
|
|
plCtx := req.Request.Context().Value(&apis.CtxKeyPipelineContext).(apis.Context)
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
var updateReq apis.UpdateContextValuesRequest
|
|
if err := req.ReadEntity(&updateReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := validate.Struct(&updateReq); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
pipelineCtx := apis.Context{Name: plCtx.Name, Values: updateReq.Values}
|
|
_, err := n.ContextService.UpdateContext(req.Request.Context(), pipeline.Project.Name, pipeline.Name, pipelineCtx)
|
|
if err != nil {
|
|
klog.Errorf("update context failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(pipelineCtx); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) deleteContextValue(req *restful.Request, res *restful.Response) {
|
|
plCtx := req.Request.Context().Value(&apis.CtxKeyPipelineContext).(apis.Context)
|
|
pipeline := req.Request.Context().Value(&apis.CtxKeyPipeline).(apis.PipelineBase)
|
|
err := n.ContextService.DeleteContext(req.Request.Context(), pipeline.Project.Name, pipeline.Name, plCtx.Name)
|
|
if err != nil {
|
|
klog.Errorf("delete context failure %s", err.Error())
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
if err := res.WriteEntity(apis.ContextNameResponse{Name: plCtx.Name}); err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func (n *project) projectCheckFilter(req *restful.Request, res *restful.Response, chain *restful.FilterChain) {
|
|
project, err := n.ProjectService.GetProject(req.Request.Context(), req.PathParameter(Project))
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
req.Request = req.Request.WithContext(context.WithValue(req.Request.Context(), &apis.CtxKeyProject, project))
|
|
chain.ProcessFilter(req, res)
|
|
}
|
|
|
|
func (n *project) pipelineCheckFilter(req *restful.Request, res *restful.Response, chain *restful.FilterChain) {
|
|
pipeline, err := n.PipelineService.GetPipeline(req.Request.Context(), req.PathParameter(Pipeline), false)
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
req.Request = req.Request.WithContext(context.WithValue(req.Request.Context(), &apis.CtxKeyPipeline, pipeline.PipelineBase))
|
|
chain.ProcessFilter(req, res)
|
|
}
|
|
|
|
func (n *project) pipelineContextCheckFilter(req *restful.Request, res *restful.Response, chain *restful.FilterChain) {
|
|
contexts, err := n.ContextService.ListContexts(req.Request.Context(), req.PathParameter(Project), req.PathParameter(Pipeline))
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
contextName := req.PathParameter("contextName")
|
|
contextValue, ok := contexts.Contexts[contextName]
|
|
if !ok {
|
|
bcode.ReturnError(req, res, bcode.ErrContextNotFound)
|
|
return
|
|
}
|
|
req.Request = req.Request.WithContext(context.WithValue(req.Request.Context(), &apis.CtxKeyPipelineContext, apis.Context{
|
|
Name: contextName,
|
|
Values: contextValue,
|
|
}))
|
|
chain.ProcessFilter(req, res)
|
|
}
|
|
|
|
func (n *project) pipelineRunCheckFilter(req *restful.Request, res *restful.Response, chain *restful.FilterChain) {
|
|
meta := apis.PipelineRunMeta{
|
|
PipelineName: req.PathParameter(Pipeline),
|
|
Project: apis.NameAlias{
|
|
Name: req.PathParameter(Project),
|
|
},
|
|
PipelineRunName: req.PathParameter(PipelineRun),
|
|
}
|
|
run, err := n.PipelineRunService.GetPipelineRun(req.Request.Context(), meta)
|
|
if err != nil {
|
|
bcode.ReturnError(req, res, err)
|
|
return
|
|
}
|
|
req.Request = req.Request.WithContext(context.WithValue(req.Request.Context(), &apis.CtxKeyPipelineRun, run))
|
|
|
|
chain.ProcessFilter(req, res)
|
|
}
|