mailcast

type RenderFunc func(ctx context.Context, b store.MailBroadcast, r store.MailRecipient) (email.Message, error)

type Runner struct {
	Store  Store
	Render RenderFunc
	Send   SendFunc
	Logger *slog.Logger
	// Delay is the pause between two messages, the sending rate limit.
	Delay time.Duration
	// Batch is how many recipients are loaded between status re-checks.
	Batch int
	// SendTimeout bounds one message.
	SendTimeout time.Duration
	// contains filtered or unexported fields
}

type SendFunc func(ctx context.Context, m email.Message) error

type Store interface {
	GetMailBroadcast(ctx context.Context, id string) (*store.MailBroadcast, error)
	UpdateMailBroadcast(ctx context.Context, b store.MailBroadcast) error
	UpdateMailBroadcastProgress(ctx context.Context, id string, sent, failed, suppressed int) error
	FinishMailBroadcast(ctx context.Context, b store.MailBroadcast) error
	ListMailBroadcastsByStatus(ctx context.Context, statuses ...string) ([]store.MailBroadcast, error)
	ListMailRecipients(ctx context.Context, broadcastID, status string, limit int) ([]store.MailRecipient, error)
	SetMailRecipientStatus(ctx context.Context, broadcastID, email, status, errText string) error
	CancelPendingMailRecipients(ctx context.Context, broadcastID string) error
	ListMailSuppressions(ctx context.Context) ([]store.MailSuppression, error)
}