Fixed bugs in webhooks

* Added notice in README about go dep bug.
* Added endpoints for webhooks in mock server
* Change names of some parameters on public methods to make their use clearer.
* Changed signature of `GetWebhook()` now returns []string.
* Changed signature of `ListWebhooks()` now returns map[string][]string.
* Both `GetWebhooks()` and `ListWebhooks()` now handle new and legacy webhooks properly.

CHANGELOG

@@ -4,6 +4,22 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [3.5.0] - 2019-05-21
+### Added
+* Added notice in README about go dep bug.
+* Added endpoints for webhooks in mock server
+### Changes
+* Change names of some parameters on public methods to make their use clearer.
+* Changed signature of `GetWebhook()` now returns []string.
+* Changed signature of `ListWebhooks()` now returns map[string][]string.
+* Both `GetWebhooks()` and `ListWebhooks()` now handle new and legacy webhooks properly.
+
+## [3.4.0] - 2019-04-23
+### Added
+* Added `Message.SetTemplate()` to allow sending with the body of a template.
+### Changes
+* Changed signature of `CreateDomain()` moved password into `CreateDomainOptions`
+
 ## [3.4.0] - 2019-04-23
 ### Added
 * Added `Message.SetTemplate()` to allow sending with the body of a template.

README.md

@@ -275,6 +275,16 @@ in your code should work fine even if you do not have golang modules enabled for
 $ go get github.com/mailgun/mailgun-go
 ```
 
+**NOTE for go dep users**
+
+Using version 3 of the mailgun-go library with go dep currently results in the following error
+```
+"github.com/mailgun/mailgun-go/v3/events", which contains malformed code: no package exists at ...
+```
+This is a known bug in go dep. You can follow the PR to fix this bug [here](https://github.com/golang/dep/pull/1963)
+Until this bug is fixed, the best way to use version 3 of the mailgun-go library is to use the golang community 
+supported [golang modules](https://github.com/golang/go/wiki/Modules).
+
 ## Testing
 
 *WARNING* - running the tests will cost you money!

credentials.go

@@ -190,11 +190,11 @@ func (mg *MailgunImpl) CreateCredential(ctx context.Context, login, password str
 }
 
 // ChangeCredentialPassword attempts to alter the indicated credential's password.
-func (mg *MailgunImpl) ChangeCredentialPassword(ctx context.Context, id, password string) error {
-	if (id == "") || (password == "") {
+func (mg *MailgunImpl) ChangeCredentialPassword(ctx context.Context, login, password string) error {
+	if (login == "") || (password == "") {
 		return ErrEmptyParam
 	}
-	r := newHTTPRequest(generateCredentialsUrl(mg, id))
+	r := newHTTPRequest(generateCredentialsUrl(mg, login))
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
 	p := newUrlEncodedPayload()
@@ -204,11 +204,11 @@ func (mg *MailgunImpl) ChangeCredentialPassword(ctx context.Context, id, passwor
 }
 
 // DeleteCredential attempts to remove the indicated principle from the domain.
-func (mg *MailgunImpl) DeleteCredential(ctx context.Context, id string) error {
-	if id == "" {
+func (mg *MailgunImpl) DeleteCredential(ctx context.Context, login string) error {
+	if login == "" {
 		return ErrEmptyParam
 	}
-	r := newHTTPRequest(generateCredentialsUrl(mg, id))
+	r := newHTTPRequest(generateCredentialsUrl(mg, login))
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
 	_, err := makeDeleteRequest(ctx, r)

examples/examples.go

@@ -626,7 +626,7 @@ func ValidateEmail(apiKey string) (mailgun.EmailVerification, error) {
 	return mv.ValidateEmail(ctx, "[email protected]", false)
 }
 
-func GetWebhook(domain, apiKey string) (string, error) {
+func GetWebhook(domain, apiKey string) ([]string, error) {
 	mg := mailgun.NewMailgun(domain, apiKey)
 
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
@@ -635,7 +635,7 @@ func GetWebhook(domain, apiKey string) (string, error) {
 	return mg.GetWebhook(ctx, "clicked")
 }
 
-func ListWebhooks(domain, apiKey string) (map[string]string, error) {
+func ListWebhooks(domain, apiKey string) (map[string][]string, error) {
 	mg := mailgun.NewMailgun(domain, apiKey)
 
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)

mailgun.go

@@ -159,8 +159,8 @@ type Mailgun interface {
 
 	ListCredentials(opts *ListOptions) *CredentialsIterator
 	CreateCredential(ctx context.Context, login, password string) error
-	ChangeCredentialPassword(ctx context.Context, id, password string) error
-	DeleteCredential(ctx context.Context, id string) error
+	ChangeCredentialPassword(ctx context.Context, login, password string) error
+	DeleteCredential(ctx context.Context, login string) error
 
 	ListUnsubscribes(opts *ListOptions) *UnsubscribesIterator
 	GetUnsubscribe(ctx context.Context, address string) (Unsubscribe, error)
@@ -179,10 +179,10 @@ type Mailgun interface {
 	DeleteRoute(ctx context.Context, address string) error
 	UpdateRoute(ctx context.Context, address string, r Route) (Route, error)
 
-	ListWebhooks(ctx context.Context) (map[string]string, error)
+	ListWebhooks(ctx context.Context) (map[string][]string, error)
 	CreateWebhook(ctx context.Context, kind string, url []string) error
 	DeleteWebhook(ctx context.Context, kind string) error
-	GetWebhook(ctx context.Context, kind string) (string, error)
+	GetWebhook(ctx context.Context, kind string) ([]string, error)
 	UpdateWebhook(ctx context.Context, kind string, url []string) error
 	VerifyWebhookRequest(req *http.Request) (verified bool, err error)
 
@@ -216,16 +216,16 @@ type Mailgun interface {
 	GetTagLimits(ctx context.Context, domain string) (TagLimits, error)
 
 	CreateTemplate(ctx context.Context, template *Template) error
-	GetTemplate(ctx context.Context, id string) (Template, error)
+	GetTemplate(ctx context.Context, name string) (Template, error)
 	UpdateTemplate(ctx context.Context, template *Template) error
-	DeleteTemplate(ctx context.Context, id string) error
+	DeleteTemplate(ctx context.Context, name string) error
 	ListTemplates(opts *ListTemplateOptions) *TemplatesIterator
 
-	AddTemplateVersion(ctx context.Context, templateId string, version *TemplateVersion) error
-	GetTemplateVersion(ctx context.Context, templateId, versionId string) (TemplateVersion, error)
-	UpdateTemplateVersion(ctx context.Context, templateId string, version *TemplateVersion) error
-	DeleteTemplateVersion(ctx context.Context, templateId, versionId string) error
-	ListTemplateVersions(templateId string, opts *ListOptions) *TemplateVersionsIterator
+	AddTemplateVersion(ctx context.Context, templateName string, version *TemplateVersion) error
+	GetTemplateVersion(ctx context.Context, templateName, tag string) (TemplateVersion, error)
+	UpdateTemplateVersion(ctx context.Context, templateName string, version *TemplateVersion) error
+	DeleteTemplateVersion(ctx context.Context, templateName, tag string) error
+	ListTemplateVersions(templateName string, opts *ListOptions) *TemplateVersionsIterator
 }
 
 // MailgunImpl bundles data needed by a large number of methods in order to interact with the Mailgun API.
@@ -336,10 +336,10 @@ func generateDomainApiUrl(m Mailgun, endpoint string) string {
 
 // generateCredentialsUrl renders a URL as generateDomainApiUrl,
 // but focuses on the SMTP credentials family of API functions.
-func generateCredentialsUrl(m Mailgun, id string) string {
+func generateCredentialsUrl(m Mailgun, login string) string {
 	tail := ""
-	if id != "" {
-		tail = fmt.Sprintf("/%s", id)
+	if login != "" {
+		tail = fmt.Sprintf("/%s", login)
 	}
 	return generateDomainApiUrl(m, fmt.Sprintf("credentials%s", tail))
 	// return fmt.Sprintf("%s/domains/%s/credentials%s", apiBase, m.Domain(), tail)

mock.go

@@ -24,6 +24,7 @@ type MockServer struct {
 	mailingList []mailingListContainer
 	routeList   []Route
 	events      []Event
+	webhooks    WebHooksListResponse
 }
 
 // Create a new instance of the mailgun API mock server
@@ -42,6 +43,7 @@ func NewMockServer() MockServer {
 		ms.addMessagesRoutes(r)
 		ms.addValidationRoutes(r)
 		ms.addRoutes(r)
+		ms.addWebhookRoutes(r)
 	})
 
 	// Start the server

mock_webhooks.go

@@ -0,0 +1,83 @@
+package mailgun
+
+import (
+	"net/http"
+
+	"github.com/go-chi/chi"
+)
+
+func (ms *MockServer) addWebhookRoutes(r chi.Router) {
+	r.Route("/domains/{domain}/webhooks", func(r chi.Router) {
+		r.Get("/", ms.listWebHooks)
+		r.Post("/", ms.postWebHook)
+		r.Get("/{webhook}", ms.getWebHook)
+		r.Put("/{webhook}", ms.putWebHook)
+		r.Delete("/{webhook}", ms.deleteWebHook)
+	})
+	ms.webhooks = WebHooksListResponse{
+		Webhooks: map[string]UrlOrUrls{
+			"new-webhook": {
+				Urls: []string{"http://example.com/new"},
+			},
+			"legacy-webhook": {
+				Url: "http://example.com/legacy",
+			},
+		},
+	}
+}
+
+func (ms *MockServer) listWebHooks(w http.ResponseWriter, _ *http.Request) {
+	toJSON(w, ms.webhooks)
+}
+
+func (ms *MockServer) getWebHook(w http.ResponseWriter, r *http.Request) {
+	resp := WebHookResponse{
+		Webhook: UrlOrUrls{
+			Urls: ms.webhooks.Webhooks[chi.URLParam(r, "webhook")].Urls,
+		},
+	}
+	toJSON(w, resp)
+}
+
+func (ms *MockServer) postWebHook(w http.ResponseWriter, r *http.Request) {
+	if err := r.ParseForm(); err != nil {
+		w.WriteHeader(http.StatusBadRequest)
+		toJSON(w, okResp{Message: err.Error()})
+		return
+	}
+
+	var urls []string
+	for _, url := range r.Form["url"] {
+		urls = append(urls, url)
+	}
+	ms.webhooks.Webhooks[r.FormValue("id")] = UrlOrUrls{Urls: urls}
+
+	toJSON(w, okResp{Message: "success"})
+}
+
+func (ms *MockServer) putWebHook(w http.ResponseWriter, r *http.Request) {
+	if err := r.ParseForm(); err != nil {
+		w.WriteHeader(http.StatusBadRequest)
+		toJSON(w, okResp{Message: err.Error()})
+		return
+	}
+
+	var urls []string
+	for _, url := range r.Form["url"] {
+		urls = append(urls, url)
+	}
+	ms.webhooks.Webhooks[chi.URLParam(r, "webhook")] = UrlOrUrls{Urls: urls}
+
+	toJSON(w, okResp{Message: "success"})
+}
+
+func (ms *MockServer) deleteWebHook(w http.ResponseWriter, r *http.Request) {
+	_, ok := ms.webhooks.Webhooks[chi.URLParam(r, "webhook")]
+	if !ok {
+		w.WriteHeader(http.StatusNotFound)
+		toJSON(w, okResp{Message: "webhook not found"})
+	}
+
+	delete(ms.webhooks.Webhooks, chi.URLParam(r, "webhook"))
+	toJSON(w, okResp{Message: "success"})
+}

webhooks.go

@@ -6,41 +6,58 @@ import (
 	"crypto/sha256"
 	"crypto/subtle"
 	"encoding/hex"
+	"fmt"
 	"io"
 	"net/http"
 
 	"github.com/mailgun/mailgun-go/v3/events"
 )
 
+type UrlOrUrls struct {
+	Urls []string `json:"urls"`
+	Url  string   `json:"url"`
+}
+
+type WebHooksListResponse struct {
+	Webhooks map[string]UrlOrUrls `json:"webhooks"`
+}
+
+type WebHookResponse struct {
+	Webhook UrlOrUrls `json:"webhook"`
+}
+
 // ListWebhooks returns the complete set of webhooks configured for your domain.
 // Note that a zero-length mapping is not an error.
-func (mg *MailgunImpl) ListWebhooks(ctx context.Context) (map[string]string, error) {
+func (mg *MailgunImpl) ListWebhooks(ctx context.Context) (map[string][]string, error) {
 	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint))
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
-	var envelope struct {
-		Webhooks map[string]interface{} `json:"webhooks"`
-	}
-	err := getResponseFromJSON(ctx, r, &envelope)
-	hooks := make(map[string]string, 0)
+
+	var body WebHooksListResponse
+	err := getResponseFromJSON(ctx, r, &body)
 	if err != nil {
-		return hooks, err
+		return nil, err
 	}
-	for k, v := range envelope.Webhooks {
-		object := v.(map[string]interface{})
-		url := object["url"]
-		hooks[k] = url.(string)
+
+	hooks := make(map[string][]string, 0)
+	for k, v := range body.Webhooks {
+		if v.Url != "" {
+			hooks[k] = []string{v.Url}
+		}
+		if len(v.Urls) != 0 {
+			hooks[k] = append(hooks[k], v.Urls...)
+		}
 	}
 	return hooks, nil
 }
 
 // CreateWebhook installs a new webhook for your domain.
-func (mg *MailgunImpl) CreateWebhook(ctx context.Context, t string, urls []string) error {
+func (mg *MailgunImpl) CreateWebhook(ctx context.Context, kind string, urls []string) error {
 	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint))
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
 	p := newUrlEncodedPayload()
-	p.addValue("id", t)
+	p.addValue("id", kind)
 	for _, url := range urls {
 		p.addValue("url", url)
 	}
@@ -49,31 +66,36 @@ func (mg *MailgunImpl) CreateWebhook(ctx context.Context, t string, urls []strin
 }
 
 // DeleteWebhook removes the specified webhook from your domain's configuration.
-func (mg *MailgunImpl) DeleteWebhook(ctx context.Context, t string) error {
-	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + t)
+func (mg *MailgunImpl) DeleteWebhook(ctx context.Context, kind string) error {
+	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + kind)
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
 	_, err := makeDeleteRequest(ctx, r)
 	return err
 }
 
 // GetWebhook retrieves the currently assigned webhook URL associated with the provided type of webhook.
-func (mg *MailgunImpl) GetWebhook(ctx context.Context, t string) (string, error) {
-	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + t)
+func (mg *MailgunImpl) GetWebhook(ctx context.Context, kind string) ([]string, error) {
+	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + kind)
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
-	var envelope struct {
-		Webhook struct {
-			Url string `json:"url"`
-		} `json:"webhook"`
+	var body WebHookResponse
+	if err := getResponseFromJSON(ctx, r, &body); err != nil {
+		return nil, err
+	}
+
+	if body.Webhook.Url != "" {
+		return []string{body.Webhook.Url}, nil
+	}
+	if len(body.Webhook.Urls) != 0 {
+		return body.Webhook.Urls, nil
 	}
-	err := getResponseFromJSON(ctx, r, &envelope)
-	return envelope.Webhook.Url, err
+	return nil, fmt.Errorf("webhook '%s' returned no urls", kind)
 }
 
 // UpdateWebhook replaces one webhook setting for another.
-func (mg *MailgunImpl) UpdateWebhook(ctx context.Context, t string, urls []string) error {
-	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + t)
+func (mg *MailgunImpl) UpdateWebhook(ctx context.Context, kind string, urls []string) error {
+	r := newHTTPRequest(generateDomainApiUrl(mg, webhooksEndpoint) + "/" + kind)
 	r.setClient(mg.Client())
 	r.setBasicAuth(basicAuthUser, mg.APIKey())
 	p := newUrlEncodedPayload()