Add NewWebhookService func

Signed-off-by: jtcheng <[email protected]>

scm/driver/bitbucket/bitbucket.go

@@ -16,6 +16,10 @@ import (
  "github.com/jenkins-x/go-scm/scm"
 )
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new Bitbucket API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/driver/gitea/gitea.go

@@ -18,6 +18,10 @@ import (
  "github.com/jenkins-x/go-scm/scm"
 )
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new Gitea API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/driver/github/github.go

@@ -25,6 +25,10 @@ import (
 // but will prevent an indefinite stall if GitHub never responds.
 const maxRequestTime = 5 * time.Minute
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new GitHub API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/driver/gitlab/gitlab.go

@@ -18,6 +18,10 @@ import (
  "github.com/jenkins-x/go-scm/scm"
 )
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new GitLab API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/driver/gogs/gogs.go

@@ -18,6 +18,10 @@ import (
  "github.com/jenkins-x/go-scm/scm"
 )
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new Gogs API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/driver/stash/stash.go

@@ -20,6 +20,10 @@ import (
 // Reference API Documentation:
 // https://docs.atlassian.com/bitbucket-server/rest/5.11.1/bitbucket-rest.html
 
+func NewWebHookService() scm.WebhookService {
+ return &webhookService{nil}
+}
+
 // New returns a new Stash API client.
 func New(uri string) (*scm.Client, error) {
  base, err := url.Parse(uri)

scm/factory/factory.go

@@ -136,3 +136,30 @@ func Client(httpClient *http.Client) clientOptionFunc {
  c.Client = httpClient
  }
 }
+
+func NewWebHookService(driver string) (scm.WebhookService, error) {
+ if driver == "" {
+ driver = "github"
+ }
+ var service scm.WebhookService = nil
+ switch driver {
+ case "bitbucket", "bitbucketcloud":
+ service = bitbucket.NewWebHookService()
+ case "fake", "fakegit":
+ // TODO: support fake
+ case "gitea":
+ service = gitea.NewWebHookService()
+ case "github":
+ service = github.NewWebHookService()
+ case "gitlab":
+ service = gitlab.NewWebHookService()
+ case "gogs":
+ service = gogs.NewWebHookService()
+ case "stash", "bitbucketserver":
+ service = stash.NewWebHookService()
+ default:
+ return nil, fmt.Errorf("Unsupported GIT_KIND value: %s", driver)
+ }
+
+ return service, nil
+}