webhook_attempt.go

package invdapi

import (
	"github.com/gabrielsoaressantos/invoiced-go/invdendpoint"
	"strconv"
)

type WebhookAttempt struct {
	*Connection
	*invdendpoint.WebhookAttempt
}

type WebhookAttempts []*WebhookAttempt

func (c *Connection) NewWebhookAttempt() *WebhookAttempt {
	webhookAttempt := new(invdendpoint.WebhookAttempt)
	return &WebhookAttempt{c, webhookAttempt}
}

func (c *WebhookAttempt) ListAll(filter *invdendpoint.Filter, sort *invdendpoint.Sort) (WebhookAttempts, error) {
	endpoint := invdendpoint.WebhookEndpoint

	endpoint = addFilterAndSort(endpoint, filter, sort)

	webhookAttempts := make(WebhookAttempts, 0)

NEXT:
	tmpWebhookAttempts := make(WebhookAttempts, 0)

	endpoint, apiErr := c.retrieveDataFromAPI(endpoint, &tmpWebhookAttempts)

	if apiErr != nil {
		return nil, apiErr
	}

	webhookAttempts = append(webhookAttempts, tmpWebhookAttempts...)

	if endpoint != "" {
		goto NEXT
	}

	for _, webhookAttempt := range webhookAttempts {
		webhookAttempt.Connection = c.Connection
	}

	return webhookAttempts, nil
}

func (c *WebhookAttempt) ReAttempt(webhookId int64) error {

	endpoint := invdendpoint.WebhookEndpoint + "/" + strconv.FormatInt(webhookId, 10) + "/retries"

	err := c.create(endpoint, nil, nil)
	if err != nil {
		return err
	}

	return nil
}