import fs from "node:fs";

import os from "node:os";

import path from "node:path";

import { writeSessionStoreForTest } from "../config/sessions/test-helpers.js";

import { clearSessionStoreCacheForTest } from "../config/sessions/store.js";

import { writeSessionStoreForTest } from "../config/sessions/test-helpers.js";

import { sendMessage } from "../infra/outbound/message.js";

import {

buildExecApprovalFollowupPrompt,

expect(sendMessage).not.toHaveBeenCalled();

});

it("preserves the originating routing target for non-built-in plugin channels", async () => {

await sendExecApprovalFollowup({

approvalId: "req-plugin",

sessionKey: "agent:main:lansenger:dm:U1",

turnSourceChannel: "lansenger",

turnSourceTo: "dm:U1",

turnSourceAccountId: "acct-1",

turnSourceThreadId: 42,

resultText: "Exec finished (gateway id=req-plugin, code 0)\nhello",

});

const agentArgs = expectGatewayAgentFollowup({

sessionKey: "agent:main:lansenger:dm:U1",

deliver: false,

channel: "lansenger",

to: "dm:U1",

accountId: "acct-1",

threadId: "42",

idempotencyKey: "exec-approval-followup:req-plugin",

});

expect(agentArgs.message).toContain("already approved has completed");

expect(sendMessage).not.toHaveBeenCalled();

});

it("waits for accepted agent followups without direct fallback", async () => {

vi.mocked(callGatewayTool)

.mockResolvedValueOnce({