outbound

type Builder func(ctx context.Context, r Row) ([]byte, error)

type Direct struct {
	LocalName string
	DNS       dnsx.Resolver
	STS       *STSCache
	Port      string // "25"; tests use another
	Dial      func(ctx context.Context, network, addr string) (net.Conn, error)
	// IPv6 allows connections over IPv6. Off unless the server's IPv6 is
	// configured and has its own PTR: Gmail refuses IPv6 senders without
	// reverse DNS (550 5.7.25), and SPF covers only published addresses.
	IPv6 bool
}

type Entry struct {
	ID       int64     `json:"id"`
	Kind     string    `json:"kind"`
	Rcpt     string    `json:"rcpt"`
	Status   string    `json:"status"`
	Attempts int       `json:"attempts"`
	Next     time.Time `json:"next"`
	Error    string    `json:"error,omitempty"`
	Created  time.Time `json:"created"`
}

type Execer interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type Failure struct {
	Temporary bool   // try again later
	Transport bool   // the relay itself is unreachable or refuses our login: nothing can go out
	Bounce    bool   // the address does not exist: suppress it
	Code      int    // SMTP reply code, 0 for network errors
	Enhanced  string // e.g. 5.1.1
	Message   string
	Handshake bool // refused before MAIL FROM: another MX may still accept
}

type Hooks struct {
	// Failed runs when delivery failed for good; f.Bounce says the address
	// does not exist.
	Failed func(ctx context.Context, r Row, f *Failure)
	// GaveUp runs when temporary failures outlasted MaxAge: a soft bounce.
	GaveUp func(ctx context.Context, r Row, reason string)
	Sent   func(ctx context.Context, r Row)
}

type Item struct {
	Kind      string
	DomainID  int64
	IssueID   int64
	ContactID int64
	MemberID  int64
	Blob      string
	EnvFrom   string // empty: a VERP bounce address on the signing domain
	Rcpt      string
	At        time.Time // earliest send time; zero for now
}

type Queue struct {
	DB        *store.DB
	Domains   *domains.Service
	Events    *events.Bus
	Builders  map[string]Builder
	Hooks     Hooks
	Bounce    func(r Row, domain string) string                              // VERP envelope sender
	Transport func(ctx context.Context) (t Transport, key string, err error) // key changes when the configuration does
	Rate      func(ctx context.Context) (perSecond, conns int)
	Now       func() time.Time
	Log       *slog.Logger
	MaxAge    time.Duration // give up after this long; default 5 days
	// contains filtered or unexported fields
}

type Relay struct {
	// contains filtered or unexported fields
}

type Row struct {
	ID        int64
	Kind      string
	DomainID  int64
	IssueID   int64
	ContactID int64
	MemberID  int64
	Blob      string
	EnvFrom   string
	Rcpt      string
	Attempts  int
	Created   time.Time
}

type STSCache struct {
	DNS    dnsx.Resolver
	Client *http.Client
	// contains filtered or unexported fields
}

type STSPolicy struct {
	Mode   string // enforce, testing, none
	MX     []string
	MaxAge time.Duration
}

type Status struct {
	Queued   int    `json:"queued"`
	Retrying int    `json:"retrying"`
	Sent24h  int    `json:"sent_24h"`
	Failed24 int    `json:"failed_24h"`
	Bounce24 int    `json:"bounced_24h"`
	Oldest   string `json:"oldest_queued,omitempty"`
	// Down says why the relay or direct delivery refuses everything, and
	// since when; mail waits without using up its attempts.
	Down      string `json:"transport_down,omitempty"`
	DownSince string `json:"transport_down_since,omitempty"`
}

type Transport interface {
	Send(ctx context.Context, from, rcpt string, raw []byte) error
	Close()
	Name() string
}