fix(deps): patch workers-ai-provider to prevent duplicate tool call streaming deltas

Author: codercatdev

patches/workers-ai-provider.patch

@@ -0,0 +1,84 @@
+diff --git a/dist/index.mjs b/dist/index.mjs
+index 764cbf5325502a9836710b1c218e03d2356cd192..219f7886a71ebe7e469718e39abb72d30e1de4b9 100644
+--- a/dist/index.mjs
++++ b/dist/index.mjs
+@@ -728,16 +728,7 @@ function getMappedStream(response, salvageContext) {
+ 					});
+ 				}
+ 			}
+-			if (Array.isArray(chunk.tool_calls)) {
+-				if (reasoningId) {
+-					controller.enqueue({
+-						type: "reasoning-end",
+-						id: reasoningId
+-					});
+-					reasoningId = null;
+-				}
+-				emitToolCallDeltas(chunk.tool_calls, controller);
+-			}
++			let toolCallsEmitted = false;
+ 			if (choices?.[0]?.delta) {
+ 				const delta = choices[0].delta;
+ 				const reasoningDelta = delta.reasoning_content ?? delta.reasoning;
+@@ -788,8 +779,19 @@ function getMappedStream(response, salvageContext) {
+ 						reasoningId = null;
+ 					}
+ 					emitToolCallDeltas(deltaToolCalls, controller);
++					toolCallsEmitted = true;
+ 				}
+ 			}
++			if (!toolCallsEmitted && Array.isArray(chunk.tool_calls)) {
++				if (reasoningId) {
++					controller.enqueue({
++						type: "reasoning-end",
++						id: reasoningId
++					});
++					reasoningId = null;
++				}
++				emitToolCallDeltas(chunk.tool_calls, controller);
++			}
+ 		},
+ 		flush(controller) {
+ 			for (const [idx] of activeToolCalls) {
+diff --git a/src/streaming.ts b/src/streaming.ts
+index 114d54f70ad03f9acb7f57886bc03961c2938cd5..7c116056e71f1410d7a7fcbb4579449c991dab2d 100644
+--- a/src/streaming.ts
++++ b/src/streaming.ts
+@@ -189,16 +189,7 @@ export function getMappedStream(
+ 					}
+ 				}
+ 
+-				// --- Native format: top-level `tool_calls` ---
+-				if (Array.isArray(chunk.tool_calls)) {
+-					// Close active reasoning block before tool calls start
+-					if (reasoningId) {
+-						controller.enqueue({ type: "reasoning-end", id: reasoningId });
+-						reasoningId = null;
+-					}
+-					emitToolCallDeltas(chunk.tool_calls as Record<string, unknown>[], controller);
+-				}
+-
++				let toolCallsEmitted = false;
+ 				// --- OpenAI format: choices[0].delta ---
+ 				if (choices?.[0]?.delta) {
+ 					const delta = choices[0].delta;
+@@ -253,8 +244,19 @@ export function getMappedStream(
+ 							reasoningId = null;
+ 						}
+ 						emitToolCallDeltas(deltaToolCalls, controller);
++						toolCallsEmitted = true;
+ 					}
+ 				}
++
++				// --- Native format: top-level `tool_calls` ---
++				if (!toolCallsEmitted && Array.isArray(chunk.tool_calls)) {
++					// Close active reasoning block before tool calls start
++					if (reasoningId) {
++						controller.enqueue({ type: "reasoning-end", id: reasoningId });
++						reasoningId = null;
++					}
++					emitToolCallDeltas(chunk.tool_calls as Record<string, unknown>[], controller);
++				}
+ 			},
+ 
+ 			flush(controller) {