
        const prompt = JSON.stringify(params.prompt);
        const say = (text) => send({method:"session/update",params:{sessionId,update:{sessionUpdate:"agent_message_chunk",content:{type:"text",text}}}});
        if (prompt.includes("Create parent.txt")) {
          NodeFS.writeFileSync(session.cwd + "/parent.txt", "Parent edit retained\n");
          say("Created parent.txt. Parent edit complete.");
          return {stopReason:"end_turn"};
        }
        if (prompt.includes("Create child.txt")) {
          NodeFS.writeFileSync(session.cwd + "/child.txt", "Completed child edit\n");
          say("Created child.txt. Shared subagent edit complete.");
          return {stopReason:"end_turn"};
        }
        if (prompt.includes("Delegate the child edit")) {
          const endpoint = process.env.T3_ACP_MCP_ENDPOINT;
          const auth = process.env.T3_ACP_MCP_AUTHORIZATION;
          let sid;
          const rpc = async (method, params, id=1) => {
            const response = await fetch(endpoint, {method:"POST",headers:{"Content-Type":"application/json",Accept:"application/json, text/event-stream",Authorization:auth,...(sid?{"Mcp-Session-Id":sid}:{})},body:JSON.stringify({jsonrpc:"2.0",id,method,params})});
            sid = response.headers.get("mcp-session-id") ?? sid;
            const text = await response.text();
            const data = text.startsWith("event:") || text.startsWith("data:") ? JSON.parse(text.split("\n").find(x=>x.startsWith("data: ")).slice(6)) : JSON.parse(text);
            if(data.error) throw new Error(JSON.stringify(data.error));
            return data.result;
          };
          await rpc("initialize",{protocolVersion:"2024-11-05",capabilities:{},clientInfo:{name:"scenario-replay",version:"1"}});
          await rpc("tools/call",{name:"orchestrator_capabilities",arguments:{}});
          const result = await rpc("tools/call",{name:"delegate_task",arguments:{task:"Create child.txt",title:"Completed shared child",isolation:"shared",mode:"wait",target:{providerInstanceId:"devReplay",model:"multi-turn"}}});
          if(result.isError) throw new Error(JSON.stringify(result));
          say("Delegated child edit completed in this worktree. child.txt exists; child history is retained.");
          return {stopReason:"end_turn"};
        }
