| 10 | `,"\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(` |
| 11 | `),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)+` |
| 12 | `);_.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: |