service

package

v0.0.0-...-d18ee5a Latest Latest Go to latest Published: Jul 24, 2023 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	SMTP      SMTPConfig
	SES       SESConfig
	Sendgrid  SendgridConfig
	Sparkpost sp.Config
}

type IProvider interface {
	SendMail(mail *models.Mail) error
}

type ISPClient interface {
	Send(*sp.Transmission) (id string, res *sp.Response, err error)
}

type ISendgridClient interface {
	Send(msg *sgHelper.SGMailV3) (*rest.Response, error)
}

type IService interface {
	QueueMail(mail *models.Mail)
}

type SESConfig struct {
	Region string `json:"region"`
}

type SESProvider struct {
	Logger  *log.Logger
	Client  sesiface.SESAPI
	Session *session.Session
}

func NewSESProvider(cfg SESConfig, logger *log.Logger) *SESProvider

func (s *SESProvider) SendMail(mail *models.Mail) error

type SMTPConfig struct {
	Host string `json:"host"`
	Port string `json:"port"`
	User string `json:"user"`
	Pass string `json:"pass"`
}

type SMTPProvider struct {
	Addr   string
	Auth   smtp.Auth
	Logger *log.Logger
}

func NewSMTPProvider(cfg SMTPConfig, logger *log.Logger) *SMTPProvider

func (s *SMTPProvider) SendMail(mail *models.Mail) error

type SendgridConfig struct {
	ApiKey string `json:"api_key"`
}

type SendgridProvider struct {
	Logger *log.Logger
	Client ISendgridClient
}

func NewSendgridProvider(cfg SendgridConfig, logger *log.Logger) *SendgridProvider

func (s *SendgridProvider) SendMail(mail *models.Mail) error

type Service struct {
	Logger    *log.Logger
	Providers []IProvider
	// contains filtered or unexported fields
}

func NewService(providers []IProvider, logger *log.Logger) *Service

func (s *Service) QueueMail(mail *models.Mail)

func (s *Service) Quit()

type SparkpostProvider struct {
	Logger *log.Logger
	Client ISPClient
}

func NewSparkpostProvider(cfg sp.Config, logger *log.Logger) *SparkpostProvider

func (s *SparkpostProvider) SendMail(mail *models.Mail) error