代码拉取完成,页面将自动刷新
package drivers
import (
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
"github.com/rancher/rancher/pkg/pipeline/remote/bitbucketcloud"
"github.com/rancher/rancher/pkg/pipeline/remote/model"
"github.com/rancher/rancher/pkg/pipeline/utils"
"github.com/rancher/rancher/pkg/ref"
"github.com/rancher/types/apis/project.cattle.io/v3"
)
const (
BitbucketCloudWebhookHeader = "X-Hook-UUID"
bitbucketCloudEventHeader = "X-Event-Key"
bitbucketCloudPushEvent = "repo:push"
bitbucketCloudPrCreatedEvent = "pullrequest:created"
bitbucketCloudPrUpdatedEvent = "pullrequest:updated"
bitbucketCloudStateOpen = "OPEN"
)
type BitbucketCloudDriver struct {
PipelineLister v3.PipelineLister
PipelineExecutions v3.PipelineExecutionInterface
SourceCodeCredentials v3.SourceCodeCredentialInterface
SourceCodeCredentialLister v3.SourceCodeCredentialLister
}
func (b BitbucketCloudDriver) Execute(req *http.Request) (int, error) {
event := req.Header.Get(bitbucketCloudEventHeader)
if event != bitbucketCloudPushEvent && event != bitbucketCloudPrCreatedEvent && event != bitbucketCloudPrUpdatedEvent {
return http.StatusUnprocessableEntity, fmt.Errorf("not trigger for event:%s", event)
}
pipelineID := req.URL.Query().Get("pipelineId")
ns, name := ref.Parse(pipelineID)
pipeline, err := b.PipelineLister.Get(ns, name)
if err != nil {
return http.StatusInternalServerError, err
}
body, err := ioutil.ReadAll(req.Body)
if err != nil {
return http.StatusUnprocessableEntity, err
}
info := &model.BuildInfo{}
if event == bitbucketCloudPushEvent {
info, err = parseBitbucketPushPayload(body)
if err != nil {
return http.StatusUnprocessableEntity, err
}
} else if event == bitbucketCloudPrCreatedEvent || event == bitbucketCloudPrUpdatedEvent {
info, err = parseBitbucketPullRequestPayload(body)
if err != nil {
return http.StatusUnprocessableEntity, err
}
}
return validateAndGeneratePipelineExecution(b.PipelineExecutions, b.SourceCodeCredentials, b.SourceCodeCredentialLister, info, pipeline)
}
func parseBitbucketPushPayload(raw []byte) (*model.BuildInfo, error) {
info := &model.BuildInfo{}
payload := bitbucketcloud.PushEventPayload{}
if err := json.Unmarshal(raw, &payload); err != nil {
return nil, err
}
info.TriggerType = utils.TriggerTypeWebhook
if len(payload.Push.Changes) > 0 {
change := payload.Push.Changes[0]
info.Commit = change.New.Target.Hash
info.Branch = change.New.Name
info.Message = change.New.Target.Message
info.Author = change.New.Target.Author.User.UserName
info.AvatarURL = change.New.Target.Author.User.Links.Avatar.Href
info.HTMLLink = change.New.Target.Links.HTML.Href
switch change.New.Type {
case "tag", "annotated_tag", "bookmark":
info.Event = utils.WebhookEventTag
info.Ref = RefsTagPrefix + change.New.Name
default:
info.Event = utils.WebhookEventPush
info.Ref = RefsBranchPrefix + change.New.Name
}
}
return info, nil
}
func parseBitbucketPullRequestPayload(raw []byte) (*model.BuildInfo, error) {
info := &model.BuildInfo{}
payload := bitbucketcloud.PullRequestEventPayload{}
if err := json.Unmarshal(raw, &payload); err != nil {
return nil, err
}
if payload.PullRequest.State != bitbucketCloudStateOpen {
return nil, fmt.Errorf("no trigger for closed pull requests")
}
info.TriggerType = utils.TriggerTypeWebhook
info.Event = utils.WebhookEventPullRequest
info.RepositoryURL = fmt.Sprintf("https://bitbucket.org/%s", payload.PullRequest.Source.Repository.FullName)
info.Branch = payload.PullRequest.Destination.Branch.Name
info.Ref = RefsBranchPrefix + payload.PullRequest.Source.Branch.Name
info.HTMLLink = payload.PullRequest.Links.HTML.Href
info.Title = payload.PullRequest.Title
info.Message = payload.PullRequest.Title
info.Commit = payload.PullRequest.Source.Commit.Hash
info.Author = payload.PullRequest.Author.UserName
info.AvatarURL = payload.PullRequest.Author.Links.Avatar.Href
return info, nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。