MCPcopy Index your code
hub / github.com/ChinaSiro/claude-code-sourcemap / AI4

Function AI4

package/cli.js:2044–2044  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

2042`),await uF1();else bc(`
2043[ACTION REQUIRED] An update to our Consumer Terms and Privacy Policy has taken effect on October 8, 2025. You must run \`claude\` to review the updated terms.
2044
2045`),await xK(1)}}var px4=86400000,Hm,K46;var lN6=y(()=>{CK();F4();k8();G7();_8();RA();H3();V1();jG();E8();Hm=_1(async()=>{if(iA())return{success:!1};try{return{success:!0,data:(await Ki(()=>{let K=DJ();if(K.error)throw Error(`Failed to get auth headers: ${K.error}`);return $1.get(`${u7().BASE_API_URL}/api/oauth/account/settings`,{headers:{...K.headers,"User-Agent":n$()}})})).data}}catch(q){return H6(q),Hm.cache.clear?.(),{success:!1}}});K46=_1(async()=>{if(iA())return{success:!1};try{let q=await Ki(()=>{let $=DJ();if($.error)throw Error(`Failed to get auth headers: ${$.error}`);return $1.get(`${u7().BASE_API_URL}/api/claude_code_grove`,{headers:{...$.headers,"User-Agent":hS()},timeout:3000})}),{grove_enabled:K,domain_excluded:_,notice_is_grace_period:z,notice_reminder_frequency:Y}=q.data;return{success:!0,data:{grove_enabled:K,domain_excluded:_??!1,notice_is_grace_period:z??!0,notice_reminder_frequency:Y}}}catch(q){return N(`Failed to fetch Grove notice config: ${q}`),{success:!1}}})});var pF1;var gx4=y(()=>{x7();pF1=B6(()=>L.object({restrictions:L.record(L.string(),L.object({allowed:L.boolean()}))}))});var dF1={};T8(dF1,{waitForPolicyLimitsToLoad:()=>_s6,stopBackgroundPolling:()=>cL8,startBackgroundPolling:()=>dx4,refreshPolicyLimits:()=>zs6,loadPolicyLimits:()=>QF1,isPolicyLimitsEligible:()=>Jm,isPolicyAllowed:()=>OO,initializePolicyLimitsLoadingPromise:()=>FF1,clearPolicyLimitsCache:()=>dL8,_resetPolicyLimitsForTesting:()=>BMz});import{createHash as hMz}from"crypto";import{readFileSync as SMz}from"fs";import{unlink as Ux4,writeFile as CMz}from"fs/promises";import{join as bMz}from"path";function xMz(q){return q instanceof Error}function BMz(){cL8(),IN=null,_46=null,QU=null}function FF1(){if(_46)return;if(Jm())_46=new Promise((q)=>{QU=q,setTimeout(()=>{if(QU)N("Policy limits: Loading promise timed out, resolving anyway"),QU(),QU=null},pMz)})}function QL8(){return bMz(c1(),IMz)}function gMz(){return`${u7().BASE_API_URL}/api/claude_code/policy_limits`}function gF1(q){if(Array.isArray(q))return q.map(gF1);if(q!==null&&typeof q==="object"){let K={};for(let[_,z]of Object.entries(q).sort(([Y],[$])=>Y.localeCompare($)))K[_]=gF1(z);return K}return q}function FMz(q){let K=gF1(q),_=g6(K);return`sha256:${hMz("sha256").update(_).digest("hex")}`}function Jm(){if(E7()!=="firstParty")return!1;if(!WP())return!1;try{let{key:K}=Ow({skipRetrievingKeyFromApiKeyHelper:!0});if(K)return!0}catch{}let q=Kq();if(!q?.accessToken)return!1;if(!q.scopes?.includes(Mh))return!1;if(q.subscriptionType!=="enterprise"&&q.subscriptionType!=="team")return!1;return!0}async function _s6(){if(_46)await _46}function UMz(){try{let{key:K}=Ow({skipRetrievingKeyFromApiKeyHelper:!0});if(K)return{headers:{"x-api-key":K}}}catch{}let q=Kq();if(q?.accessToken)return{headers:{Authorization:`Bearer ${q.accessToken}`,"anthropic-beta":rM}};return{headers:{},error:"No authentication available"}}async function QMz(q){let K=null;for(let _=1;_<=BF1+1;_++){if(K=await dMz(q),K.success)return K;if(K.skipRetry)return K;if(_>BF1)return K;let z=hC(_);N(`Policy limits: Retry ${_}/${BF1} after ${z}ms`),await R7(z)}return K}async function dMz(q){try{await k$();let K=UMz();if(K.error)return{success:!1,error:"Authentication required for policy limits",skipRetry:!0};let _=gMz(),z={...K.headers,"User-Agent":n$()};if(q)z["If-None-Match"]=`"${q}"`;let Y=await $1.get(_,{headers:z,timeout:uMz,validateStatus:(A)=>A===200||A===304||A===404});if(Y.status===304)return N("Policy limits: Using cached restrictions (304)"),{success:!0,restrictions:null,etag:q};if(Y.status===404)return N("Policy limits: No restrictions found (404)"),{success:!0,restrictions:{},etag:void 0};let $=pF1().safeParse(Y.data);if(!$.success)return N(`Policy limits: Invalid response format - ${$.error.message}`),{success:!1,error:"Invalid policy limits format"};return N("Policy limits: Fetched successfully"),{success:!0,restrictions:$.data.restrictions}}catch(K){let{kind:_,message:z}=Sc(K);switch(_){case"auth":return{success:!1,error:"Not authorized for policy limits",skipRetry:!0};case"timeout":return{success:!1,error:"Policy limits request timeout"};case"network":return{success:!1,error:"Cannot connect to server"};default:return{success:!1,error:z}}}}function Qx4(){try{let q=SMz(QL8(),"utf-8"),K=m5(q,!1),_=pF1().safeParse(K);if(!_.success)return null;return _.data.restrictions}catch{return null}}async function cMz(q){try{let K=QL8();await CMz(K,g6({restrictions:q},null,2),{encoding:"utf-8",mode:384}),N(`Policy limits: Saved to ${K}`)}catch(K){N(`Policy limits: Failed to save - ${K instanceof Error?K.message:"unknown error"}`)}}async function UF1(){if(!Jm())return null;let q=Qx4(),K=q?FMz(q):void 0;try{let _=await QMz(K);if(!_.success){if(q)return N("Policy limits: Using stale cache after fetch failure"),IN=q,q;return null}if(_.restrictions===null&&q)return N("Policy limits: Cache still valid (304 Not Modified)"),IN=q,q;let z=_.restrictions||{};if(Object.keys(z).length>0)return IN=z,await cMz(z),N("Policy limits: Applied new restrictions successfully"),z;IN=z;try{await Ux4(QL8()),N("Policy limits: Deleted cached file (404 response)")}catch($){if(xMz($)&&$.code!=="ENOENT")N(`Policy limits: Failed to delete cached file - ${$.message}`)}return z}catch{if(q)return N("Policy limits: Using stale cache after error"),IN=q,q;return null}}function OO(q){let K=nMz();if(!K){if(iA()&&lMz.has(q))return!1;return!0}let _=K[q];if(!_)return!0;return _.allowed}function nMz(){if(!Jm())return null;if(IN)return IN;let q=Qx4();if(q)return IN=q,q;return null}async function QF1(){if(Jm()&&!_46)_46=new Promise((q)=>{QU=q});try{if(await UF1(),Jm())dx4()}finally{if(QU)QU(),QU=null}}async function zs6(){if(await dL8(),!Jm())return;await UF1(),N("Policy limits: Refreshed after auth change")}async function dL8(){cL8(),IN=null,_46=null,QU=null;try{await Ux4(QL8())}catch{}}async function iMz(){if(!Jm())return;let q=IN?g6(IN):null;try{if(await UF1(),(IN?g6(IN):null)!==q)N("Policy limits: Changed during background poll")}catch{}}function dx4(){if(nN6!==null)return;if(!Jm())return;if(nN6=setInterval(()=>{iMz()},mMz),nN6.unref(),!Fx4)Fx4=!0,pq(async()=>cL8())}function cL8(){if(nN6!==null)clearInterval(nN6),nN6=null}var IMz="policy-limits.json",uMz=1e4,BF1=5,mMz=3600000,nN6=null,Fx4=!1,_46=null,QU=null,pMz=30000,IN=null,lMz;var ZD=y(()=>{CK();H3();G7();c9();_8();m8();y8();vO();Az();l8();Wr();gx4();lMz=new Set(["allow_product_feedback"])});import{isDeepStrictEqual as rMz}from"util";function cx4({isDisabled:q=!1,visibleOptionCount:K=5,options:_,defaultValue:z=[],onChange:Y,onCancel:$,onFocus:A,focusValue:O,submitButtonText:w,onSubmit:j,onDownFromLastItem:H,onUpFromFirstItem:J,initialFocusLast:M,hideIndexes:X=!1}){let[P,W]=z46.useState(z),[D,f]=z46.useState(!1),[G,Z]=z46.useState(_);if(_!==G&&!rMz(_,G))W(z),Z(_);let[T,v]=z46.useState(()=>{let R=new Map;return _.forEach((x)=>{if(x.type==="input"&&x.initialValue)R.set(x.value,x.initialValue)}),R}),V=z46.useCallback((R)=>{let x=typeof R==="function"?R(P):R;W(x),Y?.(x)},[P,Y]),E=sE8({visibleOptionCount:K,options:_,initialFocusValue:M?_[_.length-1]?.value:void 0,onFocus:A,focusValue:O});yJ("multi-select");let S=z46.useCallback((R,x)=>{v((B)=>{let p=new Map(B);return p.set(R,x),p});let I=_.find((B)=>B.value===R);if(I&&I.type==="input")I.onChange(x);V((B)=>{if(x){if(!B.includes(R))return[...B,R];return B}else return B.filter((p)=>p!==R)})},[_,V]);return k4((R,x,I)=>{let B=T_6(R),C=_.find((F)=>F.value===E.focusedValue)?.type==="input";if(C){if(!(x.upArrow||x.downArrow||x.escape||x.tab||x.return||x.ctrl&&(R==="n"||R==="p"||x.return)))return}let g=_[_.length-1]?.value;if(x.tab&&!x.shift){if(w&&j&&E.focusedValue===g&&!D)f(!0);else if(!D)E.focusNextOption();return}if(x.tab&&x.shift){if(w&&j&&D)f(!1),E.focusOption(g);else E.focusPreviousOption();return}if(x.downArrow||x.ctrl&&R==="n"||!x.ctrl&&!x.shift&&R==="j"){if(D&&H)H();else if(w&&j&&E.focusedValue===g&&!D)f(!0);else if(!w&&H&&E.focusedValue===g)H();else if(!D)E.focusNextOption();return}if(x.upArrow||x.ctrl&&R==="p"||!x.ctrl&&!x.shift&&R==="k"){if(w&&j&&D)f(!1),E.focusOption(g);else if(J&&E.focusedValue===_[0]?.value)J();else E.focusPreviousOption();return}if(x.pageDown){E.focusNextPage();return}if(x.pageUp){E.focusPreviousPage();return}if(x.return||v_6(R)===" "){if(x.ctrl&&x.return&&C&&j){j(P);return}if(D&&j){j(P);return}if(x.return&&!w&&j){j(P);return}if(E.focusedValue!==void 0){let F=P.includes(E.focusedValue)?P.filter((U)=>U!==E.focusedValue):[...P,E.focusedValue];V(F)}return}if(!X&&/^[0-9]+$/.test(B)){let F=parseInt(B)-1;if(F>=0&&F<_.length){let U=_[F].value,c=P.includes(U)?P.filter((K6)=>K6!==U):[...P,U];V(c)}return}if(x.escape)$(),I.stopImmediatePropagation()},{isActive:!q}),{...E,selectedValues:P,inputValues:T,isSubmitFocused:D,updateInputValue:S,onCancel:$}}var z46;var lx4=y(()=>{T0();s6();yg1();z46=O6(D6(),1)});function Y46(q){let K=z6(44),{isDisabled:_,visibleOptionCount:z,options:Y,defaultValue:$,onCancel:A,onChange:O,onFocus:w,focusValue:j,submitButtonText:H,onSubmit:J,onDownFromLastItem:M,onUpFromFirstItem:X,initialFocusLast:P,onOpenEditor:W,hideIndexes:D,onImagePaste:f,pastedContents:G,onRemoveImage:Z}=q,T=_===void 0?!1:_,v=z===void 0?5:z,V;if(K[0]!==$)V=$===void 0?[]:$,K[0]=$,K[1]=V;else V=K[1];let E=V,S=D===void 0?!1:D,R;if(K[2]!==E||K[3]!==j||K[4]!==S||K[5]!==P||K[6]!==T||K[7]!==A||K[8]!==O||K[9]!==M||K[10]!==w||K[11]!==J||K[12]!==X||K[13]!==Y||K[14]!==H||K[15]!==v)R={isDisabled:T,visibleOptionCount:v,options:Y,defaultValue:E,onChange:O,onCancel:A,onFocus:w,focusValue:j,submitButtonText:H,onSubmit:J,onDownFromLastItem:M,onUpFromFirstItem:X,initialFocusLast:P,hideIndexes:S},K[2]=E,K[3]=j,K[4]=S,K[5]=P,K[6]=T,K[7]=A,K[8]=O,K[9]=M,K[10]=w,K[11]=J,K[12]=X,K[13]=Y,K[14]=H,K[15]=v,K[16]=R;else R=K[16];let x=cx4(R),I,B,p,C,g;if(K[17]!==S||K[18]!==T||K[19]!==A||K[20]!==f||K[21]!==W||K[22]!==Z||K[23]!==Y.length||K[24]!==G||K[25]!==x){let K6=Y.length.toString().length;B=u,g="column",I=u,p="column",C=x.visibleOptions.map((t,q6)=>{let e=!T&&x.focusedValue===t.value&&!x.isSubmitFocused,i=x.selectedValues.includes(t.value),$6=t.index===x.visibleFromIndex,M6=t.index===x.visibleToIndex-1,j6=x.visibleToIndex<Y.length,G6=x.visibleFromIndex>0,w6=x.visibleFromIndex+q6+1;if(t.type==="input"){let o=x.inputValues.get(t.value)||"";return gG.default.createElement(u,{key:String(t.value),gap:1},gG.default.createElement(CN6,{option:t,isFocused:e,isSelected:!1,shouldShowDownArrow:j6&&M6,shouldShowUpArrow:G6&&$6,maxIndexWidth:K6,index:w6,inputValue:o,onInputChange:(s)=>{x.updateInputValue(t.value,s)},onSubmit:oMz,onExit:()=>{A()},layout:"compact",onOpenEditor:W,onImagePaste:f,pastedContents:G,onRemoveImage:Z},gG.default.createElement(k,{color:i?"success":void 0},"[",i?t6.tick:" ","]"," ")))}return gG.default.createElement(u,{key:String(t.value),gap:1},gG.default.createElement(Qq6,{isFocused:e,isSelected:!1,shouldShowDownArrow:j6&&M6,shouldShowUpArrow:G6&&$6,description:t.description},!S&&gG.default.createElement(k,{dimColor:!0},`${w6}.`.padEnd(K6)),gG.default.createElement(k,{color:i?"success":void 0},"[",i?t6.tick:" ","]"),gG.default.createElement(k,{color:e?"suggestion":void 0},t.label)))}),K[17]=S,K[18]=T,K[19]=A,K[20]=f,K[21]=W,K[22]=Z,K[23]=Y.length,K[24]=G,K[25]=x,K[26]=I,K[27]=B,K[28]=p,K[29]=C,K[30]=g}else I=K[26],B=K[27],p=K[28],C=K[29],g=K[30];let F;if(K[31]!==I||K[32]!==p||K[33]!==C)F=gG.default.createElement(I,{flexDirection:p},C),K[31]=I,K[32]=p,K[33]=C,K[34]=F;else F=K[34];let U;if(K[35]!==J||K[36]!==x.isSubmitFocused||K[37]!==H)U=H&&J&&gG.default.createElement(u,{marginTop:0,gap:1},x.isSubmitFocused?gG.default.createElement(k,{color:"suggestion"},t6.pointer):gG.default.createElement(k,null," "),gG.default.createElement(u,{marginLeft:3},gG.default.createElement(k,{color:x.isSubmitFocused?"suggestion":void 0,bold:!0},H))),K[35]=J,K[36]=x.isSubmitFocused,K[37]=H,K[38]=U;else U=K[38];let c;if(K[39]!==B||K[40]!==F||K[41]!==U||K[42]!==g)c=gG.default.createElement(B,{flexDirection:g},F,U),K[39]=B,K[40]=F,K[41]=U,K[42]=g,K[43]=c;else c=K[43];return c}function oMz(){}var gG;var Ys6=y(()=>{q8();bq();s6();Vg1();oE8();lx4();gG=O6(D6(),1)});var d_=y(()=>{Ys6();p3()});function $46(q){let K=z6(13),{title:_,subtitle:z,color:Y,workerBadge:$}=q,A=Y===void 0?"permission":Y,O;if(K[0]!==A||K[1]!==_)O=Mm.createElement(k,{bold:!0,color:A},_),K[0]=A,K[1]=_,K[2]=O;else O=K[2];let w;if(K[3]!==$)w=$&&Mm.createElement(k,{dimColor:!0},"· ","@",$.name),K[3]=$,K[4]=w;else w=K[4];let j;if(K[5]!==O||K[6]!==w)j=Mm.createElement(u,{flexDirection:"row",gap:1},O,w),K[5]=O,K[6]=w,K[7]=j;else j=K[7];let H;if(K[8]!==z)H=z!=null&&(typeof z==="string"?Mm.createElement(k,{dimColor:!0,wrap:"truncate-start"},z):z),K[8]=z,K[9]=H;else H=K[9];let J;if(K[10]!==j||K[11]!==H)J=Mm.createElement(u,{flexDirection:"column"},j,H),K[10]=j,K[11]=H,K[12]=J;else J=K[12];return J}var Mm;var $s6=y(()=>{q8();s6();Mm=O6(D6(),1)});function HY(q){let K=z6(15),{title:_,subtitle:z,color:Y,titleColor:$,innerPaddingX:A,workerBadge:O,titleRight:w,children:j}=q,H=Y===void 0?"permission":Y,J=A===void 0?1:A,M;if(K[0]!==z||K[1]!==_||K[2]!==$||K[3]!==O)M=Xm.createElement($46,{title:_,subtitle:z,color:$,workerBadge:O}),K[0]=z,K[1]=_,K[2]=$,K[3]=O,K[4]=M;else M=K[4];let X;if(K[5]!==M||K[6]!==w)X=Xm.createElement(u,{paddingX:1,flexDirection:"column"},Xm.createElement(u,{justifyContent:"space-between"},M,w)),K[5]=M,K[6]=w,K[7]=X;else X=K[7];let P;if(K[8]!==j||K[9]!==J)P=Xm.createElement(u,{flexDirection:"column",paddingX:J},j),K[8]=j,K[9]=J,K[10]=P;else P=K[10];let W;if(K[11]!==H||K[12]!==X||K[13]!==P)W=Xm.createElement(u,{flexDirection:"column",borderStyle:"round",borderColor:H,borderLeft:!1,borderRight:!1,borderBottom:!1,marginTop:1},X,P),K[11]=H,K[12]=X,K[13]=P,K[14]=W;else W=K[14];return W}var Xm;var GD=y(()=>{q8();s6();$s6();Xm=O6(D6(),1)});function nx4(q){let K=q.toUpperCase();return aMz.has(K)||sMz.some((_)=>K.startsWith(_))}var aMz,sMz,ix4,iN6;var lL8=y(()=>{aMz=new Set(["CLAUDE_CODE_PROVIDER_MANAGED_BY_HOST","CLAUDE_CODE_USE_BEDROCK","CLAUDE_CODE_USE_VERTEX","CLAUDE_CODE_USE_FOUNDRY","ANTHROPIC_BASE_URL","ANTHROPIC_BEDROCK_BASE_URL","ANTHROPIC_VERTEX_BASE_URL","ANTHROPIC_FOUNDRY_BASE_URL","ANTHROPIC_FOUNDRY_RESOURCE","ANTHROPIC_VERTEX_PROJECT_ID","CLOUD_ML_REGION","ANTHROPIC_API_KEY","ANTHROPIC_AUTH_TOKEN","CLAUDE_CODE_OAUTH_TOKEN","AWS_BEARER_TOKEN_BEDROCK","ANTHROPIC_FOUNDRY_API_KEY","CLAUDE_CODE_SKIP_BEDROCK_AUTH","CLAUDE_CODE_SKIP_VERTEX_AUTH","CLAUDE_CODE_SKIP_FOUNDRY_AUTH","ANTHROPIC_MODEL","ANTHROPIC_DEFAULT_HAIKU_MODEL","ANTHROPIC_DEFAULT_HAIKU_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_HAIKU_MODEL_NAME","ANTHROPIC_DEFAULT_HAIKU_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_DEFAULT_OPUS_MODEL","ANTHROPIC_DEFAULT_OPUS_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_OPUS_MODEL_NAME","ANTHROPIC_DEFAULT_OPUS_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_DEFAULT_SONNET_MODEL","ANTHROPIC_DEFAULT_SONNET_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_SONNET_MODEL_NAME","ANTHROPIC_DEFAULT_SONNET_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_SMALL_FAST_MODEL","ANTHROPIC_SMALL_FAST_MODEL_AWS_REGION","CLAUDE_CODE_SUBAGENT_MODEL"]),sMz=["VERTEX_REGION_CLAUDE_"];ix4=["apiKeyHelper","awsAuthRefresh","awsCredentialExport","gcpAuthRefresh","otelHeadersHelper","statusLine"],iN6=new Set(["ANTHROPIC_CUSTOM_HEADERS","ANTHROPIC_CUSTOM_MODEL_OPTION","ANTHROPIC_CUSTOM_MODEL_OPTION_DESCRIPTION","ANTHROPIC_CUSTOM_MODEL_OPTION_NAME","ANTHROPIC_DEFAULT_HAIKU_MODEL","ANTHROPIC_DEFAULT_HAIKU_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_HAIKU_MODEL_NAME","ANTHROPIC_DEFAULT_HAIKU_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_DEFAULT_OPUS_MODEL","ANTHROPIC_DEFAULT_OPUS_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_OPUS_MODEL_NAME","ANTHROPIC_DEFAULT_OPUS_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_DEFAULT_SONNET_MODEL","ANTHROPIC_DEFAULT_SONNET_MODEL_DESCRIPTION","ANTHROPIC_DEFAULT_SONNET_MODEL_NAME","ANTHROPIC_DEFAULT_SONNET_MODEL_SUPPORTED_CAPABILITIES","ANTHROPIC_FOUNDRY_API_KEY","ANTHROPIC_MODEL","ANTHROPIC_SMALL_FAST_MODEL_AWS_REGION","ANTHROPIC_SMALL_FAST_MODEL","AWS_DEFAULT_REGION","AWS_PROFILE","AWS_REGION","BASH_DEFAULT_TIMEOUT_MS","BASH_MAX_OUTPUT_LENGTH","BASH_MAX_TIMEOUT_MS","CLAUDE_BASH_MAINTAIN_PROJECT_WORKING_DIR","CLAUDE_CODE_API_KEY_HELPER_TTL_MS","CLAUDE_CODE_DISABLE_EXPERIMENTAL_BETAS","CLAUDE_CODE_DISABLE_NONESSENTIAL_TRAFFIC","CLAUDE_CODE_DISABLE_TERMINAL_TITLE","CLAUDE_CODE_ENABLE_TELEMETRY","CLAUDE_CODE_EXPERIMENTAL_AGENT_TEAMS","CLAUDE_CODE_IDE_SKIP_AUTO_INSTALL","CLAUDE_CODE_MAX_OUTPUT_TOKENS","CLAUDE_CODE_SKIP_BEDROCK_AUTH","CLAUDE_CODE_SKIP_FOUNDRY_AUTH","CLAUDE_CODE_SKIP_VERTEX_AUTH","CLAUDE_CODE_SUBAGENT_MODEL","CLAUDE_CODE_USE_BEDROCK","CLAUDE_CODE_USE_FOUNDRY","CLAUDE_CODE_USE_VERTEX","DISABLE_AUTOUPDATER","DISABLE_BUG_COMMAND","DISABLE_COST_WARNINGS","DISABLE_ERROR_REPORTING","DISABLE_FEEDBACK_COMMAND","DISABLE_TELEMETRY","ENABLE_TOOL_SEARCH","MAX_MCP_OUTPUT_TOKENS","MAX_THINKING_TOKENS","MCP_TIMEOUT","MCP_TOOL_TIMEOUT","OTEL_EXPORTER_OTLP_HEADERS","OTEL_EXPORTER_OTLP_LOGS_HEADERS","OTEL_EXPORTER_OTLP_LOGS_PROTOCOL","OTEL_EXPORTER_OTLP_METRICS_CLIENT_CERTIFICATE","OTEL_EXPORTER_OTLP_METRICS_CLIENT_KEY","OTEL_EXPORTER_OTLP_METRICS_HEADERS","OTEL_EXPORTER_OTLP_METRICS_PROTOCOL","OTEL_EXPORTER_OTLP_PROTOCOL","OTEL_EXPORTER_OTLP_TRACES_HEADERS","OTEL_LOG_TOOL_DETAILS","OTEL_LOG_USER_PROMPTS","OTEL_LOGS_EXPORT_INTERVAL","OTEL_LOGS_EXPORTER","OTEL_METRIC_EXPORT_INTERVAL","OTEL_METRICS_EXPORTER","OTEL_METRICS_INCLUDE_ACCOUNT_UUID","OTEL_METRICS_INCLUDE_SESSION_ID","OTEL_METRICS_INCLUDE_VERSION","OTEL_RESOURCE_ATTRIBUTES","USE_BUILTIN_RIPGREP","VERTEX_REGION_CLAUDE_3_5_HAIKU","VERTEX_REGION_CLAUDE_3_5_SONNET","VERTEX_REGION_CLAUDE_3_7_SONNET","VERTEX_REGION_CLAUDE_4_0_OPUS","VERTEX_REGION_CLAUDE_4_0_SONNET","VERTEX_REGION_CLAUDE_4_1_OPUS","VERTEX_REGION_CLAUDE_4_5_SONNET","VERTEX_REGION_CLAUDE_4_6_SONNET","VERTEX_REGION_CLAUDE_HAIKU_4_5"])});function rN6(q){if(!q)return{shellSettings:{},envVars:{},hasHooks:!1};let K={};for(let Y of ix4){let $=q[Y];if(typeof $==="string"&&$.length>0)K[Y]=$}let _={};if(q.env&&typeof q.env==="object"){for(let[Y,$]of Object.entries(q.env))if(typeof $==="string"&&$.length>0){if(!iN6.has(Y.toUpperCase()))_[Y]=$}}let z=q.hooks!==void 0&&q.hooks!==null&&typeof q.hooks==="object"&&Object.keys(q.hooks).length>0;return{shellSettings:K,envVars:_,hasHooks:z,hooks:z?q.hooks:void 0}}function nL8(q){return Object.keys(q.shellSettings).length>0||Object.keys(q.envVars).length>0||q.hasHooks}function rx4(q,K){let _=rN6(q),z=rN6(K);if(!nL8(z))return!1;if(!nL8(_))return!0;let Y=g6({shellSettings:_.shellSettings,envVars:_.envVars,hooks:_.hooks}),$=g6({shellSettings:z.shellSettings,envVars:z.envVars,hooks:z.hooks});return Y!==$}function ox4(q){let K=[];for(let _ of Object.keys(q.shellSettings))K.push(_);for(let _ of Object.keys(q.envVars))K.push(_);if(q.hasHooks)K.push("hooks");return K}var cF1=y(()=>{lL8();l8()});function ax4(q){let K=z6(26),{settings:_,onAccept:z,onReject:Y}=q,$=rN6(_),A=ox4($),O=o5(),w;if(K[0]===Symbol.for("react.memo_cache_sentinel"))w={context:"Confirmation"},K[0]=w;else w=K[0];P1("confirm:no",Y,w);let j;if(K[1]!==z||K[2]!==Y)j=function(F){if(F==="exit"){Y();return}z()},K[1]=z,K[2]=Y,K[3]=j;else j=K[3];let H=j,J=HY,M="warning",X="warning",P="Managed settings require approval",W=u,D="column",f=1,G=1,Z;if(K[4]===Symbol.for("react.memo_cache_sentinel"))Z=V0.default.createElement(k,null,"Your organization has configured managed settings that could allow execution of arbitrary code or interception of your prompts and responses."),K[4]=Z;else Z=K[4];let T=u,v="column",V;if(K[5]===Symbol.for("react.memo_cache_sentinel"))V=V0.default.createElement(k,{dimColor:!0},"Settings requiring approval:"),K[5]=V;else V=K[5];let E=A.map(tMz),S;if(K[6]!==T||K[7]!==V||K[8]!==E)S=V0.default.createElement(T,{flexDirection:v},V,E),K[6]=T,K[7]=V,K[8]=E,K[9]=S;else S=K[9];let R;if(K[10]===Symbol.for("react.memo_cache_sentinel"))R=V0.default.createElement(k,null,"Only accept if you trust your organization's IT administration and expect these settings to be configured."),K[10]=R;else R=K[10];let x;if(K[11]===Symbol.for("react.memo_cache_sentinel"))x=[{label:"Yes, I trust these settings",value:"accept"},{label:"No, exit Claude Code",value:"exit"}],K[11]=x;else x=K[11];let I;if(K[12]!==H)I=V0.default.createElement(H1,{options:x,onChange:(g)=>H(g),onCancel:()=>H("exit")}),K[12]=H,K[13]=I;else I=K[13];let B;if(K[14]!==O.keyName||K[15]!==O.pending)B=V0.default.createElement(k,{dimColor:!0},O.pending?V0.default.createElement(V0.default.Fragment,null,"Press ",O.keyName," again to exit"):V0.default.createElement(V0.default.Fragment,null,"Enter to confirm · Esc to exit")),K[14]=O.keyName,K[15]=O.pending,K[16]=B;else B=K[16];let p;if(K[17]!==W||K[18]!==S||K[19]!==I||K[20]!==B||K[21]!==Z)p=V0.default.createElement(W,{flexDirection:D,gap:f,paddingTop:G},Z,S,R,I,B),K[17]=W,K[18]=S,K[19]=I,K[20]=B,K[21]=Z,K[22]=p;else p=K[22];let C;if(K[23]!==J||K[24]!==p)C=V0.default.createElement(J,{color:M,titleColor:X,title:P},p),K[23]=J,K[24]=p,K[25]=C;else C=K[25];return C}function tMz(q,K){return V0.default.createElement(u,{key:K,paddingLeft:2},V0.default.createElement(k,null,V0.default.createElement(k,{dimColor:!0},"· "),V0.default.createElement(k,null,q)))}var V0;var sx4=y(()=>{q8();z2();s6();Oq();d_();GD();cF1();V0=O6(D6(),1)});function qXz(q,K){let _=z6(9),{addNotification:z,removeNotification:Y}=PK(),$;if(_[0]!==z||_[1]!==Y||_[2]!==q)$=()=>{if(q.length===0){Y("keybinding-config-warning");return}let O=$7(q,_Xz),w=$7(q,KXz),j;if(O>0&&w>0)j=`Found ${O} keybinding ${A7(O,"error")} and ${w} ${A7(w,"warning")}`;else if(O>0)j=`Found ${O} keybinding ${A7(O,"error")}`;else j=`Found ${w} keybinding ${A7(w,"warning")}`;j=j+" · /doctor for details",z({key:"keybinding-config-warning",text:j,color:O>0?"error":"warning",priority:O>0?"immediate":"high",timeoutMs:60000})},_[0]=z,_[1]=Y,_[2]=q,_[3]=$;else $=_[3];let A;if(_[4]!==z||_[5]!==K||_[6]!==Y||_[7]!==q)A=[q,K,z,Y],_[4]=z,_[5]=K,_[6]=Y,_[7]=q,_[8]=A;else A=_[8];SX.useEffect($,A)}function KXz(q){return q.severity==="warning"}function _Xz(q){return q.severity==="error"}function WM({children:q}){let[{bindings:K,warnings:_},z]=SX.useState(()=>{let D=Qo6();return N(`[keybindings] KeybindingSetup initialized with ${D.bindings.length} bindings, ${D.warnings.length} warnings`),D}),[Y,$]=SX.useState(!1);qXz(_,Y);let A=SX.useRef(null),[O,w]=SX.useState(null),j=SX.useRef(null),H=SX.useRef(new Map),J=SX.useRef(new Set),M=SX.useCallback((D)=>{J.current.add(D)},[]),X=SX.useCallback((D)=>{J.current.delete(D)},[]),P=SX.useCallback(()=>{if(j.current)clearTimeout(j.current),j.current=null},[]),W=SX.useCallback((D)=>{if(P(),D!==null)j.current=setTimeout((f,G)=>{N("[keybindings] Chord timeout - cancelling"),f.current=null,G(null)},eMz,A,w);A.current=D,w(D)},[P]);return SX.useEffect(()=>{mE4();let D=pE4((f)=>{$(!0),z(f),N(`[keybindings] Reloaded: ${f.bindings.length} bindings, ${f.warnings.length} warnings`)});return()=>{D(),P()}},[P]),SX.default.createElement(yy8,{bindings:K,pendingChordRef:A,pendingChord:O,setPendingChord:W,activeContexts:J.current,registerActiveContext:M,unregisterActiveContext:X,handlerRegistryRef:H},SX.default.createElement(zXz,{bindings:K,pendingChordRef:A,setPendingChord:W,activeContexts:J.current,handlerRegistryRef:H}),q)}function zXz(q){let K=z6(6),{bindings:_,pendingChordRef:z,setPendingChord:Y,activeContexts:$,handlerRegistryRef:A}=q,O;if(K[0]!==$||K[1]!==_||K[2]!==A||K[3]!==z||K[4]!==Y)O=(j,H,J)=>{if((H.wheelUp||H.wheelDown)&&z.current===null)return;let M=A.current,X=new Set;if(M)for(let f of M.values())for(let G of f)X.add(G.context);let P=[...X,...$,"Global"],W=z.current!==null,D=Ny8(j,H,P,_,z.current);q:switch(D.type){case"chord_started":{Y(D.pending),J.stopImmediatePropagation();break q}case"match":{if(Y(null),W){let f=new Set(P);if(M){let G=M.get(D.action);if(G&&G.size>0){for(let Z of G)if(f.has(Z.context)){Z.handler(),J.stopImmediatePropagation();break}}}}break q}case"chord_cancelled":{Y(null),J.stopImmediatePropagation();break q}case"unbound":{Y(null),J.stopImmediatePropagation();break q}case"none":}},K[0]=$,K[1]=_,K[2]=A,K[3]=z,K[4]=Y,K[5]=O;else O=K[5];return k4(O),null}var SX,eMz=1000;var dU=y(()=>{q8();h$();s6();_8();yU();Ur();do6();SX=O6(D6(),1)});import{openSync as YXz}from"fs";import{ReadStream as $Xz}from"tty";function AXz(){if(Ho!==null)return Ho;if(process.stdin.isTTY){Ho=void 0;return}if(i6(!1)){Ho=void 0;return}if(process.argv.includes("mcp")){Ho=void 0;return}if(process.platform==="win32"){Ho=void 0;return}try{let q=YXz("/dev/tty","r"),K=new $Xz(q);return K.isTTY=!0,Ho=K,Ho}catch(q){H6(q),Ho=void 0;return}}function Jo(q=!1){let K=AXz(),_={exitOnCtrlC:q};if(K)_.stdin=K;return _}var Ho=null;var As6=y(()=>{m8();E8()});async function tx4(q,K){if(!K||!nL8(rN6(K)))return"no_check_needed";if(!rx4(q,K))return"no_check_needed";if(!ET())return"no_check_needed";return d("tengu_managed_settings_security_dialog_shown",{}),new Promise((_)=>{(async()=>{let{unmount:z}=await vu(iL8.default.createElement(LJ,null,iL8.default.createElement(WM,null,iL8.default.createElement(ax4,{settings:K,onAccept:()=>{d("tengu_managed_settings_security_dialog_accepted",{}),z(),_("approved")},onReject:()=>{d("tengu_managed_settings_security_dialog_rejected",{}),z(),_("rejected")}}))),Jo(!1))})()})}function ex4(q){if(q==="rejected")return eK(1),!1;return!0}var iL8;var qI4=y(()=>{v8();sx4();cF1();s6();dU();C7();RA();As6();k8();iL8=O6(D6(),1)});function KI4(){cU=void 0,rL7()}function Pm(){if(cU!==void 0)return cU;if(E7()!=="firstParty")return cU=Ce(!1);if(!WP())return cU=Ce(!1);if(process.env.CLAUDE_CODE_ENTRYPOINT==="local-agent")return cU=Ce(!1);let q=Kq();if(q?.accessToken&&q.subscriptionType===null)return cU=Ce(!0);if(q?.accessToken&&q.scopes?.includes(Mh)&&(q.subscriptionType==="enterprise"||q.subscriptionType==="team"))return cU=Ce(!0);try{let{key:K}=Ow({skipRetrievingKeyFromApiKeyHelper:!0});if(K)return cU=Ce(!0)}catch{}return cU=Ce(!1)}var cU;var lF1=y(()=>{H3();G7();Az();h$8()});var _I4;var zI4=y(()=>{x7();_I4=B6(()=>L.object({uuid:L.string(),checksum:L.string(),settings:L.record(L.string(),L.unknown())}))});import{createHash as OXz}from"crypto";import{open as wXz,unlink as YI4}from"fs/promises";function $I4(){if(ow6)return;if(Pm())ow6=new Promise((q)=>{qb=q,setTimeout(()=>{if(qb)N("Remote settings: Loading promise timed out, resolving anyway"),qb(),qb=null},JXz)})}function MXz(){return`${u7().BASE_API_URL}/api/claude_code/settings`}function iF1(q){if(Array.isArray(q))return q.map(iF1);if(q!==null&&typeof q==="object"){let K={};for(let _ of Object.keys(q).sort())K[_]=iF1(q[_]);return K}return q}function XXz(q){let K=iF1(q),_=g6(K);return`sha256:${OXz("sha256").update(_).digest("hex")}`}function rF1(){return Pm()}async function rL8(){if(ow6)await ow6}function PXz(){try{let{key:K}=Ow({skipRetrievingKeyFromApiKeyHelper:!0});if(K)return{headers:{"x-api-key":K}}}catch{}let q=Kq();if(q?.accessToken)return{headers:{Authorization:`Bearer ${q.accessToken}`,"anthropic-beta":rM}};return{headers:{},error:"No authentication available"}}async function WXz(q){let K=null;for(let _=1;_<=nF1+1;_++){if(K=await DXz(q),K.success)return K;if(K.skipRetry)return K;if(_>nF1)return K;let z=hC(_);N(`Remote settings: Retry ${_}/${nF1} after ${z}ms`),await R7(z)}return K}async function DXz(q){try{await k$();let K=PXz();if(K.error)return{success:!1,error:"Authentication required for remote settings",skipRetry:!0};let _=MXz(),z={...K.headers,"User-Agent":n$()};if(q)z["If-None-Match"]=`"${q}"`;let Y=await $1.get(_,{headers:z,timeout:jXz,validateStatus:(O)=>O===200||O===204||O===304||O===404});if(Y.status===304)return N("Remote settings: Using cached settings (304)"),{success:!0,settings:null,checksum:q};if(Y.status===204||Y.status===404)return N(`Remote settings: No settings found (${Y.status})`),{success:!0,settings:{},checksum:void 0};let $=_I4().safeParse(Y.data);if(!$.success)return N(`Remote settings: Invalid response format - ${$.error.message}`),{success:!1,error:"Invalid remote settings format"};let A=EW().safeParse($.data.settings);if(!A.success)return N(`Remote settings: Settings validation failed - ${A.error.message}`),{success:!1,error:"Invalid settings structure"};return N("Remote settings: Fetched successfully"),{success:!0,settings:A.data,checksum:$.data.checksum}}catch(K){let{kind:_,status:z,message:Y}=Sc(K);if(z===404)return{success:!0,settings:{},checksum:""};switch(_){case"auth":return{success:!1,error:"Not authorized for remote settings",skipRetry:!0};case"timeout":return{success:!1,error:"Remote settings request timeout"};case"network":return{success:!1,error:"Cannot connect to server"};default:return{success:!1,error:Y}}}}async function fXz(q){try{let K=tm6(),_=await wXz(K,"w",384);try{await _.writeFile(g6(q,null,2),{encoding:"utf-8"}),await _.datasync()}finally{await _.close()}N(`Remote settings: Saved to ${K}`)}catch(K){N(`Remote settings: Failed to save - ${K instanceof Error?K.message:"unknown error"}`)}}async function oF1(){OI4(),KI4(),ow6=null,qb=null;try{let q=tm6();await YI4(q)}catch{}}async function aF1(){if(!Pm())return null;let q=wl(),K=q?XXz(q):void 0;try{let _=await WXz(K);if(!_.success){if(q)return N("Remote settings: Using stale cache after fetch failure"),uW6(q),q;return null}if(_.settings===null&&q)return N("Remote settings: Cache still valid (304 Not Modified)"),uW6(q),q;let z=_.settings||{};if(Object.keys(z).length>0){let $=await tx4(q,z);if(!ex4($))return N("Remote settings: User rejected new settings, using cached settings"),q;return uW6(z),await fXz(z),N("Remote settings: Applied new settings successfully"),z}uW6(z);try{let $=tm6();await YI4($),N("Remote settings: Deleted cached file (404 response)")}catch($){if(s1($)!=="ENOENT")N(`Remote settings: Failed to delete cached file - ${$ instanceof Error?$.message:"unknown error"}`)}return z}catch{if(q)return N("Remote settings: Using stale cache after error"),uW6(q),q;return null}}async function AI4(){if(Pm()&&!ow6)ow6=new Promise((q)=>{qb=q});if(wl()&&qb)qb(),qb=null;try{let q=await aF1();if(Pm())GXz();if(q!==null)WX.notifyChange("policySettings")}finally{if(qb)qb(),qb=null}}async function oL8(){if(await oF1(),!Pm()){WX.notifyChange("policySettings");return}await aF1(),N("Remote settings: Refreshed after auth change"),WX.notifyChange("policySettings")}async function ZXz(){if(!Pm())return;let q=wl(),K=q?g6(q):null;try{await aF1();let _=wl();if((_?g6(_):null)!==K)N("Remote settings: Changed during background poll"),WX.notifyChange("policySettings")}catch{}}function GXz(){if(oN6!==null)return;if(!Pm())return;oN6=setInterval(()=>{ZXz()},HXz),oN6.unref(),pq(async()=>OI4())}function OI4(){if(oN6!==null)clearInterval(oN6),oN6=null}var jXz=1e4,nF1=5,HXz=3600000,oN6=null,ow6=null,qb=null,JXz=30000;var aN6=y(()=>{CK();H3();G7();c9();_8();y8();NF();vh();l8();Wr();qI4();lF1();h$8();zI4()});var aL8=m((wI4)=>{Object.defineProperty(wI4,"__esModule",{value:!0});wI4.AggregationTemporality=void 0;var TXz;(function(q){q[q.DELTA=0]="DELTA",q[q.CUMULATIVE=1]="CUMULATIVE"})(TXz=wI4.AggregationTemporality||(wI4.AggregationTemporality={}))});var A46=m((HI4)=>{Object.defineProperty(HI4,"__esModule",{value:!0});HI4.DataPointType=HI4.InstrumentType=void 0;var vXz;(function(q){q.COUNTER="COUNTER",q.GAUGE="GAUGE",q.HISTOGRAM="HISTOGRAM",q.UP_DOWN_COUNTER="UP_DOWN_COUNTER",q.OBSERVABLE_COUNTER="OBSERVABLE_COUNTER",q.OBSERVABLE_GAUGE="OBSERVABLE_GAUGE",q.OBSERVABLE_UP_DOWN_COUNTER="OBSERVABLE_UP_DOWN_COUNTER"})(vXz=HI4.InstrumentType||(HI4.InstrumentType={}));var kXz;(function(q){q[q.HISTOGRAM=0]="HISTOGRAM",q[q.EXPONENTIAL_HISTOGRAM=1]="EXPONENTIAL_HISTOGRAM",q[q.GAUGE=2]="GAUGE",q[q.SUM=3]="SUM"})(kXz=HI4.DataPointType||(HI4.DataPointType={}))});var Wm=m((JI4)=>{Object.defineProperty(JI4,"__esModule",{value:!0});JI4.equalsCaseInsensitive=JI4.binarySearchUB=JI4.setEquals=JI4.FlatMap=JI4.isPromiseAllSettledRejectionResult=JI4.PromiseAllSettled=JI4.callWithTimeout=JI4.TimeoutError=JI4.instrumentationScopeId=JI4.hashAttributes=JI4.isNotNullish=void 0;function VXz(q){return q!==void 0&&q!==null}JI4.isNotNullish=VXz;function NXz(q){let K=Object.keys(q);if(K.length===0)return"";return K=K.sort(),JSON.stringify(K.map((_)=>[_,q[_]]))}JI4.hashAttributes=NXz;function yXz(q){return`${q.name}:${q.version??""}:${q.schemaUrl??""}`}JI4.instrumentationScopeId=yXz;class sL8 extends Error{constructor(q){super(q);Object.setPrototypeOf(this,sL8.prototype)}}JI4.TimeoutError=sL8;function EXz(q,K){let _,z=new Promise(function($,A){_=setTimeout(function(){A(new sL8("Operation timed out."))},K)});return Promise.race([q,z]).then((Y)=>{return clearTimeout(_),Y},(Y)=>{throw clearTimeout(_),Y})}JI4.callWithTimeout=EXz;async function LXz(q){return Promise.all(q.map(async(K)=>{try{return{status:"fulfilled",value:await K}}catch(_){return{status:"rejected",reason:_}}}))}JI4.PromiseAllSettled=LXz;function RXz(q){return q.status==="rejected"}JI4.isPromiseAllSettledRejectionResult=RXz;function hXz(q,K){let _=[];return q.forEach((z)=>{_.push(...K(z))}),_}JI4.FlatMap=hXz;function SXz(q,K){if(q.size!==K.size)return!1;for(let _ of q)if(!K.has(_))return!1;return!0}JI4.setEquals=SXz;function CXz(q,K){let _=0,z=q.length-1,Y=q.length;while(z>=_){let $=_+Math.trunc((z-_)/2);if(q[$]<K)_=$+1;else Y=$,z=$-1}return Y}JI4.binarySearchUB=CXz;function bXz(q,K){return q.toLowerCase()===K.toLowerCase()}JI4.equalsCaseInsensitive=bXz});var sN6=m((XI4)=>{Object.defineProperty(XI4,"__esModule",{value:!0});XI4.AggregatorKind=void 0;var dXz;(function(q){q[q.DROP=0]="DROP",q[q.SUM=1]="SUM",q[q.LAST_VALUE=2]="LAST_VALUE",q[q.HISTOGRAM=3]="HISTOGRAM",q[q.EXPONENTIAL_HISTOGRAM=4]="EXPONENTIAL_HISTOGRAM"})(dXz=XI4.AggregatorKind||(XI4.AggregatorKind={}))});var fI4=m((WI4)=>{Object.defineProperty(WI4,"__esModule",{value:!0});WI4.DropAggregator=void 0;var cXz=sN6();class PI4{kind=cXz.AggregatorKind.DROP;createAccumulation(){return}merge(q,K){return}diff(q,K){return}toMetricData(q,K,_,z){return}}WI4.DropAggregator=PI4});var vI4=m((GI4)=>{Object.defineProperty(GI4,"__esModule",{value:!0});GI4.HistogramAggregator=GI4.HistogramAccumulation=void 0;var lXz=sN6(),Os6=A46(),nXz=Wm();function iXz(q){let K=q.map(()=>0);return K.push(0),{buckets:{boundaries:q,counts:K},sum:0,count:0,hasMinMax:!1,min:1/0,max:-1/0}}class ws6{startTime;_boundaries;_recordMinMax;_current;constructor(q,K,_=!0,z=iXz(K)){this.startTime=q,this._boundaries=K,this._recordMinMax=_,this._current=z}record(q){if(Number.isNaN(q))return;if(this._current.count+=1,this._current.sum+=q,this._recordMinMax)this._current.min=Math.min(q,this._current.min),this._current.max=Math.max(q,this._current.max),this._current.hasMinMax=!0;let K=(0,nXz.binarySearchUB)(this._boundaries,q);this._current.buckets.counts[K]+=1}setStartTime(q){this.startTime=q}toPointValue(){return this._current}}GI4.HistogramAccumulation=ws6;class ZI4{_boundaries;_recordMinMax;kind=lXz.AggregatorKind.HISTOGRAM;constructor(q,K){this._boundaries=q,this._recordMinMax=K}createAccumulation(q){return new ws6(q,this._boundaries,this._recordMinMax)}merge(q,K){let _=q.toPointValue(),z=K.toPointValue(),Y=_.buckets.counts,$=z.buckets.counts,A=Array(Y.length);for(let j=0;j<Y.length;j++)A[j]=Y[j]+$[j];let O=1/0,w=-1/0;if(this._recordMinMax){if(_.hasMinMax&&z.hasMinMax)O=Math.min(_.min,z.min),w=Math.max(_.max,z.max);else if(_.hasMinMax)O=_.min,w=_.max;else if(z.hasMinMax)O=z.min,w=z.max}return new ws6(q.startTime,_.buckets.boundaries,this._recordMinMax,{buckets:{boundaries:_.buckets.boundaries,counts:A},count:_.count+z.count,sum:_.sum+z.sum,hasMinMax:this._recordMinMax&&(_.hasMinMax||z.hasMinMax),min:O,max:w})}diff(q,K){let _=q.toPointValue(),z=K.toPointValue(),Y=_.buckets.counts,$=z.buckets.counts,A=Array(Y.length);for(let O=0;O<Y.length;O++)A[O]=$[O]-Y[O];return new ws6(K.startTime,_.buckets.boundaries,this._recordMinMax,{buckets:{boundaries:_.buckets.boundaries,counts:A},count:z.count-_.count,sum:z.sum-_.sum,hasMinMax:!1,min:1/0,max:-1/0})}toMetricData(q,K,_,z){return{descriptor:q,aggregationTemporality:K,dataPointType:Os6.DataPointType.HISTOGRAM,dataPoints:_.map(([Y,$])=>{let A=$.toPointValue(),O=q.type===Os6.InstrumentType.GAUGE||q.type===Os6.InstrumentType.UP_DOWN_COUNTER||q.type===Os6.InstrumentType.OBSERVABLE_GAUGE||q.type===Os6.InstrumentType.OBSERVABLE_UP_DOWN_COUNTER;return{attributes:Y,startTime:$.startTime,endTime:z,value:{min:A.hasMinMax?A.min:void 0,max:A.hasMinMax?A.max:void 0,sum:!O?A.sum:void 0,buckets:A.buckets,count:A.count}}})}}}GI4.HistogramAggregator=ZI4});var NI4=m((kI4)=>{Object.defineProperty(kI4,"__esModule",{value:!0});kI4.Buckets=void 0;class qU1{backing;indexBase;indexStart;indexEnd;constructor(q=new KU1,K=0,_=0,z=0){this.backing=q,this.indexBase=K,this.indexStart=_,this.indexEnd=z}get offset(){return this.indexStart}get length(){if(this.backing.length===0)return 0;if(this.indexEnd===this.indexStart&&this.at(0)===0)return 0;return this.indexEnd-this.indexStart+1}counts(){return Array.from({length:this.length},(q,K)=>this.at(K))}at(q){let K=this.indexBase-this.indexStart;if(q<K)q+=this.backing.length;return q-=K,this.backing.countAt(q)}incrementBucket(q,K){this.backing.increment(q,K)}decrementBucket(q,K){this.backing.decrement(q,K)}trim(){for(let q=0;q<this.length;q++)if(this.at(q)!==0){this.indexStart+=q;break}else if(q===this.length-1){this.indexStart=this.indexEnd=this.indexBase=0;return}for(let q=this.length-1;q>=0;q--)if(this.at(q)!==0){this.indexEnd-=this.length-q-1;break}this._rotate()}downscale(q){this._rotate();let K=1+this.indexEnd-this.indexStart,_=1<<q,z=0,Y=0;for(let $=this.indexStart;$<=this.indexEnd;){let A=$%_;if(A<0)A+=_;for(let O=A;O<_&&z<K;O++)this._relocateBucket(Y,z),z++,$++;Y++}this.indexStart>>=q,this.indexEnd>>=q,this.indexBase=this.indexStart}clone(){return new qU1(this.backing.clone(),this.indexBase,this.indexStart,this.indexEnd)}_rotate(){let q=this.indexBase-this.indexStart;if(q===0)return;else if(q>0)this.backing.reverse(0,this.backing.length),this.backing.reverse(0,q),this.backing.reverse(q,this.backing.length);else this.backing.reverse(0,this.backing.length),this.backing.reverse(0,this.backing.length+q);this.indexBase=this.indexStart}_relocateBucket(q,K){if(q===K)return;this.incrementBucket(q,this.backing.emptyBucket(K))}}kI4.Buckets=qU1;class KU1{_counts;constructor(q=[0]){this._counts=q}get length(){return this._counts.length}countAt(q){return this._counts[q]}growTo(q,K,_){let z=Array(q).fill(0);z.splice(_,this._counts.length-K,...this._counts.slice(K)),z.splice(0,K,...this._counts.slice(0,K)),this._counts=z}reverse(q,K){let _=Math.floor((q+K)/2)-q;for(let z=0;z<_;z++){let Y=this._counts[q+z];this._counts[q+z]=this._counts[K-z-1],this._counts[K-z-1]=Y}}emptyBucket(q){let K=this._counts[q];return this._counts[q]=0,K}increment(q,K){this._counts[q]+=K}decrement(q,K){if(this._counts[q]>=K)this._counts[q]-=K;else this._counts[q]=0}clone(){return new KU1([...this._counts])}}});var zU1=m((yI4)=>{Object.defineProperty(yI4,"__esModule",{value:!0});yI4.getSignificand=yI4.getNormalBase2=yI4.MIN_VALUE=yI4.MAX_NORMAL_EXPONENT=yI4.MIN_NORMAL_EXPONENT=yI4.SIGNIFICAND_WIDTH=void 0;yI4.SIGNIFICAND_WIDTH=52;var oXz=2146435072,aXz=1048575,_U1=1023;yI4.MIN_NORMAL_EXPONENT=-_U1+1;yI4.MAX_NORMAL_EXPONENT=_U1;yI4.MIN_VALUE=Math.pow(2,-1022);function sXz(q){let K=new DataView(new ArrayBuffer(8));return K.setFloat64(0,q),((K.getUint32(0)&oXz)>>20)-_U1}yI4.getNormalBase2=sXz;function tXz(q){let K=new DataView(new ArrayBuffer(8));K.setFloat64(0,q);let _=K.getUint32(0),z=K.getUint32(4);return(_&aXz)*Math.pow(2,32)+z}yI4.getSignificand=tXz});var tL8=m((LI4)=>{Object.defineProperty(LI4,"__esModule",{value:!0});LI4.nextGreaterSquare=LI4.ldexp=void 0;function YPz(q,K){if(q===0||q===Number.POSITIVE_INFINITY||q===Number.NEGATIVE_INFINITY||Number.isNaN(q))return q;return q*Math.pow(2,K)}LI4.ldexp=YPz;function $Pz(q){return q--,q|=q>>1,q|=q>>2,q|=q>>4,q|=q>>8,q|=q>>16,q++,q}LI4.nextGreaterSquare=$Pz});var eL8=m((SI4)=>{Object.defineProperty(SI4,"__esModule",{value:!0});SI4.MappingError=void 0;class hI4 extends Error{}SI4.MappingError=hI4});var mI4=m((II4)=>{Object.defineProperty(II4,"__esModule",{value:!0});II4.ExponentMapping=void 0;var tN6=zU1(),OPz=tL8(),bI4=eL8();class xI4{_shift;constructor(q){this._shift=-q}mapToIndex(q){if(q<tN6.MIN_VALUE)return this._minNormalLowerBoundaryIndex();let K=tN6.getNormalBase2(q),_=this._rightShift(tN6.getSignificand(q)-1,tN6.SIGNIFICAND_WIDTH);return K+_>>this._shift}lowerBoundary(q){let K=this._minNormalLowerBoundaryIndex();if(q<K)throw new bI4.MappingError(`underflow: ${q} is < minimum lower boundary: ${K}`);let _=this._maxNormalLowerBoundaryIndex();if(q>_)throw new bI4.MappingError(`overflow: ${q} is > maximum lower boundary: ${_}`);return OPz.ldexp(1,q<<this._shift)}get scale(){if(this._shift===0)return 0;return-this._shift}_minNormalLowerBoundaryIndex(){let q=tN6.MIN_NORMAL_EXPONENT>>this._shift;if(this._shift<2)q--;return q}_maxNormalLowerBoundaryIndex(){return tN6.MAX_NORMAL_EXPONENT>>this._shift}_rightShift(q,K){return Math.floor(q*Math.pow(2,-K))}}II4.ExponentMapping=xI4});var QI4=m((FI4)=>{Object.defineProperty(FI4,"__esModule",{value:!0});FI4.LogarithmMapping=void 0;var eN6=zU1(),pI4=tL8(),BI4=eL8();class gI4{_scale;_scaleFactor;_inverseFactor;constructor(q){this._scale=q,this._scaleFactor=pI4.ldexp(Math.LOG2E,q),this._inverseFactor=pI4.ldexp(Math.LN2,-q)}mapToIndex(q){if(q<=eN6.MIN_VALUE)return this._minNormalLowerBoundaryIndex()-1;if(eN6.getSignificand(q)===0)return(eN6.getNormalBase2(q)<<this._scale)-1;let K=Math.floor(Math.log(q)*this._scaleFactor),_=this._maxNormalLowerBoundaryIndex();if(K>=_)return _;return K}lowerBoundary(q){let K=this._maxNormalLowerBoundaryIndex();if(q>=K){if(q===K)return 2*Math.exp((q-(1<<this._scale))/this._scaleFactor);throw new BI4.MappingError(`overflow: ${q} is > maximum lower boundary: ${K}`)}let _=this._minNormalLowerBoundaryIndex();if(q<=_){if(q===_)return eN6.MIN_VALUE;else if(q===_-1)return Math.exp((q+(1<<this._scale))/this._scaleFactor)/2;throw new BI4.MappingError(`overflow: ${q} is < minimum lower boundary: ${_}`)}return Math.exp(q*this._inverseFactor)}get scale(){return this._scale}_minNormalLowerBoundaryIndex(){return eN6.MIN_NORMAL_EXPONENT<<this._scale}_maxNormalLowerBoundaryIndex(){return(eN6.MAX_NORMAL_EXPONENT+1<<this._scale)-1}}FI4.LogarithmMapping=gI4});var iI4=m((lI4)=>{Object.defineProperty(lI4,"__esModule",{value:!0});lI4.getMapping=void 0;var wPz=mI4(),jPz=QI4(),HPz=eL8(),dI4=-10,cI4=20,JPz=Array.from({length:31},(q,K)=>{if(K>10)return new jPz.LogarithmMapping(K-10);return new wPz.ExponentMapping(K-10)});function MPz(q){if(q>cI4||q<dI4)throw new HPz.MappingError(`expected scale >= ${dI4} && <= ${cI4}, got: ${q}`);return JPz[q+10]}lI4.getMapping=MPz});var eI4=m((sI4)=>{Object.defineProperty(sI4,"__esModule",{value:!0});sI4.ExponentialHistogramAggregator=sI4.ExponentialHistogramAccumulation=void 0;var XPz=sN6(),js6=A46(),PPz=nK(),rI4=NI4(),oI4=iI4(),WPz=tL8();class qy6{low;high;static combine(q,K){return new qy6(Math.min(q.low,K.low),Math.max(q.high,K.high))}constructor(q,K){this.low=q,this.high=K}}var DPz=20,fPz=160,YU1=2;class qR8{startTime;_maxSize;_recordMinMax;_sum;_count;_zeroCount;_min;_max;_positive;_negative;_mapping;constructor(q,K=fPz,_=!0,z=0,Y=0,$=0,A=Number.POSITIVE_INFINITY,O=Number.NEGATIVE_INFINITY,w=new rI4.Buckets,j=new rI4.Buckets,H=(0,oI4.getMapping)(DPz)){if(this.startTime=q,this._maxSize=K,this._recordMinMax=_,this._sum=z,this._count=Y,this._zeroCount=$,this._min=A,this._max=O,this._positive=w,this._negative=j,this._mapping=H,this._maxSize<YU1)PPz.diag.warn(`Exponential Histogram Max Size set to ${this._maxSize}, changing to the minimum size of: ${YU1}`),this._maxSize=YU1}record(q){this.updateByIncrement(q,1)}setStartTime(q){this.startTime=q}toPointValue(){return{hasMinMax:this._recordMinMax,min:this.min,max:this.max,sum:this.sum,positive:{offset:this.positive.offset,bucketCounts:this.positive.counts()},negative:{offset:this.negative.offset,bucketCounts:this.negative.counts()},count:this.count,scale:this.scale,zeroCount:this.zeroCount}}get sum(){return this._sum}get min(){return this._min}get max(){return this._max}get count(){return this._count}get zeroCount(){return this._zeroCount}get scale(){if(this._count===this._zeroCount)return 0;return this._mapping.scale}get positive(){return this._positive}get negative(){return this._negative}updateByIncrement(q,K){if(Number.isNaN(q))return;if(q>this._max)this._max=q;if(q<this._min)this._min=q;if(this._count+=K,q===0){this._zeroCount+=K;return}if(this._sum+=q*K,q>0)this._updateBuckets(this._positive,q,K);else this._updateBuckets(this._negative,-q,K)}merge(q){if(this._count===0)this._min=q.min,this._max=q.max;else if(q.count!==0){if(q.min<this.min)this._min=q.min;if(q.max>this.max)this._max=q.max}this.startTime=q.startTime,this._sum+=q.sum,this._count+=q.count,this._zeroCount+=q.zeroCount;let K=this._minScale(q);this._downscale(this.scale-K),this._mergeBuckets(this.positive,q,q.positive,K),this._mergeBuckets(this.negative,q,q.negative,K)}diff(q){this._min=1/0,this._max=-1/0,this._sum-=q.sum,this._count-=q.count,this._zeroCount-=q.zeroCount;let K=this._minScale(q);this._downscale(this.scale-K),this._diffBuckets(this.positive,q,q.positive,K),this._diffBuckets(this.negative,q,q.negative,K)}clone(){return new qR8(this.startTime,this._maxSize,this._recordMinMax,this._sum,this._count,this._zeroCount,this._min,this._max,this.positive.clone(),this.negative.clone(),this._mapping)}_updateBuckets(q,K,_){let z=this._mapping.mapToIndex(K),Y=!1,$=0,A=0;if(q.length===0)q.indexStart=z,q.indexEnd=q.indexStart,q.indexBase=q.indexStart;else if(z<q.indexStart&&q.indexEnd-z>=this._maxSize)Y=!0,A=z,$=q.indexEnd;else if(z>q.indexEnd&&z-q.indexStart>=this._maxSize)Y=!0,A=q.indexStart,$=z;if(Y){let O=this._changeScale($,A);this._downscale(O),z=this._mapping.mapToIndex(K)}this._incrementIndexBy(q,z,_)}_incrementIndexBy(q,K,_){if(_===0)return;if(q.length===0)q.indexStart=q.indexEnd=q.indexBase=K;if(K<q.indexStart){let Y=q.indexEnd-K;if(Y>=q.backing.length)this._grow(q,Y+1);q.indexStart=K}else if(K>q.indexEnd){let Y=K-q.indexStart;if(Y>=q.backing.length)this._grow(q,Y+1);q.indexEnd=K}let z=K-q.indexBase;if(z<0)z+=q.backing.length;q.incrementBucket(z,_)}_grow(q,K){let _=q.backing.length,z=q.indexBase-q.indexStart,Y=_-z,$=(0,WPz.nextGreaterSquare)(K);if($>this._maxSize)$=this._maxSize;let A=$-z;q.backing.growTo($,Y,A)}_changeScale(q,K){let _=0;while(q-K>=this._maxSize)q>>=1,K>>=1,_++;return _}_downscale(q){if(q===0)return;if(q<0)throw Error(`impossible change of scale: ${this.scale}`);let K=this._mapping.scale-q;this._positive.downscale(q),this._negative.downscale(q),this._mapping=(0,oI4.getMapping)(K)}_minScale(q){let K=Math.min(this.scale,q.scale),_=qy6.combine(this._highLowAtScale(this.positive,this.scale,K),this._highLowAtScale(q.positive,q.scale,K)),z=qy6.combine(this._highLowAtScale(this.negative,this.scale,K),this._highLowAtScale(q.negative,q.scale,K));return Math.min(K-this._changeScale(_.high,_.low),K-this._changeScale(z.high,z.low))}_highLowAtScale(q,K,_){if(q.length===0)return new qy6(0,-1);let z=K-_;return new qy6(q.indexStart>>z,q.indexEnd>>z)}_mergeBuckets(q,K,_,z){let Y=_.offset,$=K.scale-z;for(let A=0;A<_.length;A++)this._incrementIndexBy(q,Y+A>>$,_.at(A))}_diffBuckets(q,K,_,z){let Y=_.offset,$=K.scale-z;for(let A=0;A<_.length;A++){let w=(Y+A>>$)-q.indexBase;if(w<0)w+=q.backing.length;q.decrementBucket(w,_.at(A))}q.trim()}}sI4.ExponentialHistogramAccumulation=qR8;class aI4{_maxSize;_recordMinMax;kind=XPz.AggregatorKind.EXPONENTIAL_HISTOGRAM;constructor(q,K){this._maxSize=q,this._recordMinMax=K}createAccumulation(q){return new qR8(q,this._maxSize,this._recordMinMax)}merge(q,K){let _=K.clone();return _.merge(q),_}diff(q,K){let _=K.clone();return _.diff(q),_}toMetricData(q,K,_,z){return{descriptor:q,aggregationTemporality:K,dataPointType:js6.DataPointType.EXPONENTIAL_HISTOGRAM,dataPoints:_.map(([Y,$])=>{let A=$.toPointValue(),O=q.type===js6.InstrumentType.GAUGE||q.type===js6.InstrumentType.UP_DOWN_COUNTER||q.type===js6.InstrumentType.OBSERVABLE_GAUGE||q.type===js6.InstrumentType.OBSERVABLE_UP_DOWN_COUNTER;return{attributes:Y,startTime:$.startTime,endTime:z,value:{min:A.hasMinMax?A.min:void 0,max:A.hasMinMax?A.max:void 0,sum:!O?A.sum:void 0,positive:{offset:A.positive.offset,bucketCounts:A.positive.bucketCounts},negative:{offset:A.negative.offset,bucketCounts:A.negative.bucketCounts},count:A.count,scale:A.scale,zeroCount:A.zeroCount}}})}}}sI4.ExponentialHistogramAggregator=aI4});var zu4=m((Ku4)=>{Object.defineProperty(Ku4,"__esModule",{value:!0});Ku4.LastValueAggregator=Ku4.LastValueAccumulation=void 0;var GPz=sN6(),Hs6=Oz(),TPz=A46();class Js6{startTime;_current;sampleTime;constructor(q,K=0,_=[0,0]){this.startTime=q,this._current=K,this.sampleTime=_}record(q){this._current=q,this.sampleTime=(0,Hs6.millisToHrTime)(Date.now())}setStartTime(q){this.startTime=q}toPointValue(){return this._current}}Ku4.LastValueAccumulation=Js6;class qu4{kind=GPz.AggregatorKind.LAST_VALUE;createAccumulation(q){return new Js6(q)}merge(q,K){let _=(0,Hs6.hrTimeToMicroseconds)(K.sampleTime)>=(0,Hs6.hrTimeToMicroseconds)(q.sampleTime)?K:q;return new Js6(q.startTime,_.toPointValue(),_.sampleTime)}diff(q,K){let _=(0,Hs6.hrTimeToMicroseconds)(K.sampleTime)>=(0,Hs6.hrTimeToMicroseconds)(q.sampleTime)?K:q;return new Js6(K.startTime,_.toPointValue(),_.sampleTime)}toMetricData(q,K,_,z){return{descriptor:q,aggregationTemporality:K,dataPointType:TPz.DataPointType.GAUGE,dataPoints:_.map(([Y,$])=>{return{attributes:Y,startTime:$.startTime,endTime:z,value:$.toPointValue()}})}}}Ku4.LastValueAggregator=qu4});var Ou4=m(($u4)=>{Object.defineProperty($u4,"__esModule",{value:!0});$u4.SumAggregator=$u4.SumAccumulation=void 0;var kPz=sN6(),VPz=A46();class aw6{startTime;monotonic;_current;reset;constructor(q,K,_=0,z=!1){this.startTime=q,this.monotonic=K,this._current=_,this.reset=z}record(q){if(this.monotonic&&q<0)return;this._current+=q}setStartTime(q){this.startTime=q}toPointValue(){return this._current}}$u4.SumAccumulation=aw6;class Yu4{monotonic;kind=kPz.AggregatorKind.SUM;constructor(q){this.monotonic=q}createAccumulation(q){return new aw6(q,this.monotonic)}merge(q,K){let _=q.toPointValue(),z=K.toPointValue();if(K.reset)return new aw6(K.startTime,this.monotonic,z,K.reset);return new aw6(q.startTime,this.monotonic,_+z)}diff(q,K){let _=q.toPointValue(),z=K.toPointValue();if(this.monotonic&&_>z)return new aw6(K.startTime,this.monotonic,z,!0);return new aw6(K.startTime,this.monotonic,z-_)}toMetricData(q,K,_,z){return{descriptor:q,aggregationTemporality:K,dataPointType:VPz.DataPointType.SUM,dataPoints:_.map(([Y,$])=>{return{attributes:Y,startTime:$.startTime,endTime:z,value:$.toPointValue()}}),isMonotonic:this.monotonic}}}$u4.SumAggregator=Yu4});var Mu4=m((Dm)=>{Object.defineProperty(Dm,"__esModule",{value:!0});Dm.SumAggregator=Dm.SumAccumulation=Dm.LastValueAggregator=Dm.LastValueAccumulation=Dm.ExponentialHistogramAggregator=Dm.ExponentialHistogramAccumulation=Dm.HistogramAggregator=Dm.HistogramAccumulation=Dm.DropAggregator=void 0;var yPz=fI4();Object.defineProperty(Dm,"DropAggregator",{enumerable:!0,get:function(){return yPz.DropAggregator}});var wu4=vI4();Object.defineProperty(Dm,"HistogramAccumulation",{enumerable:!0,get:function(){return wu4.HistogramAccumulation}});Object.defineProperty(Dm,"HistogramAggregator",{enumerable:!0,get:function(){return wu4.HistogramAggregator}});var ju4=eI4();Object.defineProperty(Dm,"ExponentialHistogramAccumulation",{enumerable:!0,get:function(){return ju4.ExponentialHistogramAccumulation}});Object.defineProperty(Dm,"ExponentialHistogramAggregator",{enumerable:!0,get:function(){return ju4.ExponentialHistogramAggregator}});var Hu4=zu4();Object.defineProperty(Dm,"LastValueAccumulation",{enumerable:!0,get:function(){return Hu4.LastValueAccumulation}});Object.defineProperty(Dm,"LastValueAggregator",{enumerable:!0,get:function(){return Hu4.LastValueAggregator}});var Ju4=Ou4();Object.defineProperty(Dm,"SumAccumulation",{enumerable:!0,get:function(){return Ju4.SumAccumulation}});Object.defineProperty(Dm,"SumAggregator",{enumerable:!0,get:function(){return Ju4.SumAggregator}})});var Gu4=m((Xu4)=>{Object.defineProperty(Xu4,"__esModule",{value:!0});Xu4.DEFAULT_AGGREGATION=Xu4.EXPONENTIAL_HISTOGRAM_AGGREGATION=Xu4.HISTOGRAM_AGGREGATION=Xu4.LAST_VALUE_AGGREGATION=Xu4.SUM_AGGREGATION=Xu4.DROP_AGGREGATION=Xu4.DefaultAggregation=Xu4.ExponentialHistogramAggregation=Xu4.ExplicitBucketHistogramAggregation=Xu4.HistogramAggregation=Xu4.LastValueAggregation=Xu4.SumAggregation=Xu4.DropAggregation=void 0;var LPz=nK(),sw6=Mu4(),lU=A46();class KR8{static DEFAULT_INSTANCE=new sw6.DropAggregator;createAggregator(q){return KR8.DEFAULT_INSTANCE}}Xu4.DropAggregation=KR8;class Ms6{static MONOTONIC_INSTANCE=new sw6.SumAggregator(!0);static NON_MONOTONIC_INSTANCE=new sw6.SumAggregator(!1);createAggregator(q){switch(q.type){case lU.InstrumentType.COUNTER:case lU.InstrumentType.OBSERVABLE_COUNTER:case lU.InstrumentType.HISTOGRAM:return Ms6.MONOTONIC_INSTANCE;default:return Ms6.NON_MONOTONIC_INSTANCE}}}Xu4.SumAggregation=Ms6;class _R8{static DEFAULT_INSTANCE=new sw6.LastValueAggregator;createAggregator(q){return _R8.DEFAULT_INSTANCE}}Xu4.LastValueAggregation=_R8;class zR8{static DEFAULT_INSTANCE=new sw6.HistogramAggregator([0,5,10,25,50,75,100,250,500,750,1000,2500,5000,7500,1e4],!0);createAggregator(q){return zR8.DEFAULT_INSTANCE}}Xu4.HistogramAggregation=zR8;class $U1{_recordMinMax;_boundaries;constructor(q,K=!0){if(this._recordMinMax=K,q==null)throw Error("ExplicitBucketHistogramAggregation should be created with explicit boundaries, if a single bucket histogram is required, please pass an empty array");q=q.concat(),q=q.sort((Y,$)=>Y-$);let _=q.lastIndexOf(-1/0),z=q.indexOf(1/0);if(z===-1)z=void 0;this._boundaries=q.slice(_+1,z)}createAggregator(q){return new sw6.HistogramAggregator(this._boundaries,this._recordMinMax)}}Xu4.ExplicitBucketHistogramAggregation=$U1;class AU1{_maxSize;_recordMinMax;constructor(q=160,K=!0){this._maxSize=q,this._recordMinMax=K}createAggregator(q){return new sw6.ExponentialHistogramAggregator(this._maxSize,this._recordMinMax)}}Xu4.ExponentialHistogramAggregation=AU1;class OU1{_resolve(q){switch(q.type){case lU.InstrumentType.COUNTER:case lU.InstrumentType.UP_DOWN_COUNTER:case lU.InstrumentType.OBSERVABLE_COUNTER:case lU.InstrumentType.OBSERVABLE_UP_DOWN_COUNTER:return Xu4.SUM_AGGREGATION;case lU.InstrumentType.GAUGE:case lU.InstrumentType.OBSERVABLE_GAUGE:return Xu4.LAST_VALUE_AGGREGATION;case lU.InstrumentType.HISTOGRAM:{if(q.advice.explicitBucketBoundaries)return new $U1(q.advice.explicitBucketBoundaries);return Xu4.HISTOGRAM_AGGREGATION}}return LPz.diag.warn(`Unable to recognize instrument type: ${q.type}`),Xu4.DROP_AGGREGATION}createAggregator(q){return this._resolve(q).createAggregator(q)}}Xu4.DefaultAggregation=OU1;Xu4.DROP_AGGREGATION=new KR8;Xu4.SUM_AGGREGATION=new Ms6;Xu4.LAST_VALUE_AGGREGATION=new _R8;Xu4.HISTOGRAM_AGGREGATION=new zR8;Xu4.EXPONENTIAL_HISTOGRAM_AGGREGATION=new AU1;Xu4.DEFAULT_AGGREGATION=new OU1});var Xs6=m((vu4)=>{Object.defineProperty(vu4,"__esModule",{value:!0});vu4.toAggregation=vu4.AggregationType=void 0;var tw6=Gu4(),ew6;(function(q){q[q.DEFAULT=0]="DEFAULT",q[q.DROP=1]="DROP",q[q.SUM=2]="SUM",q[q.LAST_VALUE=3]="LAST_VALUE",q[q.EXPLICIT_BUCKET_HISTOGRAM=4]="EXPLICIT_BUCKET_HISTOGRAM",q[q.EXPONENTIAL_HISTOGRAM=5]="EXPONENTIAL_HISTOGRAM"})(ew6=vu4.AggregationType||(vu4.AggregationType={}));function mPz(q){switch(q.type){case ew6.DEFAULT:return tw6.DEFAULT_AGGREGATION;case ew6.DROP:return tw6.DROP_AGGREGATION;case ew6.SUM:return tw6.SUM_AGGREGATION;case ew6.LAST_VALUE:return tw6.LAST_VALUE_AGGREGATION;case ew6.EXPONENTIAL_HISTOGRAM:{let K=q;return new tw6.ExponentialHistogramAggregation(K.options?.maxSize,K.options?.recordMinMax)}case ew6.EXPLICIT_BUCKET_HISTOGRAM:{let K=q;if(K.options==null)return tw6.HISTOGRAM_AGGREGATION;else return new tw6.ExplicitBucketHistogramAggregation(K.options?.boundaries,K.options?.recordMinMax)}default:throw Error("Unsupported Aggregation")}}vu4.toAggregation=mPz});var wU1=m((Vu4)=>{Object.defineProperty(Vu4,"__esModule",{value:!0});Vu4.DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR=Vu4.DEFAULT_AGGREGATION_SELECTOR=void 0;var pPz=aL8(),BPz=Xs6(),gPz=(q)=>{return{type:BPz.AggregationType.DEFAULT}};Vu4.DEFAULT_AGGREGATION_SELECTOR=gPz;var FPz=(q)=>pPz.AggregationTemporality.CUMULATIVE;Vu4.DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR=FPz});var jU1=m((Ru4)=>{Object.defineProperty(Ru4,"__esModule",{value:!0});Ru4.MetricReader=void 0;var yu4=nK(),YR8=Wm(),Eu4=wU1();class Lu4{_shutdown=!1;_metricProducers;_sdkMetricProducer;_aggregationTemporalitySelector;_aggregationSelector;_cardinalitySelector;constructor(q){this._aggregationSelector=q?.aggregationSelector??Eu4.DEFAULT_AGGREGATION_SELECTOR,this._aggregationTemporalitySelector=q?.aggregationTemporalitySelector??Eu4.DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR,this._metricProducers=q?.metricProducers??[],this._cardinalitySelector=q?.cardinalitySelector}setMetricProducer(q){if(this._sdkMetricProducer)throw Error("MetricReader can not be bound to a MeterProvider again.");this._sdkMetricProducer=q,this.onInitialized()}selectAggregation(q){return this._aggregationSelector(q)}selectAggregationTemporality(q){return this._aggregationTemporalitySelector(q)}selectCardinalityLimit(q){return this._cardinalitySelector?this._cardinalitySelector(q):2000}onInitialized(){}async collect(q){if(this._sdkMetricProducer===void 0)throw Error("MetricReader is not bound to a MetricProducer");if(this._shutdown)throw Error("MetricReader is shutdown");let[K,..._]=await Promise.all([this._sdkMetricProducer.collect({timeoutMillis:q?.timeoutMillis}),...this._metricProducers.map((A)=>A.collect({timeoutMillis:q?.timeoutMillis}))]),z=K.errors.concat((0,YR8.FlatMap)(_,(A)=>A.errors)),Y=K.resourceMetrics.resource,$=K.resourceMetrics.scopeMetrics.concat((0,YR8.FlatMap)(_,(A)=>A.resourceMetrics.scopeMetrics));return{resourceMetrics:{resource:Y,scopeMetrics:$},errors:z}}async shutdown(q){if(this._shutdown){yu4.diag.error("Cannot call shutdown twice.");return}if(q?.timeoutMillis==null)await this.onShutdown();else await(0,YR8.callWithTimeout)(this.onShutdown(),q.timeoutMillis);this._shutdown=!0}async forceFlush(q){if(this._shutdown){yu4.diag.warn("Cannot forceFlush on already shutdown MetricReader.");return}if(q?.timeoutMillis==null){await this.onForceFlush();return}await(0,YR8.callWithTimeout)(this.onForceFlush(),q.timeoutMillis)}}Ru4.MetricReader=Lu4});var Iu4=m((bu4)=>{Object.defineProperty(bu4,"__esModule",{value:!0});bu4.PeriodicExportingMetricReader=void 0;var HU1=nK(),$R8=Oz(),QPz=jU1(),Su4=Wm();class Cu4 extends QPz.MetricReader{_interval;_exporter;_exportInterval;_exportTimeout;constructor(q){super({aggregationSelector:q.exporter.selectAggregation?.bind(q.exporter),aggregationTemporalitySelector:q.exporter.selectAggregationTemporality?.bind(q.exporter),metricProducers:q.metricProducers});if(q.exportIntervalMillis!==void 0&&q.exportIntervalMillis<=0)throw Error("exportIntervalMillis must be greater than 0");if(q.exportTimeoutMillis!==void 0&&q.exportTimeoutMillis<=0)throw Error("exportTimeoutMillis must be greater than 0");if(q.exportTimeoutMillis!==void 0&&q.exportIntervalMillis!==void 0&&q.exportIntervalMillis<q.exportTimeoutMillis)throw Error("exportIntervalMillis must be greater than or equal to exportTimeoutMillis");this._exportInterval=q.exportIntervalMillis??60000,this._exportTimeout=q.exportTimeoutMillis??30000,this._exporter=q.exporter}async _runOnce(){try{await(0,Su4.callWithTimeout)(this._doRun(),this._exportTimeout)}catch(q){if(q instanceof Su4.TimeoutError){HU1.diag.error("Export took longer than %s milliseconds and timed out.",this._exportTimeout);return}(0,$R8.globalErrorHandler)(q)}}async _doRun(){let{resourceMetrics:q,errors:K}=await this.collect({timeoutMillis:this._exportTimeout});if(K.length>0)HU1.diag.error("PeriodicExportingMetricReader: metrics collection errors",...K);if(q.resource.asyncAttributesPending)try{await q.resource.waitForAsyncAttributes?.()}catch(z){HU1.diag.debug("Error while resolving async portion of resource: ",z),(0,$R8.globalErrorHandler)(z)}if(q.scopeMetrics.length===0)return;let _=await $R8.internal._export(this._exporter,q);if(_.code!==$R8.ExportResultCode.SUCCESS)throw Error(`PeriodicExportingMetricReader: metrics export failed (error ${_.error})`)}onInitialized(){if(this._interval=setInterval(()=>{this._runOnce()},this._exportInterval),typeof this._interval!=="number")this._interval.unref()}async onForceFlush(){await this._runOnce(),await this._exporter.forceFlush()}async onShutdown(){if(this._interval)clearInterval(this._interval);await this.onForceFlush(),await this._exporter.shutdown()}}bu4.PeriodicExportingMetricReader=Cu4});var gu4=m((pu4)=>{Object.defineProperty(pu4,"__esModule",{value:!0});pu4.InMemoryMetricExporter=void 0;var uu4=Oz();class mu4{_shutdown=!1;_aggregationTemporality;_metrics=[];constructor(q){this._aggregationTemporality=q}export(q,K){if(this._shutdown){setTimeout(()=>K({code:uu4.ExportResultCode.FAILED}),0);return}this._metrics.push(q),setTimeout(()=>K({code:uu4.ExportResultCode.SUCCESS}),0)}getMetrics(){return this._metrics}forceFlush(){return Promise.resolve()}reset(){this._metrics=[]}selectAggregationTemporality(q){return this._aggregationTemporality}shutdown(){return this._shutdown=!0,Promise.resolve()}}pu4.InMemoryMetricExporter=mu4});var du4=m((Uu4)=>{Object.defineProperty(Uu4,"__esModule",{value:!0});Uu4.ConsoleMetricExporter=void 0;var Fu4=Oz(),dPz=wU1();class JU1{_shutdown=!1;_temporalitySelector;constructor(q){this._temporalitySelector=q?.temporalitySelector??dPz.DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR}export(q,K){if(this._shutdown){setImmediate(K,{code:Fu4.ExportResultCode.FAILED});return}return JU1._sendMetrics(q,K)}forceFlush(){return Promise.resolve()}selectAggregationTemporality(q){return this._temporalitySelector(q)}shutdown(){return this._shutdown=!0,Promise.resolve()}static _sendMetrics(q,K){for(let _ of q.scopeMetrics)for(let z of _.metrics)console.dir({descriptor:z.descriptor,dataPointType:z.dataPointType,dataPoints:z.dataPoints},{depth:null});K({code:Fu4.ExportResultCode.SUCCESS})}}Uu4.ConsoleMetricExporter=JU1});var iu4=m((lu4)=>{Object.defineProperty(lu4,"__esModule",{value:!0});lu4.ViewRegistry=void 0;class cu4{_registeredViews=[];addView(q){this._registeredViews.push(q)}findViews(q,K){return this._registeredViews.filter((z)=>{return this._matchInstrument(z.instrumentSelector,q)&&this._matchMeter(z.meterSelector,K)})}_matchInstrument(q,K){return(q.getType()===void 0||K.type===q.getType())&&q.getNameFilter().match(K.name)&&q.getUnitFilter().match(K.unit)}_matchMeter(q,K){return q.getNameFilter().match(K.name)&&(K.version===void 0||q.getVersionFilter().match(K.version))&&(K.schemaUrl===void 0||q.getSchemaUrlFilter().match(K.schemaUrl))}}lu4.ViewRegistry=cu4});var Ps6=m((au4)=>{Object.defineProperty(au4,"__esModule",{value:!0});au4.isValidName=au4.isDescriptorCompatibleWith=au4.createInstrumentDescriptorWithView=au4.createInstrumentDescriptor=void 0;var ru4=nK(),cPz=Wm();function lPz(q,K,_){if(!ou4(q))ru4.diag.warn(`Invalid metric name: "${q}". The metric name should be a ASCII string with a length no greater than 255 characters.`);return{name:q,type:K,description:_?.description??"",unit:_?.unit??"",valueType:_?.valueType??ru4.ValueType.DOUBLE,advice:_?.advice??{}}}au4.createInstrumentDescriptor=lPz;function nPz(q,K){return{name:q.name??K.name,description:q.description??K.description,type:K.type,unit:K.unit,valueType:K.valueType,advice:K.advice}}au4.createInstrumentDescriptorWithView=nPz;function iPz(q,K){return(0,cPz.equalsCaseInsensitive)(q.name,K.name)&&q.unit===K.unit&&q.type===K.type&&q.valueType===K.valueType}au4.isDescriptorCompatibleWith=iPz;var rPz=/^[a-z][a-z0-9_.\-/]{0,254}$/i;function ou4(q){return q.match(rPz)!=null}au4.isValidName=ou4});var AR8=m(($m4)=>{Object.defineProperty($m4,"__esModule",{value:!0});$m4.isObservableInstrument=$m4.ObservableUpDownCounterInstrument=$m4.ObservableGaugeInstrument=$m4.ObservableCounterInstrument=$m4.ObservableInstrument=$m4.HistogramInstrument=$m4.GaugeInstrument=$m4.CounterInstrument=$m4.UpDownCounterInstrument=$m4.SyncInstrument=void 0;var Ky6=nK(),tPz=Oz();class _y6{_writableMetricStorage;_descriptor;constructor(q,K){this._writableMetricStorage=q,this._descriptor=K}_record(q,K={},_=Ky6.context.active()){if(typeof q!=="number"){Ky6.diag.warn(`non-number value provided to metric ${this._descriptor.name}: ${q}`);return}if(this._descriptor.valueType===Ky6.ValueType.INT&&!Number.isInteger(q)){if(Ky6.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`),q=Math.trunc(q),!Number.isInteger(q))return}this._writableMetricStorage.record(q,K,_,(0,tPz.millisToHrTime)(Date.now()))}}$m4.SyncInstrument=_y6;class tu4 extends _y6{add(q,K,_){this._record(q,K,_)}}$m4.UpDownCounterInstrument=tu4;class eu4 extends _y6{add(q,K,_){if(q<0){Ky6.diag.warn(`negative value provided to counter ${this._descriptor.name}: ${q}`);return}this._record(q,K,_)}}$m4.CounterInstrument=eu4;class qm4 extends _y6{record(q,K,_){this._record(q,K,_)}}$m4.GaugeInstrument=qm4;class Km4 extends _y6{record(q,K,_){if(q<0){Ky6.diag.warn(`negative value provided to histogram ${this._descriptor.name}: ${q}`);return}this._record(q,K,_)}}$m4.HistogramInstrument=Km4;class zy6{_observableRegistry;_metricStorages;_descriptor;constructor(q,K,_){this._observableRegistry=_,this._descriptor=q,this._metricStorages=K}addCallback(q){this._observableRegistry.addCallback(q,this)}removeCallback(q){this._observableRegistry.removeCallback(q,this)}}$m4.ObservableInstrument=zy6;class _m4 extends zy6{}$m4.ObservableCounterInstrument=_m4;class zm4 extends zy6{}$m4.ObservableGaugeInstrument=zm4;class Ym4 extends zy6{}$m4.ObservableUpDownCounterInstrument=Ym4;function ePz(q){return q instanceof zy6}$m4.isObservableInstrument=ePz});var Hm4=m((wm4)=>{Object.defineProperty(wm4,"__esModule",{value:!0});wm4.Meter=void 0;var q26=Ps6(),K26=AR8(),_26=A46();class Om4{_meterSharedState;constructor(q){this._meterSharedState=q}createGauge(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.GAUGE,K),z=this._meterSharedState.registerMetricStorage(_);return new K26.GaugeInstrument(z,_)}createHistogram(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.HISTOGRAM,K),z=this._meterSharedState.registerMetricStorage(_);return new K26.HistogramInstrument(z,_)}createCounter(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.COUNTER,K),z=this._meterSharedState.registerMetricStorage(_);return new K26.CounterInstrument(z,_)}createUpDownCounter(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.UP_DOWN_COUNTER,K),z=this._meterSharedState.registerMetricStorage(_);return new K26.UpDownCounterInstrument(z,_)}createObservableGauge(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.OBSERVABLE_GAUGE,K),z=this._meterSharedState.registerAsyncMetricStorage(_);return new K26.ObservableGaugeInstrument(_,z,this._meterSharedState.observableRegistry)}createObservableCounter(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.OBSERVABLE_COUNTER,K),z=this._meterSharedState.registerAsyncMetricStorage(_);return new K26.ObservableCounterInstrument(_,z,this._meterSharedState.observableRegistry)}createObservableUpDownCounter(q,K){let _=(0,q26.createInstrumentDescriptor)(q,_26.InstrumentType.OBSERVABLE_UP_DOWN_COUNTER,K),z=this._meterSharedState.registerAsyncMetricStorage(_);return new K26.ObservableUpDownCounterInstrument(_,z,this._meterSharedState.observableRegistry)}addBatchObservableCallback(q,K){this._meterSharedState.observableRegistry.addBatchCallback(q,K)}removeBatchObservableCallback(q,K){this._meterSharedState.observableRegistry.removeBatchCallback(q,K)}}wm4.Meter=Om4});var MU1=m((Mm4)=>{Object.defineProperty(Mm4,"__esModule",{value:!0});Mm4.MetricStorage=void 0;var jWz=Ps6();class Jm4{_instrumentDescriptor;constructor(q){this._instrumentDescriptor=q}getInstrumentDescriptor(){return this._instrumentDescriptor}updateDescription(q){this._instrumentDescriptor=(0,jWz.createInstrumentDescriptor)(this._instrumentDescriptor.name,this._instrumentDescriptor.type,{description:q,valueType:this._instrumentDescriptor.valueType,unit:this._instrumentDescriptor.unit,advice:this._instrumentDescriptor.advice})}}Mm4.MetricStorage=Jm4});var Ws6=m((Wm4)=>{Object.defineProperty(Wm4,"__esModule",{value:!0});Wm4.AttributeHashMap=Wm4.HashMap=void 0;var HWz=Wm();class XU1{_hash;_valueMap=new Map;_keyMap=new Map;constructor(q){this._hash=q}get(q,K){return K??=this._hash(q),this._valueMap.get(K)}getOrDefault(q,K){let _=this._hash(q);if(this._valueMap.has(_))return this._valueMap.get(_);let z=K();if(!this._keyMap.has(_))this._keyMap.set(_,q);return this._valueMap.set(_,z),z}set(q,K,_){if(_??=this._hash(q),!this._keyMap.has(_))this._keyMap.set(_,q);this._valueMap.set(_,K)}has(q,K){return K??=this._hash(q),this._valueMap.has(K)}*keys(){let q=this._keyMap.entries(),K=q.next();while(K.done!==!0)yield[K.value[1],K.value[0]],K=q.next()}*entries(){let q=this._valueMap.entries(),K=q.next();while(K.done!==!0)yield[this._keyMap.get(K.value[0]),K.value[1],K.value[0]],K=q.next()}get size(){return this._valueMap.size}}Wm4.HashMap=XU1;class Pm4 extends XU1{constructor(){super(HWz.hashAttributes)}}Wm4.AttributeHashMap=Pm4});var WU1=m((Zm4)=>{Object.defineProperty(Zm4,"__esModule",{value:!0});Zm4.DeltaMetricProcessor=void 0;var MWz=Wm(),PU1=Ws6();class fm4{_aggregator;_activeCollectionStorage=new PU1.AttributeHashMap;_cumulativeMemoStorage=new PU1.AttributeHashMap;_cardinalityLimit;_overflowAttributes={"otel.metric.overflow":!0};_overflowHashCode;constructor(q,K){this._aggregator=q,this._cardinalityLimit=(K??2000)-1,this._overflowHashCode=(0,MWz.hashAttributes)(this._overflowAttributes)}record(q,K,_,z){let Y=this._activeCollectionStorage.get(K);if(!Y){if(this._activeCollectionStorage.size>=this._cardinalityLimit){this._activeCollectionStorage.getOrDefault(this._overflowAttributes,()=>this._aggregator.createAccumulation(z))?.record(q);return}Y=this._aggregator.createAccumulation(z),this._activeCollectionStorage.set(K,Y)}Y?.record(q)}batchCumulate(q,K){Array.from(q.entries()).forEach(([_,z,Y])=>{let $=this._aggregator.createAccumulation(K);$?.record(z);let A=$;if(this._cumulativeMemoStorage.has(_,Y)){let O=this._cumulativeMemoStorage.get(_,Y);A=this._aggregator.diff(O,$)}else if(this._cumulativeMemoStorage.size>=this._cardinalityLimit){if(_=this._overflowAttributes,Y=this._overflowHashCode,this._cumulativeMemoStorage.has(_,Y)){let O=this._cumulativeMemoStorage.get(_,Y);A=this._aggregator.diff(O,$)}}if(this._activeCollectionStorage.has(_,Y)){let O=this._activeCollectionStorage.get(_,Y);A=this._aggregator.merge(O,A)}this._cumulativeMemoStorage.set(_,$,Y),this._activeCollectionStorage.set(_,A,Y)})}collect(){let q=this._activeCollectionStorage;return this._activeCollectionStorage=new PU1.AttributeHashMap,q}}Zm4.DeltaMetricProcessor=fm4});var DU1=m((Tm4)=>{Object.defineProperty(Tm4,"__esModule",{value:!0});Tm4.TemporalMetricProcessor=void 0;var XWz=aL8(),PWz=Ws6();class Ds6{_aggregator;_unreportedAccumulations=new Map;_reportHistory=new Map;constructor(q,K){this._aggregator=q,K.forEach((_)=>{this._unreportedAccumulations.set(_,[])})}buildMetrics(q,K,_,z){this._stashAccumulations(_);let Y=this._getMergedUnreportedAccumulations(q),$=Y,A;if(this._reportHistory.has(q)){let w=this._reportHistory.get(q),j=w.collectionTime;if(A=w.aggregationTemporality,A===XWz.AggregationTemporality.CUMULATIVE)$=Ds6.merge(w.accumulations,Y,this._aggregator);else $=Ds6.calibrateStartTime(w.accumulations,Y,j)}else A=q.selectAggregationTemporality(K.type);this._reportHistory.set(q,{accumulations:$,collectionTime:z,aggregationTemporality:A});let O=WWz($);if(O.length===0)return;return this._aggregator.toMetricData(K,A,O,z)}_stashAccumulations(q){let K=this._unreportedAccumulations.keys();for(let _ of K){let z=this._unreportedAccumulations.get(_);if(z===void 0)z=[],this._unreportedAccumulations.set(_,z);z.push(q)}}_getMergedUnreportedAccumulations(q){let K=new PWz.AttributeHashMap,_=this._unreportedAccumulations.get(q);if(this._unreportedAccumulations.set(q,[]),_===void 0)return K;for(let z of _)K=Ds6.merge(K,z,this._aggregator);return K}static merge(q,K,_){let z=q,Y=K.entries(),$=Y.next();while($.done!==!0){let[A,O,w]=$.value;if(q.has(A,w)){let j=q.get(A,w),H=_.merge(j,O);z.set(A,H,w)}else z.set(A,O,w);$=Y.next()}return z}static calibrateStartTime(q,K,_){for(let[z,Y]of q.keys())K.get(z,Y)?.setStartTime(_);return K}}Tm4.TemporalMetricProcessor=Ds6;function WWz(q){return Array.from(q.entries())}});var ym4=m((Vm4)=>{Object.defineProperty(Vm4,"__esModule",{value:!0});Vm4.AsyncMetricStorage=void 0;var DWz=MU1(),fWz=WU1(),ZWz=DU1(),GWz=Ws6();class km4 extends DWz.MetricStorage{_attributesProcessor;_aggregationCardinalityLimit;_deltaMetricStorage;_temporalMetricStorage;constructor(q,K,_,z,Y){super(q);this._attributesProcessor=_,this._aggregationCardinalityLimit=Y,this._deltaMetricStorage=new fWz.DeltaMetricProcessor(K,this._aggregationCardinalityLimit),this._temporalMetricStorage=new ZWz.TemporalMetricProcessor(K,z)}record(q,K){let _=new GWz.AttributeHashMap;Array.from(q.entries()).forEach(([z,Y])=>{_.set(this._attributesProcessor.process(z),Y)}),this._deltaMetricStorage.batchCumulate(_,K)}collect(q,K){let _=this._deltaMetricStorage.collect();return this._temporalMetricStorage.buildMetrics(q,this._instrumentDescriptor,_,K)}}Vm4.AsyncMetricStorage=km4});var bm4=m((Sm4)=>{Object.defineProperty(Sm4,"__esModule",{value:!0});Sm4.getConflictResolutionRecipe=Sm4.getDescriptionResolutionRecipe=Sm4.getTypeConflictResolutionRecipe=Sm4.getUnitConflictResolutionRecipe=Sm4.getValueTypeConflictResolutionRecipe=Sm4.getIncompatibilityDetails=void 0;function TWz(q,K){let _="";if(q.unit!==K.unit)_+=` - Unit '${q.unit}' does not match '${K.unit}'
2046`;if(q.type!==K.type)_+=` - Type '${q.type}' does not match '${K.type}'
2047`;if(q.valueType!==K.valueType)_+=` - Value Type '${q.valueType}' does not match '${K.valueType}'

Callers 1

fsYFunction · 0.85

Calls 4

PmFunction · 0.85
wlFunction · 0.85
aF1Function · 0.85
GXzFunction · 0.85

Tested by

no test coverage detected