Compare commits

...

14 Commits

Author SHA1 Message Date
Dean Karn 9a8b92d028 Update README 2017-05-04 15:04:26 -04:00
Dean Karn 248dae5b83 Merge branch 'rakeshbala-fix/githubPushPayload' into v3 2017-05-04 15:02:51 -04:00
Rakesh Balasubramanian cc075dfe29 fix(github): adds sha to commits in push payload 2017-05-02 11:25:35 -04:00
Dean Karn c93876b3e9 Merge pull request #10 from go-playground/add-handler-support
Add handler support
2017-04-27 19:24:15 -04:00
Dean Karn 0926003ddf .travis.yml tweak for gopkg.in 2017-04-27 19:19:51 -04:00
Dean Karn 58dd13d367 Add Handler function
Handler(...) return an http.Handler of the webhook for use within your own Mux
2017-04-27 17:57:51 -04:00
Dean Karn 4fa39fdfab Add .travis.yml config 2017-04-27 17:40:55 -04:00
Dean Karn fccbba5986 Update README example typo 2017-04-22 12:47:22 -04:00
Dean Karn 0d7e42cf96 correct some spelling 2017-04-21 22:13:16 -04:00
Dean Karn c9ac93f3b3 Update README 2017-04-21 22:06:42 -04:00
Dean Karn 2d256610b0 Update BitBucket + GitLab Payloads 2017-04-21 22:03:45 -04:00
Dean Karn 05a2f7cd8d refine payload interface{} to types 2017-04-21 20:40:02 -04:00
Dean Karn 5ed22cdd66 Initial GitHub Webhook revamp 2017-04-21 19:45:07 -04:00
Dean Karn 2e471dc89c Update MergerRequestEvents to MergeRequestEvents 2017-04-21 16:11:04 -04:00
15 changed files with 8024 additions and 1811 deletions
+39
View File
@@ -0,0 +1,39 @@
language: go
go:
- 1.7.5
- 1.8.1
- tip
matrix:
allow_failures:
- go: tip
notifications:
email:
recipients: dean.karn@gmail.com
on_success: change
on_failure: always
before_install:
- go get -u github.com/go-playground/overalls
- go get -u github.com/mattn/goveralls
- go get -u golang.org/x/tools/cmd/cover
- go get -u github.com/golang/lint/golint
- go get -u github.com/gordonklaus/ineffassign
- mkdir -p $GOPATH/src/gopkg.in
- ln -s $GOPATH/src/github.com/$TRAVIS_REPO_SLUG $GOPATH/src/gopkg.in/webhooks.v2
- ln -s $GOPATH/src/github.com/$TRAVIS_REPO_SLUG $GOPATH/src/gopkg.in/webhooks.v3
before_script:
- go vet ./...
script:
- gofmt -d -s .
- golint ./...
- ineffassign ./
- go test -v ./...
- go test -race
after_success: |
[ $TRAVIS_GO_VERSION = 1.8.1 ] &&
overalls -project="github.com/go-playground/webhooks" -covermode=count -ignore=.git,examples -debug &&
goveralls -coverprofile=overalls.coverprofile -service travis-ci -repotoken $COVERALLS_TOKEN
+13 -14
View File
@@ -1,13 +1,13 @@
Library webhooks Library webhooks
================ ================
<img align="right" src="https://raw.githubusercontent.com/go-playground/webhooks/v2/logo.png">![Project status](https://img.shields.io/badge/version-2.1.0-green.svg) <img align="right" src="https://raw.githubusercontent.com/go-playground/webhooks/v3/logo.png">![Project status](https://img.shields.io/badge/version-3.1.1-green.svg)
[![Build Status](https://semaphoreci.com/api/v1/projects/5b9e2eda-8f8d-40aa-8cb4-e3f6120171fe/587820/badge.svg)](https://semaphoreci.com/joeybloggs/webhooks) [![Build Status](https://travis-ci.org/go-playground/webhooks.svg?branch=v3)](https://travis-ci.org/go-playground/webhooks)
[![Coverage Status](https://coveralls.io/repos/go-playground/webhooks/badge.svg?branch=v2&service=github)](https://coveralls.io/github/go-playground/webhooks?branch=v2) [![Coverage Status](https://coveralls.io/repos/go-playground/webhooks/badge.svg?branch=v3&service=github)](https://coveralls.io/github/go-playground/webhooks?branch=v3)
[![Go Report Card](https://goreportcard.com/badge/go-playground/webhooks)](https://goreportcard.com/report/go-playground/webhooks) [![Go Report Card](https://goreportcard.com/badge/go-playground/webhooks)](https://goreportcard.com/report/go-playground/webhooks)
[![GoDoc](https://godoc.org/gopkg.in/go-playground/webhooks.v2?status.svg)](https://godoc.org/gopkg.in/go-playground/webhooks.v2) [![GoDoc](https://godoc.org/gopkg.in/go-playground/webhooks.v3?status.svg)](https://godoc.org/gopkg.in/go-playground/webhooks.v3)
![License](https://img.shields.io/dub/l/vibe-d.svg) ![License](https://img.shields.io/dub/l/vibe-d.svg)
Library webhooks allows for easy recieving and parsing of GitHub, Bitbucket and GitLab Webhook Events Library webhooks allows for easy receiving and parsing of GitHub, Bitbucket and GitLab Webhook Events
Features: Features:
@@ -24,17 +24,17 @@ Installation
Use go get. Use go get.
```shell ```shell
go get -u gopkg.in/go-playground/webhooks.v2 go get -u gopkg.in/go-playground/webhooks.v3
``` ```
Then import the package into your own code. Then import the package into your own code.
import "gopkg.in/go-playground/webhooks.v2" import "gopkg.in/go-playground/webhooks.v3"
Usage and Documentation Usage and Documentation
------ ------
Please see http://godoc.org/gopkg.in/go-playground/webhooks.v2 for detailed usage docs. Please see http://godoc.org/gopkg.in/go-playground/webhooks.v3 for detailed usage docs.
##### Examples: ##### Examples:
@@ -46,8 +46,8 @@ import (
"fmt" "fmt"
"strconv" "strconv"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
"gopkg.in/go-playground/webhooks.v2/github" "gopkg.in/go-playground/webhooks.v3/github"
) )
const ( const (
@@ -75,7 +75,7 @@ func HandleRelease(payload interface{}, header webhooks.Header) {
pl := payload.(github.ReleasePayload) pl := payload.(github.ReleasePayload)
// only want to compile on full releases // only want to compile on full releases
if pl.Release.Draft || pl.Release.Prelelease || pl.Release.TargetCommitish != "master" { if pl.Release.Draft || pl.Release.Prerelease || pl.Release.TargetCommitish != "master" {
return return
} }
@@ -93,7 +93,6 @@ func HandlePullRequest(payload interface{}, header webhooks.Header) {
// Do whatever you want from here... // Do whatever you want from here...
fmt.Printf("%+v", pl) fmt.Printf("%+v", pl)
} }
``` ```
Single receiver for events you subscribe to Single receiver for events you subscribe to
@@ -104,8 +103,8 @@ import (
"fmt" "fmt"
"strconv" "strconv"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
"gopkg.in/go-playground/webhooks.v2/github" "gopkg.in/go-playground/webhooks.v3/github"
) )
const ( const (
+25 -20
View File
@@ -5,7 +5,7 @@ import (
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
) )
// Webhook instance contains all methods needed to process events // Webhook instance contains all methods needed to process events
@@ -25,23 +25,24 @@ type Event string
// Bitbucket hook types // Bitbucket hook types
const ( const (
RepoPushEvent Event = "repo:push" RepoPushEvent Event = "repo:push"
RepoForkEvent Event = "repo:fork" RepoForkEvent Event = "repo:fork"
RepoCommitCommentCreatedEvent Event = "repo:commit_comment_created" RepoUpdatedEvent Event = "repo:updated"
RepoCommitStatusCreatedEvent Event = "repo:commit_status_created" RepoCommitCommentCreatedEvent Event = "repo:commit_comment_created"
RepoCommitStatusUpdatedEvent Event = "repo:commit_status_updated" RepoCommitStatusCreatedEvent Event = "repo:commit_status_created"
IssueCreatedEvent Event = "issue:created" RepoCommitStatusUpdatedEvent Event = "repo:commit_status_updated"
IssueUpdatedEvent Event = "issue:updated" IssueCreatedEvent Event = "issue:created"
IssueCommentCreatedEvent Event = "issue:comment_created" IssueUpdatedEvent Event = "issue:updated"
PullRequestCreatedEvent Event = "pullrequest:created" IssueCommentCreatedEvent Event = "issue:comment_created"
PullRequestUpdatedEvent Event = "pullrequest:updated" PullRequestCreatedEvent Event = "pullrequest:created"
PullRequestApprovedEvent Event = "pullrequest:approved" PullRequestUpdatedEvent Event = "pullrequest:updated"
PullRequestApprovalRemovedEvent Event = "pullrequest:unapproved" PullRequestApprovedEvent Event = "pullrequest:approved"
PullRequestMergedEvent Event = "pullrequest:fulfilled" PullRequestUnapprovedEvent Event = "pullrequest:unapproved"
PullRequestDeclinedEvent Event = "pullrequest:rejected" PullRequestMergedEvent Event = "pullrequest:fulfilled"
PullRequestCommentCreatedEvent Event = "pullrequest:comment_created" PullRequestDeclinedEvent Event = "pullrequest:rejected"
PullRequestCommentUpdatedEvent Event = "pullrequest:comment_updated" PullRequestCommentCreatedEvent Event = "pullrequest:comment_created"
PullRequestCommentDeletedEvent Event = "pull_request:comment_deleted" PullRequestCommentUpdatedEvent Event = "pullrequest:comment_updated"
PullRequestCommentDeletedEvent Event = "pull_request:comment_deleted"
) )
// New creates and returns a WebHook instance denoted by the Provider type // New creates and returns a WebHook instance denoted by the Provider type
@@ -111,6 +112,10 @@ func (hook Webhook) ParsePayload(w http.ResponseWriter, r *http.Request) {
var pl RepoForkPayload var pl RepoForkPayload
json.Unmarshal([]byte(payload), &pl) json.Unmarshal([]byte(payload), &pl)
hook.runProcessPayloadFunc(fn, pl, hd) hook.runProcessPayloadFunc(fn, pl, hd)
case RepoUpdatedEvent:
var pl RepoUpdatedPayload
json.Unmarshal([]byte(payload), &pl)
hook.runProcessPayloadFunc(fn, pl, hd)
case RepoCommitCommentCreatedEvent: case RepoCommitCommentCreatedEvent:
var pl RepoCommitCommentCreatedPayload var pl RepoCommitCommentCreatedPayload
json.Unmarshal([]byte(payload), &pl) json.Unmarshal([]byte(payload), &pl)
@@ -147,8 +152,8 @@ func (hook Webhook) ParsePayload(w http.ResponseWriter, r *http.Request) {
var pl PullRequestApprovedPayload var pl PullRequestApprovedPayload
json.Unmarshal([]byte(payload), &pl) json.Unmarshal([]byte(payload), &pl)
hook.runProcessPayloadFunc(fn, pl, hd) hook.runProcessPayloadFunc(fn, pl, hd)
case PullRequestApprovalRemovedEvent: case PullRequestUnapprovedEvent:
var pl PullRequestApprovalRemovedPayload var pl PullRequestUnapprovedPayload
json.Unmarshal([]byte(payload), &pl) json.Unmarshal([]byte(payload), &pl)
hook.runProcessPayloadFunc(fn, pl, hd) hook.runProcessPayloadFunc(fn, pl, hd)
case PullRequestMergedEvent: case PullRequestMergedEvent:
+182 -26
View File
@@ -9,7 +9,7 @@ import (
"time" "time"
. "gopkg.in/go-playground/assert.v1" . "gopkg.in/go-playground/assert.v1"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
) )
// NOTES: // NOTES:
@@ -24,7 +24,7 @@ import (
// //
// //
const ( const (
port = 3010 port = 3009
path = "/webhooks" path = "/webhooks"
) )
@@ -39,10 +39,30 @@ func TestMain(m *testing.M) {
// setup // setup
hook = New(&Config{UUID: "MY_UUID"}) hook = New(&Config{UUID: "MY_UUID"})
hook.RegisterEvents(HandlePayload, RepoPushEvent, RepoForkEvent, RepoCommitCommentCreatedEvent, RepoCommitStatusCreatedEvent, RepoCommitStatusUpdatedEvent, IssueCreatedEvent, IssueUpdatedEvent, IssueCommentCreatedEvent, PullRequestCreatedEvent, PullRequestUpdatedEvent, PullRequestApprovedEvent, PullRequestApprovalRemovedEvent, PullRequestMergedEvent, PullRequestDeclinedEvent, PullRequestCommentCreatedEvent, PullRequestCommentUpdatedEvent, PullRequestCommentDeletedEvent) hook.RegisterEvents(
HandlePayload,
RepoPushEvent,
RepoForkEvent,
RepoUpdatedEvent,
RepoCommitCommentCreatedEvent,
RepoCommitStatusCreatedEvent,
RepoCommitStatusUpdatedEvent,
IssueCreatedEvent,
IssueUpdatedEvent,
IssueCommentCreatedEvent,
PullRequestCreatedEvent,
PullRequestUpdatedEvent,
PullRequestApprovedEvent,
PullRequestUnapprovedEvent,
PullRequestMergedEvent,
PullRequestDeclinedEvent,
PullRequestCommentCreatedEvent,
PullRequestCommentUpdatedEvent,
PullRequestCommentDeletedEvent,
)
go webhooks.Run(hook, "127.0.0.1:"+strconv.Itoa(port), path) go webhooks.Run(hook, "127.0.0.1:"+strconv.Itoa(port), path)
time.Sleep(5000) time.Sleep(time.Millisecond * 500)
os.Exit(m.Run()) os.Exit(m.Run())
@@ -56,7 +76,7 @@ func TestProvider(t *testing.T) {
func TestUUIDMissingEvent(t *testing.T) { func TestUUIDMissingEvent(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Event-Key", "noneexistant_event") req.Header.Set("X-Event-Key", "noneexistant_event")
@@ -74,7 +94,7 @@ func TestUUIDMissingEvent(t *testing.T) {
func TestUUIDDoesNotMatchEvent(t *testing.T) { func TestUUIDDoesNotMatchEvent(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "THIS_DOES_NOT_MATCH") req.Header.Set("X-Hook-UUID", "THIS_DOES_NOT_MATCH")
@@ -92,7 +112,7 @@ func TestUUIDDoesNotMatchEvent(t *testing.T) {
func TestBadNoEventHeader(t *testing.T) { func TestBadNoEventHeader(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
@@ -110,7 +130,7 @@ func TestBadNoEventHeader(t *testing.T) {
func TestUnsubscribedEvent(t *testing.T) { func TestUnsubscribedEvent(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "noneexistant_event") req.Header.Set("X-Event-Key", "noneexistant_event")
@@ -129,7 +149,7 @@ func TestUnsubscribedEvent(t *testing.T) {
func TestBadBody(t *testing.T) { func TestBadBody(t *testing.T) {
payload := "" payload := ""
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:push") req.Header.Set("X-Event-Key", "repo:push")
@@ -355,7 +375,7 @@ func TestRepoPush(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:push") req.Header.Set("X-Event-Key", "repo:push")
@@ -429,7 +449,7 @@ func TestRepoFork(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:fork") req.Header.Set("X-Event-Key", "repo:fork")
@@ -445,6 +465,142 @@ func TestRepoFork(t *testing.T) {
Equal(t, resp.StatusCode, http.StatusOK) Equal(t, resp.StatusCode, http.StatusOK)
} }
func TestRepoUpdated(t *testing.T) {
payload := `{
"actor": {
"type": "user",
"username": "emmap1",
"display_name": "Emma",
"uuid": "{a54f16da-24e9-4d7f-a3a7-b1ba2cd98aa3}",
"links": {
"self": {
"href": "https://api.bitbucket.org/api/2.0/users/emmap1"
},
"html": {
"href": "https://api.bitbucket.org/emmap1"
},
"avatar": {
"href": "https://bitbucket-api-assetroot.s3.amazonaws.com/c/photos/2015/Feb/26/3613917261-0-emmap1-avatar_avatar.png"
}
}
},
"repository": {
"type": "repository",
"links": {
"self": {
"href": "https://api.bitbucket.org/api/2.0/repositories/bitbucket/bitbucket"
},
"html": {
"href": "https://api.bitbucket.org/bitbucket/bitbucket"
},
"avatar": {
"href": "https://api-staging-assetroot.s3.amazonaws.com/c/photos/2014/Aug/01/bitbucket-logo-2629490769-3_avatar.png"
}
},
"uuid": "{673a6070-3421-46c9-9d48-90745f7bfe8e}",
"project": {
"type": "project",
"project": "Untitled project",
"uuid": "{3b7898dc-6891-4225-ae60-24613bb83080}",
"links": {
"html": {
"href": "https://bitbucket.org/account/user/teamawesome/projects/proj"
},
"avatar": {
"href": "https://bitbucket.org/account/user/teamawesome/projects/proj/avatar/32"
}
},
"key": "proj"
},
"full_name": "team_name/repo_name",
"name": "repo_name",
"website": "https://mywebsite.com/",
"owner": {
"type": "user",
"username": "emmap1",
"display_name": "Emma",
"uuid": "{a54f16da-24e9-4d7f-a3a7-b1ba2cd98aa3}",
"links": {
"self": {
"href": "https://api.bitbucket.org/api/2.0/users/emmap1"
},
"html": {
"href": "https://api.bitbucket.org/emmap1"
},
"avatar": {
"href": "https://bitbucket-api-assetroot.s3.amazonaws.com/c/photos/2015/Feb/26/3613917261-0-emmap1-avatar_avatar.png"
}
}
},
"scm": "git",
"is_private": true
},
"changes": {
"name": {
"new": "repository",
"old": "repository_name"
},
"website": {
"new": "http://www.example.com/",
"old": ""
},
"language": {
"new": "java",
"old": ""
},
"links": {
"new": {
"avatar": {
"href": "https://bitbucket.org/teamawesome/repository/avatar/32/"
},
"self": {
"href": "https://api.bitbucket.org/2.0/repositories/teamawesome/repository"
},
"html": {
"href": "https://bitbucket.org/teamawesome/repository"
}
},
"old": {
"avatar": {
"href": "https://bitbucket.org/teamawesome/repository_name/avatar/32/"
},
"self": {
"href": "https://api.bitbucket.org/2.0/repositories/teamawesome/repository_name"
},
"html": {
"href": "https://bitbucket.org/teamawesome/repository_name"
}
}
},
"description": {
"new": "This is a better description.",
"old": "This is a description."
},
"full_name": {
"new": "teamawesome/repository",
"old": "teamawesome/repository_name"
}
}
}
`
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:updated")
Equal(t, err, nil)
client := &http.Client{}
resp, err := client.Do(req)
Equal(t, err, nil)
defer resp.Body.Close()
Equal(t, resp.StatusCode, http.StatusOK)
}
func TestRepoCommitCommentCreated(t *testing.T) { func TestRepoCommitCommentCreated(t *testing.T) {
payload := `{ payload := `{
@@ -514,7 +670,7 @@ func TestRepoCommitCommentCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:commit_comment_created") req.Header.Set("X-Event-Key", "repo:commit_comment_created")
@@ -588,7 +744,7 @@ func TestRepoCommitStatusCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:commit_status_created") req.Header.Set("X-Event-Key", "repo:commit_status_created")
@@ -662,7 +818,7 @@ func TestRepoCommitStatusUpdated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "repo:commit_status_updated") req.Header.Set("X-Event-Key", "repo:commit_status_updated")
@@ -747,7 +903,7 @@ func TestIssueCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "issue:created") req.Header.Set("X-Event-Key", "issue:created")
@@ -864,7 +1020,7 @@ func TestIssueUpdated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "issue:updated") req.Header.Set("X-Event-Key", "issue:updated")
@@ -975,7 +1131,7 @@ func TestIssueCommentCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "issue:comment_created") req.Header.Set("X-Event-Key", "issue:comment_created")
@@ -1172,7 +1328,7 @@ func TestPullRequestCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:created") req.Header.Set("X-Event-Key", "pullrequest:created")
@@ -1369,7 +1525,7 @@ func TestPullRequestUpdated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:updated") req.Header.Set("X-Event-Key", "pullrequest:updated")
@@ -1585,7 +1741,7 @@ func TestPullRequestApproved(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:approved") req.Header.Set("X-Event-Key", "pullrequest:approved")
@@ -1801,7 +1957,7 @@ func TestPullRequestApprovalRemoved(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:unapproved") req.Header.Set("X-Event-Key", "pullrequest:unapproved")
@@ -1998,7 +2154,7 @@ func TestPullRequestMerged(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:fulfilled") req.Header.Set("X-Event-Key", "pullrequest:fulfilled")
@@ -2195,7 +2351,7 @@ func TestPullRequestDeclined(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:rejected") req.Header.Set("X-Event-Key", "pullrequest:rejected")
@@ -2418,7 +2574,7 @@ func TestPullRequestCommentCreated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:comment_created") req.Header.Set("X-Event-Key", "pullrequest:comment_created")
@@ -2641,7 +2797,7 @@ func TestPullRequestCommentUpdated(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pullrequest:comment_updated") req.Header.Set("X-Event-Key", "pullrequest:comment_updated")
@@ -2864,7 +3020,7 @@ func TestPullRequestCommentDeleted(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3010/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Hook-UUID", "MY_UUID") req.Header.Set("X-Hook-UUID", "MY_UUID")
req.Header.Set("X-Event-Key", "pull_request:comment_deleted") req.Header.Set("X-Event-Key", "pull_request:comment_deleted")
+457 -337
View File
@@ -2,388 +2,508 @@ package bitbucket
import "time" import "time"
// PullRequestCommentDeletedPayload is the Bitbucket pull_request:comment_deleted payload // RepoPushPayload is the Bitbucket repo:push payload
type PullRequestCommentDeletedPayload struct { type RepoPushPayload struct {
Actor User `json:"actor"` Actor Owner `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// PullRequestCommentUpdatedPayload is the Bitbucket pullrequest:comment_updated payload
type PullRequestCommentUpdatedPayload struct {
Actor User `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// PullRequestCommentCreatedPayload is the Bitbucket pullrequest:comment_created payload
type PullRequestCommentCreatedPayload struct {
Actor User `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// PullRequestDeclinedPayload is the Bitbucket pullrequest:rejected payload
type PullRequestDeclinedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// PullRequestMergedPayload is the Bitbucket pullrequest:fulfilled payload
type PullRequestMergedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// PullRequestApprovalRemovedPayload is the Bitbucket pullrequest:unapproved payload
type PullRequestApprovalRemovedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
Approval Approval `json:"approval"`
}
// PullRequestApprovedPayload is the Bitbucket pullrequest:approved payload
type PullRequestApprovedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
Approval Approval `json:"approval"`
}
// PullRequestUpdatedPayload is the Bitbucket pullrequest:updated payload
type PullRequestUpdatedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// PullRequestCreatedPayload is the Bitbucket pullrequest:created payload
type PullRequestCreatedPayload struct {
Actor User `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// IssueCommentCreatedPayload is the Bitbucket issue:comment_created payload
type IssueCommentCreatedPayload struct {
Actor User `json:"actor"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
Issue Issue `json:"issue"` Push struct {
Comment Comment `json:"comment"` Changes []struct {
} New struct {
Type string `json:"type"`
// IssueUpdatedPayload is the Bitbucket issue:updated payload Name string `json:"name"`
type IssueUpdatedPayload struct { Target struct {
Actor User `json:"actor"` Type string `json:"type"`
Issue Issue `json:"issue"` Hash string `json:"hash"`
Repository Repository `json:"repository"` Author Owner `json:"author"`
Comment Comment `json:"comment"` Message string `json:"message"`
Changes IssueChanges `json:"changes"` Date time.Time `json:"date"`
} Parents []struct {
Type string `json:"type"`
// IssueCreatedPayload is the Bitbucket issue:created payload Hash string `json:"hash"`
type IssueCreatedPayload struct { Links struct {
Actor User `json:"actor"` Self struct {
Issue Issue `json:"issue"` Href string `json:"href"`
Repository Repository `json:"repository"` } `json:"self"`
} HTML struct {
Href string `json:"href"`
// RepoCommitStatusUpdatedPayload is the Bitbucket repo:commit_status_updated payload } `json:"html"`
type RepoCommitStatusUpdatedPayload struct { } `json:"links"`
Actor User `json:"actor"` } `json:"parents"`
Repository Repository `json:"repository"` Links struct {
CommitStatus CommitStatus `json:"commit_status"` Self struct {
} Href string `json:"href"`
} `json:"self"`
// RepoCommitStatusCreatedPayload is the Bitbucket repo:commit_status_created payload HTML struct {
type RepoCommitStatusCreatedPayload struct { Href string `json:"href"`
Actor User `json:"actor"` } `json:"html"`
Repository Repository `json:"repository"` } `json:"links"`
CommitStatus CommitStatus `json:"commit_status"` } `json:"target"`
} Links struct {
Self struct {
// RepoCommitCommentCreatedPayload is the Bitbucket repo:commit_comment_created payload Href string `json:"href"`
type RepoCommitCommentCreatedPayload struct { } `json:"self"`
Actor User `json:"actor"` Commits struct {
Comment Comment `json:"comment"` Href string `json:"href"`
Repository Repository `json:"repository"` } `json:"commits"`
Commit CommitHash `json:"commit"` HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} `json:"new"`
Old struct {
Type string `json:"type"`
Name string `json:"name"`
Target struct {
Type string `json:"type"`
Hash string `json:"hash"`
Author Owner `json:"author"`
Message string `json:"message"`
Date time.Time `json:"date"`
Parents []struct {
Type string `json:"type"`
Hash string `json:"hash"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} `json:"parents"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} `json:"target"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
Commits struct {
Href string `json:"href"`
} `json:"commits"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} `json:"old"`
Links struct {
HTML struct {
Href string `json:"href"`
} `json:"html"`
Diff struct {
Href string `json:"href"`
} `json:"diff"`
Commits struct {
Href string `json:"href"`
} `json:"commits"`
} `json:"links"`
Created bool `json:"created"`
Forced bool `json:"forced"`
Closed bool `json:"closed"`
Commits []struct {
Hash string `json:"hash"`
Type string `json:"type"`
Message string `json:"message"`
Author Owner `json:"author"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} `json:"commits"`
Truncated bool `json:"truncated"`
} `json:"changes"`
} `json:"push"`
} }
// RepoForkPayload is the Bitbucket repo:fork payload // RepoForkPayload is the Bitbucket repo:fork payload
type RepoForkPayload struct { type RepoForkPayload struct {
Actor User `json:"actor"` Actor Owner `json:"actor"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
Fork Repository `json:"fork"` Fork Repository `json:"fork"`
} }
// RepoPushPayload is the Bitbucket repo:push payload // RepoUpdatedPayload is the Bitbucket repo:updated payload
type RepoPushPayload struct { type RepoUpdatedPayload struct {
Actor User `json:"actor"` Actor Owner `json:"actor"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
Push Push `json:"push"` Changes struct {
Name struct {
New string `json:"new"`
Old string `json:"old"`
} `json:"name"`
Website struct {
New string `json:"new"`
Old string `json:"old"`
} `json:"website"`
Language struct {
New string `json:"new"`
Old string `json:"old"`
} `json:"language"`
Links struct {
New struct {
Avatar struct {
Href string `json:"href"`
} `json:"avatar"`
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"new"`
Old struct {
Avatar struct {
Href string `json:"href"`
} `json:"avatar"`
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"old"`
} `json:"links"`
Description struct {
New string `json:"new"`
Old string `json:"old"`
} `json:"description"`
FullName struct {
New string `json:"new"`
Old string `json:"old"`
} `json:"full_name"`
} `json:"changes"`
} }
// Approval is the common Bitbucket Issue Approval Sub Entity // RepoCommitCommentCreatedPayload is the Bitbucket repo:commit_comment_created payload
type Approval struct { type RepoCommitCommentCreatedPayload struct {
Date time.Time `json:"date"` Actor Owner `json:"actor"`
User User `json:"user"` Comment Comment `json:"comment"`
Repository Repository `json:"repository"`
Commit struct {
Hash string `json:"hash"`
} `json:"commit"`
} }
// IssueChanges is the common Bitbucket Issue Changes Sub Entity // RepoCommitStatusCreatedPayload is the Bitbucket repo:commit_status_created payload
type IssueChanges struct { type RepoCommitStatusCreatedPayload struct {
Status IssueChangeStatus `json:"status"` Actor Owner `json:"actor"`
Repository Repository `json:"repository"`
CommitStatus struct {
Name string `json:"name"`
Description string `json:"description"`
State string `json:"state"`
Key string `json:"key"`
URL string `json:"url"`
Type string `json:"type"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Links struct {
Commit struct {
Href string `json:"href"`
} `json:"commit"`
Self struct {
Href string `json:"href"`
} `json:"self"`
} `json:"links"`
} `json:"commit_status"`
} }
// IssueChangeStatus is the common Bitbucket Issue Change Status Sub Entity // RepoCommitStatusUpdatedPayload is the Bitbucket repo:commit_status_updated payload
type IssueChangeStatus struct { type RepoCommitStatusUpdatedPayload struct {
Old string `json:"old"` Actor Owner `json:"actor"`
New string `json:"new"` Repository Repository `json:"repository"`
CommitStatus struct {
Name string `json:"name"`
Description string `json:"description"`
State string `json:"state"`
Key string `json:"key"`
URL string `json:"url"`
Type string `json:"type"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Links struct {
Commit struct {
Href string `json:"href"`
} `json:"commit"`
Self struct {
Href string `json:"href"`
} `json:"self"`
} `json:"links"`
} `json:"commit_status"`
} }
// CommitStatus is the common Bitbucket CommitStatus Sub Entity // IssueCreatedPayload is the Bitbucket issue:created payload
type CommitStatus struct { type IssueCreatedPayload struct {
Name string `json:"name"` Actor Owner `json:"actor"`
Description string `json:"description"` Issue Issue `json:"issue"`
State string `json:"state"` Repository Repository `json:"repository"`
Key string `json:"key"`
URL string `json:"url"`
Type string `json:"type"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Links LinksSelfCommit `json:"links"`
} }
// Push is the common Bitbucket Push Sub Entity // IssueUpdatedPayload is the Bitbucket issue:updated payload
type Push struct { type IssueUpdatedPayload struct {
Changes []Change `json:"changes"` Actor Owner `json:"actor"`
Issue Issue `json:"issue"`
Repository Repository `json:"repository"`
Comment Comment `json:"comment"`
Changes struct {
Status struct {
Old string `json:"old"`
New string `json:"new"`
} `json:"status"`
} `json:"changes"`
} }
// Change is the common Bitbucket Change Sub Entity // IssueCommentCreatedPayload is the Bitbucket pullrequest:created payload
type Change struct { type IssueCommentCreatedPayload struct {
New ChangeData `json:"new"` Actor Owner `json:"actor"`
Old ChangeData `json:"old"` Repository Repository `json:"repository"`
Links LinksHTMLDiffCommits `json:"links"` Issue Issue `json:"issue"`
Created bool `json:"created"` Comment Comment `json:"comment"`
Forced bool `json:"forced"`
Closed bool `json:"closed"`
Commits []Commit `json:"commits"`
Truncated bool `json:"truncated"`
} }
// ChangeData is the common Bitbucket ChangeData Sub Entity // PullRequestCreatedPayload is the Bitbucket pullrequest:created payload
type ChangeData struct { type PullRequestCreatedPayload struct {
Type string `json:"type"` Actor Owner `json:"actor"`
Name string `json:"name"` PullRequest PullRequest `json:"pullrequest"`
Target Target `json:"target"` Repository Repository `json:"repository"`
Links LinksHTMLSelfCommits `json:"links"`
} }
// Target is the common Bitbucket Target Sub Entity // PullRequestUpdatedPayload is the Bitbucket pullrequest:updated payload
type Target struct { type PullRequestUpdatedPayload struct {
Type string `json:"type"` Actor Owner `json:"actor"`
Hash string `json:"hash"` PullRequest PullRequest `json:"pullrequest"`
Author User `json:"author"` Repository Repository `json:"repository"`
Message string `json:"message"`
Date time.Time `json:"date"`
Parents []Parent `json:"parents"`
Links LinksHTMLSelf `json:"links"`
} }
// Parent is the common Bitbucket Parent Sub Entity // PullRequestApprovedPayload is the Bitbucket pullrequest:approved payload
type Parent struct { type PullRequestApprovedPayload struct {
Type string `json:"type"` Actor Owner `json:"actor"`
Hash string `json:"hash"` PullRequest PullRequest `json:"pullrequest"`
Links LinksHTMLSelf `json:"links"` Repository Repository `json:"repository"`
Approval struct {
Date time.Time `json:"date"`
User Owner `json:"user"`
} `json:"approval"`
} }
// Commit is the common Bitbucket Commit Sub Entity // PullRequestUnapprovedPayload is the Bitbucket pullrequest:unapproved payload
type Commit struct { type PullRequestUnapprovedPayload struct {
Hash string `json:"hash"` Actor Owner `json:"actor"`
Type string `json:"type"` PullRequest PullRequest `json:"pullrequest"`
Message string `json:"message"` Repository Repository `json:"repository"`
Author User `json:"author"` Approval struct {
Links LinksHTMLSelf `json:"links"` Date time.Time `json:"date"`
User Owner `json:"user"`
} `json:"approval"`
} }
// User is the common Bitbucket User Entity // PullRequestMergedPayload is the Bitbucket pullrequest:fulfilled payload
type User struct { type PullRequestMergedPayload struct {
Actor Owner `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// PullRequestDeclinedPayload is the Bitbucket pullrequest:rejected payload
type PullRequestDeclinedPayload struct {
Actor Owner `json:"actor"`
PullRequest PullRequest `json:"pullrequest"`
Repository Repository `json:"repository"`
}
// PullRequestCommentCreatedPayload is the Bitbucket pullrequest:comment_updated payload
type PullRequestCommentCreatedPayload struct {
Actor Owner `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// PullRequestCommentUpdatedPayload is the Bitbucket pullrequest:comment_created payload
type PullRequestCommentUpdatedPayload struct {
Actor Owner `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// PullRequestCommentDeletedPayload is the Bitbucket pullrequest:comment_deleted payload
type PullRequestCommentDeletedPayload struct {
Actor Owner `json:"actor"`
Repository Repository `json:"repository"`
PullRequest PullRequest `json:"pullrequest"`
Comment Comment `json:"comment"`
}
// Owner is the common Bitbucket Owner Sub Entity
type Owner struct {
Type string `json:"type"`
Username string `json:"username"` Username string `json:"username"`
DisplayName string `json:"display_name"` DisplayName string `json:"display_name"`
UUID string `json:"uuid"` UUID string `json:"uuid"`
Links Links `json:"links"` Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
Avatar struct {
Href string `json:"href"`
} `json:"avatar"`
} `json:"links"`
} }
// Repository is the common Bitbucket Repository Entity // Repository is the common Bitbucket Repository Sub Entity
type Repository struct { type Repository struct {
Links Links `json:"links"` Type string `json:"type"`
UUID string `json:"uuid"` Links struct {
FullName string `json:"full_name"` Self struct {
Name string `json:"name"` Href string `json:"href"`
Scm string `json:"scm"` } `json:"self"`
IsPrivate bool `json:"is_private"` HTML struct {
Href string `json:"href"`
} `json:"html"`
Avatar struct {
Href string `json:"href"`
} `json:"avatar"`
} `json:"links"`
UUID string `json:"uuid"`
Project Project `json:"project"`
FullName string `json:"full_name"`
Name string `json:"name"`
Website string `json:"website"`
Owner Owner `json:"owner"`
Scm string `json:"scm"`
IsPrivate bool `json:"is_private"`
} }
// Issue is the common Bitbucket Issue Entity // Project is the common Bitbucket Project Sub Entity
type Project struct {
Type string `json:"type"`
Project string `json:"project"`
UUID string `json:"uuid"`
Links struct {
HTML struct {
Href string `json:"href"`
} `json:"html"`
Avatar struct {
Href string `json:"href"`
} `json:"avatar"`
} `json:"links"`
Key string `json:"key"`
}
// Issue is the common Bitbucket Issue Sub Entity
type Issue struct { type Issue struct {
ID int64 `json:"id"` ID int64 `json:"id"`
Component string `json:"component"` Component string `json:"component"`
Title string `json:"title"` Title string `json:"title"`
Content Content `json:"content"` Content struct {
Priority string `json:"priority"` Raw string `json:"raw"`
State string `json:"state"` HTML string `json:"html"`
Type string `json:"type"` Markup string `json:"markup"`
Milestone Milestone `json:"milestone"` } `json:"content"`
Version Version `json:"version"` Priority string `json:"priority"`
CreatedOn time.Time `json:"created_on"` State string `json:"state"`
UpdatedOn time.Time `json:"updated_on"` Type string `json:"type"`
Links LinksHTMLSelf `json:"links"` Milestone struct {
Name string `json:"name"`
} `json:"milestone"`
Version struct {
Name string `json:"name"`
} `json:"version"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} }
// Comment is the common Bitbucket Comment Entity // Comment is the common Bitbucket Comment Sub Entity
type Comment struct { type Comment struct {
ID int64 `json:"id"` ID int64 `json:"id"`
Parent ParentID `json:"parent"` Parent struct {
Content Content `json:"content"` ID int64 `json:"id"`
Inline Inline `json:"inline"` } `json:"parent"`
CreatedOn time.Time `json:"created_on"` Content struct {
UpdatedOn time.Time `json:"updated_on"` Raw string `json:"raw"`
Links LinksHTMLSelf `json:"links"` HTML string `json:"html"`
Markup string `json:"markup"`
} `json:"content"`
Inline struct {
Path string `json:"path"`
From *int64 `json:"from"`
To int64 `json:"to"`
} `json:"inline"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Links struct {
Self struct {
Href string `json:"href"`
} `json:"self"`
HTML struct {
Href string `json:"href"`
} `json:"html"`
} `json:"links"`
} }
// PullRequest is the common Bitbucket PullRequest Entity // PullRequest is the common Bitbucket Pull Request Sub Entity
type PullRequest struct { type PullRequest struct {
ID int64 `json:"id"` ID int64 `json:"id"`
Title string `json:"title"` Title string `json:"title"`
Description string `json:"description"` Description string `json:"description"`
State string `json:"state"` State string `json:"state"`
Author User `json:"author"` Author Owner `json:"author"`
Source Source `json:"source"` Source struct {
Destination Destination `json:"destination"` Branch struct {
MergeCommit CommitHash `json:"merge_commit"` Name string `json:"name"`
Participants []User `json:"participants"` } `json:"branch"`
Reviewers []User `json:"reviewers"` Commit struct {
CloseSourceBranch bool `json:"close_source_branch"` Hash string `json:"hash"`
ClosedBy User `json:"closed_by"` } `json:"commit"`
Reason string `json:"reason"` Repository Repository `json:"repository"`
CreatedOn time.Time `json:"created_on"` } `json:"source"`
UpdatedOn time.Time `json:"updated_on"` Destination struct {
Links LinksHTMLSelf `json:"links"` Branch struct {
} Name string `json:"name"`
} `json:"branch"`
// Destination is the common Bitbucket Destination Sub Entity Commit struct {
type Destination struct { Hash string `json:"hash"`
Branch Branch `json:"branch"` } `json:"commit"`
Commit CommitHash `json:"commit"` Repository Repository `json:"repository"`
Repository Repository `json:"repository"` } `json:"destination"`
} MergeCommit struct {
Hash string `json:"hash"`
// Source is the common Bitbucket Source Sub Entity } `json:"merge_commit"`
type Source struct { Participants []Owner `json:"participants"`
Branch Branch `json:"branch"` Reviewers []Owner `json:"reviewers"`
Commit CommitHash `json:"commit"` CloseSourceBranch bool `json:"close_source_branch"`
Repository Repository `json:"repository"` ClosedBy Owner `json:"closed_by"`
} Reason string `json:"reason"`
CreatedOn time.Time `json:"created_on"`
// Branch is the common Bitbucket Branch Sub Entity UpdatedOn time.Time `json:"updated_on"`
type Branch struct { Links struct {
Name string `json:"name"` Self struct {
} Href string `json:"href"`
} `json:"self"`
// CommitHash is the common Bitbucket CommitHash Sub Entity HTML struct {
type CommitHash struct { Href string `json:"href"`
Hash string `json:"hash"` } `json:"html"`
} } `json:"links"`
// Inline is the common Bitbucket Inline Sub Entity
type Inline struct {
Path string `json:"path"`
From *int64 `json:"from"`
To int64 `json:"to"`
}
// ParentID is the common Bitbucket ParentID Sub Entity
type ParentID struct {
ID int64 `json:"id"`
}
// Avatar is the common Bitbucket Avatar Sub Entity
type Avatar struct {
HREF string `json:"href"`
}
// HTML is the common Bitbucket HTML Sub Entity
type HTML struct {
HREF string `json:"href"`
}
// Self is the common Bitbucket Self Sub Entity
type Self struct {
HREF string `json:"href"`
}
// Diff is the common Bitbucket Diff Sub Entity
type Diff struct {
HREF string `json:"href"`
}
// Commits is the common Bitbucket Commits Sub Entity
type Commits struct {
HREF string `json:"href"`
}
// LinksSelfCommit is the common Bitbucket LinksSelfCommit Sub Entity
type LinksSelfCommit struct {
Self Self `json:"self"`
Commit Commits `json:"commit"`
}
// LinksHTMLSelfCommits is the common Bitbucket LinksHTMLSelfCommits Sub Entity
type LinksHTMLSelfCommits struct {
Self Self `json:"self"`
Commits Commits `json:"commits"`
HTML HTML `json:"html"`
}
// LinksHTMLDiffCommits is the common Bitbucket LinksHTMLDiffCommits Sub Entity
type LinksHTMLDiffCommits struct {
HTML HTML `json:"html"`
Diff Diff `json:"diff"`
Commits Commits `json:"commits"`
}
// Links is the common Bitbucket Links Sub Entity
type Links struct {
Avatar Avatar `json:"avatar"`
HTML HTML `json:"html"`
Self Self `json:"self"`
}
// LinksHTMLSelf is the common Bitbucket LinksHTMLSelf Sub Entity
type LinksHTMLSelf struct {
HTML HTML `json:"html"`
Self Self `json:"self"`
}
// Content is the common Bitbucket Content Sub Entity
type Content struct {
HTML string `json:"html"`
Markup string `json:"markup"`
Raw string `json:"raw"`
}
// Milestone is the common Bitbucket Milestone Sub Entity
type Milestone struct {
Name string `json:"name"`
}
// Version is the common Bitbucket Version Sub Entity
type Version struct {
Name string `json:"name"`
} }
+3 -3
View File
@@ -4,8 +4,8 @@ import (
"fmt" "fmt"
"strconv" "strconv"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
"gopkg.in/go-playground/webhooks.v2/github" "gopkg.in/go-playground/webhooks.v3/github"
) )
const ( const (
@@ -33,7 +33,7 @@ func HandleRelease(payload interface{}, header webhooks.Header) {
pl := payload.(github.ReleasePayload) pl := payload.(github.ReleasePayload)
// only want to compile on full releases // only want to compile on full releases
if pl.Release.Draft || pl.Release.Prelelease || pl.Release.TargetCommitish != "master" { if pl.Release.Draft || pl.Release.Prerelease || pl.Release.TargetCommitish != "master" {
return return
} }
+2 -2
View File
@@ -4,8 +4,8 @@ import (
"fmt" "fmt"
"strconv" "strconv"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
"gopkg.in/go-playground/webhooks.v2/github" "gopkg.in/go-playground/webhooks.v3/github"
) )
const ( const (
+56 -11
View File
@@ -8,7 +8,7 @@ import (
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
) )
// Webhook instance contains all methods needed to process events // Webhook instance contains all methods needed to process events
@@ -37,16 +37,25 @@ const (
GollumEvent Event = "gollum" GollumEvent Event = "gollum"
IssueCommentEvent Event = "issue_comment" IssueCommentEvent Event = "issue_comment"
IssuesEvent Event = "issues" IssuesEvent Event = "issues"
LabelEvent Event = "label"
MemberEvent Event = "member" MemberEvent Event = "member"
MembershipEvent Event = "membership" MembershipEvent Event = "membership"
MilestoneEvent Event = "milestone"
OrganizationEvent Event = "organization"
OrgBlockEvent Event = "org_block"
PageBuildEvent Event = "page_build" PageBuildEvent Event = "page_build"
ProjectCardEvent Event = "project_card"
ProjectColumnEvent Event = "project_column"
ProjectEvent Event = "project"
PublicEvent Event = "public" PublicEvent Event = "public"
PullRequestReviewCommentEvent Event = "pull_request_review_comment"
PullRequestEvent Event = "pull_request" PullRequestEvent Event = "pull_request"
PullRequestReviewEvent Event = "pull_request_review"
PullRequestReviewCommentEvent Event = "pull_request_review_comment"
PushEvent Event = "push" PushEvent Event = "push"
RepositoryEvent Event = "repository"
ReleaseEvent Event = "release" ReleaseEvent Event = "release"
RepositoryEvent Event = "repository"
StatusEvent Event = "status" StatusEvent Event = "status"
TeamEvent Event = "team"
TeamAddEvent Event = "team_add" TeamAddEvent Event = "team_add"
WatchEvent Event = "watch" WatchEvent Event = "watch"
) )
@@ -169,6 +178,10 @@ func (hook Webhook) ParsePayload(w http.ResponseWriter, r *http.Request) {
var i IssuesPayload var i IssuesPayload
json.Unmarshal([]byte(payload), &i) json.Unmarshal([]byte(payload), &i)
hook.runProcessPayloadFunc(fn, i, hd) hook.runProcessPayloadFunc(fn, i, hd)
case LabelEvent:
var l LabelPayload
json.Unmarshal([]byte(payload), &l)
hook.runProcessPayloadFunc(fn, l, hd)
case MemberEvent: case MemberEvent:
var m MemberPayload var m MemberPayload
json.Unmarshal([]byte(payload), &m) json.Unmarshal([]byte(payload), &m)
@@ -177,38 +190,70 @@ func (hook Webhook) ParsePayload(w http.ResponseWriter, r *http.Request) {
var m MembershipPayload var m MembershipPayload
json.Unmarshal([]byte(payload), &m) json.Unmarshal([]byte(payload), &m)
hook.runProcessPayloadFunc(fn, m, hd) hook.runProcessPayloadFunc(fn, m, hd)
case MilestoneEvent:
var m MilestonePayload
json.Unmarshal([]byte(payload), &m)
hook.runProcessPayloadFunc(fn, m, hd)
case OrganizationEvent:
var o OrganizationPayload
json.Unmarshal([]byte(payload), &o)
hook.runProcessPayloadFunc(fn, o, hd)
case OrgBlockEvent:
var o OrgBlockPayload
json.Unmarshal([]byte(payload), &o)
hook.runProcessPayloadFunc(fn, o, hd)
case PageBuildEvent: case PageBuildEvent:
var p PageBuildPayload var p PageBuildPayload
json.Unmarshal([]byte(payload), &p) json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd) hook.runProcessPayloadFunc(fn, p, hd)
case ProjectCardEvent:
var p ProjectCardPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case ProjectColumnEvent:
var p ProjectColumnPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case ProjectEvent:
var p ProjectPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case PublicEvent: case PublicEvent:
var p PublicPayload var p PublicPayload
json.Unmarshal([]byte(payload), &p) json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd) hook.runProcessPayloadFunc(fn, p, hd)
case PullRequestReviewCommentEvent:
var p PullRequestReviewCommentPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case PullRequestEvent: case PullRequestEvent:
var p PullRequestPayload var p PullRequestPayload
json.Unmarshal([]byte(payload), &p) json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd) hook.runProcessPayloadFunc(fn, p, hd)
case PullRequestReviewEvent:
var p PullRequestReviewPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case PullRequestReviewCommentEvent:
var p PullRequestReviewCommentPayload
json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd)
case PushEvent: case PushEvent:
var p PushPayload var p PushPayload
json.Unmarshal([]byte(payload), &p) json.Unmarshal([]byte(payload), &p)
hook.runProcessPayloadFunc(fn, p, hd) hook.runProcessPayloadFunc(fn, p, hd)
case RepositoryEvent:
var r RepositoryPayload
json.Unmarshal([]byte(payload), &r)
hook.runProcessPayloadFunc(fn, r, hd)
case ReleaseEvent: case ReleaseEvent:
var r ReleasePayload var r ReleasePayload
json.Unmarshal([]byte(payload), &r) json.Unmarshal([]byte(payload), &r)
hook.runProcessPayloadFunc(fn, r, hd) hook.runProcessPayloadFunc(fn, r, hd)
case RepositoryEvent:
var r RepositoryPayload
json.Unmarshal([]byte(payload), &r)
hook.runProcessPayloadFunc(fn, r, hd)
case StatusEvent: case StatusEvent:
var s StatusPayload var s StatusPayload
json.Unmarshal([]byte(payload), &s) json.Unmarshal([]byte(payload), &s)
hook.runProcessPayloadFunc(fn, s, hd) hook.runProcessPayloadFunc(fn, s, hd)
case TeamEvent:
var t TeamPayload
json.Unmarshal([]byte(payload), &t)
hook.runProcessPayloadFunc(fn, t, hd)
case TeamAddEvent: case TeamAddEvent:
var t TeamAddPayload var t TeamAddPayload
json.Unmarshal([]byte(payload), &t) json.Unmarshal([]byte(payload), &t)
+2169 -633
View File
File diff suppressed because it is too large Load Diff
+4921 -661
View File
File diff suppressed because it is too large Load Diff
+10 -10
View File
@@ -5,7 +5,7 @@ import (
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
) )
// Webhook instance contains all methods needed to process events // Webhook instance contains all methods needed to process events
@@ -25,14 +25,14 @@ type Event string
// GitLab hook types // GitLab hook types
const ( const (
PushEvents Event = "Push Hook" PushEvents Event = "Push Hook"
TagEvents Event = "Tag Push Hook" TagEvents Event = "Tag Push Hook"
IssuesEvents Event = "Issue Hook" IssuesEvents Event = "Issue Hook"
CommentEvents Event = "Note Hook" CommentEvents Event = "Note Hook"
MergerRequestEvents Event = "Merge Request Hook" MergeRequestEvents Event = "Merge Request Hook"
WikiPageEvents Event = "Wiki Page Hook" WikiPageEvents Event = "Wiki Page Hook"
PipelineEvents Event = "Pipeline Hook" PipelineEvents Event = "Pipeline Hook"
BuildEvents Event = "Build Hook" BuildEvents Event = "Build Hook"
) )
// New creates and returns a WebHook instance denoted by the Provider type // New creates and returns a WebHook instance denoted by the Provider type
@@ -115,7 +115,7 @@ func (hook Webhook) ParsePayload(w http.ResponseWriter, r *http.Request) {
json.Unmarshal([]byte(payload), &ce) json.Unmarshal([]byte(payload), &ce)
hook.runProcessPayloadFunc(fn, ce, hd) hook.runProcessPayloadFunc(fn, ce, hd)
case MergerRequestEvents: case MergeRequestEvents:
var mre MergeRequestEventPayload var mre MergeRequestEventPayload
json.Unmarshal([]byte(payload), &mre) json.Unmarshal([]byte(payload), &mre)
hook.runProcessPayloadFunc(fn, mre, hd) hook.runProcessPayloadFunc(fn, mre, hd)
+19 -19
View File
@@ -9,7 +9,7 @@ import (
"time" "time"
. "gopkg.in/go-playground/assert.v1" . "gopkg.in/go-playground/assert.v1"
"gopkg.in/go-playground/webhooks.v2" "gopkg.in/go-playground/webhooks.v3"
) )
// NOTES: // NOTES:
@@ -24,7 +24,7 @@ import (
// //
const ( const (
port = 3009 port = 3011
path = "/webhooks" path = "/webhooks"
) )
@@ -44,13 +44,13 @@ func TestMain(m *testing.M) {
TagEvents, TagEvents,
IssuesEvents, IssuesEvents,
CommentEvents, CommentEvents,
MergerRequestEvents, MergeRequestEvents,
WikiPageEvents, WikiPageEvents,
PipelineEvents, PipelineEvents,
BuildEvents, BuildEvents,
) )
go webhooks.Run(hook, "127.0.0.1:"+strconv.Itoa(port), path) go webhooks.Run(hook, "127.0.0.1:"+strconv.Itoa(port), path)
time.Sleep(5000) time.Sleep(time.Millisecond * 500)
os.Exit(m.Run()) os.Exit(m.Run())
@@ -64,7 +64,7 @@ func TestProvider(t *testing.T) {
func TestBadNoEventHeader(t *testing.T) { func TestBadNoEventHeader(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
Equal(t, err, nil) Equal(t, err, nil)
@@ -81,7 +81,7 @@ func TestBadNoEventHeader(t *testing.T) {
func TestUnsubscribedEvent(t *testing.T) { func TestUnsubscribedEvent(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "noneexistant_event") req.Header.Set("X-Gitlab-Event", "noneexistant_event")
@@ -99,7 +99,7 @@ func TestUnsubscribedEvent(t *testing.T) {
func TestBadBody(t *testing.T) { func TestBadBody(t *testing.T) {
payload := "" payload := ""
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
@@ -117,7 +117,7 @@ func TestBadBody(t *testing.T) {
func TestTokenMissmatch(t *testing.T) { func TestTokenMissmatch(t *testing.T) {
payload := "{}" payload := "{}"
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
req.Header.Set("X-Gitlab-Token", "itsnotasampleToken!") req.Header.Set("X-Gitlab-Token", "itsnotasampleToken!")
@@ -203,7 +203,7 @@ func TestPushEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Push Hook") req.Header.Set("X-Gitlab-Event", "Push Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -261,7 +261,7 @@ func TestTagEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Tag Push Hook") req.Header.Set("X-Gitlab-Event", "Tag Push Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -333,7 +333,7 @@ func TestIssueEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Issue Hook") req.Header.Set("X-Gitlab-Event", "Issue Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -419,7 +419,7 @@ func TestCommentCommitEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -553,7 +553,7 @@ func TestCommentMergeRequestEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -635,7 +635,7 @@ func TestCommentIssueEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -715,7 +715,7 @@ func TestCommentSunippetEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Note Hook") req.Header.Set("X-Gitlab-Event", "Note Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -812,7 +812,7 @@ func TestMergeRequestEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Merge Request Hook") req.Header.Set("X-Gitlab-Event", "Merge Request Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -872,7 +872,7 @@ func TestWikipageEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Wiki Page Hook") req.Header.Set("X-Gitlab-Event", "Wiki Page Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -1045,7 +1045,7 @@ func TestPipelineEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Pipeline Hook") req.Header.Set("X-Gitlab-Event", "Pipeline Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
@@ -1107,7 +1107,7 @@ func TestBuildEvent(t *testing.T) {
} }
` `
req, err := http.NewRequest("POST", "http://127.0.0.1:3009/webhooks", bytes.NewBuffer([]byte(payload))) req, err := http.NewRequest("POST", "http://127.0.0.1:3011/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-Gitlab-Event", "Build Hook") req.Header.Set("X-Gitlab-Event", "Build Hook")
req.Header.Set("X-Gitlab-Token", "sampleToken!") req.Header.Set("X-Gitlab-Token", "sampleToken!")
+63 -63
View File
@@ -54,15 +54,15 @@ type PushEventPayload struct {
After string `json:"after"` After string `json:"after"`
Ref string `json:"ref"` Ref string `json:"ref"`
CheckoutSHA string `json:"checkout_sha"` CheckoutSHA string `json:"checkout_sha"`
UserID int `json:"user_id"` UserID int64 `json:"user_id"`
UserName string `json:"user_name"` UserName string `json:"user_name"`
UserEmail string `json:"user_email"` UserEmail string `json:"user_email"`
UserAvatar string `json:"user_avatar"` UserAvatar string `json:"user_avatar"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
Project Project `json:"Project"` Project Project `json:"Project"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
Commits []Commit `json:"commits"` Commits []Commit `json:"commits"`
TotalCommitsCount int `json:"total_commits_count"` TotalCommitsCount int64 `json:"total_commits_count"`
} }
// TagEventPayload contains the information for GitLab's tag push event // TagEventPayload contains the information for GitLab's tag push event
@@ -72,14 +72,14 @@ type TagEventPayload struct {
After string `json:"after"` After string `json:"after"`
Ref string `json:"ref"` Ref string `json:"ref"`
CheckoutSHA string `json:"checkout_sha"` CheckoutSHA string `json:"checkout_sha"`
UserID int `json:"user_id"` UserID int64 `json:"user_id"`
UserName string `json:"user_name"` UserName string `json:"user_name"`
UserAvatar string `json:"user_avatar"` UserAvatar string `json:"user_avatar"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
Project Project `json:"Project"` Project Project `json:"Project"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
Commits []Commit `json:"commits"` Commits []Commit `json:"commits"`
TotalCommitsCount int `json:"total_commits_count"` TotalCommitsCount int64 `json:"total_commits_count"`
} }
// WikiPageEventPayload contains the information for GitLab's wiki created/updated event // WikiPageEventPayload contains the information for GitLab's wiki created/updated event
@@ -105,7 +105,7 @@ type PipelineEventPayload struct {
type CommentEventPayload struct { type CommentEventPayload struct {
ObjectKind string `json:"object_kind"` ObjectKind string `json:"object_kind"`
User User `json:"user"` User User `json:"user"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
Project Project `json:"project"` Project Project `json:"project"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
ObjectAttributes ObjectAttributes `json:"object_attributes"` ObjectAttributes ObjectAttributes `json:"object_attributes"`
@@ -122,41 +122,41 @@ type BuildEventPayload struct {
Tag bool `json:"tag"` Tag bool `json:"tag"`
BeforeSHA string `json:"before_sha"` BeforeSHA string `json:"before_sha"`
SHA string `json:"sha"` SHA string `json:"sha"`
BuildID int `json:"build_id"` BuildID int64 `json:"build_id"`
BuildName string `json:"build_name"` BuildName string `json:"build_name"`
BuildStage string `json:"build_stage"` BuildStage string `json:"build_stage"`
BuildStatus string `json:"build_status"` BuildStatus string `json:"build_status"`
BuildStartedAt customTime `json:"build_started_at"` BuildStartedAt customTime `json:"build_started_at"`
BuildFinishedAt customTime `json:"build_finished_at"` BuildFinishedAt customTime `json:"build_finished_at"`
BuildDuration int `json:"build_duration"` BuildDuration int64 `json:"build_duration"`
BuildAllowFailure bool `json:"build_allow_failure"` BuildAllowFailure bool `json:"build_allow_failure"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
ProjectName string `json:"project_name"` ProjectName string `json:"project_name"`
User User `json:"user"` User User `json:"user"`
Commit BuildCommit `json:"commit"` Commit BuildCommit `json:"commit"`
Repository Repository `json:"repository"` Repository Repository `json:"repository"`
} }
// Issue contais all of the GitLab issue information // Issue contains all of the GitLab issue information
type Issue struct { type Issue struct {
ID int `json:"id"` ID int64 `json:"id"`
Title string `json:"title"` Title string `json:"title"`
AssigneeID int `json:"assignee_id"` AssigneeID int64 `json:"assignee_id"`
AuthorID int `json:"author_id"` AuthorID int64 `json:"author_id"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
CreatedAt customTime `json:"created_at"` CreatedAt customTime `json:"created_at"`
UpdatedAt customTime `json:"updated_at"` UpdatedAt customTime `json:"updated_at"`
Position int `json:"position"` Position int64 `json:"position"`
BranchName string `json:"branch_name"` BranchName string `json:"branch_name"`
Description string `json:"description"` Description string `json:"description"`
MilestoneID int `json:"milestone_id"` MilestoneID int64 `json:"milestone_id"`
State string `json:"state"` State string `json:"state"`
IID int `json:"iid"` IID int64 `json:"iid"`
} }
// Build contais all of the GitLab build information // Build contains all of the GitLab build information
type Build struct { type Build struct {
ID int `json:"id"` ID int64 `json:"id"`
Stage string `json:"stage"` Stage string `json:"stage"`
Name string `json:"name"` Name string `json:"name"`
Status string `json:"status"` Status string `json:"status"`
@@ -170,13 +170,13 @@ type Build struct {
ArtifactsFile ArtifactsFile `json:"artifactsfile"` ArtifactsFile ArtifactsFile `json:"artifactsfile"`
} }
// ArtifactsFile contais all of the GitLab artifact information // ArtifactsFile contains all of the GitLab artifact information
type ArtifactsFile struct { type ArtifactsFile struct {
Filename string `json:"filename"` Filename string `json:"filename"`
Size string `json:"size"` Size string `json:"size"`
} }
// Wiki contais all of the GitLab wiki information // Wiki contains all of the GitLab wiki information
type Wiki struct { type Wiki struct {
WebURL string `json:"web_url"` WebURL string `json:"web_url"`
GitSSHURL string `json:"git_ssh_url"` GitSSHURL string `json:"git_ssh_url"`
@@ -185,7 +185,7 @@ type Wiki struct {
DefaultBranch string `json:"default_branch"` DefaultBranch string `json:"default_branch"`
} }
// Commit contais all of the GitLab commit information // Commit contains all of the GitLab commit information
type Commit struct { type Commit struct {
ID string `json:"id"` ID string `json:"id"`
Message string `json:"message"` Message string `json:"message"`
@@ -197,42 +197,42 @@ type Commit struct {
Removed []string `json:"removed"` Removed []string `json:"removed"`
} }
// BuildCommit contais all of the GitLab build commit information // BuildCommit contains all of the GitLab build commit information
type BuildCommit struct { type BuildCommit struct {
ID int `json:"id"` ID int64 `json:"id"`
SHA string `json:"sha"` SHA string `json:"sha"`
Message string `json:"message"` Message string `json:"message"`
AuthorName string `json:"auuthor_name"` AuthorName string `json:"auuthor_name"`
AuthorEmail string `json:"author_email"` AuthorEmail string `json:"author_email"`
Status string `json:"status"` Status string `json:"status"`
Duration int `json:"duration"` Duration int64 `json:"duration"`
StartedAt customTime `json:"started_at"` StartedAt customTime `json:"started_at"`
FinishedAt customTime `json:"finished_at"` FinishedAt customTime `json:"finished_at"`
} }
// Snippet contais all of the GitLab snippet information // Snippet contains all of the GitLab snippet information
type Snippet struct { type Snippet struct {
ID int `json:"id"` ID int64 `json:"id"`
Title string `json:"title"` Title string `json:"title"`
Content string `json:"content"` Content string `json:"content"`
AuthorID int `json:"author_id"` AuthorID int64 `json:"author_id"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
CreatedAt customTime `json:"created_at"` CreatedAt customTime `json:"created_at"`
UpdatedAt customTime `json:"updated_at"` UpdatedAt customTime `json:"updated_at"`
FileName string `json:"file_name"` FileName string `json:"file_name"`
ExpiresAt customTime `json:"expires_at"` ExpiresAt customTime `json:"expires_at"`
Type string `json:"type"` Type string `json:"type"`
VisibilityLevel int `json:"visibility_level"` VisibilityLevel int64 `json:"visibility_level"`
} }
// User contais all of the GitLab user information // User contains all of the GitLab user information
type User struct { type User struct {
Name string `json:"name"` Name string `json:"name"`
UserName string `json:"username"` UserName string `json:"username"`
AvatarURL string `json:"avatar_url"` AvatarURL string `json:"avatar_url"`
} }
// Project contais all of the GitLab project information // Project contains all of the GitLab project information
type Project struct { type Project struct {
Name string `json:"name"` Name string `json:"name"`
Description string `json:"description"` Description string `json:"description"`
@@ -241,7 +241,7 @@ type Project struct {
GitSSSHURL string `json:"git_ssh_url"` GitSSSHURL string `json:"git_ssh_url"`
GitHTTPURL string `json:"git_http_url"` GitHTTPURL string `json:"git_http_url"`
Namespace string `json:"namespace"` Namespace string `json:"namespace"`
VisibilityLevel int `json:"visibility_level"` VisibilityLevel int64 `json:"visibility_level"`
PathWithNamespace string `json:"path_with_namespace"` PathWithNamespace string `json:"path_with_namespace"`
DefaultBranch string `json:"default_branch"` DefaultBranch string `json:"default_branch"`
Homepage string `json:"homepage"` Homepage string `json:"homepage"`
@@ -250,7 +250,7 @@ type Project struct {
HTTPURL string `json:"http_url"` HTTPURL string `json:"http_url"`
} }
// Repository contais all of the GitLab repository information // Repository contains all of the GitLab repository information
type Repository struct { type Repository struct {
Name string `json:"name"` Name string `json:"name"`
URL string `json:"url"` URL string `json:"url"`
@@ -258,27 +258,27 @@ type Repository struct {
Homepage string `json:"homepage"` Homepage string `json:"homepage"`
} }
// ObjectAttributes contais all of the GitLab object attributes information // ObjectAttributes contains all of the GitLab object attributes information
type ObjectAttributes struct { type ObjectAttributes struct {
ID int `json:"id"` ID int64 `json:"id"`
Title string `json:"title"` Title string `json:"title"`
AssigneeID int `json:"assignee_id"` AssigneeID int64 `json:"assignee_id"`
AuthorID int `json:"author_id"` AuthorID int64 `json:"author_id"`
ProjectID int `json:"project_id"` ProjectID int64 `json:"project_id"`
CreatedAt customTime `json:"created_at"` CreatedAt customTime `json:"created_at"`
UpdatedAt customTime `json:"updated_at"` UpdatedAt customTime `json:"updated_at"`
Position int `json:"position"` Position int64 `json:"position"`
BranchName string `json:"branch_name"` BranchName string `json:"branch_name"`
Description string `json:"description"` Description string `json:"description"`
MilestoneID int `json:"milestone_id"` MilestoneID int64 `json:"milestone_id"`
State string `json:"state"` State string `json:"state"`
IID int `json:"iid"` IID int64 `json:"iid"`
URL string `json:"url"` URL string `json:"url"`
Action string `json:"action"` Action string `json:"action"`
TargetBranch string `json:"target_branch"` TargetBranch string `json:"target_branch"`
SourceBranch string `json:"source_branch"` SourceBranch string `json:"source_branch"`
SourceProjectID int `json:"source_project_id"` SourceProjectID int64 `json:"source_project_id"`
TargetProjectID int `json:"target_project_id"` TargetProjectID int64 `json:"target_project_id"`
StCommits string `json:"st_commits"` StCommits string `json:"st_commits"`
MergeStatus string `json:"merge_status"` MergeStatus string `json:"merge_status"`
Content string `json:"content"` Content string `json:"content"`
@@ -291,13 +291,13 @@ type ObjectAttributes struct {
BeforeSHA string `json:"before_sha"` BeforeSHA string `json:"before_sha"`
Status string `json:"status"` Status string `json:"status"`
Stages []string `json:"stages"` Stages []string `json:"stages"`
Duration int `json:"duration"` Duration int64 `json:"duration"`
Note string `json:"note"` Note string `json:"note"`
NotebookType string `json:"noteable_type"` NotebookType string `json:"noteable_type"`
At customTime `json:"attachment"` At customTime `json:"attachment"`
LineCode string `json:"line_code"` LineCode string `json:"line_code"`
CommitID string `json:"commit_id"` CommitID string `json:"commit_id"`
NoteableID int `json:"noteable_id"` NoteableID int64 `json:"noteable_id"`
System bool `json:"system"` System bool `json:"system"`
WorkInProgress bool `json:"work_in_progress"` WorkInProgress bool `json:"work_in_progress"`
StDiffs []StDiff `json:"st_diffs"` StDiffs []StDiff `json:"st_diffs"`
@@ -307,24 +307,24 @@ type ObjectAttributes struct {
Assignee Assignee `json:"assignee"` Assignee Assignee `json:"assignee"`
} }
// MergeRequest contais all of the GitLab merge request information // MergeRequest contains all of the GitLab merge request information
type MergeRequest struct { type MergeRequest struct {
ID int `json:"id"` ID int64 `json:"id"`
TargetBranch string `json:"target_branch"` TargetBranch string `json:"target_branch"`
SourceBranch string `json:"source_branch"` SourceBranch string `json:"source_branch"`
SourceProjectID string `json:"source_project_id"` SourceProjectID string `json:"source_project_id"`
AssigneeID int `json:"assignee_id"` AssigneeID int64 `json:"assignee_id"`
AuthorID int `json:"author_id"` AuthorID int64 `json:"author_id"`
Title string `json:"title"` Title string `json:"title"`
CreatedAt customTime `json:"created_at"` CreatedAt customTime `json:"created_at"`
UpdatedAt customTime `json:"updated_at"` UpdatedAt customTime `json:"updated_at"`
MilestoneID int `json:"milestone_id"` MilestoneID int64 `json:"milestone_id"`
State string `json:"state"` State string `json:"state"`
MergeStatus string `json:"merge_status"` MergeStatus string `json:"merge_status"`
TargetProjectID int `json:"target_project_id"` TargetProjectID int64 `json:"target_project_id"`
IID int `json:"iid"` IID int64 `json:"iid"`
Description string `json:"description"` Description string `json:"description"`
Position int `json:"position"` Position int64 `json:"position"`
LockedAt customTime `json:"locked_at"` LockedAt customTime `json:"locked_at"`
Source Source `json:"source"` Source Source `json:"source"`
Target Target `json:"target"` Target Target `json:"target"`
@@ -333,14 +333,14 @@ type MergeRequest struct {
Assignee Assignee `json:"assignee"` Assignee Assignee `json:"assignee"`
} }
// Assignee contais all of the GitLab assignee information // Assignee contains all of the GitLab assignee information
type Assignee struct { type Assignee struct {
Name string `json:"name"` Name string `json:"name"`
Username string `json:"username"` Username string `json:"username"`
AvatarURL string `json:"avatar_url"` AvatarURL string `json:"avatar_url"`
} }
// StDiff contais all of the GitLab diff information // StDiff contains all of the GitLab diff information
type StDiff struct { type StDiff struct {
Diff string `json:"diff"` Diff string `json:"diff"`
NewPath string `json:"new_path"` NewPath string `json:"new_path"`
@@ -352,7 +352,7 @@ type StDiff struct {
DeletedFile bool `json:"deleted_file"` DeletedFile bool `json:"deleted_file"`
} }
// Source contais all of the GitLab source information // Source contains all of the GitLab source information
type Source struct { type Source struct {
Name string `json:"name"` Name string `json:"name"`
Description string `json:"description"` Description string `json:"description"`
@@ -361,7 +361,7 @@ type Source struct {
GitSSHURL string `json:"git_ssh_url"` GitSSHURL string `json:"git_ssh_url"`
GitHTTPURL string `json:"git_http_url"` GitHTTPURL string `json:"git_http_url"`
Namespace string `json:"namespace"` Namespace string `json:"namespace"`
VisibilityLevel int `json:"visibility_level"` VisibilityLevel int64 `json:"visibility_level"`
PathWithNamespace string `json:"path_with_namespace"` PathWithNamespace string `json:"path_with_namespace"`
DefaultBranch string `json:"default_branch"` DefaultBranch string `json:"default_branch"`
Homepage string `json:"homepage"` Homepage string `json:"homepage"`
@@ -370,7 +370,7 @@ type Source struct {
HTTPURL string `json:"http_url"` HTTPURL string `json:"http_url"`
} }
// Target contais all of the GitLab target information // Target contains all of the GitLab target information
type Target struct { type Target struct {
Name string `json:"name"` Name string `json:"name"`
Description string `json:"description"` Description string `json:"description"`
@@ -379,7 +379,7 @@ type Target struct {
GitSSHURL string `json:"git_ssh_url"` GitSSHURL string `json:"git_ssh_url"`
GitHTTPURL string `json:"git_http_url"` GitHTTPURL string `json:"git_http_url"`
Namespace string `json:"namespace"` Namespace string `json:"namespace"`
VisibilityLevel int `json:"visibility_level"` VisibilityLevel int64 `json:"visibility_level"`
PathWithNamespace string `json:"path_with_namespace"` PathWithNamespace string `json:"path_with_namespace"`
DefaultBranch string `json:"default_branch"` DefaultBranch string `json:"default_branch"`
Homepage string `json:"homepage"` Homepage string `json:"homepage"`
@@ -388,7 +388,7 @@ type Target struct {
HTTPURL string `json:"http_url"` HTTPURL string `json:"http_url"`
} }
// LastCommit contais all of the GitLab last commit information // LastCommit contains all of the GitLab last commit information
type LastCommit struct { type LastCommit struct {
ID string `json:"id"` ID string `json:"id"`
Message string `json:"message"` Message string `json:"message"`
@@ -397,7 +397,7 @@ type LastCommit struct {
Author Author `json:"author"` Author Author `json:"author"`
} }
// Author contais all of the GitLab author information // Author contains all of the GitLab author information
type Author struct { type Author struct {
Name string `json:"name"` Name string `json:"name"`
Email string `json:"email"` Email string `json:"email"`
+26 -12
View File
@@ -28,25 +28,34 @@ const (
GitLab GitLab
) )
// Webhook interface defines a webhook to recieve events // Webhook interface defines a webhook to receive events
type Webhook interface { type Webhook interface {
Provider() Provider Provider() Provider
ParsePayload(w http.ResponseWriter, r *http.Request) ParsePayload(w http.ResponseWriter, r *http.Request)
} }
type server struct { type server struct {
hook Webhook hook Webhook
path string path string
includePathCheck bool
} }
// ProcessPayloadFunc is a common function for payload return values // ProcessPayloadFunc is a common function for payload return values
type ProcessPayloadFunc func(payload interface{}, header Header) type ProcessPayloadFunc func(payload interface{}, header Header)
// Handler returns the webhook http.Handler for use in your own Mux implementation
func Handler(hook Webhook) http.Handler {
return &server{
hook: hook,
}
}
// Run runs a server // Run runs a server
func Run(hook Webhook, addr string, path string) error { func Run(hook Webhook, addr string, path string) error {
srv := &server{ srv := &server{
hook: hook, hook: hook,
path: path, path: path,
includePathCheck: true,
} }
s := &http.Server{Addr: addr, Handler: srv} s := &http.Server{Addr: addr, Handler: srv}
@@ -58,8 +67,9 @@ func Run(hook Webhook, addr string, path string) error {
func RunServer(s *http.Server, hook Webhook, path string) error { func RunServer(s *http.Server, hook Webhook, path string) error {
srv := &server{ srv := &server{
hook: hook, hook: hook,
path: path, path: path,
includePathCheck: true,
} }
s.Handler = srv s.Handler = srv
@@ -74,8 +84,9 @@ func RunServer(s *http.Server, hook Webhook, path string) error {
func RunTLSServer(s *http.Server, hook Webhook, path string) error { func RunTLSServer(s *http.Server, hook Webhook, path string) error {
srv := &server{ srv := &server{
hook: hook, hook: hook,
path: path, path: path,
includePathCheck: true,
} }
s.Handler = srv s.Handler = srv
@@ -91,9 +102,12 @@ func (s *server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
http.Error(w, "405 Method not allowed", http.StatusMethodNotAllowed) http.Error(w, "405 Method not allowed", http.StatusMethodNotAllowed)
return return
} }
if r.URL.Path != s.path {
http.Error(w, "404 Not found", http.StatusNotFound) if s.includePathCheck {
return if r.URL.Path != s.path {
http.Error(w, "404 Not found", http.StatusNotFound)
return
}
} }
s.hook.ParsePayload(w, r) s.hook.ParsePayload(w, r)
+39
View File
@@ -8,6 +8,8 @@ import (
"testing" "testing"
"time" "time"
"net/http/httptest"
. "gopkg.in/go-playground/assert.v1" . "gopkg.in/go-playground/assert.v1"
) )
@@ -47,6 +49,43 @@ func TestMain(m *testing.M) {
// teardown // teardown
} }
func TestHandler(t *testing.T) {
mux := http.NewServeMux()
mux.Handle("/webhooks", Handler(fakeHook))
s := httptest.NewServer(Handler(fakeHook))
defer s.Close()
payload := "{}"
req, err := http.NewRequest("POST", s.URL+"/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json")
Equal(t, err, nil)
client := &http.Client{}
resp, err := client.Do(req)
Equal(t, err, nil)
defer resp.Body.Close()
Equal(t, resp.StatusCode, http.StatusOK)
// Test BAD METHOD
req, err = http.NewRequest("GET", s.URL+"/webhooks", bytes.NewBuffer([]byte(payload)))
req.Header.Set("Content-Type", "application/json")
Equal(t, err, nil)
resp, err = client.Do(req)
Equal(t, err, nil)
defer resp.Body.Close()
Equal(t, resp.StatusCode, http.StatusMethodNotAllowed)
}
func TestRun(t *testing.T) { func TestRun(t *testing.T) {
go Run(fakeHook, "127.0.0.1:3006", "/webhooks") go Run(fakeHook, "127.0.0.1:3006", "/webhooks")