return await getReplyFromConfig(makeAuthorizedSmsCommandMessage(body), {}, cfg);

}

function firstMockCallArg(

mock: { mock: { calls: unknown[][] } },

label: string,

): Record<string, unknown> {

const call = mock.mock.calls[0];

if (!call) {

throw new Error(`expected ${label} call params`);

}

const arg = call[0];

if (!arg || typeof arg !== "object") {

throw new Error(`expected ${label} first argument`);

}

return arg as Record<string, unknown>;

}

async function expectNextRunUsesTargetSession(

params: {

cfg: ReturnType<typeof makeCfg>;

);

expect(params.runEmbeddedPiAgentMock).toHaveBeenCalledOnce();

const runParams = params.runEmbeddedPiAgentMock.mock.calls.at(0)?.[0] as

| Record<string, unknown>

| undefined;

if (!runParams) {

throw new Error("expected embedded PI agent call params");

}

const runParams = firstMockCallArg(params.runEmbeddedPiAgentMock, "embedded PI agent");

for (const [key, value] of Object.entries(expected)) {

expect(runParams[key]).toEqual(value);

}

expect(text, testCase.label).not.toMatch(/Thinking level set/i);

expect(runEmbeddedPiAgentMock, testCase.label).toHaveBeenCalledOnce();

if (testCase.assertPrompt) {

const prompt = runEmbeddedPiAgentMock.mock.calls.at(0)?.[0]?.prompt ?? "";

const prompt = firstMockCallArg(runEmbeddedPiAgentMock, "embedded PI agent").prompt ?? "";

expect(prompt).toContain("Give me the status");

expect(prompt).not.toContain("/thinking high");

expect(prompt).not.toContain("/think high");

testCase.setup(cfg);

await getReplyFromConfig(BASE_MESSAGE, { isHeartbeat: true }, cfg);

const call = runEmbeddedPiAgentMock.mock.calls.at(0)?.[0];

const call = firstMockCallArg(runEmbeddedPiAgentMock, "embedded PI agent");

expect(call?.provider).toBe(testCase.expected.provider);

expect(call?.model).toBe(testCase.expected.model);

}

const text = maybeReplyText(res);

expect(text?.startsWith("⚙️ Compacted")).toBe(true);

expect(getCompactEmbeddedPiSessionMock()).toHaveBeenCalledOnce();

expect(getCompactEmbeddedPiSessionMock().mock.calls.at(0)?.[0]?.sessionFile).toContain(

join("agents", "worker1", "sessions"),

);

expect(

firstMockCallArg(getCompactEmbeddedPiSessionMock(), "embedded PI compaction").sessionFile,

).toContain(join("agents", "worker1", "sessions"));

});

});