Method performSelfSend

internal/agent/selfsend.go:50–107

performSelfSend writes the message as BOTH an outbound row (sender's sent history) and an inbound row (recipient's inbox). Mirrors the two-row shape the SMTP roundtrip would produce naturally, so list_messages, threading, and downstream tooling don't need any special-casing. This is the non-HITL fa

(
	ctx context.Context,
	agent *identity.AgentIdentity,
	req outbound.SendRequest,
	msgType string,
)

// fork the audit shape from the SMTP branch (which records the
// caller's actual intent).
func (a *API) performSelfSend(
	ctx context.Context,
	agent *identity.AgentIdentity,
	req outbound.SendRequest,
	msgType string,
) (string, error) {
	email := agent.EmailAddress()

	// Allocate providerID up front so the outbound row and inbound row
	// reference the same Message-ID — matching the two-row shape an
	// SMTP roundtrip produces.
	providerID := loopback.ProviderID(a.fromDomain)

	if _, err := a.store.CreateOutboundMessage(
		ctx,
		agent.ID,
		[]string{email},
		nil,
		nil,
		req.Subject,
		msgType,
		"loopback",
		providerID,
		req.ConversationID,
		nil, // self-send body is retained on the inbound twin row; don't double-store
	); err != nil {
		return "", fmt.Errorf("self-send outbound row: %w", err)
	}

	rawMessage, err := loopback.ComposeMIME(agent, req, providerID, a.fromDomain)
	if err != nil {
		return "", fmt.Errorf("self-send compose: %w", err)
	}
	if _, err := a.store.CreateInboundMessage(
		ctx,
		"",
		agent.ID,
		email,
		email,
		providerID,
		req.Subject,
		req.ConversationID,
		"unread",
		rawMessage,
		nil,
		nil,
		false,
		"",
		[]string{email},
		nil,
		nil,
		identity.InboundScreening{}, // self-send: not externally screened
	); err != nil {
		return "", fmt.Errorf("self-send inbound row: %w", err)
	}

	return providerID, nil
}