Function qz5

package/cli.js:12–16

(q=MH7)

`,"\r"]);Bt.NEWLINE_REGEXP=/\r\n|[\n\r]/g});function Xx6(){}function V38(q,K,_){if(!K||N38[q]>N38[_])return Xx6;else return K[q].bind(K)}function ZW(q){let K=q.logger,_=q.logLevel??"off";if(!K)return U_5;let z=zH7.get(K);if(z&&z[0]===_)return z[1];let Y={error:V38("error",K,_),warn:V38("warn",K,_),info:V38("info",K,_),debug:V38("debug",K,_)};return zH7.set(K,[_,Y]),Y}var N38,Dr8=(q,K,_)=>{if(!q)return;if(Qj7(N38,q))return q;ZW(_).warn(`${K} was set to ${JSON.stringify(q)}, expected one of ${JSON.stringify(Object.keys(N38))}`);return},U_5,zH7,yc=(q)=>{if(q.options)q.options={...q.options},delete q.options.headers;if(q.headers)q.headers=Object.fromEntries((q.headers instanceof Headers?[...q.headers]:Object.entries(q.headers)).map(([K,_])=>[K,K.toLowerCase()==="x-api-key"||K.toLowerCase()==="authorization"||K.toLowerCase()==="cookie"||K.toLowerCase()==="set-cookie"?"***":_]));if("retryOfRequestLogID"in q){if(q.retryOfRequestLogID)q.retryOf=q.retryOfRequestLogID;delete q.retryOfRequestLogID}return q};var y38=y(()=>{_96();N38={off:0,error:200,warn:300,info:400,debug:500};U_5={error:Xx6,warn:Xx6,info:Xx6,debug:Xx6},zH7=new WeakMap});async function*Q_5(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")}let _=new YH7,z=new Bt,Y=Jx6(q.body);for await(let $ of d_5(Y))for(let A of z.decode($)){let O=_.decode(A);if(O)yield O}for(let $ of z.flush()){let A=_.decode($);if(A)yield A}}async function*d_5(q){let K=new Uint8Array;for await(let _ of q){if(_==null)continue;let z=_ instanceof ArrayBuffer?new Uint8Array(_):typeof _==="string"?Mx6(_):_,Y=new Uint8Array(K.length+z.length);Y.set(K),Y.set(z,K.length),K=Y;let $;while(($=_H7(K))!==-1)yield K.slice(0,$),K=K.slice($)}if(K.length>0)yield K}class YH7{constructor(){this.event=null,this.data=[],this.chunks=[]}decode(q){if(q.endsWith("\r"))q=q.substring(0,q.length-1);if(!q){if(!this.event&&!this.data.length)return null;let Y={event:this.event,data:this.data.join(`
`),raw:this.chunks};return this.event=null,this.data=[],this.chunks=[],Y}if(this.chunks.push(q),q.startsWith(":"))return null;let[K,_,z]=c_5(q,":");if(z.startsWith(" "))z=z.substring(1);if(K==="event")this.event=z;else if(K==="data")this.data.push(z);return null}}function c_5(q,K){let _=q.indexOf(K);if(_!==-1)return[q.substring(0,_),K,q.substring(_+K.length)];return[q,"",""]}var Px6,RT;var fr8=y(()=>{Vc();yZ();Wr8();_96();y38();yZ();RT=class RT{constructor(q,K,_){this.iterator=q,Px6.set(this,void 0),this.controller=K,A4(this,Px6,_,"f")}static fromSSEResponse(q,K,_){let z=!1,Y=_?ZW(_):console;async function*$(){if(z)throw new O4("Cannot iterate over a consumed stream, use `.tee()` to split the stream.");z=!0;let A=!1;try{for await(let O of Q_5(q,K)){if(O.event==="completion")try{yield JSON.parse(O.data)}catch(w){throw Y.error("Could not parse message into JSON:",O.data),Y.error("From chunk:",O.raw),w}if(O.event==="message_start"||O.event==="message_delta"||O.event==="message_stop"||O.event==="content_block_start"||O.event==="content_block_delta"||O.event==="content_block_stop")try{yield JSON.parse(O.data)}catch(w){throw Y.error("Could not parse message into JSON:",O.data),Y.error("From chunk:",O.raw),w}if(O.event==="ping")continue;if(O.event==="error")throw new Qq(void 0,v38(O.data)??O.data,void 0,q.headers)}A=!0}catch(O){if(Nc(O))return;throw O}finally{if(!A)K.abort()}}return new RT($,K,_)}static fromReadableStream(q,K,_){let z=!1;async function*Y(){let A=new Bt,O=Jx6(q);for await(let w of O)for(let j of A.decode(w))yield j;for(let w of A.flush())yield w}async function*$(){if(z)throw new O4("Cannot iterate over a consumed stream, use `.tee()` to split the stream.");z=!0;let A=!1;try{for await(let O of Y()){if(A)continue;if(O)yield JSON.parse(O)}A=!0}catch(O){if(Nc(O))return;throw O}finally{if(!A)K.abort()}}return new RT($,K,_)}[(Px6=new WeakMap,Symbol.asyncIterator)](){return this.iterator()}tee(){let q=[],K=[],_=this.iterator(),z=(Y)=>{return{next:()=>{if(Y.length===0){let $=_.next();q.push($),K.push($)}return Y.shift()}}};return[new RT(()=>z(q),this.controller,E1(this,Px6,"f")),new RT(()=>z(K),this.controller,E1(this,Px6,"f"))]}toReadableStream(){let q=this,K;return Xr8({async start(){K=q[Symbol.asyncIterator]()},async pull(_){try{let{value:z,done:Y}=await K.next();if(Y)return _.close();let $=Mx6(JSON.stringify(z)+`
`);_.enqueue($)}catch(z){_.error(z)}},async cancel(){await K.return?.()}})}}});async function E38(q,K){let{response:_,requestLogID:z,retryOfRequestLogID:Y,startTime:$}=K,A=await(async()=>{if(K.options.stream){if(ZW(q).debug("response",_.status,_.url,_.headers,_.body),K.options.__streamClass)return K.options.__streamClass.fromSSEResponse(_,K.controller);return RT.fromSSEResponse(_,K.controller)}if(_.status===204)return null;if(K.options.__binaryResponse)return _;let w=_.headers.get("content-type")?.split(";")[0]?.trim();if(w?.includes("application/json")||w?.endsWith("+json")){if(_.headers.get("content-length")==="0")return;let M=await _.json();return Zr8(M,_)}return await _.text()})();return ZW(q).debug(`[${z}] response parsed`,yc({retryOfRequestLogID:Y,url:_.url,status:_.status,body:A,durationMs:Date.now()-$})),A}function Zr8(q,K){if(!q||typeof q!=="object"||Array.isArray(q))return q;return Object.defineProperty(q,"_request_id",{value:K.headers.get("request-id"),enumerable:!1})}var Gr8=y(()=>{fr8();y38()});var Wx6,z96;var L38=y(()=>{Vc();Gr8();z96=class z96 extends Promise{constructor(q,K,_=E38){super((z)=>{z(null)});this.responsePromise=K,this.parseResponse=_,Wx6.set(this,void 0),A4(this,Wx6,q,"f")}_thenUnwrap(q){return new z96(E1(this,Wx6,"f"),this.responsePromise,async(K,_)=>Zr8(q(await this.parseResponse(K,_),_),_.response))}asResponse(){return this.responsePromise.then((q)=>q.response)}async withResponse(){let[q,K]=await Promise.all([this.parse(),this.asResponse()]);return{data:q,response:K,request_id:K.headers.get("request-id")}}parse(){if(!this.parsedPromise)this.parsedPromise=this.responsePromise.then((q)=>this.parseResponse(E1(this,Wx6,"f"),q));return this.parsedPromise}then(q,K){return this.parse().then(q,K)}catch(q){return this.parse().catch(q)}finally(q){return this.parse().finally(q)}};Wx6=new WeakMap});var R38,Tr8,h38,Lx,Dx6;var _B=y(()=>{Vc();yZ();Gr8();L38();_96();Tr8=class Tr8{constructor(q,K,_,z){R38.set(this,void 0),A4(this,R38,q,"f"),this.options=z,this.response=K,this.body=_}hasNextPage(){if(!this.getPaginatedItems().length)return!1;return this.nextPageRequestOptions()!=null}async getNextPage(){let q=this.nextPageRequestOptions();if(!q)throw new O4("No next page expected; please check `.hasNextPage()` before calling `.getNextPage()`.");return await E1(this,R38,"f").requestAPIList(this.constructor,q)}async*iterPages(){let q=this;yield q;while(q.hasNextPage())q=await q.getNextPage(),yield q}async*[(R38=new WeakMap,Symbol.asyncIterator)](){for await(let q of this.iterPages())for(let K of q.getPaginatedItems())yield K}};h38=class h38 extends z96{constructor(q,K,_){super(q,K,async(z,Y)=>new _(z,Y.response,await E38(z,Y),Y.options))}async*[Symbol.asyncIterator](){let q=await this;for await(let K of q)yield K}};Lx=class Lx extends Tr8{constructor(q,K,_,z){super(q,K,_,z);this.data=_.data||[],this.has_more=_.has_more||!1,this.first_id=_.first_id||null,this.last_id=_.last_id||null}getPaginatedItems(){return this.data??[]}hasNextPage(){if(this.has_more===!1)return!1;return super.hasNextPage()}nextPageRequestOptions(){if(this.options.query?.before_id){let K=this.first_id;if(!K)return null;return{...this.options,query:{...T38(this.options.query),before_id:K}}}let q=this.last_id;if(!q)return null;return{...this.options,query:{...T38(this.options.query),after_id:q}}}};Dx6=class Dx6 extends Tr8{constructor(q,K,_,z){super(q,K,_,z);this.data=_.data||[],this.has_more=_.has_more||!1,this.next_page=_.next_page||null}getPaginatedItems(){return this.data??[]}hasNextPage(){if(this.has_more===!1)return!1;return super.hasNextPage()}nextPageRequestOptions(){let q=this.next_page;if(!q)return null;return{...this.options,query:{...T38(this.options.query),page:q}}}}});function Y96(q,K,_){return kr8(),new File(q,K??"unknown_file",_)}function fx6(q,K){let _=typeof q==="object"&&q!==null&&(("name"in q)&&q.name&&String(q.name)||("url"in q)&&q.url&&String(q.url)||("filename"in q)&&q.filename&&String(q.filename)||("path"in q)&&q.path&&String(q.path))||"";return K?_.split(/[\\/]/).pop()||void 0:_}function n_5(q){let K=typeof q==="function"?q:q.fetch,_=$H7.get(K);if(_)return _;let z=(async()=>{try{let Y="Response"in K?K.Response:(await K("data:,")).constructor,$=new FormData;if($.toString()===await new Y($).text())return!1;return!0}catch{return!0}})();return $H7.set(K,z),z}var kr8=()=>{if(typeof File>"u"){let{process:q}=globalThis,K=typeof q?.versions?.node==="string"&&parseInt(q.versions.node.split("."))<20;throw Error("`File` is not defined as a global, which is required for file uploads."+(K?" Update to Node 20 LTS or newer, or set `globalThis.File` to `import('node:buffer').File`.":""))}},Vr8=(q)=>q!=null&&typeof q==="object"&&typeof q[Symbol.asyncIterator]==="function",QX6=async(q,K,_=!0)=>{return{...q,body:await i_5(q.body,K,_)}},$H7,i_5=async(q,K,_=!0)=>{if(!await n_5(K))throw TypeError("The provided fetch function does not support file uploads with the current global FormData class.");let z=new FormData;return await Promise.all(Object.entries(q||{}).map(([Y,$])=>vr8(z,Y,$,_))),z},r_5=(q)=>q instanceof Blob&&("name"in q),vr8=async(q,K,_,z)=>{if(_===void 0)return;if(_==null)throw TypeError(`Received null for "${K}"; to pass null in FormData, you must use the string 'null'`);if(typeof _==="string"||typeof _==="number"||typeof _==="boolean")q.append(K,String(_));else if(_ instanceof Response){let Y={},$=_.headers.get("Content-Type");if($)Y={type:$};q.append(K,Y96([await _.blob()],fx6(_,z),Y))}else if(Vr8(_))q.append(K,Y96([await new Response(k38(_)).blob()],fx6(_,z)));else if(r_5(_))q.append(K,Y96([_],fx6(_,z),{type:_.type}));else if(Array.isArray(_))await Promise.all(_.map((Y)=>vr8(q,K+"[]",Y,z)));else if(typeof _==="object")await Promise.all(Object.entries(_).map(([Y,$])=>vr8(q,`${K}[${Y}]`,$,z)));else throw TypeError(`Invalid value given to form, expected a string, number, boolean, object, Array, File or Blob but got ${_} instead`)};var dX6=y(()=>{$H7=new WeakMap});async function S38(q,K,_){if(kr8(),q=await q,K||(K=fx6(q,!0)),o_5(q)){if(q instanceof File&&K==null&&_==null)return q;return Y96([await q.arrayBuffer()],K??q.name,{type:q.type,lastModified:q.lastModified,..._})}if(a_5(q)){let Y=await q.blob();return K||(K=new URL(q.url).pathname.split(/[\\/]/).pop()),Y96(await Nr8(Y),K,_)}let z=await Nr8(q);if(!_?.type){let Y=z.find(($)=>typeof $==="object"&&("type"in $)&&$.type);if(typeof Y==="string")_={..._,type:Y}}return Y96(z,K,_)}async function Nr8(q){let K=[];if(typeof q==="string"||ArrayBuffer.isView(q)||q instanceof ArrayBuffer)K.push(q);else if(AH7(q))K.push(q instanceof Blob?q:await q.arrayBuffer());else if(Vr8(q))for await(let _ of q)K.push(...await Nr8(_));else{let _=q?.constructor?.name;throw Error(`Unexpected data type: ${typeof q}${_?`; constructor: ${_}`:""}${s_5(q)}`)}return K}function s_5(q){if(typeof q!=="object"||q===null)return"";return`; props: [${Object.getOwnPropertyNames(q).map((_)=>`"${_}"`).join(", ")}]`}var AH7=(q)=>q!=null&&typeof q==="object"&&typeof q.size==="number"&&typeof q.type==="string"&&typeof q.text==="function"&&typeof q.slice==="function"&&typeof q.arrayBuffer==="function",o_5=(q)=>q!=null&&typeof q==="object"&&typeof q.name==="string"&&typeof q.lastModified==="number"&&AH7(q),a_5=(q)=>q!=null&&typeof q==="object"&&typeof q.url==="string"&&typeof q.blob==="function";var OH7=y(()=>{dX6();dX6()});var yr8=y(()=>{OH7()});var wH7=()=>{};class zH{constructor(q){this._client=q}}function*e_5(q){if(!q)return;if(jH7 in q){let{values:z,nulls:Y}=q;yield*z.entries();for(let $ of Y)yield[$,null];return}let K=!1,_;if(q instanceof Headers)_=q.entries();else if(Jr8(q))_=q;else K=!0,_=Object.entries(q??{});for(let z of _){let Y=z[0];if(typeof Y!=="string")throw TypeError("expected header name to be a string");let $=Jr8(z[1])?z[1]:[z[1]],A=!1;for(let O of $){if(O===void 0)continue;if(K&&!A)A=!0,yield[Y,null];yield[Y,O]}}}var jH7,b3=(q)=>{let K=new Headers,_=new Set;for(let z of q){let Y=new Set;for(let[$,A]of e_5(z)){let O=$.toLowerCase();if(!Y.has(O))K.delete($),Y.add(O);if(A===null)K.delete($),_.add(O);else K.append($,A),_.delete(O)}}return{[jH7]:!0,values:K,nulls:_}};var zE=y(()=>{_96();jH7=Symbol.for("brand.privateNullableHeaders")});function C38(q){return typeof q==="object"&&q!==null&&Zx6 in q}function Er8(q,K){let _=new Set;if(q){for(let z of q)if(C38(z))_.add(z[Zx6])}if(K)for(let z of K){if(C38(z))_.add(z[Zx6]);if(Array.isArray(z.content)){for(let Y of z.content)if(C38(Y))_.add(Y[Zx6])}}return Array.from(_)}function b38(q,K){let _=Er8(q,K);if(_.length===0)return{};return{"x-stainless-helper":_.join(", ")}}function HH7(q){if(C38(q))return{"x-stainless-helper":q[Zx6]};return{}}var Zx6;var Gx6=y(()=>{Zx6=Symbol("anthropic.sdk.stainlessHelper")});function MH7(q){return q.replace(/[^A-Za-z0-9\-._~!$&'()*+,;=:@]+/g,encodeURIComponent)}var JH7,qz5=(q=MH7)=>function(_,...z){if(_.length===1)return _[0];let Y=!1,$=[],A=_.reduce((H,J,M)=>{if(/[?#]/.test(J))Y=!0;let X=z[M],P=(Y?encodeURIComponent:q)(""+X);if(M!==z.length&&(X==null||typeof X==="object"&&X.toString===Object.getPrototypeOf(Object.getPrototypeOf(X.hasOwnProperty??JH7)??JH7)?.toString))P=X+"",$.push({start:H.length+J.length,length:P.length,error:`Value of type ${Object.prototype.toString.call(X).slice(8,-1)} is not a valid path parameter`});return H+J+(M===z.length?"":P)},""),O=A.split(/[?#]/,1)[0],w=/(?<=^|\/)(?:\.|%2e){1,2}(?=\/|$)/gi,j;while((j=w.exec(O))!==null)$.push({start:j.index,length:j[0].length,error:`Value "${j[0]}" can't be safely passed as a path parameter`});if($.sort((H,J)=>H.start-J.start),$.length>0){let H=0,J=$.reduce((M,X)=>{let P=" ".repeat(X.start-H),W="^".repeat(X.length);return H=X.start+X.length,M+P+W},"");throw new O4(`Path parameters result in path with invalid segments:
${$.map((M)=>M.error).join(`
`)}
${A}
${J}`)}return A},Yj;var gt=y(()=>{yZ();JH7=Object.freeze(Object.create(null)),Yj=qz5(MH7)});var Tx6;var Lr8=y(()=>{_B();zE();Gx6();dX6();gt();Tx6=class Tx6 extends zH{list(q={},K){let{betas:_,...z}=q??{};return this._client.getAPIList("/v1/files",Lx,{query:z,...K,headers:b3([{"anthropic-beta":[..._??[],"files-api-2025-04-14"].toString()},K?.headers])})}delete(q,K={},_){let{betas:z}=K??{};return this._client.delete(Yj`/v1/files/${q}`,{..._,headers:b3([{"anthropic-beta":[...z??[],"files-api-2025-04-14"].toString()},_?.headers])})}download(q,K={},_){let{betas:z}=K??{};return this._client.get(Yj`/v1/files/${q}/content`,{..._,headers:b3([{"anthropic-beta":[...z??[],"files-api-2025-04-14"].toString(),Accept:"application/binary"},_?.headers]),__binaryResponse:!0})}retrieveMetadata(q,K={},_){let{betas:z}=K??{};return this._client.get(Yj`/v1/files/${q}`,{..._,headers:b3([{"anthropic-beta":[...z??[],"files-api-2025-04-14"].toString()},_?.headers])})}upload(q,K){let{betas:_,...z}=q;return this._client.post("/v1/files",QX6({body:z,...K,headers:b3([{"anthropic-beta":[..._??[],"files-api-2025-04-14"].toString()},HH7(z.file),K?.headers])},this._client))}}});var vx6;var Rr8=y(()=>{_B();zE();gt();vx6=class vx6 extends zH{retrieve(q,K={},_){let{betas:z}=K??{};return this._client.get(Yj`/v1/models/${q}?beta=true`,{..._,headers:b3([{...z?.toString()!=null?{"anthropic-beta":z?.toString()}:void 0},_?.headers])})}list(q={},K){let{betas:_,...z}=q??{};return this._client.getAPIList("/v1/models?beta=true",Lx,{query:z,...K,headers:b3([{..._?.toString()!=null?{"anthropic-beta":_?.toString()}:void 0},K?.headers])})}}});var Ft=y(()=>{yZ()});var x38;var hr8=y(()=>{x38={"claude-opus-4-20250514":8192,"claude-opus-4-0":8192,"claude-4-opus-20250514":8192,"anthropic.claude-opus-4-20250514-v1:0":8192,"claude-opus-4@20250514":8192,"claude-opus-4-1-20250805":8192,"anthropic.claude-opus-4-1-20250805-v1:0":8192,"claude-opus-4-1@20250805":8192}});function XH7(q){return q?.output_format??q?.output_config?.format}function Sr8(q,K,_){let z=XH7(K);if(!K||!("parse"in(z??{})))return{...q,content:q.content.map((Y)=>{if(Y.type==="text"){let $=Object.defineProperty({...Y},"parsed_output",{value:null,enumerable:!1});return Object.defineProperty($,"parsed",{get(){return _.logger.warn("The `parsed` property on `text` blocks is deprecated, please use `parsed_output` instead."),null},enumerable:!1})}return Y}),parsed_output:null};return Cr8(q,K,_)}function Cr8(q,K,_){let z=null,Y=q.content.map(($)=>{if($.type==="text"){let A=zz5(K,$.text);if(z===null)z=A;let O=Object.defineProperty({...$},"parsed_output",{value:A,enumerable:!1});return Object.defineProperty(O,"parsed",{get(){return _.logger.warn("The `parsed` property on `text` blocks is deprecated, please use `parsed_output` instead."),A},enumerable:!1})}return $});return{...q,content:Y,parsed_output:z}}function zz5(q,K){let _=XH7(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 br8=y(()=>{yZ()});var Yz5=(q)=>{let K=0,_=[];while(K<q.length){let z=q[K];if(z==="\\"){K++;continue}if(z==="{"){_.push({type:"brace",value:"{"}),K++;continue}if(z==="}"){_.push({type:"brace",value:"}"}),K++;continue}if(z==="["){_.push({type:"paren",value:"["}),K++;continue}if(z==="]"){_.push({type:"paren",value:"]"}),K++;continue}if(z===":"){_.push({type:"separator",value:":"}),K++;continue}if(z===","){_.push({type:"delimiter",value:","}),K++;continue}if(z==='"'){let O="",w=!1;z=q[++K];while(z!=='"'){if(K===q.length){w=!0;break}if(z==="\\"){if(K++,K===q.length){w=!0;break}O+=z+q[K],z=q[++K]}else O+=z,z=q[++K]}if(z=q[++K],!w)_.push({type:"string",value:O});continue}if(z&&/\s/.test(z)){K++;continue}let $=/[0-9]/;if(z&&$.test(z)||z==="-"||z==="."){let O="";if(z==="-")O+=z,z=q[++K];while(z&&$.test(z)||z===".")O+=z,z=q[++K];_.push({type:"number",value:O});continue}let A=/[a-z]/i;if(z&&A.test(z)){let O="";while(z&&A.test(z)){if(K===q.length)break;O+=z,z=q[++K]}if(O=="true"||O=="false"||O==="null")_.push({type:"name",value:O});else{K++;continue}continue}K++}return _},cX6=(q)=>{if(q.length===0)return q;let K=q[q.length-1];switch(K.type){case"separator":return q=q.slice(0,q.length-1),cX6(q);break;case"number":let _=K.value[K.value.length-1];if(_==="."||_==="-")return q=q.slice(0,q.length-1),cX6(q);case"string":let z=q[q.length-2];if(z?.type==="delimiter")return q=q.slice(0,q.length-1),cX6(q);else if(z?.type==="brace"&&z.value==="{")return q=q.slice(0,q.length-1),cX6(q);break;case"delimiter":return q=q.slice(0,q.length-1),cX6(q);break}return q},$z5=(q)=>{let K=[];if(q.map((_)=>{if(_.type==="brace")if(_.value==="{")K.push("}");else K.splice(K.lastIndexOf("}"),1);if(_.type==="paren")if(_.value==="[")K.push("]");else K.splice(K.lastIndexOf("]"),1)}),K.length>0)K.reverse().map((_)=>{if(_==="}")q.push({type:"brace",value:"}"});else if(_==="]")q.push({type:"paren",value:"]"})});return q},Az5=(q)=>{let K="";return q.map((_)=>{switch(_.type){case"string":K+='"'+_.value+'"';break;default:K+=_.value;break}}),K},I38=(q)=>JSON.parse(Az5($z5(cX6(Yz5(q)))));var xr8=()=>{};var u38=y(()=>{fr8()});function fH7(q){return q.type==="tool_use"||q.type==="server_tool_use"||q.type==="mcp_tool_use"}function ZH7(q){}var tR,Ut,lX6,kx6,m38,Vx6,Nx6,p38,yx6,Ec,Ex6,B38,g38,$96,F38,U38,Lx6,Ir8,PH7,Q38,ur8,mr8,pr8,WH7,DH7="__json_buf",Rx6;var GH7=y(()=>{Vc();xr8();Ft();u38();br8();Rx6=class Rx6{constructor(q,K){tR.add(this),this.messages=[],this.receivedMessages=[],Ut.set(this,void 0),lX6.set(this,null),this.controller=new AbortController,kx6.set(this,void 0),m38.set(this,()=>{}),Vx6.set(this,()=>{}),Nx6.set(this,void 0),p38.set(this,()=>{}),yx6.set(this,()=>{}),Ec.set(this,{}),Ex6.set(this,!1),B38.set(this,!1),g38.set(this,!1),$96.set(this,!1),F38.set(this,void 0),U38.set(this,void 0),Lx6.set(this,void 0),Q38.set(this,(_)=>{if(A4(this,B38,!0,"f"),Nc(_))_=new V_;if(_ instanceof V_)return A4(this,g38,!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,kx6,new Promise((_,z)=>{A4(this,m38,_,"f"),A4(this,Vx6,z,"f")}),"f"),A4(this,Nx6,new Promise((_,z)=>{A4(this,p38,_,"f"),A4(this,yx6,z,"f")}),"f"),E1(this,kx6,"f").catch(()=>{}),E1(this,Nx6,"f").catch(()=>{}),A4(this,lX6,q,"f"),A4(this,Lx6,K?.logger??console,"f")}get response(){return E1(this,F38,"f")}get request_id(){return E1(this,U38,"f")}async withResponse(){A4(this,$96,!0,"f");let q=await E1(this,kx6,"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 Rx6(null);return K._run(()=>K._fromReadableStream(q)),K}static createMessage(q,K,_,{logger:z}={}){let Y=new Rx6(K,{logger:z});for(let $ of K.messages)Y._addMessageParam($);return A4(Y,lX6,{...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,Q38,"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,tR,"m",ur8).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,tR,"m",mr8).call(this,O);if(A.controller.signal?.aborted)throw new V_;E1(this,tR,"m",pr8).call(this)}finally{if(z&&Y)z.removeEventListener("abort",Y)}}_connected(q){if(this.ended)return;A4(this,F38,q,"f"),A4(this,U38,q?.headers.get("request-id"),"f"),E1(this,m38,"f").call(this,q),this._emit("connect")}get ended(){return E1(this,Ex6,"f")}get errored(){return E1(this,B38,"f")}get aborted(){return E1(this,g38,"f")}abort(){this.controller.abort()}on(q,K){return(E1(this,Ec,"f")[q]||(E1(this,Ec,"f")[q]=[])).push({listener:K}),this}off(q,K){let _=E1(this,Ec,"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,Ec,"f")[q]||(E1(this,Ec,"f")[q]=[])).push({listener:K,once:!0}),this}emitted(q){return new Promise((K,_)=>{if(A4(this,$96,!0,"f"),q!=="error")this.once("error",_);this.once(q,K)})}async done(){A4(this,$96,!0,"f"),await E1(this,Nx6,"f")}get currentMessage(){return E1(this,Ut,"f")}async finalMessage(){return await this.done(),E1(this,tR,"m",Ir8).call(this)}async finalText(){return await this.done(),E1(this,tR,"m",PH7).call(this)}_emit(q,...K){if(E1(this,Ex6,"f"))return;if(q==="end")A4(this,Ex6,!0,"f"),E1(this,p38,"f").call(this);let _=E1(this,Ec,"f")[q];if(_)E1(this,Ec,"f")[q]=_.filter((z)=>!z.once),_.forEach(({listener:z})=>z(...K));if(q==="abort"){let z=K[0];if(!E1(this,$96,"f")&&!_?.length)Promise.reject(z);E1(this,Vx6,"f").call(this,z),E1(this,yx6,"f").call(this,z),this._emit("end");return}if(q==="error"){let z=K[0];if(!E1(this,$96,"f")&&!_?.length)Promise.reject(z);E1(this,Vx6,"f").call(this,z),E1(this,yx6,"f").call(this,z),this._emit("end")}}_emitFinal(){if(this.receivedMessages.at(-1))this._emit("finalMessage",E1(this,tR,"m",Ir8).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,tR,"m",ur8).call(this),this._connected(null);let Y=RT.fromReadableStream(q,this.controller);for await(let $ of Y)E1(this,tR,"m",mr8).call(this,$);if(Y.controller.signal?.aborted)throw new V_;E1(this,tR,"m",pr8).call(this)}finally{if(_&&z)_.removeEventListener("abort",z)}}[(Ut=new WeakMap,lX6=new WeakMap,kx6=new WeakMap,m38=new WeakMap,Vx6=new WeakMap,Nx6=new WeakMap,p38=new WeakMap,yx6=new WeakMap,Ec=new WeakMap,Ex6=new WeakMap,B38=new WeakMap,g38=new WeakMap,$96=new WeakMap,F38=new WeakMap,U38=new WeakMap,Lx6=new WeakMap,Q38=new WeakMap,tR=new WeakSet,Ir8=function(){if(this.receivedMessages.length===0)throw new O4("stream ended without producing a Message with role=assistant");return this.receivedMessages.at(-1)},PH7=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(" ")},ur8=function(){if(this.ended)return;A4(this,Ut,void 0,"f")},mr8=function(K){if(this.ended)return;let _=E1(this,tR,"m",WH7).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(fH7(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}case"compaction_delta":{if(z.type==="compaction"&&z.content)this._emit("compaction",z.content);break}default:ZH7(K.delta)}break}case"message_stop":{this._addMessageParam(_),this._addMessage(Sr8(_,E1(this,lX6,"f"),{logger:E1(this,Lx6,"f")}),!0);break}case"content_block_stop":{this._emit("contentBlock",_.content.at(-1));break}case"message_start":{A4(this,Ut,_,"f");break}case"content_block_start":case"message_delta":break}},pr8=function(){if(this.ended)throw new O4("stream has ended, this shouldn't happen");let K=E1(this,Ut,"f");if(!K)throw new O4("request ended without sending any chunks");return A4(this,Ut,void 0,"f"),Sr8(K,E1(this,lX6,"f"),{logger:E1(this,Lx6,"f")})},WH7=function(K){let _=E1(this,Ut,"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(_.container=K.delta.container,_.stop_reason=K.delta.stop_reason,_.stop_sequence=K.delta.stop_sequence,_.usage.output_tokens=K.usage.output_tokens,_.context_management=K.context_management,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;if(K.usage.iterations!=null)_.usage.iterations=K.usage.iterations;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&&fH7(z)){let Y=z[DH7]||"";Y+=K.delta.partial_json;let $={...z};if(Object.defineProperty($,DH7,{value:Y,enumerable:!1,writable:!0}),Y)try{$.input=I38(Y)}catch(A){let O=new O4(`Unable to parse tool parameter JSON from model. Please retry your request or adjust your prompt. Error: ${A}. JSON: ${Y}`);E1(this,Q38,"f").call(this,O)}_.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}case"compaction_delta":{if(z?.type==="compaction")_.content[K.index]={...z,content:(z.content||"")+K.delta.content};break}default:ZH7(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 nX6;var d38=y(()=>{nX6=class nX6 extends Error{constructor(q){let K=typeof q==="string"?q:q.map((_)=>{if(_.type==="text")return _.text;return`[${_.type}]`}).join(" ");super(K);this.name="ToolError",this.content=q}}});var TH7=1e5,vH7=`You have been working on the task described above but have not yet completed it. Write a continuation summary that will allow you (or another instance of yourself) to resume work efficiently in a future context window where the conversation history will be replaced with this summary. Your summary should be structured, concise, and actionable. Include:
1. Task Overview
The user's core request and success criteria
Any clarifications or constraints they specified