import{l as n,d as k,r as f,e as u,u as g,o as r,f as v,s as o,n as p,g as F,h as O,i as Bt,j as I,k as pt,p as ht,m as Vt,q as Gt,t as mt,v as Yt,w as ye,x as qe,y as ot,M as ge,z as Zt,A as Xt,B as nt}from"./entry-DGV85QaO.js";import"./_virtual_mf___mfe_internal__com_mf_3_picsart_mf_3_idea_mf_2_to_mf_2_3d__mf_owner__258085600416845__loadShare__shared-k02NdQm7.js";import"./vite-preload-helper-BXl3LOEh.js";import"./pluggableService-DuCRy89Q.js";import"./_commonjsHelpers-DaWZu8wl.js";async function es({host:i,agent:e,capturedThreadId:t}){const s=e.threadId||"default",a=t||"default";return s===a?i.runAgent({agent:e}):(console.warn(`[MCPAppsRenderer] ui/message follow-up dropped: the thread changed (${a} → ${s}) between enqueue and execution, so running it would leak into the now-foreground thread.`),{result:void 0,newMessages:[]})}function ts(i){const e="'self' 'wasm-unsafe-eval' 'unsafe-inline' 'unsafe-eval' blob: data: http://localhost:* https://localhost:*",t="* blob: data: http://localhost:* https://localhost:*",s=i?.length?" "+i.join(" "):"";return`<!doctype html>
<html>
<head>
<meta charset="utf-8" />
<meta http-equiv="Content-Security-Policy" content="default-src 'self'; img-src * data: blob: 'unsafe-inline'; media-src * blob: data:; font-src * blob: data:; script-src ${e+s}; style-src * blob: data: 'unsafe-inline'; connect-src *; frame-src ${t+s}; base-uri 'self';" />
<style>html,body{margin:0;padding:0;height:100%;width:100%;overflow:hidden}*{box-sizing:border-box}iframe{background-color:transparent;border:none;padding:0;overflow:hidden;width:100%;height:100%}</style>
</head>
<body>
<script>
if(window.self===window.top){throw new Error("This file must be used in an iframe.")}
const inner=document.createElement("iframe");
inner.style="width:100%;height:100%;border:none;";
inner.setAttribute("sandbox","allow-scripts allow-same-origin allow-forms");
document.body.appendChild(inner);
window.addEventListener("message",async(event)=>{
if(event.source===window.parent){
if(event.data&&event.data.method==="ui/notifications/sandbox-resource-ready"){
const{html,sandbox}=event.data.params;
if(typeof sandbox==="string")inner.setAttribute("sandbox",sandbox);
if(typeof html==="string")inner.srcdoc=html;
}else if(inner&&inner.contentWindow){
inner.contentWindow.postMessage(event.data,"*");
}
}else if(event.source===inner.contentWindow){
window.parent.postMessage(event.data,"*");
}
});
window.parent.postMessage({jsonrpc:"2.0",method:"ui/notifications/sandbox-proxy-ready",params:{}},"*");
<\/script>
</body>
</html>`}const ft=3e4;var gt=class extends Error{constructor(i,e){super(`[CopilotKit] MCP app request dropped: the agent moved from thread "${i}" to "${e}" while it was queued.`),this.originThreadId=i,this.currentThreadId=e,this.name="MCPAppsQueueThreadChangedError"}};const at=new WeakMap;let ss=0;function os(i){let e=at.get(i);return e||(e=`agent-${ss++}`,at.set(i,e)),`${e}::${i.threadId||"default"}`}var ns=class{constructor(){this.queues=new Map,this.processing=new Map}async enqueue(i,e,t){const s=os(i);return new Promise((a,l)=>{let c=this.queues.get(s);c||(c=[],this.queues.set(s,c)),c.push({execute:e,cancelRunningWait:t?.cancelRunningWait,resolve:a,reject:l,owner:t?.owner,timeoutMs:t?.timeoutMs??ft,controller:new AbortController,originThreadId:i.threadId||"default",dropAfterThreadSwitch:t?.dropAfterThreadSwitch}),this.processQueue(s,i)})}cancelOwner(i){for(const e of this.queues.values())for(const t of e)t.owner!==i||t.executing&&!t.cancelRunningWait||t.cancelled||(t.cancelled=!0,t.controller.abort(),t.reject(new Error("[CopilotKit] MCP app request cancelled on teardown")))}async processQueue(i,e){if(!this.processing.get(i)){this.processing.set(i,!0);try{const t=this.queues.get(i);if(!t)return;for(;t.length>0;){const s=t[0];if(s.cancelled){t.shift();continue}try{if(await this.waitForAgentIdle(e,s.timeoutMs,s.controller.signal),s.cancelled){t.shift();continue}const a=e.threadId||"default";if(s.dropAfterThreadSwitch&&a!==s.originThreadId){s.reject(new gt(s.originThreadId,a)),t.shift();continue}s.executing=!0;const l=s.execute(s.controller.signal),c=s.cancelRunningWait?await as(l,s.controller.signal):await l;s.resolve(c)}catch(a){s.reject(a instanceof Error?a:new Error(String(a)))}t.shift()}}finally{const t=this.queues.get(i);!t||t.length===0?(this.queues.delete(i),this.processing.delete(i)):this.processing.set(i,!1)}}}waitForAgentIdle(i,e,t){return new Promise((s,a)=>{if(!i.isRunning){s();return}if(t?.aborted){a(new Error("[CopilotKit] MCP app request cancelled on teardown"));return}let l=!1;const c=_=>{l||(l=!0,clearTimeout(A),clearInterval(S),x.unsubscribe(),t?.removeEventListener("abort",d),_())},d=()=>c(()=>a(new Error("[CopilotKit] MCP app request cancelled on teardown")));t?.addEventListener("abort",d);const y=()=>c(s),x=i.subscribe({onRunFinalized:y,onRunFailed:y}),S=setInterval(()=>{i.isRunning||y()},500),A=setTimeout(()=>{c(()=>a(new Error("[CopilotKit] Timed out waiting for agent to become idle")))},e)})}};const be=new ns;function as(i,e){return new Promise((t,s)=>{const a=()=>s(new Error("[CopilotKit] MCP app request cancelled on teardown"));e.addEventListener("abort",a,{once:!0}),i.then(t,s).finally(()=>e.removeEventListener("abort",a)),e.aborted&&a()})}const Z="io.modelcontextprotocol/related-task",ke="2.0",P=Bt(i=>i!==null&&(typeof i=="object"||typeof i=="function")),bt=g([o(),p().int()]),wt=o();O({ttl:p().optional(),pollInterval:p().optional()});const rs=r({ttl:p().optional()}),is=r({taskId:o()}),Ce=O({progressToken:bt.optional(),[Z]:is.optional()}),$=r({_meta:Ce.optional()}),ie=$.extend({task:rs.optional()}),ls=i=>ie.safeParse(i).success,M=r({method:o(),params:$.loose().optional()}),j=r({_meta:Ce.optional()}),W=r({method:o(),params:j.loose().optional()}),E=O({_meta:Ce.optional()}),le=g([o(),p().int()]),yt=r({jsonrpc:n(ke),id:le,...M.shape}).strict(),rt=i=>yt.safeParse(i).success,St=r({jsonrpc:n(ke),...W.shape}).strict(),cs=i=>St.safeParse(i).success,Ie=r({jsonrpc:n(ke),id:le,result:E}).strict(),we=i=>Ie.safeParse(i).success;var w;(function(i){i[i.ConnectionClosed=-32e3]="ConnectionClosed",i[i.RequestTimeout=-32001]="RequestTimeout",i[i.ParseError=-32700]="ParseError",i[i.InvalidRequest=-32600]="InvalidRequest",i[i.MethodNotFound=-32601]="MethodNotFound",i[i.InvalidParams=-32602]="InvalidParams",i[i.InternalError=-32603]="InternalError",i[i.UrlElicitationRequired=-32042]="UrlElicitationRequired"})(w||(w={}));const Pe=r({jsonrpc:n(ke),id:le.optional(),error:r({code:p().int(),message:o(),data:v().optional()})}).strict(),ds=i=>Pe.safeParse(i).success,us=g([yt,St,Ie,Pe]);g([Ie,Pe]);const _t=E.strict(),ps=j.extend({requestId:le.optional(),reason:o().optional()}),Me=W.extend({method:n("notifications/cancelled"),params:ps}),hs=r({src:o(),mimeType:o().optional(),sizes:u(o()).optional(),theme:F(["light","dark"]).optional()}),ce=r({icons:u(hs).optional()}),te=r({name:o(),title:o().optional()}),Re=te.extend({...te.shape,...ce.shape,version:o(),websiteUrl:o().optional(),description:o().optional()}),ms=pt(r({applyDefaults:k().optional()}),f(o(),v())),fs=ht(i=>i&&typeof i=="object"&&!Array.isArray(i)&&Object.keys(i).length===0?{form:{}}:i,pt(r({form:ms.optional(),url:P.optional()}),f(o(),v()).optional())),gs=O({list:P.optional(),cancel:P.optional(),requests:O({sampling:O({createMessage:P.optional()}).optional(),elicitation:O({create:P.optional()}).optional()}).optional()}),bs=O({list:P.optional(),cancel:P.optional(),requests:O({tools:O({call:P.optional()}).optional()}).optional()}),ws=r({experimental:f(o(),P).optional(),sampling:r({context:P.optional(),tools:P.optional()}).optional(),elicitation:fs.optional(),roots:r({listChanged:k().optional()}).optional(),tasks:gs.optional(),extensions:f(o(),P).optional()}),ys=$.extend({protocolVersion:o(),capabilities:ws,clientInfo:Re}),Ss=M.extend({method:n("initialize"),params:ys}),_s=r({experimental:f(o(),P).optional(),logging:P.optional(),completions:P.optional(),prompts:r({listChanged:k().optional()}).optional(),resources:r({subscribe:k().optional(),listChanged:k().optional()}).optional(),tools:r({listChanged:k().optional()}).optional(),tasks:bs.optional(),extensions:f(o(),P).optional()}),ks=E.extend({protocolVersion:o(),capabilities:_s,serverInfo:Re,instructions:o().optional()}),Rs=W.extend({method:n("notifications/initialized"),params:j.optional()}),ve=M.extend({method:n("ping"),params:$.optional()}),vs=r({progress:p(),total:I(p()),message:I(o())}),Ts=r({...j.shape,...vs.shape,progressToken:bt}),Ee=W.extend({method:n("notifications/progress"),params:Ts}),xs=$.extend({cursor:wt.optional()}),de=M.extend({params:xs.optional()}),ue=E.extend({nextCursor:wt.optional()}),qs=F(["working","input_required","completed","failed","cancelled"]),pe=r({taskId:o(),status:qs,ttl:g([p(),Vt()]),createdAt:o(),lastUpdatedAt:o(),pollInterval:I(p()),statusMessage:I(o())}),He=E.extend({task:pe}),Cs=j.merge(pe),Se=W.extend({method:n("notifications/tasks/status"),params:Cs}),Ae=M.extend({method:n("tasks/get"),params:$.extend({taskId:o()})}),Ne=E.merge(pe),Le=M.extend({method:n("tasks/result"),params:$.extend({taskId:o()})});E.loose();const Ue=de.extend({method:n("tasks/list")}),ze=ue.extend({tasks:u(pe)}),Oe=M.extend({method:n("tasks/cancel"),params:$.extend({taskId:o()})}),Is=E.merge(pe),kt=r({uri:o(),mimeType:I(o()),_meta:f(o(),v()).optional()}),Rt=kt.extend({text:o()}),$e=o().refine(i=>{try{return atob(i),!0}catch{return!1}},{message:"Invalid Base64 string"}),vt=kt.extend({blob:$e}),he=F(["user","assistant"]),se=r({audience:u(he).optional(),priority:p().min(0).max(1).optional(),lastModified:Gt({offset:!0}).optional()}),Tt=r({...te.shape,...ce.shape,uri:o(),description:I(o()),mimeType:I(o()),size:I(p()),annotations:se.optional(),_meta:I(O({}))}),Ps=r({...te.shape,...ce.shape,uriTemplate:o(),description:I(o()),mimeType:I(o()),annotations:se.optional(),_meta:I(O({}))}),xt=de.extend({method:n("resources/list")}),qt=ue.extend({resources:u(Tt)}),Ct=de.extend({method:n("resources/templates/list")}),It=ue.extend({resourceTemplates:u(Ps)}),De=$.extend({uri:o()}),Ms=De,Pt=M.extend({method:n("resources/read"),params:Ms}),Mt=E.extend({contents:u(g([Rt,vt]))}),Et=W.extend({method:n("notifications/resources/list_changed"),params:j.optional()}),Es=De,Hs=M.extend({method:n("resources/subscribe"),params:Es}),As=De,Ns=M.extend({method:n("resources/unsubscribe"),params:As}),Ls=j.extend({uri:o()}),Us=W.extend({method:n("notifications/resources/updated"),params:Ls}),zs=r({name:o(),description:I(o()),required:I(k())}),Os=r({...te.shape,...ce.shape,description:I(o()),arguments:I(u(zs)),_meta:I(O({}))}),Ht=de.extend({method:n("prompts/list")}),At=ue.extend({prompts:u(Os)}),$s=$.extend({name:o(),arguments:f(o(),o()).optional()}),Ds=M.extend({method:n("prompts/get"),params:$s}),Fe=r({type:n("text"),text:o(),annotations:se.optional(),_meta:f(o(),v()).optional()}),je=r({type:n("image"),data:$e,mimeType:o(),annotations:se.optional(),_meta:f(o(),v()).optional()}),We=r({type:n("audio"),data:$e,mimeType:o(),annotations:se.optional(),_meta:f(o(),v()).optional()}),Fs=r({type:n("tool_use"),name:o(),id:o(),input:f(o(),v()),_meta:f(o(),v()).optional()}),Nt=r({type:n("resource"),resource:g([Rt,vt]),annotations:se.optional(),_meta:f(o(),v()).optional()}),Lt=Tt.extend({type:n("resource_link")}),me=g([Fe,je,We,Lt,Nt]),js=r({role:he,content:me}),Ws=E.extend({description:o().optional(),messages:u(js)}),Ut=W.extend({method:n("notifications/prompts/list_changed"),params:j.optional()}),Qs=r({title:o().optional(),readOnlyHint:k().optional(),destructiveHint:k().optional(),idempotentHint:k().optional(),openWorldHint:k().optional()}),Ks=r({taskSupport:F(["required","optional","forbidden"]).optional()}),Qe=r({...te.shape,...ce.shape,description:o().optional(),inputSchema:r({type:n("object"),properties:f(o(),P).optional(),required:u(o()).optional()}).catchall(v()),outputSchema:r({type:n("object"),properties:f(o(),P).optional(),required:u(o()).optional()}).catchall(v()).optional(),annotations:Qs.optional(),execution:Ks.optional(),_meta:f(o(),v()).optional()}),Js=de.extend({method:n("tools/list")}),zt=ue.extend({tools:u(Qe)}),ae=E.extend({content:u(me).default([]),structuredContent:f(o(),v()).optional(),isError:k().optional()});ae.or(E.extend({toolResult:v()}));const Bs=ie.extend({name:o(),arguments:f(o(),v()).optional()}),Ot=M.extend({method:n("tools/call"),params:Bs}),$t=W.extend({method:n("notifications/tools/list_changed"),params:j.optional()});r({autoRefresh:k().default(!0),debounceMs:p().int().nonnegative().default(300)});const Dt=F(["debug","info","notice","warning","error","critical","alert","emergency"]),Vs=$.extend({level:Dt}),Gs=M.extend({method:n("logging/setLevel"),params:Vs}),Ys=j.extend({level:Dt,logger:o().optional(),data:v()}),Ft=W.extend({method:n("notifications/message"),params:Ys}),Zs=r({name:o().optional()}),Xs=r({hints:u(Zs).optional(),costPriority:p().min(0).max(1).optional(),speedPriority:p().min(0).max(1).optional(),intelligencePriority:p().min(0).max(1).optional()}),eo=r({mode:F(["auto","required","none"]).optional()}),to=r({type:n("tool_result"),toolUseId:o().describe("The unique identifier for the corresponding tool call."),content:u(me).default([]),structuredContent:r({}).loose().optional(),isError:k().optional(),_meta:f(o(),v()).optional()}),so=mt("type",[Fe,je,We]),_e=mt("type",[Fe,je,We,Fs,to]),oo=r({role:he,content:g([_e,u(_e)]),_meta:f(o(),v()).optional()}),no=ie.extend({messages:u(oo),modelPreferences:Xs.optional(),systemPrompt:o().optional(),includeContext:F(["none","thisServer","allServers"]).optional(),temperature:p().optional(),maxTokens:p().int(),stopSequences:u(o()).optional(),metadata:P.optional(),tools:u(Qe).optional(),toolChoice:eo.optional()}),jt=M.extend({method:n("sampling/createMessage"),params:no}),ao=E.extend({model:o(),stopReason:I(F(["endTurn","stopSequence","maxTokens"]).or(o())),role:he,content:so}),ro=E.extend({model:o(),stopReason:I(F(["endTurn","stopSequence","maxTokens","toolUse"]).or(o())),role:he,content:g([_e,u(_e)])}),io=r({type:n("boolean"),title:o().optional(),description:o().optional(),default:k().optional()}),lo=r({type:n("string"),title:o().optional(),description:o().optional(),minLength:p().optional(),maxLength:p().optional(),format:F(["email","uri","date","date-time"]).optional(),default:o().optional()}),co=r({type:F(["number","integer"]),title:o().optional(),description:o().optional(),minimum:p().optional(),maximum:p().optional(),default:p().optional()}),uo=r({type:n("string"),title:o().optional(),description:o().optional(),enum:u(o()),default:o().optional()}),po=r({type:n("string"),title:o().optional(),description:o().optional(),oneOf:u(r({const:o(),title:o()})),default:o().optional()}),ho=r({type:n("string"),title:o().optional(),description:o().optional(),enum:u(o()),enumNames:u(o()).optional(),default:o().optional()}),mo=g([uo,po]),fo=r({type:n("array"),title:o().optional(),description:o().optional(),minItems:p().optional(),maxItems:p().optional(),items:r({type:n("string"),enum:u(o())}),default:u(o()).optional()}),go=r({type:n("array"),title:o().optional(),description:o().optional(),minItems:p().optional(),maxItems:p().optional(),items:r({anyOf:u(r({const:o(),title:o()}))}),default:u(o()).optional()}),bo=g([fo,go]),wo=g([ho,mo,bo]),yo=g([wo,io,lo,co]),So=ie.extend({mode:n("form").optional(),message:o(),requestedSchema:r({type:n("object"),properties:f(o(),yo),required:u(o()).optional()})}),_o=ie.extend({mode:n("url"),message:o(),elicitationId:o(),url:o().url()}),ko=g([So,_o]),Ro=M.extend({method:n("elicitation/create"),params:ko}),vo=j.extend({elicitationId:o()}),To=W.extend({method:n("notifications/elicitation/complete"),params:vo}),xo=E.extend({action:F(["accept","decline","cancel"]),content:ht(i=>i===null?void 0:i,f(o(),g([o(),p(),k(),u(o())])).optional())}),qo=r({type:n("ref/resource"),uri:o()}),Co=r({type:n("ref/prompt"),name:o()}),Io=$.extend({ref:g([Co,qo]),argument:r({name:o(),value:o()}),context:r({arguments:f(o(),o()).optional()}).optional()}),Po=M.extend({method:n("completion/complete"),params:Io}),Mo=E.extend({completion:O({values:u(o()).max(100),total:I(p().int()),hasMore:I(k())})}),Eo=r({uri:o().startsWith("file://"),name:o().optional(),_meta:f(o(),v()).optional()}),Ho=M.extend({method:n("roots/list"),params:$.optional()}),Ao=E.extend({roots:u(Eo)}),No=W.extend({method:n("notifications/roots/list_changed"),params:j.optional()});g([ve,Ss,Po,Gs,Ds,Ht,xt,Ct,Pt,Hs,Ns,Ot,Js,Ae,Le,Ue,Oe]);g([Me,Ee,Rs,No,Se]);g([_t,ao,ro,xo,Ao,Ne,ze,He]);g([ve,jt,Ro,Ho,Ae,Le,Ue,Oe]);g([Me,Ee,Ft,Us,Et,$t,Ut,Se,To]);g([_t,ks,Mo,Ws,At,qt,It,Mt,ae,zt,Ne,ze,He]);class m extends Error{constructor(e,t,s){super(`MCP error ${e}: ${t}`),this.code=e,this.data=s,this.name="McpError"}static fromError(e,t,s){if(e===w.UrlElicitationRequired&&s){const a=s;if(a.elicitations)return new Lo(a.elicitations,t)}return new m(e,t,s)}}class Lo extends m{constructor(e,t=`URL elicitation${e.length>1?"s":""} required`){super(w.UrlElicitationRequired,t,{elicitations:e})}get elicitations(){return this.data?.elicitations??[]}}function Ke(i){return!!i._zod}function Wt(i,e){return Ke(i)?Yt(i,e):i.safeParse(e)}function Uo(i){if(!i)return;let e;if(Ke(i)?e=i._zod?.def?.shape:e=i.shape,!!e){if(typeof e=="function")try{return e()}catch{return}return e}}function zo(i){if(Ke(i)){const l=i._zod?.def;if(l){if(l.value!==void 0)return l.value;if(Array.isArray(l.values)&&l.values.length>0)return l.values[0]}}const t=i._def;if(t){if(t.value!==void 0)return t.value;if(Array.isArray(t.values)&&t.values.length>0)return t.values[0]}const s=i.value;if(s!==void 0)return s}function Y(i){return i==="completed"||i==="failed"||i==="cancelled"}function it(i){const t=Uo(i)?.method;if(!t)throw new Error("Schema is missing a method literal");const s=zo(t);if(typeof s!="string")throw new Error("Schema method literal must be a string");return s}function lt(i,e){const t=Wt(i,e);if(!t.success)throw t.error;return t.data}const Oo=6e4;class $o{constructor(e){this._options=e,this._requestMessageId=0,this._requestHandlers=new Map,this._requestHandlerAbortControllers=new Map,this._notificationHandlers=new Map,this._responseHandlers=new Map,this._progressHandlers=new Map,this._timeoutInfo=new Map,this._pendingDebouncedNotifications=new Set,this._taskProgressTokens=new Map,this._requestResolvers=new Map,this.setNotificationHandler(Me,t=>{this._oncancel(t)}),this.setNotificationHandler(Ee,t=>{this._onprogress(t)}),this.setRequestHandler(ve,t=>({})),this._taskStore=e?.taskStore,this._taskMessageQueue=e?.taskMessageQueue,this._taskStore&&(this.setRequestHandler(Ae,async(t,s)=>{const a=await this._taskStore.getTask(t.params.taskId,s.sessionId);if(!a)throw new m(w.InvalidParams,"Failed to retrieve task: Task not found");return{...a}}),this.setRequestHandler(Le,async(t,s)=>{const a=async()=>{const l=t.params.taskId;if(!await this._taskStore.getTask(l,s.sessionId))throw new m(w.InvalidParams,`Task not found: ${l}`);if(this._taskMessageQueue){let d;for(;d=await this._taskMessageQueue.dequeue(l,s.sessionId);){if(d.type==="response"||d.type==="error"){const y=d.message,x=y.id,S=this._requestResolvers.get(x);if(S)if(this._requestResolvers.delete(x),d.type==="response")S(y);else{const A=y,_=new m(A.error.code,A.error.message,A.error.data);S(_)}else{const A=d.type==="response"?"Response":"Error";this._onerror(new Error(`${A} handler missing for request ${x}`))}continue}await this._transport?.send(d.message,{relatedRequestId:s.requestId})}}const c=await this._taskStore.getTask(l,s.sessionId);if(!c)throw new m(w.InvalidParams,`Task not found: ${l}`);if(!Y(c.status))return await this._waitForTaskUpdate(l,s.signal,s.sessionId),await a();if(Y(c.status)){const d=await this._taskStore.getTaskResult(l,s.sessionId);return this._clearTaskQueue(l,s.sessionId),{...d,_meta:{...d._meta,[Z]:{taskId:l}}}}return await a()};return await a()}),this.setRequestHandler(Ue,async(t,s)=>{try{const{tasks:a,nextCursor:l}=await this._taskStore.listTasks(t.params?.cursor,s.sessionId);return{tasks:a,nextCursor:l,_meta:{}}}catch(a){throw new m(w.InvalidParams,`Failed to list tasks: ${a instanceof Error?a.message:String(a)}`)}}),this.setRequestHandler(Oe,async(t,s)=>{try{const a=await this._taskStore.getTask(t.params.taskId,s.sessionId);if(!a)throw new m(w.InvalidParams,`Task not found: ${t.params.taskId}`);if(Y(a.status))throw new m(w.InvalidParams,`Cannot cancel task in terminal status: ${a.status}`);await this._taskStore.updateTaskStatus(t.params.taskId,"cancelled","Client cancelled task execution.",s.sessionId),this._clearTaskQueue(t.params.taskId,s.sessionId);const l=await this._taskStore.getTask(t.params.taskId,s.sessionId);if(!l)throw new m(w.InvalidParams,`Task not found after cancellation: ${t.params.taskId}`);return{_meta:{},...l}}catch(a){throw a instanceof m?a:new m(w.InvalidRequest,`Failed to cancel task: ${a instanceof Error?a.message:String(a)}`)}}))}async _oncancel(e){if(!e.params.requestId)return;this._requestHandlerAbortControllers.get(e.params.requestId)?.abort(e.params.reason)}_setupTimeout(e,t,s,a,l=!1){this._timeoutInfo.set(e,{timeoutId:setTimeout(a,t),startTime:Date.now(),timeout:t,maxTotalTimeout:s,resetTimeoutOnProgress:l,onTimeout:a})}_resetTimeout(e){const t=this._timeoutInfo.get(e);if(!t)return!1;const s=Date.now()-t.startTime;if(t.maxTotalTimeout&&s>=t.maxTotalTimeout)throw this._timeoutInfo.delete(e),m.fromError(w.RequestTimeout,"Maximum total timeout exceeded",{maxTotalTimeout:t.maxTotalTimeout,totalElapsed:s});return clearTimeout(t.timeoutId),t.timeoutId=setTimeout(t.onTimeout,t.timeout),!0}_cleanupTimeout(e){const t=this._timeoutInfo.get(e);t&&(clearTimeout(t.timeoutId),this._timeoutInfo.delete(e))}async connect(e){if(this._transport)throw new Error("Already connected to a transport. Call close() before connecting to a new transport, or use a separate Protocol instance per connection.");this._transport=e;const t=this.transport?.onclose;this._transport.onclose=()=>{t?.(),this._onclose()};const s=this.transport?.onerror;this._transport.onerror=l=>{s?.(l),this._onerror(l)};const a=this._transport?.onmessage;this._transport.onmessage=(l,c)=>{a?.(l,c),we(l)||ds(l)?this._onresponse(l):rt(l)?this._onrequest(l,c):cs(l)?this._onnotification(l):this._onerror(new Error(`Unknown message type: ${JSON.stringify(l)}`))},await this._transport.start()}_onclose(){const e=this._responseHandlers;this._responseHandlers=new Map,this._progressHandlers.clear(),this._taskProgressTokens.clear(),this._pendingDebouncedNotifications.clear();for(const s of this._timeoutInfo.values())clearTimeout(s.timeoutId);this._timeoutInfo.clear();for(const s of this._requestHandlerAbortControllers.values())s.abort();this._requestHandlerAbortControllers.clear();const t=m.fromError(w.ConnectionClosed,"Connection closed");this._transport=void 0,this.onclose?.();for(const s of e.values())s(t)}_onerror(e){this.onerror?.(e)}_onnotification(e){const t=this._notificationHandlers.get(e.method)??this.fallbackNotificationHandler;t!==void 0&&Promise.resolve().then(()=>t(e)).catch(s=>this._onerror(new Error(`Uncaught error in notification handler: ${s}`)))}_onrequest(e,t){const s=this._requestHandlers.get(e.method)??this.fallbackRequestHandler,a=this._transport,l=e.params?._meta?.[Z]?.taskId,c=a?.sessionId,d=this._taskStore;let y=!0,x;if(l&&d&&this._taskMessageQueue&&c!==void 0&&(y=!1,x=(async()=>{if(!await d.getTask(l,c))throw new m(w.InvalidParams,`Task not found: ${l}`);y=!0})()),s===void 0){const R={jsonrpc:"2.0",id:e.id,error:{code:w.MethodNotFound,message:"Method not found"}};if(l&&x){const h={type:"error",message:R,timestamp:Date.now()};x.then(()=>this._enqueueTaskMessage(l,h,c),()=>a?.send(R)).catch(D=>this._onerror(new Error(`Failed to send an error response: ${D}`)))}else l&&this._taskMessageQueue?this._enqueueTaskMessage(l,{type:"error",message:R,timestamp:Date.now()},a?.sessionId).catch(h=>this._onerror(new Error(`Failed to enqueue error response: ${h}`))):a?.send(R).catch(h=>this._onerror(new Error(`Failed to send an error response: ${h}`)));return}const S=new AbortController;this._requestHandlerAbortControllers.set(e.id,S);const A=ls(e.params)?e.params.task:void 0,_=this._taskStore?this.requestTaskStore(e,a?.sessionId):void 0,q={signal:S.signal,sessionId:a?.sessionId,_meta:e.params?._meta,sendNotification:async R=>{if(S.signal.aborted)return;const h={relatedRequestId:e.id};l&&(h.relatedTask={taskId:l}),await this.notification(R,h)},sendRequest:async(R,h,D)=>{if(S.signal.aborted)throw new m(w.ConnectionClosed,"Request was cancelled");const U={...D,relatedRequestId:e.id};l&&!U.relatedTask&&(U.relatedTask={taskId:l});const T=U.relatedTask?.taskId??l;return T&&_&&await _.updateTaskStatus(T,"input_required"),await this.request(R,h,U)},authInfo:t?.authInfo,requestId:e.id,requestInfo:t?.requestInfo,taskId:l,taskStore:_,taskRequestedTtl:A?.ttl,closeSSEStream:t?.closeSSEStream,closeStandaloneSSEStream:t?.closeStandaloneSSEStream};(x??Promise.resolve()).then(()=>{if(x&&S.signal.aborted)throw new m(w.ConnectionClosed,"Request was cancelled");A&&this.assertTaskHandlerCapability(e.method)}).then(()=>s(e,q)).then(async R=>{if(S.signal.aborted)return;const h={result:R,jsonrpc:"2.0",id:e.id};l&&this._taskMessageQueue?await this._enqueueTaskMessage(l,{type:"response",message:h,timestamp:Date.now()},a?.sessionId):await a?.send(h)},async R=>{if(S.signal.aborted)return;const h={jsonrpc:"2.0",id:e.id,error:{code:Number.isSafeInteger(R.code)?R.code:w.InternalError,message:R.message??"Internal error",...R.data!==void 0&&{data:R.data}}};l&&this._taskMessageQueue&&y?await this._enqueueTaskMessage(l,{type:"error",message:h,timestamp:Date.now()},a?.sessionId):await a?.send(h)}).catch(R=>this._onerror(new Error(`Failed to send response: ${R}`))).finally(()=>{this._requestHandlerAbortControllers.get(e.id)===S&&this._requestHandlerAbortControllers.delete(e.id)})}_onprogress(e){const{progressToken:t,...s}=e.params,a=Number(t),l=this._progressHandlers.get(a);if(!l){this._onerror(new Error(`Received a progress notification for an unknown token: ${JSON.stringify(e)}`));return}const c=this._responseHandlers.get(a),d=this._timeoutInfo.get(a);if(d&&c&&d.resetTimeoutOnProgress)try{this._resetTimeout(a)}catch(y){this._responseHandlers.delete(a),this._progressHandlers.delete(a),this._cleanupTimeout(a),c(y);return}l(s)}_onresponse(e){const t=Number(e.id),s=this._requestResolvers.get(t);if(s){if(this._requestResolvers.delete(t),we(e))s(e);else{const c=new m(e.error.code,e.error.message,e.error.data);s(c)}return}const a=this._responseHandlers.get(t);if(a===void 0){this._onerror(new Error(`Received a response for an unknown message ID: ${JSON.stringify(e)}`));return}this._responseHandlers.delete(t),this._cleanupTimeout(t);let l=!1;if(we(e)&&e.result&&typeof e.result=="object"){const c=e.result;if(c.task&&typeof c.task=="object"){const d=c.task;typeof d.taskId=="string"&&(l=!0,this._taskProgressTokens.set(d.taskId,t))}}if(l||this._progressHandlers.delete(t),we(e))a(e);else{const c=m.fromError(e.error.code,e.error.message,e.error.data);a(c)}}get transport(){return this._transport}async close(){await this._transport?.close()}async*requestStream(e,t,s){const{task:a}=s??{};if(!a){try{yield{type:"result",result:await this.request(e,t,s)}}catch(c){yield{type:"error",error:c instanceof m?c:new m(w.InternalError,String(c))}}return}let l;try{const c=await this.request(e,He,s);if(c.task)l=c.task.taskId,yield{type:"taskCreated",task:c.task};else throw new m(w.InternalError,"Task creation did not return a task");for(;;){const d=await this.getTask({taskId:l},s);if(yield{type:"taskStatus",task:d},Y(d.status)){d.status==="completed"?yield{type:"result",result:await this.getTaskResult({taskId:l},t,s)}:d.status==="failed"?yield{type:"error",error:new m(w.InternalError,`Task ${l} failed`)}:d.status==="cancelled"&&(yield{type:"error",error:new m(w.InternalError,`Task ${l} was cancelled`)});return}if(d.status==="input_required"){yield{type:"result",result:await this.getTaskResult({taskId:l},t,s)};return}const y=d.pollInterval??this._options?.defaultTaskPollInterval??1e3;await new Promise(x=>setTimeout(x,y)),s?.signal?.throwIfAborted()}}catch(c){yield{type:"error",error:c instanceof m?c:new m(w.InternalError,String(c))}}}request(e,t,s){const{relatedRequestId:a,resumptionToken:l,onresumptiontoken:c,task:d,relatedTask:y}=s??{};return new Promise((x,S)=>{const A=T=>{S(T)};if(!this._transport){A(new Error("Not connected"));return}if(this._options?.enforceStrictCapabilities===!0)try{this.assertCapabilityForMethod(e.method),d&&this.assertTaskCapability(e.method)}catch(T){A(T);return}s?.signal?.throwIfAborted();const _=this._requestMessageId++,q={...e,jsonrpc:"2.0",id:_};s?.onprogress&&(this._progressHandlers.set(_,s.onprogress),q.params={...e.params,_meta:{...e.params?._meta||{},progressToken:_}}),d&&(q.params={...q.params,task:d}),y&&(q.params={...q.params,_meta:{...q.params?._meta||{},[Z]:y}});const R=T=>{this._responseHandlers.delete(_),this._progressHandlers.delete(_),this._cleanupTimeout(_),this._transport?.send({jsonrpc:"2.0",method:"notifications/cancelled",params:{requestId:_,reason:String(T)}},{relatedRequestId:a,resumptionToken:l,onresumptiontoken:c}).catch(J=>this._onerror(new Error(`Failed to send cancellation: ${J}`)));const N=T instanceof m?T:new m(w.RequestTimeout,String(T));S(N)};this._responseHandlers.set(_,T=>{if(!s?.signal?.aborted){if(T instanceof Error)return S(T);try{const N=Wt(t,T.result);N.success?x(N.data):S(N.error)}catch(N){S(N)}}}),s?.signal?.addEventListener("abort",()=>{R(s?.signal?.reason)});const h=s?.timeout??Oo,D=()=>R(m.fromError(w.RequestTimeout,"Request timed out",{timeout:h}));this._setupTimeout(_,h,s?.maxTotalTimeout,D,s?.resetTimeoutOnProgress??!1);const U=y?.taskId;if(U){const T=N=>{const J=this._responseHandlers.get(_);J?J(N):this._onerror(new Error(`Response handler missing for side-channeled request ${_}`))};this._requestResolvers.set(_,T),this._enqueueTaskMessage(U,{type:"request",message:q,timestamp:Date.now()}).catch(N=>{this._cleanupTimeout(_),S(N)})}else this._transport.send(q,{relatedRequestId:a,resumptionToken:l,onresumptiontoken:c}).catch(T=>{this._cleanupTimeout(_),S(T)})})}async getTask(e,t){return this.request({method:"tasks/get",params:e},Ne,t)}async getTaskResult(e,t,s){return this.request({method:"tasks/result",params:e},t,s)}async listTasks(e,t){return this.request({method:"tasks/list",params:e},ze,t)}async cancelTask(e,t){return this.request({method:"tasks/cancel",params:e},Is,t)}async notification(e,t){if(!this._transport)throw new Error("Not connected");this.assertNotificationCapability(e.method);const s=t?.relatedTask?.taskId;if(s){const d={...e,jsonrpc:"2.0",params:{...e.params,_meta:{...e.params?._meta||{},[Z]:t.relatedTask}}};await this._enqueueTaskMessage(s,{type:"notification",message:d,timestamp:Date.now()});return}if((this._options?.debouncedNotificationMethods??[]).includes(e.method)&&!e.params&&!t?.relatedRequestId&&!t?.relatedTask){if(this._pendingDebouncedNotifications.has(e.method))return;this._pendingDebouncedNotifications.add(e.method),Promise.resolve().then(()=>{if(this._pendingDebouncedNotifications.delete(e.method),!this._transport)return;let d={...e,jsonrpc:"2.0"};t?.relatedTask&&(d={...d,params:{...d.params,_meta:{...d.params?._meta||{},[Z]:t.relatedTask}}}),this._transport?.send(d,t).catch(y=>this._onerror(y))});return}let c={...e,jsonrpc:"2.0"};t?.relatedTask&&(c={...c,params:{...c.params,_meta:{...c.params?._meta||{},[Z]:t.relatedTask}}}),await this._transport.send(c,t)}setRequestHandler(e,t){const s=it(e);this.assertRequestHandlerCapability(s),this._requestHandlers.set(s,(a,l)=>{const c=lt(e,a);return Promise.resolve(t(c,l))})}removeRequestHandler(e){this._requestHandlers.delete(e)}assertCanSetRequestHandler(e){if(this._requestHandlers.has(e))throw new Error(`A request handler for ${e} already exists, which would be overridden`)}setNotificationHandler(e,t){const s=it(e);this._notificationHandlers.set(s,a=>{const l=lt(e,a);return Promise.resolve(t(l))})}removeNotificationHandler(e){this._notificationHandlers.delete(e)}_cleanupTaskProgressHandler(e){const t=this._taskProgressTokens.get(e);t!==void 0&&(this._progressHandlers.delete(t),this._taskProgressTokens.delete(e))}async _enqueueTaskMessage(e,t,s){if(!this._taskStore||!this._taskMessageQueue)throw new Error("Cannot enqueue task message: taskStore and taskMessageQueue are not configured");const a=this._options?.maxTaskQueueSize;await this._taskMessageQueue.enqueue(e,t,s??this._transport?.sessionId,a)}async _clearTaskQueue(e,t){if(this._taskMessageQueue){const s=await this._taskMessageQueue.dequeueAll(e,t);for(const a of s)if(a.type==="request"&&rt(a.message)){const l=a.message.id,c=this._requestResolvers.get(l);c?(c(new m(w.InternalError,"Task cancelled or completed")),this._requestResolvers.delete(l)):this._onerror(new Error(`Resolver missing for request ${l} during task ${e} cleanup`))}}}async _waitForTaskUpdate(e,t,s){let a=this._options?.defaultTaskPollInterval??1e3;try{const l=await this._taskStore?.getTask(e,s);l?.pollInterval&&(a=l.pollInterval)}catch{}return new Promise((l,c)=>{if(t.aborted){c(new m(w.InvalidRequest,"Request cancelled"));return}const d=setTimeout(l,a);t.addEventListener("abort",()=>{clearTimeout(d),c(new m(w.InvalidRequest,"Request cancelled"))},{once:!0})})}requestTaskStore(e,t){const s=this._taskStore;if(!s)throw new Error("No task store configured");return{createTask:async a=>{if(!e)throw new Error("No request provided");return await s.createTask(a,e.id,{method:e.method,params:e.params},t)},getTask:async a=>{const l=await s.getTask(a,t);if(!l)throw new m(w.InvalidParams,"Failed to retrieve task: Task not found");return l},storeTaskResult:async(a,l,c)=>{await s.storeTaskResult(a,l,c,t);const d=await s.getTask(a,t);if(d){const y=Se.parse({method:"notifications/tasks/status",params:d});await this.notification(y),Y(d.status)&&this._cleanupTaskProgressHandler(a)}},getTaskResult:a=>s.getTaskResult(a,t),updateTaskStatus:async(a,l,c)=>{const d=await s.getTask(a,t);if(!d)throw new m(w.InvalidParams,`Task "${a}" not found - it may have been cleaned up`);if(Y(d.status))throw new m(w.InvalidParams,`Cannot update task "${a}" from terminal status "${d.status}" to "${l}". Terminal states (completed, failed, cancelled) cannot transition to other states.`);await s.updateTaskStatus(a,l,c,t);const y=await s.getTask(a,t);if(y){const x=Se.parse({method:"notifications/tasks/status",params:y});await this.notification(x),Y(y.status)&&this._cleanupTaskProgressHandler(a)}},listTasks:a=>s.listTasks(a,t)}}}(i=>typeof require<"u"?require:typeof Proxy<"u"?new Proxy(i,{get:(e,t)=>(typeof require<"u"?require:e)[t]}):i)(function(i){if(typeof require<"u")return require.apply(this,arguments);throw Error('Dynamic require of "'+i+'" is not supported')});class Do extends $o{_registeredMethods=new Set;_eventSlots=new Map;onEventDispatch(e,t){}_ensureEventSlot(e){let t=this._eventSlots.get(e);if(!t){let s=this.eventSchemas[e];if(!s)throw Error(`Unknown event: ${String(e)}`);t={listeners:[]},this._eventSlots.set(e,t);let a=s.shape.method.value;this._registeredMethods.add(a);let l=t;super.setNotificationHandler(s,c=>{let d=c.params;this.onEventDispatch(e,d),l.onHandler?.(d);for(let y of[...l.listeners])y(d)})}return t}setEventHandler(e,t){let s=this._ensureEventSlot(e);s.onHandler&&t&&console.warn(`[MCP Apps] on${String(e)} handler replaced. Use addEventListener("${String(e)}", …) to add multiple listeners without replacing.`),s.onHandler=t}getEventHandler(e){return this._eventSlots.get(e)?.onHandler}addEventListener(e,t){this._ensureEventSlot(e).listeners.push(t)}removeEventListener(e,t){let s=this._eventSlots.get(e);if(!s)return;let a=s.listeners.indexOf(t);a!==-1&&s.listeners.splice(a,1)}setRequestHandler=(e,t)=>{this._assertMethodNotRegistered(e,"setRequestHandler"),super.setRequestHandler(e,t)};setNotificationHandler=(e,t)=>{this._assertMethodNotRegistered(e,"setNotificationHandler"),super.setNotificationHandler(e,t)};warnIfRequestHandlerReplaced(e,t,s){t&&s&&console.warn(`[MCP Apps] ${e} handler replaced. Previous handler will no longer be called.`)}replaceRequestHandler=(e,t)=>{let s=e.shape.method.value;this._registeredMethods.add(s),super.setRequestHandler(e,t)};_assertMethodNotRegistered(e,t){let s=e.shape.method.value;if(this._registeredMethods.has(s))throw Error(`Handler for "${s}" already registered (via ${t}). Use addEventListener() to attach multiple listeners, or the on* setter for replace semantics.`);this._registeredMethods.add(s)}}var Je="2026-01-26",Fo="ui/notifications/tool-input-partial",jo=g([n("light"),n("dark")]).describe("Color theme preference for the host environment."),re=g([n("inline"),n("fullscreen"),n("pip")]).describe("Display mode for UI presentation."),Wo=g([n("--color-background-primary"),n("--color-background-secondary"),n("--color-background-tertiary"),n("--color-background-inverse"),n("--color-background-ghost"),n("--color-background-info"),n("--color-background-danger"),n("--color-background-success"),n("--color-background-warning"),n("--color-background-disabled"),n("--color-text-primary"),n("--color-text-secondary"),n("--color-text-tertiary"),n("--color-text-inverse"),n("--color-text-ghost"),n("--color-text-info"),n("--color-text-danger"),n("--color-text-success"),n("--color-text-warning"),n("--color-text-disabled"),n("--color-border-primary"),n("--color-border-secondary"),n("--color-border-tertiary"),n("--color-border-inverse"),n("--color-border-ghost"),n("--color-border-info"),n("--color-border-danger"),n("--color-border-success"),n("--color-border-warning"),n("--color-border-disabled"),n("--color-ring-primary"),n("--color-ring-secondary"),n("--color-ring-inverse"),n("--color-ring-info"),n("--color-ring-danger"),n("--color-ring-success"),n("--color-ring-warning"),n("--font-sans"),n("--font-mono"),n("--font-weight-normal"),n("--font-weight-medium"),n("--font-weight-semibold"),n("--font-weight-bold"),n("--font-text-xs-size"),n("--font-text-sm-size"),n("--font-text-md-size"),n("--font-text-lg-size"),n("--font-heading-xs-size"),n("--font-heading-sm-size"),n("--font-heading-md-size"),n("--font-heading-lg-size"),n("--font-heading-xl-size"),n("--font-heading-2xl-size"),n("--font-heading-3xl-size"),n("--font-text-xs-line-height"),n("--font-text-sm-line-height"),n("--font-text-md-line-height"),n("--font-text-lg-line-height"),n("--font-heading-xs-line-height"),n("--font-heading-sm-line-height"),n("--font-heading-md-line-height"),n("--font-heading-lg-line-height"),n("--font-heading-xl-line-height"),n("--font-heading-2xl-line-height"),n("--font-heading-3xl-line-height"),n("--border-radius-xs"),n("--border-radius-sm"),n("--border-radius-md"),n("--border-radius-lg"),n("--border-radius-xl"),n("--border-radius-full"),n("--border-width-regular"),n("--shadow-hairline"),n("--shadow-sm"),n("--shadow-md"),n("--shadow-lg")]).describe("CSS variable keys available to MCP apps for theming."),Qo=f(Wo.describe(`Style variables for theming MCP apps.

Individual style keys are optional - hosts may provide any subset of these values.
Values are strings containing CSS values (colors, sizes, font stacks, etc.).

Note: This type uses \`Record<K, string | undefined>\` rather than \`Partial<Record<K, string>>\`
for compatibility with Zod schema generation. Both are functionally equivalent for validation.`),g([o(),qe()]).describe(`Style variables for theming MCP apps.

Individual style keys are optional - hosts may provide any subset of these values.
Values are strings containing CSS values (colors, sizes, font stacks, etc.).

Note: This type uses \`Record<K, string | undefined>\` rather than \`Partial<Record<K, string>>\`
for compatibility with Zod schema generation. Both are functionally equivalent for validation.`)).describe(`Style variables for theming MCP apps.

Individual style keys are optional - hosts may provide any subset of these values.
Values are strings containing CSS values (colors, sizes, font stacks, etc.).

Note: This type uses \`Record<K, string | undefined>\` rather than \`Partial<Record<K, string>>\`
for compatibility with Zod schema generation. Both are functionally equivalent for validation.`),Ko=r({method:n("ui/open-link"),params:r({url:o().describe("URL to open in the host's browser")})});r({isError:k().optional().describe("True if the host failed to open the URL (e.g., due to security policy).")}).passthrough();r({isError:k().optional().describe("True if the download failed (e.g., user cancelled or host denied).")}).passthrough();r({isError:k().optional().describe("True if the host rejected or failed to deliver the message.")}).passthrough();var Jo=r({method:n("ui/notifications/sandbox-proxy-ready"),params:r({})}),Be=r({connectDomains:u(o()).optional().describe(`Origins for network requests (fetch/XHR/WebSocket).

- Maps to CSP \`connect-src\` directive
- Empty or omitted → no network connections (secure default)`),resourceDomains:u(o()).optional().describe("Origins for static resources (images, scripts, stylesheets, fonts, media).\n\n- Maps to CSP `img-src`, `script-src`, `style-src`, `font-src`, `media-src` directives\n- Wildcard subdomains supported: `https://*.example.com`\n- Empty or omitted → no network resources (secure default)"),frameDomains:u(o()).optional().describe("Origins for nested iframes.\n\n- Maps to CSP `frame-src` directive\n- Empty or omitted → no nested iframes allowed (`frame-src 'none'`)"),baseUriDomains:u(o()).optional().describe("Allowed base URIs for the document.\n\n- Maps to CSP `base-uri` directive\n- Empty or omitted → only same origin allowed (`base-uri 'self'`)")}),Ve=r({camera:r({}).optional().describe("Request camera access.\n\nMaps to Permission Policy `camera` feature."),microphone:r({}).optional().describe("Request microphone access.\n\nMaps to Permission Policy `microphone` feature."),geolocation:r({}).optional().describe("Request geolocation access.\n\nMaps to Permission Policy `geolocation` feature."),clipboardWrite:r({}).optional().describe("Request clipboard write access.\n\nMaps to Permission Policy `clipboard-write` feature.")}),Bo=r({method:n("ui/notifications/size-changed"),params:r({width:p().optional().describe("New width in pixels."),height:p().optional().describe("New height in pixels.")})});r({method:n("ui/notifications/tool-input"),params:r({arguments:f(o(),v().describe("Complete tool call arguments as key-value pairs.")).optional().describe("Complete tool call arguments as key-value pairs.")})});r({method:n("ui/notifications/tool-input-partial"),params:r({arguments:f(o(),v().describe("Partial tool call arguments (incomplete, may change).")).optional().describe("Partial tool call arguments (incomplete, may change).")})});r({method:n("ui/notifications/tool-cancelled"),params:r({reason:o().optional().describe('Optional reason for the cancellation (e.g., "user action", "timeout").')})});var Vo=r({fonts:o().optional()}),Go=r({variables:Qo.optional().describe("CSS variables for theming the app."),css:Vo.optional().describe("CSS blocks that apps can inject.")});r({method:n("ui/resource-teardown"),params:r({})});var Yo=f(o(),v()),ct=r({text:r({}).optional().describe("Host supports text content blocks."),image:r({}).optional().describe("Host supports image content blocks."),audio:r({}).optional().describe("Host supports audio content blocks."),resource:r({}).optional().describe("Host supports resource content blocks."),resourceLink:r({}).optional().describe("Host supports resource link content blocks."),structuredContent:r({}).optional().describe("Host supports structured content.")}),Zo=r({method:n("ui/notifications/request-teardown"),params:r({}).optional()}),Xo=r({experimental:f(o(),f(o(),ye()).describe("Experimental features keyed by identifier.")).optional().describe("Experimental features keyed by identifier."),openLinks:r({}).optional().describe("Host supports opening external URLs."),downloadFile:r({}).optional().describe("Host supports file downloads via ui/download-file."),serverTools:r({listChanged:k().optional().describe("Host supports tools/list_changed notifications.")}).optional().describe("Host can proxy tool calls to the MCP server."),serverResources:r({listChanged:k().optional().describe("Host supports resources/list_changed notifications.")}).optional().describe("Host can proxy resource reads to the MCP server."),logging:r({}).optional().describe("Host accepts log messages."),sandbox:r({permissions:Ve.optional().describe("Permissions granted by the host (camera, microphone, geolocation)."),csp:Be.optional().describe("CSP domains approved by the host.")}).optional().describe("Sandbox configuration applied by the host."),updateModelContext:ct.optional().describe("Host accepts context updates (ui/update-model-context) to be included in the model's context for future turns."),message:ct.optional().describe("Host supports receiving content messages (ui/message) from the view."),sampling:r({tools:r({}).optional().describe("Host supports tool use via `tools` and `toolChoice` parameters.")}).optional().describe("Host supports LLM sampling (sampling/createMessage) from the view.\nMirrors the MCP `ClientCapabilities.sampling` shape so hosts can pass it through.")}),en=r({experimental:f(o(),f(o(),ye()).describe("Experimental features keyed by identifier.")).optional().describe("Experimental features keyed by identifier."),tools:r({listChanged:k().optional().describe("App supports tools/list_changed notifications.")}).optional().describe("App exposes MCP-style tools that the host can call."),availableDisplayModes:u(re).optional().describe("Display modes the app supports.")}),tn=r({method:n("ui/notifications/initialized"),params:r({}).optional()});r({csp:Be.optional().describe("Content Security Policy configuration for UI resources."),permissions:Ve.optional().describe("Sandbox permissions requested by the UI resource."),domain:o().optional().describe(`Dedicated origin for view sandbox.

Useful when views need stable, dedicated origins for OAuth callbacks, CORS policies, or API key allowlists.

**Host-dependent:** The format and validation rules for this field are determined by each host. Servers MUST consult host-specific documentation for the expected domain format. Common patterns include:
- Hash-based subdomains (e.g., \`{hash}.claudemcpcontent.com\`)
- URL-derived subdomains (e.g., \`www-example-com.oaiusercontent.com\`)

If omitted, host uses default sandbox origin (typically per-conversation).`),prefersBorder:k().optional().describe(`Visual boundary preference - true if view prefers a visible border.

Boolean requesting whether a visible border and background is provided by the host. Specifying an explicit value for this is recommended because hosts' defaults may vary.

- \`true\`: request visible border + background
- \`false\`: request no visible border + background
- omitted: host decides border`)});var dt=r({method:n("ui/request-display-mode"),params:r({mode:re.describe("The display mode being requested.")})});r({mode:re.describe("The display mode that was actually set. May differ from requested if not supported.")}).passthrough();var sn=g([n("model"),n("app")]).describe("Tool visibility scope - who can access the tool.");r({resourceUri:o().optional(),visibility:u(sn).optional().describe(`Who can access this tool. Default: ["model", "app"]
- "model": Tool visible to and callable by the agent
- "app": Tool callable by the app from this server only`),csp:ot().optional(),permissions:ot().optional()});r({mimeTypes:u(o()).optional().describe('Array of supported MIME types for UI resources.\nMust include `"text/html;profile=mcp-app"` for MCP Apps support.')});var on=r({method:n("ui/download-file"),params:r({contents:u(g([Nt,Lt])).describe("Resource contents to download — embedded (inline data) or linked (host fetches). Uses standard MCP resource types.")})}),nn=r({method:n("ui/message"),params:r({role:n("user").describe('Message role, currently only "user" is supported.'),content:u(me).describe("Message content blocks (text, image, etc.).")})});r({method:n("ui/notifications/sandbox-resource-ready"),params:r({html:o().describe("HTML content to load into the inner iframe."),sandbox:o().optional().describe("Optional override for the inner iframe's sandbox attribute."),csp:Be.optional().describe("CSP configuration from resource metadata."),permissions:Ve.optional().describe("Sandbox permissions from resource metadata.")})});r({method:n("ui/notifications/tool-result"),params:ae.describe("Standard MCP tool execution result.")});var Qt=r({toolInfo:r({id:le.optional().describe("JSON-RPC id of the tools/call request."),tool:Qe.describe("Tool definition including name, inputSchema, etc.")}).optional().describe("Metadata of the tool call that instantiated this App."),theme:jo.optional().describe("Current color theme preference."),styles:Go.optional().describe("Style configuration for theming the app."),displayMode:re.optional().describe("How the UI is currently displayed."),availableDisplayModes:u(re).optional().describe("Display modes the host supports."),containerDimensions:g([r({height:p().describe("Fixed container height in pixels.")}),r({maxHeight:g([p(),qe()]).optional().describe("Maximum container height in pixels.")})]).and(g([r({width:p().describe("Fixed container width in pixels.")}),r({maxWidth:g([p(),qe()]).optional().describe("Maximum container width in pixels.")})])).optional().describe(`Container dimensions. Represents the dimensions of the iframe or other
container holding the app. Specify either width or maxWidth, and either height or maxHeight.`),locale:o().optional().describe("User's language and region preference in BCP 47 format."),timeZone:o().optional().describe("User's timezone in IANA format."),userAgent:o().optional().describe("Host application identifier."),platform:g([n("web"),n("desktop"),n("mobile")]).optional().describe("Platform type for responsive design decisions."),deviceCapabilities:r({touch:k().optional().describe("Whether the device supports touch input."),hover:k().optional().describe("Whether the device supports hover interactions.")}).optional().describe("Device input capabilities."),safeAreaInsets:r({top:p().describe("Top safe area inset in pixels."),right:p().describe("Right safe area inset in pixels."),bottom:p().describe("Bottom safe area inset in pixels."),left:p().describe("Left safe area inset in pixels.")}).optional().describe("Mobile safe area boundaries in pixels.")}).passthrough();r({method:n("ui/notifications/host-context-changed"),params:Qt.describe("Partial context update containing only changed fields.")});var an=r({method:n("ui/update-model-context"),params:r({content:u(me).optional().describe("Context content blocks (text, image, etc.)."),structuredContent:f(o(),v().describe("Structured content for machine-readable context data.")).optional().describe("Structured content for machine-readable context data.")})}),rn=r({method:n("ui/initialize"),params:r({appInfo:Re.describe("App identification (name and version)."),appCapabilities:en.describe("Features and capabilities this app provides."),protocolVersion:o().describe("Protocol version this app supports.")})});r({protocolVersion:o().describe('Negotiated protocol version string (e.g., "2025-11-21").'),hostInfo:Re.describe("Host application identification and version."),hostCapabilities:Xo.describe("Features and capabilities provided by the host."),hostContext:Qt.describe("Rich context about the host environment.")}).passthrough();class ln{eventTarget;eventSource;messageListener;constructor(e=window.parent,t){this.eventTarget=e,this.eventSource=t,this.messageListener=s=>{if(t&&s.source!==this.eventSource){console.debug("Ignoring message from unknown source",s);return}let a=us.safeParse(s.data);a.success?(console.debug("Parsed message",a.data),this.onmessage?.(a.data)):s.data?.jsonrpc!=="2.0"?console.debug("Ignoring non-JSON-RPC message",a.error.message,s):(console.error("Failed to parse message",a.error.message,s),this.onerror?.(Error("Invalid JSON-RPC message received: "+a.error.message)))}}async start(){window.addEventListener("message",this.messageListener)}async send(e,t){e.method!==Fo&&console.debug("Sending message",e),this.eventTarget.postMessage(e,"*")}async close(){window.removeEventListener("message",this.messageListener),this.onclose?.()}onclose;onerror;onmessage;sessionId;setProtocolVersion}var cn=[Je];class dn extends Do{_client;_hostInfo;_capabilities;_appCapabilities;_hostContext={};_appInfo;_initializedReceived=!1;_baseReplaceRequestHandler=this.replaceRequestHandler;replaceRequestHandler=(e,t)=>{this._baseReplaceRequestHandler(e,(s,a)=>(this._initializedReceived||console.warn(`[ext-apps] AppBridge received '${s.method}' before ui/notifications/initialized. The View is calling host methods before completing the handshake; it should await app.connect() first.`),t(s,a)))};eventSchemas={sizechange:Bo,sandboxready:Jo,initialized:tn,requestteardown:Zo,loggingmessage:Ft};constructor(e,t,s,a){super(a),this._client=e,this._hostInfo=t,this._capabilities=s,this.addEventListener("initialized",()=>{this._initializedReceived=!0}),this._hostContext=a?.hostContext||{},this.setRequestHandler(rn,l=>this._oninitialize(l)),this.setRequestHandler(ve,(l,c)=>(this.onping?.(l.params,c),{})),this.replaceRequestHandler(dt,l=>({mode:this._hostContext.displayMode??"inline"}))}getAppCapabilities(){return this._appCapabilities}getAppVersion(){return this._appInfo}onping;get onsizechange(){return this.getEventHandler("sizechange")}set onsizechange(e){this.setEventHandler("sizechange",e)}get onsandboxready(){return this.getEventHandler("sandboxready")}set onsandboxready(e){this.setEventHandler("sandboxready",e)}get oninitialized(){return this.getEventHandler("initialized")}set oninitialized(e){this.setEventHandler("initialized",e)}_onmessage;get onmessage(){return this._onmessage}set onmessage(e){this.warnIfRequestHandlerReplaced("onmessage",this._onmessage,e),this._onmessage=e,this.replaceRequestHandler(nn,async(t,s)=>{if(!this._onmessage)throw Error("No onmessage handler set");return this._onmessage(t.params,s)})}_onopenlink;get onopenlink(){return this._onopenlink}set onopenlink(e){this.warnIfRequestHandlerReplaced("onopenlink",this._onopenlink,e),this._onopenlink=e,this.replaceRequestHandler(Ko,async(t,s)=>{if(!this._onopenlink)throw Error("No onopenlink handler set");return this._onopenlink(t.params,s)})}_ondownloadfile;get ondownloadfile(){return this._ondownloadfile}set ondownloadfile(e){this.warnIfRequestHandlerReplaced("ondownloadfile",this._ondownloadfile,e),this._ondownloadfile=e,this.replaceRequestHandler(on,async(t,s)=>{if(!this._ondownloadfile)throw Error("No ondownloadfile handler set");return this._ondownloadfile(t.params,s)})}get onrequestteardown(){return this.getEventHandler("requestteardown")}set onrequestteardown(e){this.setEventHandler("requestteardown",e)}_onrequestdisplaymode;get onrequestdisplaymode(){return this._onrequestdisplaymode}set onrequestdisplaymode(e){this.warnIfRequestHandlerReplaced("onrequestdisplaymode",this._onrequestdisplaymode,e),this._onrequestdisplaymode=e,this.replaceRequestHandler(dt,async(t,s)=>{if(!this._onrequestdisplaymode)throw Error("No onrequestdisplaymode handler set");return this._onrequestdisplaymode(t.params,s)})}get onloggingmessage(){return this.getEventHandler("loggingmessage")}set onloggingmessage(e){this.setEventHandler("loggingmessage",e)}_onupdatemodelcontext;get onupdatemodelcontext(){return this._onupdatemodelcontext}set onupdatemodelcontext(e){this.warnIfRequestHandlerReplaced("onupdatemodelcontext",this._onupdatemodelcontext,e),this._onupdatemodelcontext=e,this.replaceRequestHandler(an,async(t,s)=>{if(!this._onupdatemodelcontext)throw Error("No onupdatemodelcontext handler set");return this._onupdatemodelcontext(t.params,s)})}_oncalltool;get oncalltool(){return this._oncalltool}set oncalltool(e){this.warnIfRequestHandlerReplaced("oncalltool",this._oncalltool,e),this._oncalltool=e,this.replaceRequestHandler(Ot,async(t,s)=>{if(!this._oncalltool)throw Error("No oncalltool handler set");return this._oncalltool(t.params,s)})}set oncreatesamplingmessage(e){this.setRequestHandler(jt,async(t,s)=>e(t.params,s))}sendToolListChanged(e={}){return this.notification({method:"notifications/tools/list_changed",params:e})}_onlistresources;get onlistresources(){return this._onlistresources}set onlistresources(e){this.warnIfRequestHandlerReplaced("onlistresources",this._onlistresources,e),this._onlistresources=e,this.replaceRequestHandler(xt,async(t,s)=>{if(!this._onlistresources)throw Error("No onlistresources handler set");return this._onlistresources(t.params,s)})}_onlistresourcetemplates;get onlistresourcetemplates(){return this._onlistresourcetemplates}set onlistresourcetemplates(e){this.warnIfRequestHandlerReplaced("onlistresourcetemplates",this._onlistresourcetemplates,e),this._onlistresourcetemplates=e,this.replaceRequestHandler(Ct,async(t,s)=>{if(!this._onlistresourcetemplates)throw Error("No onlistresourcetemplates handler set");return this._onlistresourcetemplates(t.params,s)})}_onreadresource;get onreadresource(){return this._onreadresource}set onreadresource(e){this.warnIfRequestHandlerReplaced("onreadresource",this._onreadresource,e),this._onreadresource=e,this.replaceRequestHandler(Pt,async(t,s)=>{if(!this._onreadresource)throw Error("No onreadresource handler set");return this._onreadresource(t.params,s)})}sendResourceListChanged(e={}){return this.notification({method:"notifications/resources/list_changed",params:e})}_onlistprompts;get onlistprompts(){return this._onlistprompts}set onlistprompts(e){this.warnIfRequestHandlerReplaced("onlistprompts",this._onlistprompts,e),this._onlistprompts=e,this.replaceRequestHandler(Ht,async(t,s)=>{if(!this._onlistprompts)throw Error("No onlistprompts handler set");return this._onlistprompts(t.params,s)})}sendPromptListChanged(e={}){return this.notification({method:"notifications/prompts/list_changed",params:e})}assertCapabilityForMethod(e){}assertRequestHandlerCapability(e){}assertNotificationCapability(e){}assertTaskCapability(e){throw Error("Tasks are not supported in MCP Apps")}assertTaskHandlerCapability(e){throw Error("Task handlers are not supported in MCP Apps")}getCapabilities(){return this._capabilities}async _oninitialize(e){let t=e.params.protocolVersion;return this._appInfo!==void 0&&console.warn("[ext-apps] AppBridge received a second ui/initialize. The View may be double-mounting (e.g. React StrictMode in dev) without closing the previous App instance. Responding normally; the latest appInfo/appCapabilities replace the previous values."),this._appCapabilities=e.params.appCapabilities,this._appInfo=e.params.appInfo,{protocolVersion:cn.includes(t)?t:Je,hostCapabilities:this.getCapabilities(),hostInfo:this._hostInfo,hostContext:this._hostContext}}setHostContext(e){let t={},s=!1;for(let a of Object.keys(e)){let l=this._hostContext[a],c=e[a];un(l,c)||(t[a]=c,s=!0)}s&&(this._hostContext=e,this.sendHostContextChange(t))}sendHostContextChange(e){return this.notification({method:"ui/notifications/host-context-changed",params:e})}sendToolInput(e){return this.notification({method:"ui/notifications/tool-input",params:e})}sendToolInputPartial(e){return this.notification({method:"ui/notifications/tool-input-partial",params:e})}sendToolResult(e){return this.notification({method:"ui/notifications/tool-result",params:e})}sendToolCancelled(e){return this.notification({method:"ui/notifications/tool-cancelled",params:e})}sendSandboxResourceReady(e){return this.notification({method:"ui/notifications/sandbox-resource-ready",params:e})}teardownResource(e,t){return this.request({method:"ui/resource-teardown",params:e},Yo,t)}sendResourceTeardown=this.teardownResource;callTool(e,t){return this.request({method:"tools/call",params:e},ae,t)}listTools(e,t){return this.request({method:"tools/list",params:e},zt,t)}async connect(e){if(this.transport)throw Error("AppBridge is already connected. Call close() before connecting again.");if(this._initializedReceived=!1,this._client){let t=this._client.getServerCapabilities();if(!t)throw Error("Client server capabilities not available");t.tools&&(this.oncalltool=async(s,a)=>this._client.request({method:"tools/call",params:s},ae,{signal:a.signal}),t.tools.listChanged&&this._client.setNotificationHandler($t,s=>this.sendToolListChanged(s.params))),t.resources&&(this.onlistresources=async(s,a)=>this._client.request({method:"resources/list",params:s},qt,{signal:a.signal}),this.onlistresourcetemplates=async(s,a)=>this._client.request({method:"resources/templates/list",params:s},It,{signal:a.signal}),this.onreadresource=async(s,a)=>this._client.request({method:"resources/read",params:s},Mt,{signal:a.signal}),t.resources.listChanged&&this._client.setNotificationHandler(Et,s=>this.sendResourceListChanged(s.params))),t.prompts&&(this.onlistprompts=async(s,a)=>this._client.request({method:"prompts/list",params:s},At,{signal:a.signal}),t.prompts.listChanged&&this._client.setNotificationHandler(Ut,s=>this.sendPromptListChanged(s.params)))}return super.connect(e)}}function un(i,e){return JSON.stringify(i)===JSON.stringify(e)}function xe(i){try{return JSON.stringify(i)??""}catch{return""}}function pn(i){try{const e=atob(i),t=Uint8Array.from(e,s=>s.charCodeAt(0));return new TextDecoder().decode(t)}catch{throw new Error("The MCP App resource contains invalid base64 content.")}}function hn(i,e,t=!1){const s=i?.find(a=>a.uri===e);return s||(!t&&i?.length===1?i[0]:void 0)}function ut(i){return JSON.stringify([i.resourceUri??null,i.serverHash??null,i.serverId??null])}const Rn=Je,mn=r({method:n("ui/message"),params:r({role:o().optional(),content:u(ye()).optional(),followUp:k().optional(),_meta:f(o(),ye()).optional()}).passthrough()}),fn={idleTimeoutMs:ft,initializationTimeoutMs:3e4,hostInfo:{name:"CopilotKit MCP Apps Host",version:"1.0.0"},hostCapabilities:{openLinks:{},logging:{},message:{text:{}}},hostContext:{platform:"web"}},gn=i=>{let e,t=!0;try{e=new URL(i)}catch{if(!/^(\/|\.\/|\.\.\/)/.test(i))return;t=!1;try{e=new URL(i,window.location.href)}catch{return}}if(!Zt.has(e.protocol)&&!(e.username||e.password))return t?i:e.href};function vn(i){const{iframe:e,getContent:t,getAgent:s,host:a,messageId:l,hooks:c,options:d,openLinkPolicy:y=gn,cancelFollowUpsOnTeardown:x=!1}=i,S={...fn,...d},A=ut(t()),_={};let q=!1,R=!1,h=null,D,U,T,N,J,Te=null,V,Ge=!1,Ye=!1;const oe=()=>{!R||!h||(D!==void 0&&(h.sendToolInput({arguments:D}),D=void 0),U!==void 0&&(h.sendToolResult(U),U=void 0))},Ze=(b,L)=>{const H=xe(b);H!==J&&(J=H,c?.onContentError?.(new Error(`[MCPAppsRenderer] Activity content for message "${l??"(no id)"}" does not match the MCP Apps content schema, so it was not forwarded to the widget: ${L.message}`)))},Kt=()=>{J!==void 0&&(J=void 0,c?.onContentError?.(null))},Xe=b=>{const L=ge.safeParse(b);if(!L.success){Ze(b,L.error);return}const H=L.data;if(ut(H)!==A)return;const{toolInput:Q}=H,G=H.result;if(Kt(),Q!==void 0){const C=xe(Q);C!==T&&(T=C,D=Q,oe())}if(G!==void 0){const C=xe(G);C!==N&&(N=C,U=G,oe())}},et=b=>{if(q||!l)return;const L=(b??s()?.messages)?.find(Q=>Q?.id===l);if(!L||L.activityType!==nt)return;const H=ge.safeParse(L.content);if(!H.success){Ze(L.content,H.error);return}Xe(H.data)},tt=()=>!!s()?.messages?.some(b=>b?.id===l&&b?.activityType===nt),Jt=async()=>{const b=s();if(!b)throw new Error("No agent available to fetch resource");const{resourceUri:L,serverHash:H,serverId:Q}=t(),G=(await be.enqueue(b,()=>b.runAgent({forwardedProps:{__proxiedMCPRequest:{serverHash:H,serverId:Q,method:"resources/read",params:{uri:L}}}}),{owner:_,timeoutMs:S.idleTimeoutMs,cancelRunningWait:i.cancelRunningWaitOnTeardown,dropAfterThreadSwitch:!0})).result,C=hn(G?.contents,L,i.requireExactResourceUri);if(!C)throw new Error("No resource content in response");return C},st=()=>{if(q)return;q=!0,V!==void 0&&(clearTimeout(V),V=void 0),be.cancelOwner(_),Te?.unsubscribe(),Te=null;const b=h;h=null,b?.close()};return(async()=>{try{const b=await Jt();if(q)return;c?.onResource?.(b),e.setAttribute("sandbox","allow-scripts allow-same-origin allow-forms"),e.setAttribute("data-testid","mcp-app-iframe"),e.setAttribute("title","Interactive MCP application");const L=b._meta?.ui?.csp?.resourceDomains;e.srcdoc=ts(L);const H=e.contentWindow;if(!H)throw new Error("Sandbox iframe has no contentWindow");let Q;if(b.text)Q=b.text;else if(b.blob)Q=pn(b.blob);else throw new Error("Resource has no text or blob content");h=new dn(null,S.hostInfo,S.hostCapabilities,{hostContext:{theme:e.closest(".dark")?"dark":"light",...S.hostContext}}),V=setTimeout(()=>{q||Ge||(Ye=!0,c?.onError?.(new Error(`[MCPAppsRenderer] Timed out after ${S.initializationTimeoutMs}ms waiting for the MCP App sandbox to initialize.`)),st())},S.initializationTimeoutMs),h.onsandboxready=()=>{if(Ye){console.warn("[MCPAppsRenderer] Ignoring a sandbox handshake that arrived after the initialization timeout.");return}Ge=!0,V!==void 0&&(clearTimeout(V),V=void 0),h?.sendSandboxResourceReady({html:Q}).then(()=>{q||c?.onSandboxReady?.()})},h.setRequestHandler(mn,async C=>{const z=s();if(!z)return console.warn("[MCPAppsRenderer] ui/message: No agent available"),{isError:!1};try{const K=C.params,X=K._meta?.copilotkit??{},ne=X.role||K.role||"user",B=K.content?.filter(ee=>ee.type==="text"&&ee.text).map(ee=>ee.text).join(`
`)||"";if(B&&z.addMessage({id:Xt(),role:ne,content:B}),(X.followUp??K.followUp??ne==="user")&&B){const ee=z.threadId||"default";be.enqueue(z,()=>es({host:a,agent:z,capturedThreadId:ee}),{timeoutMs:S.idleTimeoutMs,owner:x?_:void 0,cancelRunningWait:i.cancelRunningWaitOnTeardown}).catch(fe=>{q&&x||(console.error("[MCPAppsRenderer] ui/message agent run failed:",fe),c?.onFollowUpError?.(fe instanceof Error?fe:new Error(String(fe))))})}return{isError:!1}}catch(K){return console.error("[MCPAppsRenderer] ui/message error:",K),{isError:!0}}}),h.onopenlink=async({url:C})=>{const z=y(C);return z?(window.open(z,"_blank","noopener,noreferrer"),{isError:!1}):(console.warn("[MCPAppsRenderer] ui/open-link rejected by policy:",C),{isError:!0})},h.oncalltool=async C=>{const{serverHash:z,serverId:K}=t(),X=s();if(!z)throw new Error("No server hash available for proxying");if(!X)throw new Error("No agent available for proxying");let ne;try{ne=await be.enqueue(X,()=>X.runAgent({forwardedProps:{__proxiedMCPRequest:{serverHash:z,serverId:K,method:"tools/call",params:C}}}),{owner:_,timeoutMs:S.idleTimeoutMs,cancelRunningWait:i.cancelRunningWaitOnTeardown,dropAfterThreadSwitch:!0})}catch(B){throw B instanceof gt?new Error(`tools/call was not executed: ${B.message} Retry from the current thread.`,{cause:B}):B}return ge.shape.result.parse(ne.result??{})},h.onsizechange=C=>{if(q)return;const{width:z,height:K}=C||{};c?.onSizeChanged?.({width:typeof z=="number"?z:void 0,height:typeof K=="number"?K:void 0})},h.oninitialized=()=>{q||(R=!0,c?.onInitialized?.(),l&&tt()&&(D=void 0,U=void 0,T=void 0,N=void 0,et()),oe())},h.onloggingmessage=C=>{console.log("[MCPAppsRenderer] App log:",C)};const G=new ln(H,H);if(await h.connect(G),q){await h.close(),h=null;return}l&&(Te=s()?.subscribe({onMessagesChanged:({messages:C})=>et(C)})??null)}catch(b){console.error("[MCPAppsRenderer] Setup error:",b),q||c?.onError?.(b instanceof Error?b:new Error(String(b)))}})(),{sendToolInput(b){D=b,oe()},sendToolResult(b){U=ge.shape.result.parse(b),oe()},syncContent(b){l&&tt()||Xe(b)},teardown(){st()}}}export{ge as MCPAppsActivityContentSchema,nt as MCPAppsActivityType,gt as MCPAppsQueueThreadChangedError,ns as MCPAppsRequestQueue,Rn as MCP_APPS_PROTOCOL_VERSION,ft as MCP_APPS_QUEUE_IDLE_TIMEOUT_MS,fn as MCP_APPS_SESSION_DEFAULTS,Zt as MCP_OPEN_LINK_BLOCKED_SCHEMES,vn as bindMcpApp,ts as buildSandboxHTML,gn as denyDangerousSchemes,be as mcpAppsRequestQueue,pn as ɵdecodeBase64,es as ɵrunMcpFollowUp};