| 6182 | Bad (wrong case): {"title": "Fix Login Button On Mobile"}`,ifY;var PS6=y(()=>{x7();v8();k8();ew();_8();vO();i1();ifY=B6(()=>L.object({title:L.string()}))});async function xF8(q,K){let _=bF8(q);if(!_)return null;try{let z=await RG({systemPrompt:iK(['Generate a short kebab-case name (2-4 words) that captures the main topic of this conversation. Use lowercase words separated by hyphens. Examples: "fix-login-bug", "add-auth-feature", "refactor-api-client", "debug-test-failures". Return JSON with a "name" field.']),userPrompt:_,outputFormat:{type:"json_schema",schema:{type:"object",properties:{name:{type:"string"}},required:["name"],additionalProperties:!1}},signal:K,options:{querySource:"rename_generate_name",agents:[],isNonInteractiveSession:!1,hasAppendSystemPrompt:!1,mcpTools:[]}}),Y=L3(z.message.content),$=m5(Y);if($&&typeof $==="object"&&"name"in $&&typeof $.name==="string")return $.name;return null}catch(z){return N(`generateSessionName failed: ${d6(z)}`,{level:"error"}),null}}var tK7=y(()=>{ew();_8();y8();vO();i1();PS6()});function sfY(q){return q.replace(ofY,(K,_,z)=>{if(z.length<afY)return`"${_}":"[REDACTED]"`;let Y=`${z.slice(0,8)}...${z.slice(-4)}`;return`"${_}":"${Y}"`})}function eK7(q){let K=q.replace(/\n/g,"\\n");if(K.length<=IF8)return K;return K.slice(0,IF8)+`... (${K.length} chars)`}function WS6(q){let K=typeof q==="string"?q:g6(q),_=sfY(K);if(_.length<=IF8)return _;return _.slice(0,IF8)+`... (${_.length} chars)`}function uF8(q){let K=d6(q);if(q&&typeof q==="object"&&"response"in q){let _=q.response;if(_?.data&&typeof _.data==="object"){let z=_.data,Y=typeof z.message==="string"?z.message:typeof z.error==="object"&&z.error&&("message"in z.error)&&typeof z.error.message==="string"?z.error.message:void 0;if(Y)return`${K}: ${Y}`}}return K}function XRK(q){if(q&&typeof q==="object"&&"response"in q&&q.response&&typeof q.response.status==="number")return q.response.status;return}function vd(q){if(!q||typeof q!=="object")return;if("message"in q&&typeof q.message==="string")return q.message;if("error"in q&&q.error!==null&&typeof q.error==="object"&&"message"in q.error&&typeof q.error.message==="string")return q.error.message;return}function Zy(q,K,_){if(K)N(K);d("tengu_bridge_repl_skipped",{reason:q,..._!==void 0&&{v2:_}})}var IF8=2000,rfY,ofY,afY=16;var Ys=y(()=>{k8();_8();y8();l8();rfY=["session_ingress_token","environment_secret","access_token","secret","token"],ofY=new RegExp(`"(${rfY.join("|")})"\\s*:\\s*"([^"]*)"`,"g")});var DS6={};T8(DS6,{updateBridgeSessionTitle:()=>_57,getBridgeSession:()=>tfY,createBridgeSession:()=>q57,archiveBridgeSession:()=>K57});async function q57({environmentId:q,title:K,events:_,gitRepoUrl:z,branch:Y,signal:$,baseUrl:A,getAccessToken:O,permissionMode:w}){let{getClaudeAIOAuthTokens:j}=await Promise.resolve().then(() => (G7(),_L)),{getOrganizationUUID:H}=await Promise.resolve().then(() => (pW(),V06)),{getOauthConfig:J}=await Promise.resolve().then(() => (H3(),Bm6)),{getOAuthHeaders:M}=await Promise.resolve().then(() => (VM(),ge6)),{parseGitHubRepository:X}=await Promise.resolve().then(() => (mZ(),$p6)),{getDefaultBranch:P}=await Promise.resolve().then(() => (E5(),qA8)),{getMainLoopModel:W}=await Promise.resolve().then(() => (aq(),h2q)),{default:D}=await Promise.resolve().then(() => (CK(),DW6)),f=O?.()??j()?.accessToken;if(!f)return N("[bridge] No access token for session creation"),null;let G=await H();if(!G)return N("[bridge] No org UUID for session creation"),null;let Z=null,T=null;if(z){let{parseGitRemote:I}=await Promise.resolve().then(() => (mZ(),$p6)),B=I(z);if(B){let{host:p,owner:C,name:g}=B,F=Y||await P()||void 0;Z={type:"git_repository",url:`https://${p}/${C}/${g}`,revision:F},T={type:"git_repository",git_info:{type:"github",repo:`${C}/${g}`,branches:[`claude/${Y||"task"}`]}}}else{let p=X(z);if(p){let[C,g]=p.split("/");if(C&&g){let F=Y||await P()||void 0;Z={type:"git_repository",url:`https://github.com/${C}/${g}`,revision:F},T={type:"git_repository",git_info:{type:"github",repo:`${C}/${g}`,branches:[`claude/${Y||"task"}`]}}}}}}let v={...K!==void 0&&{title:K},events:_,session_context:{sources:Z?[Z]:[],outcomes:T?[T]:[],model:W()},environment_id:q,source:"remote-control",...w&&{permission_mode:w}},V={...M(f),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":G},E=`${A??J().BASE_API_URL}/v1/sessions`,S;try{S=await D.post(E,v,{headers:V,signal:$,validateStatus:(I)=>I<500})}catch(I){return N(`[bridge] Session creation request failed: ${d6(I)}`),null}if(!(S.status===200||S.status===201)){let I=vd(S.data);return N(`[bridge] Session creation failed with status ${S.status}${I?`: ${I}`:""}`),null}let x=S.data;if(!x||typeof x!=="object"||!("id"in x)||typeof x.id!=="string")return N("[bridge] No session ID in response"),null;return x.id}async function tfY(q,K){let{getClaudeAIOAuthTokens:_}=await Promise.resolve().then(() => (G7(),_L)),{getOrganizationUUID:z}=await Promise.resolve().then(() => (pW(),V06)),{getOauthConfig:Y}=await Promise.resolve().then(() => (H3(),Bm6)),{getOAuthHeaders:$}=await Promise.resolve().then(() => (VM(),ge6)),{default:A}=await Promise.resolve().then(() => (CK(),DW6)),O=K?.getAccessToken?.()??_()?.accessToken;if(!O)return N("[bridge] No access token for session fetch"),null;let w=await z();if(!w)return N("[bridge] No org UUID for session fetch"),null;let j={...$(O),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":w},H=`${K?.baseUrl??Y().BASE_API_URL}/v1/sessions/${q}`;N(`[bridge] Fetching session ${q}`);let J;try{J=await A.get(H,{headers:j,timeout:1e4,validateStatus:(M)=>M<500})}catch(M){return N(`[bridge] Session fetch request failed: ${d6(M)}`),null}if(J.status!==200){let M=vd(J.data);return N(`[bridge] Session fetch failed with status ${J.status}${M?`: ${M}`:""}`),null}return J.data}async function K57(q,K){let{getClaudeAIOAuthTokens:_}=await Promise.resolve().then(() => (G7(),_L)),{getOrganizationUUID:z}=await Promise.resolve().then(() => (pW(),V06)),{getOauthConfig:Y}=await Promise.resolve().then(() => (H3(),Bm6)),{getOAuthHeaders:$}=await Promise.resolve().then(() => (VM(),ge6)),{default:A}=await Promise.resolve().then(() => (CK(),DW6)),O=K?.getAccessToken?.()??_()?.accessToken;if(!O){N("[bridge] No access token for session archive");return}let w=await z();if(!w){N("[bridge] No org UUID for session archive");return}let j={...$(O),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":w},H=`${K?.baseUrl??Y().BASE_API_URL}/v1/sessions/${q}/archive`;N(`[bridge] Archiving session ${q}`);let J=await A.post(H,{},{headers:j,timeout:K?.timeoutMs??1e4,validateStatus:(M)=>M<500});if(J.status===200)N(`[bridge] Session ${q} archived successfully`);else{let M=vd(J.data);N(`[bridge] Session archive failed with status ${J.status}${M?`: ${M}`:""}`)}}async function _57(q,K,_){let{getClaudeAIOAuthTokens:z}=await Promise.resolve().then(() => (G7(),_L)),{getOrganizationUUID:Y}=await Promise.resolve().then(() => (pW(),V06)),{getOauthConfig:$}=await Promise.resolve().then(() => (H3(),Bm6)),{getOAuthHeaders:A}=await Promise.resolve().then(() => (VM(),ge6)),{default:O}=await Promise.resolve().then(() => (CK(),DW6)),w=_?.getAccessToken?.()??z()?.accessToken;if(!w){N("[bridge] No access token for session title update");return}let j=await Y();if(!j){N("[bridge] No org UUID for session title update");return}let H={...A(w),"anthropic-beta":"ccr-byoc-2025-07-29","x-organization-uuid":j},J=FC(q),M=`${_?.baseUrl??$().BASE_API_URL}/v1/sessions/${J}`;N(`[bridge] Updating session title: ${J} → ${K}`);try{let X=await O.patch(M,{title:K},{headers:H,timeout:1e4,validateStatus:(P)=>P<500});if(X.status===200)N("[bridge] Session title updated successfully");else{let P=vd(X.data);N(`[bridge] Session title update failed with status ${X.status}${P?`: ${P}`:""}`)}}catch(X){N(`[bridge] Session title update request failed: ${d6(X)}`)}}var eH6=y(()=>{_8();y8();Ys()});var PRK={};T8(PRK,{call:()=>efY});async function efY(q,K,_){if($Y())return q("Cannot rename: This session is a swarm teammate. Teammate names are set by the team leader.",{display:"system"}),null;let z;if(!_||_.trim()===""){let w=await xF8(i2(K.messages),K.abortController.signal);if(!w)return q("Could not generate a name: no conversation context yet. Usage: /rename <name>",{display:"system"}),null;z=w}else z=_.trim();let Y=N8(),$=Y$();await $s(Y,z,$);let O=K.getAppState().replBridgeSessionId;if(O){let w=DR6();Promise.resolve().then(() => (eH6(),DS6)).then(({updateBridgeSessionTitle:j})=>j(O,z,{baseUrl:xK6(),getAccessToken:w?()=>w:void 0}).catch(()=>{}))}return await o78(Y,z,$),K.setAppState((w)=>({...w,standaloneAgentContext:{...w.standaloneAgentContext,name:z}})),q(`Session renamed to: ${z}`,{display:"system"}),null}var WRK=y(()=>{v8();Ea();i1();_K();AY();tK7()});var q0Y,DRK;var fRK=y(()=>{q0Y={type:"local-jsx",name:"rename",description:"Rename the current conversation",immediate:!0,argumentHint:"[name]",load:()=>Promise.resolve().then(() => (WRK(),PRK))},DRK=q0Y});import{sep as K0Y}from"path";async function As(q){let K=Date.now(),{stdout:_,code:z}=await S7(L7(),["worktree","list","--porcelain"],{cwd:q,preserveOutputOnError:!1}),Y=Date.now()-K;if(z!==0)return d("tengu_worktree_detection",{duration_ms:Y,worktree_count:0,success:!1}),[];let $=_.split(` |
| 6183 | `).filter((w)=>w.startsWith("worktree ")).map((w)=>w.slice(9).normalize("NFC"));d("tengu_worktree_detection",{duration_ms:Y,worktree_count:$.length,success:!0});let A=$.find((w)=>q===w||q.startsWith(w+K0Y)),O=$.filter((w)=>w!==A).sort((w,j)=>w.localeCompare(j));return A?[A,...O]:O}var a78=y(()=>{k8();XK();E5()});function ZRK(q,K){for(let _ of q)if(!K.has(_))return!1;return!0}function GRK(q){if(q.type!=="user")return!1;let K=q.message.content[0];if(K?.type!=="text")return!1;if(!K.text.includes(`<${XA}`))return!1;if(o4(K.text,wj)!=="completed")return!1;return o4(K.text,gw)?.startsWith(FR6)??!1}function TRK(q,K){if(!p4())return q;if(K)return q;let _=[],z=0;while(z<q.length){let Y=q[z];if(GRK(Y)){let $=0;while(z<q.length&&GRK(q[z]))$++,z++;if($===1)_.push(Y);else _.push({...Y,message:{role:"user",content:[{type:"text",text:`<${XA}><${wj}>completed</${wj}><${gw}>${$} background commands completed</${gw}></${XA}>`}]}})}else _.push(Y),z++}return _}var vRK=y(()=>{RY();vK6();_M();i1()});function kRK(q){return q.type==="system"&&q.subtype==="stop_hook_summary"&&q.hookLabel!==void 0}function VRK(q){let K=[],_=0;while(_<q.length){let z=q[_];if(kRK(z)){let Y=z.hookLabel,$=[];while(_<q.length){let A=q[_];if(!kRK(A)||A.hookLabel!==Y)break;$.push(A),_++}if($.length===1)K.push(z);else K.push({...z,hookCount:$.reduce((A,O)=>A+O.hookCount,0),hookInfos:$.flatMap((A)=>A.hookInfos),hookErrors:$.flatMap((A)=>A.hookErrors),preventedContinuation:$.some((A)=>A.preventedContinuation),hasOutput:$.some((A)=>A.hasOutput),totalDurationMs:Math.max(...$.map((A)=>A.totalDurationMs??0))})}else K.push(z),_++}return K}function NRK(q){return q.type==="attachment"&&q.attachment.type==="task_status"&&q.attachment.taskType==="in_process_teammate"&&q.attachment.status==="completed"}function yRK(q){let K=[],_=0;while(_<q.length){let z=q[_];if(NRK(z)){let Y=0;while(_<q.length&&NRK(q[_]))Y++,_++;if(Y===1)K.push(z);else K.push({type:"attachment",uuid:z.uuid,timestamp:z.timestamp,attachment:{type:"teammate_shutdown_batch",count:Y}})}else K.push(z),_++}return K}function _0Y(q){let K=ERK.get(q);if(!K)K=new Set(q.filter((_)=>_.renderGroupedToolUse).map((_)=>_.name)),ERK.set(q,K);return K}function z57(q){if(q.type==="assistant"&&q.message.content[0]?.type==="tool_use"){let K=q.message.content[0];return{messageId:q.message.id,toolUseId:K.id,toolName:K.name}}return null}function LRK(q,K,_=!1){if(_)return{messages:q};let z=_0Y(K),Y=new Map;for(let H of q){let J=z57(H);if(J&&z.has(J.toolName)){let M=`${J.messageId}:${J.toolName}`,X=Y.get(M)??[];X.push(H),Y.set(M,X)}}let $=new Map,A=new Set;for(let[H,J]of Y)if(J.length>=2){$.set(H,J);for(let M of J){let X=z57(M);if(X)A.add(X.toolUseId)}}let O=new Map;for(let H of q)if(H.type==="user"){for(let J of H.message.content)if(J.type==="tool_result"&&A.has(J.tool_use_id))O.set(J.tool_use_id,H)}let w=[],j=new Set;for(let H of q){let J=z57(H);if(J){let M=`${J.messageId}:${J.toolName}`,X=$.get(M);if(X){if(!j.has(M)){j.add(M);let P=X[0],W=[];for(let f of X){let G=f.message.content[0].id,Z=O.get(G);if(Z)W.push(Z)}let D={type:"grouped_tool_use",toolName:J.toolName,messages:X,results:W,displayMessage:P,uuid:`grouped-${P.uuid}`,timestamp:P.timestamp,messageId:J.messageId};w.push(D)}continue}}if(H.type==="user"){let M=H.message.content.filter((X)=>X.type==="tool_result");if(M.length>0){if(M.every((P)=>A.has(P.tool_use_id)))continue}}w.push(H)}return{messages:w}}var ERK;var RRK=y(()=>{ERK=new WeakMap});function mF8(q){let K=CRK.get(q);if(K!==void 0)return K;let _=z0Y(q).toLowerCase();return CRK.set(q,_),_}function z0Y(q){let K="";switch(q.type){case"user":{let Y=q.message.content;if(typeof Y==="string")K=SRK.has(Y)?"":Y;else{let $=[];for(let A of Y)if(A.type==="text"){if(!SRK.has(A.text))$.push(A.text)}else if(A.type==="tool_result")$.push($0Y(q.toolUseResult));K=$.join(` |