test(e2e): a fixture da jornada também cria a mensagem carimbada

Mesma classe do commit anterior, em outro arquivo — que é o modo de falha
"conserto por instância, não por classe". `seed-silent-contact` de
`e2e-followup-journey-helpers.ts` criava o silêncio como um CAMPO
(`last_inbound_at`) sem linha em `messages`, e a varredura passou a exigir
PROCEDÊNCIA. Sem a mensagem, a conversa é invisível para o gatilho.

Medido depois do conserto da fronteira: o erro da spec MUDOU de
`service_boundary_stale` no `complete-turn` para "varredura de silêncio não
enrollou o contato a tempo" — ou seja, ela passou do defeito antigo e morreu no
seguinte, que é esta fixture.

Varri a classe: `seed-e2e-escalacao` usa `last_inbound_at` de agora (não é
silêncio) e `seed-e2e-queue` é da visão "Fila", não da varredura — nenhum dos
dois alimenta o gatilho, e as specs deles passam.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

Author: melgarafael

scripts/e2e-followup-journey-helpers.ts

@@ -36,7 +36,11 @@ import * as fs from "node:fs";
 import * as path from "node:path";
 import pg from "pg";
 
-import { createPgAdminClient, completeTurnForEnrollment, type TurnResult } from "@/lib/followup/turn-bridge";
+import {
+  createPgAdminClient,
+  completeTurnForEnrollment,
+  type TurnResult,
+} from "@/lib/followup/turn-bridge";
 import { carregarEnvLocal } from "../scripts/lib/env-de-teste";
 
 const env = carregarEnvLocal();
@@ -71,7 +75,10 @@ async function main(): Promise<void> {
       case "prepare-agent-fixtures": {
         const creds = loadCreds();
         const fixtures = creds.followup_agent_fixtures;
-        if (!fixtures) throw new Error("followup_agent_fixtures ausente em .e2e-creds.json — rode seed-e2e-followup-agent.ts antes");
+        if (!fixtures)
+          throw new Error(
+            "followup_agent_fixtures ausente em .e2e-creds.json — rode seed-e2e-followup-agent.ts antes",
+          );
         await pool.query(`update ai_provider_credentials set validated_at = now() where id = $1`, [
           fixtures.credential_id,
         ]);
@@ -110,7 +117,32 @@ async function main(): Promise<void> {
         );
         const conversationId = convRows[0]!.id;
 
-        out({ contactId, contactName, conversationId, channelSessionId: fixtures.channel_session_id });
+        // A MENSAGEM PRECISA EXISTIR, e carimbada — mesma correção feita em
+        // `e2e-elegibilidade-helpers.ts`, e pelo mesmo motivo.
+        //
+        // Esta fixture nasceu antes da fronteira do atendimento e criava o
+        // silêncio como um CAMPO (`last_inbound_at`), sem linha em `messages`.
+        // A varredura passou a exigir PROCEDÊNCIA: ela lê a mensagem inbound
+        // mais nova e o carimbo dela, porque é isso que separa "calado neste
+        // atendimento" de "calado desde outro". Sem a mensagem, a conversa é
+        // invisível para o gatilho e o contato nunca é enrolado.
+        //
+        // O carimbo não se escreve aqui: `fn_service_inbound` dispara no INSERT
+        // e o grava. Escrevê-lo à mão provaria a forma da linha, não o caminho.
+        await pool.query(
+          `insert into messages
+             (organization_id, conversation_id, channel_session_id, contact_id,
+              type, direction, status, sent_via, body, sent_at)
+           values ($1, $2, $3, $4, 'text', 'inbound', 'received', 'ai', 'Oi, tudo bem?', $5)`,
+          [creds.org_id, conversationId, fixtures.channel_session_id, contactId, lastInboundAt],
+        );
+
+        out({
+          contactId,
+          contactName,
+          conversationId,
+          channelSessionId: fixtures.channel_session_id,
+        });
         break;
       }
 
@@ -177,7 +209,9 @@ async function main(): Promise<void> {
       case "get-enrollment": {
         const enrollmentId = args[0];
         if (!enrollmentId) throw new Error("enrollmentId obrigatório");
-        const { rows } = await pool.query(`select * from followup_enrollments where id = $1`, [enrollmentId]);
+        const { rows } = await pool.query(`select * from followup_enrollments where id = $1`, [
+          enrollmentId,
+        ]);
         out(rows[0] ?? null);
         break;
       }
@@ -187,7 +221,8 @@ async function main(): Promise<void> {
       // ---- (a API de sweep não devolve id nenhum — é um cron fire-and-forget).
       case "find-enrollment": {
         const [orgId, pointerId, contactId] = args;
-        if (!orgId || !pointerId || !contactId) throw new Error("orgId, pointerId, contactId obrigatórios");
+        if (!orgId || !pointerId || !contactId)
+          throw new Error("orgId, pointerId, contactId obrigatórios");
         const { rows } = await pool.query(
           `select * from followup_enrollments
            where organization_id = $1 and pointer_id = $2 and contact_id = $3
@@ -245,7 +280,12 @@ async function main(): Promise<void> {
           [
             "message.received",
             messageId,
-            JSON.stringify({ conversation_id: conversationId, contact_id: contactId, channel_session_id: channelSessionId, body_preview: body.slice(0, 280) }),
+            JSON.stringify({
+              conversation_id: conversationId,
+              contact_id: contactId,
+              channel_session_id: channelSessionId,
+              body_preview: body.slice(0, 280),
+            }),
             orgId,
           ],
         );
@@ -298,7 +338,10 @@ async function main(): Promise<void> {
           `delete from followup_enrollment_events where enrollment_id in (select id from followup_enrollments where pointer_id = $1)`,
           [pointerId],
         );
-        const { rowCount } = await pool.query(`delete from followup_enrollments where pointer_id = $1`, [pointerId]);
+        const { rowCount } = await pool.query(
+          `delete from followup_enrollments where pointer_id = $1`,
+          [pointerId],
+        );
         out({ ok: true, deleted: rowCount });
         break;
       }
@@ -334,6 +377,9 @@ async function main(): Promise<void> {
 }
 
 main().catch((err) => {
-  console.error("❌ e2e-followup-journey-helpers falhou:", err instanceof Error ? err.message : err);
+  console.error(
+    "❌ e2e-followup-journey-helpers falhou:",
+    err instanceof Error ? err.message : err,
+  );
   process.exit(1);
 });