Function send

packages/e2e-tests/tests/long-running-session.test.ts:251–372

(sessionId: string, prompt: string, text: string, usage: MockUsage = LOW_USAGE)

let turnCounter = 0;
async function send(sessionId: string, prompt: string, text: string, usage: MockUsage = LOW_USAGE): Promise<void> {
    h.mock.setDefault({ text, usage });
    const turn = ++turnCounter;
    const reqsBefore = h.mock.requests().length;
    const startedAt = Date.now();
    // [LR-DIAG] console.error flushes immediately on CI even when console.log is buffered
    console.error(`[LR-DIAG] turn ${turn} START prompt="${prompt.slice(0, 60)}" mockReqs=${reqsBefore}`);

    // OC-DIAG: every 50 mock requests, query opencode's session DB to see
    // what its filterCompacted/latest() actually returns. This tells us why
    // OpenCode's loop break condition isn't firing.
    let lastDumpAt = 0;
    // Runaway detector: if a single turn generates >100 mock requests, it's
    // pathological. Normal turns generate 1-3 requests. Fire 1 diagnostic
    // then fail the test fast — much better than waiting for 600s timeout.
    let runawayAborted = false;
    const dumpTimer = setInterval(() => {
        const now = Date.now();
        const reqs = h.mock.requests().length;
        // Fire diagnostic as soon as we see >=25 unexpected requests, then
        // every 5s while the hang persists. The earlier we capture data the
        // less likely it is to be lost to a job-level CI timeout.
        if (reqs > reqsBefore + 25 && now - lastDumpAt > 5000) {
            lastDumpAt = now;
            // Open opencode's session DB directly (Database is imported at top of file)
            try {
                const ocDbPath = join(h.opencode.env.dataDir, "opencode", "opencode.db");
                const ocDb = openTestDb(ocDbPath, { readonly: true });
                // Get latest messages in the session
                const rows = ocDb.prepare(
                    "SELECT id, json_extract(data, '$.role') AS role, json_extract(data, '$.finish') AS finish, json_extract(data, '$.summary') AS summary FROM message WHERE session_id = ? ORDER BY id DESC LIMIT 6",
                ).all(sessionId) as Array<{ id: string; role: string; finish: string | null; summary: number | null }>;
                const stateStr = rows
                    .map((r) => `${r.role}/${r.id.slice(0, 16)}/finish=${r.finish ?? "null"}/summary=${r.summary ?? "null"}`)
                    .join("  ");
                console.error(`[LR-DIAG] OC-STATE turn=${turn} mockReqs=${reqs}  topMsgs(newest first):  ${stateStr}`);

                // Dump parts of the TOP 3 newest messages — reveals source of mystery user messages
                // (compaction marker? autocontinue text? tool result? synthetic ignored notification?)
                try {
                    const ocDb2 = openTestDb(ocDbPath, { readonly: true });
                    const topIds = rows.slice(0, 3).map((r) => r.id);
                    for (const msgId of topIds) {
                        const parts = ocDb2.prepare(
                            "SELECT id, json_extract(data, '$.type') AS type, json_extract(data, '$.text') AS text, json_extract(data, '$.synthetic') AS synthetic, json_extract(data, '$.ignored') AS ignored, json_extract(data, '$.metadata') AS metadata, json_extract(data, '$.callID') AS callID, json_extract(data, '$.tool') AS tool, json_extract(data, '$.state') AS state, json_extract(data, '$.auto') AS auto, json_extract(data, '$.overflow') AS overflow FROM part WHERE message_id = ? ORDER BY id ASC LIMIT 4",
                        ).all(msgId) as Array<{ id: string; type: string; text: string | null; synthetic: number | null; ignored: number | null; metadata: string | null; callID: string | null; tool: string | null; state: string | null; auto: number | null; overflow: number | null }>;
                        const partsStr = parts.map((p) => {
                            const flags = [
                                p.synthetic ? "synth" : null,
                                p.ignored ? "ignored" : null,
                                p.auto !== null ? `auto=${p.auto}` : null,
                                p.overflow !== null ? `overflow=${p.overflow}` : null,
                                p.callID ? `callID=${p.callID.slice(0, 12)}` : null,
                                p.tool ? `tool=${p.tool}` : null,
                            ].filter(Boolean).join(",");
                            const preview = p.text ? p.text.slice(0, 80).replace(/\n/g, "\\n") : (p.state ? `state=${p.state.slice(0, 60)}` : "");
                            return `${p.type}${flags ? `[${flags}]` : ""}=${preview}`;
                        }).join(" || ");