| 2492 | `)}if(X.sessionStatus==="archived"){A3(q,K.setAppState,(x)=>x.status==="running"?{...x,status:"completed",endTime:Date.now()}:x),To1(q,M.title,"completed",K.setAppState,M.toolUseId),Zw(q),wa(q);return}let W=Mdz.get(M.remoteTaskType);if(W){let x=await W(M.remoteTaskMetadata);if(x!==null){A3(q,K.setAppState,(I)=>I.status==="running"?{...I,status:"completed",endTime:Date.now()}:I),To1(q,x,"completed",K.setAppState,M.toolUseId),Zw(q),wa(q);return}}let D=M.isUltraplan||M.isLongRunning?void 0:w.findLast((x)=>x.type==="result");if(M.isRemoteReview&&P&&j===null)j=Wdz(X.newEvents);let f;if(M.isRemoteReview&&P){let x=`<${tq1}>`,I=`</${tq1}>`;for(let B of X.newEvents)if(B.type==="system"&&(B.subtype==="hook_progress"||B.subtype==="hook_response")){let p=B.stdout,C=p.lastIndexOf(I),g=C===-1?-1:p.lastIndexOf(x,C);if(g!==-1&&C>g)try{let F=JSON.parse(p.slice(g+x.length,C));f={stage:F.stage,bugsFound:F.bugs_found??0,bugsVerified:F.bugs_verified??0,bugsRefuted:F.bugs_refuted??0}}catch{}}}let G=w.some((x)=>x.type==="assistant"||M.isRemoteReview&&x.type==="system"&&(x.subtype==="hook_progress"||x.subtype==="hook_response"));if(X.sessionStatus==="idle"&&!P&&G)A++;else A=0;let Z=A>=$,T=w.some((x)=>x.type==="system"&&(x.subtype==="hook_started"||x.subtype==="hook_progress"||x.subtype==="hook_response")&&x.hook_event==="SessionStart"),v=w.some((x)=>x.type==="assistant"),V=M.isRemoteReview&&(j!==null||!T&&Z&&v),E=M.isRemoteReview&&Date.now()-M.pollStartedAt>Y,S=D?D.subtype==="success"?"completed":"failed":V||E?"completed":w.length>0?"running":"starting",R=!1;if(A3(q,K.setAppState,(x)=>{if(x.status!=="running")return R=!0,x;if(!P&&(S==="running"||S==="starting"))return x;return{...x,status:S==="starting"?"running":S,log:w,todoList:P?fdz(w):x.todoList,reviewProgress:f??x.reviewProgress,endTime:D||V||E?Date.now():void 0}}),R)return;if(D||V||E){let x=D&&D.subtype!=="success"?"failed":"completed";if(M.isRemoteReview){let I=j??Pdz(w);if(I&&x==="completed"){Ddz(q,I,K.setAppState),Zw(q),wa(q);return}A3(q,K.setAppState,(p)=>({...p,status:"failed"}));let B=D&&D.subtype!=="success"?"remote session returned an error":E&&!V?"remote session exceeded 30 minutes":"no review output — orchestrator may have exited early";O3K(q,B,K.setAppState),Zw(q),wa(q);return}To1(q,M.title,x,K.setAppState,M.toolUseId),Zw(q),wa(q);return}}catch(J){H6(J),A=0;try{let X=K.getAppState().tasks?.[q];if(X?.isRemoteReview&&X.status==="running"&&Date.now()-X.pollStartedAt>Y){A3(q,K.setAppState,(P)=>({...P,status:"failed",endTime:Date.now()})),O3K(q,"remote session exceeded 30 minutes",K.setAppState),Zw(q),wa(q);return}}catch{}}if(_)setTimeout(H,z)};return H(),()=>{_=!1}}function Rj6(q){return MM(q,process.env.SESSION_INGRESS_URL)}var Hdz,Mdz,AL6;var PK6=y(()=>{RY();GN();q68();M5K();_8();E8();p2();i1();pC();_K();l8();Ij();J0();VM();am();Hdz=["remote-agent","ultraplan","ultrareview","autofix-pr","background-pr"];Mdz=new Map;AL6={name:"RemoteAgentTask",type:"remote_agent",async kill(q,K){let _,z,Y,$=!1;if(A3(q,K,(A)=>{if(A.status!=="running")return A;return _=A.toolUseId,z=A.description,Y=A.sessionId,$=!0,{...A,status:"killed",notified:!0,endTime:Date.now()}}),$){if(ZN(q,"stopped",{toolUseId:_,summary:z}),Y)$L6(Y).catch((A)=>N(`RemoteAgentTask archive failed: ${String(A)}`))}Zw(q),wa(q),N(`RemoteAgentTask ${q} killed, archiving session ${Y??"unknown"}`)}}});function H3K(q,K){if(!K)return q;return q.map((_)=>{if(_.type==="user")return{..._,sourceToolUseID:K};return _})}function J3K(q,K){let _=q.message.content.find((z)=>z.type==="tool_use"&&z.name===K);return _&&_.type==="tool_use"?_.id:void 0}function M3K(q){if("status"in q&&q.status==="forked")return K_.createElement(s8,{height:1},K_.createElement(k,null,K_.createElement(I1,null,["Done"])));let K=["Successfully loaded skill"];if("allowedTools"in q&&q.allowedTools&&q.allowedTools.length>0){let _=q.allowedTools.length;K.push(`${_} ${A7(_,"tool")} allowed`)}if("model"in q&&q.model)K.push(q.model);return K_.createElement(s8,{height:1},K_.createElement(k,null,K_.createElement(I1,null,K)))}function X3K({skill:q},{commands:K}){if(!q)return null;return K?.find((Y)=>Y.name===q)?.loadedFrom==="commands_DEPRECATED"?`/${q}`:q}function Bx8(q,{tools:K,verbose:_}){if(!q.length)return K_.createElement(s8,{height:1},K_.createElement(k,{dimColor:!0},Tdz));let z=_?q:q.slice(-Gdz),Y=q.length-z.length,{inProgressToolUseIDs:$}=re6(q.map((A)=>A.data));return K_.createElement(s8,null,K_.createElement(u,{flexDirection:"column"},K_.createElement(lo6,null,z.map((A)=>K_.createElement(u,{key:A.uuid,height:1,overflow:"hidden"},K_.createElement(Xb,{message:A.data.message,lookups:za,addMargin:!1,tools:K,commands:[],verbose:_,inProgressToolUseIDs:$,progressMessagesForMessage:[],shouldAnimate:!1,shouldShowDot:!1,style:"condensed",isTranscriptMode:!1,isStatic:!0})))),Y>0&&K_.createElement(k,{dimColor:!0},"+",Y," more tool ",A7(Y,"use"))))}function P3K(q,{progressMessagesForMessage:K,tools:_,verbose:z}){return K_.createElement(K_.Fragment,null,Bx8(K,{tools:_,verbose:z}),K_.createElement(FU,null))}function W3K(q,{progressMessagesForMessage:K,tools:_,verbose:z}){return K_.createElement(K_.Fragment,null,Bx8(K,{tools:_,verbose:z}),K_.createElement(Y2,{result:q,verbose:z}))}var K_,Gdz=3,Tdz="Initializing…";var D3K=y(()=>{rv();bN();oa6();QK();dE6();gK();s6();i1();K_=O6(D6(),1)});async function Eo1(q){let K=q.getAppState().mcp.commands.filter((z)=>z.type==="prompt"&&z.loadedFrom==="mcp");if(K.length===0)return u0(Fz());let _=await u0(Fz());return u2([..._,...K],"name")}async function vdz(q,K,_,z,Y,$,A){let O=Date.now(),w=wm(),j=RQ().has(K),H=f3K(q),J=q.source==="bundled",M=j||J||H?K:"custom",X={},P=q.pluginInfo?Z4(q.pluginInfo.repository).marketplace:void 0,W=z.queryTracking?.depth??0,D=Au()?.agentId;d("tengu_skill_tool_invocation",{command_name:M,_PROTO_skill_name:K,execution_context:"fork",invocation_trigger:W>0?"nested-skill":"claude-proactive",query_depth:W,...D&&{parent_agent_id:D},...X,...!1,...q.pluginInfo&&{_PROTO_plugin_name:q.pluginInfo.pluginManifest.name,...P&&{_PROTO_marketplace_name:P},plugin_name:H?q.pluginInfo.pluginManifest.name:"third-party",plugin_repository:H?q.pluginInfo.repository:"third-party",...Zj6(q.pluginInfo)}});let{modifiedGetAppState:f,baseAgent:G,promptMessages:Z,skillContent:T}=await Kx8(q,_||"",z),v=q.effort!==void 0?{...G,effort:q.effort}:G,V=[];N(`SkillTool executing forked skill ${K} with agent ${v.agentType}`);try{for await(let R of iN({agentDefinition:v,promptMessages:Z,toolUseContext:{...z,getAppState:f},canUseTool:Y,isAsync:!1,querySource:"agent:custom",model:q.model,availableTools:z.options.tools,override:{agentId:w}}))if(V.push(R),(R.type==="assistant"||R.type==="user")&&A){let x=yX([R]);for(let I of x)if(I.message.content.some((p)=>p.type==="tool_use"||p.type==="tool_result"))A({toolUseID:`skill_${$.message.id}`,data:{message:I,type:"skill_progress",prompt:T,agentId:w}})}let E=_x8(V,"Skill execution completed");V.length=0;let S=Date.now()-O;return N(`SkillTool forked skill ${K} completed in ${S}ms`),{data:{success:!0,commandName:K,status:"forked",agentId:w,result:E}}}finally{ut(w)}}function ydz(q){for(let K of Object.keys(q)){if(Ndz.has(K))continue;let _=q[K];if(_===void 0||_===null)continue;if(Array.isArray(_)&&_.length===0)continue;if(typeof _==="object"&&!Array.isArray(_)&&Object.keys(_).length===0)continue;return!1}return!0}function f3K(q){if(q.source!=="plugin"||!q.pluginInfo?.repository)return!1;return Ru(Z4(q.pluginInfo.repository).marketplace)}var kdz,Vdz,WK6,Ndz;var Fx8=y(()=>{Fu();v8();yA();Bq();_8();Fj();hP();lE6();x7();v8();RY();k8();Ou();y8();nv();rV();i1();aq();tb8();jm();i46();yO6();D3K();kdz=B6(()=>L.object({skill:L.string().describe('The skill name. E.g., "commit", "review-pr", or "pdf"'),args:L.string().optional().describe("Optional arguments for the skill")})),Vdz=B6(()=>{let q=L.object({success:L.boolean().describe("Whether the skill is valid"),commandName:L.string().describe("The name of the skill"),allowedTools:L.array(L.string()).optional().describe("Tools allowed by this skill"),model:L.string().optional().describe("Model override if specified"),status:L.literal("inline").optional().describe("Execution status")}),K=L.object({success:L.boolean().describe("Whether the skill completed successfully"),commandName:L.string().describe("The name of the skill"),status:L.literal("forked").describe("Execution status"),agentId:L.string().describe("The ID of the sub-agent that executed the skill"),result:L.string().describe("The result from the forked skill execution")});return L.union([q,K])}),WK6=sq({name:JM,searchHint:"invoke a slash-command skill",maxResultSizeChars:1e5,get inputSchema(){return kdz()},get outputSchema(){return Vdz()},description:async({skill:q})=>`Execute skill: ${q}`,prompt:async()=>fk8(Fz()),toAutoClassifierInput:({skill:q})=>q??"",async validateInput({skill:q},K){let _=q.trim();if(!_)return{result:!1,message:`Invalid skill format: ${q}`,errorCode:1};let z=_.startsWith("/");if(z)d("tengu_skill_tool_slash_prefix",{});let Y=z?_.substring(1):_,$=await Eo1(K),A=hQ(Y,$);if(!A)return{result:!1,message:`Unknown skill: ${Y}`,errorCode:2};if(A.disableModelInvocation)return{result:!1,message:`Skill ${Y} cannot be used with ${JM} tool due to disable-model-invocation`,errorCode:4};if(A.type!=="prompt")return{result:!1,message:`Skill ${Y} is not a prompt-based skill`,errorCode:5};return{result:!0}},async checkPermissions({skill:q,args:K},_){let z=q.trim(),Y=z.startsWith("/")?z.substring(1):z,A=_.getAppState().toolPermissionContext,O=await Eo1(_),w=hQ(Y,O),j=(X)=>{let P=X.startsWith("/")?X.substring(1):X;if(P===Y)return!0;if(P.endsWith(":*")){let W=P.slice(0,-2);return Y.startsWith(W)}return!1},H=sm(A,WK6,"deny");for(let[X,P]of H.entries())if(j(X))return{behavior:"deny",message:"Skill execution blocked by permission rules",decisionReason:{type:"rule",rule:P}};let J=sm(A,WK6,"allow");for(let[X,P]of J.entries())if(j(X))return{behavior:"allow",updatedInput:{skill:q,args:K},decisionReason:{type:"rule",rule:P}};if(w?.type==="prompt"&&ydz(w))return{behavior:"allow",updatedInput:{skill:q,args:K},decisionReason:void 0};let M=[{type:"addRules",rules:[{toolName:JM,ruleContent:Y}],behavior:"allow",destination:"localSettings"},{type:"addRules",rules:[{toolName:JM,ruleContent:`${Y}:*`}],behavior:"allow",destination:"localSettings"}];return{behavior:"ask",message:`Execute skill: ${Y}`,decisionReason:void 0,suggestions:M,updatedInput:{skill:q,args:K},metadata:w?{command:w}:void 0}},async call({skill:q,args:K},_,z,Y,$){let A=q.trim(),O=A.startsWith("/")?A.substring(1):A,w=await Eo1(_),j=hQ(O,w);if(sb8(O),j?.type==="prompt"&&j.context==="fork")return vdz(j,O,K,_,z,Y,$);let{processPromptSlashCommand:H}=await Promise.resolve().then(() => (qx8(),eb8)),J=await H(O,K||"",w,_);if(!J.shouldQuery)throw Error("Command processing failed");let M=J.allowedTools||[],X=J.model,P=j?.type==="prompt"?j.effort:void 0,W=RQ().has(O),D=j?.type==="prompt"&&j.source==="bundled",f=j?.type==="prompt"&&f3K(j),G=W||D||f?O:"custom",Z={},T=j?.type==="prompt"&&j.pluginInfo?Z4(j.pluginInfo.repository).marketplace:void 0,v=_.queryTracking?.depth??0,V=Au()?.agentId;d("tengu_skill_tool_invocation",{command_name:G,_PROTO_skill_name:O,execution_context:"inline",invocation_trigger:v>0?"nested-skill":"claude-proactive",query_depth:v,...V&&{parent_agent_id:V},...Z,...!1,...j?.type==="prompt"&&j.pluginInfo&&{_PROTO_plugin_name:j.pluginInfo.pluginManifest.name,...T&&{_PROTO_marketplace_name:T},plugin_name:f?j.pluginInfo.pluginManifest.name:"third-party",plugin_repository:f?j.pluginInfo.repository:"third-party",...Zj6(j.pluginInfo)}});let E=J3K(Y,JM),S=H3K(J.messages.filter((R)=>{if(R.type==="progress")return!1;if(R.type==="user"&&"message"in R){let x=R.message.content;if(typeof x==="string"&&x.includes(`<${wP}>`))return!1}return!0}),E);return N(`SkillTool returning ${S.length} newMessages for skill ${O}`),{data:{success:!0,commandName:O,allowedTools:M.length>0?M:void 0,model:X},newMessages:S,contextModifier(R){let x=R;if(M.length>0){let I=x.getAppState;x={...x,getAppState(){let B=I();return{...B,toolPermissionContext:{...B.toolPermissionContext,alwaysAllowRules:{...B.toolPermissionContext.alwaysAllowRules,command:[...new Set([...B.toolPermissionContext.alwaysAllowRules.command||[],...M])]}}}}}}if(X)x={...x,options:{...x.options,mainLoopModel:cF6(X,R.options.mainLoopModel)}};if(P!==void 0){let I=x.getAppState;x={...x,getAppState(){return{...I(),effortValue:P}}}}return x}}},mapToolResultToToolResultBlockParam(q,K){if("status"in q&&q.status==="forked")return{type:"tool_result",tool_use_id:K,content:`Skill "${q.commandName}" completed (forked execution). |
| 2495 | ${q.result}`};return{type:"tool_result",tool_use_id:K,content:`Launching skill: ${q.commandName}`}},renderToolResultMessage:M3K,renderToolUseMessage:X3K,renderToolUseProgressMessage:Bx8,renderToolUseRejectedMessage:P3K,renderToolUseErrorMessage:W3K}),Ndz=new Set(["type","progressMessage","contentLength","argNames","model","effort","source","pluginInfo","disableNonInteractive","skillRoot","context","agent","getPromptForCommand","frontmatterKeys","name","description","hasUserSpecifiedDescription","isEnabled","isHidden","aliases","isMcp","argumentHint","whenToUse","paths","version","disableModelInvocation","userInvocable","loadedFrom","immediate","userFacingName"])});import{randomUUID as Edz}from"crypto";function T3K({serverName:q,files:K}){let _=Edz();N(`LSP Diagnostics: Registering ${K.length} diagnostic file(s) from ${q} (ID: ${_})`),ja.set(_,{serverName:q,files:K,timestamp:Date.now(),attachmentSent:!1})}function G3K(q){switch(q){case"Error":return 1;case"Warning":return 2;case"Info":return 3;case"Hint":return 4;default:return 4}}function v3K(q){return g6({message:q.message,severity:q.severity,range:q.range,source:q.source||null,code:q.code||null})}function Rdz(q){let K=new Map,_=[];for(let z of q){if(!K.has(z.uri))K.set(z.uri,new Set),_.push({uri:z.uri,diagnostics:[]});let Y=K.get(z.uri),$=_.find((O)=>O.uri===z.uri),A=DK6.get(z.uri)||new Set;for(let O of z.diagnostics)try{let w=v3K(O);if(Y.has(w)||A.has(w))continue;Y.add(w),$.diagnostics.push(O)}catch(w){let j=x1(w),H=O.message?.substring(0,100)||"<no message>";H6(Error(`Failed to deduplicate diagnostic in ${z.uri}: ${j.message}. Diagnostic message: ${H}`)),$.diagnostics.push(O)}}return _.filter((z)=>z.diagnostics.length>0)}function k3K(){N(`LSP Diagnostics: Checking registry - ${ja.size} pending`);let q=[],K=new Set,_=[];for(let j of ja.values())if(!j.attachmentSent)q.push(...j.files),K.add(j.serverName),_.push(j);if(q.length===0)return[];let z;try{z=Rdz(q)}catch(j){let H=x1(j);H6(Error(`Failed to deduplicate LSP diagnostics: ${H.message}`)),z=q}for(let j of _)j.attachmentSent=!0;for(let[j,H]of ja)if(H.attachmentSent)ja.delete(j);let Y=q.reduce((j,H)=>j+H.diagnostics.length,0),$=z.reduce((j,H)=>j+H.diagnostics.length,0);if(Y>$)N(`LSP Diagnostics: Deduplication removed ${Y-$} duplicate diagnostic(s)`);let A=0,O=0;for(let j of z){if(j.diagnostics.sort((J,M)=>G3K(J.severity)-G3K(M.severity)),j.diagnostics.length>Ux8)O+=j.diagnostics.length-Ux8,j.diagnostics=j.diagnostics.slice(0,Ux8);let H=Z3K-A;if(j.diagnostics.length>H)O+=j.diagnostics.length-H,j.diagnostics=j.diagnostics.slice(0,H);A+=j.diagnostics.length}if(z=z.filter((j)=>j.diagnostics.length>0),O>0)N(`LSP Diagnostics: Volume limiting removed ${O} diagnostic(s) (max ${Ux8}/file, ${Z3K} total)`);for(let j of z){if(!DK6.has(j.uri))DK6.set(j.uri,new Set);let H=DK6.get(j.uri);for(let J of j.diagnostics)try{H.add(v3K(J))}catch(M){let X=x1(M),P=J.message?.substring(0,100)||"<no message>";H6(Error(`Failed to track delivered diagnostic in ${j.uri}: ${X.message}. Diagnostic message: ${P}`))}}let w=z.reduce((j,H)=>j+H.diagnostics.length,0);if(w===0)return N("LSP Diagnostics: No new diagnostics to deliver (all filtered by deduplication)"),[];return N(`LSP Diagnostics: Delivering ${z.length} file(s) with ${w} diagnostic(s) from ${K.size} server(s)`),[{serverName:Array.from(K).join(", "),files:z}]}function V3K(){N(`LSP Diagnostics: Clearing ${ja.size} pending diagnostic(s)`),ja.clear()}function N3K(){N(`LSP Diagnostics: Resetting all state (${ja.size} pending, ${DK6.size} files tracked)`),ja.clear(),DK6.clear()}function Qx8(q){if(DK6.has(q))N(`LSP Diagnostics: Clearing delivered diagnostics for ${q}`),DK6.delete(q)}var Ux8=10,Z3K=30,Ldz=500,ja,DK6;var OL6=y(()=>{gW6();_8();y8();E8();l8();ja=new Map,DK6=new nk({max:Ldz})});import{readFile as y3K}from"fs/promises";import{join as hdz,relative as Sdz,resolve as Lo1}from"path";function Cdz(q,K){let _=Lo1(q),z=Lo1(q,K),Y=Sdz(_,z);if(Y.startsWith("..")||Lo1(Y)===Y)return null;return z}async function v68(q,K=[]){let _={},z=hdz(q.path,".lsp.json");try{let Y=await y3K(z,"utf-8"),$=r8(Y),A=L.record(L.string(),$D6()).safeParse($);if(A.success)Object.assign(_,A.data);else{let O=`LSP config validation failed for .lsp.json in plugin ${q.name}: ${A.error.message}`;H6(Error(O)),K.push({type:"lsp-config-invalid",plugin:q.name,serverName:".lsp.json",validationError:A.error.message,source:"plugin"})}}catch(Y){if(!_7(Y)){let $=Y instanceof Error?`Failed to read/parse .lsp.json in plugin ${q.name}: ${Y.message}`:`Failed to read/parse .lsp.json file in plugin ${q.name}`;H6(x1(Y)),K.push({type:"lsp-config-invalid",plugin:q.name,serverName:".lsp.json",validationError:Y instanceof Error?`Failed to parse JSON: ${Y.message}`:"Failed to parse JSON file",source:"plugin"})}}if(q.manifest.lspServers){let Y=await bdz(q.manifest.lspServers,q.path,q.name,K);if(Y)Object.assign(_,Y)}return Object.keys(_).length>0?_:void 0}async function bdz(q,K,_,z){let Y={},$=Array.isArray(q)?q:[q];for(let A of $)if(typeof A==="string"){let O=Cdz(K,A);if(!O){let w=`Security: Path traversal attempt blocked in plugin ${_}: ${A}`;H6(Error(w)),N(w,{level:"warn"}),z.push({type:"lsp-config-invalid",plugin:_,serverName:A,validationError:"Invalid path: must be relative and within plugin directory",source:"plugin"});continue}try{let w=await y3K(O,"utf-8"),j=r8(w),H=L.record(L.string(),$D6()).safeParse(j);if(H.success)Object.assign(Y,H.data);else{let J=`LSP config validation failed for ${A} in plugin ${_}: ${H.error.message}`;H6(Error(J)),z.push({type:"lsp-config-invalid",plugin:_,serverName:A,validationError:H.error.message,source:"plugin"})}}catch(w){let j=w instanceof Error?`Failed to read/parse LSP config from ${A} in plugin ${_}: ${w.message}`:`Failed to read/parse LSP config file ${A} in plugin ${_}`;H6(x1(w)),z.push({type:"lsp-config-invalid",plugin:_,serverName:A,validationError:w instanceof Error?`Failed to parse JSON: ${w.message}`:"Failed to parse JSON file",source:"plugin"})}}else for(let[O,w]of Object.entries(A)){let j=$D6().safeParse(w);if(j.success)Y[O]=j.data;else{let H=`LSP config validation failed for inline server "${O}" in plugin ${_}: ${j.error.message}`;H6(Error(H)),z.push({type:"lsp-config-invalid",plugin:_,serverName:O,validationError:j.error.message,source:"plugin"})}}return Object.keys(Y).length>0?Y:void 0}function xdz(q,K,_,z){let Y=[],$=(w)=>{let j=dF(w,K);if(_)j=kk6(j,_);let{expanded:H,missingVars:J}=$N6(j);return Y.push(...J),H},A={...q};if(A.command)A.command=$(A.command);if(A.args)A.args=A.args.map((w)=>$(w));let O={CLAUDE_PLUGIN_ROOT:K.path,CLAUDE_PLUGIN_DATA:ei(K.source),...A.env||{}};for(let[w,j]of Object.entries(O))if(w!=="CLAUDE_PLUGIN_ROOT"&&w!=="CLAUDE_PLUGIN_DATA")O[w]=$(j);if(A.env=O,A.workspaceFolder)A.workspaceFolder=$(A.workspaceFolder);if(Y.length>0){let j=`Missing environment variables in plugin LSP config: ${[...new Set(Y)].join(", ")}`;H6(Error(j)),N(j,{level:"warn"})}return A}function Idz(q,K){let _={};for(let[z,Y]of Object.entries(q)){let $=`plugin:${K}:${z}`;_[$]={...Y,scope:"dynamic",source:K}}return _}async function E3K(q,K=[]){if(!q.enabled)return;let _=q.lspServers||await v68(q,K);if(!_)return;let z=q.manifest.userConfig?VG(Fi6(q)):void 0,Y={};for(let[$,A]of Object.entries(_))Y[$]=xdz(A,q,z,K);return Idz(Y,q.name)}var dx8=y(()=>{x7();_8();y8();E8();l8();aV();mu();BZ()});async function L3K(){let q={};try{let{enabled:K}=await ZJ(),_=await Promise.all(K.map(async(z)=>{let Y=[];try{let $=await E3K(z,Y);return{plugin:z,scopedServers:$,errors:Y}}catch($){return N(`Failed to load LSP servers for plugin ${z.name}: ${$}`,{level:"error"}),{plugin:z,scopedServers:void 0,errors:Y}}}));for(let{plugin:z,scopedServers:Y,errors:$}of _){let A=Y?Object.keys(Y).length:0;if(A>0)Object.assign(q,Y),N(`Loaded ${A} LSP server(s) from plugin: ${z.name}`);if($.length>0)N(`${$.length} error(s) loading LSP servers from plugin: ${z.name}`)}N(`Total LSP servers loaded: ${Object.keys(q).length}`)}catch(K){H6(x1(K)),N(`Error loading LSP servers: ${d6(K)}`)}return{servers:q}}var R3K=y(()=>{_8();y8();E8();dx8();bj()});var wL6=m((C3K)=>{Object.defineProperty(C3K,"__esModule",{value:!0});C3K.stringArray=C3K.array=C3K.func=C3K.error=C3K.number=C3K.string=C3K.boolean=void 0;function udz(q){return q===!0||q===!1}C3K.boolean=udz;function h3K(q){return typeof q==="string"||q instanceof String}C3K.string=h3K;function mdz(q){return typeof q==="number"||q instanceof Number}C3K.number=mdz;function pdz(q){return q instanceof Error}C3K.error=pdz;function Bdz(q){return typeof q==="function"}C3K.func=Bdz;function S3K(q){return Array.isArray(q)}C3K.array=S3K;function gdz(q){return S3K(q)&&q.every((K)=>h3K(K))}C3K.stringArray=gdz});var So1=m((_9K)=>{Object.defineProperty(_9K,"__esModule",{value:!0});_9K.Message=_9K.NotificationType9=_9K.NotificationType8=_9K.NotificationType7=_9K.NotificationType6=_9K.NotificationType5=_9K.NotificationType4=_9K.NotificationType3=_9K.NotificationType2=_9K.NotificationType1=_9K.NotificationType0=_9K.NotificationType=_9K.RequestType9=_9K.RequestType8=_9K.RequestType7=_9K.RequestType6=_9K.RequestType5=_9K.RequestType4=_9K.RequestType3=_9K.RequestType2=_9K.RequestType1=_9K.RequestType=_9K.RequestType0=_9K.AbstractMessageSignature=_9K.ParameterStructures=_9K.ResponseError=_9K.ErrorCodes=void 0;var hj6=wL6(),Ro1;(function(q){q.ParseError=-32700,q.InvalidRequest=-32600,q.MethodNotFound=-32601,q.InvalidParams=-32602,q.InternalError=-32603,q.jsonrpcReservedErrorRangeStart=-32099,q.serverErrorStart=-32099,q.MessageWriteError=-32099,q.MessageReadError=-32098,q.PendingResponseRejected=-32097,q.ConnectionInactive=-32096,q.ServerNotInitialized=-32002,q.UnknownErrorCode=-32001,q.jsonrpcReservedErrorRangeEnd=-32000,q.serverErrorEnd=-32000})(Ro1||(_9K.ErrorCodes=Ro1={}));class ho1 extends Error{constructor(q,K,_){super(K);this.code=hj6.number(q)?q:Ro1.UnknownErrorCode,this.data=_,Object.setPrototypeOf(this,ho1.prototype)}toJson(){let q={code:this.code,message:this.message};if(this.data!==void 0)q.data=this.data;return q}}_9K.ResponseError=ho1;class iG{constructor(q){this.kind=q}static is(q){return q===iG.auto||q===iG.byName||q===iG.byPosition}toString(){return this.kind}}_9K.ParameterStructures=iG;iG.auto=new iG("auto");iG.byPosition=new iG("byPosition");iG.byName=new iG("byName");class Uj{constructor(q,K){this.method=q,this.numberOfParams=K}get parameterStructures(){return iG.auto}}_9K.AbstractMessageSignature=Uj;class I3K extends Uj{constructor(q){super(q,0)}}_9K.RequestType0=I3K;class u3K extends Uj{constructor(q,K=iG.auto){super(q,1);this._parameterStructures=K}get parameterStructures(){return this._parameterStructures}}_9K.RequestType=u3K;class m3K extends Uj{constructor(q,K=iG.auto){super(q,1);this._parameterStructures=K}get parameterStructures(){return this._parameterStructures}}_9K.RequestType1=m3K;class p3K extends Uj{constructor(q){super(q,2)}}_9K.RequestType2=p3K;class B3K extends Uj{constructor(q){super(q,3)}}_9K.RequestType3=B3K;class g3K extends Uj{constructor(q){super(q,4)}}_9K.RequestType4=g3K;class F3K extends Uj{constructor(q){super(q,5)}}_9K.RequestType5=F3K;class U3K extends Uj{constructor(q){super(q,6)}}_9K.RequestType6=U3K;class Q3K extends Uj{constructor(q){super(q,7)}}_9K.RequestType7=Q3K;class d3K extends Uj{constructor(q){super(q,8)}}_9K.RequestType8=d3K;class c3K extends Uj{constructor(q){super(q,9)}}_9K.RequestType9=c3K;class l3K extends Uj{constructor(q,K=iG.auto){super(q,1);this._parameterStructures=K}get parameterStructures(){return this._parameterStructures}}_9K.NotificationType=l3K;class n3K extends Uj{constructor(q){super(q,0)}}_9K.NotificationType0=n3K;class i3K extends Uj{constructor(q,K=iG.auto){super(q,1);this._parameterStructures=K}get parameterStructures(){return this._parameterStructures}}_9K.NotificationType1=i3K;class r3K extends Uj{constructor(q){super(q,2)}}_9K.NotificationType2=r3K;class o3K extends Uj{constructor(q){super(q,3)}}_9K.NotificationType3=o3K;class a3K extends Uj{constructor(q){super(q,4)}}_9K.NotificationType4=a3K;class s3K extends Uj{constructor(q){super(q,5)}}_9K.NotificationType5=s3K;class t3K extends Uj{constructor(q){super(q,6)}}_9K.NotificationType6=t3K;class e3K extends Uj{constructor(q){super(q,7)}}_9K.NotificationType7=e3K;class q9K extends Uj{constructor(q){super(q,8)}}_9K.NotificationType8=q9K;class K9K extends Uj{constructor(q){super(q,9)}}_9K.NotificationType9=K9K;var x3K;(function(q){function K(Y){let $=Y;return $&&hj6.string($.method)&&(hj6.string($.id)||hj6.number($.id))}q.isRequest=K;function _(Y){let $=Y;return $&&hj6.string($.method)&&Y.id===void 0}q.isNotification=_;function z(Y){let $=Y;return $&&($.result!==void 0||!!$.error)&&(hj6.string($.id)||hj6.number($.id)||$.id===null)}q.isResponse=z})(x3K||(_9K.Message=x3K={}))});var bo1=m((A9K)=>{var Y9K;Object.defineProperty(A9K,"__esModule",{value:!0});A9K.LRUCache=A9K.LinkedMap=A9K.Touch=void 0;var rG;(function(q){q.None=0,q.First=1,q.AsOld=q.First,q.Last=2,q.AsNew=q.Last})(rG||(A9K.Touch=rG={}));class Co1{constructor(){this[Y9K]="LinkedMap",this._map=new Map,this._head=void 0,this._tail=void 0,this._size=0,this._state=0}clear(){this._map.clear(),this._head=void 0,this._tail=void 0,this._size=0,this._state++}isEmpty(){return!this._head&&!this._tail}get size(){return this._size}get first(){return this._head?.value}get last(){return this._tail?.value}has(q){return this._map.has(q)}get(q,K=rG.None){let _=this._map.get(q);if(!_)return;if(K!==rG.None)this.touch(_,K);return _.value}set(q,K,_=rG.None){let z=this._map.get(q);if(z){if(z.value=K,_!==rG.None)this.touch(z,_)}else{switch(z={key:q,value:K,next:void 0,previous:void 0},_){case rG.None:this.addItemLast(z);break;case rG.First:this.addItemFirst(z);break;case rG.Last:this.addItemLast(z);break;default:this.addItemLast(z);break}this._map.set(q,z),this._size++}return this}delete(q){return!!this.remove(q)}remove(q){let K=this._map.get(q);if(!K)return;return this._map.delete(q),this.removeItem(K),this._size--,K.value}shift(){if(!this._head&&!this._tail)return;if(!this._head||!this._tail)throw Error("Invalid list");let q=this._head;return this._map.delete(q.key),this.removeItem(q),this._size--,q.value}forEach(q,K){let _=this._state,z=this._head;while(z){if(K)q.bind(K)(z.value,z.key,this);else q(z.value,z.key,this);if(this._state!==_)throw Error("LinkedMap got modified during iteration.");z=z.next}}keys(){let q=this._state,K=this._head,_={[Symbol.iterator]:()=>{return _},next:()=>{if(this._state!==q)throw Error("LinkedMap got modified during iteration.");if(K){let z={value:K.key,done:!1};return K=K.next,z}else return{value:void 0,done:!0}}};return _}values(){let q=this._state,K=this._head,_={[Symbol.iterator]:()=>{return _},next:()=>{if(this._state!==q)throw Error("LinkedMap got modified during iteration.");if(K){let z={value:K.value,done:!1};return K=K.next,z}else return{value:void 0,done:!0}}};return _}entries(){let q=this._state,K=this._head,_={[Symbol.iterator]:()=>{return _},next:()=>{if(this._state!==q)throw Error("LinkedMap got modified during iteration.");if(K){let z={value:[K.key,K.value],done:!1};return K=K.next,z}else return{value:void 0,done:!0}}};return _}[(Y9K=Symbol.toStringTag,Symbol.iterator)](){return this.entries()}trimOld(q){if(q>=this.size)return;if(q===0){this.clear();return}let K=this._head,_=this.size;while(K&&_>q)this._map.delete(K.key),K=K.next,_--;if(this._head=K,this._size=_,K)K.previous=void 0;this._state++}addItemFirst(q){if(!this._head&&!this._tail)this._tail=q;else if(!this._head)throw Error("Invalid list");else q.next=this._head,this._head.previous=q;this._head=q,this._state++}addItemLast(q){if(!this._head&&!this._tail)this._head=q;else if(!this._tail)throw Error("Invalid list");else q.previous=this._tail,this._tail.next=q;this._tail=q,this._state++}removeItem(q){if(q===this._head&&q===this._tail)this._head=void 0,this._tail=void 0;else if(q===this._head){if(!q.next)throw Error("Invalid list");q.next.previous=void 0,this._head=q.next}else if(q===this._tail){if(!q.previous)throw Error("Invalid list");q.previous.next=void 0,this._tail=q.previous}else{let{next:K,previous:_}=q;if(!K||!_)throw Error("Invalid list");K.previous=_,_.next=K}q.next=void 0,q.previous=void 0,this._state++}touch(q,K){if(!this._head||!this._tail)throw Error("Invalid list");if(K!==rG.First&&K!==rG.Last)return;if(K===rG.First){if(q===this._head)return;let{next:_,previous:z}=q;if(q===this._tail)z.next=void 0,this._tail=z;else _.previous=z,z.next=_;q.previous=void 0,q.next=this._head,this._head.previous=q,this._head=q,this._state++}else if(K===rG.Last){if(q===this._tail)return;let{next:_,previous:z}=q;if(q===this._head)_.previous=void 0,this._head=_;else _.previous=z,z.next=_;q.next=void 0,q.previous=this._tail,this._tail.next=q,this._tail=q,this._state++}}toJSON(){let q=[];return this.forEach((K,_)=>{q.push([_,K])}),q}fromJSON(q){this.clear();for(let[K,_]of q)this.set(K,_)}}A9K.LinkedMap=Co1;class $9K extends Co1{constructor(q,K=1){super();this._limit=q,this._ratio=Math.min(Math.max(0,K),1)}get limit(){return this._limit}set limit(q){this._limit=q,this.checkTrim()}get ratio(){return this._ratio}set ratio(q){this._ratio=Math.min(Math.max(0,q),1),this.checkTrim()}get(q,K=rG.AsNew){return super.get(q,K)}peek(q){return super.get(q,rG.None)}set(q,K){return super.set(q,K,rG.Last),this.checkTrim(),this}checkTrim(){if(this.size>this._limit)this.trimOld(Math.round(this._limit*this._ratio))}}A9K.LRUCache=$9K});var J9K=m((j9K)=>{Object.defineProperty(j9K,"__esModule",{value:!0});j9K.Disposable=void 0;var w9K;(function(q){function K(_){return{dispose:_}}q.create=K})(w9K||(j9K.Disposable=w9K={}))});var fK6=m((M9K)=>{Object.defineProperty(M9K,"__esModule",{value:!0});var xo1;function Io1(){if(xo1===void 0)throw Error("No runtime abstraction layer installed");return xo1}(function(q){function K(_){if(_===void 0)throw Error("No runtime abstraction layer provided");xo1=_}q.install=K})(Io1||(Io1={}));M9K.default=Io1});var jL6=m((W9K)=>{Object.defineProperty(W9K,"__esModule",{value:!0});W9K.Emitter=W9K.Event=void 0;var vcz=fK6(),X9K;(function(q){let K={dispose(){}};q.None=function(){return K}})(X9K||(W9K.Event=X9K={}));class P9K{add(q,K=null,_){if(!this._callbacks)this._callbacks=[],this._contexts=[];if(this._callbacks.push(q),this._contexts.push(K),Array.isArray(_))_.push({dispose:()=>this.remove(q,K)})}remove(q,K=null){if(!this._callbacks)return;let _=!1;for(let z=0,Y=this._callbacks.length;z<Y;z++)if(this._callbacks[z]===q)if(this._contexts[z]===K){this._callbacks.splice(z,1),this._contexts.splice(z,1);return}else _=!0;if(_)throw Error("When adding a listener with a context, you should remove it with the same context")}invoke(...q){if(!this._callbacks)return[];let K=[],_=this._callbacks.slice(0),z=this._contexts.slice(0);for(let Y=0,$=_.length;Y<$;Y++)try{K.push(_[Y].apply(z[Y],q))}catch(A){(0,vcz.default)().console.error(A)}return K}isEmpty(){return!this._callbacks||this._callbacks.length===0}dispose(){this._callbacks=void 0,this._contexts=void 0}}class cx8{constructor(q){this._options=q}get event(){if(!this._event)this._event=(q,K,_)=>{if(!this._callbacks)this._callbacks=new P9K;if(this._options&&this._options.onFirstListenerAdd&&this._callbacks.isEmpty())this._options.onFirstListenerAdd(this);this._callbacks.add(q,K);let z={dispose:()=>{if(!this._callbacks)return;if(this._callbacks.remove(q,K),z.dispose=cx8._noop,this._options&&this._options.onLastListenerRemove&&this._callbacks.isEmpty())this._options.onLastListenerRemove(this)}};if(Array.isArray(_))_.push(z);return z};return this._event}fire(q){if(this._callbacks)this._callbacks.invoke.call(this._callbacks,q)}dispose(){if(this._callbacks)this._callbacks.dispose(),this._callbacks=void 0}}W9K.Emitter=cx8;cx8._noop=function(){}});var nx8=m((Z9K)=>{Object.defineProperty(Z9K,"__esModule",{value:!0});Z9K.CancellationTokenSource=Z9K.CancellationToken=void 0;var Vcz=fK6(),Ncz=wL6(),uo1=jL6(),lx8;(function(q){q.None=Object.freeze({isCancellationRequested:!1,onCancellationRequested:uo1.Event.None}),q.Cancelled=Object.freeze({isCancellationRequested:!0,onCancellationRequested:uo1.Event.None});function K(_){let z=_;return z&&(z===q.None||z===q.Cancelled||Ncz.boolean(z.isCancellationRequested)&&!!z.onCancellationRequested)}q.is=K})(lx8||(Z9K.CancellationToken=lx8={}));var ycz=Object.freeze(function(q,K){let _=(0,Vcz.default)().timer.setTimeout(q.bind(K),0);return{dispose(){_.dispose()}}});class mo1{constructor(){this._isCancelled=!1}cancel(){if(!this._isCancelled){if(this._isCancelled=!0,this._emitter)this._emitter.fire(void 0),this.dispose()}}get isCancellationRequested(){return this._isCancelled}get onCancellationRequested(){if(this._isCancelled)return ycz;if(!this._emitter)this._emitter=new uo1.Emitter;return this._emitter.event}dispose(){if(this._emitter)this._emitter.dispose(),this._emitter=void 0}}class f9K{get token(){if(!this._token)this._token=new mo1;return this._token}cancel(){if(!this._token)this._token=lx8.Cancelled;else this._token.cancel()}dispose(){if(!this._token)this._token=lx8.None;else if(this._token instanceof mo1)this._token.dispose()}}Z9K.CancellationTokenSource=f9K});var E9K=m((N9K)=>{Object.defineProperty(N9K,"__esModule",{value:!0});N9K.SharedArrayReceiverStrategy=N9K.SharedArraySenderStrategy=void 0;var Lcz=nx8(),k68;(function(q){q.Continue=0,q.Cancelled=1})(k68||(k68={}));class T9K{constructor(){this.buffers=new Map}enableCancellation(q){if(q.id===null)return;let K=new SharedArrayBuffer(4),_=new Int32Array(K,0,1);_[0]=k68.Continue,this.buffers.set(q.id,K),q.$cancellationData=K}async sendCancellation(q,K){let _=this.buffers.get(K);if(_===void 0)return;let z=new Int32Array(_,0,1);Atomics.store(z,0,k68.Cancelled)}cleanup(q){this.buffers.delete(q)}dispose(){this.buffers.clear()}}N9K.SharedArraySenderStrategy=T9K;class v9K{constructor(q){this.data=new Int32Array(q,0,1)}get isCancellationRequested(){return Atomics.load(this.data,0)===k68.Cancelled}get onCancellationRequested(){throw Error("Cancellation over SharedArrayBuffer doesn't support cancellation events")}}class k9K{constructor(q){this.token=new v9K(q)}cancel(){}dispose(){}}class V9K{constructor(){this.kind="request"}createCancellationTokenSource(q){let K=q.$cancellationData;if(K===void 0)return new Lcz.CancellationTokenSource;return new k9K(K)}}N9K.SharedArrayReceiverStrategy=V9K});var po1=m((R9K)=>{Object.defineProperty(R9K,"__esModule",{value:!0});R9K.Semaphore=void 0;var hcz=fK6();class L9K{constructor(q=1){if(q<=0)throw Error("Capacity must be greater than 0");this._capacity=q,this._active=0,this._waiting=[]}lock(q){return new Promise((K,_)=>{this._waiting.push({thunk:q,resolve:K,reject:_}),this.runNext()})}get active(){return this._active}runNext(){if(this._waiting.length===0||this._active===this._capacity)return;(0,hcz.default)().timer.setImmediate(()=>this.doRunNext())}doRunNext(){if(this._waiting.length===0||this._active===this._capacity)return;let q=this._waiting.shift();if(this._active++,this._active>this._capacity)throw Error("To many thunks active");try{let K=q.thunk();if(K instanceof Promise)K.then((_)=>{this._active--,q.resolve(_),this.runNext()},(_)=>{this._active--,q.reject(_),this.runNext()});else this._active--,q.resolve(K),this.runNext()}catch(K){this._active--,q.reject(K),this.runNext()}}}R9K.Semaphore=L9K});var I9K=m((b9K)=>{Object.defineProperty(b9K,"__esModule",{value:!0});b9K.ReadableStreamMessageReader=b9K.AbstractMessageReader=b9K.MessageReader=void 0;var go1=fK6(),HL6=wL6(),Bo1=jL6(),Scz=po1(),S9K;(function(q){function K(_){let z=_;return z&&HL6.func(z.listen)&&HL6.func(z.dispose)&&HL6.func(z.onError)&&HL6.func(z.onClose)&&HL6.func(z.onPartialMessage)}q.is=K})(S9K||(b9K.MessageReader=S9K={}));class Uo1{constructor(){this.errorEmitter=new Bo1.Emitter,this.closeEmitter=new Bo1.Emitter,this.partialMessageEmitter=new Bo1.Emitter}dispose(){this.errorEmitter.dispose(),this.closeEmitter.dispose()}get onError(){return this.errorEmitter.event}fireError(q){this.errorEmitter.fire(this.asError(q))}get onClose(){return this.closeEmitter.event}fireClose(){this.closeEmitter.fire(void 0)}get onPartialMessage(){return this.partialMessageEmitter.event}firePartialMessage(q){this.partialMessageEmitter.fire(q)}asError(q){if(q instanceof Error)return q;else return Error(`Reader received error. Reason: ${HL6.string(q.message)?q.message:"unknown"}`)}}b9K.AbstractMessageReader=Uo1;var Fo1;(function(q){function K(_){let z,Y,$,A=new Map,O,w=new Map;if(_===void 0||typeof _==="string")z=_??"utf-8";else{if(z=_.charset??"utf-8",_.contentDecoder!==void 0)$=_.contentDecoder,A.set($.name,$);if(_.contentDecoders!==void 0)for(let j of _.contentDecoders)A.set(j.name,j);if(_.contentTypeDecoder!==void 0)O=_.contentTypeDecoder,w.set(O.name,O);if(_.contentTypeDecoders!==void 0)for(let j of _.contentTypeDecoders)w.set(j.name,j)}if(O===void 0)O=(0,go1.default)().applicationJson.decoder,w.set(O.name,O);return{charset:z,contentDecoder:$,contentDecoders:A,contentTypeDecoder:O,contentTypeDecoders:w}}q.fromOptions=K})(Fo1||(Fo1={}));class C9K extends Uo1{constructor(q,K){super();this.readable=q,this.options=Fo1.fromOptions(K),this.buffer=(0,go1.default)().messageBuffer.create(this.options.charset),this._partialMessageTimeout=1e4,this.nextMessageLength=-1,this.messageToken=0,this.readSemaphore=new Scz.Semaphore(1)}set partialMessageTimeout(q){this._partialMessageTimeout=q}get partialMessageTimeout(){return this._partialMessageTimeout}listen(q){this.nextMessageLength=-1,this.messageToken=0,this.partialMessageTimer=void 0,this.callback=q;let K=this.readable.onData((_)=>{this.onData(_)});return this.readable.onError((_)=>this.fireError(_)),this.readable.onClose(()=>this.fireClose()),K}onData(q){try{this.buffer.append(q);while(!0){if(this.nextMessageLength===-1){let _=this.buffer.tryReadHeaders(!0);if(!_)return;let z=_.get("content-length");if(!z){this.fireError(Error(`Header must provide a Content-Length property. |