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

Function HS

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

Source from the content-addressed store, hash-verified

455GFS4: `),console.error(q)};if(!ZH[nf]){if(_v1=global[nf]||[],wCq(ZH,_v1),ZH.close=function(q){function K(_,z){return q.call(ZH,_,function(Y){if(!Y)OCq();if(typeof z==="function")z.apply(this,arguments)})}return Object.defineProperty(K,XD8,{value:q}),K}(ZH.close),ZH.closeSync=function(q){function K(_){q.apply(ZH,arguments),OCq()}return Object.defineProperty(K,XD8,{value:q}),K}(ZH.closeSync),/\bgfs4\b/i.test(process.env.NODE_DEBUG||""))process.on("exit",function(){H$6(ZH[nf]),U6("assert").equal(ZH[nf].length,0)})}var _v1;if(!global[nf])wCq(global,ZH[nf]);$v1.exports=zv1(Ut9(ZH));if(process.env.TEST_GRACEFUL_FS_GLOBAL_PATCH&&!ZH.__patched)$v1.exports=zv1(ZH),ZH.__patched=!0;function zv1(q){gt9(q),q.gracefulify=zv1,q.createReadStream=v,q.createWriteStream=V;var K=q.readFile;q.readFile=_;function _(R,x,I){if(typeof x==="function")I=x,x=null;return B(R,x,I);function B(p,C,g,F){return K(p,C,function(U){if(U&&(U.code==="EMFILE"||U.code==="ENFILE"))ZG6([B,[p,C,g],U,F||Date.now(),Date.now()]);else if(typeof g==="function")g.apply(this,arguments)})}}var z=q.writeFile;q.writeFile=Y;function Y(R,x,I,B){if(typeof I==="function")B=I,I=null;return p(R,x,I,B);function p(C,g,F,U,c){return z(C,g,F,function(K6){if(K6&&(K6.code==="EMFILE"||K6.code==="ENFILE"))ZG6([p,[C,g,F,U],K6,c||Date.now(),Date.now()]);else if(typeof U==="function")U.apply(this,arguments)})}}var $=q.appendFile;if($)q.appendFile=A;function A(R,x,I,B){if(typeof I==="function")B=I,I=null;return p(R,x,I,B);function p(C,g,F,U,c){return $(C,g,F,function(K6){if(K6&&(K6.code==="EMFILE"||K6.code==="ENFILE"))ZG6([p,[C,g,F,U],K6,c||Date.now(),Date.now()]);else if(typeof U==="function")U.apply(this,arguments)})}}var O=q.copyFile;if(O)q.copyFile=w;function w(R,x,I,B){if(typeof I==="function")B=I,I=0;return p(R,x,I,B);function p(C,g,F,U,c){return O(C,g,F,function(K6){if(K6&&(K6.code==="EMFILE"||K6.code==="ENFILE"))ZG6([p,[C,g,F,U],K6,c||Date.now(),Date.now()]);else if(typeof U==="function")U.apply(this,arguments)})}}var j=q.readdir;q.readdir=J;var H=/^v[0-5]\./;function J(R,x,I){if(typeof x==="function")I=x,x=null;var B=H.test(process.version)?function(g,F,U,c){return j(g,p(g,F,U,c))}:function(g,F,U,c){return j(g,F,p(g,F,U,c))};return B(R,x,I);function p(C,g,F,U){return function(c,K6){if(c&&(c.code==="EMFILE"||c.code==="ENFILE"))ZG6([B,[C,g,F],c,U||Date.now(),Date.now()]);else{if(K6&&K6.sort)K6.sort();if(typeof F==="function")F.call(this,c,K6)}}}}if(process.version.substr(0,4)==="v0.8"){var M=Ft9(q);f=M.ReadStream,Z=M.WriteStream}var X=q.ReadStream;if(X)f.prototype=Object.create(X.prototype),f.prototype.open=G;var P=q.WriteStream;if(P)Z.prototype=Object.create(P.prototype),Z.prototype.open=T;Object.defineProperty(q,"ReadStream",{get:function(){return f},set:function(R){f=R},enumerable:!0,configurable:!0}),Object.defineProperty(q,"WriteStream",{get:function(){return Z},set:function(R){Z=R},enumerable:!0,configurable:!0});var W=f;Object.defineProperty(q,"FileReadStream",{get:function(){return W},set:function(R){W=R},enumerable:!0,configurable:!0});var D=Z;Object.defineProperty(q,"FileWriteStream",{get:function(){return D},set:function(R){D=R},enumerable:!0,configurable:!0});function f(R,x){if(this instanceof f)return X.apply(this,arguments),this;else return f.apply(Object.create(f.prototype),arguments)}function G(){var R=this;S(R.path,R.flags,R.mode,function(x,I){if(x){if(R.autoClose)R.destroy();R.emit("error",x)}else R.fd=I,R.emit("open",I),R.read()})}function Z(R,x){if(this instanceof Z)return P.apply(this,arguments),this;else return Z.apply(Object.create(Z.prototype),arguments)}function T(){var R=this;S(R.path,R.flags,R.mode,function(x,I){if(x)R.destroy(),R.emit("error",x);else R.fd=I,R.emit("open",I)})}function v(R,x){return new q.ReadStream(R,x)}function V(R,x){return new q.WriteStream(R,x)}var E=q.open;q.open=S;function S(R,x,I,B){if(typeof I==="function")B=I,I=null;return p(R,x,I,B);function p(C,g,F,U,c){return E(C,g,F,function(K6,t){if(K6&&(K6.code==="EMFILE"||K6.code==="ENFILE"))ZG6([p,[C,g,F,U],K6,c||Date.now(),Date.now()]);else if(typeof U==="function")U.apply(this,arguments)})}}return q}function ZG6(q){H$6("ENQUEUE",q[0].name,q[1]),ZH[nf].push(q),Yv1()}var MD8;function OCq(){var q=Date.now();for(var K=0;K<ZH[nf].length;++K)if(ZH[nf][K].length>2)ZH[nf][K][3]=q,ZH[nf][K][4]=q;Yv1()}function Yv1(){if(clearTimeout(MD8),MD8=void 0,ZH[nf].length===0)return;var q=ZH[nf].shift(),K=q[0],_=q[1],z=q[2],Y=q[3],$=q[4];if(Y===void 0)H$6("RETRY",K.name,_),K.apply(null,_);else if(Date.now()-Y>=60000){H$6("TIMEOUT",K.name,_);var A=_.pop();if(typeof A==="function")A.call(null,z)}else{var O=Date.now()-$,w=Math.max($-Y,1),j=Math.min(w*1.2,100);if(O>=j)H$6("RETRY",K.name,_),K.apply(null,_.concat([Y]));else ZH[nf].push(q)}if(MD8===void 0)MD8=setTimeout(Yv1,0)}});var HCq=m((NDA,jCq)=>{function SS(q,K){if(typeof K==="boolean")K={forever:K};if(this._originalTimeouts=JSON.parse(JSON.stringify(q)),this._timeouts=q,this._options=K||{},this._maxRetryTime=K&&K.maxRetryTime||1/0,this._fn=null,this._errors=[],this._attempts=1,this._operationTimeout=null,this._operationTimeoutCb=null,this._timeout=null,this._operationStart=null,this._options.forever)this._cachedTimeouts=this._timeouts.slice(0)}jCq.exports=SS;SS.prototype.reset=function(){this._attempts=1,this._timeouts=this._originalTimeouts};SS.prototype.stop=function(){if(this._timeout)clearTimeout(this._timeout);this._timeouts=[],this._cachedTimeouts=null};SS.prototype.retry=function(q){if(this._timeout)clearTimeout(this._timeout);if(!q)return!1;var K=new Date().getTime();if(q&&K-this._operationStart>=this._maxRetryTime)return this._errors.unshift(Error("RetryOperation timeout occurred")),!1;this._errors.push(q);var _=this._timeouts.shift();if(_===void 0)if(this._cachedTimeouts)this._errors.splice(this._errors.length-1,this._errors.length),this._timeouts=this._cachedTimeouts.slice(0),_=this._timeouts.shift();else return!1;var z=this,Y=setTimeout(function(){if(z._attempts++,z._operationTimeoutCb){if(z._timeout=setTimeout(function(){z._operationTimeoutCb(z._attempts)},z._operationTimeout),z._options.unref)z._timeout.unref()}z._fn(z._attempts)},_);if(this._options.unref)Y.unref();return!0};SS.prototype.attempt=function(q,K){if(this._fn=q,K){if(K.timeout)this._operationTimeout=K.timeout;if(K.cb)this._operationTimeoutCb=K.cb}var _=this;if(this._operationTimeoutCb)this._timeout=setTimeout(function(){_._operationTimeoutCb()},_._operationTimeout);this._operationStart=new Date().getTime(),this._fn(this._attempts)};SS.prototype.try=function(q){console.log("Using RetryOperation.try() is deprecated"),this.attempt(q)};SS.prototype.start=function(q){console.log("Using RetryOperation.start() is deprecated"),this.attempt(q)};SS.prototype.start=SS.prototype.try;SS.prototype.errors=function(){return this._errors};SS.prototype.attempts=function(){return this._attempts};SS.prototype.mainError=function(){if(this._errors.length===0)return null;var q={},K=null,_=0;for(var z=0;z<this._errors.length;z++){var Y=this._errors[z],$=Y.message,A=(q[$]||0)+1;if(q[$]=A,A>=_)K=Y,_=A}return K}});var MCq=m((ct9)=>{var dt9=HCq();ct9.operation=function(q){var K=ct9.timeouts(q);return new dt9(K,{forever:q&&q.forever,unref:q&&q.unref,maxRetryTime:q&&q.maxRetryTime})};ct9.timeouts=function(q){if(q instanceof Array)return[].concat(q);var K={retries:10,factor:2,minTimeout:1000,maxTimeout:1/0,randomize:!1};for(var _ in q)K[_]=q[_];if(K.minTimeout>K.maxTimeout)throw Error("minTimeout is greater than maxTimeout");var z=[];for(var Y=0;Y<K.retries;Y++)z.push(this.createTimeout(Y,K));if(q&&q.forever&&!z.length)z.push(this.createTimeout(Y,K));return z.sort(function($,A){return $-A}),z};ct9.createTimeout=function(q,K){var _=K.randomize?Math.random()+1:1,z=Math.round(_*K.minTimeout*Math.pow(K.factor,q));return z=Math.min(z,K.maxTimeout),z};ct9.wrap=function(q,K,_){if(K instanceof Array)_=K,K=null;if(!_){_=[];for(var z in q)if(typeof q[z]==="function")_.push(z)}for(var Y=0;Y<_.length;Y++){var $=_[Y],A=q[$];q[$]=function(w){var j=ct9.operation(K),H=Array.prototype.slice.call(arguments,1),J=H.pop();H.push(function(M){if(j.retry(M))return;if(M)arguments[0]=j.mainError();J.apply(this,arguments)}),j.attempt(function(){w.apply(q,H)})}.bind(q,A),q[$].options=K}}});var XCq=m((EDA,PD8)=>{PD8.exports=["SIGABRT","SIGALRM","SIGHUP","SIGINT","SIGTERM"];if(process.platform!=="win32")PD8.exports.push("SIGVTALRM","SIGXCPU","SIGXFSZ","SIGUSR2","SIGTRAP","SIGSYS","SIGQUIT","SIGIOT");if(process.platform==="linux")PD8.exports.push("SIGIO","SIGPOLL","SIGPWR","SIGSTKFLT","SIGUNUSED")});var PCq=m((LDA,TG6)=>{var Tj=global.process,J$6=function(q){return q&&typeof q==="object"&&typeof q.removeListener==="function"&&typeof q.emit==="function"&&typeof q.reallyExit==="function"&&typeof q.listeners==="function"&&typeof q.kill==="function"&&typeof q.pid==="number"&&typeof q.on==="function"};if(!J$6(Tj))TG6.exports=function(){return function(){}};else{if(Av1=U6("assert"),M$6=XCq(),Ov1=/^win/i.test(Tj.platform),GG6=U6("events"),typeof GG6!=="function")GG6=GG6.EventEmitter;if(Tj.__signal_exit_emitter__)kP=Tj.__signal_exit_emitter__;else kP=Tj.__signal_exit_emitter__=new GG6,kP.count=0,kP.emitted={};if(!kP.infinite)kP.setMaxListeners(1/0),kP.infinite=!0;TG6.exports=function(q,K){if(!J$6(global.process))return function(){};if(Av1.equal(typeof q,"function","a callback must be provided for exit handler"),X$6===!1)WD8();var _="exit";if(K&&K.alwaysLast)_="afterexit";var z=function(){if(kP.removeListener(_,q),kP.listeners("exit").length===0&&kP.listeners("afterexit").length===0)Fd6()};return kP.on(_,q),z},Fd6=function(){if(!X$6||!J$6(global.process))return;X$6=!1,M$6.forEach(function(K){try{Tj.removeListener(K,Ud6[K])}catch(_){}}),Tj.emit=Qd6,Tj.reallyExit=DD8,kP.count-=1},TG6.exports.unload=Fd6,_16=function(K,_,z){if(kP.emitted[K])return;kP.emitted[K]=!0,kP.emit(K,_,z)},Ud6={},M$6.forEach(function(q){Ud6[q]=function(){if(!J$6(global.process))return;var _=Tj.listeners(q);if(_.length===kP.count){if(Fd6(),_16("exit",null,q),_16("afterexit",null,q),Ov1&&q==="SIGHUP")q="SIGINT";Tj.kill(Tj.pid,q)}}}),TG6.exports.signals=function(){return M$6},X$6=!1,WD8=function(){if(X$6||!J$6(global.process))return;X$6=!0,kP.count+=1,M$6=M$6.filter(function(K){try{return Tj.on(K,Ud6[K]),!0}catch(_){return!1}}),Tj.emit=jv1,Tj.reallyExit=wv1},TG6.exports.load=WD8,DD8=Tj.reallyExit,wv1=function(K){if(!J$6(global.process))return;Tj.exitCode=K||0,_16("exit",Tj.exitCode,null),_16("afterexit",Tj.exitCode,null),DD8.call(Tj,Tj.exitCode)},Qd6=Tj.emit,jv1=function(K,_){if(K==="exit"&&J$6(global.process)){if(_!==void 0)Tj.exitCode=_;var z=Qd6.apply(this,arguments);return _16("exit",Tj.exitCode,null),_16("afterexit",Tj.exitCode,null),z}else return Qd6.apply(this,arguments)}}var Av1,M$6,Ov1,GG6,kP,Fd6,_16,Ud6,X$6,WD8,DD8,wv1,Qd6,jv1});var DCq=m((at9,Hv1)=>{var WCq=Symbol();function rt9(q,K,_){let z=K[WCq];if(z)return K.stat(q,($,A)=>{if($)return _($);_(null,A.mtime,z)});let Y=new Date(Math.ceil(Date.now()/1000)*1000+5);K.utimes(q,Y,Y,($)=>{if($)return _($);K.stat(q,(A,O)=>{if(A)return _(A);let w=O.mtime.getTime()%1000===0?"s":"ms";Object.defineProperty(K,WCq,{value:w}),_(null,O.mtime,w)})})}function ot9(q){let K=Date.now();if(q==="s")K=Math.ceil(K/1000)*1000;return new Date(K)}at9.probe=rt9;at9.getMtime=ot9});var vCq=m(($e9,cd6)=>{var et9=U6("path"),Xv1=kA(),qe9=MCq(),Ke9=PCq(),fCq=DCq(),tn={};function dd6(q,K){return K.lockfilePath||`${q}.lock`}function Pv1(q,K,_){if(!K.realpath)return _(null,et9.resolve(q));K.fs.realpath(q,_)}function Mv1(q,K,_){let z=dd6(q,K);K.fs.mkdir(z,(Y)=>{if(!Y)return fCq.probe(z,K.fs,($,A,O)=>{if($)return K.fs.rmdir(z,()=>{}),_($);_(null,A,O)});if(Y.code!=="EEXIST")return _(Y);if(K.stale<=0)return _(Object.assign(Error("Lock file is already being held"),{code:"ELOCKED",file:q}));K.fs.stat(z,($,A)=>{if($){if($.code==="ENOENT")return Mv1(q,{...K,stale:0},_);return _($)}if(!ZCq(A,K))return _(Object.assign(Error("Lock file is already being held"),{code:"ELOCKED",file:q}));GCq(q,K,(O)=>{if(O)return _(O);Mv1(q,{...K,stale:0},_)})})})}function ZCq(q,K){return q.mtime.getTime()<Date.now()-K.stale}function GCq(q,K,_){K.fs.rmdir(dd6(q,K),(z)=>{if(z&&z.code!=="ENOENT")return _(z);_()})}function fD8(q,K){let _=tn[q];if(_.updateTimeout)return;if(_.updateDelay=_.updateDelay||K.update,_.updateTimeout=setTimeout(()=>{_.updateTimeout=null,K.fs.stat(_.lockfilePath,(z,Y)=>{let $=_.lastUpdate+K.stale<Date.now();if(z){if(z.code==="ENOENT"||$)return Jv1(q,_,Object.assign(z,{code:"ECOMPROMISED"}));return _.updateDelay=1000,fD8(q,K)}if(_.mtime.getTime()!==Y.mtime.getTime())return Jv1(q,_,Object.assign(Error("Unable to update lock within the stale threshold"),{code:"ECOMPROMISED"}));let O=fCq.getMtime(_.mtimePrecision);K.fs.utimes(_.lockfilePath,O,O,(w)=>{let j=_.lastUpdate+K.stale<Date.now();if(_.released)return;if(w){if(w.code==="ENOENT"||j)return Jv1(q,_,Object.assign(w,{code:"ECOMPROMISED"}));return _.updateDelay=1000,fD8(q,K)}_.mtime=O,_.lastUpdate=Date.now(),_.updateDelay=null,fD8(q,K)})})},_.updateDelay),_.updateTimeout.unref)_.updateTimeout.unref()}function Jv1(q,K,_){if(K.released=!0,K.updateTimeout)clearTimeout(K.updateTimeout);if(tn[q]===K)delete tn[q];K.options.onCompromised(_)}function _e9(q,K,_){K={stale:1e4,update:null,realpath:!0,retries:0,fs:Xv1,onCompromised:(z)=>{throw z},...K},K.retries=K.retries||0,K.retries=typeof K.retries==="number"?{retries:K.retries}:K.retries,K.stale=Math.max(K.stale||0,2000),K.update=K.update==null?K.stale/2:K.update||0,K.update=Math.max(Math.min(K.update,K.stale/2),1000),Pv1(q,K,(z,Y)=>{if(z)return _(z);let $=qe9.operation(K.retries);$.attempt(()=>{Mv1(Y,K,(A,O,w)=>{if($.retry(A))return;if(A)return _($.mainError());let j=tn[Y]={lockfilePath:dd6(Y,K),mtime:O,mtimePrecision:w,options:K,lastUpdate:Date.now()};fD8(Y,K),_(null,(H)=>{if(j.released)return H&&H(Object.assign(Error("Lock is already released"),{code:"ERELEASED"}));TCq(Y,{...K,realpath:!1},H)})})})})}function TCq(q,K,_){K={fs:Xv1,realpath:!0,...K},Pv1(q,K,(z,Y)=>{if(z)return _(z);let $=tn[Y];if(!$)return _(Object.assign(Error("Lock is not acquired/owned by you"),{code:"ENOTACQUIRED"}));$.updateTimeout&&clearTimeout($.updateTimeout),$.released=!0,delete tn[Y],GCq(Y,K,_)})}function ze9(q,K,_){K={stale:1e4,realpath:!0,fs:Xv1,...K},K.stale=Math.max(K.stale||0,2000),Pv1(q,K,(z,Y)=>{if(z)return _(z);K.fs.stat(dd6(Y,K),($,A)=>{if($)return $.code==="ENOENT"?_(null,!1):_($);return _(null,!ZCq(A,K))})})}function Ye9(){return tn}Ke9(()=>{for(let q in tn){let K=tn[q].options;try{K.fs.rmdirSync(dd6(q,K))}catch(_){}}});$e9.lock=_e9;$e9.unlock=TCq;$e9.check=ze9;$e9.getLocks=Ye9});var VCq=m((RDA,kCq)=>{var He9=kA();function Je9(q){let K=["mkdir","realpath","stat","rmdir","utimes"],_={...q};return K.forEach((z)=>{_[z]=(...Y)=>{let $=Y.pop(),A;try{A=q[`${z}Sync`](...Y)}catch(O){return $(O)}$(null,A)}}),_}function Me9(q){return(...K)=>new Promise((_,z)=>{K.push((Y,$)=>{if(Y)z(Y);else _($)}),q(...K)})}function Xe9(q){return(...K)=>{let _,z;if(K.push((Y,$)=>{_=Y,z=$}),q(...K),_)throw _;return z}}function Pe9(q){if(q={...q},q.fs=Je9(q.fs||He9),typeof q.retries==="number"&&q.retries>0||q.retries&&typeof q.retries.retries==="number"&&q.retries.retries>0)throw Object.assign(Error("Cannot use retries with the sync api"),{code:"ESYNC"});return q}kCq.exports={toPromise:Me9,toSync:Xe9,toSyncOptions:Pe9}});var yCq=m((hDA,z16)=>{var vG6=vCq(),{toPromise:ZD8,toSync:GD8,toSyncOptions:Wv1}=VCq();async function NCq(q,K){let _=await ZD8(vG6.lock)(q,K);return ZD8(_)}function We9(q,K){let _=GD8(vG6.lock)(q,Wv1(K));return GD8(_)}function De9(q,K){return ZD8(vG6.unlock)(q,K)}function fe9(q,K){return GD8(vG6.unlock)(q,Wv1(K))}function Ze9(q,K){return ZD8(vG6.check)(q,K)}function Ge9(q,K){return GD8(vG6.check)(q,Wv1(K))}z16.exports=NCq;z16.exports.lock=NCq;z16.exports.unlock=De9;z16.exports.lockSync=We9;z16.exports.unlockSync=fe9;z16.exports.check=Ze9;z16.exports.checkSync=Ge9});function fv1(){if(!Dv1)Dv1=yCq();return Dv1}function PJ(q,K){return fv1().lock(q,K)}function ECq(q,K){return fv1().lockSync(q,K)}function LCq(q,K){return fv1().check(q,K)}var Dv1;function RCq(q,K){return{name:`${q.name}-with-${K.name}-fallback`,read(){let _=q.read();if(_!==null&&_!==void 0)return _;return K.read()||{}},async readAsync(){let _=await q.readAsync();if(_!==null&&_!==void 0)return _;return await K.readAsync()||{}},update(_){let z=q.read(),Y=q.update(_);if(Y.success){if(z===null)K.delete();return Y}let $=K.update(_);if($.success){if(z!==null)q.delete();return{success:!0,warning:$.warning}}return{success:!1}},delete(){let _=q.delete(),z=K.delete();return _||z}}}async function ve9(){try{let q=gE(bz6),K=An(),{stdout:_,code:z}=await a8("security",["find-generic-password","-a",K,"-w","-s",q],{useCwd:!1,preserveOutputOnError:!1});if(z===0&&_)return r8(_.trim())}catch(q){}return null}function SCq(){if(kG6!==void 0)return kG6;if(process.platform!=="darwin")return kG6=!1,!1;try{kG6=K_6("security",["show-keychain-info"],{reject:!1,stdio:["ignore","pipe","pipe"]}).exitCode===36}catch{kG6=!1}return kG6}var Te9=4032,hCq,kG6;var Zv1=y(()=>{Df();_8();XK();k41();l8();xz6();hCq={name:"keychain",read(){let q=DP.cache;if(Date.now()-q.cachedAt<bJ1)return q.data;try{let K=gE(bz6),_=An(),z=Ph(`security find-generic-password -a "${_}" -w -s "${K}"`);if(z){let Y=r8(z);return DP.cache={data:Y,cachedAt:Date.now()},Y}}catch(K){}if(q.data!==null)return N("[keychain] read failed; serving stale cache",{level:"warn"}),DP.cache={data:q.data,cachedAt:Date.now()},q.data;return DP.cache={data:null,cachedAt:Date.now()},null},async readAsync(){let q=DP.cache;if(Date.now()-q.cachedAt<bJ1)return q.data;if(DP.readInFlight)return DP.readInFlight;let K=DP.generation,_=ve9().then((z)=>{if(K===DP.generation){if(z===null&&q.data!==null)N("[keychain] readAsync failed; serving stale cache",{level:"warn"});let Y=z??q.data;return DP.cache={data:Y,cachedAt:Date.now()},DP.readInFlight=null,Y}return z});return DP.readInFlight=_,_},update(q){ZV();try{let K=gE(bz6),_=An(),z=g6(q),Y=Buffer.from(z,"utf-8").toString("hex"),$=`add-generic-password -U -a "${_}" -s "${K}" -X "${Y}"
456`,A;if($.length<=Te9)A=K_6("security",["-i"],{input:$,stdio:["pipe","pipe","pipe"],reject:!1});else N(`Keychain payload (${z.length}B JSON) exceeds security -i stdin limit; using argv`,{level:"warn"}),A=K_6("security",["add-generic-password","-U","-a",_,"-s",K,"-X",Y],{stdio:["ignore","pipe","pipe"],reject:!1});if(A.exitCode!==0)return{success:!1};return DP.cache={data:q,cachedAt:Date.now()},{success:!0}}catch(K){return{success:!1}}},delete(){ZV();try{let q=gE(bz6),K=An();return Ph(`security delete-generic-password -a "${K}" -s "${q}"`),!0}catch(q){return!1}}}});import{chmodSync as ke9}from"fs";import{join as Ve9}from"path";function TD8(){let q=c1(),K=".credentials.json";return{storageDir:q,storagePath:Ve9(q,".credentials.json")}}var Gv1;var CCq=y(()=>{m8();y8();e7();l8();Gv1={name:"plaintext",read(){let{storagePath:q}=TD8();try{let K=X8().readFileSync(q,{encoding:"utf8"});return r8(K)}catch{return null}},async readAsync(){let{storagePath:q}=TD8();try{let K=await X8().readFile(q,{encoding:"utf8"});return r8(K)}catch{return null}},update(q){try{let{storageDir:K,storagePath:_}=TD8();try{X8().mkdirSync(K)}catch(z){if(s1(z)!=="EEXIST")throw z}return $j(_,g6(q),{encoding:"utf8",flush:!1}),ke9(_,384),{success:!0,warning:"Warning: Storing credentials in plaintext."}}catch{return{success:!1}}},delete(){let{storagePath:q}=TD8();try{return X8().unlinkSync(q),!0}catch(K){if(s1(K)==="ENOENT")return!0;return!1}}}});function c3(){if(process.platform==="darwin")return RCq(hCq,Gv1);return Gv1}var $16=y(()=>{Zv1();CCq()});import{execFile as Ne9}from"child_process";function bCq(q){return new Promise((K)=>{Ne9("security",["find-generic-password","-a",An(),"-w","-s",q],{encoding:"utf-8",timeout:ye9},(_,z)=>{K({stdout:_?null:z?.trim()||null,timedOut:Boolean(_&&"killed"in _&&_.killed)})})})}function xCq(){if(process.platform!=="darwin"||vD8||f9())return;let q=bCq(gE(bz6)),K=bCq(gE());vD8=Promise.all([q,K]).then(([_,z])=>{if(!_.timedOut)HYq(_.stdout);if(!z.timedOut)Tv1={stdout:z.stdout}})}async function ICq(){if(vD8)await vD8}function uCq(){return Tv1}function vv1(){Tv1=null}var ye9=1e4,Tv1=null,vD8=null;var kv1=y(()=>{m8();xz6()});function R7(q,K,_){return new Promise((z,Y)=>{if(K?.aborted){if(_?.throwOnAbort||_?.abortError)Y(_.abortError?.()??Error("aborted"));else z();return}let $=setTimeout((O,w,j)=>{O?.removeEventListener("abort",w),j()},q,K,A,z);function A(){if(clearTimeout($),_?.throwOnAbort||_?.abortError)Y(_.abortError?.()??Error("aborted"));else z()}if(K?.addEventListener("abort",A,{once:!0}),_?.unref)$.unref()})}function pCq(){return mCq}function kD8(){mCq.clear()}var mCq;var VD8=y(()=>{mCq=new Map});var _L={};T8(_L,{validateForceLoginOrg:()=>qi,saveOAuthTokensIfNeeded:()=>yG6,saveApiKey:()=>RJ1,removeApiKey:()=>pv1,refreshGcpCredentialsIfNeeded:()=>gd6,refreshGcpAuth:()=>nCq,refreshAwsAuth:()=>cCq,refreshAndGetAwsCredentials:()=>l66,prefetchGcpCredentialsIfSafe:()=>uv1,prefetchAwsCredentialsAndBedRockInfoIfSafe:()=>mv1,prefetchApiKeyFromApiKeyHelperIfSafe:()=>bv1,isUsing3PServices:()=>A16,isTeamSubscriber:()=>W$6,isTeamPremiumSubscriber:()=>_86,isProSubscriber:()=>mI,isOverageProvisioningAllowed:()=>EG6,isOtelHeadersHelperFromProjectOrLocalSettings:()=>oCq,isMaxSubscriber:()=>HS,isGcpAuthRefreshFromProjectSettings:()=>Iv1,isEnterpriseSubscriber:()=>LG6,isCustomApiKeyApproved:()=>Fe9,isConsumerSubscriber:()=>sd6,isClaudeAISubscriber:()=>d7,isAwsCredentialExportFromProjectSettings:()=>Sv1,isAwsAuthRefreshFromProjectSettings:()=>Rv1,isAnthropicAuthEnabled:()=>WJ,is1PApiCustomer:()=>P$6,hasProfileScope:()=>BW,hasOpusAccess:()=>de9,hasAnthropicApiKeyAuth:()=>Ev1,handleOAuth401Error:()=>OS,getSubscriptionType:()=>yK,getSubscriptionName:()=>ED8,getRateLimitTier:()=>qF,getOtelHeadersFromHelper:()=>Bv1,getOauthAccountInfo:()=>B_,getConfiguredApiKeyHelper:()=>eg,getClaudeAIOAuthTokensAsync:()=>nd6,getClaudeAIOAuthTokens:()=>Kq,getAuthTokenSource:()=>qS,getApiKeyHelperElapsedMs:()=>Cv1,getApiKeyFromConfigOrMacOSKeychain:()=>NG6,getApiKeyFromApiKeyHelperCached:()=>Nv1,getApiKeyFromApiKeyHelper:()=>WG6,getAnthropicApiKeyWithSource:()=>Ow,getAnthropicApiKey:()=>zv,getAccountInformation:()=>RG6,clearOAuthTokenCache:()=>ad6,clearGcpCredentialsCache:()=>od6,clearAwsCredentialsCache:()=>rd6,clearApiKeyHelperCache:()=>id6,checkGcpCredentialsValid:()=>lCq,checkAndRefreshOAuthTokenIfNeeded:()=>k$,calculateApiKeyHelperTTL:()=>dCq});import{exec as UCq}from"child_process";import{mkdir as Ee9,stat as Le9}from"fs/promises";import{join as Re9}from"path";function yD8(){return i6(process.env.CLAUDE_CODE_REMOTE)||process.env.CLAUDE_CODE_ENTRYPOINT==="claude-desktop"}function WJ(){if(f9())return!1;if(process.env.ANTHROPIC_UNIX_SOCKET)return!!process.env.CLAUDE_CODE_OAUTH_TOKEN;let q=i6(process.env.CLAUDE_CODE_USE_BEDROCK)||i6(process.env.CLAUDE_CODE_USE_VERTEX)||i6(process.env.CLAUDE_CODE_USE_FOUNDRY),_=(Z7()||{}).apiKeyHelper,z=process.env.ANTHROPIC_AUTH_TOKEN||_||process.env.CLAUDE_CODE_API_KEY_FILE_DESCRIPTOR,{source:Y}=Ow({skipRetrievingKeyFromApiKeyHelper:!0}),$=Y==="ANTHROPIC_API_KEY"||Y==="apiKeyHelper";return!(q||z&&!yD8()||$&&!yD8())}function qS(){if(f9()){if(eg())return{source:"apiKeyHelper",hasToken:!0};return{source:"none",hasToken:!1}}if(process.env.ANTHROPIC_AUTH_TOKEN&&!yD8())return{source:"ANTHROPIC_AUTH_TOKEN",hasToken:!0};if(process.env.CLAUDE_CODE_OAUTH_TOKEN)return{source:"CLAUDE_CODE_OAUTH_TOKEN",hasToken:!0};if(HJ8()){if(process.env.CLAUDE_CODE_OAUTH_TOKEN_FILE_DESCRIPTOR)return{source:"CLAUDE_CODE_OAUTH_TOKEN_FILE_DESCRIPTOR",hasToken:!0};return{source:"CCR_OAUTH_TOKEN_FILE",hasToken:!0}}if(eg()&&!yD8())return{source:"apiKeyHelper",hasToken:!0};let _=Kq();if(KS(_?.scopes)&&_?.accessToken)return{source:"claude.ai",hasToken:!0};return{source:"none",hasToken:!1}}function zv(){let{key:q}=Ow();return q}function Ev1(){let{key:q,source:K}=Ow({skipRetrievingKeyFromApiKeyHelper:!0});return q!==null&&K!=="none"}function Ow(q={}){if(f9()){if(process.env.ANTHROPIC_API_KEY)return{key:process.env.ANTHROPIC_API_KEY,source:"ANTHROPIC_API_KEY"};if(eg())return{key:q.skipRetrievingKeyFromApiKeyHelper?null:Nv1(),source:"apiKeyHelper"};return{key:null,source:"none"}}let K=LT()?void 0:process.env.ANTHROPIC_API_KEY;if(cb6()&&K)return{key:K,source:"ANTHROPIC_API_KEY"};if(i6(!1)){let $=SJ1();if($)return{key:$,source:"ANTHROPIC_API_KEY"};if(!K&&!process.env.CLAUDE_CODE_OAUTH_TOKEN&&!process.env.CLAUDE_CODE_OAUTH_TOKEN_FILE_DESCRIPTOR)throw Error("ANTHROPIC_API_KEY or CLAUDE_CODE_OAUTH_TOKEN env var is required");if(K)return{key:K,source:"ANTHROPIC_API_KEY"};return{key:null,source:"none"}}if(K&&j8().customApiKeyResponses?.approved?.includes(GV(K)))return{key:K,source:"ANTHROPIC_API_KEY"};let _=SJ1();if(_)return{key:_,source:"ANTHROPIC_API_KEY"};if(eg()){if(q.skipRetrievingKeyFromApiKeyHelper)return{key:null,source:"apiKeyHelper"};return{key:Nv1(),source:"apiKeyHelper"}}let Y=NG6();if(Y)return Y;return{key:null,source:"none"}}function eg(){if(f9())return v1("flagSettings")?.apiKeyHelper;return(Z7()||{}).apiKeyHelper}function QCq(){let q=eg();if(!q)return!1;let K=v1("projectSettings"),_=v1("localSettings");return K?.apiKeyHelper===q||_?.apiKeyHelper===q}function Lv1(){return(Z7()||{}).awsAuthRefresh}function Rv1(){let q=Lv1();if(!q)return!1;let K=v1("projectSettings"),_=v1("localSettings");return K?.awsAuthRefresh===q||_?.awsAuthRefresh===q}function hv1(){return(Z7()||{}).awsCredentialExport}function Sv1(){let q=hv1();if(!q)return!1;let K=v1("projectSettings"),_=v1("localSettings");return K?.awsCredentialExport===q||_?.awsCredentialExport===q}function dCq(){let q=process.env.CLAUDE_CODE_API_KEY_HELPER_TTL_MS;if(q){let K=parseInt(q,10);if(!Number.isNaN(K)&&K>=0)return K;N(`Found CLAUDE_CODE_API_KEY_HELPER_TTL_MS env var, but it was not a valid number. Got ${q}`,{level:"error"})}return he9}function Cv1(){let q=en?.startedAt;return q?Date.now()-q:0}async function WG6(q){if(!eg())return null;let K=dCq();if(KL){if(Date.now()-KL.timestamp<K)return KL.value;if(!en)en={promise:BCq(q,!1,VG6),startedAt:null};return KL.value}if(en)return en.promise;return en={promise:BCq(q,!0,VG6),startedAt:Date.now()},en.promise}async function BCq(q,K,_){try{let z=await Se9(q);if(_!==VG6)return z;if(z!==null)KL={value:z,timestamp:Date.now()};return z}catch(z){if(_!==VG6)return" ";let Y=z instanceof Error?z.message:String(z);if(console.error($8.red(`apiKeyHelper failed: ${Y}`)),N(`Error getting API key from apiKeyHelper: ${Y}`,{level:"error"}),!K&&KL&&KL.value!==" ")return KL={...KL,timestamp:Date.now()},KL.value;return KL={value:" ",timestamp:Date.now()}," "}finally{if(_===VG6)en=null}}async function Se9(q){let K=eg();if(!K)return null;if(QCq()){if(!l$()&&!q){let $=Error(`Security: apiKeyHelper executed before workspace trust is confirmed. If you see this message, post in ${{ISSUES_EXPLAINER:"report the issue at https://github.com/anthropics/claude-code/issues",PACKAGE_URL:"@anthropic-ai/claude-code",README_URL:"https://code.claude.com/docs/en/overview",VERSION:"2.1.88",FEEDBACK_CHANNEL:"https://github.com/anthropics/claude-code/issues",BUILD_TIME:"2026-03-30T21:59:52Z"}.FEEDBACK_CHANNEL}.`);return OE("apiKeyHelper invoked before trust check",$),d("tengu_apiKeyHelper_missing_trust11",{}),null}}let _=await m_(K,{shell:!0,timeout:600000,reject:!1});if(_.failed){let Y=_.timedOut?"timed out":`exited ${_.exitCode}`,$=_.stderr?.trim();throw Error($?`${Y}: ${$}`:Y)}let z=_.stdout?.trim();if(!z)throw Error("did not return a value");return z}function Nv1(){return KL?.value??null}function id6(){VG6++,KL=null,en=null}function bv1(q){if(QCq()&&!l$())return;WG6(q)}async function be9(){let q=Lv1();if(!q)return!1;if(Rv1()){if(!l$()&&!i7()){let _=Error(`Security: awsAuthRefresh executed before workspace trust is confirmed. If you see this message, post in ${{ISSUES_EXPLAINER:"report the issue at https://github.com/anthropics/claude-code/issues",PACKAGE_URL:"@anthropic-ai/claude-code",README_URL:"https://code.claude.com/docs/en/overview",VERSION:"2.1.88",FEEDBACK_CHANNEL:"https://github.com/anthropics/claude-code/issues",BUILD_TIME:"2026-03-30T21:59:52Z"}.FEEDBACK_CHANNEL}.`);return OE("awsAuthRefresh invoked before trust check",_),d("tengu_awsAuthRefresh_missing_trust",{}),!1}}try{return N("Fetching AWS caller identity for AWS auth refresh command"),await VX1(),N("Fetched AWS caller identity, skipping AWS auth refresh command"),!1}catch{return cCq(q)}}function cCq(q){N("Running AWS auth refresh command");let K=FW.getInstance();return K.startAuthentication(),new Promise((_)=>{let z=UCq(q,{timeout:xe9});z.stdout.on("data",(Y)=>{let $=Y.toString().trim();if($)K.addOutput($),N($,{level:"debug"})}),z.stderr.on("data",(Y)=>{let $=Y.toString().trim();if($)K.setError($),N($,{level:"error"})}),z.on("close",(Y,$)=>{if(Y===0)N("AWS auth refresh completed successfully"),K.endAuthentication(!0),_(!0);else{let O=$==="SIGTERM"?$8.red("AWS auth refresh timed out after 3 minutes. Run your auth command manually in a separate terminal."):$8.red("Error running awsAuthRefresh (in settings or ~/.claude.json):");console.error(O),K.endAuthentication(!1),_(!1)}})})}async function Ie9(){let q=hv1();if(!q)return null;if(Sv1()){if(!l$()&&!i7()){let _=Error(`Security: awsCredentialExport executed before workspace trust is confirmed. If you see this message, post in ${{ISSUES_EXPLAINER:"report the issue at https://github.com/anthropics/claude-code/issues",PACKAGE_URL:"@anthropic-ai/claude-code",README_URL:"https://code.claude.com/docs/en/overview",VERSION:"2.1.88",FEEDBACK_CHANNEL:"https://github.com/anthropics/claude-code/issues",BUILD_TIME:"2026-03-30T21:59:52Z"}.FEEDBACK_CHANNEL}.`);return OE("awsCredentialExport invoked before trust check",_),d("tengu_awsCredentialExport_missing_trust",{}),null}}try{return N("Fetching AWS caller identity for credential export command"),await VX1(),N("Fetched AWS caller identity, skipping AWS credential export command"),null}catch{try{N("Running AWS credential export command");let K=await m_(q,{shell:!0,reject:!1});if(K.exitCode!==0||!K.stdout)throw Error("awsCredentialExport did not return a valid value");let _=r8(K.stdout.trim());if(!O2q(_))throw Error("awsCredentialExport did not return valid AWS STS output structure");return N("AWS credentials retrieved from awsCredentialExport"),{accessKeyId:_.Credentials.AccessKeyId,secretAccessKey:_.Credentials.SecretAccessKey,sessionToken:_.Credentials.SessionToken}}catch(K){let _=$8.red("Error getting AWS credentials from awsCredentialExport (in settings or ~/.claude.json):");if(K instanceof Error)console.error(_,K.message);else console.error(_,K);return null}}}function rd6(){l66.cache.clear()}function xv1(){return(Z7()||{}).gcpAuthRefresh}function Iv1(){let q=xv1();if(!q)return!1;let K=v1("projectSettings"),_=v1("localSettings");return K?.gcpAuthRefresh===q||_?.gcpAuthRefresh===q}async function lCq(){try{let{GoogleAuth:q}=await Promise.resolve().then(() => O6(KD8(),1)),K=new q({scopes:["https://www.googleapis.com/auth/cloud-platform"]}),_=(async()=>{await(await K.getClient()).getAccessToken()})(),z=R7(ue9).then(()=>{throw new aCq("GCP credentials check timed out")});return await Promise.race([_,z]),!0}catch{return!1}}async function pe9(){let q=xv1();if(!q)return!1;if(Iv1()){if(!l$()&&!i7()){let _=Error(`Security: gcpAuthRefresh executed before workspace trust is confirmed. If you see this message, post in ${{ISSUES_EXPLAINER:"report the issue at https://github.com/anthropics/claude-code/issues",PACKAGE_URL:"@anthropic-ai/claude-code",README_URL:"https://code.claude.com/docs/en/overview",VERSION:"2.1.88",FEEDBACK_CHANNEL:"https://github.com/anthropics/claude-code/issues",BUILD_TIME:"2026-03-30T21:59:52Z"}.FEEDBACK_CHANNEL}.`);return OE("gcpAuthRefresh invoked before trust check",_),d("tengu_gcpAuthRefresh_missing_trust",{}),!1}}try{if(N("Checking GCP credentials validity for auth refresh"),await lCq())return N("GCP credentials are valid, skipping auth refresh command"),!1}catch{}return nCq(q)}function nCq(q){N("Running GCP auth refresh command");let K=FW.getInstance();return K.startAuthentication(),new Promise((_)=>{let z=UCq(q,{timeout:Be9});z.stdout.on("data",(Y)=>{let $=Y.toString().trim();if($)K.addOutput($),N($,{level:"debug"})}),z.stderr.on("data",(Y)=>{let $=Y.toString().trim();if($)K.setError($),N($,{level:"error"})}),z.on("close",(Y,$)=>{if(Y===0)N("GCP auth refresh completed successfully"),K.endAuthentication(!0),_(!0);else{let O=$==="SIGTERM"?$8.red("GCP auth refresh timed out after 3 minutes. Run your auth command manually in a separate terminal."):$8.red("Error running gcpAuthRefresh (in settings or ~/.claude.json):");console.error(O),K.endAuthentication(!1),_(!1)}})})}function od6(){gd6.cache.clear()}function uv1(){if(!xv1())return;if(Iv1()){if(!l$()&&!i7())return}gd6()}function mv1(){let q=Lv1(),K=hv1();if(!q&&!K)return;if(Rv1()||Sv1()){if(!l$()&&!i7())return}l66(),n9()}function ge9(q){return/^[a-zA-Z0-9-_]+$/.test(q)}async function RJ1(q){if(!ge9(q))throw Error("Invalid API key format. API key must contain only alphanumeric characters, dashes, and underscores.");await iCq();let K=!1;if(process.platform==="darwin")try{let z=gE(),Y=An(),$=Buffer.from(q,"utf-8").toString("hex"),A=`add-generic-password -U -a "${Y}" -s "${z}" -X "${$}"
457`;await m_("security",["-i"],{input:A,reject:!1}),d("tengu_api_key_saved_to_keychain",{}),K=!0}catch(z){H6(z),d("tengu_api_key_keychain_error",{error:d6(z)}),d("tengu_api_key_saved_to_config",{})}else d("tengu_api_key_saved_to_config",{});let _=GV(q);b8((z)=>{let Y=z.customApiKeyResponses?.approved??[];return{...z,primaryApiKey:K?z.primaryApiKey:q,customApiKeyResponses:{...z.customApiKeyResponses,approved:Y.includes(_)?Y:[...Y,_],rejected:z.customApiKeyResponses?.rejected??[]}}}),NG6.cache.clear?.(),vv1()}function Fe9(q){let K=j8(),_=GV(q);return K.customApiKeyResponses?.approved?.includes(_)??!1}async function pv1(){await iCq(),b8((q)=>({...q,primaryApiKey:void 0})),NG6.cache.clear?.(),vv1()}async function iCq(){try{await JYq()}catch(q){H6(q)}}function yG6(q){if(!KS(q.scopes))return d("tengu_oauth_tokens_not_claude_ai",{}),{success:!0};if(!q.refreshToken||!q.expiresAt)return d("tengu_oauth_tokens_inference_only",{}),{success:!0};let K=c3(),_=K.name;try{let z=K.read()||{},Y=z.claudeAiOauth;z.claudeAiOauth={accessToken:q.accessToken,refreshToken:q.refreshToken,expiresAt:q.expiresAt,scopes:q.scopes,subscriptionType:q.subscriptionType??Y?.subscriptionType??null,rateLimitTier:q.rateLimitTier??Y?.rateLimitTier??null};let $=K.update(z);if($.success)d("tengu_oauth_tokens_saved",{storageBackend:_});else d("tengu_oauth_tokens_save_failed",{storageBackend:_});return Kq.cache?.clear?.(),wD8(),kD8(),$}catch(z){return H6(z),d("tengu_oauth_tokens_save_exception",{storageBackend:_,error:d6(z)}),{success:!1,warning:"Failed to save OAuth tokens"}}}function ad6(){Kq.cache?.clear?.(),ZV()}async function Ue9(){try{let{mtimeMs:q}=await Le9(Re9(c1(),".credentials.json"));if(q!==gCq)gCq=q,ad6()}catch{Kq.cache?.clear?.()}}function OS(q){let K=Vv1.get(q);if(K)return K;let _=Qe9(q).finally(()=>{Vv1.delete(q)});return Vv1.set(q,_),_}async function Qe9(q){ad6();let K=await nd6();if(!K?.refreshToken)return!1;if(K.accessToken!==q)return d("tengu_oauth_401_recovered_from_keychain",{}),!0;return k$(0,!0)}async function nd6(){if(f9())return null;if(process.env.CLAUDE_CODE_OAUTH_TOKEN||HJ8())return Kq();try{let _=(await c3().readAsync())?.claudeAiOauth;if(!_?.accessToken)return null;return _}catch(q){return H6(q),null}}function k$(q=0,K=!1){if(q===0&&!K){if(ld6)return ld6;return ld6=yv1(q,K).finally(()=>{ld6=null}),ld6}return yv1(q,K)}async function yv1(q,K){await Ue9();let z=Kq();if(!K){if(!z?.refreshToken||!Gg(z.expiresAt))return!1}if(!z?.refreshToken)return!1;if(!KS(z.scopes))return!1;Kq.cache?.clear?.(),ZV();let Y=await nd6();if(!Y?.refreshToken||!Gg(Y.expiresAt))return!1;let $=c1();await Ee9($,{recursive:!0});let A;try{d("tengu_oauth_token_refresh_lock_acquiring",{}),A=await PJ($),d("tengu_oauth_token_refresh_lock_acquired",{})}catch(O){if(O.code==="ELOCKED"){if(q<5)return d("tengu_oauth_token_refresh_lock_retry",{retryCount:q+1}),await R7(1000+Math.random()*1000),yv1(q+1,K);return d("tengu_oauth_token_refresh_lock_retry_limit_reached",{maxRetries:5}),!1}return H6(O),d("tengu_oauth_token_refresh_lock_error",{error:d6(O)}),!1}try{Kq.cache?.clear?.(),ZV();let O=await nd6();if(!O?.refreshToken||!Gg(O.expiresAt))return d("tengu_oauth_token_refresh_race_resolved",{}),!1;d("tengu_oauth_token_refresh_starting",{});let w=await kF6(O.refreshToken,{scopes:KS(O.scopes)?void 0:O.scopes});return yG6(w),Kq.cache?.clear?.(),ZV(),!0}catch(O){H6(O),Kq.cache?.clear?.(),ZV();let w=await nd6();if(w&&!Gg(w.expiresAt))return d("tengu_oauth_token_refresh_race_recovered",{}),!0;return!1}finally{d("tengu_oauth_token_refresh_lock_releasing",{}),await A(),d("tengu_oauth_token_refresh_lock_released",{})}}function d7(){if(!WJ())return!1;return KS(Kq()?.scopes)}function BW(){return Kq()?.scopes?.includes(e96)??!1}function P$6(){if(i6(process.env.CLAUDE_CODE_USE_BEDROCK)||i6(process.env.CLAUDE_CODE_USE_VERTEX)||i6(process.env.CLAUDE_CODE_USE_FOUNDRY))return!1;if(d7())return!1;return!0}function B_(){return WJ()?j8().oauthAccount:void 0}function EG6(){let K=B_()?.billingType;if(!d7()||!K)return!1;if(K!=="stripe_subscription"&&K!=="stripe_subscription_contracted"&&K!=="apple_subscription"&&K!=="google_play_subscription")return!1;return!0}function de9(){let q=yK();return q==="max"||q==="enterprise"||q==="team"||q==="pro"||q===null}function yK(){if(OYq())return AYq();if(!WJ())return null;let q=Kq();if(!q)return null;return q.subscriptionType??null}function HS(){return yK()==="max"}function W$6(){return yK()==="team"}function _86(){return yK()==="team"&&qF()==="default_claude_max_5x"}function LG6(){return yK()==="enterprise"}function mI(){return yK()==="pro"}function qF(){if(!WJ())return null;let q=Kq();if(!q)return null;return q.rateLimitTier??null}function ED8(){switch(yK()){case"enterprise":return"Claude Enterprise";case"team":return"Claude Team";case"max":return"Claude Max";case"pro":return"Claude Pro";default:return"Claude API"}}function A16(){return!!(i6(process.env.CLAUDE_CODE_USE_BEDROCK)||i6(process.env.CLAUDE_CODE_USE_VERTEX)||i6(process.env.CLAUDE_CODE_USE_FOUNDRY))}function rCq(){return(Z7()||{}).otelHeadersHelper}function oCq(){let q=rCq();if(!q)return!1;let K=v1("projectSettings"),_=v1("localSettings");return K?.otelHeadersHelper===q||_?.otelHeadersHelper===q}function Bv1(){let q=rCq();if(!q)return{};let K=parseInt(process.env.CLAUDE_CODE_OTEL_HEADERS_HELPER_DEBOUNCE_MS||ce9.toString());if(ND8&&Date.now()-FCq<K)return ND8;if(oCq()){if(!l$())return{}}try{let _=Ph(q,{timeout:30000})?.toString().trim();if(!_)throw Error("otelHeadersHelper did not return a valid value");let z=r8(_);if(typeof z!=="object"||z===null||Array.isArray(z))throw Error("otelHeadersHelper must return a JSON object with string key-value pairs");for(let[Y,$]of Object.entries(z))if(typeof $!=="string")throw Error(`otelHeadersHelper returned non-string value for key "${Y}": ${typeof $}`);return ND8=z,FCq=Date.now(),ND8}catch(_){throw H6(Error(`Error getting OpenTelemetry headers from otelHeadersHelper (in settings): ${d6(_)}`)),_}}function le9(q){return q==="max"||q==="pro"}function sd6(){let q=yK();return d7()&&q!==null&&le9(q)}function RG6(){if(E7()!=="firstParty")return;let{source:K}=qS(),_={};if(K==="CLAUDE_CODE_OAUTH_TOKEN"||K==="CLAUDE_CODE_OAUTH_TOKEN_FILE_DESCRIPTOR")_.tokenSource=K;else if(d7())_.subscription=ED8();else _.tokenSource=K;let{key:z,source:Y}=Ow();if(z)_.apiKeySource=Y;if(K==="claude.ai"||Y==="/login managed key"){let A=B_()?.organizationName;if(A)_.organization=A}let $=B_()?.emailAddress;if((K==="claude.ai"||Y==="/login managed key")&&$)_.email=$;return _}async function qi(){if(process.env.ANTHROPIC_UNIX_SOCKET)return{valid:!0};if(!WJ())return{valid:!0};let q=v1("policySettings")?.forceLoginOrgUUID;if(!q)return{valid:!0};await k$();let K=Kq();if(!K)return{valid:!0};let{source:_}=qS(),z=_==="CLAUDE_CODE_OAUTH_TOKEN"||_==="CLAUDE_CODE_OAUTH_TOKEN_FILE_DESCRIPTOR",Y=await Zg(K.accessToken);if(!Y)return{valid:!1,message:`Unable to verify organization for the current authentication token.
458This machine requires organization ${q} but the profile could not be fetched.
459This may be a network error, or the token may lack the user:profile scope required for
460verification (tokens from 'claude setup-token' do not include this scope).

Callers 6

KGFunction · 0.85
F06Function · 0.85
Fn6Function · 0.85
L7YFunction · 0.85
PaKFunction · 0.85
n15Function · 0.85

Calls 1

yKFunction · 0.85

Tested by

no test coverage detected