| 38 | Wrap your summary in <summary></summary> tags.`;function VH7(){let q,K;return{promise:new Promise((z,Y)=>{q=z,K=Y}),resolve:q,reject:K}}async function Oz5(q,K=q.messages.at(-1)){if(!K||K.role!=="assistant"||!K.content||typeof K.content==="string")return null;let _=K.content.filter((Y)=>Y.type==="tool_use");if(_.length===0)return null;return{role:"user",content:await Promise.all(_.map(async(Y)=>{let $=q.tools.find((A)=>("name"in A?A.name:A.mcp_server_name)===Y.name);if(!$||!("run"in $))return{type:"tool_result",tool_use_id:Y.id,content:`Error: Tool '${Y.name}' not found`,is_error:!0};try{let A=Y.input;if("parse"in $&&$.parse)A=$.parse(A);let O=await $.run(A);return{type:"tool_result",tool_use_id:Y.id,content:O}}catch(A){return{type:"tool_result",tool_use_id:Y.id,content:A instanceof nX6?A.content:`Error: ${A instanceof Error?A.message:String(A)}`,is_error:!0}}}))}}var hx6,iX6,A96,$P,Sx6,YE,Lc,Qt,Cx6,kH7,Br8,bx6;var gr8=y(()=>{Vc();d38();yZ();zE();Gx6();bx6=class bx6{constructor(q,K,_){hx6.add(this),this.client=q,iX6.set(this,!1),A96.set(this,!1),$P.set(this,void 0),Sx6.set(this,void 0),YE.set(this,void 0),Lc.set(this,void 0),Qt.set(this,void 0),Cx6.set(this,0),A4(this,$P,{params:{...K,messages:structuredClone(K.messages)}},"f");let Y=["BetaToolRunner",...Er8(K.tools,K.messages)].join(", ");A4(this,Sx6,{..._,headers:b3([{"x-stainless-helper":Y},_?.headers])},"f"),A4(this,Qt,VH7(),"f")}async*[(iX6=new WeakMap,A96=new WeakMap,$P=new WeakMap,Sx6=new WeakMap,YE=new WeakMap,Lc=new WeakMap,Qt=new WeakMap,Cx6=new WeakMap,hx6=new WeakSet,kH7=async function(){let K=E1(this,$P,"f").params.compactionControl;if(!K||!K.enabled)return!1;let _=0;if(E1(this,YE,"f")!==void 0)try{let w=await E1(this,YE,"f");_=w.usage.input_tokens+(w.usage.cache_creation_input_tokens??0)+(w.usage.cache_read_input_tokens??0)+w.usage.output_tokens}catch{return!1}let z=K.contextTokenThreshold??TH7;if(_<z)return!1;let Y=K.model??E1(this,$P,"f").params.model,$=K.summaryPrompt??vH7,A=E1(this,$P,"f").params.messages;if(A[A.length-1].role==="assistant"){let w=A[A.length-1];if(Array.isArray(w.content)){let j=w.content.filter((H)=>H.type!=="tool_use");if(j.length===0)A.pop();else w.content=j}}let O=await this.client.beta.messages.create({model:Y,messages:[...A,{role:"user",content:[{type:"text",text:$}]}],max_tokens:E1(this,$P,"f").params.max_tokens},{headers:{"x-stainless-helper":"compaction"}});if(O.content[0]?.type!=="text")throw new O4("Expected text response for compaction");return E1(this,$P,"f").params.messages=[{role:"user",content:O.content}],!0},Symbol.asyncIterator)](){var q;if(E1(this,iX6,"f"))throw new O4("Cannot iterate over a consumed stream");A4(this,iX6,!0,"f"),A4(this,A96,!0,"f"),A4(this,Lc,void 0,"f");try{while(!0){let K;try{if(E1(this,$P,"f").params.max_iterations&&E1(this,Cx6,"f")>=E1(this,$P,"f").params.max_iterations)break;A4(this,A96,!1,"f"),A4(this,Lc,void 0,"f"),A4(this,Cx6,(q=E1(this,Cx6,"f"),q++,q),"f"),A4(this,YE,void 0,"f");let{max_iterations:_,compactionControl:z,...Y}=E1(this,$P,"f").params;if(Y.stream)K=this.client.beta.messages.stream({...Y},E1(this,Sx6,"f")),A4(this,YE,K.finalMessage(),"f"),E1(this,YE,"f").catch(()=>{}),yield K;else A4(this,YE,this.client.beta.messages.create({...Y,stream:!1},E1(this,Sx6,"f")),"f"),yield E1(this,YE,"f");if(!await E1(this,hx6,"m",kH7).call(this)){if(!E1(this,A96,"f")){let{role:O,content:w}=await E1(this,YE,"f");E1(this,$P,"f").params.messages.push({role:O,content:w})}let A=await E1(this,hx6,"m",Br8).call(this,E1(this,$P,"f").params.messages.at(-1));if(A)E1(this,$P,"f").params.messages.push(A);else if(!E1(this,A96,"f"))break}}finally{if(K)K.abort()}}if(!E1(this,YE,"f"))throw new O4("ToolRunner concluded without a message from the server");E1(this,Qt,"f").resolve(await E1(this,YE,"f"))}catch(K){throw A4(this,iX6,!1,"f"),E1(this,Qt,"f").promise.catch(()=>{}),E1(this,Qt,"f").reject(K),A4(this,Qt,VH7(),"f"),K}}setMessagesParams(q){if(typeof q==="function")E1(this,$P,"f").params=q(E1(this,$P,"f").params);else E1(this,$P,"f").params=q;A4(this,A96,!0,"f"),A4(this,Lc,void 0,"f")}async generateToolResponse(){let q=await E1(this,YE,"f")??this.params.messages.at(-1);if(!q)return null;return E1(this,hx6,"m",Br8).call(this,q)}done(){return E1(this,Qt,"f").promise}async runUntilDone(){if(!E1(this,iX6,"f"))for await(let q of this);return this.done()}get params(){return E1(this,$P,"f").params}pushMessages(...q){this.setMessagesParams((K)=>({...K,messages:[...K.messages,...q]}))}then(q,K){return this.runUntilDone().then(q,K)}};Br8=async function(K){if(E1(this,Lc,"f")!==void 0)return E1(this,Lc,"f");return A4(this,Lc,Oz5(E1(this,$P,"f").params,K),"f"),E1(this,Lc,"f")}});var rX6;var Fr8=y(()=>{yZ();Wr8();rX6=class rX6{constructor(q,K){this.iterator=q,this.controller=K}async*decoder(){let q=new Bt;for await(let K of this.iterator)for(let _ of q.decode(K))yield JSON.parse(_);for(let K of q.flush())yield JSON.parse(K)}[Symbol.asyncIterator](){return this.decoder()}static fromResponse(q,K){if(!q.body){if(K.abort(),typeof globalThis.navigator<"u"&&globalThis.navigator.product==="ReactNative")throw new O4("The default react-native fetch implementation does not support streaming. Please use expo/fetch: https://docs.expo.dev/versions/latest/sdk/expo/#expofetch-api");throw new O4("Attempted to iterate over a response with no body")}return new rX6(Jx6(q.body),K)}}});var xx6;var Ur8=y(()=>{_B();zE();Fr8();Ft();gt();xx6=class xx6 extends zH{create(q,K){let{betas:_,...z}=q;return this._client.post("/v1/messages/batches?beta=true",{body:z,...K,headers:b3([{"anthropic-beta":[..._??[],"message-batches-2024-09-24"].toString()},K?.headers])})}retrieve(q,K={},_){let{betas:z}=K??{};return this._client.get(Yj`/v1/messages/batches/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...z??[],"message-batches-2024-09-24"].toString()},_?.headers])})}list(q={},K){let{betas:_,...z}=q??{};return this._client.getAPIList("/v1/messages/batches?beta=true",Lx,{query:z,...K,headers:b3([{"anthropic-beta":[..._??[],"message-batches-2024-09-24"].toString()},K?.headers])})}delete(q,K={},_){let{betas:z}=K??{};return this._client.delete(Yj`/v1/messages/batches/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...z??[],"message-batches-2024-09-24"].toString()},_?.headers])})}cancel(q,K={},_){let{betas:z}=K??{};return this._client.post(Yj`/v1/messages/batches/${q}/cancel?beta=true`,{..._,headers:b3([{"anthropic-beta":[...z??[],"message-batches-2024-09-24"].toString()},_?.headers])})}async results(q,K={},_){let z=await this.retrieve(q);if(!z.results_url)throw new O4(`No batch \`results_url\`; Has it finished processing? ${z.processing_status} - ${z.id}`);let{betas:Y}=K??{};return this._client.get(z.results_url,{..._,headers:b3([{"anthropic-beta":[...Y??[],"message-batches-2024-09-24"].toString(),Accept:"application/binary"},_?.headers]),stream:!0,__binaryResponse:!0})._thenUnwrap(($,A)=>rX6.fromResponse(A.response,A.controller))}}});function yH7(q){if(!q.output_format)return q;if(q.output_config?.format)throw new O4("Both output_format and output_config.format were provided. Please use only output_config.format (output_format is deprecated).");let{output_format:K,..._}=q;return{..._,output_config:{...q.output_config,format:K}}}var NH7,jz5,dt;var Qr8=y(()=>{Ft();hr8();zE();Gx6();br8();GH7();gr8();d38();Ur8();Ur8();gr8();d38();NH7={"claude-1.3":"November 6th, 2024","claude-1.3-100k":"November 6th, 2024","claude-instant-1.1":"November 6th, 2024","claude-instant-1.1-100k":"November 6th, 2024","claude-instant-1.2":"November 6th, 2024","claude-3-sonnet-20240229":"July 21st, 2025","claude-3-opus-20240229":"January 5th, 2026","claude-2.1":"July 21st, 2025","claude-2.0":"July 21st, 2025","claude-3-7-sonnet-latest":"February 19th, 2026","claude-3-7-sonnet-20250219":"February 19th, 2026"},jz5=["claude-opus-4-6"];dt=class dt extends zH{constructor(){super(...arguments);this.batches=new xx6(this._client)}create(q,K){let _=yH7(q),{betas:z,...Y}=_;if(Y.model in NH7)console.warn(`The model '${Y.model}' is deprecated and will reach end-of-life on ${NH7[Y.model]} |
| 39 | Please migrate to a newer model. Visit https://docs.anthropic.com/en/docs/resources/model-deprecations for more information.`);if(Y.model in jz5&&Y.thinking&&Y.thinking.type==="enabled")console.warn(`Using Claude with ${Y.model} and 'thinking.type=enabled' is deprecated. Use 'thinking.type=adaptive' instead which results in better model performance in our testing: https://platform.claude.com/docs/en/build-with-claude/adaptive-thinking`);let $=this._client._options.timeout;if(!Y.stream&&$==null){let O=x38[Y.model]??void 0;$=this._client.calculateNonstreamingTimeout(Y.max_tokens,O)}let A=b38(Y.tools,Y.messages);return this._client.post("/v1/messages?beta=true",{body:Y,timeout:$??600000,...K,headers:b3([{...z?.toString()!=null?{"anthropic-beta":z?.toString()}:void 0},A,K?.headers]),stream:_.stream??!1})}parse(q,K){return K={...K,headers:b3([{"anthropic-beta":[...q.betas??[],"structured-outputs-2025-12-15"].toString()},K?.headers])},this.create(q,K).then((_)=>Cr8(_,q,{logger:this._client.logger??console}))}stream(q,K){return Rx6.createMessage(this,q,K)}countTokens(q,K){let _=yH7(q),{betas:z,...Y}=_;return this._client.post("/v1/messages/count_tokens?beta=true",{body:Y,...K,headers:b3([{"anthropic-beta":[...z??[],"token-counting-2024-11-01"].toString()},K?.headers])})}toolRunner(q,K){return new bx6(this._client,q,K)}};dt.Batches=xx6;dt.BetaToolRunner=bx6;dt.ToolError=nX6});var Ix6;var dr8=y(()=>{_B();zE();dX6();gt();Ix6=class Ix6 extends zH{create(q,K={},_){let{betas:z,...Y}=K??{};return this._client.post(Yj`/v1/skills/${q}/versions?beta=true`,QX6({body:Y,..._,headers:b3([{"anthropic-beta":[...z??[],"skills-2025-10-02"].toString()},_?.headers])},this._client))}retrieve(q,K,_){let{skill_id:z,betas:Y}=K;return this._client.get(Yj`/v1/skills/${z}/versions/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...Y??[],"skills-2025-10-02"].toString()},_?.headers])})}list(q,K={},_){let{betas:z,...Y}=K??{};return this._client.getAPIList(Yj`/v1/skills/${q}/versions?beta=true`,Dx6,{query:Y,..._,headers:b3([{"anthropic-beta":[...z??[],"skills-2025-10-02"].toString()},_?.headers])})}delete(q,K,_){let{skill_id:z,betas:Y}=K;return this._client.delete(Yj`/v1/skills/${z}/versions/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...Y??[],"skills-2025-10-02"].toString()},_?.headers])})}}});var oX6;var cr8=y(()=>{dr8();dr8();_B();zE();dX6();gt();oX6=class oX6 extends zH{constructor(){super(...arguments);this.versions=new Ix6(this._client)}create(q={},K){let{betas:_,...z}=q??{};return this._client.post("/v1/skills?beta=true",QX6({body:z,...K,headers:b3([{"anthropic-beta":[..._??[],"skills-2025-10-02"].toString()},K?.headers])},this._client,!1))}retrieve(q,K={},_){let{betas:z}=K??{};return this._client.get(Yj`/v1/skills/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...z??[],"skills-2025-10-02"].toString()},_?.headers])})}list(q={},K){let{betas:_,...z}=q??{};return this._client.getAPIList("/v1/skills?beta=true",Dx6,{query:z,...K,headers:b3([{"anthropic-beta":[..._??[],"skills-2025-10-02"].toString()},K?.headers])})}delete(q,K={},_){let{betas:z}=K??{};return this._client.delete(Yj`/v1/skills/${q}?beta=true`,{..._,headers:b3([{"anthropic-beta":[...z??[],"skills-2025-10-02"].toString()},_?.headers])})}};oX6.Versions=Ix6});var EZ;var lr8=y(()=>{Lr8();Lr8();Rr8();Rr8();Qr8();Qr8();cr8();cr8();EZ=class EZ extends zH{constructor(){super(...arguments);this.models=new vx6(this._client),this.messages=new dt(this._client),this.files=new Tx6(this._client),this.skills=new oX6(this._client)}};EZ.Models=vx6;EZ.Messages=dt;EZ.Files=Tx6;EZ.Skills=oX6});var ct;var nr8=y(()=>{zE();ct=class ct extends zH{create(q,K){let{betas:_,...z}=q;return this._client.post("/v1/complete",{body:z,timeout:this._client._options.timeout??600000,...K,headers:b3([{..._?.toString()!=null?{"anthropic-beta":_?.toString()}:void 0},K?.headers]),stream:q.stream??!1})}}});function EH7(q){return q?.output_config?.format}function ir8(q,K,_){let z=EH7(K);if(!K||!("parse"in(z??{})))return{...q,content:q.content.map((Y)=>{if(Y.type==="text")return Object.defineProperty({...Y},"parsed_output",{value:null,enumerable:!1});return Y}),parsed_output:null};return rr8(q,K,_)}function rr8(q,K,_){let z=null,Y=q.content.map(($)=>{if($.type==="text"){let A=Xz5(K,$.text);if(z===null)z=A;return Object.defineProperty({...$},"parsed_output",{value:A,enumerable:!1})}return $});return{...q,content:Y,parsed_output:z}}function Xz5(q,K){let _=EH7(q);if(_?.type!=="json_schema")return null;try{if("parse"in _)return _.parse(K);return JSON.parse(K)}catch(z){throw new O4(`Failed to parse structured output: ${z}`)}}var or8=y(()=>{yZ()});function SH7(q){return q.type==="tool_use"||q.type==="server_tool_use"}function CH7(q){}var eR,lt,aX6,ux6,c38,mx6,px6,l38,Bx6,Rc,gx6,n38,i38,O96,r38,o38,Fx6,ar8,LH7,sr8,tr8,er8,qo8,RH7,hH7="__json_buf",Ux6;var bH7=y(()=>{Vc();Ft();u38();xr8();or8();Ux6=class Ux6{constructor(q,K){eR.add(this),this.messages=[],this.receivedMessages=[],lt.set(this,void 0),aX6.set(this,null),this.controller=new AbortController,ux6.set(this,void 0),c38.set(this,()=>{}),mx6.set(this,()=>{}),px6.set(this,void 0),l38.set(this,()=>{}),Bx6.set(this,()=>{}),Rc.set(this,{}),gx6.set(this,!1),n38.set(this,!1),i38.set(this,!1),O96.set(this,!1),r38.set(this,void 0),o38.set(this,void 0),Fx6.set(this,void 0),sr8.set(this,(_)=>{if(A4(this,n38,!0,"f"),Nc(_))_=new V_;if(_ instanceof V_)return A4(this,i38,!0,"f"),this._emit("abort",_);if(_ instanceof O4)return this._emit("error",_);if(_ instanceof Error){let z=new O4(_.message);return z.cause=_,this._emit("error",z)}return this._emit("error",new O4(String(_)))}),A4(this,ux6,new Promise((_,z)=>{A4(this,c38,_,"f"),A4(this,mx6,z,"f")}),"f"),A4(this,px6,new Promise((_,z)=>{A4(this,l38,_,"f"),A4(this,Bx6,z,"f")}),"f"),E1(this,ux6,"f").catch(()=>{}),E1(this,px6,"f").catch(()=>{}),A4(this,aX6,q,"f"),A4(this,Fx6,K?.logger??console,"f")}get response(){return E1(this,r38,"f")}get request_id(){return E1(this,o38,"f")}async withResponse(){A4(this,O96,!0,"f");let q=await E1(this,ux6,"f");if(!q)throw Error("Could not resolve a `Response` object");return{data:this,response:q,request_id:q.headers.get("request-id")}}static fromReadableStream(q){let K=new Ux6(null);return K._run(()=>K._fromReadableStream(q)),K}static createMessage(q,K,_,{logger:z}={}){let Y=new Ux6(K,{logger:z});for(let $ of K.messages)Y._addMessageParam($);return A4(Y,aX6,{...K,stream:!0},"f"),Y._run(()=>Y._createMessage(q,{...K,stream:!0},{..._,headers:{..._?.headers,"X-Stainless-Helper-Method":"stream"}})),Y}_run(q){q().then(()=>{this._emitFinal(),this._emit("end")},E1(this,sr8,"f"))}_addMessageParam(q){this.messages.push(q)}_addMessage(q,K=!0){if(this.receivedMessages.push(q),K)this._emit("message",q)}async _createMessage(q,K,_){let z=_?.signal,Y;if(z){if(z.aborted)this.controller.abort();Y=this.controller.abort.bind(this.controller),z.addEventListener("abort",Y)}try{E1(this,eR,"m",tr8).call(this);let{response:$,data:A}=await q.create({...K,stream:!0},{..._,signal:this.controller.signal}).withResponse();this._connected($);for await(let O of A)E1(this,eR,"m",er8).call(this,O);if(A.controller.signal?.aborted)throw new V_;E1(this,eR,"m",qo8).call(this)}finally{if(z&&Y)z.removeEventListener("abort",Y)}}_connected(q){if(this.ended)return;A4(this,r38,q,"f"),A4(this,o38,q?.headers.get("request-id"),"f"),E1(this,c38,"f").call(this,q),this._emit("connect")}get ended(){return E1(this,gx6,"f")}get errored(){return E1(this,n38,"f")}get aborted(){return E1(this,i38,"f")}abort(){this.controller.abort()}on(q,K){return(E1(this,Rc,"f")[q]||(E1(this,Rc,"f")[q]=[])).push({listener:K}),this}off(q,K){let _=E1(this,Rc,"f")[q];if(!_)return this;let z=_.findIndex((Y)=>Y.listener===K);if(z>=0)_.splice(z,1);return this}once(q,K){return(E1(this,Rc,"f")[q]||(E1(this,Rc,"f")[q]=[])).push({listener:K,once:!0}),this}emitted(q){return new Promise((K,_)=>{if(A4(this,O96,!0,"f"),q!=="error")this.once("error",_);this.once(q,K)})}async done(){A4(this,O96,!0,"f"),await E1(this,px6,"f")}get currentMessage(){return E1(this,lt,"f")}async finalMessage(){return await this.done(),E1(this,eR,"m",ar8).call(this)}async finalText(){return await this.done(),E1(this,eR,"m",LH7).call(this)}_emit(q,...K){if(E1(this,gx6,"f"))return;if(q==="end")A4(this,gx6,!0,"f"),E1(this,l38,"f").call(this);let _=E1(this,Rc,"f")[q];if(_)E1(this,Rc,"f")[q]=_.filter((z)=>!z.once),_.forEach(({listener:z})=>z(...K));if(q==="abort"){let z=K[0];if(!E1(this,O96,"f")&&!_?.length)Promise.reject(z);E1(this,mx6,"f").call(this,z),E1(this,Bx6,"f").call(this,z),this._emit("end");return}if(q==="error"){let z=K[0];if(!E1(this,O96,"f")&&!_?.length)Promise.reject(z);E1(this,mx6,"f").call(this,z),E1(this,Bx6,"f").call(this,z),this._emit("end")}}_emitFinal(){if(this.receivedMessages.at(-1))this._emit("finalMessage",E1(this,eR,"m",ar8).call(this))}async _fromReadableStream(q,K){let _=K?.signal,z;if(_){if(_.aborted)this.controller.abort();z=this.controller.abort.bind(this.controller),_.addEventListener("abort",z)}try{E1(this,eR,"m",tr8).call(this),this._connected(null);let Y=RT.fromReadableStream(q,this.controller);for await(let $ of Y)E1(this,eR,"m",er8).call(this,$);if(Y.controller.signal?.aborted)throw new V_;E1(this,eR,"m",qo8).call(this)}finally{if(_&&z)_.removeEventListener("abort",z)}}[(lt=new WeakMap,aX6=new WeakMap,ux6=new WeakMap,c38=new WeakMap,mx6=new WeakMap,px6=new WeakMap,l38=new WeakMap,Bx6=new WeakMap,Rc=new WeakMap,gx6=new WeakMap,n38=new WeakMap,i38=new WeakMap,O96=new WeakMap,r38=new WeakMap,o38=new WeakMap,Fx6=new WeakMap,sr8=new WeakMap,eR=new WeakSet,ar8=function(){if(this.receivedMessages.length===0)throw new O4("stream ended without producing a Message with role=assistant");return this.receivedMessages.at(-1)},LH7=function(){if(this.receivedMessages.length===0)throw new O4("stream ended without producing a Message with role=assistant");let K=this.receivedMessages.at(-1).content.filter((_)=>_.type==="text").map((_)=>_.text);if(K.length===0)throw new O4("stream ended without producing a content block with type=text");return K.join(" ")},tr8=function(){if(this.ended)return;A4(this,lt,void 0,"f")},er8=function(K){if(this.ended)return;let _=E1(this,eR,"m",RH7).call(this,K);switch(this._emit("streamEvent",K,_),K.type){case"content_block_delta":{let z=_.content.at(-1);switch(K.delta.type){case"text_delta":{if(z.type==="text")this._emit("text",K.delta.text,z.text||"");break}case"citations_delta":{if(z.type==="text")this._emit("citation",K.delta.citation,z.citations??[]);break}case"input_json_delta":{if(SH7(z)&&z.input)this._emit("inputJson",K.delta.partial_json,z.input);break}case"thinking_delta":{if(z.type==="thinking")this._emit("thinking",K.delta.thinking,z.thinking);break}case"signature_delta":{if(z.type==="thinking")this._emit("signature",z.signature);break}default:CH7(K.delta)}break}case"message_stop":{this._addMessageParam(_),this._addMessage(ir8(_,E1(this,aX6,"f"),{logger:E1(this,Fx6,"f")}),!0);break}case"content_block_stop":{this._emit("contentBlock",_.content.at(-1));break}case"message_start":{A4(this,lt,_,"f");break}case"content_block_start":case"message_delta":break}},qo8=function(){if(this.ended)throw new O4("stream has ended, this shouldn't happen");let K=E1(this,lt,"f");if(!K)throw new O4("request ended without sending any chunks");return A4(this,lt,void 0,"f"),ir8(K,E1(this,aX6,"f"),{logger:E1(this,Fx6,"f")})},RH7=function(K){let _=E1(this,lt,"f");if(K.type==="message_start"){if(_)throw new O4(`Unexpected event order, got ${K.type} before receiving "message_stop"`);return K.message}if(!_)throw new O4(`Unexpected event order, got ${K.type} before "message_start"`);switch(K.type){case"message_stop":return _;case"message_delta":if(_.stop_reason=K.delta.stop_reason,_.stop_sequence=K.delta.stop_sequence,_.usage.output_tokens=K.usage.output_tokens,K.usage.input_tokens!=null)_.usage.input_tokens=K.usage.input_tokens;if(K.usage.cache_creation_input_tokens!=null)_.usage.cache_creation_input_tokens=K.usage.cache_creation_input_tokens;if(K.usage.cache_read_input_tokens!=null)_.usage.cache_read_input_tokens=K.usage.cache_read_input_tokens;if(K.usage.server_tool_use!=null)_.usage.server_tool_use=K.usage.server_tool_use;return _;case"content_block_start":return _.content.push({...K.content_block}),_;case"content_block_delta":{let z=_.content.at(K.index);switch(K.delta.type){case"text_delta":{if(z?.type==="text")_.content[K.index]={...z,text:(z.text||"")+K.delta.text};break}case"citations_delta":{if(z?.type==="text")_.content[K.index]={...z,citations:[...z.citations??[],K.delta.citation]};break}case"input_json_delta":{if(z&&SH7(z)){let Y=z[hH7]||"";Y+=K.delta.partial_json;let $={...z};if(Object.defineProperty($,hH7,{value:Y,enumerable:!1,writable:!0}),Y)$.input=I38(Y);_.content[K.index]=$}break}case"thinking_delta":{if(z?.type==="thinking")_.content[K.index]={...z,thinking:z.thinking+K.delta.thinking};break}case"signature_delta":{if(z?.type==="thinking")_.content[K.index]={...z,signature:K.delta.signature};break}default:CH7(K.delta)}return _}case"content_block_stop":return _}},Symbol.asyncIterator)](){let q=[],K=[],_=!1;return this.on("streamEvent",(z)=>{let Y=K.shift();if(Y)Y.resolve(z);else q.push(z)}),this.on("end",()=>{_=!0;for(let z of K)z.resolve(void 0);K.length=0}),this.on("abort",(z)=>{_=!0;for(let Y of K)Y.reject(z);K.length=0}),this.on("error",(z)=>{_=!0;for(let Y of K)Y.reject(z);K.length=0}),{next:async()=>{if(!q.length){if(_)return{value:void 0,done:!0};return new Promise((Y,$)=>K.push({resolve:Y,reject:$})).then((Y)=>Y?{value:Y,done:!1}:{value:void 0,done:!0})}return{value:q.shift(),done:!1}},return:async()=>{return this.abort(),{value:void 0,done:!0}}}}toReadableStream(){return new RT(this[Symbol.asyncIterator].bind(this),this.controller).toReadableStream()}}});var Qx6;var Ko8=y(()=>{_B();zE();Fr8();Ft();gt();Qx6=class Qx6 extends zH{create(q,K){return this._client.post("/v1/messages/batches",{body:q,...K})}retrieve(q,K){return this._client.get(Yj`/v1/messages/batches/${q}`,K)}list(q={},K){return this._client.getAPIList("/v1/messages/batches",Lx,{query:q,...K})}delete(q,K){return this._client.delete(Yj`/v1/messages/batches/${q}`,K)}cancel(q,K){return this._client.post(Yj`/v1/messages/batches/${q}/cancel`,K)}async results(q,K){let _=await this.retrieve(q);if(!_.results_url)throw new O4(`No batch \`results_url\`; Has it finished processing? ${_.processing_status} - ${_.id}`);return this._client.get(_.results_url,{...K,headers:b3([{Accept:"application/binary"},K?.headers]),stream:!0,__binaryResponse:!0})._thenUnwrap((z,Y)=>rX6.fromResponse(Y.response,Y.controller))}}});var $E,xH7,Wz5;var _o8=y(()=>{zE();Gx6();bH7();or8();Ko8();Ko8();hr8();$E=class $E extends zH{constructor(){super(...arguments);this.batches=new Qx6(this._client)}create(q,K){if(q.model in xH7)console.warn(`The model '${q.model}' is deprecated and will reach end-of-life on ${xH7[q.model]} |