Function seedOutbound

internal/delivery/integration_test.go:18–44

seedOutbound creates a user + verified domain + agent + one outbound message with the given SES provider id, marked sent to `to`. Returns userID, messageID, agentEmail.

(t *testing.T, store *identity.Store, prefix, providerID string, to []string)

// with the given SES provider id, marked sent to `to`. Returns userID,
// messageID, agentEmail.
func seedOutbound(t *testing.T, store *identity.Store, prefix, providerID string, to []string) (string, string, string) {
	t.Helper()
	ctx := context.Background()
	user, err := store.CreateOrGetUser(ctx, "owner-"+prefix+"@example.com", "Owner", "g-"+prefix)
	if err != nil {
		t.Fatalf("CreateOrGetUser: %v", err)
	}
	domain := prefix + ".example.com"
	if _, err := store.ClaimOrCreateDomain(ctx, domain, user.ID); err != nil {
		t.Fatalf("ClaimOrCreateDomain: %v", err)
	}
	if err := store.VerifyDomain(ctx, domain, user.ID); err != nil {
		t.Fatalf("VerifyDomain: %v", err)
	}
	agentEmail := "bot@" + domain
	if _, err := store.CreateAgent(ctx, agentEmail, domain, "", "", "", user.ID); err != nil {
		t.Fatalf("CreateAgent: %v", err)
	}
	msg, err := store.CreateOutboundMessage(ctx, agentEmail, to, nil, nil, "Subj", "send", "smtp", providerID, "", nil)
	if err != nil {
		t.Fatalf("CreateOutboundMessage: %v", err)
	}
	if err := store.MarkMessageSent(ctx, msg.ID, "relay", to, nil, nil); err != nil {
		t.Fatalf("MarkMessageSent: %v", err)
	}
	return user.ID, msg.ID, agentEmail
}

func deliveryStatus(t *testing.T, store *identity.Store, messageID, agentEmail string) string {
	t.Helper()