caicloud · caicloud-bot · Dec 6, 2018 · Dec 5, 2018
diff --git a/cmd/server/server.go b/cmd/server/server.go
@@ -31,6 +31,8 @@ import (
 	_ "github.com/caicloud/cyclone/pkg/scm/provider/github"
 	_ "github.com/caicloud/cyclone/pkg/scm/provider/gitlab"
 	_ "github.com/caicloud/cyclone/pkg/scm/provider/svn"
+
+	_ "github.com/caicloud/cyclone/pkg/integrate/provider/sonar"
 )
 
 // NeverStop may be passed to Until to make it never stop.

diff --git a/pkg/api/types.go b/pkg/api/types.go
@@ -245,7 +245,7 @@ type ScanSonarQubeConfig struct {
 	SourcePath    string `bson:"sourcePath,omitempty" json:"sourcePath,omitempty" description:"path of the code used to be scanned"`
 	EncodingStyle string `bson:"encodingStyle,omitempty" json:"encodingStyle,omitempty" description:"encoding style of the source code"`
 	Language      string `bson:"language,omitempty" json:"language,omitempty" description:"language of the source code"`
-	Threshold     string `bson:"threshold,omitempty" json:"threshold,omitempty" description:"sonarqube threshold"`
+	Threshold     int    `bson:"threshold,omitempty" json:"threshold,omitempty" description:"sonarqube threshold"`
 }
 
 // PackageStage represents the config of package stage.
@@ -503,8 +503,9 @@ type ImageReleaseTaskStatus struct {
 
 // ScanStatusSonarQube including status of sonarqube scanning result overview.
 type ScanStatusSonarQube struct {
-	// including 'reliability_rating, sqale_rating, security_rating, coverage, duplicated_lines_density'
+	// including 'reliability_rating, sqale_rating, security_rating, coverage, duplicated_lines_density, quality_gate_details'
 	Measures     []*SonarMeasure `bson:"measures,omitempty" json:"measures,omitempty" description:"measures of this project from sonarqube"`
+	QGStatus     string          `bson:"qgstatus,omitempty" json:"qgstatus,omitempty" description:"quality gate status of this project from sonarqube"`
 	OverviewLink string          `bson:"overviewLink,omitempty" json:"overviewLink,omitempty" description:"link to sonarqube result website"`
 }
 
@@ -822,6 +823,9 @@ const (
 
 	// NodeRepoType represents the repository type NodeJS.
 	NodeRepoType string = "NodeJS"
+
+	// GolangType represents Go language.
+	GolangType string = "Go"
 )
 
 // NotificationContent contains some pipeline record infomation.

diff --git a/pkg/common/constant.go b/pkg/common/constant.go
diff --git a/pkg/worker/integrate/manager.go → pkg/integrate/manager.go b/pkg/worker/integrate/manager.go → pkg/integrate/manager.go
@@ -4,14 +4,25 @@ import (
 	"fmt"
 
 	"github.com/caicloud/cyclone/pkg/api"
+	"github.com/caicloud/cyclone/pkg/util/http/errors"
 )
 
 // ITGProvider is an interface for ingetration.
 type ITGProvider interface {
 	// CodeScan execute code analysis.
 	CodeScan(url, token string, config *CodeScanConfig) (string, error)
+
 	// SetCodeScanStatus sets status for CodeScanStageStatus.
 	SetCodeScanStatus(url, token string, pid string, s *api.CodeScanStageStatus) error
+
+	// CreateProject create a project.
+	CreateProject(url, token string, projectKey, projectName string) error
+
+	// SetQualityGate sets the project's quality gate.
+	SetQualityGate(url, token string, projectKey string, gateId int) error
+
+	// Validate validate the token.
+	Validate(url, token string) (bool, error)
 }
 
 // itgProviders represents the set of integration providers.
@@ -46,7 +57,7 @@ type CodeScanConfig struct {
 	SourcePath    string   `bson:"sourcePath,omitempty" json:"sourcePath,omitempty"`
 	EncodingStyle string   `bson:"encodingStyle,omitempty" json:"encodingStyle,omitempty"`
 	Language      string   `bson:"language,omitempty" json:"language,omitempty"`
-	Threshold     string   `bson:"threshold,omitempty" json:"threshold,omitempty"`
+	Threshold     int      `bson:"threshold,omitempty" json:"threshold,omitempty"`
 	ExtensionAgrs []string `bson:"extensionArgs,omitempty" json:"extensionArgs,omitempty"`
 	ProjectName   string   `bson:"projectName,omitempty" json:"projectName,omitempty"`
 	ProjectKey    string   `bson:"projectKey,omitempty" json:"projectKey,omitempty"`
@@ -75,3 +86,46 @@ func SetCodeScanStatus(itype api.IntegrationType, url, token string, projectID s
 
 	return p.SetCodeScanStatus(url, token, projectID, s)
 }
+
+// CreateProject create a project.
+func CreateProject(itype api.IntegrationType, url, token string, projectKey, projectName string) error {
+	p, err := GetProvider(itype)
+	if err != nil {
+		return err
+	}
+	return p.CreateProject(url, token, projectKey, projectName)
+}
+
+// SetQualityGate sets the project's quality gate.
+func SetQualityGate(itype api.IntegrationType, url, token string, projectKey string, gateId int) error {
+	p, err := GetProvider(itype)
+	if err != nil {
+		return err
+	}
+	return p.SetQualityGate(url, token, projectKey, gateId)
+}
+
+// Validate validate the token.
+func Validate(it *api.Integration) (bool, error) {
+	p, err := GetProvider(it.Type)
+	if err != nil {
+		return false, err
+	}
+
+	var url, token string
+
+	switch it.Type {
+	case api.IntegrationTypeSonar:
+		if it.SonarQube == nil {
+			return false, fmt.Errorf("integration type is SonarQube, so SonarQube info can not be empty")
+		}
+		url = it.SonarQube.Address
+		token = it.SonarQube.Token
+
+	default:
+		return false, errors.ErrorNotImplemented.Error(
+			fmt.Sprintf("Validate token for %s type integration", it.Type))
+	}
+
+	return p.Validate(url, token)
+}