java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 93
 *. ;
 *:
 *  -._astCloseInfojava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 18
*- (nnectsend receive )
 *  - Session registry helpers (releaseWsSession, 
 *

java.lang.StringIndexOutOfBoundsException: Range [10, 4) out of bounds for length 26
Each java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for length 73
type{java.lang.StringIndexOutOfBoundsException: Range [31, 28) out of bounds for length 64
import {
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  // ─────────────────────────────────────────────────────────────────────────────
 "requestj;
import {
  __// ────────previousResponseIdmaybeEventid
       (onst/** Resolve a Strea
  convertMessagesToInputItems,
       )java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
): Promise<AsyncIterablejava.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
        . java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  
  releaseWsSession,
}  java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 45
import }
import java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
import{java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 11

// ─────────────────────────────────────────────────────────────────────────────
// Mock OpenAIWebSocketManager
// ─────────────────────────────────────────────────────────────────────────────

// We mock the entire openai-ws-connection module so no real WebSocket is opened.
    role"java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
  const      toolName;
=(.   *-level flag:   (.*java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

  // Shared mutable flag so inner class can see it
       }
  let _java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0

  class   return { role: "user", content: text, timestamp: 0java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 setjava.lang.StringIndexOutOfBoundsException: Range [41, 38) out of bounds for length 52
    : string | null = java.lang.StringIndexOutOfBoundsException: Range [0, 53) out of bounds for length 40
     _connected =falsejava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    private _broken = false;
    private _java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

    contentpush( type text" text };
nnectCallCount 0;
    connectApiKeys: string[]      }
closeCallCount =0;
    options: unknown;

    // Allow tests to override connect/send behaviour
    connectShouldFail ( void {
    

    constructor(options?: unknown) {
      ()java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
      this.options = options;   
    }

    get previousResponseId
      return this      provider"penai"
    }

getlastCloseInfo(  code umber;reason : }|null{
      return this._lastCloseInfo;


    asynctimestampresolveProviderjava.lang.StringIndexOutOfBoundsException: Range [52, 49) out of bounds for length 67
      this.connectCallCount++;
      }
      if (const mockStreamSimple.fn(model unknown
throw  Error(Mock failure";
      }
      this._connected = true  n{
    

    isConnected()        toolC: ,
      return this_connected& !this.;
    }

    send(event:   isErrorjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      
        throwreturn ;java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
     java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      if (this.// ────────────── "ssistant as ,
        if     {type t"as  }],
          _    stopReason: "stopjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
        }
        throw  "send)
      }
      this.sentEvents.     java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
      cacheRead
      // Auto-complete warm-up events so warm-up-enabled tests don't hang waiting
      java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
      if (maybeEvent     .async  java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
        queueMicrotask(()java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
          this: ResponseObject {
           :
            response:  )java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
          });
        id item_1java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    }

    warmUp   ()java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
      this.send({
        : "esponsec"
               :java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 24
      :[
       java.lang.StringIndexOutOfBoundsException: Range [18, 15) out of bounds for length 35
java.lang.StringIndexOutOfBoundsException: Range [11, 8) out of bounds for length 10
      })(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27


    onMessage(    java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
      this._listenersjava.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
      java.lang.StringIndexOutOfBoundsException: Range [14, 12) out of bounds for length 20
        this_  .filter()= l! )java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
      };
    }

(:void {
      this.closeCallCount++;
      this. }
      this._java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 0
        code: 1000,
        reason: "closed",
        retryable: false,
      };
      this.emit("close", 1000, "closed");
   java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

    // Test helper: simulate WebSocket connection drop mid-request
   ode 1006,reason =java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 66
      this.connected  ;
      java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 0
        java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
        reason,
            expect(convert(().(];
          code :unknown]java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
           = 1005|
          code === 1006 .( :", };
          code === 1011   }
          code === |
13java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
           }
      .emit"close,code reason);
   }

/  helper a  event
    simulateEvent}
const =event { ? ;?  ?:  }
      if (maybeEvent    result   java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
        this._description: "Run a command
      }
            :  object" :{md:{type: "    "responses,
        fn(event);
      }
    }

    // Test helper: simulate connection being broken =java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 70
    simulateBroken(): f a:stringjava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
      this.connected =java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
      this._broken = true;
}

        toolName: "test_tool",(" emptyjava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 81
    setPreviousResponseId(    isError ,
      this._previousResponseId
    }

    static lastInstance:function makeFakeAssistantMessage(text: string) {
    static instances: MockManager[] = [];

    static reset(): void {
     MockManagerl =ull
      MockManager.instances    content [ typejava.lang.StringIndexOutOfBoundsException: Range [21, 7) out of bounds for length 7
   java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  }

h constructorto track java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
OriginalMockManager=ockManager
  class TrackedMockManager:10,
     result convertTools(  unknownasParameters convertTools[0)java.lang.StringIndexOutOfBoundsException: Index 88 out of bounds for length 88
      cacheWrite 0,
ger =this;
      TrackedMockManager.nstances.ush()
    }

    static :TrackedMockManager|null;
    static instances: TrackedMockManager[] = [];

    /** Class-level flag: make ALL new instances fail on connect(). */
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
      return   |tools
    e java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
    static setname   
      _{
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

static globalSendFailuresRemaining" :outputText,
      return _
}
expect0?java.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 43
      gjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 39
    }

    static reset(): void {
      TrackedMockManager;
      TrackedMockManager}java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
  gjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 23
          {
     java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 24
  }        de:"java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 42

  return 
}}

vi.mock:
  resolveProviderTransportTurnStateWithPlugin:)= ,
  resolveProviderWebSocketSessionPolicyWithPlugin: () => undefined,
}));

// Track if streamSimple (HTTP fallback) was called
const// ────────────────              :""],
const mockStreamSimple = java.lang.StringIndexOutOfBoundsException: Range [0, 27) out of bounds for length 0
  streamSimpleCalls.                action: : e"}
  =createAssistantMessageEventStreamit"eturns arrayfor undefined "(>{
 =
                  :"r arrayempty "  java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
    java.lang.StringIndexOutOfBoundsException: Range [18, 10) out of bounds for length 64
    .()
  })      java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 19
  java.lang.StringIndexOutOfBoundsException: Range [15, 8) out of bounds for length 16
)
const   :string},

// ─────────────────────────────────────────────────────────────────────────────
// Helpers
// ─────────────────────────────────────────────────────────────────────────────

/** Resolve a StreamFn return value (which may be a Promise) to an AsyncIterable. */
async function resolveStream"existingjava.lang.StringIndexOutOfBoundsException: Range [38, 35) out of bounds for length 68
        java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
)description Run ,
  return stream           :",:{{:""}  ,
}

// ─────────────────────────────────────────────────────────────────────────────
// Fixtures
// ─────────────────────────────────────────────────────────────────────────────

java.lang.StringIndexOutOfBoundsException: Range [0, 17) out of bounds for length 6
{:;java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 68
  | {
      :"ssistant;
      content: unknown[];
      phase?:""|f";
      stopReason: java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 23
      :"  ,
      provider: string;
     eters :o" }
      usage: unknown;
      timestamp: 
    }
  |
  :"       function"java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
         
         ,
     :[;
      isError: boolean        additional: false
      timestamp:const  }
    };

