| 1755 | `&&z++}}return[K,_]}var Gp1;var Tp1=y(()=>{Gp1=class Gp1 extends Error{constructor(q,K){super(q),this.name="ParseError",this.type=K.type,this.field=K.field,this.value=K.value,this.line=K.line}}});function HYz(q){let K=globalThis.DOMException;return typeof K=="function"?new K(q,"SyntaxError"):SyntaxError(q)}function kp1(q){return q instanceof Error?"errors"in q&&Array.isArray(q.errors)?q.errors.map(kp1).join(", "):("cause"in q)&&q.cause instanceof Error?`${q}: ${kp1(q.cause)}`:q.message:`${q}`}function ey4(q){return{type:q.type,message:q.message,code:q.code,defaultPrevented:q.defaultPrevented,cancelable:q.cancelable,timeStamp:q.timeStamp}}function JYz(){let q="document"in globalThis?globalThis.document:void 0;return q&&typeof q=="object"&&"baseURI"in q&&typeof q.baseURI=="string"?q.baseURI:void 0}var vp1,KE4=(q)=>{throw TypeError(q)},Sp1=(q,K,_)=>K.has(q)||KE4("Cannot "+_),Ez=(q,K,_)=>(Sp1(q,K,"read from private field"),_?_.call(q):K.get(q)),mP=(q,K,_)=>K.has(q)?KE4("Cannot add the same private member more than once"):K instanceof WeakSet?K.add(q):K.set(q,_),uj=(q,K,_,z)=>(Sp1(q,K,"write to private field"),K.set(q,_),_),Fr=(q,K,_)=>(Sp1(q,K,"access private method"),_),kN,Xw6,BV6,sN8,tN8,xo6,UV6,Io6,Nq6,gV6,QV6,FV6,Co6,su,Vp1,Np1,yp1,qE4,Ep1,Lp1,bo6,Rp1,hp1,dV6;var _E4=y(()=>{Tp1();vp1=class vp1 extends Event{constructor(q,K){var _,z;super(q),this.code=(_=K==null?void 0:K.code)!=null?_:void 0,this.message=(z=K==null?void 0:K.message)!=null?z:void 0}[Symbol.for("nodejs.util.inspect.custom")](q,K,_){return _(ey4(this),K)}[Symbol.for("Deno.customInspect")](q,K){return q(ey4(this),K)}};dV6=class dV6 extends EventTarget{constructor(q,K){var _,z;super(),mP(this,su),this.CONNECTING=0,this.OPEN=1,this.CLOSED=2,mP(this,kN),mP(this,Xw6),mP(this,BV6),mP(this,sN8),mP(this,tN8),mP(this,xo6),mP(this,UV6),mP(this,Io6,null),mP(this,Nq6),mP(this,gV6),mP(this,QV6,null),mP(this,FV6,null),mP(this,Co6,null),mP(this,Np1,async(Y)=>{var $;Ez(this,gV6).reset();let{body:A,redirected:O,status:w,headers:j}=Y;if(w===204){Fr(this,su,bo6).call(this,"Server sent HTTP 204, not reconnecting",204),this.close();return}if(O?uj(this,BV6,new URL(Y.url)):uj(this,BV6,void 0),w!==200){Fr(this,su,bo6).call(this,`Non-200 status code (${w})`,w);return}if(!(j.get("content-type")||"").startsWith("text/event-stream")){Fr(this,su,bo6).call(this,'Invalid content type, expected "text/event-stream"',w);return}if(Ez(this,kN)===this.CLOSED)return;uj(this,kN,this.OPEN);let H=new Event("open");if(($=Ez(this,Co6))==null||$.call(this,H),this.dispatchEvent(H),typeof A!="object"||!A||!("getReader"in A)){Fr(this,su,bo6).call(this,"Invalid response body, expected a web ReadableStream",w),this.close();return}let J=new TextDecoder,M=A.getReader(),X=!0;do{let{done:P,value:W}=await M.read();W&&Ez(this,gV6).feed(J.decode(W,{stream:!P})),P&&(X=!1,Ez(this,gV6).reset(),Fr(this,su,Rp1).call(this))}while(X)}),mP(this,yp1,(Y)=>{uj(this,Nq6,void 0),!(Y.name==="AbortError"||Y.type==="aborted")&&Fr(this,su,Rp1).call(this,kp1(Y))}),mP(this,Ep1,(Y)=>{typeof Y.id=="string"&&uj(this,Io6,Y.id);let $=new MessageEvent(Y.event||"message",{data:Y.data,origin:Ez(this,BV6)?Ez(this,BV6).origin:Ez(this,Xw6).origin,lastEventId:Y.id||""});Ez(this,FV6)&&(!Y.event||Y.event==="message")&&Ez(this,FV6).call(this,$),this.dispatchEvent($)}),mP(this,Lp1,(Y)=>{uj(this,xo6,Y)}),mP(this,hp1,()=>{uj(this,UV6,void 0),Ez(this,kN)===this.CONNECTING&&Fr(this,su,Vp1).call(this)});try{if(q instanceof URL)uj(this,Xw6,q);else if(typeof q=="string")uj(this,Xw6,new URL(q,JYz()));else throw Error("Invalid URL")}catch{throw HYz("An invalid or illegal string was specified")}uj(this,gV6,aN8({onEvent:Ez(this,Ep1),onRetry:Ez(this,Lp1)})),uj(this,kN,this.CONNECTING),uj(this,xo6,3000),uj(this,tN8,(_=K==null?void 0:K.fetch)!=null?_:globalThis.fetch),uj(this,sN8,(z=K==null?void 0:K.withCredentials)!=null?z:!1),Fr(this,su,Vp1).call(this)}get readyState(){return Ez(this,kN)}get url(){return Ez(this,Xw6).href}get withCredentials(){return Ez(this,sN8)}get onerror(){return Ez(this,QV6)}set onerror(q){uj(this,QV6,q)}get onmessage(){return Ez(this,FV6)}set onmessage(q){uj(this,FV6,q)}get onopen(){return Ez(this,Co6)}set onopen(q){uj(this,Co6,q)}addEventListener(q,K,_){let z=K;super.addEventListener(q,z,_)}removeEventListener(q,K,_){let z=K;super.removeEventListener(q,z,_)}close(){Ez(this,UV6)&&clearTimeout(Ez(this,UV6)),Ez(this,kN)!==this.CLOSED&&(Ez(this,Nq6)&&Ez(this,Nq6).abort(),uj(this,kN,this.CLOSED),uj(this,Nq6,void 0))}};kN=new WeakMap,Xw6=new WeakMap,BV6=new WeakMap,sN8=new WeakMap,tN8=new WeakMap,xo6=new WeakMap,UV6=new WeakMap,Io6=new WeakMap,Nq6=new WeakMap,gV6=new WeakMap,QV6=new WeakMap,FV6=new WeakMap,Co6=new WeakMap,su=new WeakSet,Vp1=function(){uj(this,kN,this.CONNECTING),uj(this,Nq6,new AbortController),Ez(this,tN8)(Ez(this,Xw6),Fr(this,su,qE4).call(this)).then(Ez(this,Np1)).catch(Ez(this,yp1))},Np1=new WeakMap,yp1=new WeakMap,qE4=function(){var q;let K={mode:"cors",redirect:"follow",headers:{Accept:"text/event-stream",...Ez(this,Io6)?{"Last-Event-ID":Ez(this,Io6)}:void 0},cache:"no-store",signal:(q=Ez(this,Nq6))==null?void 0:q.signal};return"window"in globalThis&&(K.credentials=this.withCredentials?"include":"same-origin"),K},Ep1=new WeakMap,Lp1=new WeakMap,bo6=function(q,K){var _;Ez(this,kN)!==this.CLOSED&&uj(this,kN,this.CLOSED);let z=new vp1("error",{code:K,message:q});(_=Ez(this,QV6))==null||_.call(this,z),this.dispatchEvent(z)},Rp1=function(q,K){var _;if(Ez(this,kN)===this.CLOSED)return;uj(this,kN,this.CONNECTING);let z=new vp1("error",{code:K,message:q});(_=Ez(this,QV6))==null||_.call(this,z),this.dispatchEvent(z),uj(this,UV6,setTimeout(Ez(this,hp1),Ez(this,xo6)))},hp1=new WeakMap,dV6.CONNECTING=0,dV6.OPEN=1,dV6.CLOSED=2});function cV6(q){if(!q)return{};if(q instanceof Headers)return Object.fromEntries(q.entries());if(Array.isArray(q))return Object.fromEntries(q);return{...q}}function Pw6(q=fetch,K){if(!K)return q;return async(_,z)=>{let Y={...K,...z,headers:z?.headers?{...cV6(K.headers),...cV6(z.headers)}:K.headers};return q(_,Y)}}async function MYz(q){return(await Cp1).getRandomValues(new Uint8Array(q))}async function XYz(q){let _="",z=await MYz(q);for(let Y=0;Y<q;Y++){let $=z[Y]%66;_+="abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789-._~"[$]}return _}async function PYz(q){return await XYz(q)}async function WYz(q){let K=await(await Cp1).subtle.digest("SHA-256",new TextEncoder().encode(q));return btoa(String.fromCharCode(...new Uint8Array(K))).replace(/\//g,"_").replace(/\+/g,"-").replace(/=/g,"")}async function bp1(q){if(!q)q=43;if(q<43||q>128)throw`Expected a length between 43 and 128. Received ${q}.`;let K=await PYz(q),_=await WYz(K);return{code_verifier:K,code_challenge:_}}var Cp1;var zE4=y(()=>{Cp1=globalThis.crypto?.webcrypto??globalThis.crypto??import("node:crypto").then((q)=>q.webcrypto)});var X0,$E4,uo6,DYz,eN8,qy8,Ky8,YE4,fYz,ZYz,AE4,dzO,czO;var mo6=y(()=>{x7();X0=$61().superRefine((q,K)=>{if(!URL.canParse(q))return K.addIssue({code:C61.custom,message:"URL must be parseable",fatal:!0}),VI6}).refine((q)=>{let K=new URL(q);return K.protocol!=="javascript:"&&K.protocol!=="data:"&&K.protocol!=="vbscript:"},{message:"URL cannot use javascript:, data:, or vbscript: scheme"}),$E4=cM({resource:Q8().url(),authorization_servers:cq(X0).optional(),jwks_uri:Q8().url().optional(),scopes_supported:cq(Q8()).optional(),bearer_methods_supported:cq(Q8()).optional(),resource_signing_alg_values_supported:cq(Q8()).optional(),resource_name:Q8().optional(),resource_documentation:Q8().optional(),resource_policy_uri:Q8().url().optional(),resource_tos_uri:Q8().url().optional(),tls_client_certificate_bound_access_tokens:lA().optional(),authorization_details_types_supported:cq(Q8()).optional(),dpop_signing_alg_values_supported:cq(Q8()).optional(),dpop_bound_access_tokens_required:lA().optional()}),uo6=cM({issuer:Q8(),authorization_endpoint:X0,token_endpoint:X0,registration_endpoint:X0.optional(),scopes_supported:cq(Q8()).optional(),response_types_supported:cq(Q8()),response_modes_supported:cq(Q8()).optional(),grant_types_supported:cq(Q8()).optional(),token_endpoint_auth_methods_supported:cq(Q8()).optional(),token_endpoint_auth_signing_alg_values_supported:cq(Q8()).optional(),service_documentation:X0.optional(),revocation_endpoint:X0.optional(),revocation_endpoint_auth_methods_supported:cq(Q8()).optional(),revocation_endpoint_auth_signing_alg_values_supported:cq(Q8()).optional(),introspection_endpoint:Q8().optional(),introspection_endpoint_auth_methods_supported:cq(Q8()).optional(),introspection_endpoint_auth_signing_alg_values_supported:cq(Q8()).optional(),code_challenge_methods_supported:cq(Q8()).optional(),client_id_metadata_document_supported:lA().optional()}),DYz=cM({issuer:Q8(),authorization_endpoint:X0,token_endpoint:X0,userinfo_endpoint:X0.optional(),jwks_uri:X0,registration_endpoint:X0.optional(),scopes_supported:cq(Q8()).optional(),response_types_supported:cq(Q8()),response_modes_supported:cq(Q8()).optional(),grant_types_supported:cq(Q8()).optional(),acr_values_supported:cq(Q8()).optional(),subject_types_supported:cq(Q8()),id_token_signing_alg_values_supported:cq(Q8()),id_token_encryption_alg_values_supported:cq(Q8()).optional(),id_token_encryption_enc_values_supported:cq(Q8()).optional(),userinfo_signing_alg_values_supported:cq(Q8()).optional(),userinfo_encryption_alg_values_supported:cq(Q8()).optional(),userinfo_encryption_enc_values_supported:cq(Q8()).optional(),request_object_signing_alg_values_supported:cq(Q8()).optional(),request_object_encryption_alg_values_supported:cq(Q8()).optional(),request_object_encryption_enc_values_supported:cq(Q8()).optional(),token_endpoint_auth_methods_supported:cq(Q8()).optional(),token_endpoint_auth_signing_alg_values_supported:cq(Q8()).optional(),display_values_supported:cq(Q8()).optional(),claim_types_supported:cq(Q8()).optional(),claims_supported:cq(Q8()).optional(),service_documentation:Q8().optional(),claims_locales_supported:cq(Q8()).optional(),ui_locales_supported:cq(Q8()).optional(),claims_parameter_supported:lA().optional(),request_parameter_supported:lA().optional(),request_uri_parameter_supported:lA().optional(),require_request_uri_registration:lA().optional(),op_policy_uri:X0.optional(),op_tos_uri:X0.optional(),client_id_metadata_document_supported:lA().optional()}),eN8=Y4({...DYz.shape,...uo6.pick({code_challenge_methods_supported:!0}).shape}),qy8=Y4({access_token:Q8(),id_token:Q8().optional(),token_type:Q8(),expires_in:Mu6.number().optional(),scope:Q8().optional(),refresh_token:Q8().optional()}).strip(),Ky8=Y4({error:Q8(),error_description:Q8().optional(),error_uri:Q8().optional()}),YE4=X0.optional().or(JK("").transform(()=>{return})),fYz=Y4({redirect_uris:cq(X0),token_endpoint_auth_method:Q8().optional(),grant_types:cq(Q8()).optional(),response_types:cq(Q8()).optional(),client_name:Q8().optional(),client_uri:X0.optional(),logo_uri:YE4,scope:Q8().optional(),contacts:cq(Q8()).optional(),tos_uri:YE4,policy_uri:Q8().optional(),jwks_uri:X0.optional(),jwks:k61().optional(),software_id:Q8().optional(),software_version:Q8().optional(),software_statement:Q8().optional()}).strip(),ZYz=Y4({client_id:Q8(),client_secret:Q8().optional(),client_id_issued_at:NY().optional(),client_secret_expires_at:NY().optional()}).strip(),AE4=fYz.merge(ZYz),dzO=Y4({error:Q8(),error_description:Q8().optional()}).strip(),czO=Y4({token:Q8(),token_type_hint:Q8().optional()}).strip()});function OE4(q){let K=typeof q==="string"?new URL(q):new URL(q.href);return K.hash="",K}function wE4({requestedResource:q,configuredResource:K}){let _=typeof q==="string"?new URL(q):new URL(q.href),z=typeof K==="string"?new URL(K):new URL(K.href);if(_.origin!==z.origin)return!1;if(_.pathname.length<z.pathname.length)return!1;let Y=_.pathname.endsWith("/")?_.pathname:_.pathname+"/",$=z.pathname.endsWith("/")?z.pathname:z.pathname+"/";return Y.startsWith($)}var VJ,_y8,lV6,yq6,nV6,zy8,Yy8,$y8,VU,iV6,Ay8,Oy8,wy8,jy8,rV6,oV6,Hy8,Jy8,jE4;var xp1=y(()=>{VJ=class VJ extends Error{constructor(q,K){super(q);this.errorUri=K,this.name=this.constructor.name}toResponseObject(){let q={error:this.errorCode,error_description:this.message};if(this.errorUri)q.error_uri=this.errorUri;return q}get errorCode(){return this.constructor.errorCode}};_y8=class _y8 extends VJ{};_y8.errorCode="invalid_request";lV6=class lV6 extends VJ{};lV6.errorCode="invalid_client";yq6=class yq6 extends VJ{};yq6.errorCode="invalid_grant";nV6=class nV6 extends VJ{};nV6.errorCode="unauthorized_client";zy8=class zy8 extends VJ{};zy8.errorCode="unsupported_grant_type";Yy8=class Yy8 extends VJ{};Yy8.errorCode="invalid_scope";$y8=class $y8 extends VJ{};$y8.errorCode="access_denied";VU=class VU extends VJ{};VU.errorCode="server_error";iV6=class iV6 extends VJ{};iV6.errorCode="temporarily_unavailable";Ay8=class Ay8 extends VJ{};Ay8.errorCode="unsupported_response_type";Oy8=class Oy8 extends VJ{};Oy8.errorCode="unsupported_token_type";wy8=class wy8 extends VJ{};wy8.errorCode="invalid_token";jy8=class jy8 extends VJ{};jy8.errorCode="method_not_allowed";rV6=class rV6 extends VJ{};rV6.errorCode="too_many_requests";oV6=class oV6 extends VJ{};oV6.errorCode="invalid_client_metadata";Hy8=class Hy8 extends VJ{};Hy8.errorCode="insufficient_scope";Jy8=class Jy8 extends VJ{};Jy8.errorCode="invalid_target";jE4={[_y8.errorCode]:_y8,[lV6.errorCode]:lV6,[yq6.errorCode]:yq6,[nV6.errorCode]:nV6,[zy8.errorCode]:zy8,[Yy8.errorCode]:Yy8,[$y8.errorCode]:$y8,[VU.errorCode]:VU,[iV6.errorCode]:iV6,[Ay8.errorCode]:Ay8,[Oy8.errorCode]:Oy8,[wy8.errorCode]:wy8,[jy8.errorCode]:jy8,[rV6.errorCode]:rV6,[oV6.errorCode]:oV6,[Hy8.errorCode]:Hy8,[Jy8.errorCode]:Jy8}});function GYz(q){return["client_secret_basic","client_secret_post","none"].includes(q)}function TYz(q,K){let _=q.client_secret!==void 0;if(K.length===0)return _?"client_secret_post":"none";if("token_endpoint_auth_method"in q&&q.token_endpoint_auth_method&&GYz(q.token_endpoint_auth_method)&&K.includes(q.token_endpoint_auth_method))return q.token_endpoint_auth_method;if(_&&K.includes("client_secret_basic"))return"client_secret_basic";if(_&&K.includes("client_secret_post"))return"client_secret_post";if(K.includes("none"))return"none";return _?"client_secret_post":"none"}function vYz(q,K,_,z){let{client_id:Y,client_secret:$}=K;switch(q){case"client_secret_basic":kYz(Y,$,_);return;case"client_secret_post":VYz(Y,$,z);return;case"none":NYz(Y,z);return;default:throw Error(`Unsupported client authentication method: ${q}`)}}function kYz(q,K,_){if(!K)throw Error("client_secret_basic authentication requires a client_secret");let z=btoa(`${q}:${K}`);_.set("Authorization",`Basic ${z}`)}function VYz(q,K,_){if(_.set("client_id",q),K)_.set("client_secret",K)}function NYz(q,K){K.set("client_id",q)}async function JE4(q){let K=q instanceof Response?q.status:void 0,_=q instanceof Response?await q.text():q;try{let z=Ky8.parse(JSON.parse(_)),{error:Y,error_description:$,error_uri:A}=z;return new(jE4[Y]||VU)($||"",A)}catch(z){let Y=`${K?`HTTP ${K}: `:""}Invalid OAuth error response: ${z}. Raw body: ${_}`;return new VU(Y)}}async function gC(q,K){try{return await mp1(q,K)}catch(_){if(_ instanceof lV6||_ instanceof nV6)return await q.invalidateCredentials?.("all"),await mp1(q,K);else if(_ instanceof yq6)return await q.invalidateCredentials?.("tokens"),await mp1(q,K);throw _}}async function mp1(q,{serverUrl:K,authorizationCode:_,scope:z,resourceMetadataUrl:Y,fetchFn:$}){let A=await q.discoveryState?.(),O,w,j,H=Y;if(!H&&A?.resourceMetadataUrl)H=new URL(A.resourceMetadataUrl);if(A?.authorizationServerUrl){if(w=A.authorizationServerUrl,O=A.resourceMetadata,j=A.authorizationServerMetadata??await Ww6(w,{fetchFn:$}),!O)try{O=await My8(K,{resourceMetadataUrl:H},$)}catch{}if(j!==A.authorizationServerMetadata||O!==A.resourceMetadata)await q.saveDiscoveryState?.({authorizationServerUrl:String(w),resourceMetadataUrl:H?.toString(),resourceMetadata:O,authorizationServerMetadata:j})}else{let G=await gp1(K,{resourceMetadataUrl:H,fetchFn:$});w=G.authorizationServerUrl,j=G.authorizationServerMetadata,O=G.resourceMetadata,await q.saveDiscoveryState?.({authorizationServerUrl:String(w),resourceMetadataUrl:H?.toString(),resourceMetadata:O,authorizationServerMetadata:j})}let J=await EYz(K,q,O),M=await Promise.resolve(q.clientInformation());if(!M){if(_!==void 0)throw Error("Existing OAuth client information is required when exchanging an authorization code");let G=j?.client_id_metadata_document_supported===!0,Z=q.clientMetadataUrl;if(Z&&!yYz(Z))throw new oV6(`clientMetadataUrl must be a valid HTTPS URL with a non-root pathname, got: ${Z}`);if(G&&Z)M={client_id:Z},await q.saveClientInformation?.(M);else{if(!q.saveClientInformation)throw Error("OAuth client information must be saveable for dynamic registration");let v=await bYz(w,{metadata:j,clientMetadata:q.clientMetadata,fetchFn:$});await q.saveClientInformation(v),M=v}}let X=!q.redirectUrl;if(_!==void 0||X){let G=await CYz(q,w,{metadata:j,resource:J,authorizationCode:_,fetchFn:$});return await q.saveTokens(G),"AUTHORIZED"}let P=await q.tokens();if(P?.refresh_token)try{let G=await Qp1(w,{metadata:j,clientInformation:M,refreshToken:P.refresh_token,resource:J,addClientAuthentication:q.addClientAuthentication,fetchFn:$});return await q.saveTokens(G),"AUTHORIZED"}catch(G){if(!(G instanceof VJ)||G instanceof VU);else throw G}let W=q.state?await q.state():void 0,{authorizationUrl:D,codeVerifier:f}=await Fp1(w,{metadata:j,clientInformation:M,state:W,redirectUrl:q.redirectUrl,scope:z||O?.scopes_supported?.join(" ")||q.clientMetadata.scope,resource:J});return await q.saveCodeVerifier(f),await q.redirectToAuthorization(D),"REDIRECT"}function yYz(q){if(!q)return!1;try{let K=new URL(q);return K.protocol==="https:"&&K.pathname!=="/"}catch{return!1}}async function EYz(q,K,_){let z=OE4(q);if(K.validateResourceURL)return await K.validateResourceURL(z,_?.resource);if(!_)return;if(!wE4({requestedResource:z,configuredResource:_.resource}))throw Error(`Protected resource ${_.resource} does not match expected ${z} (or origin)`);return new URL(_.resource)}function aV6(q){let K=q.headers.get("WWW-Authenticate");if(!K)return{};let[_,z]=K.split(" ");if(_.toLowerCase()!=="bearer"||!z)return{};let Y=pp1(q,"resource_metadata")||void 0,$;if(Y)try{$=new URL(Y)}catch{}let A=pp1(q,"scope")||void 0,O=pp1(q,"error")||void 0;return{resourceMetadataUrl:$,scope:A,error:O}}function pp1(q,K){let _=q.headers.get("WWW-Authenticate");if(!_)return null;let z=new RegExp(`${K}=(?:"([^"]+)"|([^\\s,]+))`),Y=_.match(z);if(Y)return Y[1]||Y[2];return null}async function My8(q,K,_=fetch){let z=await hYz(q,"oauth-protected-resource",_,{protocolVersion:K?.protocolVersion,metadataUrl:K?.resourceMetadataUrl});if(!z||z.status===404)throw await z?.body?.cancel(),Error("Resource server does not implement OAuth 2.0 Protected Resource Metadata.");if(!z.ok)throw await z.body?.cancel(),Error(`HTTP ${z.status} trying to load well-known OAuth protected resource metadata.`);return $E4.parse(await z.json())}async function Bp1(q,K,_=fetch){try{return await _(q,{headers:K})}catch(z){if(z instanceof TypeError)if(K)return Bp1(q,void 0,_);else return;throw z}}function LYz(q,K="",_={}){if(K.endsWith("/"))K=K.slice(0,-1);return _.prependPathname?`${K}/.well-known/${q}`:`/.well-known/${q}${K}`}async function HE4(q,K,_=fetch){return await Bp1(q,{"MCP-Protocol-Version":K},_)}function RYz(q,K){return!q||q.status>=400&&q.status<500&&K!=="/"}async function hYz(q,K,_,z){let Y=new URL(q),$=z?.protocolVersion??we,A;if(z?.metadataUrl)A=new URL(z.metadataUrl);else{let w=LYz(K,Y.pathname);A=new URL(w,z?.metadataServerUrl??Y),A.search=Y.search}let O=await HE4(A,$,_);if(!z?.metadataUrl&&RYz(O,Y.pathname)){let w=new URL(`/.well-known/${K}`,Y);O=await HE4(w,$,_)}return O}function SYz(q){let K=typeof q==="string"?new URL(q):q,_=K.pathname!=="/",z=[];if(!_)return z.push({url:new URL("/.well-known/oauth-authorization-server",K.origin),type:"oauth"}),z.push({url:new URL("/.well-known/openid-configuration",K.origin),type:"oidc"}),z;let Y=K.pathname;if(Y.endsWith("/"))Y=Y.slice(0,-1);return z.push({url:new URL(`/.well-known/oauth-authorization-server${Y}`,K.origin),type:"oauth"}),z.push({url:new URL(`/.well-known/openid-configuration${Y}`,K.origin),type:"oidc"}),z.push({url:new URL(`${Y}/.well-known/openid-configuration`,K.origin),type:"oidc"}),z}async function Ww6(q,{fetchFn:K=fetch,protocolVersion:_=we}={}){let z={"MCP-Protocol-Version":_,Accept:"application/json"},Y=SYz(q);for(let{url:$,type:A}of Y){let O=await Bp1($,z,K);if(!O)continue;if(!O.ok){if(await O.body?.cancel(),O.status>=400&&O.status<500)continue;throw Error(`HTTP ${O.status} trying to load ${A==="oauth"?"OAuth":"OpenID provider"} metadata from ${$}`)}if(A==="oauth")return uo6.parse(await O.json());else return eN8.parse(await O.json())}return}async function gp1(q,K){let _,z;try{if(_=await My8(q,{resourceMetadataUrl:K?.resourceMetadataUrl},K?.fetchFn),_.authorization_servers&&_.authorization_servers.length>0)z=_.authorization_servers[0]}catch{}if(!z)z=String(new URL("/",q));let Y=await Ww6(z,{fetchFn:K?.fetchFn});return{authorizationServerUrl:z,authorizationServerMetadata:Y,resourceMetadata:_}}async function Fp1(q,{metadata:K,clientInformation:_,redirectUrl:z,scope:Y,state:$,resource:A}){let O;if(K){if(O=new URL(K.authorization_endpoint),!K.response_types_supported.includes(Ip1))throw Error(`Incompatible auth server: does not support response type ${Ip1}`);if(K.code_challenge_methods_supported&&!K.code_challenge_methods_supported.includes(up1))throw Error(`Incompatible auth server: does not support code challenge method ${up1}`)}else O=new URL("/authorize",q);let w=await bp1(),j=w.code_verifier,H=w.code_challenge;if(O.searchParams.set("response_type",Ip1),O.searchParams.set("client_id",_.client_id),O.searchParams.set("code_challenge",H),O.searchParams.set("code_challenge_method",up1),O.searchParams.set("redirect_uri",String(z)),$)O.searchParams.set("state",$);if(Y)O.searchParams.set("scope",Y);if(Y?.includes("offline_access"))O.searchParams.append("prompt","consent");if(A)O.searchParams.set("resource",A.href);return{authorizationUrl:O,codeVerifier:j}}function ME4(q,K,_){return new URLSearchParams({grant_type:"authorization_code",code:q,code_verifier:K,redirect_uri:String(_)})}async function Up1(q,{metadata:K,tokenRequestParams:_,clientInformation:z,addClientAuthentication:Y,resource:$,fetchFn:A}){let O=K?.token_endpoint?new URL(K.token_endpoint):new URL("/token",q),w=new Headers({"Content-Type":"application/x-www-form-urlencoded",Accept:"application/json"});if($)_.set("resource",$.href);if(Y)await Y(w,_,O,K);else if(z){let H=K?.token_endpoint_auth_methods_supported??[],J=TYz(z,H);vYz(J,z,w,_)}let j=await(A??fetch)(O,{method:"POST",headers:w,body:_});if(!j.ok)throw await JE4(j);return qy8.parse(await j.json())}async function XE4(q,{metadata:K,clientInformation:_,authorizationCode:z,codeVerifier:Y,redirectUri:$,resource:A,addClientAuthentication:O,fetchFn:w}){let j=ME4(z,Y,$);return Up1(q,{metadata:K,tokenRequestParams:j,clientInformation:_,addClientAuthentication:O,resource:A,fetchFn:w})}async function Qp1(q,{metadata:K,clientInformation:_,refreshToken:z,resource:Y,addClientAuthentication:$,fetchFn:A}){let O=new URLSearchParams({grant_type:"refresh_token",refresh_token:z}),w=await Up1(q,{metadata:K,tokenRequestParams:O,clientInformation:_,addClientAuthentication:$,resource:Y,fetchFn:A});return{refresh_token:z,...w}}async function CYz(q,K,{metadata:_,resource:z,authorizationCode:Y,fetchFn:$}={}){let A=q.clientMetadata.scope,O;if(q.prepareTokenRequest)O=await q.prepareTokenRequest(A);if(!O){if(!Y)throw Error("Either provider.prepareTokenRequest() or authorizationCode is required");if(!q.redirectUrl)throw Error("redirectUrl is required for authorization_code flow");let j=await q.codeVerifier();O=ME4(Y,j,q.redirectUrl)}let w=await q.clientInformation();return Up1(K,{metadata:_,tokenRequestParams:O,clientInformation:w??void 0,addClientAuthentication:q.addClientAuthentication,resource:z,fetchFn:$})}async function bYz(q,{metadata:K,clientMetadata:_,fetchFn:z}){let Y;if(K){if(!K.registration_endpoint)throw Error("Incompatible auth server: does not support dynamic client registration");Y=new URL(K.registration_endpoint)}else Y=new URL("/register",q);let $=await(z??fetch)(Y,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify(_)});if(!$.ok)throw await JE4($);return AE4.parse(await $.json())}var XD,Ip1="code",up1="S256";var Dw6=y(()=>{zE4();lM();mo6();mo6();xp1();XD=class XD extends Error{constructor(q){super(q??"Unauthorized")}}});class Xy8{constructor(q,K){this._url=q,this._resourceMetadataUrl=void 0,this._scope=void 0,this._eventSourceInit=K?.eventSourceInit,this._requestInit=K?.requestInit,this._authProvider=K?.authProvider,this._fetch=K?.fetch,this._fetchWithInit=Pw6(K?.fetch,K?.requestInit)}async _authThenStart(){if(!this._authProvider)throw new XD("No auth provider");let q;try{q=await gC(this._authProvider,{serverUrl:this._url,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})}catch(K){throw this.onerror?.(K),K}if(q!=="AUTHORIZED")throw new XD;return await this._startOrAuth()}async _commonHeaders(){let q={};if(this._authProvider){let _=await this._authProvider.tokens();if(_)q.Authorization=`Bearer ${_.access_token}`}if(this._protocolVersion)q["mcp-protocol-version"]=this._protocolVersion;let K=cV6(this._requestInit?.headers);return new Headers({...q,...K})}_startOrAuth(){let q=this?._eventSourceInit?.fetch??this._fetch??fetch;return new Promise((K,_)=>{this._eventSource=new dV6(this._url.href,{...this._eventSourceInit,fetch:async(z,Y)=>{let $=await this._commonHeaders();$.set("Accept","text/event-stream");let A=await q(z,{...Y,headers:$});if(A.status===401&&A.headers.has("www-authenticate")){let{resourceMetadataUrl:O,scope:w}=aV6(A);this._resourceMetadataUrl=O,this._scope=w}return A}}),this._abortController=new AbortController,this._eventSource.onerror=(z)=>{if(z.code===401&&this._authProvider){this._authThenStart().then(K,_);return}let Y=new PE4(z.code,z.message,z);_(Y),this.onerror?.(Y)},this._eventSource.onopen=()=>{},this._eventSource.addEventListener("endpoint",(z)=>{let Y=z;try{if(this._endpoint=new URL(Y.data,this._url),this._endpoint.origin!==this._url.origin)throw Error(`Endpoint origin does not match connection origin: ${this._endpoint.origin}`)}catch($){_($),this.onerror?.($),this.close();return}K()}),this._eventSource.onmessage=(z)=>{let Y=z,$;try{$=Fx.parse(JSON.parse(Y.data))}catch(A){this.onerror?.(A);return}this.onmessage?.($)}})}async start(){if(this._eventSource)throw Error("SSEClientTransport already started! If using Client class, note that connect() calls start() automatically.");return await this._startOrAuth()}async finishAuth(q){if(!this._authProvider)throw new XD("No auth provider");if(await gC(this._authProvider,{serverUrl:this._url,authorizationCode:q,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})!=="AUTHORIZED")throw new XD("Failed to authorize")}async close(){this._abortController?.abort(),this._eventSource?.close(),this.onclose?.()}async send(q){if(!this._endpoint)throw Error("Not connected");try{let K=await this._commonHeaders();K.set("content-type","application/json");let _={...this._requestInit,method:"POST",headers:K,body:JSON.stringify(q),signal:this._abortController?.signal},z=await(this._fetch??fetch)(this._endpoint,_);if(!z.ok){let Y=await z.text().catch(()=>null);if(z.status===401&&this._authProvider){let{resourceMetadataUrl:$,scope:A}=aV6(z);if(this._resourceMetadataUrl=$,this._scope=A,await gC(this._authProvider,{serverUrl:this._url,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})!=="AUTHORIZED")throw new XD;return this.send(q)}throw Error(`Error POSTing to endpoint (HTTP ${z.status}): ${Y}`)}await z.body?.cancel()}catch(K){throw this.onerror?.(K),K}}setProtocolVersion(q){this._protocolVersion=q}}var PE4;var WE4=y(()=>{_E4();lM();Dw6();PE4=class PE4 extends Error{constructor(q,K,_){super(`SSE error: ${K}`);this.code=q,this.event=_}}});import Py8 from"node:process";import{PassThrough as xYz}from"node:stream";function uYz(){let q={};for(let K of IYz){let _=Py8.env[K];if(_===void 0)continue;if(_.startsWith("()"))continue;q[K]=_}return q}class dp1{constructor(q){if(this._readBuffer=new Ym6,this._stderrStream=null,this._serverParams=q,q.stderr==="pipe"||q.stderr==="overlapped")this._stderrStream=new xYz}async start(){if(this._process)throw Error("StdioClientTransport already started! If using Client class, note that connect() calls start() automatically.");return new Promise((q,K)=>{if(this._process=DE4.default(this._serverParams.command,this._serverParams.args??[],{env:{...uYz(),...this._serverParams.env},stdio:["pipe","pipe",this._serverParams.stderr??"inherit"],shell:!1,windowsHide:Py8.platform==="win32"&&mYz(),cwd:this._serverParams.cwd}),this._process.on("error",(_)=>{K(_),this.onerror?.(_)}),this._process.on("spawn",()=>{q()}),this._process.on("close",(_)=>{this._process=void 0,this.onclose?.()}),this._process.stdin?.on("error",(_)=>{this.onerror?.(_)}),this._process.stdout?.on("data",(_)=>{this._readBuffer.append(_),this.processReadBuffer()}),this._process.stdout?.on("error",(_)=>{this.onerror?.(_)}),this._stderrStream&&this._process.stderr)this._process.stderr.pipe(this._stderrStream)})}get stderr(){if(this._stderrStream)return this._stderrStream;return this._process?.stderr??null}get pid(){return this._process?.pid??null}processReadBuffer(){while(!0)try{let q=this._readBuffer.readMessage();if(q===null)break;this.onmessage?.(q)}catch(q){this.onerror?.(q)}}async close(){if(this._process){let q=this._process;this._process=void 0;let K=new Promise((_)=>{q.once("close",()=>{_()})});try{q.stdin?.end()}catch{}if(await Promise.race([K,new Promise((_)=>setTimeout(_,2000).unref())]),q.exitCode===null){try{q.kill("SIGTERM")}catch{}await Promise.race([K,new Promise((_)=>setTimeout(_,2000).unref())])}if(q.exitCode===null)try{q.kill("SIGKILL")}catch{}}this._readBuffer.clear()}send(q){return new Promise((K)=>{if(!this._process?.stdin)throw Error("Not connected");let _=az8(q);if(this._process.stdin.write(_))K();else this._process.stdin.once("drain",K)})}}function mYz(){return"type"in Py8}var DE4,IYz;var fE4=y(()=>{h11();DE4=O6(Vq1(),1),IYz=Py8.platform==="win32"?["APPDATA","HOMEDRIVE","HOMEPATH","LOCALAPPDATA","PATH","PROCESSOR_ARCHITECTURE","SYSTEMDRIVE","SYSTEMROOT","TEMP","USERNAME","USERPROFILE","PROGRAMFILES"]:["HOME","LOGNAME","PATH","SHELL","TERM","USER"]});var cp1;var ZE4=y(()=>{Tp1();cp1=class cp1 extends TransformStream{constructor({onError:q,onRetry:K,onComment:_}={}){let z;super({start(Y){z=aN8({onEvent:($)=>{Y.enqueue($)},onError($){q==="terminate"?Y.error($):typeof q=="function"&&q($)},onRetry:K,onComment:_})},transform(Y){z.feed(Y)}})}}});class Wy8{constructor(q,K){this._hasCompletedAuthFlow=!1,this._url=q,this._resourceMetadataUrl=void 0,this._scope=void 0,this._requestInit=K?.requestInit,this._authProvider=K?.authProvider,this._fetch=K?.fetch,this._fetchWithInit=Pw6(K?.fetch,K?.requestInit),this._sessionId=K?.sessionId,this._reconnectionOptions=K?.reconnectionOptions??pYz}async _authThenStart(){if(!this._authProvider)throw new XD("No auth provider");let q;try{q=await gC(this._authProvider,{serverUrl:this._url,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})}catch(K){throw this.onerror?.(K),K}if(q!=="AUTHORIZED")throw new XD;return await this._startOrAuthSse({resumptionToken:void 0})}async _commonHeaders(){let q={};if(this._authProvider){let _=await this._authProvider.tokens();if(_)q.Authorization=`Bearer ${_.access_token}`}if(this._sessionId)q["mcp-session-id"]=this._sessionId;if(this._protocolVersion)q["mcp-protocol-version"]=this._protocolVersion;let K=cV6(this._requestInit?.headers);return new Headers({...q,...K})}async _startOrAuthSse(q){let{resumptionToken:K}=q;try{let _=await this._commonHeaders();if(_.set("Accept","text/event-stream"),K)_.set("last-event-id",K);let z=await(this._fetch??fetch)(this._url,{method:"GET",headers:_,signal:this._abortController?.signal});if(!z.ok){if(await z.body?.cancel(),z.status===401&&this._authProvider)return await this._authThenStart();if(z.status===405)return;throw new fw6(z.status,`Failed to open SSE stream: ${z.statusText}`)}this._handleSseStream(z.body,q,!0)}catch(_){throw this.onerror?.(_),_}}_getNextReconnectionDelay(q){if(this._serverRetryMs!==void 0)return this._serverRetryMs;let K=this._reconnectionOptions.initialReconnectionDelay,_=this._reconnectionOptions.reconnectionDelayGrowFactor,z=this._reconnectionOptions.maxReconnectionDelay;return Math.min(K*Math.pow(_,q),z)}_scheduleReconnection(q,K=0){let _=this._reconnectionOptions.maxRetries;if(K>=_){this.onerror?.(Error(`Maximum reconnection attempts (${_}) exceeded.`));return}let z=this._getNextReconnectionDelay(K);this._reconnectionTimeout=setTimeout(()=>{this._startOrAuthSse(q).catch((Y)=>{this.onerror?.(Error(`Failed to reconnect SSE stream: ${Y instanceof Error?Y.message:String(Y)}`)),this._scheduleReconnection(q,K+1)})},z)}_handleSseStream(q,K,_){if(!q)return;let{onresumptiontoken:z,replayMessageId:Y}=K,$,A=!1,O=!1;(async()=>{try{let j=q.pipeThrough(new TextDecoderStream).pipeThrough(new cp1({onRetry:(M)=>{this._serverRetryMs=M}})).getReader();while(!0){let{value:M,done:X}=await j.read();if(X)break;if(M.id)$=M.id,A=!0,z?.(M.id);if(!M.data)continue;if(!M.event||M.event==="message")try{let P=Fx.parse(JSON.parse(M.data));if(S96(P)){if(O=!0,Y!==void 0)P.id=Y}this.onmessage?.(P)}catch(P){this.onerror?.(P)}}if((_||A)&&!O&&this._abortController&&!this._abortController.signal.aborted)this._scheduleReconnection({resumptionToken:$,onresumptiontoken:z,replayMessageId:Y},0)}catch(j){if(this.onerror?.(Error(`SSE stream disconnected: ${j}`)),(_||A)&&!O&&this._abortController&&!this._abortController.signal.aborted)try{this._scheduleReconnection({resumptionToken:$,onresumptiontoken:z,replayMessageId:Y},0)}catch(M){this.onerror?.(Error(`Failed to reconnect: ${M instanceof Error?M.message:String(M)}`))}}})()}async start(){if(this._abortController)throw Error("StreamableHTTPClientTransport already started! If using Client class, note that connect() calls start() automatically.");this._abortController=new AbortController}async finishAuth(q){if(!this._authProvider)throw new XD("No auth provider");if(await gC(this._authProvider,{serverUrl:this._url,authorizationCode:q,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})!=="AUTHORIZED")throw new XD("Failed to authorize")}async close(){if(this._reconnectionTimeout)clearTimeout(this._reconnectionTimeout),this._reconnectionTimeout=void 0;this._abortController?.abort(),this.onclose?.()}async send(q,K){try{let{resumptionToken:_,onresumptiontoken:z}=K||{};if(_){this._startOrAuthSse({resumptionToken:_,replayMessageId:Pu6(q)?q.id:void 0}).catch((J)=>this.onerror?.(J));return}let Y=await this._commonHeaders();Y.set("content-type","application/json"),Y.set("accept","application/json, text/event-stream");let $={...this._requestInit,method:"POST",headers:Y,body:JSON.stringify(q),signal:this._abortController?.signal},A=await(this._fetch??fetch)(this._url,$),O=A.headers.get("mcp-session-id");if(O)this._sessionId=O;if(!A.ok){let J=await A.text().catch(()=>null);if(A.status===401&&this._authProvider){if(this._hasCompletedAuthFlow)throw new fw6(401,"Server returned 401 after successful authentication");let{resourceMetadataUrl:M,scope:X}=aV6(A);if(this._resourceMetadataUrl=M,this._scope=X,await gC(this._authProvider,{serverUrl:this._url,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetchWithInit})!=="AUTHORIZED")throw new XD;return this._hasCompletedAuthFlow=!0,this.send(q)}if(A.status===403&&this._authProvider){let{resourceMetadataUrl:M,scope:X,error:P}=aV6(A);if(P==="insufficient_scope"){let W=A.headers.get("WWW-Authenticate");if(this._lastUpscopingHeader===W)throw new fw6(403,"Server returned 403 after trying upscoping");if(X)this._scope=X;if(M)this._resourceMetadataUrl=M;if(this._lastUpscopingHeader=W??void 0,await gC(this._authProvider,{serverUrl:this._url,resourceMetadataUrl:this._resourceMetadataUrl,scope:this._scope,fetchFn:this._fetch})!=="AUTHORIZED")throw new XD;return this.send(q)}}throw new fw6(A.status,`Error POSTing to endpoint: ${J}`)}if(this._hasCompletedAuthFlow=!1,this._lastUpscopingHeader=void 0,A.status===202){if(await A.body?.cancel(),nW7(q))this._startOrAuthSse({resumptionToken:void 0}).catch((J)=>this.onerror?.(J));return}let j=(Array.isArray(q)?q:[q]).filter((J)=>("method"in J)&&("id"in J)&&J.id!==void 0).length>0,H=A.headers.get("content-type");if(j)if(H?.includes("text/event-stream"))this._handleSseStream(A.body,{onresumptiontoken:z},!1);else if(H?.includes("application/json")){let J=await A.json(),M=Array.isArray(J)?J.map((X)=>Fx.parse(X)):[Fx.parse(J)];for(let X of M)this.onmessage?.(X)}else throw await A.body?.cancel(),new fw6(-1,`Unexpected content type: ${H}`);else await A.body?.cancel()}catch(_){throw this.onerror?.(_),_}}get sessionId(){return this._sessionId}async terminateSession(){if(!this._sessionId)return;try{let q=await this._commonHeaders(),K={...this._requestInit,method:"DELETE",headers:q,signal:this._abortController?.signal},_=await(this._fetch??fetch)(this._url,K);if(await _.body?.cancel(),!_.ok&&_.status!==405)throw new fw6(_.status,`Failed to terminate session: ${_.statusText}`);this._sessionId=void 0}catch(q){throw this.onerror?.(q),q}}setProtocolVersion(q){this._protocolVersion=q}get protocolVersion(){return this._protocolVersion}async resumeStream(q,K){await this._startOrAuthSse({resumptionToken:q,onresumptiontoken:K?.onresumptiontoken})}}var pYz,fw6;var GE4=y(()=>{lM();Dw6();ZE4();pYz={initialReconnectionDelay:1000,maxReconnectionDelay:30000,reconnectionDelayGrowFactor:1.5,maxRetries:2};fw6=class fw6 extends Error{constructor(q,K){super(`Streamable HTTP error: ${K}`);this.code=q}}});function BYz(q,K){return q&&y$8(q,K,nR)}var Dy8;var lp1=y(()=>{Y41();p36();Dy8=BYz});function gYz(q,K){var _={};return K=oR(K,3),Dy8(q,function(z,Y,$){it(_,Y,K(z,Y,$))}),_}var NU;var po6=y(()=>{nx6();lp1();U36();NU=gYz});function FYz(q,K,_){var z=-1,Y=q.length,$=K.length,A={};while(++z<Y){var O=z<$?K[z]:void 0;_(A,q[z],O)}return A}var TE4;var vE4=y(()=>{TE4=FYz});function UYz(q,K){return TE4(q||[],K||[],rt)}var kE4;var VE4=y(()=>{ix6();vE4();kE4=UYz});async function Bo6(q,K,{concurrency:_=Number.POSITIVE_INFINITY,stopOnError:z=!0,signal:Y}={}){return new Promise(($,A)=>{if(q[Symbol.iterator]===void 0&&q[Symbol.asyncIterator]===void 0)throw TypeError(`Expected \`input\` to be either an \`Iterable\` or \`AsyncIterable\`, got (${typeof q})`);if(typeof K!=="function")throw TypeError("Mapper function is required");if(!(Number.isSafeInteger(_)&&_>=1||_===Number.POSITIVE_INFINITY))throw TypeError(`Expected \`concurrency\` to be an integer from 1 and up or \`Infinity\`, got \`${_}\` (${typeof _})`);let O=[],w=[],j=new Map,H=!1,J=!1,M=!1,X=0,P=0,W=q[Symbol.iterator]===void 0?q[Symbol.asyncIterator]():q[Symbol.iterator](),D=()=>{Z(Y.reason)},f=()=>{Y?.removeEventListener("abort",D)},G=(v)=>{$(v),f()},Z=(v)=>{H=!0,J=!0,A(v),f()};if(Y){if(Y.aborted)Z(Y.reason);Y.addEventListener("abort",D,{once:!0})}let T=async()=>{if(J)return;let v=await W.next(),V=P;if(P++,v.done){if(M=!0,X===0&&!J){if(!z&&w.length>0){Z(AggregateError(w));return}if(J=!0,j.size===0){G(O);return}let E=[];for(let[S,R]of O.entries()){if(j.get(S)===NE4)continue;E.push(R)}G(E)}return}X++,(async()=>{try{let E=await v.value;if(J)return;let S=await K(E,V);if(S===NE4)j.set(V,S);O[V]=S,X--,await T()}catch(E){if(z)Z(E);else{w.push(E),X--;try{await T()}catch(S){Z(S)}}}})()};(async()=>{for(let v=0;v<_;v++){try{await T()}catch(V){Z(V);break}if(M||H)break}})()})}var NE4;var np1=y(()=>{NE4=Symbol("skip")});var yE4={};T8(yE4,{toInfraSessionId:()=>op1,toCompatSessionId:()=>FC,setCseShimGate:()=>rp1});function rp1(q){ip1=q}function FC(q){if(!q.startsWith("cse_"))return q;if(ip1&&!ip1())return q;return"session_"+q.slice(4)}function op1(q){if(!q.startsWith("session_"))return q;return"cse_"+q.slice(8)}var ip1;function QYz(q,K){return q?.includes("_staging_")===!0||K?.includes("staging")===!0}function fy8(q,K){return q?.includes("_local_")===!0||K?.includes("localhost")===!0}function ap1(q,K){if(fy8(q,K))return"http://localhost:4000";if(QYz(q,K))return"https://claude-ai.staging.ant.dev";return"https://claude.ai"}function MM(q,K){let{toCompatSessionId:_}=Eq(yE4),z=_(q);return`${ap1(z,K)}/code/${z}`}var Zw6="https://claude.com/claude-code";var dYz,cYz,lYz,tV6;var Zy8=y(()=>{vK();dYz=Z1()==="windows"?"alt+v":"ctrl+v",cYz=Z1()!=="windows"||(eW6()?vE1(process.versions.bun,">=1.2.23"):vE1(process.versions.node,">=22.17.0 <23.0.0 || >=24.2.0")),lYz=cYz?"shift+tab":"meta+m",tV6=[{context:"Global",bindings:{"ctrl+c":"app:interrupt","ctrl+d":"app:exit","ctrl+l":"app:redraw","ctrl+t":"app:toggleTodos","ctrl+o":"app:toggleTranscript",...{"ctrl+shift+b":"app:toggleBrief"},"ctrl+shift+o":"app:toggleTeammatePreview","ctrl+r":"history:search",...{},...{}}},{context:"Chat",bindings:{escape:"chat:cancel","ctrl+x ctrl+k":"chat:killAgents",[lYz]:"chat:cycleMode","meta+p":"chat:modelPicker","meta+o":"chat:fastMode","meta+t":"chat:thinkingToggle",enter:"chat:submit",up:"history:previous",down:"history:next","ctrl+_":"chat:undo","ctrl+shift+-":"chat:undo","ctrl+x ctrl+e":"chat:externalEditor","ctrl+g":"chat:externalEditor","ctrl+s":"chat:stash",[dYz]:"chat:imagePaste",...{},...{space:"voice:pushToTalk"}}},{context:"Autocomplete",bindings:{tab:"autocomplete:accept",escape:"autocomplete:dismiss",up:"autocomplete:previous",down:"autocomplete:next"}},{context:"Settings",bindings:{escape:"confirm:no",up:"select:previous",down:"select:next",k:"select:previous",j:"select:next","ctrl+p":"select:previous","ctrl+n":"select:next",space:"select:accept",enter:"settings:close","/":"settings:search",r:"settings:retry"}},{context:"Confirmation",bindings:{y:"confirm:yes",n:"confirm:no",enter:"confirm:yes",escape:"confirm:no",up:"confirm:previous",down:"confirm:next",tab:"confirm:nextField",space:"confirm:toggle","shift+tab":"confirm:cycleMode","ctrl+e":"confirm:toggleExplanation","ctrl+d":"permission:toggleDebug"}},{context:"Tabs",bindings:{tab:"tabs:next","shift+tab":"tabs:previous",right:"tabs:next",left:"tabs:previous"}},{context:"Transcript",bindings:{"ctrl+e":"transcript:toggleShowAll","ctrl+c":"transcript:exit",escape:"transcript:exit",q:"transcript:exit"}},{context:"HistorySearch",bindings:{"ctrl+r":"historySearch:next",escape:"historySearch:accept",tab:"historySearch:accept","ctrl+c":"historySearch:cancel",enter:"historySearch:execute"}},{context:"Task",bindings:{"ctrl+b":"task:background"}},{context:"ThemePicker",bindings:{"ctrl+t":"theme:toggleSyntaxHighlighting"}},{context:"Scroll",bindings:{pageup:"scroll:pageUp",pagedown:"scroll:pageDown",wheelup:"scroll:lineUp",wheeldown:"scroll:lineDown","ctrl+home":"scroll:top","ctrl+end":"scroll:bottom","ctrl+shift+c":"selection:copy","cmd+c":"selection:copy"}},{context:"Help",bindings:{escape:"help:dismiss"}},{context:"Attachments",bindings:{right:"attachments:next",left:"attachments:previous",backspace:"attachments:remove",delete:"attachments:remove",down:"attachments:exit",escape:"attachments:exit"}},{context:"Footer",bindings:{up:"footer:up","ctrl+p":"footer:up",down:"footer:down","ctrl+n":"footer:down",right:"footer:next",left:"footer:previous",enter:"footer:openSelected",escape:"footer:clearSelection"}},{context:"MessageSelector",bindings:{up:"messageSelector:up",down:"messageSelector:down",k:"messageSelector:up",j:"messageSelector:down","ctrl+p":"messageSelector:up","ctrl+n":"messageSelector:down","ctrl+up":"messageSelector:top","shift+up":"messageSelector:top","meta+up":"messageSelector:top","shift+k":"messageSelector:top","ctrl+down":"messageSelector:bottom","shift+down":"messageSelector:bottom","meta+down":"messageSelector:bottom","shift+j":"messageSelector:bottom",enter:"messageSelector:select"}},...[],{context:"DiffDialog",bindings:{escape:"diff:dismiss",left:"diff:previousSource",right:"diff:nextSource",up:"diff:previousFile",down:"diff:nextFile",enter:"diff:viewDetails"}},{context:"ModelPicker",bindings:{left:"modelPicker:decreaseEffort",right:"modelPicker:increaseEffort"}},{context:"Select",bindings:{up:"select:previous",down:"select:next",j:"select:next",k:"select:previous","ctrl+n":"select:next","ctrl+p":"select:previous",enter:"select:accept",escape:"select:cancel"}},{context:"Plugin",bindings:{space:"plugin:toggle",i:"plugin:install"}}]});function go6(q){let K=q.split("+"),_={key:"",ctrl:!1,alt:!1,shift:!1,meta:!1,super:!1};for(let z of K){let Y=z.toLowerCase();switch(Y){case"ctrl":case"control":_.ctrl=!0;break;case"alt":case"opt":case"option":_.alt=!0;break;case"shift":_.shift=!0;break;case"meta":_.meta=!0;break;case"cmd":case"command":case"super":case"win":_.super=!0;break;case"esc":_.key="escape";break;case"return":_.key="enter";break;case"space":_.key=" ";break;case"↑":_.key="up";break;case"↓":_.key="down";break;case"←":_.key="left";break;case"→":_.key="right";break;default:_.key=Y;break}}return _}function sp1(q){if(q===" ")return[go6("space")];return q.trim().split(/\s+/).map(go6)}function nYz(q){let K=[];if(q.ctrl)K.push("ctrl");if(q.alt)K.push("alt");if(q.shift)K.push("shift");if(q.meta)K.push("meta");if(q.super)K.push("cmd");let _=iYz(q.key);return K.push(_),K.join("+")}function iYz(q){switch(q){case"escape":return"Esc";case" ":return"Space";case"tab":return"tab";case"enter":return"Enter";case"backspace":return"Backspace";case"delete":return"Delete";case"up":return"↑";case"down":return"↓";case"left":return"←";case"right":return"→";case"pageup":return"PageUp";case"pagedown":return"PageDown";case"home":return"Home";case"end":return"End";default:return q}}function Fo6(q){return q.map(nYz).join(" ")}function Gy8(q){let K=[];for(let _ of q)for(let[z,Y]of Object.entries(_.bindings))K.push({chord:sp1(z),action:Y,context:_.context});return K}function EE4(){let q=Z1(),K=[...Uo6,...tp1];if(q==="macos")K.push(...ep1);return K}function Gw6(q){return q.trim().split(/\s+/).map(rYz).join(" ")}function rYz(q){let K=q.split("+"),_=[],z="";for(let Y of K){let $=Y.trim().toLowerCase();if(["ctrl","control","alt","opt","option","meta","cmd","command","shift"].includes($))if($==="control")_.push("ctrl");else if($==="option"||$==="opt")_.push("alt");else if($==="command"||$==="cmd")_.push("cmd");else _.push($);else z=$}return _.sort(),[..._,z].join("+")}var Uo6,tp1,ep1;var Ty8=y(()=>{vK();Uo6=[{key:"ctrl+c",reason:"Cannot be rebound - used for interrupt/exit (hardcoded)",severity:"error"},{key:"ctrl+d",reason:"Cannot be rebound - used for exit (hardcoded)",severity:"error"},{key:"ctrl+m",reason:"Cannot be rebound - identical to Enter in terminals (both send CR)",severity:"error"}],tp1=[{key:"ctrl+z",reason:"Unix process suspend (SIGTSTP)",severity:"warning"},{key:"ctrl+\\",reason:"Terminal quit signal (SIGQUIT)",severity:"error"}],ep1=[{key:"cmd+c",reason:"macOS system copy",severity:"error"},{key:"cmd+v",reason:"macOS system paste",severity:"error"},{key:"cmd+x",reason:"macOS system cut",severity:"error"},{key:"cmd+q",reason:"macOS quit application",severity:"error"},{key:"cmd+w",reason:"macOS close window/tab",severity:"error"},{key:"cmd+tab",reason:"macOS app switcher",severity:"error"},{key:"cmd+space",reason:"macOS Spotlight",severity:"error"}]});function oYz(q){if(typeof q!=="object"||q===null)return!1;let K=q;return typeof K.context==="string"&&typeof K.bindings==="object"&&K.bindings!==null}function aYz(q){return Array.isArray(q)&&q.every(oYz)}function sYz(q){return LE4.includes(q)}function tYz(q){let K=q.toLowerCase().split("+");for(let z of K)if(!z.trim())return{type:"parse_error",severity:"error",message:`Empty key part in "${q}"`,key:q,suggestion:'Remove extra "+" characters'};let _=go6(q);if(!_.key&&!_.ctrl&&!_.alt&&!_.shift&&!_.meta)return{type:"parse_error",severity:"error",message:`Could not parse keystroke "${q}"`,key:q};return null}function eYz(q,K){let _=[];if(typeof q!=="object"||q===null)return _.push({type:"parse_error",severity:"error",message:`Keybinding block ${K+1} is not an object`}),_;let z=q,Y=z.context,$;if(typeof Y!=="string")_.push({type:"parse_error",severity:"error",message:`Keybinding block ${K+1} missing "context" field`});else if(!sYz(Y))_.push({type:"invalid_context",severity:"error",message:`Unknown context "${Y}"`,context:Y,suggestion:`Valid contexts: ${LE4.join(", ")}`});else $=Y;if(typeof z.bindings!=="object"||z.bindings===null)return _.push({type:"parse_error",severity:"error",message:`Keybinding block ${K+1} missing "bindings" field`}),_;let A=z.bindings;for(let[O,w]of Object.entries(A)){let j=tYz(O);if(j)j.context=$,_.push(j);if(w!==null&&typeof w!=="string")_.push({type:"invalid_action",severity:"error",message:`Invalid action for "${O}": must be a string or null`,key:O,context:$});else if(typeof w==="string"&&w.startsWith("command:")){if(!/^command:[a-zA-Z0-9:\-_]+$/.test(w))_.push({type:"invalid_action",severity:"warning",message:`Invalid command binding "${w}" for "${O}": command name may only contain alphanumeric characters, colons, hyphens, and underscores`,key:O,context:$,action:w});if($&&$!=="Chat")_.push({type:"invalid_action",severity:"warning",message:`Command binding "${w}" must be in "Chat" context, not "${$}"`,key:O,context:$,action:w,suggestion:'Move this binding to a block with "context": "Chat"'})}else if(w==="voice:pushToTalk"){let H=sp1(O)[0];if(H&&!H.ctrl&&!H.alt&&!H.shift&&!H.meta&&!H.super&&/^[a-z]$/.test(H.key))_.push({type:"invalid_action",severity:"warning",message:`Binding "${O}" to voice:pushToTalk prints into the input during warmup; use space or a modifier combo like meta+k`,key:O,context:$,action:w})}}return _}function qB1(q){let K=[],_=/"bindings"\s*:\s*\{([^{}]*(?:\{[^{}]*\}[^{}]*)*)\}/g,z;while((z=_.exec(q))!==null){let Y=z[1];if(!Y)continue;let O=q.slice(0,z.index).match(/"context"\s*:\s*"([^"]+)"[^{]*$/)?.[1]??"unknown",w=/"([^"]+)"\s*:/g,j=new Map,H;while((H=w.exec(Y))!==null){let J=H[1];if(!J)continue;let M=(j.get(J)??0)+1;if(j.set(J,M),M===2)K.push({type:"duplicate",severity:"warning",message:`Duplicate key "${J}" in ${O} bindings`,key:J,context:O,suggestion:"This key appears multiple times in the same context. JSON uses the last value, earlier values are ignored."})}}return K}function q$z(q){let K=[];if(!Array.isArray(q))return K.push({type:"parse_error",severity:"error",message:"keybindings.json must contain an array",suggestion:"Wrap your bindings in [ ]"}),K;for(let _=0;_<q.length;_++)K.push(...eYz(q[_],_));return K}function K$z(q){let K=[],_=new Map;for(let z of q){let Y=_.get(z.context)??new Map;_.set(z.context,Y);for(let[$,A]of Object.entries(z.bindings)){let O=Gw6($),w=Y.get(O);if(w&&w!==A)K.push({type:"duplicate",severity:"warning",message:`Duplicate binding "${$}" in ${z.context} context`,key:$,context:z.context,action:A??"null (unbind)",suggestion:`Previously bound to "${w}". Only the last binding will be used.`});Y.set(O,A??"null")}}return K}function _$z(q){let K=[],_=EE4();for(let z of q){let Y=Fo6(z.chord),$=Gw6(Y);for(let A of _)if(Gw6(A.key)===$)K.push({type:"reserved",severity:A.severity,message:`"${Y}" may not work: ${A.reason}`,key:Y,context:z.context,action:z.action??void 0})}return K}function z$z(q){let K=[];for(let _ of q)for(let[z,Y]of Object.entries(_.bindings)){let $=z.split(" ").map((A)=>go6(A));K.push({chord:$,action:Y,context:_.context})}return K}function KB1(q,K){let _=[];if(_.push(...q$z(q)),aYz(q)){_.push(...K$z(q));let Y=z$z(q);_.push(..._$z(Y))}let z=new Set;return _.filter((Y)=>{let $=`${Y.type}:${Y.key}:${Y.context}`;if(z.has($))return!1;return z.add($),!0})}var LE4;var RE4=y(()=>{Ty8();LE4=["Global","Chat","Autocomplete","Confirmation","Help","Transcript","HistorySearch","Task","ThemePicker","Settings","Tabs","Attachments","Footer","MessageSelector","DiffDialog","ModelPicker","Select","Plugin"]});import{readFileSync as Y$z}from"fs";import{readFile as $$z,stat as A$z}from"fs/promises";import{dirname as O$z,join as w$z}from"path";function IL(){return g8("tengu_keybinding_customization_release",!1)}function xE4(q){let K=new Date().toISOString().slice(0,10);if(SE4===K)return;SE4=K,d("tengu_custom_keybindings_loaded",{user_binding_count:q})}function J$z(q){if(typeof q!=="object"||q===null)return!1;let K=q;return typeof K.context==="string"&&typeof K.bindings==="object"&&K.bindings!==null}function IE4(q){return Array.isArray(q)&&q.every(J$z)}function vw6(){return w$z(c1(),"keybindings.json")}function _B1(){return Gy8(tV6)}async function M$z(){let q=_B1();if(!IL())return{bindings:q,warnings:[]};let K=vw6();try{let _=await $$z(K,"utf-8"),z=r8(_),Y;if(typeof z==="object"&&z!==null&&"bindings"in z)Y=z.bindings;else return N('[keybindings] Invalid keybindings.json: keybindings.json must have a "bindings" array'),{bindings:q,warnings:[{type:"parse_error",severity:"error",message:'keybindings.json must have a "bindings" array',suggestion:'Use format: { "bindings": [ ... ] }'}]};if(!IE4(Y)){let j=!Array.isArray(Y)?'"bindings" must be an array':"keybindings.json contains invalid block structure",H=!Array.isArray(Y)?'Set "bindings" to an array of keybinding blocks':'Each block must have "context" (string) and "bindings" (object)';return N(`[keybindings] Invalid keybindings.json: ${j}`),{bindings:q,warnings:[{type:"parse_error",severity:"error",message:j,suggestion:H}]}}let $=Gy8(Y);N(`[keybindings] Loaded ${$.length} user bindings from ${K}`);let A=[...q,...$];xE4($.length);let w=[...qB1(_),...KB1(Y,A)];if(w.length>0)N(`[keybindings] Found ${w.length} validation issue(s)`);return{bindings:A,warnings:w}}catch(_){if(_7(_))return{bindings:q,warnings:[]};return N(`[keybindings] Error loading ${K}: ${d6(_)}`),{bindings:q,warnings:[{type:"parse_error",severity:"error",message:`Failed to parse keybindings.json: ${d6(_)}`}]}}}function uE4(){if(P0)return P0;return Qo6().bindings}function Qo6(){if(P0)return{bindings:P0,warnings:CG};let q=_B1();if(!IL())return P0=q,CG=[],{bindings:P0,warnings:CG};let K=vw6();try{let _=Y$z(K,"utf-8"),z=r8(_),Y;if(typeof z==="object"&&z!==null&&"bindings"in z)Y=z.bindings;else return P0=q,CG=[{type:"parse_error",severity:"error",message:'keybindings.json must have a "bindings" array',suggestion:'Use format: { "bindings": [ ... ] }'}],{bindings:P0,warnings:CG};if(!IE4(Y)){let O=!Array.isArray(Y)?'"bindings" must be an array':"keybindings.json contains invalid block structure",w=!Array.isArray(Y)?'Set "bindings" to an array of keybinding blocks':'Each block must have "context" (string) and "bindings" (object)';return P0=q,CG=[{type:"parse_error",severity:"error",message:O,suggestion:w}],{bindings:P0,warnings:CG}}let $=Gy8(Y);if(N(`[keybindings] Loaded ${$.length} user bindings from ${K}`),P0=[...q,...$],xE4($.length),CG=[...qB1(_),...KB1(Y,P0)],CG.length>0)N(`[keybindings] Found ${CG.length} validation issue(s)`);return{bindings:P0,warnings:CG}}catch{return P0=q,CG=[],{bindings:P0,warnings:CG}}}async function mE4(){if(hE4||bE4)return;if(!IL()){N("[keybindings] Skipping file watcher - user customization disabled");return}let q=vw6(),K=O$z(q);try{if(!(await A$z(K)).isDirectory()){N(`[keybindings] Not watching: ${K} is not a directory`);return}}catch{N(`[keybindings] Not watching: ${K} does not exist`);return}hE4=!0,N(`[keybindings] Watching for changes to ${q}`),Tw6=di.watch(q,{persistent:!0,ignoreInitial:!0,awaitWriteFinish:{stabilityThreshold:j$z,pollInterval:H$z},ignorePermissionErrors:!0,usePolling:!1,atomic:!0}),Tw6.on("add",CE4),Tw6.on("change",CE4),Tw6.on("unlink",P$z),pq(async()=>X$z())}function X$z(){if(bE4=!0,Tw6)Tw6.close(),Tw6=null;vy8.clear()}async function CE4(q){N(`[keybindings] Detected change to ${q}`);try{let K=await M$z();P0=K.bindings,CG=K.warnings,vy8.emit(K)}catch(K){N(`[keybindings] Error reloading: ${d6(K)}`)}}function P$z(q){N(`[keybindings] Detected deletion of ${q}`);let K=_B1();P0=K,CG=[],vy8.emit({bindings:K,warnings:[]})}function BE4(){return CG}var j$z=500,H$z=200,Tw6=null,hE4=!1,bE4=!1,P0=null,CG,vy8,SE4=null,pE4;var Ur=y(()=>{sT6();o1();k8();c9();_8();m8();y8();l8();Zy8();RE4();CG=[],vy8=Dz();pE4=vy8.subscribe});function gE4(q,K){if(K.escape)return"escape";if(K.return)return"enter";if(K.tab)return"tab";if(K.backspace)return"backspace";if(K.delete)return"delete";if(K.upArrow)return"up";if(K.downArrow)return"down";if(K.leftArrow)return"left";if(K.rightArrow)return"right";if(K.pageUp)return"pageup";if(K.pageDown)return"pagedown";if(K.wheelUp)return"wheelup";if(K.wheelDown)return"wheeldown";if(K.home)return"home";if(K.end)return"end";if(q.length===1)return q.toLowerCase();return null}function ky8(q,K,_){let z=_.findLast((Y)=>Y.action===q&&Y.context===K);return z?Fo6(z.chord):void 0}function W$z(q,K){let _=gE4(q,K);if(!_)return null;let z=K.escape?!1:K.meta;return{key:_,ctrl:K.ctrl,alt:z,shift:K.shift,meta:z,super:K.super}}function Vy8(q,K){return q.key===K.key&&q.ctrl===K.ctrl&&q.shift===K.shift&&(q.alt||q.meta)===(K.alt||K.meta)&&q.super===K.super}function D$z(q,K){if(q.length>=K.chord.length)return!1;for(let _=0;_<q.length;_++){let z=q[_],Y=K.chord[_];if(!z||!Y)return!1;if(!Vy8(z,Y))return!1}return!0}function f$z(q,K){if(q.length!==K.chord.length)return!1;for(let _=0;_<q.length;_++){let z=q[_],Y=K.chord[_];if(!z||!Y)return!1;if(!Vy8(z,Y))return!1}return!0}function Ny8(q,K,_,z,Y){if(K.escape&&Y!==null)return{type:"chord_cancelled"};let $=W$z(q,K);if(!$){if(Y!==null)return{type:"chord_cancelled"};return{type:"none"}}let A=Y?[...Y,$]:[$],O=new Set(_),w=z.filter((M)=>O.has(M.context)),j=new Map;for(let M of w)if(M.chord.length>A.length&&D$z(A,M))j.set(Fo6(M.chord),M.action);let H=!1;for(let M of j.values())if(M!==null){H=!0;break}if(H)return{type:"chord_started",pending:A};let J;for(let M of w)if(f$z(A,M))J=M;if(J){if(J.action===null)return{type:"unbound"};return{type:"match",action:J.action}}if(Y!==null)return{type:"chord_cancelled"};return{type:"none"}}var do6=()=>{};function RH(q,K,_){let z=uE4(),Y=ky8(q,K,z);if(Y===void 0){let $=`${q}:${K}`;if(!FE4.has($))FE4.add($),d("tengu_keybinding_fallback_used",{action:q,context:K,fallback:_,reason:"action_not_found"});return _}return Y}var FE4;var tu=y(()=>{k8();Ur();do6();FE4=new Set});function yy8(q){let K=z6(24),{bindings:_,pendingChordRef:z,pendingChord:Y,setPendingChord:$,activeContexts:A,registerActiveContext:O,unregisterActiveContext:w,handlerRegistryRef:j,children:H}=q,J;if(K[0]!==_)J=(v,V)=>ky8(v,V,_),K[0]=_,K[1]=J;else J=K[1];let M=J,X;if(K[2]!==j)X=(v)=>{let V=j.current;if(!V)return Z$z;if(!V.has(v.action))V.set(v.action,new Set);return V.get(v.action).add(v),()=>{let E=V.get(v.action);if(E){if(E.delete(v),E.size===0)V.delete(v.action)}}},K[2]=j,K[3]=X;else X=K[3];let P=X,W;if(K[4]!==A||K[5]!==j)W=(v)=>{let V=j.current;if(!V)return!1;let E=V.get(v);if(!E||E.size===0)return!1;for(let S of E)if(A.has(S.context))return S.handler(),!0;return!1},K[4]=A,K[5]=j,K[6]=W;else W=K[6];let D=W,f;if(K[7]!==_||K[8]!==z)f=(v,V,E)=>Ny8(v,V,E,_,z.current),K[7]=_,K[8]=z,K[9]=f;else f=K[9];let G;if(K[10]!==A||K[11]!==_||K[12]!==M||K[13]!==D||K[14]!==Y||K[15]!==O||K[16]!==P||K[17]!==$||K[18]!==f||K[19]!==w)G={resolve:f,setPendingChord:$,getDisplayText:M,bindings:_,pendingChord:Y,activeContexts:A,registerActiveContext:O,unregisterActiveContext:w,registerHandler:P,invokeAction:D},K[10]=A,K[11]=_,K[12]=M,K[13]=D,K[14]=Y,K[15]=O,K[16]=P,K[17]=$,K[18]=f,K[19]=w,K[20]=G;else G=K[20];let Z=G,T;if(K[21]!==H||K[22]!==Z)T=Eq6.default.createElement(UE4.Provider,{value:Z},H),K[21]=H,K[22]=Z,K[23]=T;else T=K[23];return T}function Z$z(){}function VN(){return Eq6.useContext(UE4)}function Ey8(q,K){let _=z6(5),z=K===void 0?!0:K,Y=VN(),$,A;if(_[0]!==q||_[1]!==z||_[2]!==Y)$=()=>{if(!Y||!z)return;return Y.registerActiveContext(q),()=>{Y.unregisterActiveContext(q)}},A=[q,Y,z],_[0]=q,_[1]=z,_[2]=Y,_[3]=$,_[4]=A;else $=_[3],A=_[4];Eq6.useLayoutEffect($,A)}var Eq6,UE4;var yU=y(()=>{q8();do6();Eq6=O6(D6(),1),UE4=Eq6.createContext(null)});function R5(q,K,_){let z=VN(),Y=z?.getDisplayText(q,K),$=Y===void 0,A=z?"action_not_found":"no_context",O=Ly8.useRef(!1);return Ly8.useEffect(()=>{if($&&!O.current)O.current=!0,d("tengu_keybinding_fallback_used",{action:q,context:K,fallback:_,reason:A})},[$,q,K,_,A]),$?_:Y}var Ly8;var LX=y(()=>{k8();yU();Ly8=O6(D6(),1)});function t8(q){let K=z6(9),{shortcut:_,action:z,parens:Y,bold:$}=q,A=Y===void 0?!1:Y,O=$===void 0?!1:$,w;if(K[0]!==O||K[1]!==_)w=O?Ry8.default.createElement(q$,{bold:!0},_):_,K[0]=O,K[1]=_,K[2]=w;else w=K[2];let j=w;if(A){let J;if(K[3]!==z||K[4]!==j)J=Ry8.default.createElement(q$,null,"(",j," to ",z,")"),K[3]=z,K[4]=j,K[5]=J;else J=K[5];return J}let H;if(K[6]!==z||K[7]!==j)H=Ry8.default.createElement(q$,null,j," to ",z),K[6]=z,K[7]=j,K[8]=H;else H=K[8];return H}var Ry8;var rK=y(()=>{q8();DA6();Ry8=O6(D6(),1)});function P1(q,K,_={}){let{context:z="Global",isActive:Y=!0}=_,$=VN();eV6.useEffect(()=>{if(!$||!Y)return;return $.registerHandler({action:q,context:z,handler:K})},[q,z,K,$,Y]);let A=eV6.useCallback((O,w,j)=>{if(!$)return;let H=[...$.activeContexts,z,"Global"],J=[...new Set(H)],M=$.resolve(O,w,J);switch(M.type){case"match":if($.setPendingChord(null),M.action===q){if(K()!==!1)j.stopImmediatePropagation()}break;case"chord_started":$.setPendingChord(M.pending),j.stopImmediatePropagation();break;case"chord_cancelled":$.setPendingChord(null);break;case"unbound":$.setPendingChord(null),j.stopImmediatePropagation();break;case"none":break}},[q,z,K,$]);k4(A,{isActive:Y})}function o7(q,K={}){let{context:_="Global",isActive:z=!0}=K,Y=VN();eV6.useEffect(()=>{if(!Y||!z)return;let A=[];for(let[O,w]of Object.entries(q))A.push(Y.registerHandler({action:O,context:_,handler:w}));return()=>{for(let O of A)O()}},[_,q,Y,z]);let $=eV6.useCallback((A,O,w)=>{if(!Y)return;let j=[...Y.activeContexts,_,"Global"],H=[...new Set(j)],J=Y.resolve(A,O,H);switch(J.type){case"match":if(Y.setPendingChord(null),J.action in q){let M=q[J.action];if(M&&M()!==!1)w.stopImmediatePropagation()}break;case"chord_started":Y.setPendingChord(J.pending),w.stopImmediatePropagation();break;case"chord_cancelled":Y.setPendingChord(null);break;case"unbound":Y.setPendingChord(null),w.stopImmediatePropagation();break;case"none":break}},[_,q,Y]);k4($,{isActive:z})}var eV6;var Oq=y(()=>{s6();yU();eV6=O6(D6(),1)});function QE4(q){switch(q.type){case"assistant":{let K=q.message.content[0];return K?.type==="text"&&!qN6(K.text)&&!i76.has(K.text)||K?.type==="tool_use"&&K.name in co6}case"user":{if(q.isMeta||q.isCompactSummary)return!1;let K=q.message.content[0];if(K?.type!=="text")return!1;if(i76.has(K.text))return!1;return!Cy8(K.text).startsWith("<")}case"system":switch(q.subtype){case"api_metrics":case"stop_hook_summary":case"turn_duration":case"memory_saved":case"agents_killed":case"away_summary":case"thinking":return!1}return!0;case"grouped_tool_use":case"collapsed_read_search":return!0;case"attachment":switch(q.attachment.type){case"queued_command":case"diagnostics":case"hook_blocking_error":case"hook_error_during_execution":return!0}return!1}}function Sy8(q){if(q.type==="assistant"){let K=q.message.content[0];if(K?.type==="tool_use")return{name:K.name,input:K.input}}if(q.type==="grouped_tool_use"){let K=q.messages[0]?.message.content[0];if(K?.type==="tool_use")return{name:q.toolName,input:K.input}}return}function hy8(q){return q}function dE4(q,K){if(!q.types.includes(K.msgType))return!1;return!q.applies||q.applies(K)}function W0(){return mj.default.useContext(Qr)?"messageActionsBackground":void 0}function cE4(q,K,_,z){let Y=mj.useRef(q);Y.current=q;let $=mj.useRef(z);$.current=z;let A=mj.useMemo(()=>{let w={"messageActions:prev":()=>_.current?.navigatePrev(),"messageActions:next":()=>_.current?.navigateNext(),"messageActions:prevUser":()=>_.current?.navigatePrevUser(),"messageActions:nextUser":()=>_.current?.navigateNextUser(),"messageActions:top":()=>_.current?.navigateTop(),"messageActions:bottom":()=>_.current?.navigateBottom(),"messageActions:escape":()=>K((j)=>j?.expanded?{...j,expanded:!1}:null),"messageActions:ctrlc":()=>K(null)};for(let j of new Set(YB1.map((H)=>H.key)))w[`messageActions:${j}`]=()=>{let H=Y.current;if(!H)return;let J=YB1.find((X)=>X.key===j&&dE4(X,H));if(!J)return;if(J.stays){K((X)=>X?{...X,expanded:!X.expanded}:null);return}let M=_.current?.getSelected();if(!M)return;J.run(M,$.current),K(null)};return w},[K,_]);return{enter:mj.useCallback(()=>{d("tengu_message_actions_enter",{}),_.current?.enterCursor()},[_]),handlers:A}}function lE4(q){let K=z6(28),{cursor:_}=q,z,Y,$,A,O,w,j,H,J;if(K[0]!==_){let Z=YB1.filter((T)=>dE4(T,_));if(Y=u,w="column",j=0,H=1,K[10]===Symbol.for("react.memo_cache_sentinel"))J=mj.default.createElement(u,{borderStyle:"single",borderTop:!0,borderBottom:!1,borderLeft:!1,borderRight:!1,borderDimColor:!0}),K[10]=J;else J=K[10];z=u,$=2,A=1,O=Z.map((T,v)=>{let V=typeof T.label==="function"?T.label(_):T.label;return mj.default.createElement(mj.default.Fragment,{key:T.key},v>0&&mj.default.createElement(k,{dimColor:!0}," · "),mj.default.createElement(k,{bold:!0,dimColor:!1},T.key),mj.default.createElement(k,{dimColor:!0}," ",V))}),K[0]=_,K[1]=z,K[2]=Y,K[3]=$,K[4]=A,K[5]=O,K[6]=w,K[7]=j,K[8]=H,K[9]=J}else z=K[1],Y=K[2],$=K[3],A=K[4],O=K[5],w=K[6],j=K[7],H=K[8],J=K[9];let M,X,P,W,D;if(K[11]===Symbol.for("react.memo_cache_sentinel"))W=mj.default.createElement(k,{dimColor:!0}," · "),D=mj.default.createElement(k,{bold:!0,dimColor:!1},t6.arrowUp,t6.arrowDown),M=mj.default.createElement(k,{dimColor:!0}," navigate · "),X=mj.default.createElement(k,{bold:!0,dimColor:!1},"esc"),P=mj.default.createElement(k,{dimColor:!0}," back"),K[11]=M,K[12]=X,K[13]=P,K[14]=W,K[15]=D;else M=K[11],X=K[12],P=K[13],W=K[14],D=K[15];let f;if(K[16]!==z||K[17]!==$||K[18]!==A||K[19]!==O)f=mj.default.createElement(z,{paddingX:$,paddingY:A},O,W,D,M,X,P),K[16]=z,K[17]=$,K[18]=A,K[19]=O,K[20]=f;else f=K[20];let G;if(K[21]!==Y||K[22]!==f||K[23]!==w||K[24]!==j||K[25]!==H||K[26]!==J)G=mj.default.createElement(Y,{flexDirection:w,flexShrink:j,paddingY:H},J,f),K[21]=Y,K[22]=f,K[23]=w,K[24]=j,K[25]=H,K[26]=J,K[27]=G;else G=K[27];return G}function Cy8(q){let _=q.trimStart();while(_.startsWith("<system-reminder>")){let z=_.indexOf("</system-reminder>");if(z<0)break;_=_.slice(z+18).trimStart()}return _}function T$z(q){switch(q.type){case"user":{let K=q.message.content[0];return K?.type==="text"?Cy8(K.text):""}case"assistant":{let K=q.message.content[0];if(K?.type==="text")return K.text;let _=Sy8(q);return _?co6[_.name]?.extract(_.input)??"":""}case"grouped_tool_use":return q.results.map(zB1).filter(Boolean).join(` |