recipients.go

package mailersend

import (
	"context"
	"fmt"
	"net/http"
)

const recipientBasePath = "/recipients"

type RecipientService service

// recipientRoot - recipients response
type recipientRoot struct {
	Data  []recipient `json:"data"`
	Links Links       `json:"links"`
	Meta  Meta        `json:"meta"`
}

// singleRecipientRoot - single recipient response
type singleRecipientRoot struct {
	Data recipientData `json:"data"`
}

type recipientData struct {
	ID        string        `json:"id"`
	Email     string        `json:"email"`
	CreatedAt string        `json:"created_at"`
	UpdatedAt string        `json:"updated_at"`
	DeletedAt string        `json:"deleted_at"`
	Emails    []interface{} `json:"emails"`
	Domain    Domain        `json:"domain"`
}

// recipient - a single recipient
type recipient struct {
	ID        string `json:"id"`
	Email     string `json:"email"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
	DeletedAt string `json:"deleted_at"`
}

// ListRecipientOptions - modifies the behavior of RecipientService.List method
type ListRecipientOptions struct {
	DomainID string `url:"domain_id,omitempty"`
	Page     int    `url:"page,omitempty"`
	Limit    int    `url:"limit,omitempty"`
}

func (s *RecipientService) List(ctx context.Context, options *ListRecipientOptions) (*recipientRoot, *Response, error) {
	req, err := s.client.newRequest(http.MethodGet, recipientBasePath, options)
	if err != nil {
		return nil, nil, err
	}

	root := new(recipientRoot)
	res, err := s.client.do(ctx, req, root)
	if err != nil {
		return nil, res, err
	}

	return root, res, nil
}

func (s *RecipientService) Get(ctx context.Context, recipientID string) (*singleRecipientRoot, *Response, error) {
	path := fmt.Sprintf("%s/%s", recipientBasePath, recipientID)

	req, err := s.client.newRequest(http.MethodGet, path, nil)
	if err != nil {
		return nil, nil, err
	}

	root := new(singleRecipientRoot)
	res, err := s.client.do(ctx, req, root)
	if err != nil {
		return nil, res, err
	}

	return root, res, nil
}

func (s *RecipientService) Delete(ctx context.Context, recipientID string) (*Response, error) {
	path := fmt.Sprintf("%s/%s", recipientBasePath, recipientID)

	req, err := s.client.newRequest(http.MethodDelete, path, nil)
	if err != nil {
		return nil, err
	}

	return s.client.do(ctx, req, nil)

}