courier

Documentation

Index

• Variables
• type ConfigProvider
• type Courier
  • func NewSMTP(ctx context.Context, d SMTPDependencies) *Courier
  • func (m *Courier) DispatchMessage(ctx context.Context, msg Message) error
  • func (m *Courier) DispatchQueue(ctx context.Context) error
  • func (m *Courier) QueueEmail(ctx context.Context, t EmailTemplate) (uuid.UUID, error)
  • func (m *Courier) Work(ctx context.Context) error
• type EmailTemplate
  • func NewEmailTemplateFromMessage(c SMTPConfig, msg Message) (EmailTemplate, error)
• type EmailTemplateFromMessage
• type Message
  • func (m *Message) GetID() uuid.UUID
  • func (m *Message) GetNID() uuid.UUID
  • func (m Message) TableName(ctx context.Context) string
• type MessageStatus
• type MessageType
• type PersistenceProvider
• type Persister
• type Provider
• type SMTPConfig
• type SMTPDependencies
• type TemplateType
  • func GetTemplateType(t EmailTemplate) (TemplateType, error)
• type TemplateTyper

Variables

var ErrQueueEmpty = errors.New("queue is empty")

Types

type ConfigProvider

type ConfigProvider interface {
	CourierConfig(ctx context.Context) SMTPConfig
}

type Courier

type Courier struct {
	Dialer *gomail.Dialer

	GetTemplateType             TemplateTyper
	NewEmailTemplateFromMessage EmailTemplateFromMessage
	// contains filtered or unexported fields
}

func NewSMTP

func NewSMTP(ctx context.Context, d SMTPDependencies) *Courier

func (*Courier) DispatchMessage

func (m *Courier) DispatchMessage(ctx context.Context, msg Message) error

func (*Courier) DispatchQueue

func (m *Courier) DispatchQueue(ctx context.Context) error

func (*Courier) QueueEmail

func (m *Courier) QueueEmail(ctx context.Context, t EmailTemplate) (uuid.UUID, error)

func (*Courier) Work

func (m *Courier) Work(ctx context.Context) error

type EmailTemplate

type EmailTemplate interface {
	json.Marshaler
	EmailSubject() (string, error)
	EmailBody() (string, error)
	EmailBodyPlaintext() (string, error)
	EmailRecipient() (string, error)
}

func NewEmailTemplateFromMessage

func NewEmailTemplateFromMessage(c SMTPConfig, msg Message) (EmailTemplate, error)

type EmailTemplateFromMessage

type EmailTemplateFromMessage func(c SMTPConfig, msg Message) (EmailTemplate, error)

type Message

type Message struct {
	ID           uuid.UUID     `json:"-" faker:"-" db:"id"`
	NID          uuid.UUID     `json:"-"  faker:"-" db:"nid"`
	Status       MessageStatus `json:"-" db:"status"`
	Type         MessageType   `json:"-" db:"type"`
	Recipient    string        `json:"-" db:"recipient"`
	Body         string        `json:"-" db:"body"`
	Subject      string        `json:"-" db:"subject"`
	TemplateType TemplateType  `json:"-" db:"template_type"`
	TemplateData []byte        `json:"-" db:"template_data"`

	// CreatedAt is a helper struct field for gobuffalo.pop.
	CreatedAt time.Time `json:"-" faker:"-" db:"created_at"`
	// UpdatedAt is a helper struct field for gobuffalo.pop.
	UpdatedAt time.Time `json:"-" faker:"-" db:"updated_at"`
}

swagger:ignore

func (*Message) GetID

func (m *Message) GetID() uuid.UUID

func (*Message) GetNID

func (m *Message) GetNID() uuid.UUID

func (Message) TableName

func (m Message) TableName(ctx context.Context) string

type MessageStatus

type MessageStatus int

const (
	MessageStatusQueued MessageStatus = iota + 1
	MessageStatusSent
	MessageStatusProcessing
)

type MessageType

type MessageType int

const (
	MessageTypeEmail MessageType = iota + 1
)

type PersistenceProvider

type PersistenceProvider interface {
	CourierPersister() Persister
}

type Persister

type Persister interface {
	AddMessage(context.Context, *Message) error

	NextMessages(context.Context, uint8) ([]Message, error)

	SetMessageStatus(context.Context, uuid.UUID, MessageStatus) error

	LatestQueuedMessage(ctx context.Context) (*Message, error)
}

type Provider

type Provider interface {
	Courier(ctx context.Context) *Courier
}

type SMTPConfig

type SMTPConfig interface {
	CourierSMTPURL() *url.URL
	CourierSMTPFrom() string
	CourierSMTPFromName() string
	CourierSMTPHeaders() map[string]string
	CourierTemplatesRoot() string
}

type SMTPDependencies

type SMTPDependencies interface {
	PersistenceProvider
	x.LoggingProvider
	ConfigProvider
}

type TemplateType

type TemplateType string

const (
	TypeRecoveryInvalid     TemplateType = "recovery_invalid"
	TypeRecoveryValid       TemplateType = "recovery_valid"
	TypeVerificationInvalid TemplateType = "verification_invalid"
	TypeVerificationValid   TemplateType = "verification_valid"
	TypeTestStub            TemplateType = "stub"
)

func GetTemplateType

func GetTemplateType(t EmailTemplate) (TemplateType, error)

type TemplateTyper

type TemplateTyper func(t EmailTemplate) (TemplateType, error)