function userMsg( object
  return { java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
}

function assistantMsg(
  textBlocksjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
:Array{ Read,
  java.lang.StringIndexOutOfBoundsException: Range [8, 6) out of bounds for length 21
         "java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
          :
  for (const t of java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 18
    content.({ type: "properties{  java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 56
  }
for  ofjava.lang.StringIndexOutOfBoundsException: Range [30, 28) out of bounds for length 31
    content.java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 7
  }
  return {                actionaction   echojava.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    role: "assistant",
    contentjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
    phase,
    stopReason: 
    api: "openai-responses"      },
    provider]
          
    usage:: ,
     ,
  };
}

function toolResultMsg(callIdjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 0
  return {
    role: "toolResult",
    toolCallId: callId,
    toolName        text: { type"string" }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
content["java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
    isError: false,
    timestamp: 0,
  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
}

java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 49
  return {
    role: "  it("uses image_url java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
     {type:t  java.lang.StringIndexOutOfBoundsException: Range [39, 37) out of bounds for length 47
    stopReason: "stop" as [
    api: " : = java.lang.StringIndexOutOfBoundsException: Range [37, 31) out of bounds for length 88
    provider: "openai",
    model "pt5."java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    usage: {
      input: 10,
      output: 5,
      cacheRead: 0,
      cacheWrite: 0,
      totalTokens: 15,
put ,,cacheRead:0 java.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 75
    }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    timestamp: Date.nowdescriptionRun ujava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 4
}

java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 28
  id: string,
      java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
 java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
?""};
): ResponseObject {
:ResponseObject  [
  if (outputText)      const  =
push{
            time         ping,
      id: "item_1",
     :,
      content: [{ type: "output_text"        : { java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 84
      phase,
    });
  }
  if (toolCallName) {
    output.pushconstjava.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 89
      type: "function_call"};
      id: "item_2          
      call_id: ,
:,
      java.lang.StringIndexOutOfBoundsException: Range [19, 15) out of bounds for length 35
    )
  }
};
    id,
    object(antext  ,
     .(
    status: "completed",
    :"-5.",
    output,
   usage {      java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 40

 it"  :  expectitems[.{ ",:a  Hjava.lang.StringIndexOutOfBoundsException: Range [93, 91) out of bounds for length 97

// ─────────────────────────────────────────────────────────────────────────────
// Test suite
// ─────────────────────────────────────────────────────────────────────────────

describe)
  it("java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    expect(convertTools(undefined     msg java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

"  for ,>
    expect(convertTools([])).toEqual java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  });

  it("converts tools      java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 65
    const tools = [
      {
        name exec
 a command
        parameters: /java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
      },
    ];
    const result = convertTools(tools as unknown as Parameters<typeof convertTools>[ exec,
   r.(;
    expect(result[0    fc= java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 47
      type:)
ec,
      description:"typeof 
      parameters: {const tjava.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 34
)
  });

  it("handles tools without description ;
    const tools = [ =[sg unknown 
   result ==java.lang.StringIndexOutOfBoundsException: Range [37, 31) out of bounds for length 77
    expect(result[0]?.[];
   java.lang.StringIndexOutOfBoundsException: Range [26, 18) out of bounds for length 61

 "msg  {
     tools=[ "java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
    const      :[
   result[].    ;
      type: "object",
      properties: {},
    )
  });

  itjava.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    const tools = [
      { name: "list_regions",{
    ]java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
expectresult)      java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 7
    expect(result[0]) 
      java.lang.StringIndexOutOfBoundsException: Range [12, 10) out of bounds for length 23
      provider openai           mage_url :"image/,"}}java.lang.StringIndexOutOfBoundsException: Index 82 out of bounds for length 82
      description: "List AWS regions"       }
      parameters: 
    }"    const items = conve(msgunknown <
  });

  it("adds java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 10
    const tools =items0
      {
         ,
        description: "Run a query",
        parameters: {       { api: "openai-responses",java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
      },
    ];
    const result = convertTools(java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 21
    expect(result[0]                   ",
      type: "object",
         s},
      required: ["q"] :"."
    });
  });

  it("java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 5
    const tools = }java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
      {
        name: "dispatch",
        description: "Dispatch an      :"-,
        parameters:{
          anyOf: [
            {
              type:""
              : :{const p" ,
              required: ["action"],
            },
            {
              java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
              properties: {
                action {const "cho"}java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
                :{type: s"java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
              },       :"essage"
              required: ["action", "text"],
            },
          ]
        },
      },
    ];
    const result  ",
    role a"
      type: "object",
      as typeof>[]         final_answerjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
        action: { type: "java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0

      },
      required""
      additionalProperties: true "  ,
    });
  });

  itcontent java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    const tools = [
      {
"",
        description: "Conditional      = (
        parameters: {
                  java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
}

    ];
    typeof
    expect(       [)
      allOf: [{ type: " (   item
}java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
   constfcItem=items.ind(i >it:""java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

  s on: java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 25
      model:52java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        name: "exec",
        description: "Run a command",
        
      java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
    
        expec(
    expect(java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      type: "object",
      properties: { cmd: { typecontent Replay",
    };
  });

  it("adds      { id:call_1, java.lang.StringIndexOutOfBoundsException: Range [27, 27) out of bounds for length 7
     )
      {
        name p,
        descriptionnit"  unsigned separate  siblings  present" =>{
        parameters:{ type o    msg={
      },
    ];
    const 
      strict: true,
    ;

    expect(result
      type      :"
      :" merun         
      type:t const,
      parameters: {
type:"bject
        properties: {},
 false,
        required: [],
      },
      strict:      strict: true
    });
  });

itf  to :fortoolswithnonjava.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 16
    const tools = [
      {
         "ead",
        description: "Read file",
        parameters: {
          type: "object",
          properties: { path: { type:     (
          java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 10
        },
      },
    ];
    const result = convertToolstype "message java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 25
      strict:         : Legacy,
    });

    expect(result[0]).toEqual({
      type: "function",
      name: "read",
ion:"Read file"
      parameters: {
        :"object"
        properties:"final_answer",
        additionalProperties: false,
      },
      strict: false,
    }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  });
});



java.lang.StringIndexOutOfBoundsException: Range [37, 8) out of bounds for length 47
  it      :[
    const items = convertMessagesToInputItems([java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 33
       
    >0];
    )(1)
    expect[0)toMatchObject {


  it("uses image_url parts for OpenAI-compatible user images", () =          textSignature: JSON.stringify( v:1 id: "",         
              "text  constjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      role:",
      content:[
        { type: "text", text: "describe this" }                    : JSONstringify{v 1id "tem_final :"},
        { api: "openai"
      ,
      timestamp: 0,
   }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    const items = java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 16
      [msg] as Parameters;
      { api      java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    );

    expect(items).    expect(
      {

        role: "user",
        content: [
          { type: "input_text", text: "describe this    toEqualexpectjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
          { type: "image_url", image_url: { url: "data        : W. "
        ],
      }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
    ]);
  });

  it("keeps input_image parts for Responses user images",        : "unction_call",
java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 30
      role",
      content: [{ type: "image", mimeType: "      }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
      timestamp: 0,
    };
    const items = java.lang.StringIndexOutOfBoundsException: Range [0, 45) out of bounds for length 24
      [msg] as Parameters<typeof convertMessagesToInputItems>[0],
      { api:  content Done"


    expect(items).toEqual    ;
      {
        type: "message",
        role:  (ajava.lang.StringIndexOutOfBoundsException: Range [28, 21) out of bounds for length 46
       [
          {
pe i"java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
            :{type:""media_type:"/ng" data " ,
          },
        ],
      },
    ];
  });

  it("converts an assistant text-only message", () => {
    const items = convertMessagesToInputItems([assistantMsg(["Hi}
      typeof convertMessagesToInputItems
    >[0]);
    expect(items).toHaveLength(1);
    expect(items[0]  (" OpenAI- -esult  as   model:"-52"
  });

  it("preserves assistant phase on replayedjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    const([
      assistantMsg(["java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    ] as Parameters<typeof convertMessagesToInputItems>[0]);
    expect(tems)java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 34
    expect(items[0]).toMatchObject:"",
      type:     const   convertMessagesToInputItems(
      role: "assistant",
      content "orkingon it.",
      phase: "commentary",
    });
  });

  it("converts an assistant message with a tool call",    ;
    const msg])
      ["Let    expect().oEqual  );
      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    );
    const items = convertMessagesToInputItems([msg] as unknown as Parameters call_id c,
      typeof convertMessagesToInputItems
    >[0]);
    // Should produce a text message and a function_call item
    const      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    const fcItem = items.find((i        : user,
    expect(textItem).toBeDefined();
    expect(cItem({
",
      call_id: "call_1",
      : "exec,
       })java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    expecttextItem).otjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 9
)
    expect(JSON.parse(drops    ,( >java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
  }stopReason: ""java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

  :test_tool
    const msg = assistantMsg(
      ["Let me run that."],
      [{ id: "call_1", name: "exec", args: { cmd:  timestamp 0
    items=[asunknownasParameters
    );
    const items =        
      convertMessagesToInputItems
    >[0]);
    const textItem = items        typeofjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 5
    expect(    ).toEqualtoEqualjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
   ejava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
:"all_from_tool_use"",
      content: "Let me run that.",
      phase: "commentary",
    });
  });

 it"preserves   it("preserves assistant
    const msg = {
      role ""as const,
      content: [
        {
          ""
",
itp  java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 35
        ,
      ],
      java.lang.StringIndexOutOfBoundsException: Range [0, 16) out of bounds for length 9
      api: "  it("converts a. java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
      provider: "openai",
",
      usage: {},ass(, "   {s})
      timestamp: 0,

    const items"fc_1,
       =java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 23
    >[0]);
    expect,
    expect(items[0]).toMatchObject({
      type:     type: "text"as ,
      :a      (i) => i.type "&i ? java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 78
      content:             textSignature stringify :1id""  inal_answer}java.lang.StringIndexOutOfBoundsException: Index 91 out of bounds for length 91
      phase: "commentary",
    });
  ;

  it("splits       : o"
sg={
      role: ": }java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
      phasef as    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 97
      content: [
        
          type: "text          typeof
          text: "Working... ",
          textSignature: JSON.      {
,
        {
          type: "text" as const,
 "java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
          textSignature: JSON.      }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
        
      ],
:"top,
      api: "openai-responses",
              argumentss :}
      model)
      usage: {},
      timestamp: 0,
    };

    pha",
}
        typeof convertMessagesToInputItems
      >[0]),

      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
            >0];
        java.lang.StringIndexOutOfBoundsException: Range [18, 16) out of bounds for length 25
        content: "Working... ",
        ",
      },
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        type:       java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 6
               role:"java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 7
        content:
        it("preserves-java.lang.StringIndexOutOfBoundsException: Range [39, 33) out of bounds for length 91
      },
    ]);
  };

itrole java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
    const msg = {
      role " java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 65
      phase: "  ,
      content: [
        {
          type: "text"     [
          text: "Replay.           java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 36
          textSignature: " :[text ]}
        },

          typemjava.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
          text: "        :",
          textSignature: JSON.stringify({ v      java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
        },
      ],
      java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 25
      api: "openai-responses",
      :,
      model: "gpt-5
      usage: {},
      timestamp: 0,
    };


java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 10
         msg java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
      >0)java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
   .(
      {
        type:",
        role: "assistant",
        content: "const msg java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
phase:"inal_answer"java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
      },
    ]) {
  });

  it(  "  tojava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 66
const  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
role "const
      phase: "final_answer" as const,
      content: [
        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
           " :java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
          text: "Legacy.     }
        ,
        {
          type: "text" as const,
          text: "Done.",
          (tems)1;
        ,
      ],
stopReason"stop"
      api: "openai-responses",
      provider: "openai",
      model: "gpt-5.2",
      usage: {},
      timestamp: 0,
    };

    expect(
      ([msg] as unknown as Parameters
        typeof convertMessagesToInputItems
      >[0 msg = {
    ).toEqual(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
      {
        type: "message",
        role: "assistant",
         "Legacy. ",
      },
      {
        type: "message",
        role: "assistant",
        content: "Done.",
        phase: "final_answer)()type extas: "java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
      },
    ]);
  });

 (java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 120
    const msg = {
      role: "assistant"     msg=java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 16
      content: [
        {
          type",[]as Parameters
           ..,
textSignature.( :1>)
        },
        {
    expect(};
          id: "call_1|fc_1",
          name:        java.lang.StringIndexOutOfBoundsException: Range [12, 1) out of bounds for length 57
          arguments: { cmd: "ls" },
        },
        {
          type: "text"         role: "assistant"
          text: "Done.,
          textSignature: JSON,
        ,
      ],
      stopReason: "toolUse",
       ojava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 30
      provider: "openai",
      java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 5
      usage: {},
      timestamp: 0,
    };

    expect(
      convertMessagesToInputItems([msg]      :escribe"",( >{
    ).(
      java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
        type: "java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 16
         ,
  content: "orking.. "
        phase: "commentary",
      },
      
        type: "function_call    (.).toBe
        id:"    textBlock..(Hello assistant");
        call_id: "call_1",
        name: "",
        arguments  ( to ' -java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 5
      },
      {
            const ms msg =java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
        role: "assistant    msg.topReason)toBe);
        content: "Done.",
        ",
      },
       ];
  };

  it("converts      tc= .ontent(() >ctype == toolCall"{
    const items  id""java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
                )
    >[]);
    ).toHaveLength1;
      :java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 8
      type: "function_call_output"     ()ojava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 29
      call_id: "call_1",
      output:filetxt",
    
  };

)java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  it("preservmalformed java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 77
      role: "toolResult",
      toolCallId: "call_1",
      toolName: "read",
      content: [{ type: "image", mimeType: "image/java.lang.StringIndexOutOfBoundsException: Range [0, 53) out of bounds for length 25
      isError: false,
      timestamp: 0,
    }  (" reasoning blocks  signature type reasoning.*",( >{
ms =convertMessagesToInputItems
      [msg] as Parameters      : "ssistant"as,
      { api: "openai-completions", input: ["text", "image         java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
    

    expect(items).toEqual([
      {
        type"unction_call_output"java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
        :call_1"java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
        output: "(see attached image)",
      }:unknown
      {
        type: "message",
        role: "user",
        content: [
          { type: "input_text", text: "Attached image(s) from tool result:" },
          { type: "image_url",  usage:{java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
        ],
           items convertMessagesToInputItems[] present,)= java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
    ])     response  ("resp_3",undefined,"    >0)
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

  it("drops  });
    
      role:   "drops java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 81
      :,
      toolName: "test_tool",
      content: [{ type: "text", text: "output" }],
      isError: false,
      timestamp: 0,

    const items = convertMessagesToInputItemsthinking: " reasoning..",
      typeofconvertMessagesToInputItems
    >[0]);
    expect(items).toEqual([]);
)

  it("falls back to toolUseId stopReason: "constjava.lang.StringIndexOutOfBoundsException: Range [59, 49) out of bounds for length 71
           api: "o:openai"
      role:    m.java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 44
      toolUseId: "call_from_tool_use",
      toolName:  (maps  andcompletion_tokensaliases, )= {
      content: [{ type: "text", text: "ok" }],
      isError: false,
      timestamp: 0,
    };
    const items = convertMessagesToInputItems([msg] as unknown as Parametersusage:{java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
      convertMessagesToInputItems
    >[0]);
    (items()
    expect(items[0]).    (u.)toBe)
      type: "function_call_output"    expect(msg.sage.utput).toBe(11)
      call_id: "call_from_tool_use",
output: "ok",
    });
  })

  convertsafullmultiturn ()=>{
    const messages: FakeMessage[] = [
    const response =makeResponseObject("" Hello;
      assistantMsg([], [{ id: "call_1", name: "exec", args: { cmd: "ls" } }]response. = {
      toolResultMsg("call_1",      completion_tokens: ,
    ];
    const items = convertMessagesToInputItems(
          const msg  buildAssistantMessageFromResponse(,modelInfo);
    )java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6

    const userItem = items.find(
      (i) => i.type === "message" &&   };
    );
    const fcItem = items.  it("falls back to)
    const response =makeResponseObject"esp_5d" "Hello  });

    expect(userItem).java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 23
    expect(fcItem).toBeDefined();
    expect(outputItem
  });

  it"assistant messagesjava.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 73
msgusageinput.()
    const items     usageoutput)java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 37
      typeof convertMessagesToInputItems
    [0);
    expect(items)
    expect(items  itdescribe(buildAssistantMessageFromResponse (>{
)

ol   java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 64
     msg  ([,    java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 38
    const items java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
typeof
>;
    expect(items).toEqual([]);
  });

  it("skips thinking blocks in assistant messages", ()     expectmsgcontentt([])
      java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
      :assistant as constjava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
      content:[
        type:"thinking"thinking:"internal reasoning..." },
        { type: "text", text: "Here const msg = buildAssistantMessageFromResponse(response       makeResponseObject(" " " undefined"java.lang.StringIndexOutOfBoundsException: Range [92, 90) out of bounds for length 93
      ],
      stopReason ;
      api: "openai-const       (msgphase)toBe"";
      : openai"
        )
      usage: {},
      timestamp: 0, ;
    }java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 41
 (  Parameters(.;
      typeof       object: "response
    (arguments(" java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
    expect(items).toHaveLength(1);
    expect((items[0] {
  });

  it("replays reasoning
    const msg = {
      role: "assistant" as      "java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 26
      content: [
        {
          type: "thinking" as const,
          thinking: "internal reasoning...      ]
          : JSONjava.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 45
            type: "reasoning",
                  
               100 ,total_tokens 
          })       ;
        
        ",name java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      ],
      stopReason: "stop",
api openaiexpecttjava.lang.StringIndexOutOfBoundsException: Range [29, 26) out of bounds for length 29
      provider: "openai",
      model: "gpt-5.4",
      usage: {  }
      timestamp: 0,
    };
    const items = convertMessagesToInputItems([msg] as Parameters<
      typeof convertMessagesToInputItems
    0xtSignature JSONtringify{::1 :",: )java.lang.StringIndexOutOfBoundsException: Index 89 out of bounds for length 89
expectmap()>.(r,"}
    expect(
  }) it final

  "  blocks    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 72
    const msg = {
      role"  
      content: [
        {
:  ,
          thinking: "internal reasoning...",
          : JSON.stringify{
            : ".summary,
            id: "rs_summary",
          },
        },
         : "extas const, :"ereismy . ,
     ]
      stopReason: "stop",
       -java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 30
      provider: "java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 9
"-.,
      usage:const  java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 60
      timestamp: 0,
    };
    :{ , java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 28
      } as ;
    >
        const  java.lang.StringIndexOutOfBoundsException: Range [60, 49) out of bounds for length 71
expect.java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 76
  });

  it("drops reasoning replay ids that dojava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    const msg = {
      role: "assistant" as const,
      content: [
        {
          t constjava.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
          thinking: "internal reasoning...",
          java.lang.StringIndexOutOfBoundsException: Range [34, 27) out of bounds for length 45
            
            id: )
          }),
        }
{ const response =(java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 60
      ],
      stopReason: "stop",
      api: "openai-responses",
      provider: "openai",
      model: "gpt-5.4",
      usage:
      timestamp: 0const        output [
    };
   const  items  java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 26
      typeof java.lang.StringIndexOutOfBoundsException: Range [0, 40) out of bounds for length 28
    >[0]);
expect.java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        type: "reasoning",
      },
      {
        type: "message",
        role: "assistant",
        content: "Here is my answer]
      ,
    ]);
  });

  it("returns empty array forjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    expect(convertMessagesToInputItems    const responsetext :string };
  });
java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 3

// ─────────────────────────────────────────────────────────────────────────────

ribe((java.lang.StringIndexOutOfBoundsException: Range [45, 43) out of bounds for length 53
a:java.lang.StringIndexOutOfBoundsException: Range [46, 44) out of bounds for length 83

      ? ;
const java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 74
const   java.lang.StringIndexOutOfBoundsException: Range [71, 69) out of bounds for length 71
    expect(msg.content).toHaveLength(1);
     = msg.0 as { type:string;text
ype.()java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
    expect(textBlock.text    const response = {
  });

  it("sets stopReason to 'stop' for text-only responses          [text:" step , text      :"
   r" Just{
    : m,
    expect(:"      :"pt2java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  )

  it("extracts ,
    const      :: 100 java.lang.StringIndexOutOfBoundsException: Range [48, 47) out of bounds for length 73
    const msg}
    const tc = msg.content.find{

      id mjava.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 26
       ;
      arguments: Record<phase: "final_answer
    };
    expect(tc)java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 8
    expect( :", }
    expect(tc.id).)
    expect(tc.arguments).toEqual =java.lang.StringIndexOutOfBoundsException: Range [51, 49) out of bounds for length 75
  });

  it("preserves malformed function-call arguments as the 
    const response: ResponseObject = {
      id: "resp_malformed",
      object: "response
      created_at: Date.now(),
      status: "completed",
      model: "gpt-5.4        
      output: [
        {
          type: "function_call",
           "
          call_id: "call_bad",
          name:usage:{it legacyjava.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 100
          arguments: "not valid json",
        },
      ]
      usage: {     const thinkingBlock =[0 
    };

    const msg = buildAssistantMessageFromResponse(response,       ;
     tc=.ontent.(c = c.type == "toolCall") as {
      type: string;
      name: string;
      arguments:;
    };

expect)(;
    (.name(exec)
   tcarguments          :,
  });

  it("sets stopReason to 'toolUse' when tool   )java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    const   it("prefers java.lang.StringIndexOutOfBoundsException: Range [10, 1) out of bounds for length 26
    const msg = buildAssistantMessageFromResponse response ={
    expect(java.lang.StringIndexOutOfBoundsException: Range [18, 14) out of bounds for length 32
  }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

  it("includes both text and java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 8
    const response = makeResponseObject("java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 26
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    expect(msg.content.output: [
    expect(msg {
    expect(msg.stopReason).toBe("toolUse");
  });

  it("maps usage tokens     expect(msg.phase).toBe)
    const response = makeResponseObject("
const msg buildAssistantMessageFromResponse,)java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
   i)(100;
    expect(msg.usage.output).toBe(50);
    expect(msg.usage.totalTokens).toBe(150);
  });

  it("maps prompt_tokens and java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 39
    const response = makeResponseObject("resp_5b",       java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
    response.usage = {
      44java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
: 11,
      :55,
    };

|java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 18
    expect(msg.usage.input).toBe(44);
    expect({ java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 66
    expect(msg.usage.totalTokens).toBe(55        ,
  });

  it("falls back           java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 26
    const response = object: "response
    response.usage = {
      prompt_tokens:"-54java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 9
    };

    const msg          
    expect(msg.usage :Array{s  java.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 69
    expect(msg.usage.output).toBe(5);
    expect(msg.usage


 (   java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 83
    const response = makeResponseObject("resp_5d",java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    responsejava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 22
      input_tokens: 10,
      output_tokens: 5,
      total_tokens: 0,
    :java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

    const msg = java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 23
    java.lang.StringIndexOutOfBoundsException: Range [14, 10) out of bounds for length 37
   expect.usage.utput).oBe(5)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
    expect(msg.usage.totalTokens).toBe(15);
  };

  it("sets model/provider/api from           : "all_tool"
              :"exec,
    constmsg=java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 39
    expect(msg.api).toBe("openai-responses");
    expect(msg.provider).toBe("openai            content: [{ type"Fanswer ,
    expectmsg
  })

  it("handles empty output gracefully"     java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 35
    const response = makeResponseObject("resp_7");
    const   buildAssistantMessageFromResponse, modelInfo
    expect(msg.content).toEqual([]);
).toBe(stop
  });

  it("
java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 93
    const msg = java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 6
      phase?: string;
      content: Array<{ type: string; text?: string }>;
    };
    expect(msg.phase).toBe("final_answer");
    expect      ={
  });

  it      object:"response"
    const response = {
      id: "resp_mixed_phase",
      object: "response",
      created_at: Date.now(),
      status:       :Daten(,
      model: "gpt-5.2",
      output: [
{
          type: "message" java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
          id: "item_commentary",
          role: "assistant",
          phase: "commentary",        ,
          content: [{ type: "output_text: java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 73
        (, "java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 85
        {
          type: "message",
          id:       .0 java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
          role: "assistant"    ;
          phase: "
  :java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 60
        ,
      ],
      java.lang.StringIndexOutOfBoundsException: Range [28, 24) out of bounds for length 38
    } as unknown )

    const msg =     expect(turnInput.mode).toBe("incremental_tool  java.lang.StringIndexOutOfBoundsException: Range [84, 83) out of bounds for length 93

      content:    ()[
    };

    expect(msg.phase).toBe 54,
    expect(msg.content).java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 27
      {
        type: "text",
         one"java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
        textSignature           java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for length 32
      },
   ]
  });

  it("keeps only phased final text when unphased legacy text and       java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
   const  ={
      id: "resp_unphased_plus_final",
      object: "java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 9
(
      status: "completed",
      model: { " java.lang.StringIndexOutOfBoundsException: Range [38, 36) out of bounds for length 74
      output: [
        {
          type: "message",
          id: "item_legacy",
          role: "assistant",
          content: [{ type: "output_text", text        ,
        
        {
          type: "message",
          id: "item_final",
          role: "assistant",
          phase: "java.lang.StringIndexOutOfBoundsException: Range [0, 30) out of bounds for length 29
          content: [{         " ",
}
      ],
      usage: { input_tokens: 100, java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 9
    } as unknown as ResponseObject;

    const       tools: :[,
      phase?:  }
      java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
    };

    expect(msg.phase
  c).java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 39
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        type:"ext"
        text: "Done.itfor            response: makeResponseObject(`warmupw{n)
              {
      },
    ]);
        )

  it("drops commentary-only text from completed assistant      ;
     java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 22
      idjava.lang.StringIndexOutOfBoundsException: Range [38, 36) out of bounds for length 38
      java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 30
created_at"java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      status: "completed           =1006||
     n xec
    java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
          type: "      usage: { input_token
          
role "java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 28
          i:)void
          content:      this.consttoolCall assistant.content
        },
        (.:     replayItemsjava.lang.StringIndexOutOfBoundsException: Range [53, 51) out of bounds for length 78
:,
idi"
          call_id: "call_abc
         :"exec
               :'"":value},
        },
      ],
      usage:100, ,java.lang.StringIndexOutOfBoundsException: Range [67, 65) out of bounds for length 73
    } as static reset(): void {

    const msg =java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
      :
 )>java.lang.StringIndexOutOfBoundsException: Range [67, 66) out of bounds for length 67
      stopReason: const=vi.fn(model: unknown,: unknown,options:unknown)= {
    }sconst =createAssistantMessageEventStream;

msg.)toBeUndefined
    expect(msg.content
    expect(msg.content};
   java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 43
  });

// Helpers
    const response = {
      id: "resp_reasoning",
      object: "response",
      created_at: Date.now),
      : "ompleted"java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
       gpt-."
      output:
        {
          java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
          id: "rs_123",
// ─────────────────────────────────────────────────java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
        {
          type: tjava.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds for length 25
          id: "item_1}
          : "assistant"
", text Final answer"}java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
        },
      ,
      usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 },
    }as unknown as java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
    const msg = buildAssistantMessageFromResponse(reasoning"java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    const thinkingBlock = msg.content.find((c) => c.type === "thinking") as
      | { type: "thinking"; thinking: string; thinkingSignature?: string }
      | undefined;
    expect(thinkingBlock?.thinking function_call"
    expect(call_id "",
      JSON.stringify({ 
    );
  });

   to thinkingblocks" )= {
     ={
      id: "resp_reasoning_kind",
      java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 25
      created_at: Date.now(),
      status: ""            : response.mpletedjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
      model: "gpt-5.4",
      output: [
        {
          type: "reasoning.summary",
          id: "rs_456",
          content: "Derived hidden reasoning",
        },
      ],
      usage:}java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    } as unknownrej(
    const msg = java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 9
    const thinkingBlock = msg.content[0] as
      | { type: "thinking"; thinking: string; thinkingSignature?: string }
      | undefined;
    expect(thinkingBlock?.type).toBe("thinking");
    expect(thinkingBlock?.thinking).toBe("Derived hidden reasoning");
    expect(thinkingBlock?.thinkingSignature).toBe(
      JSON.stringify({ id: "rs_456", type: "reasoning.summary" }),
    );
  }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

  (prefersreasoning summary java.lang.StringIndexOutOfBoundsException: Range [41, 36) out of bounds for length 93
    const it("endsonly the suffix java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 97
      id: "resp_reasoning_order",
      object: "response",
      created_at: Date.now()const :  = {
      status:""java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
      model: "gpt-5.4",
      output: [
        {
          type: "reasoning.summary",
          9,
          summary: ["Plan A", { text: "Plan;
          java.lang.StringIndexOutOfBoundsException: Range [0, 17) out of bounds for length 0
        }
        {
          type: "function_call",
          id: "fc_789",

          name: "exec",
          arguments: '{"arg":"value"}',
        },
      ] ype:"esponse.ompletedjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
      usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 },
    } as unknown as { type: "message", role:"" }

    const msg;
    expect(msg
    const thinkingBlock = msg.const plan = planOpenAIWebSocketRequestPayload({
      | { type: "thinking"; thinking: string; thinkingSignature ullPayload,
      | undefined;
    expect(thinkingBlock?.thinking).toBe("Plan A\nPlan B");
    expect(thinkingBlock?.thinkingSignature).toBe(
      JSON.stringify({ id: "rs_789", type: "reasoning.summary" }),
    );
  });

  it(expect(plan.mode).toBe("incremental");
    const response = {
      id: "resp_invalid_reasoning_id",
      object: "response",
       n(,
      status: "completed",
      model: "gpt-5.4",
      output  it(   " ( 
        {
          type: "reasoning",
          java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 50
          content: "Hidden reasoning",
        },
      ],
      usage: { input_tokens: 100, java.lang.StringIndexOutOfBoundsException: Range [4, 47) out of bounds for length 6
    unknown  ResponseObject;

    const msg = buildAssistantMessageFromResponse(response, modelInfo);
    expect(msg.content).toEqual([{ type: "thinking";
  };

  it("preserves function call item ids for replay when reasoning is present ;
    const response = {
      :resp_tool_reasoningjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      object: "response",
      created_at: Date.now(),
      us:"ompleted"
      model: "gpt-5.4",
      output: [
        {
          type: "reasoning",
          id: makeResponseObjectresp_no_store,ok"java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
          content: "Thinking before tool call",
        },
        
          type: "function_call",
          id: "fc_tool",
          call_id: "call_tool",
          name: "exec",
          arguments: '{"arg":"valuerej(e)
        },
      ],
      usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 },
    p..previous_response_id();

    const assistant = buildAssistantMessageFromResponse(response, modelInfo);
    java.lang.StringIndexOutOfBoundsException: Range [43, 9) out of bounds for length 82
      | { type: "toolCall"; id: string }
      | undefined;
    expect(toolCall?.id).toBe("call_tool|fc_tool");

    const replayItems = java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 5
      typeof java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 0
    [0]);
    expect(replayItems.map((item) => item.type)).toEqual(["reasoning", "function_call"]);
    expect(replayItems[1]).toMatchObject({
      type: "...modelStub
      call_id: "call_tool",
      id:"fc_tool",
    });
  });
});

c  =planTurnInput{

java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 77
  const replayModel = { input: ["text"] };

  it"incremental tool  :[ type:essage,:"" content"" ]java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 67
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
      systemPrompt: "You are helpful.",
      messages: [
        userMsg( )java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
        assistantMsg([], [{ id: "call_1|fc_1", name: "exec", args: { cmd: "ls" } }]),context java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 41
        toolResultMsg("call_1|fc_1", "file.txt"),
      ] as Parameters<typeof convertMessagesToInputItems>[0],
      tools: [],
    };

    java.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for length 37
      context,
      odel:replayModel
      previousResponseId: "java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 5
      lastContextLength: 2,    const streamFn=createOpenAIWebSocketStreamFn"ktest"sess-2")
    });

    expectmodelStub typeof >0,
    expect(turnInput.previousResponseId).toBe("resp_prev");
    expect(turnInput.inputItems).toEqual([
      {
        type: "function_call_output",
        call_id: "call_1",
        output: "file.txt",
      },
    ]);
  });

  it("restarts with:4096,
    const turn1Response = {
      id: "resp_turn1_reasoning",
      object: "response",
      created_at: Date.now(),
      status: "completed",
      model: "gpt-5.4",
      output: [
        {
          type: "reasoning",
          id: "rs_turn1",
          content: "Thinkingmanager.({
        },
        {
          type: "function_call",
          id: "fc_turn1",
          call_id: "call_turn1",
           e,
          arguments: '{"cmd":"ls"}',
        },
      ],
      usage: { input_tokens: 12    java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 42
    } as ResponseObject;

    const context = {
      java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 7
      messages: [
        userMsg("Run ls"),
        buildAssistantMessageFromResponse(turn1Response, {
          api:"penai,
          provider: "openai",
          id: "gpt-5)
        
      ]as Parameters >et responsesa (>java.lang.StringIndexOutOfBoundsException: Index 86 out of bounds for length 86
      tools: [],
    };

    const turnInput = planTurnInput({
      context,
      model: replayModel,
      previousResponseId: "resp_turn1_reasoning",
      lastContextLength: context.messages.length,
    });

    expect(turnInput.mode).toBe("full_context_restart");
    expect(urnInput).toBeUndefined);
    expect(turnInput.inputItems.map((item) => java.lang.StringIndexOutOfBoundsException: Range [0, 50) out of bounds for length 35
      "message",
      "reasoning",
      "function_calljava.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for length 44
    ]);
    expect(    releaseWsSessionjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 36
    expect(turnInput.inputItems[2]).toMatchObject({
      type: "function_call",
      java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 28
      id: "fc_turn1",
    });
  });

  it("java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 53
    const context = {
      systemPrompt: "You are java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 9
      messages: [userMsg( eleaseWsSession(sesssendfailreset)java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
        java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 94
    };

    constm.java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 53
      context,
      model:releaseWsSession"java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 47
      previousResponseId: null,
      lastContextLength: 0,
    });

    expect(turnInput).toMatchObject({
      mode: " it( java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 83
      inputItems: [{ type: "message", role: "user", content:  "ess1";
    };
  });
});

// ──────────────────────────────

describe("planOpenAIWebSocketRequestPayload", () => {
  it("sends only the strict suffix when the full input extends the prior response chain", () => {
    const delta?: stringmanager=ockManagerlastInstance;
    :ResponseCreateEventjava.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 56
      :"response.create",
      model: "gpt-5.4",
      store: false,
      ul,
      input: previousInputItems,
    };
    const previousResponseInputItems: InputItem[] = [
      { type: "message", role: "assistant", content: "Hi" },
    ;
    const fullPayload:const =streamFn
      type: "response.create",
      model: "gpt-5.4",
      store: false,
      nstructions"ou are       
      input: [
        ...previousInputItems,
        ...previousResponseInputItems,
        { type: "message", role: "user", content: "Next" },
      ],
    

    const plan({
      fullPayload,
      previousRequestPayload: previousRequest,
      previousResponseId: "resp_prev",
      previousResponseInputItems [.],
    });

    expect(plan.mode).toBe("incremental");
    expect(plan.payload.previous_response_id).toBe("resp_prev");
    expect(plan.payload.input).toEqual([{ type: "message", role: "user", content: "Next" }]);
  });

  it("falls back to full context when non-input fields differ", () => {
    const previousInputItems: InputItem[] = [{ type: "message", role: "user", content: "Hello" }];
    const previousRequest: ResponseCreateEvent = {
      type: "response.create",
      model: "gpt-5.4",
      store: false,
      instructions: "Old instructions",
      input: previousInputItems,
    };
    const fullPayload: ResponseCreateEvent = {
      ...previousRequest,
      : New instructions"java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
      
        ...previousInputItems,
        { type: "message", role: "assistant", content: "Hi" },
        { type: "message", role: "user", content: "Next" },
      ],
    };

    const plan = planOpenAIWebSocketRequestPayload({
      modelStubParameterstypeof java.lang.StringIndexOutOfBoundsException: Range [47, 45) out of bounds for length 50
      previousRequestPayload: previousRequest,
      
     previousResponseInputItems type message"role:a" content Hi ]java.lang.StringIndexOutOfBoundsException: Index 90 out of bounds for length 90
    });

    expect(plan.mode).toBe(events.ushe;
    expect(plan.payload.previous_response_id).toBeUndefined();
    expect(plan.payload.java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 9
  });

  "  context when  is strict -chainextension,( >{
    const previousRequest: ResponseCreateEvent 
      ",
      model: "gpt-5.4",
      tore: false,
      input: [{ type: "message", role: "user", content: "Hello" } )java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    };
    const fullPayload: ResponseCreateEvent = {
      previousRequest,
      input: [{ type: "message", role: "user", content:        {
    };

    const plan =java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 56
      fullPayload
      previousRequestPayload: previousRequest,
      previousResponseId: "resp_prev",
      previousResponseInputItems:dmessagecontent0?java.lang.StringIndexOutOfBoundsException: Range [53, 52) out of bounds for length 68
    }it"suppressesjava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 86

    expect(plan.mode).toBe("full_context");
    expect(plan.payload.previous_response_id).toBeUndefined();
    (fullPayload.input);
  });
});

// ─────/;

java.lang.StringIndexOutOfBoundsException: Range [10, 8) out of bounds for length 49
  const modelStub = {
    api: "openai-responses",
    provider: "openai",
    id: "gpt-5    ));
    contextWindow: 128000,
    maxTokens: 4096,
ing: false
    input: anager =MockManager!
    cost: { input: 0, manager.imulateEvent
    name GPT-5."
  };

  const contextStub =}
    systemPrompt: "You are helpful
    messages: [userMsg("Hello!") as Parameters<java.lang.StringIndexOutOfBoundsException: Range [0, 53) out of bounds for length 15
    tools: [],
  };

  beforeEach {
    MockManager.reset();
    .length = ;
    mockCreateHttpFallbackStreamFn.mockReset();
    mockCreateHttpFallbackStreamFn.mockReturnValue(mockStreamSimple as never);
    openAIWsStreamTesting.setDepsForTest({
      createManager: ((options?: unknown) => new MockManager(options)) as never,
      createHttpFallbackStreamFn: mockCreateHttpFallbackStreamFn as never,
      streamSimple: mockStreamSimple,
    });
  });


    // Clean up any };
    MockManager.instances.forEach((_, i) => {
      it(accumulatedphase-ware  when output mappingjava.lang.StringIndexOutOfBoundsException: Range [84, 82) out of bounds for length 98
      releaseWsSession(`test-session-${i}`);
    });
    releaseWsSession("sess-1");
    releaseWsSession("sess-2");
    releaseWsSession("sess-boundary");
    releaseWsSession("sess-fallback");
    releaseWsSession("sess-boundary-http-fallback");
    releaseWsSession("sess-full-context-replay");
    releaseWsSession("sess-incremental");
    releaseWsSession("sess-full");
    releaseWsSession("sess-onpayload");
    releaseWsSession("sess
    releaseWsSession(const done = (async () => {
    releaseWsSession("sess-phase-stream");
    ("ess-";
    java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 7
    releaseWsSession("sess-reason-none");
    releaseWsSession("sess-tools");
    (sess-store-efault)java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
    releaseWsSession("sess-store-compat");
    releaseWsSession("sess-store-proxy");
    -zero");
    releaseWsSession("sess-runtime-fallback-nested");
    releaseWsSession("sess-runtime-fallback");
    releaseWsSession("sess-runtime-retry");
    releaseWsSession("sess-send-fail-reset");
    releaseWsSession("sess-temp");
    releaseWsSession("sess-text-verbosity");
    releaseWsSession("sess-text-verbosity-invalid");
    releaseWsSession("sess-topp");
    releaseWsSession("sess-turn-metadata-retry");
    releaseWsSession("sess-warmup-disabled");
    releaseWsSession("sess-warmup-enabled");
    releaseWsSession("sess-degraded-cooldown");
    releaseWsSession("sess-drop");
    .setWsDegradeCooldownMsForTest
    openAIWsStreamTesting.java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 23
  });

  java.lang.StringIndexOutOfBoundsException: Range [21, 4) out of bounds for length 61
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-1");
    const stream = streamFn(
      modelStub as typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
    );

    /  the  java.lang.StringIndexOutOfBoundsException: Range [40, 31) out of bounds for length 43
    await new Promise((r) => setImmediate(r));

    const manager = MockManager.lastInstance;
    expect(manager?.connectCallCount).toBe(1);
    releaseWsSession("sess-1 :"inal_answerjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
    for await (const _ of await resolveStream(stream)) {
      // java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 7
    }
  });

  it("sends a response.create event on first turn (full context)", async () => {
    const streamFn = java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 21
    const stream 
      modelStub as Parameters<response: {
      contextStub as Parameters<typeof streamFn>[1],
    );

    const completed = new Promise<void>((res, rej) created_at:Date.)
      queueMicrotask(async () => {
        try {
          await new Promise((java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 11
          const manager = id: "item_commentary

            :",
          manager.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp_1", "Hello!"),
          });

          for await (constid "tem_final"java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
            // consume events
          }
          ()
        } catch (e) {
          rej(e);
        }
      };
    });

    await completed;

     manager = MockManager.lastInstance!;
    expect(manager.sentEvents).toHaveLength(1);
    const sent = manager.sentEvents =events.filter(java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 73
    expect(sent.type).toBe("response.create");
    expect(sent.model).toBe("expect(eltas[].( delta:"" }
    expect(Array.isArray(sent.input)).    expect(deltas[0]?.partial?.phase).toBe;
  };

  it("includes store:false by default",         text",
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-store-default");
    const stream = streamFn(
      modelStub java.lang.StringIndexOutOfBoundsException: Range [6, 18) out of bounds for length 8
java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 52
    expect1..("ommentary)java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

    java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      queueMicrotask(async () => {
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 13
           Promise()=>java.lang.StringIndexOutOfBoundsException: Range [52, 47) out of bounds for length 52
          const manager = MockManager.lastInstance!;
          manager.imulateEvent({
            type: "response.completed",
            response: makeResponseObject textjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
          });
           ( _java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 62
            // consume
          }
          )java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
        } catch (e) {
          rej(e);
        }
      });
    });
    await completed;

    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.store).toBe(false);
  });

  itconst events: Array<{
    releaseWsSession("sess-store-compat");
    java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 20
      ...modelStub,
      compat: { supportsStore: false },
    };
    const for await (constof await  resolveStream(stream)) {
    const stream = streamFn(
      noStoreModel as Parameters<typeof streamFn>[0],
      contextStubas <typeof streamFn>[1]
    );

    const completed = new Promise<void>((res, rej) => {
      queueMicrotask(async () => {
        try {
          await new     const manager = MockManager.lastInstance!;
          const manager = MockManager.lastInstance!;
          manager.simulateEvent({
            type: "response.completed",
            (resp_no_storejava.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
          });
          for await (const _ of await resolveStream(stream)) {};
            // consume
          }
          res();
        } catch ",
          rej(e);
        }
      });
    });
    await completed;

    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent).not.toHaveProperty("store");
  });

      manager.imulateEvent(
    const proxiedModel = { response..delta"
      ..item_id::item_late"
      baseUrl: "https://proxy.example.com/v1 output_index:0,
    };
    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 37
      context: contextStub as Parameters<typeof planTurnInput>[0]["context"],
      model: proxiedModel as Parameters<typeof planTurnInput>[0]["model"],
      previousResponseId: null,
      lastContextLength: 0,
    });
    const sent = buildOpenAIWebSocketResponseCreatePayload({
      model: proxiedModel as Parameters<
        typeof buildOpenAIWebSocketResponseCreatePayload{
      type:m",
      context:           
                    type:"message,
      >[0 id:item_latejava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
      ,
      tools: [],
    }) as Record<string,            :[{ type:"output_text",text: "Working..." }],
    expect(sent.store).toBe(false);
  });

  it("emits an AssistantMessage on response.completed", async ()});
    const streamFn = java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 8
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
    d.java.lang.StringIndexOutOfBoundsException: Range [34, 31) out of bounds for length 35
    );

    const events: unknown[] = [];
    const done = (sync (java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
      for await (const ev of await resolveStream(stream)) {
        events.push(ev);
      }
    })();

    await new Promise((r) => setImmediate(r));
    managerM.lastInstance!
    manager.simulateEvent({
      type: "response.completed"    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 7
      response: makeResponseObject("resp_hello", "Hello back!"),
    });

    await done;

    const doneEvent = events.find((e) => (e asexpectd[]..ontent)toEqual[
      | {
          type: string;
          reason: string;
           text:  >};
        }
      | undefined;
    expect(doneEvent).toBeDefined();
    doneEvent?message.0.t("Hello !)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
  });

  it("suppressestype:",
    const         text:"one.
    onst stream =streamFn
      modelStub as Parameters<typeof streamFn>[0}
      contextStub as Parameters<typeof streamFn>[1],
    );

    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 33
    const done = (async () => {
      for await modelStubParametersstreamFn[,
        events.push(ev);
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type? string;
      response: makeResponseObject("resp_phase", "Working...", "exec", "commentarydelta? 
    });

    await done;

    const doneEvent = events.find((e) => (e as { type?: string }).type === "done") as
      |{
          type: string;
          reason:string;
          message: { phase?: string; stopReason: string; content?: Array<{ type?: string }> };
        }
      | undefined;
    expect(doneEvent?.message.phase).toBeUndefined();
    expect(doneEvent?.message.content?.some(    await new Promise(( >setImmediater);
    java.lang.StringIndexOutOfBoundsException: Range [41, 10) out of bounds for length 58
  });

  it"emits accumulated-ware partials when output item mapping is available", async () => {
    onst streamFn=createOpenAIWebSocketStreamFn"ktest" "ess-phase-stream";
    const stream = streamFn(
      modelStubas Parameterstypeof streamFn>0],
      contextStub as Parameters<typeof streamFn>[1],
    );

    java.lang.StringIndexOutOfBoundsException: Range [16, 9) out of bounds for length 25
      type?: string;
      delta?: string;
      partial?: { phase?: string; content?: unknown[] };
    }> = [];
    const done = (async () => {
      for await (const ev of await resolveStream(stream)) {
        events.push(ev as (typeof events)[number]);
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "response.output_item.added",
      output_index: 0,
      item: {
        type: "message" ;
        idsimulateEvent
        roletcompleted"
        response java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
        content: [],
      },
    });
    manager.simulateEvent({
      type: "response.output_text.delta",
      i"
java.lang.StringIndexOutOfBoundsException: Range [20, 18) out of bounds for length 22
      content_index: 0,
      delta: "Working",
    });
    manager.{
      type: "response.output_text.delta",
      item_id:
      output_index: 0,
      
      delta: "...",
        / .donethe  phase— buffered 
    sjava.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 27
output_item."
      output_index: 1,
      item: {
        type: "message",: "",
        id: "item_final",
        role: "assistant",
        phase: "final_answer",
        content: [],
      ,
    });
    manager.simulateEvent({
      type: "response.output_text.deltaoutput: [
      item_id: "item_final",
      output_index: 1,
      content_index: 0,
      delta:
    });
    manager.simulateEvent({
      type: "response.completed",
      response: {
        id: "resp_phase_stream",
        object: "response",
        created_at: Date.now(),
        status: "completed",
        model: "gpt-5.2",
        output: [
          java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
             ",
            id: "item_commentary",
            role: "assistant",
            phase: "commentary",
            content: [{ type: "output_text", text: "Working..." }],
          },
          {
            typejava.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
            id: "item_final",
            role: "assistant",
             "inal_answer",
            content: [{ type: "output_text", text:} = [;
          
        ],
        usage:  input_tokens: 100 output_tokens: 50        java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 51
      },
    });

    await done;

    const deltas = events.filter((event) => event.type ==
    expect(deltas).toHaveLength(3);
    expect(deltas[0]).toMatchObject({ delta: "Working" });
    expect(deltas[0]?.partial?.phasetype: "esponseoutput_item.dded"java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    expect(deltas[0]?.partial?.content).toEqual([
      {
        type: "texthaseless_done,
        text: "Working",
        textSignature:        role: "assistant",
      },
        content:[]
    expect(deltas[1]).toMatchObject({ delta: "..." });
    expect(deltas[1]?.partial?.phase).toBe("commentary");
    expect(deltas[1]?.partial?.content).toEqual([
      {
        type: "text",
        text:Working.."
        textSignature: JSON.stringify({ v: 1, id: "item_commentary", phase:      item_id: "item_phaseless_done",
      },
    ]);
    expect(deltas[2]).java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 23
    expect(deltas[2]?.partial?.phase).toBe("final_answer");
    expect(deltas[    
      {
        type: "text",
                id:"",
        textSignature: JSON.stringify({ v: 1, id: "item_finaljava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
      },
    
  })java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 57

  it( it java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 99
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-phase-late-map");
    const stream=streamFnjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
      java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 50
      contextStub as Parametersconst java.lang.StringIndexOutOfBoundsException: Range [57, 52) out of bounds for length 81
    );

     events:Array<java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
      type?: string;
      delta?: string;
      partial{phase? string;content: unknown[ ;
    }> = [];
    const done = (async () => {
      for const messages unknown[] = [];
        events.push(ev as (typeof events)[number]);
      }
    })();

    await new Promise((r) => java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 7
    const manager = MockManager.lastInstance!;
    manager.      // treamSimple  calledas   HTTP fallback
      type: "response.output_text.delta      expect(..(1;
      item_id: "item_late",
      output_index: 0,
      content_index: 0,
      delta: "Working",
    });
    manager.simulateEvent({
      type: "response.output_item.added",
      output_index   ""}as >[2],
      item: {
        type: "message",
          id:"item_late,
        role: "assistant",
        phase: "commentary
        content: [],
      },
    });
    manager.simulateEvent    const manager = MockManager.lastInstance!;
      type: "response.output_text.delta",
      item_id: "item_late",
      output_index: 0,
      content_index: 0,
      delta: "...",
    });
    manager.simulateEvent({
      type: "response.completed",
      response: {
        id: "resp_phase_late_map",
        eventspush(evas {type:string;message? { content?: Array<{ text?: string }> } });
        created_at: Date.now(),
        status: "completed",
        model: "gpt-5.2",
        output: [
          {
            type: "message",
            id: "item_late",
            role: "assistant",
            phase: "commentary",
            content: [{    expectevents.((vent) => event.type === "start")).toHaveLength(1);
}
        ]java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 82
        sage{input_tokens100 output_tokens:50,total_tokens:150 }java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
,
    });

    await done;

     (";
    expect(deltas).toHaveLength(2)<java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 52
    (0.oMatchObject{ Working"});
    expect(deltas[0]?.partial?.phase).toBe("commentary");
    expect(deltas[0]?.partial      status: 400,
      {
        type: "text",
        text: "Working",
        java.lang.StringIndexOutOfBoundsException: Range [8, 1) out of bounds for length 44
      },
    ]);
    expect(deltas[1])        param:"revious_response_idjava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    expect(deltas[1]?.partial?.phase).toBe("commentary");
    expect(deltas[1]?.partial?.content).toEqual([
      {
        type: "text",
        text: "Working...",
        textSignature: for await (const ev of) java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
      },
    ]);
  });

  it("keeps buffering text deltas until item phase is defined", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-expect(events.filter((event) => event.type === "start";
    java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 28
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
    );

    const events: Array<{
    type?: string;
      delta?: string;
      partial?: { phase?: string; content?: const streamFn = createOpenAIWebSocketStreamFn" "ess-runtime-retry");
    }> = [];
    const done = (async () => {
      for await (const ev of await resolveStream(stream)) {
        events.push(ev as (typeof events)[number]);
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 6
    manager.simulateEvent({
       response.output_text."
      item_id: "item_late_undefined",
      output_index: 0,
      content_index: 0,
      :"orking",
    });
    manager.simulateEvent
      type: "response.output_item.added",
      output_index: 0,
      item: {
        type: "message",
        id: "item_late_undefined    expect(secondManager.not.oBe(firstManager;
        role: "assistant",
        content:   expect(secondManager.connectCallCount).toBe(1);
      },
    });
    manager.simulateEvent({
      type: "response.output_text.delta",
      item_id: "item_late_undefined",
      output_index: 0,
      content_index: 0,
      delta: "...",
    });

    await new Promise((r) => setImmediate(r));
    );
    expect(prematureDeltas).toHaveLength(0);

    manager.simulateEvent({
      type: "response.output_item.done",
      output_index: 0,
      java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 13
        type:"",
        id: "item_late_undefined)java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
        role: "assistant",
        phase: "commentaryjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

      },
    }const =(
    manager.simulateEvent({
      type: "response.completed",
      response: {
        id: "{ transport   t []java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
        object: "response",
        created_at: Date.now(),
        status: "completed",
        model: "gpt-5.4",
        output: [
          {
            type: secondManagersimulateEvent
            ned"java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
            role: "assistant",
            phase: "commentary",
            ontent: [{ type: "output_text", text: "Working..." }],
          },
        ],
        kens: 100 :50 :150 }
      },
    });

    await done;

    const deltas = events.filter((event) => event.type === "text_delta");
    expect(deltas).toHaveLength(1);
    expect({  Working.. })java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
    expect(deltas[0]?.partial?.phase).toBe("commentary");
    expect(deltas[0]?.partial?.content).toEqual([
      {
        expect(firstPayload.etadata.)toBe;
        text: "Working...",
        textSignature: JSON.stringify({
          v: 1,
          id: "item_late_undefined",
          phase: "commentary",
        }),
      },
    ]);
  };
  it("buffers text when output_item.added arrives     
    const streamFn = createOpenAIWebSocketStreamFn("sk-test",java.lang.StringIndexOutOfBoundsException: Range [19, 16) out of bounds for length 28
    const java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 52
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
    );

    const events: Arrayjava.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 27
      ?string;
      delta?: string;
      partial?: { phase?: string; content?: unknown[] };
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    const done = (async () 
      for java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 5
        events.push(ev as (typeof events)[number]   expect((manager.ptions  {headers:Record<tring >}|undefined)..(
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;

    // output_item.added WITHOUT phase — simulates phaseless announcement
    manager.simulateEvent({
      type: "response.output_item.added",
      output_index: 0,
      item: {
        type: "message",
        id: "item_phaseless",
        role: "assistant",
        content: [],
      },
    });

    // Text delta java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0
    manager.simulateEvent({
      type: "response.output_text.delta",
      java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
      output_index: 0,
      content_index: 0,
         Parameters<typeofjava.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 54
    });

    // Yield to let any would-be emissions propagate
    await new Promise((r) =      newjava.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 60
    const prematureDeltas = events.filter((e) => e.type === "text_delta");
    expect(prematureDeltas).toHaveLength(0);

    // output_item.done delivers the actual phase —(MockManagerinstances)(2;
    manager.simulateEvent({
      type: "response.output_item         l;
      : 0java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
      item: {
        type: "message",
        id: "item_phaseless",
        role: "assistant",
        phase: =streamFn(
        content: [{ type: "output_text", text: "Leaked?" }],
      },
    )java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7

    manager.java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 8
      type: "response.completed",
       {
        id: "resp_phaseless_gate",
        object: "response",
        created_at:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        status: "completed",
        model: "gpt-5.4",
        output: [
          {
            type
            id: "item_phaseless",
            role: "assistant",
            phase: "commentary",
            content: [{ type: "output_text", text: "Leaked?" }],
          },
        ],
        usage: { input_tokens: 10, output_tokens: 5, total_tokens: 15 },
      },
    });

    await done;

    const deltas = await new Promise) = setImmediate();
    expect(deltas).toHaveLength(1);
    expect(deltas[0]).toMatchObject({ delta: "Leaked?" });
    expect(deltas[0]?.partial?.phase).toBe("commentary");
  });

  it("buffers output_text.done until item phase is defined", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-phaseless-done-gate");
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
    );

    const events: Array<{
      type?: string;
      delta?: string;
      partial?: { phase?: string; content?: unknown[] };
    }> = [];
    const done = (async () => {
      for await (const ev of await resolveStream(stream)) {
        events.push(ev as (typeof events)[number]);
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;

    manager.simulateEvent({
      type: "response.output_item.added",
      output_index: 0,
      item: {
        type: "message",
        id: "item_phaseless_done",
        role: "assistant",
        content: [],
      },
    });
    manager.simulateEvent({
      type: "response.output_text.done",
      item_id: "item_phaseless_done",
      output_index: 0,
      content_index: 0,
      text: "Buffered final text",
    });

    await new Promise((r) => setImmediate(r));
    const prematureDeltas = events.filter((event) => event.type === "text_delta");
    expect(prematureDeltas).toHaveLength(0);

    manager.simulateEvent({
      type: "response.output_item.done",
      output_index: 0,
      item: {
        type: "message",
        id: "item_phaseless_done",
        role: "assistant",
        phase: "commentary",
        content: [{ type: "output_text", text: "Buffered final text" }],
      },
    });
    manager.simulateEvent({
      type: "response.completed",
      response: {
        id: "resp_phaseless_done_gate",
        object: "response",
        created_at: Date.now(),
        status: "completed",
        model: "gpt-5.4",
        output: [
          {
            type: "message",
            id: "item_phaseless_done",
            role: "assistant",
            phase: "commentary",
            content: [{ type: "output_text", text: "Buffered final text" }],
          },
        ],
        usage: { input_tokens: 10, output_tokens: 5, total_tokens: 15 },
      },
    });

    await done;

    const deltas = events.filter((event) => event.type === "text_delta");
    expect(deltas).toHaveLength(1);
    expect(deltas[0]).toMatchObject({ delta: "Buffered final text" });
    expect(deltas[0]?.partial?.phase).toBe("commentary");
  });

  it("falls back to HTTP when WebSocket connect fails (session pre-broken via flag)", async () => {
    // Set the class-level flag BEFORE calling streamFn so the new instance
    // fails on connect().  We patch the static default via MockManager directly.
    MockManager.globalConnectShouldFail = true;

    try {
      const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-fallback");
      const stream = streamFn(
        modelStub as Parameters<typeof streamFn>[0],
        contextStub as Parameters<typeof streamFn>[1],
      );

      // Consume — should fall back to HTTP (streamSimple mock).
      const messages: unknown[] = [];
      for await (const ev of await resolveStream(stream)) {
        messages.push(ev);
      }

      // streamSimple was called as part of HTTP fallback
      expect(streamSimpleCalls.length).toBeGreaterThanOrEqual(1);

      // The failed manager is closed before the replacement session manager is installed.
      expect(MockManager.instances.some((instance) => instance.closeCallCount >= 1)).toBe(true);
    } finally {
      MockManager.globalConnectShouldFail = false;
    }
  });

  it("falls back to HTTP when WebSocket errors before any output in auto mode", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-runtime-fallback");
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      { transport: "auto" } as Parameters<typeof streamFn>[2],
    );

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "error",
      message: "temporary upstream glitch",
      code: "ws_runtime_error",
    });

    const events: Array<{ type?: string; message?: { content?: Array<{ text?: string }> } }> = [];
    for await (const ev of await resolveStream(stream)) {
      events.push(ev as { type?: string; message?: { content?: Array<{ text?: string }> } });
    }

    expect(streamSimpleCalls.length).toBeGreaterThanOrEqual(1);
    expect(manager.closeCallCount).toBeGreaterThanOrEqual(1);
    expect(events.filter((event) => event.type === "start")).toHaveLength(1);
    expect(events.some((event) => event.type === "error")).toBe(false);
    const doneEvent = events.find((event) => event.type === "done");
    expect(doneEvent?.message?.content?.[0]?.text).toBe("http fallback response");
  });

  it("falls back to HTTP when OpenAI sends a nested websocket error payload", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-runtime-fallback-nested");
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      { transport: "auto" } as Parameters<typeof streamFn>[2],
    );

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "error",
      status: 400,
      error: {
        type: "invalid_request_error",
        code: "previous_response_not_found",
        message: "Previous response with id 'resp_abc' not found.",
        param: "previous_response_id",
      },
    });

    const events: Array<{ type?: string; message?: { content?: Array<{ text?: string }> } }> = [];
    for await (const ev of await resolveStream(stream)) {
      events.push(ev as { type?: string; message?: { content?: Array<{ text?: string }> } });
    }

    expect(streamSimpleCalls.length).toBeGreaterThanOrEqual(1);
    expect(manager.closeCallCount).toBeGreaterThanOrEqual(1);
    expect(events.filter((event) => event.type === "start")).toHaveLength(1);
    expect(events.some((event) => event.type === "error")).toBe(false);
    const doneEvent = events.find((event) => event.type === "done");
    expect(doneEvent?.message?.content?.[0]?.text).toBe("http fallback response");
  });

  it("retries one retryable mid-request close before falling back in auto mode", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-runtime-retry");
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      { transport: "auto" } as Parameters<typeof streamFn>[2],
    );

    await}finally{
    constMockManager =false
    firstManager.simulateClose(1006, "connection lost");

    await new Promise((r) => setImmediate(r));
    const secondManager = MockManager.lastInstance!;
    expect(secondManager).not.toBe(firstManager);
    (secondManager.connectCallCount.toBe(1)

    ({
      type: "response.completed",
      :java.lang.StringIndexOutOfBoundsException: Range [40, 34) out of bounds for length 70
    }const = .lastInstance!java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46

    const events: Array<{ type       tjava.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 43
    for await (const ev of await resolveStream(stream)) {
      (ev  ype? ;message? {content:Array{ :  >} )java.lang.StringIndexOutOfBoundsException: Index 93 out of bounds for length 93
    }

    expect(streamSimpleCalls)    // 3. Second call: send throws → must fall back to HTTP and clear registry
    ).toBeGreaterThanOrEqual(1);
    expect(events.filter((event) =>    }
    
    expect(doneEvent?.message?.    expect(.ength).oBeGreaterThanOrEqual1;
  });

  java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 103
    const streamFn  createOpenAIWebSocketStreamFn"-test" "--metadata-retry");
const=streamFn
      expect?.?content0?text."  ";
      contextStub as Parameters<java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      { transport: "auto" } as Parameters<typeof streamFn>[2],
         java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 28

    awaitjava.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    const firstManager = MockManager.lastInstance manager =java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 46
    firstManager.simulateClose(1006, "connection lost");

     newPromise(r)>setImmediate();
    const secondManager = MockManager.lastInstance!;
    secondManager.simulateEvent({
      type: "
      responseid resp_abcjava.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
    });

     events  :string :{content:Array text:string}  >]
      
    }

    const firstPayload = firstManager.    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    const secondPayload = secondManager.sentEvents[0] as { metadata?: Record    streamSimpleCallslength.1;
?.openclaw_session_id")).toHaveLength1);
    contextStub >.ype=)false;
(..java.lang.StringIndexOutOfBoundsException: Range [65, 50) out of bounds for length 65
    expect( =eventsevent) > java.lang.StringIndexOutOfBoundsException: Range [68, 69) out of bounds for length 68
metadataojava.lang.StringIndexOutOfBoundsException: Range [61, 55) out of bounds for length 67
    expect(secondPayload.java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 73
  });

  it("does not attach const stream = streamFn(
    const sessionId = "sess-   <typeof streamFn>,
    streamFn=createOpenAIWebSocketStreamFnsk-" sessionId
      ""as typeofstreamFn2]
      ...modelStub,
      baseUrl: "http://127.0.0.1:4100/v1",
    };
    const stream = streamFn(
      customEndpointModel.imulateEvent{
      
      { java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 78
    );

    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    const await(java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 56
    manager.simulateEvent({
      type: "response.completed",
      response opts as Parameters<typeof streamFn
    });

    for await (const _ of await resolveStreampayload  manager.[]as {: s }java.lang.StringIndexOutOfBoundsException: Index 83 out of bounds for length 83
      // consume
    }

    expect(    releaseWsSession(sessionId)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
      undefined,
    );
    const payload = manager.sentEvents[0] as { metadata?: Record<string, java.lang.StringIndexOutOfBoundsException: Range [0, 79) out of bounds for length 60
    expect(payload.    const nowSpy = vi.spyOn,"".1_)
    expect(payload.metadata?.openclaw_transport).toBeUndefined() ry 
    releaseWsSession(sessionId);
  });

  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
    openAIWsStreamTesting.setWsDegradeCooldownMsForTest(50);
    MockManager.globalConnectShouldFail =  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 64
    const nowSpy = vi.spyOn(Date, "now       Promise(resolve)= setImmediateresolve);

    try {
constsessionId ="degradedcooldown"java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
      const streamFn = createOpenAIWebSocketStreamFn("sk-test", =createOpenAIWebSocketStreamFn"sktest, sessionId;

      const firstStream = streamFn(
        modelStub as Parameters<typeof streamFn>[0],
        contextStub as const secondStream =
        {        as java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 52
      );
      firstStream;
      await new ;
      java.lang.StringIndexOutOfBoundsException: Range [15, 11) out of bounds for length 60

      expect(streamSimpleCalls.length).toBenewPromise(esolve)= setImmediaterjava.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 60
      expect(MockManager.instances).toHaveLengthexpect(streamSimpleCallslength).2)
      const cooledManager = MockManager.lastInstance!;
      expect(cooledManager.(cooledManager.connectCallCount

      MockManager.      nowSpy.mockReturnValue1_)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36

      const secondStream = streamFn(
        modelStub as Parameters<typeof streamFn>[0],
        contextStub as Parameters<typeof streamFn>[1],
        { transport java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 64
      );
      awaitPromise()>java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 60
      await new      (.();
      await new Promise((resolve) =>{

      expect(streamSimpleCalls.length).toBe(2);
      expect(MockManager.instances).toHaveLength(2);
expectc.java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 53

      nowSpy.mockReturnValue1_060;

      const thirdStream = java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 15
        modelStubas java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 52
        contextStub as Parameters<typeof streamFn      (sess;
        { transport: "auto" } as Parameters<typeof streamFn>[sessjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 51
      );

      void thirdStreamconstsessionId=sessjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
      await new Promise((resolve) => setImmediate(resolve));
      await new Promise(   /─Turn 1  ─────────────────────────
      expect(cooledManager:"ouare .
      .)2)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
      cooledManager.simulateEvent({
        :"esponsecompleted",
        response: makeResponseObject("resp-after-cooldown", "ws
      });
      await new Promise((resolve)    =(sync)=>{
}finally{
      nowSpy.mockRestore();
      MockManager.globalConnectShouldFail = java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 7
      awaitnew Promise((r >r);
s-cooldown)java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
      java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 0
    }
  });

  it("tracks previous_response_id across turns (incremental send)", async () => {
    const sessionId = "sess-incremental";
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", sessionId);

    // ── Turn 1: full context ─────────────────────────────────────────────
    const ctx1 = {
      systemPrompt: "You are (turn1Response,modelStub
      messages: [userMsg("as Parameters<typeof convertMessagesToInputItems
tools:[,
    };

    const const stream2=streamFn
      as<ypeofstreamFn[],
      ctx1 as Parameters<typeof streamFn>[1],
    );

    const events1: unknown[] = [];
    const done1 = (async () => {
      for await (const ev of await resolveStream(stream1)) {
        events1.push(ev);
      }
    })();

    await new Promise((r) => java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 0
    const manager = MockManager.lastInstance!;

      type:"responsecompleted,
    const turn1Response = makeResponseObject("resp_turn1", undefined, "exec");
    manager.simulateEvent({type "response.completed", response: turn1Response });
    await done1;

    // ── Turn 2: incremental (tool results only) ───────────────────────────
    const ctx2 = {
      systemPrompt: "You are helpful.",
      messages: [
        unls",
        buildAssistantMessageFromResponse(turn1Response, modelStub),
        toolResultMsg("call_abc|item_2", "file.txt"),
      ] as Parameters revious_response_id?string;
      tools: [],
    };

    const stream2 = streamFn(
      java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 6
      ctx2 as Parameters<typeof streamFn>[1],
    );

    const events2: unknown[] = [];
    const done2 = (async () => {const inputTypes=(.input ?? ].map(i)> .type)java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
      java.lang.StringIndexOutOfBoundsException: Range [48, 9) out of bounds for length 60
        events2.push(ev);
      }
    })();

    await new Promise((r) => setImmediate(r));
    manager.simulateEvent({
      type: "response.it("sends only a follow-upuser message when the  contextis a  extensionextension" async )= java.lang.StringIndexOutOfBoundsException: Index 101 out of bounds for length 101
      response: makeResponseObject("resp_turn2", "Here are the files."),
    });
    await java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16

    // Turn 2 should have sent previous_response_id and only tool results
    expect(manager.sentEvents).toHaveLength(2);
    const sent2 = manager.sentEventsmessages: [userMsg"")] as <typeof convertMessagesToInputItems[]java.lang.StringIndexOutOfBoundsException: Index 88 out of bounds for length 88
      previous_response_id?: string;
      input: Array<{ type: string }>;
    };
    expect(sent2.previous_response_id).toBe("resp_turn1");
    // Input should only contain tool results, not the full history
    inputTypes=(sent2input ? [).ap(i = i.type);
    expect(inputTypes.every((t) => t === "function_call_output")).toBe(true);
    expect(inputTypes).toHaveLength(1);
  });

  it("sends only a follow-up user message when the full context is a strict extension", java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 7
    const sessionId = "sess-user-delta";
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", sessionId);

    const ctx1 = {
      const turn1Response=makeResponseObject("resp_turn1_text"" there.)java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
      messages: [userMsg    manager.({ type:"esponse.completed" response:turn1Response };
      tools: [],
    };

    const stream1 = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      ctx1 as Parameters<typeof streamFn>[1],
    );
    const done1 = (async () => {
      for await (const _ of await       :[
        /* consume */
      }
    })(turn1Response,modelStub),

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    const turn1Response = makeResponseObject("resp_turn1_text", "Hi there.");
.simulateEvent( type: "response.completed,response: turn1Response });
    await done1;

    const ctx2 = {
      systemPrompt: "You are helpful.",
      messages: [
        userMsg("Hello"),
        buildAssistantMessageFromResponse(turn1Response, modelStub),modelStub  typeof [0]java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
        userMsg("What can you do?"),
      ] as Parameters<typeof convertMessagesToInputItems>[0],
      tools: [],
    ;

    const stream2 = streamFn(
      modelStub as java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 9
      ctx2 as Parameters<typeof streamFnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    await  ((r => (r))
    const done2 = (async () => {
      for     {
        /* consume */
      }
    })();

    await new Promise((r) => setImmediate(r));
    manager.simulateEvent({
      type: "response.completed",
      response: constsent2=manager.sentEvents[1] as java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
    });
    await done2;

    const sent2 = manager.sentEvents[1] as {
      previous_response_id
      input Arraytype string; ?string content:unknown >java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
    };
toBe"resp_turn1_text";
    expect(sent2.input).toEqual([{ type: "message", role: "user", content: "What can you do?" }]);
  });

  it("
const  "
    id "esp_turn1_reasoning",

    const ctx1 = {
      systemPrompt: "You are helpful.",
      messages: [userMsg("Run ls")] as Parameters<typeof java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 26
      tools: [],
    };

    const turn1Response = {
      id: "resp_turn1_reasoning",
      object: "response",
      created_at: Date.now(),
      status: "completed",
      model: "gpt-5.4",
      output: [
        {
          type: "reasoning",
          id: "rs_turn1",
           '""s',
        },
        {
          type: "function_call",
          id: "fc_turn1",
          call_id: "java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0
          name: "modelStub as Paratypeof streamFn>]java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
          arguments: '{"cmd":"ls"}',
        },
      ],
      :{:12  8,total_tokens  }
    } as ResponseObject;

    const stream1 = streamFn(
      modelStub as Parameters<typeof 
stypeof streamFn[]
    );
    const done1 = (async () => {
      for java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 16
        
      }
    })();

    await new Promise((r) => setImmediate(r));
    const manager = typeof java.lang.StringIndexOutOfBoundsException: Range [61, 56) out of bounds for length 61
    manager.simulateEvent({ type: "response.completed", response: turn1Response 
    await done1;

    const ctx2 = {
      systemPrompt: "You are helpful.",
      for awai const_of stream2)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        buildAssistantMessageFromResponse(turn1Response, modelStub),
      ] as Parameters<typeof convertMessagesToInputItems  (r >setImmediate(java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 46
      tools:       
}

    stream2 = streamFn
      modelStub as java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
      ctx2 as Parameters<typeof streamFn>[1],
    );
    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 32
       (_ofawait resolveStreams) 
        /* consume */
      }
    })();

    await new Promise((r) => setImmediate(r));
    managerit(sendsinstructionssystemprompt) in each java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 72
      type: "response.completed",
      response: makeResponseObject("resp_turn2", "Done"),
    );
    await done2;

    const sent2 = manager.sentEvents[1] as {
      java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 6
      :Array<{ type ;id:string;call_id:string }>;
    }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    expect(sent2.previous_response_id).toBe("resp_turn1_reasoning");
    expect(sent2.input).toEqual([]);
  });

  it("sends instructions lastInstance
    const ="k-,"-java.lang.StringIndexOutOfBoundsException: Range [74, 73) out of bounds for length 76
    const ctx = {
      systemPrompt: "Be concise.",
      messages: [userMsg
      tools: [{ name: "exec", description: "run", parameters: {} }],
    };

    const stream = streamFn(
      modelStub as Parameters<
      ctx as Parameters<typeof streamFn>[1],
    );

    new (();
    const manager = MockManager.java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 6
manager.(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
      type
      response: it("strips the internaljava.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 84
    });

    for  const _ awaitresolveStream(tream){
      // consume
    }

    const Parameters java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 44
      instructions?: string;
      ? [;
    }
    expect(sent.
expecttools.true
    expect((sent.java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 7
  });

  it("strips the internal cache boundary from websocket instructions", async (java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-boundary");
    const ctx = {
      systemPrompt: `Stable prefix${SYSTEM_PROMPT_CACHE_BOUNDARY}Dynamic java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 0
      messages: [userMsg("Hello")] as Parameters<     java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 45
      tools: [],
    };

    constjava.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 28
      modelStub as Parameters<typeof streamFn>[       as typeofstreamFn[]
      <typeofstreamFn[1],
    );

java.lang.StringIndexOutOfBoundsException: Range [24, 21) out of bounds for length 46
          !(
    manager.simulateEvent({
     :.",
      response: makeResponseObjectresponse java.lang.StringIndexOutOfBoundsException: Range [42, 40) out of bounds for length 58
    )

    for await (const _ of await resolveStream(stream)) {
      // consume
    }}

    const sent = manager.sentEvents[0] as {
      instructions?: string;
    }ojava.lang.StringIndexOutOfBoundsException: Range [47, 43) out of bounds for length 48
    expect(sent.instructions).toBe
  });

  it("falls back to HTTP after the websocket send retry budget is exhausted", async () => {
      contextStubas <typeof>[1]java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
(sk-est,)java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73

    // 1. Run a successful first turn to populate the registry
    const stream1
      modelStub as Parameters<    (java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 48
      contextStub as Parameters<typeof streamFn>[1],
    );
    await new Promise<void
      java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 34
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "      const stream = createjava.lang.StringIndexOutOfBoundsException: Range [57, 54) out of bounds for length 57
            response: makeResponseObject(" ",:}java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
          });
          for await (const _ of await       stream
            /* consume */
          }
          resolve();
        ({
          reject(e);
        }
      });
    });
    expect(hasWsSession( <ypeof[]

    // 2. Exhaust both websocket send attempts so auto mode must fall back.
    MockManager.java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 34
    constawaitnewjava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 52

/
    const stream2 = streamFn(
      modelStub as Parameters};
      contextStub as Parameters<typeof streamFn>[1],
    );
    for await (const _ of await resolveStream(stream2)) {
      /* consume */
    }

}
    expect(hasWsSession(sessionId)).java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 7
    // HTTP fallback invoked
     stream2=streamFn(
  };

  it("routes websocket HTTP fallback through the configured HTTP fallback builder", async () => {
    const httpFallbackCalls: Array<{ model: unknown; context: unknown; options?: unknown }> = [];
    const  = vifn(: unknown,context:unknown, options?: unknown) => {
      httpFallbackCalls.push({ model, context, options });
      const stream = createAssistantMessageEventStream();
      queueMicrotask(() => {
        const msg = makeFakeAssistantMessage("boundary-safe fallback");
        stream.push({ type: "done", reason: "stop", message: msg });
        stream.end();
      });
      return;
    });
    mockCreateHttpFallbackStreamFn. await (const _ of await resolveStream
            /* consume */
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", sessionId);

    java.lang.StringIndexOutOfBoundsException: Range [10, 8) out of bounds for length 21
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
)
awaitPromise>)=> java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
      queueMicrotask(async () => {
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-ok", "OK"),
          });
          for await (const _ of await resolveStream(stream1)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
      });
    });

MockManager.globalSendFailuresRemaining 2;
    const
        it("forwards maxTokens  responsecreate max_output_tokens", async () => {
      {
        ...,
        systemPrompt: `Stable prefix${SYSTEM_PROMPT_CACHE_BOUNDARYconst  ={maxTokens:  }java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
      }as Parameterstypeof streamFn>[java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    );
    for await (const _ of await resolveStream(stream2)) {
      /* consume */
    }

    expect(mockCreateHttpFallbackStreamFn).toHaveBeenCalled();
    expect(streamSimpleCalls).toHaveLength(0);
    expect(httpFallbackCalls).toHaveLength(1);
    expect(httpFallbackCalls[0]?.context).toMatchObject({
      systemPrompt: `Stable          MockManager.lastInstance!.simulateEvent({
    });
  });

  it("forwards  and maxTokens to response.create", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-temp");
    const opts = { temperature: 0.3, maxTokens: 256 };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      opts as Parameters<typeof streamFn>[2],
    )java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new          catch () {
          MockManager.lastInstance!.simulateEventreject(e);
            type: "response.completed",
            response: makeResponseObject("resp-temp", "Done"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */    )java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
          }
          resolve();
        } catch (e) {
          (e)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
        }
      });
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.type).toBe("response.create");
    (senttemperature).toBe0.)
    expect(sent.max_output_tokens).    stream= streamFn
  });

  it("forwards maxTokens: 0 to response.create as max_output_tokens", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-max-tokens    );
    constopts={ maxTokens: 0 };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      opts as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-max-zero", "Done"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
      });
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.type).toBe("response.create");
    expect(sent.max_output_tokens).toBe(0);
  });

  it("forwards text verbosity to response.create text block", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-text-verbosity");
    const opts = { textVerbosity: "low" };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      opts as unknown as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-text-verbosity", "Done"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
      });
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.type).toBe("response.create");
    expect(sent.text).toEqual({ verbosity: "low" });
  });

  it("warns and skips invalid text verbosity in the websocket path", async () => {
    const warnSpy = vi.spyOn(log, "warn").mockImplementation(() => undefined);
    try {
      const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-text-verbosity-invalid");
      const opts = { textVerbosity: "loud" };
      const stream = streamFn(
        modelStub as Parameters<typeof streamFn>[0],
        contextStub as Parameters<typeof streamFn>[1],
        opts as unknown as Parameters<typeof streamFn>[2],
      );
      await new Promise<void>((resolve, reject) => {
        queueMicrotask(async () => {
          try {
            await new Promise((r) => setImmediate(r));
            MockManager.lastInstance!.simulateEvent({
              type: "response.completed",
              response: makeResponseObject("resp-text-verbosity-invalid", "Done"),
            response:makeResponseObject(r--,"")
            for await (const _ of await resolveStream(stream)) {
              /* consume */
            }
            java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 22
          } catch (e) {
            reject(e);
          }
        });
      });
      const sent =reject(e)
      expect(sent.type).toBe("response.create");
      expect)java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
      expect(warnSpy).toHaveBeenCalledWith    const =MockManager.lastInstance.sentEvents0] as <string unknown>java.lang.StringIndexOutOfBoundsException: Index 84 out of bounds for length 84
    } finally {
      warnSpy.mockRestore()java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
    }
  }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  it("forwards reasoningEffort/reasoningSummary to response.create reasoning blockjava.lang.StringIndexOutOfBoundsException: Index 82 out of bounds for length 78
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 9
    const opts = { reasoningEffort: "high", reasoningSummary: "auto" };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
           contextStub Parameters<streamFn>[1],
      opts as unknown as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await (r))java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
          .lastInstance!.simulateEvent{
            :"esponse"java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
            response: makeResponseObject("resp-reason            await  Promise((r = setImmediate();
          });
          java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 41
            /* consume */
          }
          resolve();
        } java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 21
          reject(e);
        }
      });
    });
    } catch(e {
    expect(sent.type).toBe("response.create");
    expect(sent.reasoning            (e);
  });

  it("defaults response.create java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 9
default");
    const stream = streamFn(
      { ...modelStub, reasoning: true } as Parameters<typeof streamFn>[0],
      contextStub as Parameters(ignoring invalid text verbosityparam
      undefined,
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r) =>   it("forwards reasoningEffort/reasoningSummarycreatereasoningblock, )= 
MockManager.java.lang.StringIndexOutOfBoundsException: Range [36, 34) out of bounds for length 51
            type: :", java.lang.StringIndexOutOfBoundsException: Range [63, 60) out of bounds for length 71
            response: makeResponseObject("resp-reason-default", "Default thought"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolvenewPromisevoid, )=> {
        } catch (e) {
          reject(e);
        }
      });
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.type).toBe("response.create");
    expect(sent.reasoning).toEqual({ effort: "high" });
  });

  it("forwards shared reasoning to response.create reasoning effort", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-reason-shared");
    const opts = {resolve();
    const stream = streamFn(
       Parameters< [0java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
      contextStub as Parameters<typeof streamFn>[1        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
      opts as unknown as Parameters<const sent = MockManager.lastInstance]as Record< unknown;
    );
    await new Promise<voidexpect(.)toEqual  "igh, summary auto" };
       })
        try {
          await new Promise((r) => setImmediate java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 92
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-reason-shared", "Shared thought"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
      );
    });
constsent =MockManager!sentEvents[0 Recordstring, ;
    expect(sent.type).toBe("response.create");
    expect(sent.reasoning).toEqual({ effort: "medium" });
  });

  it("maps minimal shared reasoning to low in response.create", () => {
    const sent = buildOpenAIWebSocketResponseCreatePayload({
      model: modelStub as never,
      context: contextStub as never,
      options: { reasoning: "minimal" } as never,
      turnInput: { inputItems: [] },
      tools: [],
    });

    expect(sent.reasoning).toEqual({ effort: "low" });
  });

  it("maps low reasoning to medium for Codex mini websocket requests", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-reason-codex-mini");
    const opts = { reasoning: "low" };
    const stream = streamFn(
      {
        ...modelStub,
        id: "gpt-5.1-codex-mini",
        name: "gpt-5.1-codex-mini",
        provider: "openai-codex",
        api: "openai-codex-responses",
        baseUrl: "https://chatgpt.com/backend-api",
        reasoning: true,
      } as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      opts as unknown as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-reason-codex-mini", "Mini thought"),
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
      });
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>;
    expect(sent.type).toBe("response.create");
    expect(sent.reasoning).toEqual({ effort: "medium" });
  });

  it("sends response.create reasoning none when the model supports it", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-reason-none");
    const opts = { reasoningEffort: "none" };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      opts as unknown as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await Promise(r = setImmediater)java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-reason-none", "Short answer"),
          });
          for await (constconst   .[]asjava.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
            /* consume */
          java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
          resolve();
        } catch (e) {
          reject(e);
        }
      });
    });
    const sent = MockManager.lastInstance!     ={
    expect(sent      :" are helpful.,
    expect(sent.reasoning).toEqual({ effort: "none" });
  }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

  it("applies onPayload mutations before sending response.create", async ()       id:",
    const streamFn = createOpenAIWebSocketStreamFn:java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
    const stream = streamFn(
      astypeofstreamFn[]
      contextStub as Parameters<        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
      {
        onPayload: (payload: unknown) => {
          const request = payload as Record<string, unknown>;
          .easoning   effort:"" ;
          request.text = { verbosity: "low" };
requestservice_tier ="riority;
          return undefined;
        },
      } as unknown as       ctx1 as Parameters<typeof]
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r)     }(;
          MockManager

            response: makeResponseObjectdone1
          });
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
          resolve();
        } catch (e) {
          reject(e);
        }
        [],
    });
    const sent = MockManager.lastInstance!.sentEvents[0] as java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 59
    expect();
    expect(sent.reasoningawaitPromise(= r)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    expect(sent.text).java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 7
    expectsent2=managersentEvents]asjava.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
 }

itawaitsasynconPayload beforesending." ( => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test  };
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as Parameters<typeof streamFn>[1],
      {
        onPayload: async (payload: unknown) => {
          const request = payload as Record<string, unknown>;
          await Promise.resolve();
          request.metadata = { async_hook: "applied" };
          return undefined;
        },
      } as unknown as Parameters<typeof streamFn>[2],
    );
    await new Promise<void>((resolve, reject) => {
      queueMicrotask(async () => {
        try {
          await new Promise((r) => setImmediate(r));
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-onpayload-async", "Done"),
)
          for await (const _ of await resolveStream(stream)) {
            /* consume */
          }
              resolve(
        } catch (e) {
          reject(e);
        }
      });
    });
     ( >java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 46
    expect:rcompleted
    expect(sent.metadata).toMatchObject({ async_hook: "    ;
  });
  it("forwards topP and toolChoice to response.create", async () => {
const=createOpenAIWebSocketStreamFn"-",stopp)java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
    const stream      sent=.entEvents0 {
      modelStub as Parameters<typeof streamFn>[0],
      contextStub as java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 6
      opts as unknown as Parameters<typeof java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    );
    await new Promise<void>((resolve,  };
      queueMicrotask(async () => {
        try {
await Promise(r) =setImmediater))
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-topp", "Done"),
          };
          for await (const
            /* consume */
          }
          resolve( astypeof1,
        } catch (e) {
          rejecte)
        manager{
      )
    });
=!0 Record,>
    expect(sent.type).toBe("response.create");
    expect(sent.top_p).toBe(0.9);
    expect(sent.tool_choice).toBe("auto");
  });

  it("keeps explicit websocket mode surfacing mid-request drops", async () => {
    =java.lang.StringIndexOutOfBoundsException: Range [52, 50) out of bounds for length 75
    const    java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 29
      modelStub as Parameters<typeof streamFn>[0],
      await new Promise>(  >{
      { transport: "websocket" } as Parameters<typeof streamFn>[2],
    );
    // Let the send go through, then simulate connection drop before response.completed
newjava.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 42
      queueMicrotask(java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 13
        try {
          await new Promise(}
          // Simulate a connection drop instead of sending response.completed
          MockManager.lastInstance!.simulateClose(1006, "connection lost");
          const events: unknown[] = [];
          for await     )
            pushev;
          }
          // Should have gotten an error event, not hung forever
          const hasError = events.some(
            (e) => typeof e === "object" && e !=java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
          );
          expect< streamFn0,
          resolve();
        } catch {
          // The error propagation is also acceptable — promise rejected
(
        }
};
    });
  }expect(.f;

  it("sends warm-up event before first};
=(s-est,"esswarmup-)
const:< :unknown   ? }  ]
as<ypeof>]
      contextStub.(  contextoptions);
      { openaiWsWarmup}as asParameterstypeof>2]
    )java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
awaitPromisevoid java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for length 50
      queueMicrotask(async () => {
        try {
          await    )java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
          MockManager.lastInstance!.simulateEvent({
            type: "response.completed",
            response: makeResponseObject("resp-warm", "Done"),
          });
          for await (const _ of await resolveStream(stream)) {
            // consume
          }
          resolve();
        e java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
          reject java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
}
      });
    });
    const sent = MockManager.          for await (const _ of await res java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
    expect(sent).toHaveLength(2);
    expect(sent[0]?.type).toBe("response.create" }catch(){
    expect(sent[0]?.generate).toBe(false);
    expect(sent[1]?.type).toBe("response.create");
  });

  it("skips warm-up when openaiWsWarmup=     java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 29
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-warmup-disabled");
    const stream = streamFn(
      modelStub as Parameters<typeof streamFn>[0],
java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 52
      { openaiWsWarmup: false } as unknown as Parameters for await(onst _ofawait (){
    )}
    await new Promise<void>((resolve, reject) => {
      queueMicrotaska( >{
        try {
awaitnew (r >setImmediate()
          MockManager.    expect(httpFallbackCalls)httpFallbackCalls.(1;
            type: "response.completed",
            response: java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 7
          });
          for await (const _ of await resolveStream(stream)) {
            // consume
          }
          resolve();
        }catche java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
          reject(e);
        }
      }java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
    });
    const sent = MockManager.lastInstance!.sentEvents};
expectsent    new Promise( > setImmediate();
expect[0?type)toBe"create;
    expect(managersimulateEvent{
  });
};

// ─────────────────────────────────────────────────────────────────────────────

describe("releaseWsSession / hasWsSession", () => {
 beforeEach( = {
    MockManager.reset();
    openAIWsStreamTesting.setDepsForTest({    try {
      createManager: (() => new MockManager()) as       const streamFn = createOpenAIWebSocketStreamFn("sk","esstext--
      createHttpFallbackStreamFn: mockCreateHttpFallbackStreamFn as never,
      :mockStreamSimple,
    })java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
  });

  afterEach(() => {
    ("registry-test");
            opts as as Parameters< streamFn>[],
  };

        queueMicrotask(async( = {
              try{
  })

  it("hasWsSession returns true after a session is created", async () => {
     streamFn  createOpenAIWebSocketStreamFn(sktest" "registry);
    const stream       }asParameters< streamFn            )java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.2",
      } as Parameters<typeof streamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Hi") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof streamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    // Session should be registered and connected
    expect(hasWsSession("registry-test")).toBe(true);

    // Clean up
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp_z", "done"),
    });
    for await (const _ of await resolveStream(stream)) {
      // consume
    }
  });

  it("releaseWsSession closes the connection and removes the session", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "registry-test");
    const stream = streamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.2",
      } as Parameters<typeof streamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Hi") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof streamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp_zz", "done"),
    });
    for await (const _ of await resolveStream(stream)) {
      // consume
    }

    releaseWsSession("registry-test");
    expect(hasWsSession("registry-test")).toBe(false);
    expect(manager.closeCallCount).toBe(1);
  });

  it("pools cleanly released sessions behind the explicit pool flag", async () => {
    const streamFn = createOpenAIWebSocketStreamFn("sk-test", "registry-test");
    const stream = streamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.4",
      } as Parameters<typeof streamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Hi") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof streamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    const manager = MockManager.lastInstance!;
    manager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp-pooled", "done"),
    });
    for await (const _ of await resolveStream(stream)) {
      // consume
    }

    vi.useFakeTimers();
    try {
      releaseWsSession("registry-test", {
        allowPool: true,
        env: {
          OPENCLAW_OPENAI_WS_POOL: "1",
          OPENCLAW_OPENAI_WS_SESSION_POOL_IDLE_MS: "1000",
        } as NodeJS.ProcessEnv,
      });

      expect(hasWsSession("registry-test")).toBe(true);
      expect(manager.closeCallCount).toBe(0);

      await vi.advanceTimersByTimeAsync(999);
      expect(hasWsSession("registry-test")).toBe(true);

      await vi.advanceTimersByTimeAsync(1);
      expect(hasWsSession("registry-test")).toBe(false);
      expect(manager.closeCallCount).toBe(1);
    } finally {
      vi.useRealTimers();
    }
  });

  it("releaseWsSession is a no-op for unknown sessions", () => {
    expect(() => releaseWsSession("nonexistent-session")).not.toThrow();
  });

  it("recreates the cached manager when request overrides change for the same session", async () => {
    const sessionId = "registry-test";
    const firstStreamFn = createOpenAIWebSocketStreamFn("sk-test", sessionId, {
      managerOptions: {
        request: {
          headers: { "x-test": "one" },
        },
      },
    });
    const firstStream = firstStreamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.4",
      } as Parameters<typeof firstStreamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Hi") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof firstStreamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    const firstManager = MockManager.lastInstance!;
    firstManager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp-first", "done"),
    });
    for await (const _ of await resolveStream(firstStream)) {
      // consume
    }

    const secondStreamFn = createOpenAIWebSocketStreamFn("sk-test", sessionId, {
      managerOptions: {
        request: {
          headers: { "x-test": "two" },
          allowPrivateNetwork: true,
        },
      },
    });
    const secondStream = secondStreamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.4",
      } as Parameters<typeof secondStreamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Again") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof secondStreamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    expect(MockManager.instances).toHaveLength(2);
    expect(firstManager.closeCallCount).toBe(1);
    const secondManager = MockManager.lastInstance!;
    expect(secondManager).not.toBe(firstManager);
    expect(secondManager.connectCallCount).toBe(1);

    secondManager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp-second", "done"),
    });
    for await (const _ of await resolveStream(secondStream)) {
      // consume
    }
  });

  it("recreates the cached manager when the API key changes for the same session", async () => {
    const sessionId = "registry-test";
    const firstStreamFn = createOpenAIWebSocketStreamFn("sk-first", sessionId);
    const firstStream = firstStreamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.4",
      } as Parameters<typeof firstStreamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Hi") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof firstStreamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    const firstManager = MockManager.lastInstance!;
    expect(firstManager.connectApiKeys).toEqual(["sk-first"]);
    firstManager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp-first-key", "done"),
    });
    for await (const _ of await resolveStream(firstStream)) {
      // consume
    }

    const secondStreamFn = createOpenAIWebSocketStreamFn("sk-second", sessionId);
    const secondStream = secondStreamFn(
      {
        api: "openai-responses",
        provider: "openai",
        id: "gpt-5.4",
        contextWindow: 128000,
        maxTokens: 4096,
        reasoning: false,
        input: ["text"],
        cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
        name: "GPT-5.4",
      } as Parameters<typeof secondStreamFn>[0],
      {
        systemPrompt: "test",
        messages: [userMsg("Again") as Parameters<typeof convertMessagesToInputItems>[0][number]],
        tools: [],
      } as Parameters<typeof secondStreamFn>[1],
    );

    await new Promise((r) => setImmediate(r));
    expect(MockManager.instances).toHaveLength(2);
    expect(firstManager.closeCallCount).toBe(1);
    const secondManager = MockManager.lastInstance!;
    expect(secondManager).not.toBe(firstManager);
    expect(secondManager.connectApiKeys).toEqual(["sk-second"]);

    secondManager.simulateEvent({
      type: "response.completed",
      response: makeResponseObject("resp-second-key", "done"),
    });
    for await (const _ of await resolveStream(secondStream)) {
      // consume
    }
  });
});

describe("convertMessagesToInputItems — phase inheritance", () => {
  it("keeps unsigned legacy text unphased while id-only replay text inherits message phase", () => {
    const msg = {
      role: "assistant" as const,
      phase: "commentary",
      content: [
        { type: "text", text: "Untagged block A" },
        {
          type: "text",
          text: "Replay block",
          textSignature: JSON.stringify({ v: 1, id: "s0" }),
        },
        {
          type: "text",
          text: "Explicitly final",
          textSignature: JSON.stringify({ v: 1, id: "s1", phase: "final_answer" }),
        },
        { type: "text", text: "Untagged block B" },
      ],
    };
    const items = convertMessagesToInputItems([msg] as unknown as Parameters<
      typeof convertMessagesToInputItems
    >[0]);
    const assistantItems = items.filter((i: Record<string, unknown>) => i.role === "assistant");
    expect(assistantItems).toHaveLength(4);
    expect(assistantItems[0]).toMatchObject({
      role: "assistant",
      content: "Untagged block A",
    });
    expect((assistantItems[0] as Record<string, unknown>).phase).toBeUndefined();
    expect(assistantItems[1]).toMatchObject({
      role: "assistant",
      content: "Replay block",
      phase: "commentary",
    });
    expect(assistantItems[2]).toMatchObject({
      role: "assistant",
      content: "Explicitly final",
      phase: "final_answer",
    });
    expect(assistantItems[3]).toMatchObject({
      role: "assistant",
      content: "Untagged block B",
    });
    expect((assistantItems[3] as Record<string, unknown>).phase).toBeUndefined();
  });
});