const sessionFile = path.join(tempDir, "session.jsonl");

const workspaceDir = path.join(tempDir, "workspace");

testing.setOpenClawCodingToolsFactoryForTests(() => [createRuntimeDynamicTool("message")]);

const harness = createStartedThreadHarness();

const harness = createAppServerHarness(async (method) => {

if (method === "thread/start") {

return threadStartResult();

}

if (method === "turn/start") {

return {

turn: {

...turnStartResult("turn-1", "completed").turn,

items: [

{

id: "msg-1",

type: "agentMessage",

text: "hello back",

status: "completed",

},

],

},

};

}

return {};

});

const params = createParams(sessionFile, workspaceDir);

params.disableTools = false;

params.runtimePlan = createCodexRuntimePlanFixture();

} as never;

const run = runCodexAppServerAttempt(params);

await harness.waitForMethod("turn/start");

await new Promise<void>((resolve) => setImmediate(resolve));

await harness.notify({

method: "item/agentMessage/delta",

params: {

threadId: "thread-1",

turnId: "turn-1",

itemId: "msg-1",

delta: "hello back",

},

});

await harness.completeTurn({ threadId: "thread-1", turnId: "turn-1" });

await run;

await flushDiagnosticEvents();