webhooks.go

package gochimp3

import "fmt"

const (
	webhooks_path       = "/lists/%s/webhooks"
	single_webhook_path = webhooks_path + "/%s"
)

type ListOfWebHooks struct {
	baseList
	ListID   string    `json:"list_id"`
	WebHooks []WebHook `json:"webhooks"`
}

type WebHookRequest struct {
	URL     string      `json:"url"`
	Events  HookEvents  `json:"events"`
	Sources HookSources `json:"sources"`
}

type WebHook struct {
	WebHookRequest
	ID     string `json:"id"`
	ListID string `json:"list_id"`
	withLinks
}

type HookSources struct {
	User  bool `json:"user"`
	Admin bool `json:"admin"`
	API   bool `json:"api"`
}

type HookEvents struct {
	Subscribe   bool `json:"subscribe"`
	Unsubscribe bool `json:"unsubscribe"`
	Profile     bool `json:"profile"`
	Cleaned     bool `json:"cleaned"`
	Upemail     bool `json:"upemail"`
	Campaign    bool `json:"campaign"`
}

func (list ListResponse) CreateWebHooks(body *WebHookRequest) (*WebHook, error) {
	if err := list.CanMakeRequest(); err != nil {
		return nil, err
	}

	endpoint := fmt.Sprintf(webhooks_path, list.ID)
	response := new(WebHook)

	return response, list.api.Request("POST", endpoint, nil, &body, response)
}

func (list ListResponse) UpdateWebHook(id string, body *WebHookRequest) (*WebHook, error) {
	if err := list.CanMakeRequest(); err != nil {
		return nil, err
	}

	endpoint := fmt.Sprintf(single_webhook_path, list.ID, id)
	response := new(WebHook)

	return response, list.api.Request("PATCH", endpoint, nil, &body, response)
}

// TODO - does this take filters? undocumented

func (list ListResponse) GetWebHooks() (*ListOfWebHooks, error) {
	if err := list.CanMakeRequest(); err != nil {
		return nil, err
	}

	endpoint := fmt.Sprintf(webhooks_path, list.ID)
	response := new(ListOfWebHooks)

	return response, list.api.Request("GET", endpoint, nil, nil, response)
}

func (list ListResponse) GetWebHook(id string) (*WebHook, error) {
	if err := list.CanMakeRequest(); err != nil {
		return nil, err
	}

	endpoint := fmt.Sprintf(single_webhook_path, list.ID, id)
	response := new(WebHook)

	return response, list.api.Request("GET", endpoint, nil, nil, response)
}

func (list ListResponse) DeleteWebHook(id string) (bool, error) {
	if err := list.CanMakeRequest(); err != nil {
		return false, err
	}

	endpoint := fmt.Sprintf(single_webhook_path, list.ID, id)
	return list.api.RequestOk("DELETE", endpoint)
}