kubesphere/pkg/models/devops/project_pipeline_handler.go

package devops

import (
	"fmt"
	"github.com/emicklei/go-restful"
	"github.com/golang/glog"
	"kubesphere.io/devops/pkg/utils/stringutils"
	"kubesphere.io/kubesphere/pkg/gojenkins/utils"
	"kubesphere.io/kubesphere/pkg/simple/client/admin_jenkins"
	"net/http"
)

func CreateProjectPipeline(projectId string, pipeline *ProjectPipeline) (string, error) {
	jenkinsClient := admin_jenkins.Client()
	switch pipeline.Type {
	case NoScmPipelineType:

		config, err := createPipelineConfigXml(pipeline.Pipeline)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(http.StatusInternalServerError, err.Error())
		}

		job, err := jenkinsClient.GetJob(pipeline.Pipeline.Name, projectId)
		if job != nil {
			err := fmt.Errorf("job name [%s] has been used", job.GetName())
			glog.Warning(err.Error())
			return "", restful.NewError(http.StatusConflict, err.Error())
		}

		if err != nil && utils.GetJenkinsStatusCode(err) != http.StatusNotFound {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		_, err = jenkinsClient.CreateJobInFolder(config, pipeline.Pipeline.Name, projectId)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		return pipeline.Pipeline.Name, nil
	case MultiBranchPipelineType:
		config, err := createMultiBranchPipelineConfigXml(projectId, pipeline.MultiBranchPipeline)
		if err != nil {
			glog.Errorf("%+v", err)

			return "", restful.NewError(http.StatusInternalServerError, err.Error())
		}

		job, err := jenkinsClient.GetJob(pipeline.MultiBranchPipeline.Name, projectId)
		if job != nil {
			err := fmt.Errorf("job name [%s] has been used", job.GetName())
			glog.Warning(err.Error())
			return "", restful.NewError(http.StatusConflict, err.Error())
		}

		if err != nil && utils.GetJenkinsStatusCode(err) != http.StatusNotFound {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		_, err = jenkinsClient.CreateJobInFolder(config, pipeline.MultiBranchPipeline.Name, projectId)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		return pipeline.MultiBranchPipeline.Name, nil

	default:
		err := fmt.Errorf("error unsupport job type")
		glog.Errorf("%+v", err)
		return "", restful.NewError(http.StatusBadRequest, err.Error())
	}
}

func DeleteProjectPipeline(projectId string, pipelineId string) (string, error) {
	jenkinsClient := admin_jenkins.Client()
	_, err := jenkinsClient.DeleteJob(pipelineId, projectId)
	if err != nil {
		glog.Errorf("%+v", err)
		return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}
	return pipelineId, nil
}

func UpdateProjectPipeline(projectId, pipelineId string, pipeline *ProjectPipeline) (string, error) {
	jenkinsClient := admin_jenkins.Client()
	switch pipeline.Type {
	case NoScmPipelineType:

		config, err := createPipelineConfigXml(pipeline.Pipeline)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(http.StatusInternalServerError, err.Error())
		}

		job, err := jenkinsClient.GetJob(pipelineId, projectId)

		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		err = job.UpdateConfig(config)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		return pipeline.Pipeline.Name, nil
	case MultiBranchPipelineType:

		config, err := createMultiBranchPipelineConfigXml(projectId, pipeline.MultiBranchPipeline)
		if err != nil {
			glog.Errorf("%+v", err)

			return "", restful.NewError(http.StatusInternalServerError, err.Error())
		}

		job, err := jenkinsClient.GetJob(pipelineId, projectId)

		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		err = job.UpdateConfig(config)
		if err != nil {
			glog.Errorf("%+v", err)
			return "", restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}

		return pipeline.MultiBranchPipeline.Name, nil

	default:
		err := fmt.Errorf("error unsupport job type")
		glog.Errorf("%+v", err)
		return "", restful.NewError(http.StatusBadRequest, err.Error())
	}
}

func GetProjectPipeline(projectId, pipelineId string) (*ProjectPipeline, error) {
	jenkinsClient := admin_jenkins.Client()

	job, err := jenkinsClient.GetJob(pipelineId, projectId)
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}
	switch job.Raw.Class {
	case "org.jenkinsci.plugins.workflow.job.WorkflowJob":
		config, err := job.GetConfig()
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		pipeline, err := parsePipelineConfigXml(config)
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		pipeline.Name = pipelineId
		return &ProjectPipeline{
			Type:     NoScmPipelineType,
			Pipeline: pipeline,
		}, nil

	case "org.jenkinsci.plugins.workflow.multibranch.WorkflowMultiBranchProject":
		config, err := job.GetConfig()
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		pipeline, err := parseMultiBranchPipelineConfigXml(config)
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		pipeline.Name = pipelineId
		return &ProjectPipeline{
			Type:                MultiBranchPipelineType,
			MultiBranchPipeline: pipeline,
		}, nil
	default:
		err := fmt.Errorf("error unsupport job type")
		glog.Errorf("%+v", err)
		return nil, restful.NewError(http.StatusBadRequest, err.Error())

	}
}

func GetPipelineSonar(projectId, pipelineId string) ([]*SonarStatus, error) {
	jenkinsClient := admin_jenkins.Client()
	job, err := jenkinsClient.GetJob(pipelineId, projectId)
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}
	build, err := job.GetLastBuild()
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}

	sonarStatus, err := getBuildSonarResults(build)
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(http.StatusBadRequest, err.Error())
	}
	if len(sonarStatus) == 0 {
		build, err := job.GetLastCompletedBuild()
		if err != nil && stringutils.GetJenkinsStatusCode(err) != http.StatusNotFound {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		sonarStatus, err = getBuildSonarResults(build)
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(http.StatusBadRequest, err.Error())
		}
	}
	return sonarStatus, nil
}

func GetMultiBranchPipelineSonar(projectId, pipelineId, branchId string) ([]*SonarStatus, error) {
	jenkinsClient := admin_jenkins.Client()
	job, err := jenkinsClient.GetJob(branchId, projectId, pipelineId)
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}
	build, err := job.GetLastBuild()
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
	}

	sonarStatus, err := getBuildSonarResults(build)
	if err != nil {
		glog.Errorf("%+v", err)
		return nil, restful.NewError(http.StatusBadRequest, err.Error())
	}
	if len(sonarStatus) == 0 {
		build, err := job.GetLastCompletedBuild()
		if err != nil && stringutils.GetJenkinsStatusCode(err) != http.StatusNotFound {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(utils.GetJenkinsStatusCode(err), err.Error())
		}
		sonarStatus, err = getBuildSonarResults(build)
		if err != nil {
			glog.Errorf("%+v", err)
			return nil, restful.NewError(http.StatusBadRequest, err.Error())
		}
	}
	return sonarStatus, nil
}