@@ -11,9 +11,8 @@ import {
1111 type ResolvedProviderFailureError ,
1212} from "../inference-error-message.js" ;
1313import { createPermissionGate } from "../permission/gate.js" ;
14- import { createFleetRecords , createSpawnAgentTool , createWaitAgentsTool } from "./agent-fleet.js" ;
14+ import { createFleetMailbox , createSpawnAgentTool , createWaitAgentsTool } from "./agent-fleet.js" ;
1515import { createSubAgentSessionStore } from "./session-store.js" ;
16- import { createTaskTool } from "./task-tool.js" ;
1716import type { RunSubAgentParams , RunSubAgentResult } from "./types.js" ;
1817
1918const RAW_DIAGNOSTIC = "POST https://provider.invalid returned secret response body" ;
@@ -130,33 +129,10 @@ describe("resolved sub-agent provider failures", () => {
130129 expect ( observed . some ( ( event ) => JSON . stringify ( event ) . includes ( RAW_DIAGNOSTIC ) ) ) . toBe ( true ) ;
131130 } ) ;
132131
133- test ( "fused task returns only the safe message for the resolved reply sequence" , async ( ) => {
134- await withResolvedProviderRun ( async ( run , cwd ) => {
135- const sessions = createSubAgentSessionStore ( ) ;
136- const task = createTaskTool ( {
137- ...runParams ( cwd ) ,
138- getWorkdirBase : ( ) => join ( cwd , ".ctx" ) ,
139- sessions,
140- fleetRecords : createFleetRecords ( ) ,
141- run,
142- } ) ;
143- const result = await callTool ( task , "task" , {
144- description : "provider failure" ,
145- prompt : "trigger it" ,
146- intent : "explore" ,
147- } ) ;
148-
149- expect ( result . isError ) . toBe ( true ) ;
150- expect ( result . content ) . toBe ( SAFE_MESSAGE ) ;
151- expect ( String ( result . content ) ) . not . toContain ( RAW_DIAGNOSTIC ) ;
152- expect ( sessions . list ( ) [ 0 ] ?. error ) . toBe ( SAFE_MESSAGE ) ;
153- } ) ;
154- } ) ;
155-
156132 test ( "split spawn_agent and wait_agents return only the safe message" , async ( ) => {
157133 await withResolvedProviderRun ( async ( run , cwd ) => {
158134 const sessions = createSubAgentSessionStore ( ) ;
159- const fleetRecords = createFleetRecords ( ) ;
135+ const fleetRecords = createFleetMailbox ( sessions ) ;
160136 const deps = {
161137 ...runParams ( cwd ) ,
162138 getWorkdirBase : ( ) => join ( cwd , ".ctx" ) ,
0 commit comments