-
Notifications
You must be signed in to change notification settings - Fork 50
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge master into prod, release: v1.1.28
- Loading branch information
Showing
6 changed files
with
413 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,3 +1,4 @@ | ||
| .bitrise* | ||
| gin-bin | ||
| .gows.user.yml | ||
| .idea |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,153 @@ | ||
| package assembla | ||
|
|
||
| // | ||
| // Docs: https://articles.assembla.com/assembla-basics/learn-more/post-information-to-external-systems-using-webhooks | ||
| // | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "errors" | ||
| "fmt" | ||
| "net/http" | ||
|
|
||
| "github.com/bitrise-io/bitrise-webhooks/bitriseapi" | ||
| hookCommon "github.com/bitrise-io/bitrise-webhooks/service/hook/common" | ||
| ) | ||
|
|
||
| // -------------------------- | ||
| // --- Webhook Data Model --- | ||
|
|
||
| // SpaceEventModel ... | ||
| type SpaceEventModel struct { | ||
| Space string `json:"space"` | ||
| Action string `json:"action"` | ||
| Object string `json:"object"` | ||
| } | ||
|
|
||
| // MessageEventModel ... | ||
| type MessageEventModel struct { | ||
| Title string `json:"title"` | ||
| Body string `json:"body"` | ||
| Author string `json:"author"` | ||
| } | ||
|
|
||
| // GitEventModel ... | ||
| type GitEventModel struct { | ||
| RepositorySuffix string `json:"repository_suffix"` | ||
| RepositoryURL string `json:"repository_url"` | ||
| Branch string `json:"branch"` | ||
| CommitID string `json:"commit_id"` | ||
| } | ||
|
|
||
| // PushEventModel ... | ||
| type PushEventModel struct { | ||
| SpaceEventModel SpaceEventModel `json:"assembla"` | ||
| MessageEventModel MessageEventModel `json:"message"` | ||
| GitEventModel GitEventModel `json:"git"` | ||
| } | ||
|
|
||
| // --------------------------------------- | ||
| // --- Webhook Provider Implementation --- | ||
|
|
||
| // HookProvider ... | ||
| type HookProvider struct{} | ||
|
|
||
| func detectContentType(header http.Header) (string, error) { | ||
| contentType := header.Get("Content-Type") | ||
| if contentType == "" { | ||
| return "", errors.New("No Content-Type Header found") | ||
| } | ||
|
|
||
| return contentType, nil | ||
| } | ||
|
|
||
| func detectAssemblaData(pushEvent PushEventModel) error { | ||
| if (pushEvent.GitEventModel.CommitID == "") || | ||
| (pushEvent.GitEventModel.Branch == "") || | ||
| (pushEvent.GitEventModel.RepositoryURL == "") || | ||
| (pushEvent.GitEventModel.RepositorySuffix == "") { | ||
| return errors.New("Webhook is not correctly setup, make sure you post updates about 'Code commits' in Assembla") | ||
| } | ||
|
|
||
| if (pushEvent.GitEventModel.CommitID == "---") || | ||
| (pushEvent.GitEventModel.Branch == "---") || | ||
| (pushEvent.GitEventModel.RepositoryURL == "---") || | ||
| (pushEvent.GitEventModel.RepositorySuffix == "---") { | ||
| return errors.New("Webhook is not correctly setup, make sure you post updates about 'Code commits' in Assembla") | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func transformPushEvent(pushEvent PushEventModel) hookCommon.TransformResultModel { | ||
| if pushEvent.SpaceEventModel.Action != "committed" { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Action was not 'committed', was: %s", pushEvent.SpaceEventModel.Action), | ||
| } | ||
| } | ||
| if pushEvent.MessageEventModel.Body == "" { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Message body can't be empty"), | ||
| } | ||
| } | ||
| if pushEvent.MessageEventModel.Author == "" { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Message author can't be empty"), | ||
| } | ||
| } | ||
| if pushEvent.GitEventModel.Branch == "" { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Git branch can't be empty"), | ||
| } | ||
| } | ||
| if pushEvent.GitEventModel.CommitID == "" { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Git commit id can't be empty"), | ||
| } | ||
| } | ||
|
|
||
| triggerAPIParams := []bitriseapi.TriggerAPIParamsModel{ | ||
| { | ||
| BuildParams: bitriseapi.BuildParamsModel{ | ||
| CommitMessage: pushEvent.MessageEventModel.Body, | ||
| Branch: pushEvent.GitEventModel.Branch, | ||
| CommitHash: pushEvent.GitEventModel.CommitID, | ||
| }, | ||
| TriggeredBy: "webhook", | ||
| }, | ||
| } | ||
|
|
||
| return hookCommon.TransformResultModel{ | ||
| TriggerAPIParams: triggerAPIParams, | ||
| } | ||
| } | ||
|
|
||
| // TransformRequest ... | ||
| func (hp HookProvider) TransformRequest(r *http.Request) hookCommon.TransformResultModel { | ||
| contentType, err := detectContentType(r.Header) | ||
| if err != nil { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Issue with Headers: %s", err), | ||
| } | ||
| } | ||
| if contentType != hookCommon.ContentTypeApplicationJSON { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Content-Type is not supported: %s", contentType), | ||
| } | ||
| } | ||
|
|
||
| if r.Body == nil { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Failed to read content of request body: no or empty request body"), | ||
| } | ||
| } | ||
|
|
||
| var pushEvent PushEventModel | ||
| if err := json.NewDecoder(r.Body).Decode(&pushEvent); err != nil { | ||
| return hookCommon.TransformResultModel{ | ||
| Error: fmt.Errorf("Failed to parse request body as JSON: %s", err), | ||
| } | ||
| } | ||
|
|
||
| return transformPushEvent(pushEvent) | ||
| } |
Oops, something went wrong.