| 2440 | This repo is ${$8.bold(w)}. |
| 2441 | `))}case"error":throw new AP($.errorMessage||"Failed to validate session repository",$8.red(`Error: ${$.errorMessage||"Failed to validate session repository"} |
| 2442 | `));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} |
| 2443 | `))}}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(` |
| 2444 | ${$} |
| 2445 | `)})}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. |