Function Go1

package/cli.js:2442–2444

(q,K,_,z)

This repo is ${$8.bold(w)}.
`))}case"error":throw new AP($.errorMessage||"Failed to validate session repository",$8.red(`Error: ${$.errorMessage||"Failed to validate session repository"}
`));default:{let A=$.status;throw Error(`Unhandled repo validation status: ${A}`)}}return await $3K(q,z,_,K,Y)}catch(_){if(_ instanceof AP)throw _;let z=x1(_);throw H6(z),d("tengu_teleport_resume_error",{error_type:"resume_session_id_catch"}),new AP(z.message,$8.red(`Error: ${z.message}
`))}}async function jdz(q,K){let _=await Ur1();if(_.size>0)d("tengu_teleport_errors_detected",{error_types:Array.from(_).join(","),errors_ignored:Array.from(K||[]).join(",")}),await new Promise((z)=>{q.render(bx8.default.createElement(LJ,null,bx8.default.createElement(WM,null,bx8.default.createElement(Yx8,{errorsToIgnore:K,onComplete:()=>{d("tengu_teleport_errors_resolved",{error_types:Array.from(_).join(",")}),z()}}))))})}async function Go1(q,K,_,z){return await jdz(q,new Set(["needsGitStash"])),Lj6({initialMessage:K,signal:_,branchName:z,onBundleFail:($)=>process.stderr.write(`
${$}
`)})}async function $3K(q,K,_,z,Y){let $=Date.now();try{N(`[teleport] Starting fetch for session: ${q}`),z?.("fetching_logs");let A=Date.now(),O=await Z5K(q,_,K);if(O===null)N("[teleport] v2 endpoint returned null, trying session-ingress"),O=await f5K(q,_,K);if(N(`[teleport] Session logs fetched in ${Date.now()-A}ms`),O===null)throw Error("Failed to fetch session logs");let w=Date.now(),j=O.filter((J)=>Oa(J)&&!J.isSidechain);N(`[teleport] Filtered ${O.length} entries to ${j.length} messages in ${Date.now()-w}ms`),z?.("fetching_branch");let H=Y?Wb8(Y):void 0;if(H)N(`[teleport] Found branch: ${H}`);return N(`[teleport] Total teleportFromSessionsAPI time: ${Date.now()-$}ms`),{log:j,branch:H}}catch(A){let O=x1(A);if($1.isAxiosError(A)&&A.response?.status===404)throw d("tengu_teleport_error_session_not_found_404",{sessionId:q}),new AP(`${q} not found.`,`${q} not found.
${$8.dim("Run /status in Claude Code to check your account.")}`);throw H6(O),Error(`Failed to fetch session from Sessions API: ${O.message}`)}}async function T68(q,K=null,_){let z=Kq()?.accessToken;if(!z)throw Error("No access token for polling");let Y=await mW();if(!Y)throw Error("No org UUID for polling");let $={...UY(z),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":Y},A=`${u7().BASE_API_URL}/v1/sessions/${q}/events`,O=50,w=[],j=K;for(let M=0;M<O;M++){let X=await $1.get(A,{headers:$,params:j?{after_id:j}:void 0,timeout:30000});if(X.status!==200)throw Error(`Failed to fetch session events: ${X.statusText}`);let P=X.data;if(!P?.data||!Array.isArray(P.data))throw Error("Invalid events response");for(let W of P.data)if(W&&typeof W==="object"&&"type"in W){if(W.type==="env_manager_log"||W.type==="control_response")continue;if("session_id"in W)w.push(W)}if(!P.last_id)break;if(j=P.last_id,!P.has_more)break}if(_?.skipMetadata)return{newEvents:w,lastEventId:j};let H,J;try{let M=await s46(q);H=Wb8(M),J=M.session_status}catch(M){N(`teleport: failed to fetch session ${q} metadata: ${M}`,{level:"debug"})}return{newEvents:w,lastEventId:j,branch:H,sessionStatus:J}}async function Lj6(q){let{initialMessage:K,signal:_}=q;try{await k$();let z=Kq()?.accessToken;if(!z)return H6(Error("No access token found for remote session creation")),null;let Y=await mW();if(!Y)return H6(Error("Unable to get organization UUID for remote session creation")),null;if(q.environmentId){let C=`${u7().BASE_API_URL}/v1/sessions`,g={...UY(z),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":Y},F={CLAUDE_CODE_OAUTH_TOKEN:z,...q.environmentVariables??{}},U=null,c=null;if(q.useBundle){let e=await fo1({oauthToken:z,sessionId:N8(),baseUrl:u7().BASE_API_URL},{signal:_});if(!e.success)return H6(Error(`Bundle upload failed: ${e.error}`)),null;c=e.fileId,d("tengu_teleport_bundle_mode",{size_bytes:e.bundleSizeBytes,scope:e.scope,has_wip:e.hasWip,reason:"explicit_env_bundle"})}else{let e=await Dh();if(e)U={type:"git_repository",url:`https://${e.host}/${e.owner}/${e.name}`,revision:q.branchName}}let K6={title:q.title||q.description||"Remote task",events:[],session_context:{sources:U?[U]:[],...c&&{seed_bundle_file_id:c},outcomes:[],environment_variables:F},environment_id:q.environmentId};N(`[teleportToRemote] explicit env ${q.environmentId}, ${Object.keys(F).length} env vars, ${c?`bundle=${c}`:`source=${U?.url??"none"}@${q.branchName??"default"}`}`);let t=await $1.post(C,K6,{headers:g,signal:_});if(t.status!==200&&t.status!==201)return H6(Error(`CreateSession ${t.status}: ${g6(t.data)}`)),null;let q6=t.data;if(!q6||typeof q6.id!=="string")return H6(Error(`No session id in response: ${g6(t.data)}`)),null;return{id:q6.id,title:q6.title||K6.title}}let $=null,A=null,O=null,w=await Dh(),j,H;if(q.title&&q.reuseOutcomeBranch)j=q.title,H=q.reuseOutcomeBranch;else{let C=await $dz(q.description||K||"Background task",_);j=q.title||C.title,H=q.reuseOutcomeBranch||C.branchName}let J=!1,M="no_git_at_all",X=hY(Z8()),P=!q.skipBundle&&i6(process.env.CCR_FORCE_BUNDLE),W=!q.skipBundle&&X!==null&&(i6(process.env.CCR_ENABLE_BUNDLE)||await FV("tengu_ccr_bundle_seed_enabled"));if(w&&!P)if(w.host==="github.com")J=await K68(w.owner,w.name,_),M=J?"github_preflight_ok":"github_preflight_failed";else J=!0,M="ghes_optimistic";else if(P)M="forced_bundle";else if(X)M="no_github_remote";if(!J&&!W&&w)J=!0;if(J&&w){let{host:C,owner:g,name:F}=w,U=q.branchName??await dT()??void 0;N(`[teleportToRemote] Git source: ${C}/${g}/${F}, revision: ${U??"none"}`),$={type:"git_repository",url:`https://${C}/${g}/${F}`,revision:U,...q.reuseOutcomeBranch&&{allow_unrestricted_git_push:!0}},A={type:"git_repository",git_info:{type:"github",repo:`${g}/${F}`,branches:[H]}}}if(!$&&W){N(`[teleportToRemote] Bundling (reason: ${M})`);let C=await fo1({oauthToken:z,sessionId:N8(),baseUrl:u7().BASE_API_URL},{signal:_});if(!C.success){H6(Error(`Bundle upload failed: ${C.error}`));let g=w?". Please setup GitHub on https://claude.ai/code":"",F;switch(C.failReason){case"empty_repo":F='Repository has no commits — run `git add . && git commit -m "initial"` then retry';break;case"too_large":F=`Repo is too large to teleport${g}`;break;case"git_error":F=`Failed to create git bundle (${C.error})${g}`;break;case void 0:F=`Bundle upload failed: ${C.error}${g}`;break;default:{let U=C.failReason;F=`Bundle upload failed: ${C.error}`}}return q.onBundleFail?.(F),null}O=C.fileId,d("tengu_teleport_bundle_mode",{size_bytes:C.bundleSizeBytes,scope:C.scope,has_wip:C.hasWip,reason:M})}if(d("tengu_teleport_source_decision",{reason:M,path:$?"github":O?"bundle":"empty"}),!$&&!O)N("[teleportToRemote] No repository detected — session will have an empty sandbox");let D=await rm();if(!D||D.length===0)return H6(Error("No environments available for session creation")),null;N(`Available environments: ${D.map((C)=>`${C.environment_id} (${C.name}, ${C.kind})`).join(", ")}`);let f=Z7(),G=q.useDefaultEnvironment?void 0:f?.remote?.defaultEnvironmentId,Z=D.find((C)=>C.kind==="anthropic_cloud");if(q.useDefaultEnvironment&&!Z){N(`No anthropic_cloud in env list (${D.length} envs); retrying fetchEnvironments`);let C=await rm();if(Z=C?.find((g)=>g.kind==="anthropic_cloud"),!Z)return H6(Error(`No anthropic_cloud environment available after retry (got: ${(C??D).map((g)=>`${g.name} (${g.kind})`).join(", ")}). Silent byoc fallthrough would launch into a dead env — fail fast instead.`)),null;if(C)D=C}let T=G&&D.find((C)=>C.environment_id===G)||Z||D.find((C)=>C.kind!=="bridge")||D[0];if(!T)return H6(Error("No environments available for session creation")),null;if(G){let C=T.environment_id===G;N(C?`Using configured default environment: ${G}`:`Configured default environment ${G} not found, using first available`)}let v=T.environment_id;N(`Selected environment: ${v} (${T.name}, ${T.kind})`);let V=`${u7().BASE_API_URL}/v1/sessions`,E={...UY(z),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":Y},S={sources:$?[$]:[],...O&&{seed_bundle_file_id:O},outcomes:A?[A]:[],model:q.model??D5(),...q.reuseOutcomeBranch&&{reuse_outcome_branches:!0},...q.githubPr&&{github_pr:q.githubPr}},R=[];if(q.permissionMode)R.push({type:"event",data:{type:"control_request",request_id:`set-mode-${Y3K()}`,request:{subtype:"set_permission_mode",mode:q.permissionMode,ultraplan:q.ultraplan}}});if(K)R.push({type:"event",data:{uuid:Y3K(),session_id:"",type:"user",parent_tool_use_id:null,message:{role:"user",content:K}}});let x={title:q.ultraplan?`ultraplan: ${j}`:j,events:R,session_context:S,environment_id:v};N(`Creating session with payload: ${g6(x,null,2)}`);let I=await $1.post(V,x,{headers:E,signal:_});if(!(I.status===200||I.status===201))return H6(Error(`API request failed with status ${I.status}: ${I.statusText}