| 6707 | ${z.analysis.recommendation}`);let $=VR7();await X8().mkdir($);let A=K>0?`-dump${K}`:"",O=`${_}${A}.heapsnapshot`,w=`${_}${A}-diagnostics.json`,j=mIK($,O),H=mIK($,w);return await ZVY(H,g6(z,null,2),{mode:384}),N(`[HeapDump] Diagnostics written to ${H}`),await NVY(j),N(`[HeapDump] Heap dump written to ${j}`),d("tengu_heap_dump",{triggerManual:q==="manual",triggerAuto15GB:q==="auto-1.5GB",dumpNumber:K,success:!0}),{success:!0,heapPath:j,diagPath:H}}catch(_){let z=x1(_);return H6(z),d("tengu_heap_dump",{triggerManual:q==="manual",triggerAuto15GB:q==="auto-1.5GB",dumpNumber:K,success:!1}),{success:!1,error:z.message}}}async function NVY(q){if(typeof Bun<"u"){WVY(q,Bun.generateHeapSnapshot("v8","arraybuffer"),{mode:384}),Bun.gc(!0);return}let K=PVY(q,{mode:384}),_=TVY();await GVY(_,K)}var BIK=y(()=>{v8();k8();_8();y8();bK();e7();E8();l8()});var gIK={};T8(gIK,{call:()=>yVY});async function yVY(){let q=await pIK();if(!q.success)return{type:"text",value:`Failed to create heap dump: ${q.error}`};return{type:"text",value:`${q.heapPath} |
| 6708 | ${q.diagPath}`}}var FIK=y(()=>{BIK()});var EVY,UIK;var QIK=y(()=>{EVY={type:"local",name:"heapdump",description:"Dump the JS heap to ~/Desktop",isHidden:!0,supportsNonInteractive:!0,load:()=>Promise.resolve().then(() => (FIK(),gIK))},UIK=EVY});var dIK;var cIK=y(()=>{dIK={isEnabled:()=>!1,isHidden:!0,name:"stub"}});function XT(q,K){if(!q||!RVY.test(q))throw Error(`Invalid ${K}: contains unsafe characters`);return q}function Tq8(q){function K(O){q.onDebug?.(O)}let _=0,z=100;function Y(O){let w={Authorization:`Bearer ${O}`,"Content-Type":"application/json","anthropic-version":"2023-06-01","anthropic-beta":LVY,"x-environment-runner-version":q.runnerVersion},j=q.getTrustedDeviceToken?.();if(j)w["X-Trusted-Device-Token"]=j;return w}function $(){let O=q.getAccessToken();if(!O)throw Error(kS6);return O}async function A(O,w){let j=$(),H=await O(j);if(H.status!==401)return H;if(!q.onAuth401)return K(`[bridge:api] ${w}: 401 received, no refresh handler`),H;if(K(`[bridge:api] ${w}: 401 received, attempting token refresh`),await q.onAuth401(j)){K(`[bridge:api] ${w}: Token refreshed, retrying request`);let M=$(),X=await O(M);if(X.status!==401)return X;K(`[bridge:api] ${w}: Retry after refresh also got 401`)}else K(`[bridge:api] ${w}: Token refresh failed`);return H}return{async registerBridgeEnvironment(O){K(`[bridge:api] POST /v1/environments/bridge bridgeId=${O.bridgeId}`);let w=await A((j)=>$1.post(`${q.baseUrl}/v1/environments/bridge`,{machine_name:O.machineName,directory:O.dir,branch:O.branch,git_repo_url:O.gitRepoUrl,max_sessions:O.maxSessions,metadata:{worker_type:O.workerType},...O.reuseEnvironmentId&&{environment_id:O.reuseEnvironmentId}},{headers:Y(j),timeout:15000,validateStatus:(H)=>H<500}),"Registration");return Ds(w.status,w.data,"Registration"),K(`[bridge:api] POST /v1/environments/bridge -> ${w.status} environment_id=${w.data.environment_id}`),K(`[bridge:api] >>> ${WS6({machine_name:O.machineName,directory:O.dir,branch:O.branch,git_repo_url:O.gitRepoUrl,max_sessions:O.maxSessions,metadata:{worker_type:O.workerType}})}`),K(`[bridge:api] <<< ${WS6(w.data)}`),w.data},async pollForWork(O,w,j,H){XT(O,"environmentId");let J=_;_=0;let M=await $1.get(`${q.baseUrl}/v1/environments/${O}/work/poll`,{headers:Y(w),params:H!==void 0?{reclaim_older_than_ms:H}:void 0,timeout:1e4,signal:j,validateStatus:(X)=>X<500});if(Ds(M.status,M.data,"Poll"),!M.data){if(_=J+1,_===1||_%z===0)K(`[bridge:api] GET .../work/poll -> ${M.status} (no work, ${_} consecutive empty polls)`);return null}return K(`[bridge:api] GET .../work/poll -> ${M.status} workId=${M.data.id} type=${M.data.data?.type}${M.data.data?.id?` sessionId=${M.data.data.id}`:""}`),K(`[bridge:api] <<< ${WS6(M.data)}`),M.data},async acknowledgeWork(O,w,j){XT(O,"environmentId"),XT(w,"workId"),K(`[bridge:api] POST .../work/${w}/ack`);let H=await $1.post(`${q.baseUrl}/v1/environments/${O}/work/${w}/ack`,{},{headers:Y(j),timeout:1e4,validateStatus:(J)=>J<500});Ds(H.status,H.data,"Acknowledge"),K(`[bridge:api] POST .../work/${w}/ack -> ${H.status}`)},async stopWork(O,w,j){XT(O,"environmentId"),XT(w,"workId"),K(`[bridge:api] POST .../work/${w}/stop force=${j}`);let H=await A((J)=>$1.post(`${q.baseUrl}/v1/environments/${O}/work/${w}/stop`,{force:j},{headers:Y(J),timeout:1e4,validateStatus:(M)=>M<500}),"StopWork");Ds(H.status,H.data,"StopWork"),K(`[bridge:api] POST .../work/${w}/stop -> ${H.status}`)},async deregisterEnvironment(O){XT(O,"environmentId"),K(`[bridge:api] DELETE /v1/environments/bridge/${O}`);let w=await A((j)=>$1.delete(`${q.baseUrl}/v1/environments/bridge/${O}`,{headers:Y(j),timeout:1e4,validateStatus:(H)=>H<500}),"Deregister");Ds(w.status,w.data,"Deregister"),K(`[bridge:api] DELETE /v1/environments/bridge/${O} -> ${w.status}`)},async archiveSession(O){XT(O,"sessionId"),K(`[bridge:api] POST /v1/sessions/${O}/archive`);let w=await A((j)=>$1.post(`${q.baseUrl}/v1/sessions/${O}/archive`,{},{headers:Y(j),timeout:1e4,validateStatus:(H)=>H<500}),"ArchiveSession");if(w.status===409){K(`[bridge:api] POST /v1/sessions/${O}/archive -> 409 (already archived)`);return}Ds(w.status,w.data,"ArchiveSession"),K(`[bridge:api] POST /v1/sessions/${O}/archive -> ${w.status}`)},async reconnectSession(O,w){XT(O,"environmentId"),XT(w,"sessionId"),K(`[bridge:api] POST /v1/environments/${O}/bridge/reconnect session_id=${w}`);let j=await A((H)=>$1.post(`${q.baseUrl}/v1/environments/${O}/bridge/reconnect`,{session_id:w},{headers:Y(H),timeout:1e4,validateStatus:(J)=>J<500}),"ReconnectSession");Ds(j.status,j.data,"ReconnectSession"),K(`[bridge:api] POST .../bridge/reconnect -> ${j.status}`)},async heartbeatWork(O,w,j){XT(O,"environmentId"),XT(w,"workId"),K(`[bridge:api] POST .../work/${w}/heartbeat`);let H=await $1.post(`${q.baseUrl}/v1/environments/${O}/work/${w}/heartbeat`,{},{headers:Y(j),timeout:1e4,validateStatus:(J)=>J<500});return Ds(H.status,H.data,"Heartbeat"),K(`[bridge:api] POST .../work/${w}/heartbeat -> ${H.status} lease_extended=${H.data.lease_extended} state=${H.data.state}`),H.data},async sendPermissionResponseEvent(O,w,j){XT(O,"sessionId"),K(`[bridge:api] POST /v1/sessions/${O}/events type=${w.type}`);let H=await $1.post(`${q.baseUrl}/v1/sessions/${O}/events`,{events:[w]},{headers:Y(j),timeout:1e4,validateStatus:(J)=>J<500});Ds(H.status,H.data,"SendPermissionResponseEvent"),K(`[bridge:api] POST /v1/sessions/${O}/events -> ${H.status}`),K(`[bridge:api] >>> ${WS6({events:[w]})}`),K(`[bridge:api] <<< ${WS6(H.data)}`)}}}function Ds(q,K,_){if(q===200||q===204)return;let z=vd(K),Y=hVY(K);switch(q){case 401:throw new PT(`${_}: Authentication failed (401)${z?`: ${z}`:""}. ${kS6}`,401,Y);case 403:throw new PT(bS6(Y)?"Remote Control session has expired. Please restart with `claude remote-control` or /remote-control.":`${_}: Access denied (403)${z?`: ${z}`:""}. Check your organization permissions.`,403,Y);case 404:throw new PT(z??`${_}: Not found (404). Remote Control may not be available for this organization.`,404,Y);case 410:throw new PT(z??"Remote Control session has expired. Please restart with `claude remote-control` or /remote-control.",410,Y??"environment_expired");case 429:throw Error(`${_}: Rate limited (429). Polling too frequently.`);default:throw Error(`${_}: Failed with status ${q}${z?`: ${z}`:""}`)}}function bS6(q){if(!q)return!1;return q.includes("expired")||q.includes("lifetime")}function vq8(q){if(q.status!==403)return!1;return q.message.includes("external_poll_sessions")||q.message.includes("environments:manage")}function hVY(q){if(q&&typeof q==="object"){if("error"in q&&q.error&&typeof q.error==="object"&&"type"in q.error&&typeof q.error.type==="string")return q.error.type}return}var LVY="environments-2025-11-01",RVY,PT;var kq8=y(()=>{CK();Ys();RVY=/^[a-zA-Z0-9_-]+$/;PT=class PT extends Error{status;errorType;constructor(q,K,_){super(q);this.name="BridgeFatalError",this.status=K,this.errorType=_}}});function lIK(){return SVY}var SVY=null;var Q37=y(()=>{_8();kq8()});var d37=`/bridge-kick <subcommand> |