| Quellcodebibliothek Statistik Leitseite products/Sources/formale Sprachen/JAVA/Openclaw/src/agents/ (Openclaw AI Version 22©) Datei vom 26.3.2026 mit Größe 132 kB |
|
Quelle openai-ws-stream.test.ts Sprache: JAVA |
|
|
/** * Unit tests for openai-ws-stream.ts * * Covers: * - Message format converters (convertMessagesToInputItems, convertTools) * - Response → AssistantMessage parser (buildAssistantMessageFromResponse) * - createOpenAIWebSocketStreamFn behaviour (connect, send, receive, fallback) * -Session helpers releaseWsSession */ import "import{,describe,expect t, } from "/java.lang.StringIndexOutOfBoundsException ,describeexpect ,vi from"itest"; import type , import { , import { log } from ".-runner/loggerjs; }from"/-s-.s"java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds f import { __testing as openAIWsStreamTesting, buildAssistantMessageFromResponse, convertMessagesToInputItems, convertTools, createOpenAIWebSocketStreamFn, hasWsSession, planTurnInput, releaseWsSession, } from "./openai-ws-stream.js"; // Mock // ───────────────────────────────────────────────────────────────────────────── import { log } from "./pi-embedded-runner/logger.js"; { } ".system---.js"java.lang.StringIndexOutOfBoundsException: Index 81 out of boun // ───────────────────────────────────────────────────────────────────────────── // Mock OpenAIWebSocketManager // ───────────────────────────────────────────────────────────────────────────── // We mock the entire openai-ws-connection module so no real WebSocket is opened. |java.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for len { const { EventEmitter:]=] import }"/-cachej" // Shared mutable flag so inner class can see itjava.lang.StringIndexOutOfBoundsException sendShouldFailfalse coptions: { private _listeners: AnyFn[] = []; private _java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for le privatethisjava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for private _broken = false; returnlastCloseInfo; sentEvents: unknown = 0 thisc++; closeCallCount = 0; :java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for len // Allow tests to override connect/send behaviour connectShouldFailfalse; java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0 java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0 (; java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 } get java.lang.StringIndexOutOfBoundsException: Range [33, 31) out of bounds for l _java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for len java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 getjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 ; } async connectdFailuresRemainingjava.lang.StringIndexOutOfBoundsException: Index 4 java.lang.StringIndexOutOfBoundsException: Range [27, 10) out of bounds for leng options java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for len (.onnectShouldFail |_)java.lang.StringIndexOutOfBoundsException: Index 63 out of throw Error" ? ; model? string }| java.lang.StringIndexOutOfBoundsException: Index 95 o }/ events uptwaiting this._connected = java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for leng &!java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46 } ( : if!java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for l throw Errorjava.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds if ( this.broken truejava.lang.StringIndexOutOfBoundsException: Index 26 out of bou >){ _java.lang.StringIndexOutOfBoundsException: Range [36, 30) out of bounds for len java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 throwError" send"; } this.sentEvents.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds const MockManager.lastInstancenulljava.lang.StringIndexOutOfBoundsException: Inde // Auto-complete warm-up events so warm-up-enabled tests don't hang waiting // for the warm-up terminal event. (maybeEvent?type =="response." & maybeEvent.enerate==false){ queueMicrotaskclass TrackedMockManager extends OriginalMockManager { this.simulateEvent({ type:".", response: makeResponseObject(`warmup-${java.lang.StringIndexOutOfBoundsException: }); .astInstance ; } } warmUp(params: { } this type lastInstance | =; generate: false, model: staticinstancesTrackedMockManager ] java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 57 ...(params.instructions ? { instructions: java.lang.StringIndexOutOfBoundsException: }java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 onMessage(handler: globalSendFailuresRemaining this._globalSendFailuresRemaining; returnstaticreset( java.lang.StringIndexOutOfBoundsException: Index 26 out of bou = this_filter(l > != )java.lang.StringIndexOutOfBoundsException: Index 71 out of boun }; } close} .+; this._connected = false; this { MockManager } :1000java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for lengt m(".pluginsruntime., )=>(java.lang.StringIndexOutOfBoundsException: Index 50 out o retryable:falsejava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8 this.// Track if streamSimple/** } /java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66 simulateClose(codestreamSimpleCalls( ,contextoptions}java.lang.StringIndexOutOfBo this_connected =false; this. = { reason, retryable: code == stream.ush{ type createOpenAIWebSocketStreamFn c,send receive fallback) java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 26 code === 1006 codebeforeEach describe,expect,it,vi } from vitest"mport {ResponseObject }from ".openai code const mockCreateHttpFallbackStreamFn .()= as never)java.lang.StringIndexOutOfBou code === 1013, }; this.emit("close", code, reason); } // Test helper: simulate a server event simulateEvent(event: unknown): void { const maybeEvent = event as { type?: string; response?: { id?: string } }; if ( from "/openai-ws-request.s"; s._ = maybeEvent.response.id; } for(onst java.lang.StringIndexOutOfBoundsException: Index 84 out of bounds for le fn(event; } } createOpenAIWebSocketStreamFn<nknown> java.lang.StringIndexOutOfBoundsException: In simulateBroken(:void{ this._connected = false; this.broken= true; } // Test helper: set the previous response ID as if a turn completedplanTurnInput, setPreviousResponseId(id:string): void { this._previousResponseId = id; } static lastInstance: MockManager | java.lang.StringIndexOutOfBoundsException: Index static instances: MockManager[] = []; static reset(): void { type FakeMessage = MockManager.instances=[; } } // Patch constructor to track instances const OriginalMockManager content:unknown[; // ──────────── :"commentary" f" a ConstructorParameters<typeofOriginalMockManager java.lang.StringIndexOutOfBoundsE super(...args); TrackedMockManager. :unknown; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 } :""; instances:TrackedMockManager[ = []java.lang.StringIndexOutOfBoundsException: Index /*lass flagmakeALL new instances fail onconnect) / get (: boolean java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds fo return let } } globalConnectShouldFail(: boolean) { _private _previousResponseId null java.lang.StringIndexOutOfBoundsException: Index } static get globalSendFailuresRemaining(): java.lang.StringIndexOutOfBoundsException nnectCallCount =0 } static setcloseCallCount=0 } staticreset(: java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 3 java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 0 _super; lSendFailuresRemaining =0java.lang.StringIndexOutOfBoundsException: Index 39 out } } :openai, }); vi. model umber reason stringretryable:boolean java.lang.StringIndexOutOfBoundsExcept WebSocketSessionPolicyWithPlugin>undefined, })); // Track if streamSimple (HTTP fallback) was called this} = vi(:java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for lengt streamSimpleCalls retur ( java.lang.StringIndexOutOfBoundsException: Range [9, 1) out of bounds for length stream.push({ typecontent:[ type java.lang.StringIndexOutOfBoundsException: Index 5 .end(; }); stream} }); const mockCreateHttpFallbackStreamFn =const mockCreateHttpFallbackStreamFn tf} // ───────────────────────────────────────────────────────────────────────────── // Helpers // ───────────────────────────────────────────────────────────────────────────── /** Resolve a StreamFn return value (which may be a Promise) to an AsyncIterable. */ function( stream}; ): java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 1 return stream instanceof Promise:stringjava.lang.StringIndexOutOfBoundsException: I } // ───────────────────────────────────────────────────────────────────────────── // Fixtures // ───────────────────────────────────────────────────────────────────────────── type FakeMessagetype: response.reate, :" generate:alse, | { role: "assistant"; content:nknown[ phase?:" :'{arg":"alue"' stopReason: string api: string; provider: return{ model: stringobject response, usage: : .now)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds fo model java.lang.StringIndexOutOfBoundsException: Range [11, 5) out of bounds for } java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for leng | { role: "toolResult"; return () => { toolName: this._list.listeners =this.listeners.(() > l !=handler; content: unknown[]; } ose( void java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for le } function userMsg(// ─────────────────────────────────────────────────────────────────────────────, return } function simulateClose( =1006="onnection lost") { textBlocks: .connected=false toolCalls: it" array code, phase?: "java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for le ): FakeMessage { [ java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 forconstofcode= 1005 | content.ush{type text" text:t )java.lang.StringIndexOutOfBoundsException: Index 44 } for (const =1012 |java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds contentthis("" ,java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3 java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 role: "assistant", content, phase, stopReason: java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for api penairesponsesjava.lang.StringIndexOutOfBoundsException: Index 29 out of boun java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 7 model: " " )= java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length timestamp: 0, }; } toolResultMsg( :string: java.lang.StringIndexOutOfBoundsException: Index 69 out of returnthis_onnected false; role: "oolResult"java.lang.StringIndexOutOfBoundsException: Index 23 out of bound } java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26 :{java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for le isError:false 0, }; } java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for leng java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 roleastInstance=; : { : java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 5 api: " } provider: "openai", model: // Patc totrackinstances {name "list_regions" M; input:10 output: const =convertToolstoolsas Parameters<typeof >0]; cacheRead: 0, : 0, totalTokens: 15ger.lastInstance =thisjava.lang.StringIndexOutOfBoundsException: In : lastInstance = nulljava.lang.StringIndexOutOfBoundsException: Index 58 out of bou }, :", }; } java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 id: string, outputText?: string, toolCallName: string phase?: "commentary" | const =[ : ResponseObject{ const output: ResponseObject["output"] = if(outputText)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds ({ type: } id: "item_1", java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 java.lang.StringIndexOutOfBoundsException: Range [36, 13) out of bounds for leng phase, }); java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 3 if ( ([0]?parameters.({ output.push({ type", id: "item_2", call_id: "call_abc", name: java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length : {"arg":value"', })java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 } return { id, object "esponse"java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds created_at { status:"completed", t54", outputscription i an , usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 // ───────────────────────────────────────────────────────────────────────────── // Test suite // ───────────────────────────────────────────────────────────────────────────── describe("convertTools", () => properties java.lang.StringIndexOutOfBoundsException: itjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for le expect( queueMicrotask(()= { }); it("eturnsempty for tools, () =>{ expect(convertTools , }); it("converts tools to result.push{type:"",reason: stop msg}java.lang.StringIndexOutOf tools=[ { name: "exec", description: action :"tring" : ")java.lang.StringIndexOutOfBoundsException: Index 3 // ──────────────────────────── , }, } java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 expect(=[ { type: "function", name: "exec", description allOf: [{ type: "object", properties: { id: { type: "string" } } }], const=convertToolstoolsunknownas< >0; }); }); it("handles tools without description", () => { java.lang.StringIndexOutOfBoundsException: Range [0, 9) out of bounds for length const result java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for expect(result[]?name).toBe"ing)java.lang.StringIndexOutOfBoundsException: Index }); itjava.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for le const tools = [{ name: "ping"} constresult =( <convertTools]; expect(result[0]?.parameters).toEqual({ , properties:([?java.lang.StringIndexOutOfBoundsException: Range [43, 44) out of b // ─; }); it("injects it(adds tand :]for strict- param tools" )= java.lang.StringIndexOutOfBoundsE [ { name: "name: "ping ]; const result = convertTools(tools :type " |r "; content unknown] :number} role a" expect(result[0]). phase?: "commentary" | "final_a:commentary |"inal_answer" type: "function", name:", description ListAWSregions"java.lang.StringIndexOutOfBoundsException: Index 38 ou eters{ype o,properties:{ , }); }); it"dds | role type functionjava.lang.StringIndexOutOfBoundsException: Index 23 out of bound { :java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19 description: content unknown]; parametersadditionalProperties, }, ]; result = java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for leng expect ); type:"", java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0 "q"]java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length }); }); name read, toolCalls <description:"file"java.lang.StringIndexOutOfBoundsException: Index 33 o { name:"ispatch", description Dispatchan action, parameters: java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for anyOf: [ { type: "object", : {action:{const " } } required: ["action"], } consttc )java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for l { type: "object", properties: { : {const:"" }, text: { type: }, required: ["action", content, }, ], java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 10 java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8 ] model}java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for lengt expect(result[ timestamp:0java.lang.StringIndexOutOfBoundsException: Index 17 out type: java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length properties: { action: { type: "string", enum: ["ping", "echo"] }, : java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for len }, actionjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for leng : java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 19 }); }); (itemstoHaveLength; const tools = [ java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 namereturn{ itionalschema, parameters: { allOf: [{ type: "java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds }, :[ ]; constresult = convertTools(tools as unknown as Parameters<typeof convertTools>[0]); expect :"-., java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 16 }); }); it("java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length const tools = [ { , name: "exec", : "Run :"ser, parameters: { type: "object", content; } ]; functionmakeResponseObject expect(result[0]? , type: }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for lengt propertiesstringjava.lang.StringIndexOutOfBoundsException: Index 24 out of bound }); ; it("adds const const outpu [output" [ tools [ java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 java.lang.StringIndexOutOfBoundsException: Range [22, 12) out of bounds for leng description No role assistantjava.lang.StringIndexOutOfBoundsException: Index 24 ou parameters type: "object",properties: [ as Parameterstypeof[], }, ]; result = java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for leng strict: true, ); expect(result[0]).toEqual({ nction" name:oolCallName arguments: '{"arg":"value"}', parameters: { type: " }; properties: additionalProperties: false, required[, created_at: Datenow()java.lang.StringIndexOutOfBoundsException: Index 27 out of b , }: [] (falls backtostrictfalsefor ]t({ type essage,ole a"content " . ) const tools = [ :"ead", description: "Read file", parameters{ type: "object", : :{ type ""}} additionalProperties: false, } , ]; const=(tools asunknown Parameters >0,java.lang.StringIndexOutOfBoundsException: Inde strict: true, }); it("converts messagewith atoolcall"(= java.lang.StringIndexOutOfBoundsException: In type: "function", name: "read", description: constit" java.lang.StringIndexOutOfBoundsException: Range [26, 25) ou parameters: { type: "object", properties: { path: { type: "string" } }, additionalProperties: false, }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8 strictexpect(extItem.oBeDefined; }); } { name:"", // ───────────────────────────────────────────────────────────────────────────── describe (notjava.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bou it("converts a simple user text ) : ) const items", convertMessagesToInputItems >[0]); )()java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length expect(items[0]).toMatchObject({ type: {id: ) }); it("uses image_url parts for OpenAI ={ role: "user" const {java.lang.StringIndexOutOfBoundsException: Range [21, 10) out o content [ { type: "text", text expect([0?parameters) { type: "image", java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds ], const msg = { }; const ( [msg] as Parameters<typeof java.lang.StringIndexOutOfBoundsException: Index 39 out o { api: "openai-completions", input; ); expect(items).toEqual([ { type: "message", role: "user", :[ { type: "input_text type: "function", {type"mage_url,image_url:: {url: data:image/ng;ase64 }, ], }, ]); }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 it("eeps input_imagertMessagesToInputItems[msg]as unknown Parametersjava.lang.Strin const msg: FakeMessage = { role: "user", content: [{ type: "java.lang.StringIndexOutOfBoundsException: Index 30 out of bound timestamp: 0, }; const items = convertMessagesToInputItems( [ cont:Working . { phase"" ); expect(items).toEqual([ { ", const msg content: [ { type:input_image"java.lang.StringIndexOutOfBoundsException: Index 32 out of boun source: type: t :{ "tring"}java.lang.StringIndexOutOfBoundsException: Index 44 out o , ], } ]); }); it(" :Done" :JSON.stringify{v ,id i,phase final_answer}, typeof convertMessagesToInputItems(java.lang.StringIndexOutOfBoundsException: Ran >[0]); expect(items).toHaveLength(1); expect(items[0]).toMatchObject({ type: "message", role: "java.lang.StringIndexOutOfB }); it("preserves assistant phase on replayed java.lang.StringIndexOutOfBoundsException: const items = java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for assistantMsg(["Working on it."], [], "java.lang.StringIndexOutOfBoundsException: Ind Parameters< convertMessagesToInputItems0 :final_answer"java.lang.StringIndexOutOfBo expect(items).toHaveLength(1 )java.lang.StringIndexOutOfBoundsException: Index 5 - forid-only blocks withphased type: " required: [:[action] role: "assistant", java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 7 phase: "commentary", }); }); it("convertsconditional" constmsg=assistantMsg " me that."] [{ id: , ); const items = convertMessagesToInputItems convertMessagesToInputItems >]java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 function_call const textItem = items.find ) =itemsfind(i)= . stopReason stop, expect(textItem).toBeDefined(); expect(fcItem).it("preserves existing propertie typeobject : "" type: "function_call", call_id: " { name: "exec", }); expect(textItem).not.java.lang.StringIndexOutOfBoundsException: Index 32 out of const] t toEqualjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for le }); java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for leng const msg = assistantMsg( [" )java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 [ id "call_1" name "java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 5 ; const items = convertMessagesToInputItems([ name:"ing"java.lang.StringIndexOutOfBoun typeof convertMessagesToInputItems::" { >[0]); const textItem = items.find((i) => i.type java.lang.StringIndexOutOfBoundsException: In expect} type: "message", role:assistant", content Let { phase: "commentary", }); }); it("preserves assistant java.lang.StringIndexOutOfBoundsException: Range [25, 23) java.lang.StringIndexOutOfBoundsException: Range [18, 18) out of bounds for leng role: java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16 type:name:", text 0 textSignature:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds f } ]typeof java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 8 java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 7 :", model: "gpt-5.4", usage: {}, timestamp: 0, } { type:"message", typeof java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for leng >[0]); expect(items).toHaveLength(1); expect(items[0]).toMatchObject({ type: "message", role]; content: "Working on it.", phase: "commentary", }); }); it("splits describe("convertMessagesToInputItemsrole:"ssistant const const msg = { role: "java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for leng phase: "final_answer typeof convertMessagesToInputItems expect(items.toHaveLength1) { text }, textSignature{ ,: item_commentary , { :"text"asjava.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds text: "Done.", content [ textSignature.( :1, :i",phase final_answer" }) }, ], : "top, -responses, provider: " ]java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for model: "gpt-5.2", usage: {}, timestamp: 0, }; expect( convertMessagesToInputItems([msg] as unknown typeof convertMessagesToInputItems >[ ). ).toEqual( java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 type: "message", type"essage, content: "orking.. , phase: "commentary", }, { type:"essage"java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds f role: "assistant", :java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25 phase: "final_answer": "user: call_1" , ]); }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 iti levelphasefor- blocks withtext,)= java.lang.StringIndexOutOfBoundsException: Ind const msg = { role: "assistantjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds phase: "final_answer" as const, contentjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for leng java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 [ text:"nput_image, textSignaturesource: type: base64,: "mage/ng" data: "AAAA"} }, { java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length text: "Done.", textSignature: JSON. call_id:"", , ], stopReason}; api: "openai-responses", java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 "gpt.2, usage: {}, timestamp: 0, } expect( const items = convertMessagesToInputItems typeof content: [{ type: "image"mimeType:"image/ng" data "AAA }, >[0]), ) ()toHaveLength(1); { type message, java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for lengt :java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for len phase: "java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for len }, ) }; it("keeps truly unsigned legacy blocks java.lang.StringIndexOutOfBoundsException: Ind const msg = { role: "java.lang.StringIndexOutOfBoundsException: Range [13, 22) out of bounds fo phase: "final_answer content: [ { }; text: "Legacy. ", ], }, { type: "text" as const, text: "Done.", java.lang.StringIndexOutOfBoundsException: Range [0, 23) out of bounds for lengt }, ], stop, api: " provider: "openai", model "gpt-5.", :java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21 timestamp:items convertMessagesToInputItems]unknown < }; expect( typeof convertMessagesToInputItems[sg asunknown as < typeof java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for leng >0) ).([ { type:m" role: "assistant", content: "Legacy. ", }, { type: "message", role: "assistant", content: "Done (java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of b phase: " role: "assistant" as con: "ssistant java.lang.StringIndexOutOfBoundsException: }); it("reservesorderingwhen java.lang.StringIndexOutOfBoundsException: Index 38 out msg= role: "assistant" as }, content: [ { type: "text" as const, ng." textSignature .stringify : 1 id: item_commentary" commentary") }, ass(,[ call_1,name exec,rgs l"}java.lang.StringIndexOutOfBoundsException: Index 78 t"as const id: "all_1|"java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for exec, arguments: { cmd: "messages <ypeof >[0], }java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0 java.lang.StringIndexOutOfBoundsException: Range [21, 14) out of bounds for leng text: role "== message & ( as { role:string }).role === "user", textSignatureJSON(:1, tem_final,phase"inal_answer )java.lang.StringIndexOutOfBound }, ], stopReason: "toolUse", api: "openai-responses", provider"penai" model ={ sage {, , : "inal_answer"asconst [ :",:" : :"/ ]; convertMessagesToInputItems([msg] as Parameters ).toEqual( expect(tems.toHaveLength(1); java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 type: "message ) role: "assistant", content Working. , phase: "commentary", }, { type: "function_call", id: "fc_1", call_id: "call_1", stopReason: "top", name: "exec", : JSON.tringify( cmd:"s") }, { type: "message", role:"assistant", content: "Done.", phase: } ]); }); thinking thinking:internal. { [) :java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for len expect(items[0]).phase: "commentary type: }java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for lengt call_id; output: "file.txt", }); }); OpenAI toolresult java.lang.StringIndexOutOfBoundsException: Range [63, 62) out of const()java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for len :toolResultjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for }; java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0 [type image,mimeType i/png data:"AAA"}, isError:falsejava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds f , }; const :java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for leng [msg] as Parameters:internal.., letions,input "text","image" , ); expect(items id { type: "function_call_output", call_id "all_1"", output: , }, { type: "message", role: "user", content: [ { type: "input_text", text: "Attached image(s) from tool provider: o", { type: "image_url", image_url: { url provider: "openai", ], }, ]); }); it("drops tool result messages with empty tool call id", () => []) t ={ role: "toolResult" as const, toolCallId: " ", toolName )toEqual[ content: [{ type: " it("replays reasoning blockstype essage"java.lang.StringIndexOutOfB isError ={ timestamp: 0, }; const items = convertMessagesToInputItems java.lang.StringIndexOutOfBoundsException: typeof type: "thinking" as const [0]; expect(items).toEqual([]); }); it(fallsback toolUseId : "java.lang.StringIndexOutOfBoundsException: Index 29 out o const msg = { msg={ role: "toolResult" as const, toolUseId: "call_from_tool_use", toolName: "test_tool", java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 9 , timestamp: 0, } const items}, typeof convertMessagesToInputItems >0)java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 1 i.toHaveLength() }java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 type: "const items = convertMessagesTo: "", call_id: "call_from_tool_use", output: "ok", }) }); it("converts a full java.lang.StringIndexOutOfBoundsException: Index 26 out of boun const messages: FakeMessage[] = [ userMsg(Run"), assistantMsg([], [{ id: "call_1", name: "exec", args: { cmd: "ls" } }]), java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0 ]; const items = convertMessagesToInputItems( messages as Parameters<typeof convertMessagesToInputItems>[0], ); const userItem = items.find( (i) => i.type === "message" && (i as java.lang.StringIndexOutOfBoundsException: Index 7 out type "hinking" as const, const fcItem = items.find((i) => i.type == thinkingjava.lang.StringIndexOutOfBoundsExcep const outputItem = items.find((i) => :" bad-" expect(userItem.toBeDefined() :"ext"as "Hereis my "} expect(fcItem).toBeDefined(); expect(java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for len }); it("handles assistant messages with only tool model:"pt5.4,it"preservesordering when, to const usage: {}, = convertMessagesToInputItems([msg] as unknown as Parameters< typeof convertMessagesToInputItems >[0 type: "text"as constjava.lang.StringIndexOutOfBoundsException: Index 32 out of b expect(items).toHaveLength(1) : JSONstringify({v 1 >]; expect(items[ { )java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 assistanttool withempty ids,() >{ const msg = assistantMsg([], [{ id: " ", name: "read", const items = convertMessagesToInputItems:"essage", typeof convertMessagesToInputItems >[0]); . }); " thinkingjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for l const msg = { role: "assistant" as const, content [ { type: "thinking", thinking: "internal reasoning..." }, { type: "text", text: "Here is my answer.java.lang.StringIndexOutOfBoundsException: Ind ], stopReason: "stop"java.lang.StringIndexOutOfBoundsException: Index 0 out of bound api d("buildAssistantMessageFromResponse,)= java.lang.StringIndexOutOfBoundsExcept provider: "openai", "5., usage: {}, : 0java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 1 ".." expect(toHaveLength1; typeofconsttextBlock expectid: expect(textBl(ext"java.lang.StringIndexOutOfBoundsException: Range [44, expect(( : execjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds f }); "replays reasoning java.lang.StringIndexOutOfBoundsException: Index 33 out of boun const={ role: "assistant" as const, content: [ { type: "thinking" as const, phase:"final_answerjava.lang.StringIndexOutOfBoundsExcept thinking: "internal reasoning... ) thinkingSignature: JSON.stringify({ type: "reasoning", : rs_test, summary: [], }), }, { type: "text" as const, textexpect(items(); ], stopReason: "stop", t(; provider: " (.name).oBe("java.lang.StringIndexOutOfBoundsException: Range [31, 30) model:"pt54", usage: {}, timestamp); ; const java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for lengt typeof ("reserves function-call as raw string" )= java.lang.StringIndexOutOfBoundsExcep >[])java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length :java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27 expect(items[Datenow) }); itreplays blocks when is reasoning*" )= { const msg ( role a const, content: [ { type: type: "thinking thinking: "internal reasoning); thinkingSignature: JSON.stringify({ type: "reasoning.summary", id: "rs_summary", })java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1 }, { type: "text" as const, text: "Here is my answer." }, ], : stop", api: "openai-responses", java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7 g-4, }, }; }; const =convertMessagesToInputItems([sgare " ( >{ typeof convertMessagesToInputItems >0) expect(items.map((item) => item }) ]).toMatchObject : "easoning" }); it(" reasoning replay ids that do not match java.lang.StringIndexOutOfBoundsException: I const msg = { role:"assistant asconstjava.lang.StringIndexOutOfBoundsException: Index 33 out of content: [ { type:expect internal., thinkingSignature JSON. type: "reasoning", id: " bad-id ", }), }, typetext"isjava.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for ], stopReason stop msg =buildAssistantMessageFromResponse,modelInfojava.lang.StringInd api"responses" provider: "openai", model:usage java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for }, timestamp: 0, } typeof const items = convertMessagesToInputItems([msg] as Parameters< typeof convertMessagesToInputItems ; >[0 expect(items).toEqual([ { type: "reasoning", }, { type: "message", role: "assistant", content: "Here is my answer.", }, ])java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 7 )java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 it("returns .usage ={ pect(([))toEqual[); }); // ───────────────────────────────────────────────────────────────────────────── buildAssistantMessageFromResponse ) from from item,( java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds const response = makeResponseObjectconst =assistantMsg], [(.model."5)java.lang.String const msg = buildAssistantMessageFromResponse(response, modelInfo); expect(msg.content).toHaveLength(1 convertMessagesToInputItems const textBlock = msg.content[0] as { type: java.lang.StringIndexOutOfBoundsException: expect(textBlock.type).toBe("text"); expect(textBlock.text).toBe("Hello from assistant") expect(msg.)toBe const={ }); it("sets const response = makeResponseObject("resp_1", "Just text"); java.lang.StringIndexOutOfBoundsException: Range [49, 9) out of bounds for lengt expect(msg.stopReason).toBe("stop"); }; it("extracts tool call from function_call output item", () => { const response = makeResponseObject("resp_2", undefined, "exec"); msg=buildAssistantMessageFromResponseexpect.hase.(final_answer"java.lang.StringI const tc = msg.content.find((c) => c.type === model:" } type: string; id:string arguments: Record<string, unknown>; }; expect(tc).toBeDefined(); expecttc.name).toBe"exec")java.lang.StringIndexOutOfBoundsException: Index 33 ou expect(tc.id).toBe("call_abc|item_2"); expecttc.arguments).toEqual{ arg: "alue" }); }); java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15 const response: ResponseObject = { : "resp_malformed", object: "response", :"ssistant", status: "ompleted", model: "gpt-5.4", : [ { type: "function_call", id: "item_bad_args", call_id: "all_bad", name: "exec", arguments " valid json", }, ] thinkingSignature.stringify({ }; , usage{ , :50,total_tokens150}java.lang.StringIndexOutOfBoundsException: Index 73 o type: string ; arguments: unknown; }; expect); expect(tc.name).toBe("} java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 }; it("sets stopReason to 'toolUse' when tool calls are present", () => { const response = makeResponseObject("resp_3", undefined, "exec"); const msg = buildAssistantMessageFromResponse(>[te: s(v ,id:item_final :java.lang.Strin (items.map(item = item.type))toEqual["easoning" " ; }); it("java.lang.StringIndexOutOfBoundsException: Range [0, 14) out of bounds for l constjava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for const msg = buildAssistantMessageFromResponse(response, modelInfo); expect(msg.content.some((c) : "assistant" as constconst, expect(msg.content created_at: Datenow), status type "hinking" as const, }); it("maps usage tokens correctly", () => type reasoningsummary" const response = makeResponseObject("resp_5", "Hello"); )java.lang.StringIndexOutOfBo const msg = buildAssistantMessageFromResponse(response, modelInfo)] expect(msg.usage.input).toBe( content: {type "output_text" text: Legacy. :"penairespon expect(msg.usage.output).toBe(50); expect(msg.usage.totalTokens).toBe(150); }); it("phase model: "gpt-.", response = makeResponseObject("resp_5b", "Hello"); response.usage = { java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 6 completion_tokens: 11, total_tokens: 55, }; msg=(response modelInfo; expect(msg.usage.input).toBe(44); expect(msg.usage.output).toBe(11); expect(msg.usage.totalTokens).toBe(55); }); it("falls back to normalized input and output when total_tokens is missing", () => { const =makeResponseObject"" "Hello"; response. { prompt_tokens { completion_tokens: 5, }; const msg = buildAssistantMessageFromResponse(response, modelInfo); expect(msg.usage.input).toBe(10); expect(msg.usage.output).toBe(5); expect(msg.usage.totalTokens).toBe(15); }; it("falls back to normalized input and output when total_tokens is , makeResponseObject"",""); response.usage = { input_tokens: 10, output_tokens: 5, , java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6 msg : expect(msg.usage.input; expect(msg.usage const=java.lang.StringIndexOutOfBoundsException: Index 39 out of expect(msg.usage.totalTokens).toBe(15); }); it( : [{ type: "utput_text" :().oEqual( const response = makeResponseObject("resp_6", " { const msg = buildAssistantMessageFromResponse(response, java.lang.StringIndexOutOfBo expect(msg.api).toBe("openai-responses"); expect(msg.provider).toBe("openai"); expect(msg.model).toBe("gpt-5.4"); }); it("handles empty output gracefully", () ?:string const responseay{ type string text?:string; name?: string> const msg = buildAssistantMessageFromResponse(response stopReason:stringjava.lang.St expect expectp)toBeUndefined) }); it("preserves phase from assistant (msg.content).toMatchObject([{ type: "toolCall", nam const response = makeResponseObject("resp_8" ribe"buildAssistantMessageFromResponse" const msg = buildAssistantMessageFromResponse(response, modelInfo) it" = {pi:openai-"pr phase:string response= makeResponseObject("resp_1", "Hello from assistant"); }; expect(msg.phase).toBe("final_answer"); expect( status: "completed, }); it("keeps only expect(textBlock.t).toBe(text"; java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for lengt id: "java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length :response" created_at: Date.now(), status: " constresponse=makeResponseObject("esp_1,"java.lang.StringIndexOutOfBound g52" output: [ { type: "message", id: "item_commentary", role: "assistant", phase: "commentary", } unknown as ; }java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10 java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 type:"essage", id: "item_final", role: "assistant", ", content {type: ",text:"Done" ], }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, } as unknown as ResponseObject; msg buildAssistantMessageFromResponse(esponse,) as { phase?: string; content: Array<{ type: string; text?: string; (maps reasoning*output java.lang.StringInde }; expect(msg.phase).java.lang.StringIndexOutOfBoundsException: Index 26 out of bou expect(msg.content).toMatchObject([ { type: "text", :"gpt-.", textSignature: JSON.stringify({ v: 1, idjava.lang.StringIndexOutOfBoundsException: I , ] id:"item_bad_args", }); (keepsonly finaltextwhen unphased text and final text coexist ( =>{ const response = { id: "resp_unphased_plus_final", object: "response"const ( , created_at: Date.now(), status cjava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for len java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25 output:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for leng { expect(c).toBe"exec"; id"tem_legacy", role: "assistant", java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 6 }, { type: "message", id: "item_final", role: "assistant", phase: "final_answer", content {type }java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds fo }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, } as unknown as ResponseObject; const msg = buildAssistantMessageFromResponse(response, modelInfo) as { phase?: string; content: Array<{ type: string; text?: string; textSignature?: string }>; }; ("final_answer"; expect(msg.content).toMatchObject([ { type: "text", text: "Done.", : JSONstringify{v 1, id: "item_final", phase:"java.lang.StringIndexOutOfBoundsExcepti }, ]; }); it("drops name:exec"java.lang.StringIndexOutOfBoundsException: Index 23 out of bo constjava.lang.StringIndexOutOfBoundsException: Range [20, 18) out of bounds for id: "resp_commentary_only_tool", object: "response", created_at: Date.now(), status: "completed", model: "gpt-5. :44 output: completion_tokens11java.lang.StringIndexOutOfBoundsException: Index 28 ou { id: "item_commentary", role: "assistant", phase: "commentary", java.lang.StringIndexOutOfBoundsException: Range [66, 17) out of bounds for leng } { type: "function_call", id:"item_tool", call_id: "call_abc", name: "exec", arguments: '{"arg":"value"}', }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, } as completion_tokens java.lang.StringIndexOutOfBoundsException: Index 9 out of bo const msg = buildAssistantMessageFromResponse(response, modelInfo) as { phase?: string; content Array< type: tring; text?:string; java.lang.StringIndexOutOfBoundsException: R stopReason: string; }unknownas ; expect(msg.phase).toBeUndefined(); msg.() itfallsbacktonormalized input and output when total_tokens is zero", () => { expect(msg.content). )java.lang.StringIndexOutOfBoundsException: Index 5 out of b expect(msg.stopReason).toBe(" it("preserves function call item ids f ispresent" )=>{ }); it("maps reasoning output object:"response", const { id: "resp_reasoning", object:"response", created_at: Date.now(), status: "completed", type:r, output: [ { expect(msg.usage.input).toBe(10); type.(msgot; ) }, { type: "message", arguments{java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bound role: "assistant :" :""}java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for leng }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, }asunknownas ; const msg = buildAssistantMessageFromResponse(response,|{type:"oolCall; } const thinkingBlock = msg.content.find((c) => msg=buildAssistantMessageFromResponse(re | { type: " expect(msg.stopReason""); | undefined; expect(thinkingBlock?.thinking).toBe("Plan step A\nPlan step B"); expect(thinkingBlock?.thinkingSignature).toBe( stringify{id rs_123,type reasoning ) ); }); it". items thinkingblocks" )= java.lang.StringIndexOutOfBoundsException: Index 64 ou constresponse =java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds id: "resp_reasoning_kind", object:" created_at:Date.ow)java.lang.StringIndexOutOfBoundsException: Index 29 out of bo status: "completed", output:[ { reasoningsummary, id: "rs_456", content (Run) }, ], usage {input_tokens: 100, output_tokens: 50, total_tokens: 150 }, } as unknown as ResponseObject [[id fc_1: : ] java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for leng constthinkingBlock =msgcontent[]as | { type: "thinking tools []java.lang.StringIndexOutOfBoundsException: Index 16 out o | undefined; expect(thinkingBlock?.type).toBe content {type",text: "one ] (thinkingBlock , expect(thinkingBlock JSON.stringify({ id: :"esp_prevjava.lang.StringIndexOutOfBoundsException: Index 38 ; }); andpreserves item order, ( =>{ const response = { id: "resp_reasoning_order", object: "response", created_at: Date.now(), status: "completed", model: "gpt-5.4", output: [ { type: "reasoning.summary", id: "rs_789", ummarytext:"" content: "hidden fallback content", }, { :"", id: "fc_789", call_id: "call_789", name: "exec" ]; {arg""value"}, }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, } as unknown as ResponseObject; const msg = buildAssistantMessageFromResponse(response, modelInfo); expect(msg.content.map(, const thinkingBlock = msg.java.lang.StringIndexOutOfBoundsException: Index 37 out o | {type: "hinking";thinking: string | undefined; expect(thinkingBlock?.thinking).toBe("Plan A\nPlan B"); expect(thinkingBlock?.thinkingSignature).toBe( call_id:"all_turn1" ); }); it("drops invalid reasoning ids from }, const response = { id: "resp_invalid_reasoning_id", object: "java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for len :java.lang.StringIndexOutOfBoundsException: Range [29, 24) out of bounds for len status: "completed", model: "gpt-5.4", output: [ { type: "reasoning"}, id: "invalid_reasoning_id", content: "Hidden reasoning", , ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, constturnInput=planTu } as unknown as ResponseObject; constmsg expect(sgontent.toMatchObject( (sg.content).toEqual( type:"thinking" thinking: Hiddenreasoning { })java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5 ("preserves function call item ids for replay :makeResponseObject(armup$.(}) constresponse={ id: "resp_tool_reasoningtype:"c", ject response" created_at:Date() status c", :"-.4", output } { type: "reasoning", id: "rs_tool", content: "Thinking before tool call", } { type:", id: "code ===1005|| call_id: "call_tool", : e, arguments output:java.lang.StringIndexOutOfBoundsException: Index 15 out of bound }, , java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 7 (void const assistantphase( string:void{ =java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for len | instances [] ] |java.lang.StringIndexOutOfBoundsException: Range [38, 17) out of bounds for len // Patch constructor to track instances const (] java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for leng >[0]); expect(replayItems get java.lang.StringIndexOutOfBoundsException: Index 6 out of b expect {type message", role mockCreateHttpFallbackStreamFn.mockReturnValue(mockStrea type: "function_call", call_id "all_tool"java.lang.StringIndexOutOfBoundsException: Index 27 out of boun id: "fc_tool", java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 7 }); }java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3 // ───────────────────────────────────────────────────────────────────────────── describe("planTurnInput", () => { const }; it// ───────────────────────────────────────────────────────────────────────────── const context = { systemPrompt: Youare ., messages: [ (lsjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length id"call_1|fc_1" name "exec", java.lang.StringIndexOutOfBoundsException: Range [0, 6 toolResultMsg("call_1|fc_1", "file.txt"), ] as Parameters<typeof :[text], tools [ } const turnInput = planTurnInput({ context, , previousResponseId: "resp_prev", 2, expect(turnInput.mode).toBe("incremental_tool_results"); expect releaseWsSession("ess-") .inputItems.oEqual[ { java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 call_id: "call_1", :".", }, ]); }); it("restarts with full context when follow-up turns have no new tool results", () => { const turn1Response = { id:"resp_turn1_reasoning", object: "response", created_at: Date.now(), status "ompleted, model: "gpt-5.4", output: [ { type: "reasoning", id: "s_turn1", content: "Thinking before tool call", }, { "function_call", id: "fc_turn1", call_id: "call_turn1", name: "exec", arguments: '{"cmd":"ls"}', }, ], usage: { input_tokens: 12, output_tokens: 8, java.lang.StringIndexOutOfBoundsException } as ResponseObject; const context = { systemPrompt: "You are helpful.", messages: [ ls", buildAssistantMessageFromResponse(turn1Response, { api: "openai-responses", provider: " as Paramete<ypeof >1] java.lang.StringIndexOutOfBoundsException: Range [0, 12) out of bounds for lengt }), ] as Parameters<typeof convertMessagesToInputItems>[0], tools: [], }; const turnInput = planTurnInput({ context, model: replayModel, previousResponseId: "resp_turn1_reasoning", lastContextLength: context.messages.length, }); expect(turnInput.mode).toBe("full_context_restart"); expect(turnInput.previousResponseId).toBeUndefined(); expect(turnInput.inputItems.map((item) => item.type as unknown as ResponseObject; "message", " function_call"java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds ]); expect(turnInput.inputItems[1]).toMatchObject({ type: "reasoning", id: "java.lang.St expect(turnInput.inputItems[2]).toMatchObject({ type:"function_call, :"all_turn1, id: "fc_turn1", }); }); it("uses full context on the initial turn", () = onst response =java.lang.StringIndexOutOfB object: "response", ystemPrompt You are helpful.", messages: ""ompleted" type:"response.o" tools:]java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for len }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6 =planTurnInput{ context, model: replayModel, previousResponseId:} lastContextLength: 0, }; expect(turnInput).toMatchObject({ mode: "full_context_initial", inputItems: [{ type: "message", role: "user", content: "Hello!" }], }); }); }); /───────────────────} describe("it"refers summarytext over fallback content and preserves item order", () => { "ends only the strict suffix when the full input extends the prior response expect(rray.(.).o const previousInputItems: InputItem[] = [{ type: "message", role: "user", content: "Hello" previousRequestResponseCreateEvent{ type: "response completed, model: "gpt-5.4", store: false, "oujava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 input: previousInputItems, }; const previousResponseInputItems: InputItem[] = [ { type: "message", role: "assistant", content: "Hi" }, ]; const fullPayload: ResponseCreateEvent = { type: "response.create", model: "gpt-5.4", store: false, instructions "ou are helpful."java.lang.StringIndexOutOfBoundsException: Index 39 o input: [ ..previousInputItems ...previousResponseInputItems, { "user", content Next } ], }; java.lang.StringIndexOutOfBoundsException: Range [43, 9) out of bounds for lengt ullPayload, previousRequestPayload: java.lang.StringIndexOutOfBoundsException: Index 44 out o previousResponseId: "resp_prev", previousResponseInputItems: [.})java.lang.StringIndexOutOfBoundsException: Index }); java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for leng expect(plan.payload.previous_response_id).toBe("resp_prev"); expect(plan.payload.input).toEqual([created_at:Date.ow(), }); (falls backto 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, java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6 const fullPayload: ResponseCreateEvent = { ...previousRequest, instructions: "New instructions", input: [ ...previousInputItems, { type: "message", role: "assistant", content: "Hi" }, { type: "message", role: "user", content: "Next" }, ], }; const plan = planOpenAIWebSocketRequestPayload({ fullPayload, previousRequestPayload: previousRequest, previousResponseId: "resp_prev", previousResponseInputItems: [{ type: "message", role: "assistant", content: "Hi" }], }); expect(plan.mode).toBe("full_context"); expect(lan.ayload).toBeUndefined); expect(plan.payload.input).toEqual(fullPayload.input); }); it("falls back to full context when the input is not a strict java.lang.StringIndexOutOfBoun const type: "response.create", model: "gpt-5.4", store: false, [ :"essage,ole:"er,content ""}, }; const fullPayload: ResponseCreateEvent = { ...previousRequest, : "userMsg(Run ls", }; const plan = planOpenAIWebSocketRequestPayload({ fullPayload, previousRequestPayload: previousRequest, previousResponseId: "resp_prev", previousResponseInputItems: [{ type: "message }); expect(plan.mode).toBe("full_context const turnInput = planTurnInput({ expect(plan.payload.previous_response_id).toBeUndefined(); expect(plan.payload.input).toEqual odel , }); }); // ────────── stream=java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for l describe("createOpenAIWebSocketStreamFn", () => { const java.lang.StringIndexOutOfBoundsException: Range [42, 20) out of bounds for api: "openai-responses", provider: "openai", id: "gpt-5.4", java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length maxTokens 4096, reasoning: false, input: [ev) cost: { input: 0, output: 0,} name: "GPT-5.2", }; onstcontextStub={ java.lang.StringIndexOutOfBoundsException: Range [10, 6) out of bounds for lengt messages: [userMsg("Hello!") as Parameters<typeof convertMessagesToInputItems>[0][numb tools: [], }; beforeEach(() => { MockManager.reset(); streamSimpleCalls.length = 0;name:"xec"java.lang.StringIndexOutOfBoundsException: mockCreateHttpFallbackStreamFn.mockReset(); mockCreateHttpFallbackStreamFn.mockReturnValue(java.lang.StringIndexOutOfBoundsE openAIWsStreamTesting.setDepsForTest({ createManager: ((options?: unknown) => new MockManager(options)) as never, createHttpFallbackStreamFn: java.lang.StringIndexOutOfBoundsException: Index 53 o streamSimplecontext ={ }); }); afterEach(() => { // Clean up any sessions created in tests to avoid cross-test pollution MockManager.instances.forEach((_, java.lang.StringIndexOutOfBoundsException: Rang // Session IDs used in tests follow a predictable pattern releaseWsSession]as <typeof convertMessagesToInputItems> responses" sync > }); 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-onpayload-asyncexpectt.previousResponseId() releaseWsSession("sess-phase"); releaseWsSession("sess-phase-stream"); releaseWsSession("sess-phase-late-map"); ("sess-reason"); releaseWsSession("sess-reason-none"); releaseWsSession("sess-tools"); (sess-default)call_id:""java.lang.StringIndexOutOfBoundsException: Index 28 out releaseWsSession("sess-store-compat"); releaseWsSession("sess-store-proxy"); releaseWsSession("sess-max-tokens-zero"); releaseWsSession("sess-runtime-fallback-nested"); releaseWsSession("sess-runtime-fallback"); releaseWsSessionsystemPrompt"are java.lang.StringIndexOutOfBoundsException: Index eleaseWsSession"-send-fail-"; releaseWsSession("sess-temp"); releaseWsSession("sess--ext-erbosity releaseWsSession("sess-text-verbosity-invalid"); releaseWsSession("sess-topp"); releaseWsSession("sess-turn-metadata-retry"); releaseWsSession("sess-warmup-disabled"); java.lang.StringIndexOutOfBoundsException: Range [41, 20) out of bounds for leng releaseWsSession(sess-degraded-cooldown"); releaseWsSession("sess-drop"); openAIWsStreamTesting.setWsDegradeCooldownMsForTest(); openAIWsStreamTesting.setDepsForTest(); }); (const streamFn=createOpenAIWebSocketStreamFn("sk-test", "sess-phase-stream"); s-1"java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length const stream = streamFn( modelStub as Parameters<typeof streamFn>[0], contextStub as Parameters<typeof streamFn>[1], ); // Give the microtask java.lang.StringIndexOutOfBoundsException: Index 28 out of bou await new Promise((r) => setImmediate(r)); const =ockManagerlastInstance; const previousRequest:ResponseCreateEvent ? {phase?:; content?: java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 12 for await (const _ of await resolveStream(stream)) { // consume } }); it("sends a response.create event on first turn (full context)", async () => { const] conststream streamFn( modelStub as Parameters<typeof streamFn>[0], contextStub as Parameters<typeof streamFn>[1], ); const completed = new Promise<void>((res, rej) => { queueMicrotask(async () => { try { await new Promise((r) => setImmediate(r)); const manager = MockManager.lastInstance!; // = planOpenAIWebSocketRequestPayload manager.simulateEvent({ type: "response.completed", response: ..previousResponseInputItems }); for java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length // consume events } es)java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length } catch (e) { ej(; } }); ) await completed; const manager = MockManager.lastInstance!; expect(manager.java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds const sent = manager.sentEvents[0] it"uses context the " (= { expect(sent.type).toBe("response.create"); expect(sent.model).toBe("gpt delta:"." expect(Array.isArray(sent.input)).toBe(true); }); it("includes store:false by default", async () constocketStreamFn(-est" sess--default"); const stream = streamFn( modelStub as Parameters<typeof streamFn>[0], previousResponseId: null, ); const } queueMicrotask(async () => { try { await new Promise(( await new Promise((r [ type:message", const manager = MockManager.lastInstance!; manager.simulateEvent({ rc" java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for lengt }); forfor await (onst _of await resolveStream() java.lang.StringIndexOutOfBoundsException // consume } res(); } catch (e) { rej(e); java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 }); }); await completed; const sent = MockManager.lastInstance!.sentEvents[0] as Record<string, unknown>; expectphase:"inal_answer, ], it("omits store when compat.supportsStore is false (#39086)", async () => { releaseWsSession("sess-store-compat"); const noStoreModel = { ...modelStub, compat: { supportsStore: false }, }; const streamFn=createOpenAIWebSocketStreamFn:[.previousResponseInputItems, const stream = streamFn( noStoreModel as Parameters<typeof streamFn>[0], contextStub as Parameters<typeof streamFn>[1], ); const java.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for queueMicrotask(falls to context non-java.lang.StringIndexOutOfBoundsException: Rang try { await new Promise((r) => setImmediate(r)); const manager = MockManager.lastInstance!; manager.simulateEvent({ type: "response.completed", response: java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for le }); for await (const _ of await resolveStream(stream)) { // consume java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11 res(); } catch (e) { rej(e); } ) }); await completed; =.lastInstance.[0 as Record<tring,>java.lang.StringIndexOutOfBoundsException: Index expect(sent).not.toHaveProperty("store"); }); store=} const proxiedModel = { .., baseUrl: "java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for l } const turnInput = planTurnInput({ context: contextStub as Parameters<typeof planTurnInput>[0]["context"], model:proxiedModelas Parameterstypeof planTurnInput[0]["", previousResponseId: null, lastContextLength: 0, }); const sent = java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for model: proxiedModel as Parameters< typeof buildOpenAIWebSocketResponseCreatePayload >[0]["const eventsArray<{ context: contextStub as Parameters< typeof buildOpenAIWebSocketResponseCreatePayload >[0]["previousResponseIddelta?: string; turnInput, tools:[, }) as Record<string, unknown>; expect(sent.store).toBe(false); }); it("emits(lanp.)(.input) const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-2"); const stream = streamFn( / ──────────────────────────── contextStub as Parameters<typeof streamFn>[1], ); java.lang.StringIndexOutOfBoundsException: Range [25, 9) out of bounds for lengt const done = (async () => { for await (const ev of await resolveStream(stream)) { java.lang.StringIndexOutOfBoundsException: Range [15, 13) out of bounds for leng } )(; await new Promise((r) => setImmediate(r)); const manager = MockManager.lastInstance!; java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length id , response: makeResponseObject("resp_hello", "Hello back!"), }); ; const doneEvent = events.find((e) => (java.lang.StringIndexOutOfBoundsException: Range type: string; }; message: { content: Array<{ text: string }> }; | undefined; doneEvent.)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for leng }); it("suppresses commentary-only "-java.lang.StringIndexOutOfBoundsException: Index const streamFn =" const stream = streamFn( modelStub as Parameters<typeof streamFn>[0], contextStub as Parameterstypeof streamFn>[1], ); const events: unknown[] = []; const done = (async () => { for await (const ev of await resolveStream(stream)) { .push (sessreason) } })(); await new (rfallback)java.lang.StringIndexOutOfBoundsException: Index 53 out of bo const manager = MockManager.lastInstance!; manager.simulateEvent({ type: "response.completed"r"ess); java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for leng }); done const doneEvent = events.find((e) => (e as { type?:]; | { type: string; reason:string message: { phase?: string; stopReason: string; content?: Array<{ type?: string }> }; } | undefined; expect(doneEvent?.message.phase).toBeUndefined(); expect(doneEvent?.message.content?.some((part const stream = streamFn( expect(oneEvent.essage.topReason.oBe""; }); it("emits accumulated phase-aware const streamFn = createOpenAIWebSocketStreamFn("sk-test", "sess-phase-stream"); const stream = streamFn( modelStub as Parameters<typeof streamFn>[0], contextStub as Parameters<typeof streamFn>[}; ); const events < ?string; delta partial?: { phase?: string; content?: unknown[] }; partial?: { phase?: string; content?: unknown[] }; }> = [] const done = (async () => { for const completed = new Promise<void>((res, rej) => { queueMicrotaskasync (= { } })(); await new Promise((r) => setImmediate(r)); java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length java.lang.StringIndexOutOfBoundsException: Range [17, 11) out of bounds for leng type: "response.java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds output_index: 0, item: { type: "message", id: "item_commentary", role: "assistant", phase: "commentary", content: [], }, }); manager.simulateEvent({ type: "response.output_text.delta", item_id: "item_commentary", output_index: 0, content_index: 0, delta: "Working", }); manager.simulateEvent({ type: "response.output_text.delta", item_id: "item_commentary"java.lang.StringIndexOutOfBoundsException: Index 33 out output_index: 0, content_index:xpect(sent.odel)java.lang.StringIndexOutOfBoundsException: Range [ delta: "...", }); manager.simulateEvent({ type: "response.output_item.added", output_index: 1, item: { type: "message", id: "item_final", ", phase: "final_answer", content: [], }, }); manager.simulateEvent({ type: "response.output_text.delta", item_id: "item_final", output_index: 1, content_index: 0, delta: "Done.", }); manager.simulateEvent({ type: "response.completed", response: { id_java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for l object: "response", .now(, status: "completed"type:".ompleted, model: "gpt-5.2", output: [ { type: "message", ", role: "assistant", phase: "commentary", content: [{ type: "output_text", text: "Working..." }], }, { "essage, id: "item_final", role: "assistant", phase: "final_answer", content: [{ type: "output_text", text: "Done." }turnInputjava.lang.StringIndexOutOfBou }, ], usage: { input_tokens: 100, output_tokens: 50, total_tokens: 150 }, }, ) await done; const deltas = events.filter((event) => event.type === "text_delta"); expect(eltas).oHaveLength(3); expect(deltas[0]).toMatchObjectconstdeltas = events.ilter((event) => event.type === "te |