Method MarkMessageSent

internal/identity/delivery_store.go:148–188

MarkMessageSent records that an outbound message was accepted by the relay: delivery_status='sent', the From identity actually used, and one message_recipients row per recipient (to/cc/bcc) at 'sent'. Called after a successful relay accept. Idempotent on the recipient rows.

(ctx context.Context, messageID, sentAs string, to, cc, bcc []string)

// message_recipients row per recipient (to/cc/bcc) at 'sent'. Called after a
// successful relay accept. Idempotent on the recipient rows.
func (s *Store) MarkMessageSent(ctx context.Context, messageID, sentAs string, to, cc, bcc []string) error {
	tx, err := s.pool.Begin(ctx)
	if err != nil {
		return err
	}
	defer tx.Rollback(ctx)

	if _, err := tx.Exec(ctx,
		`UPDATE messages SET delivery_status = 'sent', sent_as = $2 WHERE id = $1`,
		messageID, nullIfEmpty(sentAs),
	); err != nil {
		return err
	}
	add := func(addrs []string, kind string) error {
		for _, a := range addrs {
			addr := NormalizeEmail(a)
			if addr == "" {
				continue
			}
			if _, err := tx.Exec(ctx,
				`INSERT INTO message_recipients (id, message_id, address, kind, status)
				 VALUES ($1, $2, $3, $4, 'sent')
				 ON CONFLICT (message_id, address) DO NOTHING`,
				"rcpt_"+generateID(), messageID, addr, kind,
			); err != nil {
				return err
			}
		}
		return nil
	}
	if err := add(to, "to"); err != nil {
		return err
	}
	if err := add(cc, "cc"); err != nil {
		return err
	}
	if err := add(bcc, "bcc"); err != nil {
		return err
	}
	return tx.Commit(ctx)
}

// --- Suppression list ---