Function AX

package/cli.js:348–348

(q)

`)}
${A}
${J}`)}return A},KW1;var tPq=y(()=>{oP1();aPq=Object.freeze(Object.create(null)),KW1=bS9(sPq)});function uS9(q){let K=new $E(q);return delete K.batches,delete K.countTokens,K}function mS9(q){let K=new EZ(q);return delete K.promptCaching,delete K.messages.batches,delete K.messages.countTokens,K}var xS9="bedrock-2023-05-31",IS9,_W1;var zW1=y(()=>{hc();dx6();FJq();iPq();KU6();oPq();tPq();hc();IS9=new Set(["/v1/complete","/v1/messages","/v1/messages?beta=true"]);_W1=class _W1 extends D${constructor({awsRegion:q=eP1("AWS_REGION")??"us-east-1",baseURL:K=eP1("ANTHROPIC_BEDROCK_BASE_URL")??`https://bedrock-runtime.${q}.amazonaws.com`,awsSecretKey:_=null,awsAccessKey:z=null,awsSessionToken:Y=null,providerChainResolver:$=null,...A}={}){super({baseURL:K,...A});this.skipAuth=!1,this.messages=uS9(this),this.completions=new ct(this),this.beta=mS9(this),this.awsSecretKey=_,this.awsAccessKey=z,this.awsRegion=q,this.awsSessionToken=Y,this.skipAuth=A.skipAuth??!1,this.providerChainResolver=$}validateHeaders(){}async prepareRequest(q,{url:K,options:_}){if(this.skipAuth)return;let z=this.awsRegion;if(!z)throw Error("Expected `awsRegion` option to be passed to the client or the `AWS_REGION` environment variable to be present");let Y=await gJq(q,{url:K,regionName:z,awsAccessKey:this.awsAccessKey,awsSecretKey:this.awsSecretKey,awsSessionToken:this.awsSessionToken,fetchOptions:this.fetchOptions,providerChainResolver:this.providerChainResolver});q.headers=qW1([Y,q.headers]).values}async buildRequest(q){if(q.__streamClass=dM8,FM8(q.body))q.body={...q.body};if(FM8(q.body)){if(!q.body.anthropic_version)q.body.anthropic_version=xS9;if(q.headers&&!q.body.anthropic_beta){let K=qW1([q.headers]).values.get("anthropic-beta");if(K!=null)q.body.anthropic_beta=K.split(",")}}if(IS9.has(q.path)&&q.method==="post"){if(!FM8(q.body))throw Error("Expected request body to be an object for post /v1/messages");let K=q.body.model;q.body.model=void 0;let _=q.body.stream;if(q.body.stream=void 0,_)q.path=KW1`/model/${K}/invoke-with-response-stream`;else q.path=KW1`/model/${K}/invoke`}return super.buildRequest(q)}}});var ePq={};T8(ePq,{default:()=>_W1,BaseAnthropic:()=>D$,AnthropicBedrock:()=>_W1});var qWq=y(()=>{zW1();zW1()});var cM8=y(()=>{yZ()});var YW1=(q)=>(YW1=Array.isArray,YW1(q)),$W1;var lM8=y(()=>{cM8();$W1=YW1});function*BS9(q){if(!q)return;if(KWq 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($W1(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 $=$W1(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 KWq,AW1=(q)=>{let K=new Headers,_=new Set;for(let z of q){let Y=new Set;for(let[$,A]of BS9(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{[KWq]:!0,values:K,nulls:_}};var _Wq=y(()=>{lM8();KWq=Symbol.for("brand.privateNullableHeaders")});var zWq=y(()=>{cM8()});var nM8=(q)=>{if(typeof globalThis.process<"u")return globalThis.process.env?.[q]?.trim()??void 0;if(typeof globalThis.Deno<"u")return globalThis.Deno.env?.get?.(q)?.trim();return};var YWq=y(()=>{lM8()});var $Wq=y(()=>{lM8();zWq();YWq()});function gS9(q){let K=new $E(q);return delete K.batches,K}function FS9(q){let K=new EZ(q);return delete K.messages.batches,K}var OW1;var wW1=y(()=>{_Wq();cM8();$Wq();hc();hc();dx6();OW1=class OW1 extends Rx{constructor({baseURL:q=nM8("ANTHROPIC_FOUNDRY_BASE_URL"),apiKey:K=nM8("ANTHROPIC_FOUNDRY_API_KEY"),resource:_=nM8("ANTHROPIC_FOUNDRY_RESOURCE"),azureADTokenProvider:z,dangerouslyAllowBrowser:Y,...$}={}){if(typeof z==="function")Y=!0;if(!z&&!K)throw new O4("Missing credentials. Please pass one of `apiKey` and `azureTokenProvider`, or set the `ANTHROPIC_FOUNDRY_API_KEY` environment variable.");if(z&&K)throw new O4("The `apiKey` and `azureADTokenProvider` arguments are mutually exclusive; only one can be passed at a time.");if(!q){if(!_)throw new O4("Must provide one of the `baseURL` or `resource` arguments, or the `ANTHROPIC_FOUNDRY_RESOURCE` environment variable");q=`https://${_}.services.ai.azure.com/anthropic/`}else if(_)throw new O4("baseURL and resource are mutually exclusive");super({apiKey:z??K,baseURL:q,...$,...Y!==void 0?{dangerouslyAllowBrowser:Y}:{}});this.resource=null,this.messages=gS9(this),this.beta=FS9(this),this.models=void 0}async authHeaders(){if(typeof this._options.apiKey==="function"){let q;try{q=await this._options.apiKey()}catch(K){if(K instanceof O4)throw K;throw new O4(`Failed to get token from azureADTokenProvider: ${K.message}`,{cause:K})}if(typeof q!=="string"||!q)throw new O4(`Expected azureADTokenProvider function argument to return a string but it returned ${q}`);return AW1([{Authorization:`Bearer ${q}`}])}if(typeof this._options.apiKey==="string")return AW1([{"x-api-key":this.apiKey}]);return}validateHeaders(){return}}});var AWq={};T8(AWq,{default:()=>OW1,BaseAnthropic:()=>D$,AnthropicFoundry:()=>OW1});var OWq=y(()=>{wW1();wW1()});var iM8="4.10.1",lz6="04b07795-8ddb-461a-bbee-02f9e1bf7b46",wWq="common",hg,zU6,jWq="login.microsoftonline.com",HWq,JWq="cae",MWq="nocae",XWq="msal.cache";var Sg=y(()=>{(function(q){q.AzureChina="https://login.chinacloudapi.cn",q.AzureGermany="https://login.microsoftonline.de",q.AzureGovernment="https://login.microsoftonline.us",q.AzurePublicCloud="https://login.microsoftonline.com"})(hg||(hg={}));zU6=hg.AzurePublicCloud,HWq=["*"]});function US9(q){var K,_,z,Y,$,A,O;let w={cache:{},broker:{isEnabled:(_=(K=q.brokerOptions)===null||K===void 0?void 0:K.enabled)!==null&&_!==void 0?_:!1,enableMsaPassthrough:(Y=(z=q.brokerOptions)===null||z===void 0?void 0:z.legacyEnableMsaPassthrough)!==null&&Y!==void 0?Y:!1,parentWindowHandle:($=q.brokerOptions)===null||$===void 0?void 0:$.parentWindowHandle}};if((A=q.tokenCachePersistenceOptions)===null||A===void 0?void 0:A.enabled){if(rM8===void 0)throw Error(["Persistent token caching was requested, but no persistence provider was configured.","You must install the identity-cache-persistence plugin package (`npm install --save @azure/identity-cache-persistence`)","and enable it by importing `useIdentityPlugin` from `@azure/identity` and calling","`useIdentityPlugin(cachePersistencePlugin)` before using `tokenCachePersistenceOptions`."].join(" "));let j=q.tokenCachePersistenceOptions.name||XWq;w.cache.cachePlugin=rM8(Object.assign({name:`${j}.${MWq}`},q.tokenCachePersistenceOptions)),w.cache.cachePluginCae=rM8(Object.assign({name:`${j}.${JWq}`},q.tokenCachePersistenceOptions))}if((O=q.brokerOptions)===null||O===void 0?void 0:O.enabled){if(jW1===void 0)throw Error(["Broker for WAM was requested to be enabled, but no native broker was configured.","You must install the identity-broker plugin package (`npm install --save @azure/identity-broker`)","and enable it by importing `useIdentityPlugin` from `@azure/identity` and calling","`useIdentityPlugin(createNativeBrokerPlugin())` before using `enableBroker`."].join(" "));w.broker.nativeBrokerPlugin=jW1.broker}return w}var rM8=void 0,PWq,jW1=void 0,WWq,DWq;var HW1=y(()=>{Sg();PWq={setPersistence(q){rM8=q}},WWq={setNativeBroker(q){jW1={broker:q}}};DWq={generatePluginConfiguration:US9}});import{EOL as QS9}from"node:os";import dS9 from"node:util";import*as fWq from"node:process";function ZWq(q,...K){fWq.stderr.write(`${dS9.format(q,...K)}${QS9}`)}var GWq=()=>{};function XW1(q){vWq=q,JW1=[],MW1=[];let K=/\*/g,_=q.split(",").map((z)=>z.trim().replace(K,".*?"));for(let z of _)if(z.startsWith("-"))MW1.push(new RegExp(`^${z.substr(1)}$`));else JW1.push(new RegExp(`^${z}$`));for(let z of oM8)z.enabled=PW1(z.namespace)}function PW1(q){if(q.endsWith("*"))return!0;for(let K of MW1)if(K.test(q))return!1;for(let K of JW1)if(K.test(q))return!0;return!1}function cS9(){let q=vWq||"";return XW1(""),q}function VWq(q){let K=Object.assign(_,{enabled:PW1(q),destroy:lS9,log:kWq.log,namespace:q,extend:nS9});function _(...z){if(!K.enabled)return;if(z.length>0)z[0]=`${q} ${z[0]}`;K.log(...z)}return oM8.push(K),K}function lS9(){let q=oM8.indexOf(this);if(q>=0)return oM8.splice(q,1),!0;return!1}function nS9(q){let K=VWq(`${this.namespace}:${q}`);return K.log=this.log,K}var TWq,vWq,JW1,MW1,oM8,kWq,a06;var NWq=y(()=>{GWq();TWq=typeof process<"u"&&process.env&&process.env.DEBUG||void 0,JW1=[],MW1=[],oM8=[];if(TWq)XW1(TWq);kWq=Object.assign((q)=>{return VWq(q)},{enable:XW1,enabled:PW1,disable:cS9,log:ZWq});a06=kWq});function EWq(q,K){K.log=(..._)=>{q.log(..._)}}function LWq(q){return WW1.includes(q)}function aM8(q){let K=new Set,_=typeof process<"u"&&process.env&&process.env[q.logLevelEnvVarName]||void 0,z,Y=a06(q.namespace);Y.log=(...H)=>{a06.log(...H)};function $(H){if(H&&!LWq(H))throw Error(`Unknown log level '${H}'. Acceptable values: ${WW1.join(",")}`);z=H;let J=[];for(let M of K)if(A(M))J.push(M.namespace);a06.enable(J.join(","))}if(_)if(LWq(_))$(_);else console.error(`${q.logLevelEnvVarName} set to unknown log level '${_}'; logging is not enabled. Acceptable values: ${WW1.join(", ")}.`);function A(H){return Boolean(z&&yWq[H.level]<=yWq[z])}function O(H,J){let M=Object.assign(H.extend(J),{level:J});if(EWq(H,M),A(M)){let X=a06.disable();a06.enable(X+","+M.namespace)}return K.add(M),M}function w(){return z}function j(H){let J=Y.extend(H);return EWq(Y,J),{error:O(J,"error"),warning:O(J,"warning"),info:O(J,"info"),verbose:O(J,"verbose")}}return{setLogLevel:$,getLogLevel:w,createClientLogger:j,logger:Y}}function sM8(q){return RWq.createClientLogger(q)}var WW1,yWq,RWq,co$;var tM8=y(()=>{NWq();WW1=["verbose","info","warning","error"],yWq={verbose:400,info:300,warning:200,error:100};RWq=aM8({logLevelEnvVarName:"TYPESPEC_RUNTIME_LOG_LEVEL",namespace:"typeSpecRuntime"}),co$=RWq.logger});var hWq=y(()=>{tM8()});function eM8(){return DW1.getLogLevel()}function j86(q){return DW1.createClientLogger(q)}var DW1,oo$;var nz6=y(()=>{hWq();DW1=aM8({logLevelEnvVarName:"AZURE_LOG_LEVEL",namespace:"azure"}),oo$=DW1.logger});function qX8(q){return q.reduce((K,_)=>{if(process.env[_])K.assigned.push(_);else K.missing.push(_);return K},{missing:[],assigned:[]})}function AX(q){return`SUCCESS. Scopes: ${Array.isArray(q)?q.join(", "):q}.`}function nz(q,K){let _="ERROR.";if(q===null||q===void 0?void 0:q.length)_+=` Scopes: ${Array.isArray(q)?q.join(", "):q}.`;return`${_} Error message: ${typeof K==="string"?K:K.message}.`}function SWq(q,K,_=EV){let z=K?`${K.fullTitle} ${q}`:q;function Y(w){_.info(`${z} =>`,w)}function $(w){_.warning(`${z} =>`,w)}function A(w){_.verbose(`${z} =>`,w)}function O(w){_.error(`${z} =>`,w)}return{title:q,fullTitle:z,info:Y,warning:$,verbose:A,error:O}}function T9(q,K=EV){let _=SWq(q,void 0,K);return Object.assign(Object.assign({},_),{parent:K,getToken:SWq("=> getToken()",_,K)})}var EV;var yO=y(()=>{nz6();EV=j86("identity")});function iS9(q){return q&&typeof q.error==="string"&&typeof q.error_description==="string"}function CWq(q){return{error:q.error,errorDescription:q.error_description,correlationId:q.correlation_id,errorCodes:q.error_codes,timestamp:q.timestamp,traceId:q.trace_id}}var fW1="CredentialUnavailableError",x4,YU6="AuthenticationError",pI,ZW1="AggregateAuthenticationError",$U6,BI;var ZP=y(()=>{x4=class x4 extends Error{constructor(q,K){super(q,K);this.name=fW1}};pI=class pI extends Error{constructor(q,K,_){let z={error:"unknown",errorDescription:"An unknown error occurred and no additional details are available."};if(iS9(K))z=CWq(K);else if(typeof K==="string")try{let Y=JSON.parse(K);z=CWq(Y)}catch(Y){if(q===400)z={error:"invalid_request",errorDescription:`The service indicated that the request was invalid.

${K}`};else z={error:"unknown_error",errorDescription:`An unknown error has occurred. Response body: