Function tUK

package/cli.js:7962–7962

(q)

\r
`);q.end(),oS6(K)},O.onclose=()=>{if(K.closed)return;K.closed=!0,q.end(),oS6(K)}}function GxY(q){if(q.readyState===WebSocket.OPEN)q.send(t_7(new Uint8Array(0)))}function PUK(q,K){if(q.readyState!==WebSocket.OPEN)return;for(let _=0;_<K.length;_+=HUK){let z=K.subarray(_,_+HUK);q.send(t_7(z))}}function oS6(q){if(!q)return;if(q.pinger)clearInterval(q.pinger);if(q.ws&&q.ws.readyState<=WebSocket.OPEN)try{q.ws.close()}catch{}q.ws=void 0}var s_7,HUK=524288,PxY=30000;var WUK=y(()=>{_8();PI();qv()});var TUK={};T8(TUK,{resetUpstreamProxyForTests:()=>LxY,initUpstreamProxy:()=>yxY,getUpstreamProxyEnv:()=>ExY,SESSION_TOKEN_PATH:()=>GUK});import{mkdir as TxY,readFile as fUK,unlink as vxY,writeFile as kxY}from"fs/promises";import{homedir as VxY}from"os";import{join as ZUK}from"path";async function yxY(q){if(!i6(process.env.CLAUDE_CODE_REMOTE))return fT;if(!i6(process.env.CCR_UPSTREAM_PROXY_ENABLED))return fT;let K=process.env.CLAUDE_CODE_REMOTE_SESSION_ID;if(!K)return N("[upstreamproxy] CLAUDE_CODE_REMOTE_SESSION_ID unset; proxy disabled",{level:"warn"}),fT;let _=q?.tokenPath??GUK,z=await RxY(_);if(!z)return N("[upstreamproxy] no session token file; proxy disabled"),fT;hxY();let Y=q?.ccrBaseUrl??process.env.ANTHROPIC_BASE_URL??"https://api.anthropic.com",$=q?.caBundlePath??ZUK(VxY(),".ccr","ca-bundle.crt");if(!await SxY(Y,q?.systemCaPath??NxY,$))return fT;try{let O=Y.replace(/^http/,"ws")+"/v1/code/upstreamproxy/ws",w=await MUK({wsUrl:O,sessionId:K,token:z});pq(async()=>w.stop()),fT={enabled:!0,port:w.port,caBundlePath:$},N(`[upstreamproxy] enabled on 127.0.0.1:${w.port}`),await vxY(_).catch(()=>{N("[upstreamproxy] token file unlink failed",{level:"warn"})})}catch(O){N(`[upstreamproxy] relay start failed: ${O instanceof Error?O.message:String(O)}; proxy disabled`,{level:"warn"})}return fT}function ExY(){if(!fT.enabled||!fT.port||!fT.caBundlePath){if(process.env.HTTPS_PROXY&&process.env.SSL_CERT_FILE){let K={};for(let _ of["HTTPS_PROXY","https_proxy","NO_PROXY","no_proxy","SSL_CERT_FILE","NODE_EXTRA_CA_CERTS","REQUESTS_CA_BUNDLE","CURL_CA_BUNDLE"])if(process.env[_])K[_]=process.env[_];return K}return{}}let q=`http://127.0.0.1:${fT.port}`;return{HTTPS_PROXY:q,https_proxy:q,NO_PROXY:DUK,no_proxy:DUK,SSL_CERT_FILE:fT.caBundlePath,NODE_EXTRA_CA_CERTS:fT.caBundlePath,REQUESTS_CA_BUNDLE:fT.caBundlePath,CURL_CA_BUNDLE:fT.caBundlePath}}function LxY(){fT={enabled:!1}}async function RxY(q){try{return(await fUK(q,"utf8")).trim()||null}catch(K){if(_7(K))return null;return N(`[upstreamproxy] token read failed: ${K instanceof Error?K.message:String(K)}`,{level:"warn"}),null}}function hxY(){if(process.platform!=="linux"||typeof Bun>"u")return;try{let K=U6("bun:ffi").dlopen("libc.so.6",{prctl:{args:["int","u64","u64","u64","u64"],returns:"int"}}),_=4;if(K.symbols.prctl(4,0n,0n,0n,0n)!==0)N("[upstreamproxy] prctl(PR_SET_DUMPABLE,0) returned nonzero",{level:"warn"})}catch(q){N(`[upstreamproxy] prctl unavailable: ${q instanceof Error?q.message:String(q)}`,{level:"warn"})}}async function SxY(q,K,_){try{let z=await fetch(`${q}/v1/code/upstreamproxy/ca-cert`,{signal:AbortSignal.timeout(5000)});if(!z.ok)return N(`[upstreamproxy] ca-cert fetch ${z.status}; proxy disabled`,{level:"warn"}),!1;let Y=await z.text(),$=await fUK(K,"utf8").catch(()=>"");return await TxY(ZUK(_,".."),{recursive:!0}),await kxY(_,$+`
`+Y,"utf8"),!0}catch(z){return N(`[upstreamproxy] ca-cert download failed: ${z instanceof Error?z.message:String(z)}; proxy disabled`,{level:"warn"}),!1}}var GUK="/run/ccr/session_token",NxY="/etc/ssl/certs/ca-certificates.crt",DUK,fT;var vUK=y(()=>{c9();_8();m8();y8();WUK();DUK=["localhost","127.0.0.1","::1","169.254.0.0/16","10.0.0.0/8","172.16.0.0/12","192.168.0.0/16","anthropic.com",".anthropic.com","*.anthropic.com","github.com","api.github.com","*.github.com","*.githubusercontent.com","registry.npmjs.org","pypi.org","files.pythonhosted.org","index.crates.io","proxy.golang.org"].join(","),fT={enabled:!1}});var kUK={};T8(kUK,{showInvalidConfigDialog:()=>xxY});function CxY(q){let K=z6(19),{filePath:_,errorDescription:z,onExit:Y,onReset:$}=q,A;if(K[0]!==Y||K[1]!==$)A=(W)=>{if(W==="exit")Y();else $()},K[0]=Y,K[1]=$,K[2]=A;else A=K[2];let O=A,w;if(K[3]!==_)w=sb.default.createElement(k,null,"The configuration file at ",sb.default.createElement(k,{bold:!0},_)," contains invalid JSON."),K[3]=_,K[4]=w;else w=K[4];let j;if(K[5]!==z)j=sb.default.createElement(k,null,z),K[5]=z,K[6]=j;else j=K[6];let H;if(K[7]!==w||K[8]!==j)H=sb.default.createElement(u,{flexDirection:"column",gap:1},w,j),K[7]=w,K[8]=j,K[9]=H;else H=K[9];let J;if(K[10]===Symbol.for("react.memo_cache_sentinel"))J=sb.default.createElement(k,{bold:!0},"Choose an option:"),K[10]=J;else J=K[10];let M;if(K[11]===Symbol.for("react.memo_cache_sentinel"))M=[{label:"Exit and fix manually",value:"exit"},{label:"Reset with default configuration",value:"reset"}],K[11]=M;else M=K[11];let X;if(K[12]!==O||K[13]!==Y)X=sb.default.createElement(u,{flexDirection:"column"},J,sb.default.createElement(H1,{options:M,onChange:O,onCancel:Y})),K[12]=O,K[13]=Y,K[14]=X;else X=K[14];let P;if(K[15]!==Y||K[16]!==H||K[17]!==X)P=sb.default.createElement(R1,{title:"Configuration Error",color:"error",onCancel:Y},H,X),K[15]=Y,K[16]=H,K[17]=X,K[18]=P;else P=K[18];return P}async function xxY({error:q}){let K={...Jo(!1),theme:bxY};await new Promise(async(_)=>{let{unmount:z}=await vu(sb.default.createElement(LJ,null,sb.default.createElement(WM,null,sb.default.createElement(CxY,{filePath:q.filePath,errorDescription:q.message,onExit:()=>{z(),_(),process.exit(1)},onReset:()=>{$j(q.filePath,g6(q.defaultConfig,null,2),{flush:!1,encoding:"utf8"}),z(),_(),process.exit(0)}}))),K)})}var sb,bxY="dark";var VUK=y(()=>{q8();s6();dU();C7();As6();l8();d_();e4();sb=O6(D6(),1)});function oQ8(){if(rF1()){if(i7()&&bH())qz7().catch((q)=>{N(`[3P telemetry] Eager telemetry init failed (beta tracing): ${d6(q)}`,{level:"error"})});N("[3P telemetry] Waiting for remote managed settings before telemetry init"),rL8().then(async()=>{N("[3P telemetry] Remote managed settings loaded, initializing telemetry"),xd(),await qz7()}).catch((q)=>{N(`[3P telemetry] Telemetry init failed (remote settings path): ${d6(q)}`,{level:"error"})})}else qz7().catch((q)=>{N(`[3P telemetry] Telemetry init failed: ${d6(q)}`,{level:"error"})})}async function qz7(){if(e_7)return;e_7=!0;try{await IxY()}catch(q){throw e_7=!1,q}}async function IxY(){let{initializeTelemetry:q}=await Promise.resolve().then(() => (Fl1(),gl1)),K=await q();if(K)Oi8(K,(z,Y)=>{let $=K?.createCounter(z,Y);return{add(A,O={}){let j={...GV6(),...O};$?.add(A,j)}}}),wi8()?.add(1)}var e_7=!1,NUK;var Kz7=y(()=>{Cx();v8();V1();F4();v8();v8();uQ();pW();ZD();aN6();AUK();wUK();c9();V1();_8();mZ();oY();J16();m8();y8();RA();q48();PI();Tz();qv();Ts6();tV8();NB();NUK=_1(async()=>{let q=Date.now();c8("info","init_started"),U4("init_function_start");try{let K=Date.now();d$6(),c8("info","init_configs_enabled",{duration_ms:Date.now()-K}),U4("init_configs_enabled");let _=Date.now();if(jUK(),OUK(),c8("info","init_safe_env_vars_applied",{duration_ms:Date.now()-_}),U4("init_safe_env_vars_applied"),Ix4(),U4("init_after_graceful_shutdown"),Promise.all([Promise.resolve().then(() => (Hi(),Trq)),Promise.resolve().then(() => (o1(),Srq))]).then(([$,A])=>{$.initialize1PEventLogging(),A.onGrowthBookRefresh(()=>{$.reinitialize1PEventLoggingIfConfigChanged()})}),U4("init_after_1p_event_logging"),LJ1(),U4("init_after_oauth_populate"),NV1(),U4("init_after_jetbrains_detection"),ge(),rF1())$I4();if(Jm())FF1();U4("init_after_remote_settings_check"),$N1();let z=Date.now();N("[init] configureGlobalMTLS starting"),oF7(),c8("info","init_mtls_configured",{duration_ms:Date.now()-z}),N("[init] configureGlobalMTLS complete");let Y=Date.now();if(N("[init] configureGlobalAgents starting"),Zj8(),c8("info","init_proxy_configured",{duration_ms:Date.now()-Y}),N("[init] configureGlobalAgents complete"),U4("init_network_configured"),$UK(),i6(process.env.CLAUDE_CODE_REMOTE))try{let{initUpstreamProxy:$,getUpstreamProxyEnv:A}=await Promise.resolve().then(() => (vUK(),TUK)),{registerUpstreamProxyEnvFn:O}=await Promise.resolve().then(() => (bw6(),$S4));O(A),await $()}catch($){N(`[init] upstreamproxy init failed: ${$ instanceof Error?$.message:String($)}; continuing without proxy`,{level:"warn"})}if(AR7(),pq(C_K),pq(async()=>{let{cleanupSessionTeams:$}=await Promise.resolve().then(() => (RD(),PqK));await $()}),Sd()){let $=Date.now();await dBK(),c8("info","init_scratchpad_created",{duration_ms:Date.now()-$})}c8("info","init_completed",{duration_ms:Date.now()-q}),U4("init_function_end")}catch(K){if(K instanceof hT){if(i7()){process.stderr.write(`Configuration error in ${K.filePath}: ${K.message}
`),eK(1);return}return Promise.resolve().then(() => (VUK(),kUK)).then((_)=>_.showInvalidConfigDialog({error:K}))}else throw K}})});function EUK(q){let K=z6(3),{getFpsMetrics:_,children:z}=q,Y;if(K[0]!==z||K[1]!==_)Y=aS6.default.createElement(yUK.Provider,{value:_},z),K[0]=z,K[1]=_,K[2]=Y;else Y=K[2];return Y}function LUK(){return aS6.useContext(yUK)}var aS6,yUK;var _z7=y(()=>{q8();aS6=O6(D6(),1),yUK=aS6.createContext(void 0)});function zz7(q,K){let _=K/100*(q.length-1),z=Math.floor(_),Y=Math.ceil(_);if(z===Y)return q[z];return q[z]+(q[Y]-q[z])*(_-z)}function Yz7(){let q=new Map,K=new Map,_=new Map;return{increment(z,Y=1){q.set(z,(q.get(z)??0)+Y)},set(z,Y){q.set(z,Y)},observe(z,Y){let $=K.get(z);if(!$)$={reservoir:[],count:0,sum:0,min:Y,max:Y},K.set(z,$);if($.count++,$.sum+=Y,Y<$.min)$.min=Y;if(Y>$.max)$.max=Y;if($.reservoir.length<RUK)$.reservoir.push(Y);else{let A=Math.floor(Math.random()*$.count);if(A<RUK)$.reservoir[A]=Y}},add(z,Y){let $=_.get(z);if(!$)$=new Set,_.set(z,$);$.add(Y)},getAll(){let z=Object.fromEntries(q);for(let[Y,$]of K){if($.count===0)continue;z[`${Y}_count`]=$.count,z[`${Y}_min`]=$.min,z[`${Y}_max`]=$.max,z[`${Y}_avg`]=$.sum/$.count;let A=[...$.reservoir].sort((O,w)=>O-w);z[`${Y}_p50`]=zz7(A,50),z[`${Y}_p95`]=zz7(A,95),z[`${Y}_p99`]=zz7(A,99)}for(let[Y,$]of _)z[Y]=$.size;return z}}}function hUK(q){let K=z6(7),{store:_,children:z}=q,Y;if(K[0]===Symbol.for("react.memo_cache_sentinel"))Y=Yz7(),K[0]=Y;else Y=K[0];let A=_??Y,O,w;if(K[1]!==A)O=()=>{let H=()=>{let J=A.getAll();if(Object.keys(J).length>0)jw((M)=>({...M,lastSessionMetrics:J}))};return process.on("exit",H),()=>{process.off("exit",H)}},w=[A],K[1]=A,K[2]=O,K[3]=w;else O=K[2],w=K[3];LJ6.useEffect(O,w);let j;if(K[4]!==z||K[5]!==A)j=LJ6.default.createElement(uxY.Provider,{value:A},z),K[4]=z,K[5]=A,K[6]=j;else j=K[6];return j}var LJ6,RUK=1024,uxY;var $z7=y(()=>{q8();V1();LJ6=O6(D6(),1);uxY=LJ6.createContext(null)});function bUK(q){SUK=q}function xUK(q){K48=q}function IUK(q){CUK=q}function mUK(){return uUK}function sS6(q,K){if(uUK=q,SUK?.(q,K),q==="requires_action"&&K)Az7=!0,K48?.({pending_action:K});else if(Az7)Az7=!1,K48?.({pending_action:null});if(q==="idle")K48?.({task_summary:null});if(i6(process.env.CLAUDE_CODE_EMIT_SESSION_STATE_EVENTS))ur({type:"system",subtype:"session_state_changed",state:q})}function _48(q){K48?.(q)}function pUK(q){CUK?.(q)}var SUK=null,K48=null,CUK=null,Az7=!1,uUK="idle";var z48=y(()=>{m8();pC()});function BUK(q){return(K)=>({...K,...typeof q.permission_mode==="string"?{toolPermissionContext:{...K.toolPermissionContext,mode:vE(q.permission_mode)}}:{},...typeof q.is_ultraplan_mode==="boolean"?{isUltraplanMode:q.is_ultraplan_mode}:{}})}function Ss({newState:q,oldState:K}){let _=K.toolPermissionContext.mode,z=q.toolPermissionContext.mode;if(_!==z){let Y=KI(_),$=KI(z);if(Y!==$){let A=$==="plan"&&q.isUltraplanMode&&!K.isUltraplanMode?!0:null;_48({permission_mode:$,is_ultraplan_mode:A})}pUK(z)}if(q.mainLoopModel!==K.mainLoopModel&&q.mainLoopModel===null)W7("userSettings",{model:void 0}),YP(null);if(q.mainLoopModel!==K.mainLoopModel&&q.mainLoopModel!==null)W7("userSettings",{model:q.mainLoopModel}),YP(q.mainLoopModel);if(q.expandedView!==K.expandedView){let Y=q.expandedView==="tasks",$=q.expandedView==="teammates";if(j8().showExpandedTodos!==Y||j8().showSpinnerTree!==$)b8((A)=>({...A,showExpandedTodos:Y,showSpinnerTree:$}))}if(q.verbose!==K.verbose&&j8().verbose!==q.verbose){let Y=q.verbose;b8(($)=>({...$,verbose:Y}))}if(q.settings!==K.settings)try{if(id6(),rd6(),od6(),q.settings.env!==K.settings.env)xd()}catch(Y){H6(x1(Y))}}var tS6=y(()=>{v8();G7();V1();y8();E8();q48();yW();z48();U1()});var Oz7={};T8(Oz7,{App:()=>mxY});function mxY(q){let K=z6(9),{getFpsMetrics:_,stats:z,initialState:Y,children:$}=q,A;if(K[0]!==$||K[1]!==Y)A=aQ8.default.createElement(LJ,{initialState:Y,onChangeAppState:Ss},$),K[0]=$,K[1]=Y,K[2]=A;else A=K[2];let O;if(K[3]!==z||K[4]!==A)O=aQ8.default.createElement(hUK,{store:z},A),K[3]=z,K[4]=A,K[5]=O;else O=K[5];let w;if(K[6]!==_||K[7]!==O)w=aQ8.default.createElement(EUK,{getFpsMetrics:_},O),K[6]=_,K[7]=O,K[8]=w;else w=K[8];return w}var aQ8;var wz7=y(()=>{q8();_z7();$z7();C7();tS6();aQ8=O6(D6(),1)});function gUK(){sQ8.useContext(Zi);let q=VA.get(process.stdout);return sQ8.useMemo(()=>{if(!q)return{setQuery:()=>{},scanElement:()=>[],setPositions:()=>{}};return{setQuery:(K)=>q.setSearchHighlight(K),scanElement:(K)=>q.scanElementSubtree(K),setPositions:(K)=>q.setSearchPositions(K)}},[q])}var sQ8;var FUK=y(()=>{pc6();QV();sQ8=O6(D6(),1)});function UUK(q){let K=z6(7),{onDone:_}=q,z;if(K[0]===Symbol.for("react.memo_cache_sentinel"))z=eS6.default.createElement(u,{flexDirection:"column"},eS6.default.createElement(k,null,"Learn more about how to monitor your spending:"),eS6.default.createElement(hq,{url:"https://code.claude.com/docs/en/costs"})),K[0]=z;else z=K[0];let Y;if(K[1]===Symbol.for("react.memo_cache_sentinel"))Y=[{value:"ok",label:"Got it, thanks!"}],K[1]=Y;else Y=K[1];let $;if(K[2]!==_)$=eS6.default.createElement(H1,{options:Y,onChange:_}),K[2]=_,K[3]=$;else $=K[3];let A;if(K[4]!==_||K[5]!==$)A=eS6.default.createElement(R1,{title:"You've spent $5 on the Anthropic API this session.",onCancel:_},z,$),K[4]=_,K[5]=$,K[6]=A;else A=K[6];return A}var eS6;var QUK=y(()=>{q8();s6();d_();e4();eS6=O6(D6(),1)});function dUK(q){let K=z6(16),{idleMinutes:_,totalInputTokens:z,onDone:Y}=q,$;if(K[0]!==_)$=pxY(_),K[0]=_,K[1]=$;else $=K[1];let A=$,O;if(K[2]!==z)O=_Y(z),K[2]=z,K[3]=O;else O=K[3];let j=`You've been away ${A} and this conversation is ${O} tokens.`,H;if(K[4]!==Y)H=()=>Y("dismiss"),K[4]=Y,K[5]=H;else H=K[5];let J;if(K[6]===Symbol.for("react.memo_cache_sentinel"))J=Y48.default.createElement(u,{flexDirection:"column"},Y48.default.createElement(k,null,"If this is a new task, clearing context will save usage and be faster.")),K[6]=J;else J=K[6];let M;if(K[7]===Symbol.for("react.memo_cache_sentinel"))M={value:"continue",label:"Continue this conversation"},K[7]=M;else M=K[7];let X;if(K[8]===Symbol.for("react.memo_cache_sentinel"))X={value:"clear",label:"Send message as a new conversation"},K[8]=X;else X=K[8];let P;if(K[9]===Symbol.for("react.memo_cache_sentinel"))P=[M,X,{value:"never",label:"Don't ask me again"}],K[9]=P;else P=K[9];let W;if(K[10]!==Y)W=Y48.default.createElement(H1,{options:P,onChange:(f)=>Y(f)}),K[10]=Y,K[11]=W;else W=K[11];let D;if(K[12]!==j||K[13]!==H||K[14]!==W)D=Y48.default.createElement(R1,{title:j,onCancel:H},J,W),K[12]=j,K[13]=H,K[14]=W,K[15]=D;else D=K[15];return D}function pxY(q){if(q<1)return"< 1m";if(q<60)return`${Math.floor(q)}m`;let K=Math.floor(q/60),_=Math.floor(q%60);if(_===0)return`${K}h`;return`${K}h ${_}m`}var Y48;var cUK=y(()=>{q8();s6();U7();d_();e4();Y48=O6(D6(),1)});import{spawn as BxY}from"child_process";function nUK(){if(RJ6++,RJ6===1)oUK(),QxY()}function iUK(){if(RJ6>0)RJ6--;if(RJ6===0)rUK(),jz7()}function UxY(){RJ6=0,rUK(),jz7()}function QxY(){if(process.platform!=="darwin")return;if(qC6!==null)return;qC6=setInterval(()=>{if(RJ6>0)N("Restarting caffeinate to maintain sleep prevention"),jz7(),oUK()},FxY),qC6.unref()}function rUK(){if(qC6!==null)clearInterval(qC6),qC6=null}function oUK(){if(process.platform!=="darwin")return;if(ky!==null)return;if(!lUK)lUK=!0,pq(async()=>{UxY()});try{ky=BxY("caffeinate",["-i","-t",String(gxY)],{stdio:"ignore"}),ky.unref();let q=ky;ky.on("error",(K)=>{if(N(`caffeinate spawn error: ${K.message}`),ky===q)ky=null}),ky.on("exit",()=>{if(ky===q)ky=null}),N("Started caffeinate to prevent sleep")}catch{ky=null}}function jz7(){if(ky!==null){let q=ky;ky=null;try{q.kill("SIGKILL"),N("Stopped caffeinate, allowing sleep")}catch{}}}var gxY=300,FxY=240000,ky=null,qC6=null,RJ6=0,lUK=!1;var aUK=y(()=>{c9();_8()});class Hz7{_status="idle";_generation=0;_changed=Dz();reserve(){if(this._status!=="idle")return!1;return this._status="dispatching",this._notify(),!0}cancelReservation(){if(this._status!=="dispatching")return;this._status="idle",this._notify()}tryStart(){if(this._status==="running")return null;return this._status="running",++this._generation,this._notify(),this._generation}end(q){if(this._generation!==q)return!1;if(this._status!=="running")return!1;return this._status="idle",this._notify(),!0}forceEnd(){if(this._status==="idle")return;this._status="idle",++this._generation,this._notify()}get isActive(){return this._status!=="idle"}get generation(){return this._generation}subscribe=this._changed.subscribe;getSnapshot=()=>{return this._status!=="idle"};_notify(){this._changed.emit()}}var sUK=()=>{};function tUK(q){let K=z6(7),{name:_,color:z}=q,Y;if(K[0]!==z)Y=R0(z),K[0]=z,K[1]=Y;else Y=K[1];let $=Y,A;if(K[2]!==_)A=hJ6.createElement(k,{bold:!0},"@",_),K[2]=_,K[3]=A;else A=K[3];let O;if(K[4]!==$||K[5]!==A)O=hJ6.createElement(u,{flexDirection:"row",gap:1},hJ6.createElement(k,{color:$},A_," ",A)),K[4]=$,K[5]=A,K[6]=O;else O=K[6];return O}var hJ6;var eUK=y(()=>{q8();zz();s6();Fo();hJ6=O6(D6(),1)});function Jz7(q){let K=z6(15),{toolName:_,description:z}=q,Y;if(K[0]===Symbol.for("react.memo_cache_sentinel"))Y=$9(),K[0]=Y;else Y=K[0];let $=Y,A;if(K[1]===Symbol.for("react.memo_cache_sentinel"))A=M_(),K[1]=A;else A=K[1];let O=A,w;if(K[2]===Symbol.for("react.memo_cache_sentinel"))w=vj(),K[2]=w;else w=K[2];let j=w,H,J;if(K[3]===Symbol.for("react.memo_cache_sentinel"))H=WO.createElement(u,{marginBottom:1},WO.createElement(IK,null),WO.createElement(k,{color:"warning",bold:!0}," ","Waiting for team lead approval")),J=O&&j&&WO.createElement(u,{marginBottom:1},WO.createElement(tUK,{name:O,color:j})),K[3]=H,K[4]=J;else H=K[3],J=K[4];let M;if(K[5]===Symbol.for("react.memo_cache_sentinel"))M=WO.createElement(k,{dimColor:!0},"Tool: "),K[5]=M;else M=K[5];let X;if(K[6]!==_)X=WO.createElement(u,null,M,WO.createElement(k,null,_)),K[6]=_,K[7]=X;else X=K[7];let P;if(K[8]===Symbol.for("react.memo_cache_sentinel"))P=WO.createElement(k,{dimColor:!0},"Action: "),K[8]=P;else P=K[8];let W;if(K[9]!==z)W=WO.createElement(u,null,P,WO.createElement(k,null,z)),K[9]=z,K[10]=W;else W=K[10];let D;if(K[11]===Symbol.for("react.memo_cache_sentinel"))D=$&&WO.createElement(u,{marginTop:1},WO.createElement(k,{dimColor:!0},"Permission request sent to team ",'"',$,'"'," leader")),K[11]=D;else D=K[11];let f;if(K[12]!==X||K[13]!==W)f=WO.createElement(u,{flexDirection:"column",borderStyle:"round",borderColor:"warning",paddingX:1},H,J,X,W,D),K[12]=X,K[13]=W,K[14]=f;else f=K[14];return f}var WO;var qQK=y(()=>{q8();s6();AY();Q2();eUK();WO=O6(D6(),1)});function KQK(q,K=!1){let _=P8((O)=>O.teamContext),z=SJ6.useRef(0),Y=SJ6.useRef(void 0),$=SJ6.useRef(void 0),A=SJ6.useRef(0);SJ6.useEffect(()=>{if(K)return;let O=q[0]?.uuid,w=z.current,j=$.current===void 0,H=O!==void 0&&!j&&O===$.current&&w<=q.length,J=O!==void 0&&!j&&O===$.current&&w>q.length,M=H?w:0;if(M===q.length)return;let X=M===0?q:q.slice(M),P=H?Y.current:void 0,W=++A.current;if(fN(X,nq()?{teamName:_?.teamName,agentName:_?.selfAgentName}:{},P,q).then((D)=>{if(W!==A.current)return;if(D&&!H)Y.current=D}),H||j||J){let D=Bq8(X,q).findLast(FS6);if(D)Y.current=D.uuid}z.current=q.length,$.current=O},[q,K,_?.teamName,_?.selfAgentName])}var SJ6;var _QK=y(()=>{C7();i$();_K();SJ6=O6(D6(),1)});function zQK(q){if(!q||typeof q!=="object")return!1;return"behavior"in q&&(q.behavior==="allow"||q.behavior==="deny")}var YQK=()=>{};function tQ8(q){if(q.type!=="user")return;let K=q.message?.content;if(!K)return;if(Array.isArray(K)&&K.length===0)return;let _="uuid"in q&&typeof q.uuid==="string"?q.uuid:void 0;return{content:Array.isArray(K)?dxY(K):K,uuid:_}}function dxY(q){if(!q.some($QK))return q;return q.map((K)=>{if(!$QK(K))return K;let _=K.source,z=typeof _.mediaType==="string"&&_.mediaType?_.mediaType:Cr6(K.source.data);return{...K,source:{type:"base64",media_type:z,data:K.source.data}}})}function $QK(q){if(q.type!=="image"||q.source?.type!=="base64")return!1;return!q.source.media_type}var Mz7=y(()=>{RL()});import{randomUUID as cxY}from"crypto";function Xz7(q){return q===v4?CB:q}function eQ8(q){let _=Z7()?.outputStyle??iv,z={type:"system",subtype:"init",cwd:Z8(),session_id:N8(),tools:q.tools.map((Y)=>Xz7(Y.name)),mcp_servers:q.mcpClients.map((Y)=>({name:Y.name,status:Y.type})),model:q.model,permissionMode:q.permissionMode,slash_commands:q.commands.filter((Y)=>Y.userInvocable!==!1).map((Y)=>Y.name),apiKeySource:Ow().source,betas:QM(),claude_code_version:{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"}.VERSION,output_style:_,agents:q.agents.map((Y)=>Y.agentType),skills:q.skills.filter((Y)=>Y.userInvocable!==!1).map((Y)=>Y.name),plugins:q.plugins.map((Y)=>({name:Y.name,path:Y.path,source:Y.source})),uuid:cxY()};return z.fast_mode_state=II(q.model,q.fastMode),z}var Pz7=y(()=>{v8();TU();Z$();G7();I7();xf();U1()});function qd8(q){if(q===null||typeof q!=="object")return q;let K=q;if("requestId"in K&&!("request_id"in K))K.request_id=K.requestId,delete K.requestId;if("response"in K&&K.response!==null&&typeof K.response==="object"){let _=K.response;if("requestId"in _&&!("request_id"in _))_.request_id=_.requestId,delete _.requestId}return q}import{randomUUID as lxY}from"crypto";function nxY(q){return q!==null&&typeof q==="object"&&"type"in q&&typeof q.type==="string"}function ixY(q){return q!==null&&typeof q==="object"&&"type"in q&&q.type==="control_response"&&"response"in q}function rxY(q){return q!==null&&typeof q==="object"&&"type"in q&&q.type==="control_request"&&"request_id"in q&&"request"in q}function KC6(q){if((q.type==="user"||q.type==="assistant")&&q.isVirtual)return!1;return q.type==="user"||q.type==="assistant"||q.type==="system"&&q.subtype==="local_command"}function Kd8(q){if(q.type!=="user"||q.isMeta||q.toolUseResult||q.isCompactSummary)return;if(q.origin&&q.origin.kind!=="human")return;let K=q.message.content,_;if(typeof K==="string")_=K;else for(let Y of K)if(Y.type==="text"){_=Y.text;break}if(!_)return;return CW6(_)||void 0}function _d8(q,K,_,z,Y,$){try{let A=qd8(r8(q));if(ixY(A)){N("[bridge:repl] Ingress message type=control_response"),Y?.(A);return}if(rxY(A)){N(`[bridge:repl] Inbound control_request subtype=${A.request.subtype}`),$?.(A);return}if(!nxY(A))return;let O="uuid"in A&&typeof A.uuid==="string"?A.uuid:void 0;if(O&&K.has(O)){N(`[bridge:repl] Ignoring echo: type=${A.type} uuid=${O}`);return}if(O&&_.has(O)){N(`[bridge:repl] Ignoring re-delivered inbound: type=${A.type} uuid=${O}`);return}if(N(`[bridge:repl] Ingress message type=${A.type}${O?` uuid=${O}`:""}`),A.type==="user"){if(O)_.add(O);d("tengu_bridge_message_received",{is_repl:!0}),z?.(A)}else N(`[bridge:repl] Ignoring non-user inbound message: type=${A.type}`)}catch(A){N(`[bridge:repl] Failed to parse ingress message: ${d6(A)}`)}}function zd8(q,K){let{transport:_,sessionId:z,outboundOnly:Y,onInterrupt:$,onSetModel:A,onSetMaxThinkingTokens:O,onSetPermissionMode:w}=K;if(!_){N("[bridge:repl] Cannot respond to control_request: transport not configured");return}let j;if(Y&&q.request.subtype!=="initialize"){j={type:"control_response",response:{subtype:"error",request_id:q.request_id,error:oxY}};let J={...j,session_id:z};_.write(J),N(`[bridge:repl] Rejected ${q.request.subtype} (outbound-only) request_id=${q.request_id}`);return}switch(q.request.subtype){case"initialize":j={type:"control_response",response:{subtype:"success",request_id:q.request_id,response:{commands:[],output_style:"normal",available_output_styles:["normal"],models:[],account:{},pid:process.pid}}};break;case"set_model":A?.(q.request.model),j={type:"control_response",response:{subtype:"success",request_id:q.request_id}};break;case"set_max_thinking_tokens":O?.(q.request.max_thinking_tokens),j={type:"control_response",response:{subtype:"success",request_id:q.request_id}};break;case"set_permission_mode":{let J=w?.(q.request.mode)??{ok:!1,error:"set_permission_mode is not supported in this context (onSetPermissionMode callback not registered)"};if(J.ok)j={type:"control_response",response:{subtype:"success",request_id:q.request_id}};else j={type:"control_response",response:{subtype:"error",request_id:q.request_id,error:J.error}};break}case"interrupt":$?.(),j={type:"control_response",response:{subtype:"success",request_id:q.request_id}};break;default:j={type:"control_response",response:{subtype:"error",request_id:q.request_id,error:`REPL bridge does not handle control_request subtype: ${q.request.subtype}`}}}let H={...j,session_id:z};_.write(H),N(`[bridge:repl] Sent control_response for ${q.request.subtype} request_id=${q.request_id} result=${j.response.subtype}`)}function _C6(q){return{type:"result",subtype:"success",duration_ms:0,duration_api_ms:0,is_error:!1,num_turns:0,result:"",stop_reason:null,total_cost_usd:0,usage:{...n0},modelUsage:{},permission_denials:[],session_id:q,uuid:lxY()}}class Cs{capacity;ring;set=new Set;writeIdx=0;constructor(q){this.capacity=q,this.ring=Array(q)}add(q){if(this.set.has(q))return;let K=this.ring[this.writeIdx];if(K!==void 0)this.set.delete(K);this.ring[this.writeIdx]=q,this.set.add(q),this.writeIdx=(this.writeIdx+1)%this.capacity}has(q){return this.set.has(q)}clear(){this.set.clear(),this.ring.fill(void 0),this.writeIdx=0}}var oxY="This session is outbound-only. Enable Remote Control locally to allow inbound control.";var Yd8=y(()=>{k8();E87();_8();bW6();y8();l8()});class CJ6{pending=[];pendingAtClose=0;draining=!1;closed=!1;backpressureResolvers=[];sleepResolve=null;flushResolvers=[];droppedBatches=0;config;constructor(q){this.config=q}get droppedBatchCount(){return this.droppedBatches}get pendingCount(){return this.closed?this.pendingAtClose:this.pending.length}async enqueue(q){if(this.closed)return;let K=Array.isArray(q)?q:[q];if(K.length===0)return;while(this.pending.length+K.length>this.config.maxQueueSize&&!this.closed)await new Promise((_)=>{this.backpressureResolvers.push(_)});if(this.closed)return;this.pending.push(...K),this.drain()}flush(){if(this.pending.length===0&&!this.draining)return Promise.resolve();return this.drain(),new Promise((q)=>{this.flushResolvers.push(q)})}close(){if(this.closed)return;this.closed=!0,this.pendingAtClose=this.pending.length,this.pending=[],this.sleepResolve?.(),this.sleepResolve=null;for(let q of this.backpressureResolvers)q();this.backpressureResolvers=[];for(let q of this.flushResolvers)q();this.flushResolvers=[]}async drain(){if(this.draining||this.closed)return;this.draining=!0;let q=0;try{while(this.pending.length>0&&!this.closed){let K=this.takeBatch();if(K.length===0)continue;try{await this.config.send(K),q=0}catch(_){if(q++,this.config.maxConsecutiveFailures!==void 0&&q>=this.config.maxConsecutiveFailures){this.droppedBatches++,this.config.onBatchDropped?.(K.length,q),q=0,this.releaseBackpressure();continue}this.pending=K.concat(this.pending);let z=_ instanceof zC6?_.retryAfterMs:void 0;await this.sleep(this.retryDelay(q,z));continue}this.releaseBackpressure()}}finally{if(this.draining=!1,this.pending.length===0){for(let K of this.flushResolvers)K();this.flushResolvers=[]}}}takeBatch(){let{maxBatchSize:q,maxBatchBytes:K}=this.config;if(K===void 0)return this.pending.splice(0,q);let _=0,z=0;while(z<this.pending.length&&z<q){let Y;try{Y=Buffer.byteLength(g6(this.pending[z]))}catch{this.pending.splice(z,1);continue}if(z>0&&_+Y>K)break;_+=Y,z++}return this.pending.splice(0,z)}retryDelay(q,K){let _=Math.random()*this.config.jitterMs;if(K!==void 0)return Math.max(this.config.baseDelayMs,Math.min(K,this.config.maxDelayMs))+_;return Math.min(this.config.baseDelayMs*2**(q-1),this.config.maxDelayMs)+_}releaseBackpressure(){let q=this.backpressureResolvers;this.backpressureResolvers=[];for(let K of q)K()}sleep(q){return new Promise((K)=>{this.sleepResolve=K,setTimeout((_,z)=>{_.sleepResolve=null,z()},q,this,K)})}}var zC6;var Wz7=y(()=>{l8();zC6=class zC6 extends Error{retryAfterMs;constructor(q,K){super(q);this.retryAfterMs=K}}});class $48{ws=null;lastSentId=null;url;state="idle";onData;onCloseCallback;onConnectCallback;headers;sessionId;autoReconnect;isBridge;reconnectAttempts=0;reconnectStartTime=null;reconnectTimer=null;lastReconnectAttemptTime=null;lastActivityTime=0;pingInterval=null;pongReceived=!0;keepAliveInterval=null;messageBuffer;isBunWs=!1;connectStartTime=0;refreshHeaders;constructor(q,K={},_,z,Y){this.url=q,this.headers=K,this.sessionId=_,this.refreshHeaders=z,this.autoReconnect=Y?.autoReconnect??!0,this.isBridge=Y?.isBridge??!1,this.messageBuffer=new I68(sxY)}async connect(){if(this.state!=="idle"&&this.state!=="reconnecting"){N(`WebSocketTransport: Cannot connect, current state is ${this.state}`,{level:"error"}),c8("error","cli_websocket_connect_failed");return}this.state="reconnecting",this.connectStartTime=Date.now(),N(`WebSocketTransport: Opening ${this.url.href}`),c8("info","cli_websocket_connect_opening");let q={...this.headers};if(this.lastSentId)q["X-Last-Request-Id"]=this.lastSentId,N(`WebSocketTransport: Adding X-Last-Request-Id header: ${this.lastSentId}`);if(typeof Bun<"u"){let K=new globalThis.WebSocket(this.url.href,{headers:q,proxy:NI(this.url.href),tls:YV()||void 0});this.ws=K,this.isBunWs=!0,K.addEventListener("open",this.onBunOpen),K.addEventListener("message",this.onBunMessage),K.addEventListener("error",this.onBunError),K.addEventListener("close",this.onBunClose),K.addEventListener("pong",this.onPong)}else{let{default:K}=await Promise.resolve().then(() => (W96(),MI6)),_=new K(this.url.href,{headers:q,agent:VI(this.url.href),...YV()});this.ws=_,this.isBunWs=!1,_.on("open",this.onNodeOpen),_.on("message",this.onNodeMessage),_.on("error",this.onNodeError),_.on("close",this.onNodeClose),_.on("pong",this.onPong)}}onBunOpen=()=>{if(this.handleOpenEvent(),this.lastSentId)this.replayBufferedMessages("")};onBunMessage=(q)=>{let K=typeof q.data==="string"?q.data:String(q.data);if(this.lastActivityTime=Date.now(),c8("info","cli_websocket_message_received",{length:K.length}),this.onData)this.onData(K)};onBunError=()=>{N("WebSocketTransport: Error",{level:"error"}),c8("error","cli_websocket_connect_error")};onBunClose=(q)=>{let K=q.code===1000||q.code===1001;N(`WebSocketTransport: Closed: ${q.code}`,K?void 0:{level:"error"}),c8("error","cli_websocket_connect_closed"),this.handleConnectionError(q.code)};onNodeOpen=()=>{let q=this.ws;if(this.handleOpenEvent(),!q)return;let _=q.upgradeReq;if(_?.headers?.["x-last-request-id"]){let z=_.headers["x-last-request-id"];this.replayBufferedMessages(z)}};onNodeMessage=(q)=>{let K=q.toString();if(this.lastActivityTime=Date.now(),c8("info","cli_websocket_message_received",{length:K.length}),this.onData)this.onData(K)};onNodeError=(q)=>{N(`WebSocketTransport: Error: ${q.message}`,{level:"error"}),c8("error","cli_websocket_connect_error")};onNodeClose=(q,K)=>{let _=q===1000||q===1001;N(`WebSocketTransport: Closed: ${q}`,_?void 0:{level:"error"}),c8("error","cli_websocket_connect_closed"),this.handleConnectionError(q)};onPong=()=>{this.pongReceived=!0};handleOpenEvent(){let q=Date.now()-this.connectStartTime;if(N("WebSocketTransport: Connected"),c8("info","cli_websocket_connect_connected",{duration_ms:q}),this.isBridge&&this.reconnectStartTime!==null)d("tengu_ws_transport_reconnected",{attempts:this.reconnectAttempts,downtimeMs:Date.now()-this.reconnectStartTime});this.reconnectAttempts=0,this.reconnectStartTime=null,this.lastReconnectAttemptTime=null,this.lastActivityTime=Date.now(),this.state="connected",this.onConnectCallback?.(),this.startPingInterval(),this.startKeepaliveInterval(),Yp8(()=>{this.write({type:"keep_alive"})})}sendLine(q){if(!this.ws||this.state!=="connected")return N("WebSocketTransport: Not connected"),c8("info","cli_websocket_send_not_connected"),!1;try{return this.ws.send(q),this.lastActivityTime=Date.now(),!0}catch(K){return N(`WebSocketTransport: Failed to send: ${K}`,{level:"error"}),c8("error","cli_websocket_send_error"),this.handleConnectionError(),!1}}removeWsListeners(q){if(this.isBunWs){let K=q;K.removeEventListener("open",this.onBunOpen),K.removeEventListener("message",this.onBunMessage),K.removeEventListener("error",this.onBunError),K.removeEventListener("close",this.onBunClose),K.removeEventListener("pong",this.onPong)}else{let K=q;K.off("open",this.onNodeOpen),K.off("message",this.onNodeMessage),K.off("error",this.onNodeError),K.off("close",this.onNodeClose),K.off("pong",this.onPong)}}doDisconnect(){if(this.stopPingInterval(),this.stopKeepaliveInterval(),z18(),this.ws)this.removeWsListeners(this.ws),this.ws.close(),this.ws=null}handleConnectionError(q){if(N(`WebSocketTransport: Disconnected from ${this.url.href}`+(q!=null?` (code ${q})`:"")),c8("info","cli_websocket_disconnected"),this.isBridge)d("tengu_ws_transport_closed",{closeCode:q,msSinceLastActivity:this.lastActivityTime>0?Date.now()-this.lastActivityTime:-1,wasConnected:this.state==="connected",reconnectAttempts:this.reconnectAttempts});if(this.doDisconnect(),this.state==="closing"||this.state==="closed")return;let K=!1;if(q===4003&&this.refreshHeaders){let Y=this.refreshHeaders();if(Y.Authorization!==this.headers.Authorization)Object.assign(this.headers,Y),K=!0,N("WebSocketTransport: 4003 received but headers refreshed, scheduling reconnect"),c8("info","cli_websocket_4003_token_refreshed")}if(q!=null&&_IY.has(q)&&!K){N(`WebSocketTransport: Permanent close code ${q}, not reconnecting`,{level:"error"}),c8("error","cli_websocket_permanent_close",{closeCode:q}),this.state="closed",this.onCloseCallback?.(q);return}if(!this.autoReconnect){this.state="closed",this.onCloseCallback?.(q);return}let _=Date.now();if(!this.reconnectStartTime)this.reconnectStartTime=_;if(this.lastReconnectAttemptTime!==null&&_-this.lastReconnectAttemptTime>AQK)N(`WebSocketTransport: Detected system sleep (${Math.round((_-this.lastReconnectAttemptTime)/1000)}s gap), resetting reconnection budget`),c8("info","cli_websocket_sleep_detected",{gapMs:_-this.lastReconnectAttemptTime}),this.reconnectStartTime=_,this.reconnectAttempts=0;this.lastReconnectAttemptTime=_;let z=_-this.reconnectStartTime;if(z<exY){if(this.reconnectTimer)clearTimeout(this.reconnectTimer),this.reconnectTimer=null;if(!K&&this.refreshHeaders){let A=this.refreshHeaders();Object.assign(this.headers,A),N("WebSocketTransport: Refreshed headers for reconnect")}this.state="reconnecting",this.reconnectAttempts++;let Y=Math.min(txY*Math.pow(2,this.reconnectAttempts-1),OQK),$=Math.max(0,Y+Y*0.25*(2*Math.random()-1));if(N(`WebSocketTransport: Reconnecting in ${Math.round($)}ms (attempt ${this.reconnectAttempts}, ${Math.round(z/1000)}s elapsed)`),c8("error","cli_websocket_reconnect_attempt",{reconnectAttempts:this.reconnectAttempts}),this.isBridge)d("tengu_ws_transport_reconnecting",{attempt:this.reconnectAttempts,elapsedMs:z,delayMs:Math.round($)});this.reconnectTimer=setTimeout(()=>{this.reconnectTimer=null,this.connect()},$)}else if(N(`WebSocketTransport: Reconnection time budget exhausted after ${Math.round(z/1000)}s for ${this.url.href}`,{level:"error"}),c8("error","cli_websocket_reconnect_exhausted",{reconnectAttempts:this.reconnectAttempts,elapsedMs:z}),this.state="closed",this.onCloseCallback)this.onCloseCallback(q)}close(){if(this.reconnectTimer)clearTimeout(this.reconnectTimer),this.reconnectTimer=null;this.stopPingInterval(),this.stopKeepaliveInterval(),z18(),this.state="closing",this.doDisconnect()}replayBufferedMessages(q){let K=this.messageBuffer.toArray();if(K.length===0)return;let _=0;if(q){let Y=K.findIndex(($)=>("uuid"in $)&&$.uuid===q);if(Y>=0){_=Y+1;let $=K.slice(_);if(this.messageBuffer.clear(),this.messageBuffer.addAll($),$.length===0)this.lastSentId=null;N(`WebSocketTransport: Evicted ${_} confirmed messages, ${$.length} remaining`),c8("info","cli_websocket_evicted_confirmed_messages",{evicted:_,remaining:$.length})}}let z=K.slice(_);if(z.length===0){N("WebSocketTransport: No new messages to replay"),c8("info","cli_websocket_no_messages_to_replay");return}N(`WebSocketTransport: Replaying ${z.length} buffered messages`),c8("info","cli_websocket_messages_to_replay",{count:z.length});for(let Y of z){let $=g6(Y)+`
`;if(!this.sendLine($)){this.handleConnectionError();break}}}isConnectedStatus(){return this.state==="connected"}isClosedStatus(){return this.state==="closed"}setOnData(q){this.onData=q}setOnConnect(q){this.onConnectCallback=q}setOnClose(q){this.onCloseCallback=q}getStateLabel(){return this.state}async write(q){if("uuid"in q&&typeof q.uuid==="string")this.messageBuffer.add(q),this.lastSentId=q.uuid;let K=g6(q)+`
`;if(this.state!=="connected")return;let _=this.sessionId?` session=${this.sessionId}`:"",z=this.getControlMessageDetailLabel(q);N(`WebSocketTransport: Sending message type=${q.type}${_}${z}`),this.sendLine(K)}getControlMessageDetailLabel(q){if(q.type==="control_request"){let{request_id:K,request:_}=q,z=_.subtype==="can_use_tool"?_.tool_name:"";return` subtype=${_.subtype} request_id=${K}${z?` tool=${z}`:""}`}if(q.type==="control_response"){let{subtype:K,request_id:_}=q.response;return` subtype=${K} request_id=${_}`}return""}startPingInterval(){this.stopPingInterval(),this.pongReceived=!0;let q=Date.now();this.pingInterval=setInterval(()=>{if(this.state==="connected"&&this.ws){let K=Date.now(),_=K-q;if(q=K,_>AQK){N(`WebSocketTransport: ${Math.round(_/1000)}s tick gap detected — process was suspended, forcing reconnect`),c8("info","cli_websocket_sleep_detected_on_ping",{gapMs:_}),this.handleConnectionError();return}if(!this.pongReceived){N("WebSocketTransport: No pong received, connection appears dead",{level:"error"}),c8("error","cli_websocket_pong_timeout"),this.handleConnectionError();return}this.pongReceived=!1;try{this.ws.ping?.()}catch(z){N(`WebSocketTransport: Ping failed: ${z}`,{level:"error"}),c8("error","cli_websocket_ping_failed")}}},qIY)}stopPingInterval(){if(this.pingInterval)clearInterval(this.pingInterval),this.pingInterval=null}startKeepaliveInterval(){if(this.stopKeepaliveInterval(),i6(process.env.CLAUDE_CODE_REMOTE))return;this.keepAliveInterval=setInterval(()=>{if(this.state==="connected"&&this.ws)try{this.ws.send(axY),this.lastActivityTime=Date.now(),N("WebSocketTransport: Sent periodic keep_alive data frame")}catch(q){N(`WebSocketTransport: Periodic keep_alive failed: ${q}`,{level:"error"}),c8("error","cli_websocket_keepalive_failed")}},KIY)}stopKeepaliveInterval(){if(this.keepAliveInterval)clearInterval(this.keepAliveInterval),this.keepAliveInterval=null}}var axY=`{"type":"keep_alive"}