Function TestFlow1_HumanAgentHuman

internal/relay/flow_test.go:76–120

--- Flow 1: Human → Agent → Human --------------------------------------

(t *testing.T)

// --- Flow 1: Human → Agent → Human --------------------------------------

func TestFlow1_HumanAgentHuman(t *testing.T) {
	const (
		human   = "user@gmail.com"
		agent   = "bot@agent.mnexa.ai"
		convID  = "conv-flow1"
		msg2SES = "<msg2-ses-id@send.e2a.dev>" // SES-assigned ID on the agent's outbound (msg 2)
	)

	// Msg 1: Human → Agent. New thread, no X-E2A header, envelope from Gmail.
	msg1 := composeHumanOutbound(t, human, agent, "Hello agent", "Question for you", "")
	sender1, conv1 := simulateInbound(t, msg1, "bounce@gmail.com", nil /* no prior thread */)
	if sender1 != human {
		t.Errorf("msg 1 sender = %q, want %q", sender1, human)
	}
	if conv1 != "" {
		t.Errorf("msg 1 conv_id = %q, want empty (human has no conv_id concept)", conv1)
	}

	// Agent now picks conversation_id=convID locally and replies.

	// Msg 2: Agent → Human via reply (In-Reply-To + X-E2A header).
	// Human's Gmail just displays it — we don't simulate inbound here. The
	// header presence on outbound is already covered in compose_test.go.
	_ = composeAgentOutbound(t, agent, []string{human}, "Re: Hello agent", "Reply body",
		"<human-msg-id@gmail.com>" /* In-Reply-To */, convID)

	// Msg 3: Human → Agent, replying to msg 2 (Gmail sets In-Reply-To = msg 2's SES id).
	//        Envelope from Gmail, so X-E2A header gate fails; conv_id recovers via lookup.
	msg3 := composeHumanOutbound(t, human, agent, "Re: Hello agent", "Follow-up", msg2SES)
	lookup := func(ctx context.Context, ids []string) (string, error) {
		for _, id := range ids {
			if id == msg2SES {
				return convID, nil // the DB finds msg 2 and returns its conv_id
			}
		}
		return "", fmt.Errorf("not found")
	}
	sender3, conv3 := simulateInbound(t, msg3, "bounce@gmail.com", lookup)
	if sender3 != human {
		t.Errorf("msg 3 sender = %q, want %q", sender3, human)
	}
	if conv3 != convID {
		t.Errorf("msg 3 conv_id = %q, want %q (recovered via In-Reply-To)", conv3, convID)
	}
}

// --- Flow 2: Agent A → Agent B → Agent A --------------------------------