/**
 * Minified by jsDelivr using Terser v5.39.0.
 * Original file: /npm/@mastra/client-js@1.13.4/dist/index.js
 *
 * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files
 */
import{processDataStream,parsePartialJson}from"@ai-sdk/ui-utils";import{v4}from"@lukeed/uuid";import{getErrorFromUnknown}from"@mastra/core/error";import{standardSchemaToJSONSchema,toStandardSchema}from"@mastra/schema-compat/schema";import{RequestContext}from"@mastra/core/request-context";import{zodToJsonSchema as zodToJsonSchema$1}from"@mastra/schema-compat/zod-to-json";function normalizeRoutePath(e){let t=e.trim();if(t.includes("..")||t.includes("?")||t.includes("#"))throw new Error(`Invalid route path: "${e}". Path cannot contain '..', '?', or '#'`);return t=t.replace(/\/+/g,"/"),"/"===t||""===t?"":(t.endsWith("/")&&(t=t.slice(0,-1)),t.startsWith("/")||(t=`/${t}`),t)}function isComplexValue(e){return null!=e&&(!(e instanceof Date)&&"object"==typeof e)}function serializeQueryValue(e){return e instanceof Date?e.toISOString():isComplexValue(e)?JSON.stringify(e,((e,t)=>t instanceof Date?t.toISOString():t)):String(e)}function toQueryParams(e,t=[]){const r=new URLSearchParams,s=t;return function e(t){for(const[o,n]of Object.entries(t))null!=n&&(!s.includes(o)||"object"!=typeof n||Array.isArray(n)||n instanceof Date?r.set(o,serializeQueryValue(n)):e(n))}(e),r.toString()}function parseSuperJsonString(e){const t=JSON.parse(e);return t&&"object"==typeof t&&!Array.isArray(t)&&"json"in t?t.json:t}function parseClientRequestContext(e){if(e)return e instanceof RequestContext?Object.fromEntries(e.entries()):e}function base64RequestContext(e){if(e){const t=(new TextEncoder).encode(JSON.stringify(e));return btoa(Array.from(t,(e=>String.fromCharCode(e))).join(""))}}function requestContextQueryString(e,t="?"){const r=base64RequestContext(parseClientRequestContext(e));if(!r)return"";const s=new URLSearchParams;s.set("requestContext",r);const o=s.toString();return o?`${t}${o}`:""}function isZodType(e){return"object"==typeof e&&null!==e&&"_def"in e&&"parse"in e&&"function"==typeof e.parse&&"safeParse"in e&&"function"==typeof e.safeParse}function zodToJsonSchema(e){return isZodType(e)?zodToJsonSchema$1(e):e}function processClientTools(e){if(e)return Object.fromEntries(Object.entries(e).map((([e,t])=>{const r=t;return[e,{...t,...void 0!==r.parameters?{parameters:zodToJsonSchema(r.parameters)}:{},...void 0!==r.inputSchema?{inputSchema:zodToJsonSchema(r.inputSchema)}:{},...void 0!==r.outputSchema?{outputSchema:zodToJsonSchema(r.outputSchema)}:{}}]})))}async function sharedProcessMastraStream({stream:e,onChunk:t}){const r=e.getReader(),s=new TextDecoder;let o="";try{for(;;){const{done:e,value:n}=await r.read();if(e)break;o+=s.decode(n,{stream:!0});const a=o.split("\n\n");o=a.pop()||"";for(const e of a)if(e.startsWith("data: ")){const r=e.slice(6);if("[DONE]"===r)return;let s;try{s=JSON.parse(r)}catch(e){console.error("❌ JSON parse error:",e,"Data:",r);continue}s&&await t(s)}}}finally{r.releaseLock()}}async function processMastraNetworkStream({stream:e,onChunk:t}){return sharedProcessMastraStream({stream:e,onChunk:t})}async function processMastraStream({stream:e,onChunk:t}){return sharedProcessMastraStream({stream:e,onChunk:t})}var MastraClientError=class extends Error{status;statusText;body;constructor(e,t,r,s){super(r),this.name="MastraClientError",this.status=e,this.statusText=t,this.body=s}},BaseResource=class{options;apiPrefix;constructor(e){this.options=e,this.apiPrefix=normalizeRoutePath(e.apiPrefix??"/api")}async request(e,t={}){let r=null;const{baseUrl:s,retries:o=3,backoffMs:n=100,maxBackoffMs:a=1e3,headers:i={},credentials:d,fetch:u}=this.options,c=u||fetch;let l=n;const h=`${this.apiPrefix}${e}`;for(let e=0;e<=o;e++)try{const e=await c(`${s.replace(/\/$/,"")}${h}`,{...t,headers:{...!t.body||t.body instanceof FormData||"POST"!==t.method&&"PUT"!==t.method&&"PATCH"!==t.method&&"DELETE"!==t.method?{}:{"content-type":"application/json"},...i,...t.headers},signal:this.options.abortSignal,credentials:t.credentials??d,body:t.body instanceof FormData?t.body:t.body?JSON.stringify(t.body):void 0});if(!e.ok){const t=await e.text();let r,s=`HTTP error! status: ${e.status}`;try{r=JSON.parse(t),s+=` - ${JSON.stringify(r)}`}catch{t&&(s+=` - ${t}`)}throw new MastraClientError(e.status,e.statusText,s,r)}if(t.stream)return e;return await e.json()}catch(t){r=t;const s=t.status;if(void 0!==s&&s>=400&&s<500)throw t;if(e===o)break;await new Promise((e=>setTimeout(e,l))),l=Math.min(2*l,a)}throw r||new Error("Request failed")}};async function executeToolCallAndRespond({response:e,params:t,agentId:r,resourceId:s,threadId:o,requestContext:n,respondFn:a}){if("tool-calls"===e.finishReason){const i=e.toolCalls;if(!i||!Array.isArray(i))return e;for(const d of i){const i=t.clientTools?.[d.payload.toolName];if(i&&i.execute){const u=await i.execute(d?.payload.args,{requestContext:n,tracingContext:{currentSpan:void 0},agent:{agentId:r,messages:e.messages,toolCallId:d?.payload.toolCallId,suspend:async()=>{},threadId:o,resourceId:s}}),c=[...e.response.messages||[],{role:"tool",content:[{type:"tool-result",toolCallId:d.payload.toolCallId,toolName:d.payload.toolName,result:u}]}],l=o?c:[...Array.isArray(t.messages)?t.messages:[],...c],h={...t};return delete h.messages,a(l,h)}}}return e}var AgentVoice=class extends BaseResource{constructor(e,t,r){super(e),this.agentId=t,this.version=r,this.agentId=t}agentId;version;getQueryString(e,t="?"){const r=new URLSearchParams(requestContextQueryString(e).slice(1));this.version&&new URLSearchParams(toQueryParams(this.version)).forEach(((e,t)=>{r.set(t,e)}));const s=r.toString();return s?`${t}${s}`:""}async speak(e,t){return this.request(`/agents/${this.agentId}/voice/speak`,{method:"POST",headers:{"Content-Type":"application/json"},body:{text:e,options:t},stream:!0})}listen(e,t){const r=new FormData;return r.append("audio",e),t&&r.append("options",JSON.stringify(t)),this.request(`/agents/${this.agentId}/voice/listen`,{method:"POST",body:r})}getSpeakers(e){return this.request(`/agents/${this.agentId}/voice/speakers${this.getQueryString(e)}`)}getListener(e){return this.request(`/agents/${this.agentId}/voice/listener${this.getQueryString(e)}`)}},Agent=class extends BaseResource{constructor(e,t,r){super(e),this.agentId=t,this.version=r,this.voice=new AgentVoice(e,this.agentId,this.version)}agentId;version;voice;getQueryString(e,t="?"){const r=new URLSearchParams(requestContextQueryString(e).slice(1));this.version&&new URLSearchParams(toQueryParams(this.version)).forEach(((e,t)=>{r.set(t,e)}));const s=r.toString();return s?`${t}${s}`:""}details(e){return this.request(`/agents/${this.agentId}${this.getQueryString(e)}`)}enhanceInstructions(e,t){return this.request(`/agents/${this.agentId}/instructions/enhance`,{method:"POST",body:{instructions:e,comment:t}})}clone(e){const{requestContext:t,...r}=e||{};return this.request(`/agents/${this.agentId}/clone`,{method:"POST",body:{...r,requestContext:parseClientRequestContext(t)}})}listVersions(e,t){const r=new URLSearchParams;void 0!==e?.page&&r.set("page",String(e.page)),void 0!==e?.perPage&&r.set("perPage",String(e.perPage)),e?.orderBy&&r.set("orderBy",e.orderBy),e?.sortDirection&&r.set("sortDirection",e.sortDirection);const s=r.toString(),o=requestContextQueryString(t);return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions${s?`?${s}`:""}${o?`${s?"&":"?"}${o.slice(1)}`:""}`)}createVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions${requestContextQueryString(t)}`,{method:"POST",body:e||{}})}getVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}activateVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions/${encodeURIComponent(e)}/activate${requestContextQueryString(t)}`,{method:"POST"})}restoreVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions/${encodeURIComponent(e)}/restore${requestContextQueryString(t)}`,{method:"POST"})}deleteVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}compareVersions(e,t,r){const s=new URLSearchParams;s.set("from",e),s.set("to",t);const o=requestContextQueryString(r);return this.request(`/stored/agents/${encodeURIComponent(this.agentId)}/versions/compare?${s.toString()}${o?`&${o.slice(1)}`:""}`)}async generateLegacy(e){const t={...e,output:e.output?zodToJsonSchema(e.output):void 0,experimental_output:e.experimental_output?zodToJsonSchema(e.experimental_output):void 0,requestContext:parseClientRequestContext(e.requestContext),clientTools:processClientTools(e.clientTools)},{resourceId:r,threadId:s,requestContext:o}=t,n=await this.request(`/agents/${this.agentId}/generate-legacy`,{method:"POST",body:t});if("tool-calls"===n.finishReason){const t=n.toolCalls;if(!t||!Array.isArray(t))return n;for(const a of t){const t=e.clientTools?.[a.toolName];if(t&&t.execute){const i=await t.execute(a?.args,{requestContext:o,tracingContext:{currentSpan:void 0},agent:{agentId:this.agentId,messages:n.messages,toolCallId:a?.toolCallId,suspend:async()=>{},threadId:s,resourceId:r}}),d=[...n.response.messages,{role:"tool",content:[{type:"tool-result",toolCallId:a.toolCallId,toolName:a.toolName,result:i}]}];return this.generateLegacy({...e,messages:d})}}}return n}async generate(e,t){const r={...t,messages:e},s={...r,requestContext:parseClientRequestContext(r.requestContext),clientTools:processClientTools(r.clientTools),structuredOutput:r.structuredOutput?{...r.structuredOutput,schema:standardSchemaToJSONSchema(toStandardSchema(r.structuredOutput.schema))}:void 0},{memory:o,requestContext:n}=s,{resource:a,thread:i}=o??{},d=a,u="string"==typeof i?i:i?.id,c=await this.request(`/agents/${this.agentId}/generate`,{method:"POST",body:s});return"tool-calls"===c.finishReason?executeToolCallAndRespond({response:c,params:r,agentId:this.agentId,resourceId:d,threadId:u,requestContext:n,respondFn:this.generate.bind(this)}):c}async processChatResponse({stream:e,update:t,onToolCall:r,onFinish:s,getCurrentDate:o=()=>new Date,lastMessage:n}){const a="assistant"===n?.role;let i=a?1+(n.toolInvocations?.reduce(((e,t)=>Math.max(e,t.step??0)),0)??0):0;const d=a?structuredClone(n):{id:v4(),createdAt:o(),role:"assistant",content:"",parts:[]};let u,c,l;function h(e,t){const r=d.parts.find((t=>"tool-invocation"===t.type&&t.toolInvocation.toolCallId===e));null!=r?r.toolInvocation=t:d.parts.push({type:"tool-invocation",toolInvocation:t})}const p=[];let m=a?n?.annotations:void 0;const g={};let y={completionTokens:NaN,promptTokens:NaN,totalTokens:NaN},S="unknown";function I(){const e=[...p];m?.length&&(d.annotations=m);const r={...structuredClone(d),revisionId:v4()};t({message:r,data:e,replaceLastMessage:a})}await processDataStream({stream:e,onTextPart(e){null==u?(u={type:"text",text:e},d.parts.push(u)):u.text+=e,d.content+=e,I()},onReasoningPart(e){null==l?(l={type:"text",text:e},null!=c&&c.details.push(l)):l.text+=e,null==c?(c={type:"reasoning",reasoning:e,details:[l]},d.parts.push(c)):c.reasoning+=e,d.reasoning=(d.reasoning??"")+e,I()},onReasoningSignaturePart(e){null!=l&&(l.signature=e.signature)},onRedactedReasoningPart(e){null==c&&(c={type:"reasoning",reasoning:"",details:[]},d.parts.push(c)),c.details.push({type:"redacted",data:e.data}),l=void 0,I()},onFilePart(e){d.parts.push({type:"file",mimeType:e.mimeType,data:e.data}),I()},onSourcePart(e){d.parts.push({type:"source",source:e}),I()},onToolCallStreamingStartPart(e){null==d.toolInvocations&&(d.toolInvocations=[]),g[e.toolCallId]={text:"",step:i,toolName:e.toolName,index:d.toolInvocations.length};const t={state:"partial-call",step:i,toolCallId:e.toolCallId,toolName:e.toolName,args:void 0};d.toolInvocations.push(t),h(e.toolCallId,t),I()},onToolCallDeltaPart(e){const t=g[e.toolCallId];t.text+=e.argsTextDelta;const{value:r}=parsePartialJson(t.text),s={state:"partial-call",step:t.step,toolCallId:e.toolCallId,toolName:t.toolName,args:r};d.toolInvocations[t.index]=s,h(e.toolCallId,s),I()},async onToolCallPart(e){const t={state:"call",step:i,...e};if(null!=g[e.toolCallId]?d.toolInvocations[g[e.toolCallId].index]=t:(null==d.toolInvocations&&(d.toolInvocations=[]),d.toolInvocations.push(t)),h(e.toolCallId,t),I(),r){const t=await r({toolCall:e});if(null!=t){const r={state:"result",step:i,...e,result:t};d.toolInvocations[d.toolInvocations.length-1]=r,h(e.toolCallId,r),I()}}},onToolResultPart(e){const t=d.toolInvocations;if(null==t)throw new Error("tool_result must be preceded by a tool_call");const r=t.findIndex((t=>t.toolCallId===e.toolCallId));if(-1===r)throw new Error("tool_result must be preceded by a tool_call with the same toolCallId");const s={...t[r],state:"result",...e};t[r]=s,h(e.toolCallId,s),I()},onDataPart(e){p.push(...e),I()},onMessageAnnotationsPart(e){null==m?m=[...e]:m.push(...e),I()},onFinishStepPart(e){i+=1,u=e.isContinued?u:void 0,c=void 0,l=void 0},onStartStepPart(e){a||(d.id=e.messageId),d.parts.push({type:"step-start"}),I()},onFinishMessagePart(e){S=e.finishReason,null!=e.usage&&(y=e.usage)},onErrorPart(e){throw new Error(e)}}),s?.({message:d,finishReason:S,usage:y})}async streamLegacy(e){const t={...e,output:e.output?zodToJsonSchema(e.output):void 0,experimental_output:e.experimental_output?zodToJsonSchema(e.experimental_output):void 0,requestContext:parseClientRequestContext(e.requestContext),clientTools:processClientTools(e.clientTools)},{readable:r,writable:s}=new TransformStream,o=await this.processStreamResponseLegacy(t,s),n=new Response(r,{status:o.status,statusText:o.statusText,headers:o.headers});return n.processDataStream=async(e={})=>{await processDataStream({stream:n.body,...e})},n}async processChatResponse_vNext({stream:e,update:t,onToolCall:r,onFinish:s,getCurrentDate:o=()=>new Date,lastMessage:n}){const a="assistant"===n?.role;let i=a?1+(n.toolInvocations?.reduce(((e,t)=>Math.max(e,t.step??0)),0)??0):0;const d=a?structuredClone(n):{id:v4(),createdAt:o(),role:"assistant",content:"",parts:[]};let u,c,l;function h(e,t){const r=d.parts.find((t=>"tool-invocation"===t.type&&t.toolInvocation.toolCallId===e));null!=r?r.toolInvocation=t:d.parts.push({type:"tool-invocation",toolInvocation:t})}const p=[];let m=a?n?.annotations:void 0;const g={};let y={completionTokens:NaN,promptTokens:NaN,totalTokens:NaN},S="unknown";function I(){const e=[...p];m?.length&&(d.annotations=m);const r={...structuredClone(d),revisionId:v4()};t({message:r,data:e,replaceLastMessage:a})}await processMastraStream({stream:e,onChunk:async e=>{switch(e.type){case"tripwire":d.parts.push({type:"text",text:e.payload.reason}),I();break;case"step-start":a||(d.id=e.payload.messageId),d.parts.push({type:"step-start"}),I();break;case"text-delta":null==u?(u={type:"text",text:e.payload.text},d.parts.push(u)):u.text+=e.payload.text,d.content+=e.payload.text,I();break;case"reasoning-delta":null==l?(l={type:"text",text:e.payload.text},null!=c&&c.details.push(l)):l.text+=e.payload.text,null==c?(c={type:"reasoning",reasoning:e.payload.text,details:[l]},d.parts.push(c)):c.reasoning+=e.payload.text,d.reasoning=(d.reasoning??"")+e.payload.text,I();break;case"file":d.parts.push({type:"file",mimeType:e.payload.mimeType,data:e.payload.data}),I();break;case"source":d.parts.push({type:"source",source:e.payload.source}),I();break;case"tool-call":{const t={state:"call",step:i,...e.payload};if(null!=g[e.payload.toolCallId]?d.toolInvocations[g[e.payload.toolCallId].index]=t:(null==d.toolInvocations&&(d.toolInvocations=[]),d.toolInvocations.push(t)),h(e.payload.toolCallId,t),I(),r){const t=await r({toolCall:e.payload});if(null!=t){const r={state:"result",step:i,...e.payload,result:t};d.toolInvocations[d.toolInvocations.length-1]=r,h(e.payload.toolCallId,r),I()}}}case"tool-call-input-streaming-start":{null==d.toolInvocations&&(d.toolInvocations=[]),g[e.payload.toolCallId]={text:"",step:i,toolName:e.payload.toolName,index:d.toolInvocations.length};const t={state:"partial-call",step:i,toolCallId:e.payload.toolCallId,toolName:e.payload.toolName,args:e.payload.args};d.toolInvocations.push(t),h(e.payload.toolCallId,t),I();break}case"tool-call-delta":{const t=g[e.payload.toolCallId];t.text+=e.payload.argsTextDelta;const{value:r}=parsePartialJson(t.text),s={state:"partial-call",step:t.step,toolCallId:e.payload.toolCallId,toolName:t.toolName,args:r};d.toolInvocations[t.index]=s,h(e.payload.toolCallId,s),I();break}case"tool-result":{const t=d.toolInvocations;if(null==t)throw new Error("tool_result must be preceded by a tool_call");const r=t.findIndex((t=>t.toolCallId===e.payload.toolCallId));if(-1===r)throw new Error("tool_result must be preceded by a tool_call with the same toolCallId");const s={...t[r],state:"result",...e.payload};t[r]=s,h(e.payload.toolCallId,s),I();break}case"error":throw getErrorFromUnknown(e.payload.error,{fallbackMessage:"Unknown error in stream",supportSerialization:!1});case"data":p.push(...e.payload.data),I();break;case"step-finish":i+=1,u=e.payload.stepResult.isContinued?u:void 0,c=void 0,l=void 0,I();break;case"finish":S=e.payload.stepResult.reason,null!=e.payload.usage&&(y=e.payload.usage)}}}),s?.({message:d,finishReason:S,usage:y})}async processStreamResponse(e,t,r="stream"){const{memory:s}=e??{},{resource:o,thread:n}=s??{},a=e.threadId??("string"==typeof n?n:n?.id),i=e.resourceId??o,d=await this.request(`/agents/${this.agentId}/${r}`,{method:"POST",body:e,stream:!0});if(!d.body)throw new Error("No response body");try{let r=[],s=[];const[o,n]=d.body.tee(),u=o.pipeTo(new WritableStream({async write(e){try{const r=(new TextDecoder).decode(e),s=r.split("\n\n").filter((e=>"[DONE]"!==e.trim()&&"data: [DONE]"!==e.trim())).join("\n\n");if(s){const e=(new TextEncoder).encode(s);t.enqueue(e)}}catch(r){console.error("Error enqueueing to controller:",r),t.enqueue(e)}}})).catch((e=>{console.error("Error piping to controller:",e);try{t.close()}catch{}}));this.processChatResponse_vNext({stream:n,update:({message:e})=>{const t=s.findIndex((t=>t.id===e.id));-1!==t?s[t]=e:s.push(e)},onFinish:async({finishReason:o,message:n})=>{if("tool-calls"===o){const o=[...n?.parts??[]].reverse().find((e=>"tool-invocation"===e.type))?.toolInvocation;o&&r.push(o);let c=!1;for(const o of r){const r=e.clientTools?.[o.toolName];if(r&&r.execute){c=!0;const n=await r.execute(o?.args,{requestContext:e.requestContext,tracingContext:{currentSpan:void 0},agent:{agentId:this.agentId,messages:d.messages,toolCallId:o?.toolCallId,suspend:async()=>{},threadId:a,resourceId:i}}),u=s[s.length-1],l=null!=u?JSON.parse(JSON.stringify(u)):void 0,h=l?.parts?.find((e=>"tool-invocation"===e.type&&e.toolInvocation?.toolCallId===o.toolCallId));h&&(h.toolInvocation={...h.toolInvocation,state:"result",result:n});const p=l?.toolInvocations?.find((e=>e.toolCallId===o.toolCallId));p&&(p.state="result",p.result=n);const m=null!=l?[...s.filter((e=>e.id!==l.id)),l]:[...s],g=a?m:[...Array.isArray(e.messages)?e.messages:[],...m];try{await this.processStreamResponse({...e,messages:g},t)}catch(e){console.error("Error processing recursive stream response:",e)}}}c||(await u,t.close())}else await u,t.close()},lastMessage:void 0}).catch((async e=>{console.error("Error processing stream response:",e);try{await u,t.close()}catch{}}))}catch(e){console.error("Error processing stream response:",e)}return d}async network(e,t){const r={...t,messages:e,requestContext:parseClientRequestContext(t.requestContext),structuredOutput:t.structuredOutput?{...t.structuredOutput,schema:zodToJsonSchema(t.structuredOutput.schema)}:void 0},s=await this.request(`/agents/${this.agentId}/network`,{method:"POST",body:r,stream:!0});if(!s.body)throw new Error("No response body");const o=new Response(s.body,{status:s.status,statusText:s.statusText,headers:s.headers});return o.processDataStream=async({onChunk:e})=>{await processMastraNetworkStream({stream:o.body,onChunk:e})},o}async approveNetworkToolCall(e){const{requestContext:t,...r}=e,s=await this.request(`/agents/${this.agentId}/approve-network-tool-call`,{method:"POST",body:{...r,requestContext:parseClientRequestContext(t)},stream:!0});if(!s.body)throw new Error("No response body");const o=new Response(s.body,{status:s.status,statusText:s.statusText,headers:s.headers});return o.processDataStream=async({onChunk:e})=>{await processMastraNetworkStream({stream:o.body,onChunk:e})},o}async declineNetworkToolCall(e){const{requestContext:t,...r}=e,s=await this.request(`/agents/${this.agentId}/decline-network-tool-call`,{method:"POST",body:{...r,requestContext:parseClientRequestContext(t)},stream:!0});if(!s.body)throw new Error("No response body");const o=new Response(s.body,{status:s.status,statusText:s.statusText,headers:s.headers});return o.processDataStream=async({onChunk:e})=>{await processMastraNetworkStream({stream:o.body,onChunk:e})},o}async stream(e,t){let r,s={messages:e,...t};s.structuredOutput?.schema&&(r={...s.structuredOutput,schema:standardSchemaToJSONSchema(toStandardSchema(s.structuredOutput.schema))});const o={...s,requestContext:parseClientRequestContext(s.requestContext),clientTools:processClientTools(s.clientTools),structuredOutput:r};let n;const a=new ReadableStream({start(e){n=e}}),i=await this.processStreamResponse(o,n),d=new Response(a,{status:i.status,statusText:i.statusText,headers:i.headers});return d.processDataStream=async({onChunk:e})=>{await processMastraStream({stream:d.body,onChunk:e})},d}async approveToolCall(e){const{requestContext:t,...r}=e,s={...r,requestContext:parseClientRequestContext(t)};let o;const n=new ReadableStream({start(e){o=e}}),a=await this.processStreamResponse(s,o,"approve-tool-call"),i=new Response(n,{status:a.status,statusText:a.statusText,headers:a.headers});return i.processDataStream=async({onChunk:e})=>{await processMastraStream({stream:i.body,onChunk:e})},i}async declineToolCall(e){const{requestContext:t,...r}=e,s={...r,requestContext:parseClientRequestContext(t)};let o;const n=new ReadableStream({start(e){o=e}}),a=await this.processStreamResponse(s,o,"decline-tool-call"),i=new Response(n,{status:a.status,statusText:a.statusText,headers:a.headers});return i.processDataStream=async({onChunk:e})=>{await processMastraStream({stream:i.body,onChunk:e})},i}async approveToolCallGenerate(e){const{requestContext:t,...r}=e;return this.request(`/agents/${this.agentId}/approve-tool-call-generate`,{method:"POST",body:{...r,requestContext:parseClientRequestContext(t)}})}async declineToolCallGenerate(e){const{requestContext:t,...r}=e;return this.request(`/agents/${this.agentId}/decline-tool-call-generate`,{method:"POST",body:{...r,requestContext:parseClientRequestContext(t)}})}async processStreamResponseLegacy(e,t){const{memory:r}=e??{},{resource:s,thread:o}=r??{},n=e.threadId??("string"==typeof o?o:o?.id),a=e.resourceId??s,i=await this.request(`/agents/${this.agentId}/stream-legacy`,{method:"POST",body:e,stream:!0});if(!i.body)throw new Error("No response body");try{let r=[],s=[];const[o,d]=i.body.tee();o.pipeTo(t,{preventClose:!0}).catch((e=>{console.error("Error piping to writable stream:",e)})),this.processChatResponse({stream:d,update:({message:e})=>{const t=s.findIndex((t=>t.id===e.id));-1!==t?s[t]=e:s.push(e)},onFinish:async({finishReason:o,message:d})=>{if("tool-calls"===o){const o=[...d?.parts??[]].reverse().find((e=>"tool-invocation"===e.type))?.toolInvocation;o&&r.push(o);for(const o of r){const r=e.clientTools?.[o.toolName];if(r&&r.execute){const d=await r.execute(o?.args,{requestContext:e.requestContext,tracingContext:{currentSpan:void 0},agent:{agentId:this.agentId,messages:i.messages,toolCallId:o?.toolCallId,suspend:async()=>{},threadId:n,resourceId:a}}),u=JSON.parse(JSON.stringify(s[s.length-1])),c=u?.parts?.find((e=>"tool-invocation"===e.type&&e.toolInvocation?.toolCallId===o.toolCallId));c&&(c.toolInvocation={...c.toolInvocation,state:"result",result:d});const l=u?.toolInvocations?.find((e=>e.toolCallId===o.toolCallId));l&&(l.state="result",l.result=d);const h=t.getWriter();try{await h.write((new TextEncoder).encode("a:"+JSON.stringify({toolCallId:o.toolCallId,result:d})+"\n"))}finally{h.releaseLock()}const p=[...s.filter((e=>e.id!==u.id)),u],m=n?p:[...Array.isArray(e.messages)?e.messages:[],...p];this.processStreamResponseLegacy({...e,messages:m},t).catch((e=>{console.error("Error processing stream response:",e)}))}}}else setTimeout((()=>{t.close()}),0)},lastMessage:void 0}).catch((e=>{console.error("Error processing stream response:",e)}))}catch(e){console.error("Error processing stream response:",e)}return i}getTool(e,t){return this.request(`/agents/${this.agentId}/tools/${e}${this.getQueryString(t)}`)}executeTool(e,t){const r={data:t.data,requestContext:parseClientRequestContext(t.requestContext)};return this.request(`/agents/${this.agentId}/tools/${e}/execute`,{method:"POST",body:r})}updateModel(e){return this.request(`/agents/${this.agentId}/model`,{method:"POST",body:e})}resetModel(){return this.request(`/agents/${this.agentId}/model/reset`,{method:"POST",body:{}})}updateModelInModelList({modelConfigId:e,...t}){return this.request(`/agents/${this.agentId}/models/${e}`,{method:"POST",body:t})}reorderModelList(e){return this.request(`/agents/${this.agentId}/models/reorder`,{method:"POST",body:e})}},MemoryThread=class extends BaseResource{constructor(e,t,r){super(e),this.threadId=t,this.agentId=r}threadId;agentId;getAgentIdQueryParam(e="?"){return this.agentId?`${e}agentId=${this.agentId}`:""}get(e){const t=this.getAgentIdQueryParam("?"),r=requestContextQueryString(e,t?"&":"?");return this.request(`/memory/threads/${this.threadId}${t}${r}`)}update(e){const t=this.getAgentIdQueryParam("?"),r=requestContextQueryString(e.requestContext,t?"&":"?");return this.request(`/memory/threads/${this.threadId}${t}${r}`,{method:"PATCH",body:e})}delete(e){const t=this.getAgentIdQueryParam("?"),r=requestContextQueryString(e,t?"&":"?");return this.request(`/memory/threads/${this.threadId}${t}${r}`,{method:"DELETE"})}listMessages(e={}){const{page:t,perPage:r,orderBy:s,filter:o,include:n,resourceId:a,requestContext:i,includeSystemReminders:d}=e,u={};this.agentId&&(u.agentId=this.agentId),a&&(u.resourceId=a),void 0!==t&&(u.page=String(t)),void 0!==r&&(u.perPage=String(r)),s&&(u.orderBy=JSON.stringify(s)),o&&(u.filter=JSON.stringify(o)),n&&(u.include=JSON.stringify(n)),void 0!==d&&(u.includeSystemReminders=String(d));const c=new URLSearchParams(u).toString(),l=`/memory/threads/${this.threadId}/messages${c?`?${c}`:""}${requestContextQueryString(i,c?"&":"?")}`;return this.request(l)}deleteMessages(e,t){const r={};this.agentId&&(r.agentId=this.agentId);const s=new URLSearchParams(r).toString();return this.request(`/memory/messages/delete${s?`?${s}`:""}${requestContextQueryString(t,s?"&":"?")}`,{method:"POST",body:{messageIds:e}})}clone(e={}){const{requestContext:t,...r}=e,s=this.getAgentIdQueryParam("?"),o=requestContextQueryString(t,s?"&":"?");return this.request(`/memory/threads/${this.threadId}/clone${s}${o}`,{method:"POST",body:r})}},Vector=class extends BaseResource{constructor(e,t){super(e),this.vectorName=t}vectorName;details(e,t){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/indexes/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}delete(e){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/indexes/${encodeURIComponent(e)}`,{method:"DELETE"})}getIndexes(e){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/indexes${requestContextQueryString(e)}`)}createIndex(e){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/create-index`,{method:"POST",body:e})}upsert(e){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/upsert`,{method:"POST",body:e})}query(e){return this.request(`/vector/${encodeURIComponent(this.vectorName)}/query`,{method:"POST",body:e})}},Tool=class extends BaseResource{constructor(e,t){super(e),this.toolId=t}toolId;details(e){return this.request(`/tools/${this.toolId}${requestContextQueryString(e)}`)}execute(e){const t=new URLSearchParams;e.runId&&t.set("runId",e.runId);const r={data:e.data,requestContext:parseClientRequestContext(e.requestContext)};return this.request(`/tools/${this.toolId}/execute?${t.toString()}`,{method:"POST",body:r})}},Processor=class extends BaseResource{constructor(e,t){super(e),this.processorId=t}processorId;details(e){return this.request(`/processors/${this.processorId}${requestContextQueryString(e)}`)}execute(e){const t={phase:e.phase,messages:e.messages,agentId:e.agentId,requestContext:parseClientRequestContext(e.requestContext)};return this.request(`/processors/${this.processorId}/execute`,{method:"POST",body:t})}},ConversationItems=class extends BaseResource{constructor(e){super(e)}list(e,t){return this.request(`/v1/conversations/${encodeURIComponent(e)}/items${requestContextQueryString(t)}`)}},Conversations=class extends BaseResource{items;constructor(e){super(e),this.items=new ConversationItems(e)}create(e){const{requestContext:t,...r}=e;return this.request(`/v1/conversations${requestContextQueryString(t)}`,{method:"POST",body:r})}retrieve(e,t){return this.request(`/v1/conversations/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}delete(e,t){return this.request(`/v1/conversations/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}};function deserializeWorkflowError(e){return"failed"===e.status&&e.error&&(e.error=getErrorFromUnknown(e.error,{fallbackMessage:"Unknown workflow error",supportSerialization:!1})),e}var RECORD_SEPARATOR="",Run=class extends BaseResource{constructor(e,t,r){super(e),this.workflowId=t,this.runId=r}workflowId;runId;createChunkTransformStream(){let e;return new TransformStream({start(){},async transform(t,r){try{const s=(new TextDecoder).decode(t).split(RECORD_SEPARATOR);for(const t of s)if(t){const s=e?e+t:t;try{const t=JSON.parse(s);r.enqueue(t),e=void 0}catch{e=s}}}catch{}}})}cancelRun(){return this.request(`/workflows/${this.workflowId}/runs/${this.runId}/cancel`,{method:"POST"})}cancel(){return this.request(`/workflows/${this.workflowId}/runs/${this.runId}/cancel`,{method:"POST"})}start(e){const t=parseClientRequestContext(e.requestContext);return this.request(`/workflows/${this.workflowId}/start?runId=${this.runId}`,{method:"POST",body:{inputData:e?.inputData,initialState:e?.initialState,requestContext:t,tracingOptions:e.tracingOptions,perStep:e.perStep}})}resume({step:e,resumeData:t,tracingOptions:r,perStep:s,...o}){const n=parseClientRequestContext(o.requestContext);return this.request(`/workflows/${this.workflowId}/resume?runId=${this.runId}`,{method:"POST",body:{step:e,resumeData:t,requestContext:n,tracingOptions:r,perStep:s}})}startAsync(e){const t=new URLSearchParams;t.set("runId",this.runId);const r=parseClientRequestContext(e.requestContext);return this.request(`/workflows/${this.workflowId}/start-async?${t.toString()}`,{method:"POST",body:{inputData:e.inputData,initialState:e.initialState,requestContext:r,tracingOptions:e.tracingOptions,resourceId:e.resourceId,perStep:e.perStep}}).then(deserializeWorkflowError)}async stream(e){const t=new URLSearchParams;t.set("runId",this.runId);const r=parseClientRequestContext(e.requestContext),s=await this.request(`/workflows/${this.workflowId}/stream?${t.toString()}`,{method:"POST",body:{inputData:e.inputData,initialState:e.initialState,requestContext:r,tracingOptions:e.tracingOptions,resourceId:e.resourceId,perStep:e.perStep,closeOnSuspend:e.closeOnSuspend},stream:!0});if(!s.ok)throw new Error(`Failed to stream workflow: ${s.statusText}`);if(!s.body)throw new Error("Response body is null");return s.body.pipeThrough(this.createChunkTransformStream())}async observeStream(){const e=new URLSearchParams;e.set("runId",this.runId);const t=await this.request(`/workflows/${this.workflowId}/observe-stream?${e.toString()}`,{method:"POST",stream:!0});if(!t.ok)throw new Error(`Failed to observe workflow stream: ${t.statusText}`);if(!t.body)throw new Error("Response body is null");return t.body.pipeThrough(this.createChunkTransformStream())}resumeAsync(e){const t=parseClientRequestContext(e.requestContext);return this.request(`/workflows/${this.workflowId}/resume-async?runId=${this.runId}`,{method:"POST",body:{step:e.step,resumeData:e.resumeData,requestContext:t,tracingOptions:e.tracingOptions,perStep:e.perStep}}).then(deserializeWorkflowError)}async resumeStream(e){const t=new URLSearchParams;t.set("runId",this.runId);const r=parseClientRequestContext(e.requestContext),s=await this.request(`/workflows/${this.workflowId}/resume-stream?${t.toString()}`,{method:"POST",body:{step:e.step,resumeData:e.resumeData,requestContext:r,tracingOptions:e.tracingOptions,perStep:e.perStep},stream:!0});if(!s.ok)throw new Error(`Failed to stream vNext workflow: ${s.statusText}`);if(!s.body)throw new Error("Response body is null");return s.body.pipeThrough(this.createChunkTransformStream())}restart(e){const t=parseClientRequestContext(e.requestContext);return this.request(`/workflows/${this.workflowId}/restart?runId=${this.runId}`,{method:"POST",body:{requestContext:t,tracingOptions:e.tracingOptions}})}restartAsync(e){const t=parseClientRequestContext(e?.requestContext);return this.request(`/workflows/${this.workflowId}/restart-async?runId=${this.runId}`,{method:"POST",body:{requestContext:t,tracingOptions:e?.tracingOptions}}).then(deserializeWorkflowError)}timeTravel({requestContext:e,...t}){const r=parseClientRequestContext(e);return this.request(`/workflows/${this.workflowId}/time-travel?runId=${this.runId}`,{method:"POST",body:{...t,requestContext:r}})}timeTravelAsync({requestContext:e,...t}){const r=parseClientRequestContext(e);return this.request(`/workflows/${this.workflowId}/time-travel-async?runId=${this.runId}`,{method:"POST",body:{...t,requestContext:r}}).then(deserializeWorkflowError)}async timeTravelStream({requestContext:e,...t}){const r=parseClientRequestContext(e),s=await this.request(`/workflows/${this.workflowId}/time-travel-stream?runId=${this.runId}`,{method:"POST",body:{...t,requestContext:r},stream:!0});if(!s.ok)throw new Error(`Failed to time travel workflow: ${s.statusText}`);if(!s.body)throw new Error("Response body is null");return s.body.pipeThrough(this.createChunkTransformStream())}},RECORD_SEPARATOR2="",Workflow=class extends BaseResource{constructor(e,t){super(e),this.workflowId=t}workflowId;details(e){return this.request(`/workflows/${this.workflowId}${requestContextQueryString(e)}`)}runs(e,t){const r=base64RequestContext(parseClientRequestContext(t)),s=new URLSearchParams;return e?.fromDate&&s.set("fromDate",e.fromDate.toISOString()),e?.toDate&&s.set("toDate",e.toDate.toISOString()),void 0!==e?.page&&s.set("page",String(e.page)),void 0!==e?.perPage&&s.set("perPage",String(e.perPage)),null!=e?.limit&&(!1===e.limit?s.set("limit","false"):"number"==typeof e.limit&&e.limit>0&&Number.isInteger(e.limit)&&s.set("limit",String(e.limit))),null==e?.offset||isNaN(Number(e?.offset))||s.set("offset",String(e.offset)),e?.resourceId&&s.set("resourceId",e.resourceId),e?.status&&s.set("status",e.status),r&&s.set("requestContext",r),s.size?this.request(`/workflows/${this.workflowId}/runs?${s}`):this.request(`/workflows/${this.workflowId}/runs`)}runById(e,t){const r=new URLSearchParams;t?.fields&&t.fields.length>0&&r.set("fields",t.fields.join(",")),void 0!==t?.withNestedWorkflows&&r.set("withNestedWorkflows",String(t.withNestedWorkflows));const s=base64RequestContext(parseClientRequestContext(t?.requestContext));s&&r.set("requestContext",s);const o=r.size>0?`?${r.toString()}`:"";return this.request(`/workflows/${this.workflowId}/runs/${e}${o}`)}deleteRunById(e){return this.request(`/workflows/${this.workflowId}/runs/${e}`,{method:"DELETE"})}async getSchema(){const e=await this.details();return{inputSchema:e.inputSchema?parseSuperJsonString(e.inputSchema):null,outputSchema:e.outputSchema?parseSuperJsonString(e.outputSchema):null}}async createRun(e){const t=new URLSearchParams;e?.runId&&t.set("runId",e.runId);const r=await this.request(`/workflows/${this.workflowId}/create-run?${t.toString()}`,{method:"POST",body:{resourceId:e?.resourceId,disableScorers:e?.disableScorers}});return new Run(this.options,this.workflowId,r.runId)}static createRecordStream(e){const t=new TextEncoder;return new ReadableStream({async start(r){try{for await(const s of e){const e=JSON.stringify(s)+RECORD_SEPARATOR2;r.enqueue(t.encode(e))}r.close()}catch(e){r.error(e)}}})}},A2A=class extends BaseResource{constructor(e,t){super(e),this.agentId=t}agentId;async getCard(){return this.request(`/.well-known/${this.agentId}/agent-card.json`)}async sendMessage(e){return await this.request(`/a2a/${this.agentId}`,{method:"POST",body:{jsonrpc:"2.0",id:crypto.randomUUID(),method:"message/send",params:e}})}async sendStreamingMessage(e){return await this.request(`/a2a/${this.agentId}`,{method:"POST",body:{jsonrpc:"2.0",id:crypto.randomUUID(),method:"message/stream",params:e},stream:!0})}async getTask(e){return await this.request(`/a2a/${this.agentId}`,{method:"POST",body:{jsonrpc:"2.0",id:crypto.randomUUID(),method:"tasks/get",params:e}})}async cancelTask(e){return this.request(`/a2a/${this.agentId}`,{method:"POST",body:{jsonrpc:"2.0",id:crypto.randomUUID(),method:"tasks/cancel",params:e}})}},MCPTool=class extends BaseResource{serverId;toolId;constructor(e,t,r){super(e),this.serverId=t,this.toolId=r}details(e){return this.request(`/mcp/${encodeURIComponent(this.serverId)}/tools/${encodeURIComponent(this.toolId)}${requestContextQueryString(e)}`)}execute(e){const t={};return void 0!==e.data&&(t.data=e.data),void 0!==e.requestContext&&(t.requestContext=e.requestContext),this.request(`/mcp/${encodeURIComponent(this.serverId)}/tools/${encodeURIComponent(this.toolId)}/execute`,{method:"POST",body:Object.keys(t).length>0?t:void 0})}},RECORD_SEPARATOR3="",AgentBuilder=class extends BaseResource{constructor(e,t){super(e),this.actionId=t}actionId;transformWorkflowResult(e){return"success"===e.status?{success:e.result.success||!1,applied:e.result.applied||!1,branchName:e.result.branchName,message:e.result.message||"Agent builder action completed",validationResults:e.result.validationResults,error:e.result.error,errors:e.result.errors,stepResults:e.result.stepResults}:"failed"===e.status?{success:!1,applied:!1,message:`Agent builder action failed: ${e.error.message}`,error:e.error.message}:{success:!1,applied:!1,message:"Agent builder action was suspended",error:"Workflow suspended - manual intervention required"}}createRecordParserTransform(){let e;return new TransformStream({start(){},async transform(t,r){try{const s=(new TextDecoder).decode(t).split(RECORD_SEPARATOR3);for(const t of s)if(t){const s=e?e+t:t;try{const t=JSON.parse(s);r.enqueue(t),e=void 0}catch{e=s}}}catch{}}})}async createRun(e){const t=new URLSearchParams;e?.runId&&t.set("runId",e.runId);const r=`/agent-builder/${this.actionId}/create-run${t.toString()?`?${t.toString()}`:""}`;return this.request(r,{method:"POST"})}async startAsync(e,t){const r=new URLSearchParams;t&&r.set("runId",t);const s=parseClientRequestContext(e.requestContext),{requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/start-async${r.toString()?`?${r.toString()}`:""}`,i=await this.request(a,{method:"POST",body:{...n,requestContext:s}});return this.transformWorkflowResult(i)}async startActionRun(e,t){const r=new URLSearchParams;r.set("runId",t);const s=parseClientRequestContext(e.requestContext),{requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/start?${r.toString()}`;return this.request(a,{method:"POST",body:{...n,requestContext:s}})}async resume(e,t){const r=new URLSearchParams;r.set("runId",t);const s=parseClientRequestContext(e.requestContext),{requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/resume?${r.toString()}`;return this.request(a,{method:"POST",body:{...n,requestContext:s}})}async resumeAsync(e,t){const r=new URLSearchParams;r.set("runId",t);const s=parseClientRequestContext(e.requestContext),{requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/resume-async?${r.toString()}`,i=await this.request(a,{method:"POST",body:{...n,requestContext:s}});return this.transformWorkflowResult(i)}async*streamProcessor(e){const t=e.getReader();let r=!1,s="";try{for(;!r;){const{done:e,value:o}=await t.read();if(r=e,!e||o)try{const e=(s+(o?(new TextDecoder).decode(o):"")).split(RECORD_SEPARATOR3);s=e.pop()||"";for(const t of e)if(t&&"string"==typeof t)try{const e=JSON.parse(t);yield e}catch{}}catch{}}if(s)try{yield JSON.parse(s)}catch{}}finally{t.cancel().catch((()=>{}))}}async stream(e,t){const r=new URLSearchParams;t&&r.set("runId",t);const s=parseClientRequestContext(e.requestContext),{requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/stream${r.toString()?`?${r.toString()}`:""}`,i=await this.request(a,{method:"POST",body:{...n,requestContext:s},stream:!0});if(!i.ok)throw new Error(`Failed to stream agent builder action: ${i.statusText}`);if(!i.body)throw new Error("Response body is null");return i.body.pipeThrough(this.createRecordParserTransform())}async observeStream(e){const t=new URLSearchParams;t.set("runId",e.runId);const r=`/agent-builder/${this.actionId}/observe?${t.toString()}`,s=await this.request(r,{method:"POST",stream:!0});if(!s.ok)throw new Error(`Failed to observe agent builder action stream: ${s.statusText}`);if(!s.body)throw new Error("Response body is null");return s.body.pipeThrough(this.createRecordParserTransform())}async observeStreamLegacy(e){const t=new URLSearchParams;t.set("runId",e.runId);const r=`/agent-builder/${this.actionId}/observe-stream-legacy?${t.toString()}`,s=await this.request(r,{method:"POST",stream:!0});if(!s.ok)throw new Error(`Failed to observe agent builder action stream legacy: ${s.statusText}`);if(!s.body)throw new Error("Response body is null");return s.body.pipeThrough(this.createRecordParserTransform())}async resumeStream(e){const t=new URLSearchParams;t.set("runId",e.runId);const r=parseClientRequestContext(e.requestContext),{runId:s,requestContext:o,...n}=e,a=`/agent-builder/${this.actionId}/resume-stream?${t.toString()}`,i=await this.request(a,{method:"POST",body:{...n,requestContext:r},stream:!0});if(!i.ok)throw new Error(`Failed to resume agent builder action stream: ${i.statusText}`);if(!i.body)throw new Error("Response body is null");return i.body.pipeThrough(this.createRecordParserTransform())}async runById(e,t){const r=new URLSearchParams;t?.fields&&t.fields.length>0&&r.set("fields",t.fields.join(",")),void 0!==t?.withNestedWorkflows&&r.set("withNestedWorkflows",String(t.withNestedWorkflows));const s=r.size>0?`?${r.toString()}`:"",o=`/agent-builder/${this.actionId}/runs/${e}${s}`;return this.request(o,{method:"GET"})}async details(){return await this.request(`/agent-builder/${this.actionId}`)}async runs(e){const t=new URLSearchParams;e?.fromDate&&t.set("fromDate",e.fromDate.toISOString()),e?.toDate&&t.set("toDate",e.toDate.toISOString()),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),void 0!==e?.page&&t.set("page",String(e.page)),null!=e?.limit&&(!1===e.limit?t.set("limit","false"):"number"==typeof e.limit&&e.limit>0&&Number.isInteger(e.limit)&&t.set("limit",String(e.limit))),null==e?.offset||isNaN(Number(e?.offset))||t.set("offset",String(e.offset)),e?.resourceId&&t.set("resourceId",e.resourceId);const r=`/agent-builder/${this.actionId}/runs${t.toString()?`?${t.toString()}`:""}`;return this.request(r,{method:"GET"})}async cancelRun(e){const t=`/agent-builder/${this.actionId}/runs/${e}/cancel`;return this.request(t,{method:"POST"})}},Observability=class extends BaseResource{constructor(e){super(e)}getTrace(e){return this.request(`/observability/traces/${e}`)}getTraceTrajectory(e){return this.request(`/observability/traces/${e}/trajectory`)}getTraces(e){const{pagination:t,filters:r}=e,{page:s,perPage:o,dateRange:n}=t||{},{name:a,spanType:i,entityId:d,entityType:u}=r||{},c=new URLSearchParams;if(void 0!==s&&c.set("page",String(s)),void 0!==o&&c.set("perPage",String(o)),a&&c.set("name",a),void 0!==i&&c.set("spanType",String(i)),d&&u&&(c.set("entityId",d),c.set("entityType",u)),n){const e=JSON.stringify({start:n.start instanceof Date?n.start.toISOString():n.start,end:n.end instanceof Date?n.end.toISOString():n.end});c.set("dateRange",e)}const l=c.toString();return this.request("/observability/traces"+(l?`?${l}`:""))}listTraces(e={}){const t=toQueryParams(e,["filters","pagination","orderBy"]);return this.request("/observability/traces"+(t?`?${t}`:""))}listScoresBySpan(e){const{traceId:t,spanId:r,...s}=e,o=toQueryParams(s);return this.request(`/observability/traces/${encodeURIComponent(t)}/${encodeURIComponent(r)}/scores${o?`?${o}`:""}`)}score(e){return this.request("/observability/traces/score",{method:"POST",body:{...e}})}listLogs(e={}){const t=toQueryParams(e,["filters","pagination","orderBy"]);return this.request("/observability/logs"+(t?`?${t}`:""))}listScores(e={}){const t=toQueryParams(e,["filters","pagination","orderBy"]);return this.request("/observability/scores"+(t?`?${t}`:""))}createScore(e){return this.request("/observability/scores",{method:"POST",body:e})}getScoreAggregate(e){return this.request("/observability/scores/aggregate",{method:"POST",body:e})}getScoreBreakdown(e){return this.request("/observability/scores/breakdown",{method:"POST",body:e})}getScoreTimeSeries(e){return this.request("/observability/scores/timeseries",{method:"POST",body:e})}getScorePercentiles(e){return this.request("/observability/scores/percentiles",{method:"POST",body:e})}listFeedback(e={}){const t=toQueryParams(e,["filters","pagination","orderBy"]);return this.request("/observability/feedback"+(t?`?${t}`:""))}createFeedback(e){return this.request("/observability/feedback",{method:"POST",body:e})}getFeedbackAggregate(e){return this.request("/observability/feedback/aggregate",{method:"POST",body:e})}getFeedbackBreakdown(e){return this.request("/observability/feedback/breakdown",{method:"POST",body:e})}getFeedbackTimeSeries(e){return this.request("/observability/feedback/timeseries",{method:"POST",body:e})}getFeedbackPercentiles(e){return this.request("/observability/feedback/percentiles",{method:"POST",body:e})}getMetricAggregate(e){return this.request("/observability/metrics/aggregate",{method:"POST",body:e})}getMetricBreakdown(e){return this.request("/observability/metrics/breakdown",{method:"POST",body:e})}getMetricTimeSeries(e){return this.request("/observability/metrics/timeseries",{method:"POST",body:e})}getMetricPercentiles(e){return this.request("/observability/metrics/percentiles",{method:"POST",body:e})}getMetricNames(e={}){const t=toQueryParams(e);return this.request("/observability/discovery/metric-names"+(t?`?${t}`:""))}getMetricLabelKeys(e){const t=toQueryParams(e);return this.request("/observability/discovery/metric-label-keys"+(t?`?${t}`:""))}getMetricLabelValues(e){const t=toQueryParams(e);return this.request("/observability/discovery/metric-label-values"+(t?`?${t}`:""))}getEntityTypes(){return this.request("/observability/discovery/entity-types")}getEntityNames(e={}){const t=toQueryParams(e);return this.request("/observability/discovery/entity-names"+(t?`?${t}`:""))}getServiceNames(){return this.request("/observability/discovery/service-names")}getEnvironments(){return this.request("/observability/discovery/environments")}getTags(e={}){const t=toQueryParams(e);return this.request("/observability/discovery/tags"+(t?`?${t}`:""))}},StoredAgent=class extends BaseResource{constructor(e,t){super(e),this.storedAgentId=t}storedAgentId;details(e,t){const r=requestContextQueryString(e),s=t?.status?`status=${t.status}`:"",o=`/stored/agents/${encodeURIComponent(this.storedAgentId)}${r}${s?`${r?"&":"?"}${s}`:""}`;return this.request(o)}update(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}${requestContextQueryString(t)}`,{method:"PATCH",body:e})}delete(e){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}${requestContextQueryString(e)}`,{method:"DELETE"})}listVersions(e,t){const r=new URLSearchParams;void 0!==e?.page&&r.set("page",String(e.page)),void 0!==e?.perPage&&r.set("perPage",String(e.perPage)),e?.orderBy&&r.set("orderBy",e.orderBy),e?.sortDirection&&r.set("sortDirection",e.sortDirection);const s=r.toString(),o=requestContextQueryString(t);return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions${s?`?${s}`:""}${o?`${s?"&":"?"}${o.slice(1)}`:""}`)}createVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions${requestContextQueryString(t)}`,{method:"POST",body:e||{}})}getVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}activateVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions/${encodeURIComponent(e)}/activate${requestContextQueryString(t)}`,{method:"POST"})}restoreVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions/${encodeURIComponent(e)}/restore${requestContextQueryString(t)}`,{method:"POST"})}deleteVersion(e,t){return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}compareVersions(e,t,r){const s=new URLSearchParams;s.set("from",e),s.set("to",t);const o=requestContextQueryString(r);return this.request(`/stored/agents/${encodeURIComponent(this.storedAgentId)}/versions/compare?${s.toString()}${o?`&${o.slice(1)}`:""}`)}},StoredPromptBlock=class extends BaseResource{constructor(e,t){super(e),this.storedPromptBlockId=t}storedPromptBlockId;details(e,t){const r=requestContextQueryString(e),s=t?.status?`status=${t.status}`:"",o=`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}${r}${s?`${r?"&":"?"}${s}`:""}`;return this.request(o)}update(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}${requestContextQueryString(t)}`,{method:"PATCH",body:e})}delete(e){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}${requestContextQueryString(e)}`,{method:"DELETE"})}listVersions(e,t){const r=new URLSearchParams;void 0!==e?.page&&r.set("page",String(e.page)),void 0!==e?.perPage&&r.set("perPage",String(e.perPage)),e?.orderBy&&r.set("orderBy",e.orderBy),e?.sortDirection&&r.set("sortDirection",e.sortDirection);const s=r.toString(),o=requestContextQueryString(t,s?"&":"?");return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions${s?`?${s}`:""}${o}`)}createVersion(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions${requestContextQueryString(t)}`,{method:"POST",body:e||{}})}getVersion(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}activateVersion(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions/${encodeURIComponent(e)}/activate${requestContextQueryString(t)}`,{method:"POST"})}restoreVersion(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions/${encodeURIComponent(e)}/restore${requestContextQueryString(t)}`,{method:"POST"})}deleteVersion(e,t){return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}compareVersions(e,t,r){const s=new URLSearchParams;s.set("from",e),s.set("to",t);const o=requestContextQueryString(r,"&");return this.request(`/stored/prompt-blocks/${encodeURIComponent(this.storedPromptBlockId)}/versions/compare?${s.toString()}${o}`)}},StoredMCPClient=class extends BaseResource{constructor(e,t){super(e),this.storedMCPClientId=t}storedMCPClientId;details(e){return this.request(`/stored/mcp-clients/${encodeURIComponent(this.storedMCPClientId)}${requestContextQueryString(e)}`)}update(e,t){return this.request(`/stored/mcp-clients/${encodeURIComponent(this.storedMCPClientId)}${requestContextQueryString(t)}`,{method:"PATCH",body:e})}delete(e){return this.request(`/stored/mcp-clients/${encodeURIComponent(this.storedMCPClientId)}${requestContextQueryString(e)}`,{method:"DELETE"})}},StoredScorer=class extends BaseResource{constructor(e,t){super(e),this.storedScorerId=t}storedScorerId;details(e,t){const r=requestContextQueryString(e),s=t?.status?`status=${t.status}`:"",o=r?"&":"?",n=`/stored/scorers/${encodeURIComponent(this.storedScorerId)}${r}${s?`${r?o:"?"}${s}`:""}`;return this.request(n)}update(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}${requestContextQueryString(t)}`,{method:"PATCH",body:e})}delete(e){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}${requestContextQueryString(e)}`,{method:"DELETE"})}listVersions(e,t){const r=new URLSearchParams;void 0!==e?.page&&r.set("page",String(e.page)),void 0!==e?.perPage&&r.set("perPage",String(e.perPage)),e?.orderBy&&r.set("orderBy",e.orderBy),e?.sortDirection&&r.set("sortDirection",e.sortDirection);const s=r.toString(),o=requestContextQueryString(t);return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions${s?`?${s}`:""}${o?`${s?"&":"?"}${o.slice(1)}`:""}`)}createVersion(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions${requestContextQueryString(t)}`,{method:"POST",body:e||{}})}getVersion(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`)}activateVersion(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions/${encodeURIComponent(e)}/activate${requestContextQueryString(t)}`,{method:"POST"})}restoreVersion(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions/${encodeURIComponent(e)}/restore${requestContextQueryString(t)}`,{method:"POST"})}deleteVersion(e,t){return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}compareVersions(e,t,r){const s=new URLSearchParams;s.set("from",e),s.set("to",t);const o=requestContextQueryString(r);return this.request(`/stored/scorers/${encodeURIComponent(this.storedScorerId)}/versions/compare?${s.toString()}${o?`&${o.slice(1)}`:""}`)}},ToolProvider=class extends BaseResource{constructor(e,t){super(e),this.providerId=t}providerId;listToolkits(){return this.request(`/tool-providers/${encodeURIComponent(this.providerId)}/toolkits`)}listTools(e){const t=new URLSearchParams;e?.toolkit&&t.set("toolkit",e.toolkit),e?.search&&t.set("search",e.search),void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage));const r=t.toString();return this.request(`/tool-providers/${encodeURIComponent(this.providerId)}/tools${r?`?${r}`:""}`)}getToolSchema(e){return this.request(`/tool-providers/${encodeURIComponent(this.providerId)}/tools/${encodeURIComponent(e)}/schema`)}},ProcessorProvider=class extends BaseResource{constructor(e,t){super(e),this.providerId=t}providerId;details(){return this.request(`/processor-providers/${encodeURIComponent(this.providerId)}`)}},WorkspaceSkillResource=class extends BaseResource{constructor(e,t,r,s){super(e),this.workspaceId=t,this.skillName=r,this.skillPath=s,this.basePath=`/workspaces/${encodeURIComponent(this.workspaceId)}/skills/${encodeURIComponent(this.skillName)}`,this.pathQuery=this.skillPath?`?path=${encodeURIComponent(this.skillPath)}`:""}workspaceId;skillName;skillPath;basePath;pathQuery;details(){return this.request(`${this.basePath}${this.pathQuery}`)}listReferences(){return this.request(`${this.basePath}/references${this.pathQuery}`)}getReference(e){return this.request(`${this.basePath}/references/${encodeURIComponent(e)}${this.pathQuery}`)}},Workspace=class extends BaseResource{workspaceId;constructor(e,t){super(e),this.workspaceId=t}get basePath(){return`/workspaces/${encodeURIComponent(this.workspaceId)}`}info(){return this.request(this.basePath)}readFile(e,t){const r=new URLSearchParams;return r.set("path",e),t&&r.set("encoding",t),this.request(`${this.basePath}/fs/read?${r.toString()}`)}writeFile(e,t,r){return this.request(`${this.basePath}/fs/write`,{method:"POST",body:{path:e,content:t,encoding:r?.encoding,recursive:r?.recursive}})}listFiles(e,t){const r=new URLSearchParams;return r.set("path",e),void 0!==t&&r.set("recursive",String(t)),this.request(`${this.basePath}/fs/list?${r.toString()}`)}delete(e,t){const r=new URLSearchParams;return r.set("path",e),void 0!==t?.recursive&&r.set("recursive",String(t.recursive)),void 0!==t?.force&&r.set("force",String(t.force)),this.request(`${this.basePath}/fs/delete?${r.toString()}`,{method:"DELETE"})}mkdir(e,t){return this.request(`${this.basePath}/fs/mkdir`,{method:"POST",body:{path:e,recursive:t}})}stat(e){const t=new URLSearchParams;return t.set("path",e),this.request(`${this.basePath}/fs/stat?${t.toString()}`)}search(e){const t=new URLSearchParams;return t.set("query",e.query),void 0!==e.topK&&t.set("topK",String(e.topK)),e.mode&&t.set("mode",e.mode),void 0!==e.minScore&&t.set("minScore",String(e.minScore)),this.request(`${this.basePath}/search?${t.toString()}`)}index(e){return this.request(`${this.basePath}/index`,{method:"POST",body:e})}listSkills(){return this.request(`${this.basePath}/skills`)}searchSkills(e){const t=new URLSearchParams;return t.set("query",e.query),void 0!==e.topK&&t.set("topK",String(e.topK)),void 0!==e.minScore&&t.set("minScore",String(e.minScore)),e.skillNames&&e.skillNames.length>0&&t.set("skillNames",e.skillNames.join(",")),void 0!==e.includeReferences&&t.set("includeReferences",String(e.includeReferences)),this.request(`${this.basePath}/skills/search?${t.toString()}`)}getSkill(e,t){return new WorkspaceSkillResource(this.options,this.workspaceId,e,t)}},StoredSkill=class extends BaseResource{constructor(e,t){super(e),this.storedSkillId=t}storedSkillId;details(e){return this.request(`/stored/skills/${encodeURIComponent(this.storedSkillId)}${requestContextQueryString(e)}`)}update(e,t){return this.request(`/stored/skills/${encodeURIComponent(this.storedSkillId)}${requestContextQueryString(t)}`,{method:"PATCH",body:e})}delete(e){return this.request(`/stored/skills/${encodeURIComponent(this.storedSkillId)}${requestContextQueryString(e)}`,{method:"DELETE"})}};function getOutputText(e){return e.flatMap((e=>"message"===e.type?e.content:[])).map((e=>"string"==typeof e?.text?e.text:"")).filter(Boolean).join("")}function attachOutputText(e){return{...e,output_text:getOutputText(e.output)}}function hydrateOutputItem(e){return"message"!==e.type?e:{...e,content:e.content??[]}}function hydrateStreamEvent(e){return"object"!=typeof e||null===e||!("response"in e)||"response.created"!==e.type&&"response.in_progress"!==e.type&&"response.completed"!==e.type?"object"==typeof e&&null!==e&&"output"in e?attachOutputText(e):"object"!=typeof e||null===e||!("item"in e)||"response.output_item.added"!==e.type&&"response.output_item.done"!==e.type?e:{...e,item:hydrateOutputItem(e.item)}:{...e,response:attachOutputText(e.response)}}function parseSseBlock(e){const t=e.replace(/\r\n/g,"\n").trim();if(!t)return null;const r=t.split("\n").filter((e=>e.startsWith("data:"))).map((e=>e.slice(5).trim()));if(!r.length)return null;const s=r.join("\n");return"[DONE]"===s?null:hydrateStreamEvent(JSON.parse(s))}var ResponsesStream=class{constructor(e){this.response=e}response;asResponse(){return this.response}async*[Symbol.asyncIterator](){if(!this.response.body)return;const e=this.response.body.getReader(),t=new TextDecoder;let r="",s=!1;try{for(;;){const{done:s,value:o}=await e.read();r+=t.decode(o??new Uint8Array,{stream:!s});let n=r.indexOf("\n\n");for(;-1!==n;){const e=r.slice(0,n);r=r.slice(n+2);const t=parseSseBlock(e);t&&(yield t),n=r.indexOf("\n\n")}if(s)break}const o=parseSseBlock(r);s=!0,o&&(yield o)}finally{s||await e.cancel(),e.releaseLock()}}},Responses=class extends BaseResource{constructor(e){super(e)}async create(e){const{requestContext:t,...r}=e,s=`/v1/responses${requestContextQueryString(t)}`;if(e.stream){const e=await this.request(s,{method:"POST",body:r,stream:!0});return new ResponsesStream(e)}return attachOutputText(await this.request(s,{method:"POST",body:r}))}stream(e){return this.create({...e,stream:!0})}async retrieve(e,t){return attachOutputText(await this.request(`/v1/responses/${encodeURIComponent(e)}${requestContextQueryString(t)}`))}delete(e,t){return this.request(`/v1/responses/${encodeURIComponent(e)}${requestContextQueryString(t)}`,{method:"DELETE"})}},MastraClient=class extends BaseResource{observability;conversations;responses;constructor(e){super(e),this.observability=new Observability(e),this.conversations=new Conversations(e),this.responses=new Responses(e)}listAgents(e,t){const r=base64RequestContext(parseClientRequestContext(e)),s=new URLSearchParams;r&&s.set("requestContext",r),t&&s.set("partial","true");const o=s.toString();return this.request("/agents"+(o?`?${o}`:""))}listAgentsModelProviders(){return this.request("/agents/providers")}getAgent(e,t){return new Agent(this.options,e,t)}async listMemoryThreads(e={}){const t=new URLSearchParams;e.resourceId&&t.set("resourceId",e.resourceId),e.metadata&&t.set("metadata",JSON.stringify(e.metadata)),e.agentId&&t.set("agentId",e.agentId),void 0!==e.page&&t.set("page",e.page.toString()),void 0!==e.perPage&&t.set("perPage",e.perPage.toString()),e.orderBy&&t.set("orderBy",e.orderBy),e.sortDirection&&t.set("sortDirection",e.sortDirection);const r=t.toString(),s=await this.request(`/memory/threads${r?`?${r}`:""}${requestContextQueryString(e.requestContext,r?"&":"?")}`);return"threads"in s?s:{threads:s,total:s.length,page:e.page??0,perPage:e.perPage??100,hasMore:!1}}getMemoryConfig(e){return this.request(`/memory/config?agentId=${e.agentId}${requestContextQueryString(e.requestContext,"&")}`)}createMemoryThread(e){return this.request(`/memory/threads?agentId=${e.agentId}${requestContextQueryString(e.requestContext,"&")}`,{method:"POST",body:e})}getMemoryThread({threadId:e,agentId:t}){return new MemoryThread(this.options,e,t)}listThreadMessages(e,t={}){let r="";const s=void 0===t.includeSystemReminders?"":`includeSystemReminders=${t.includeSystemReminders}`;return r=t.networkId?`/memory/network/threads/${e}/messages?networkId=${t.networkId}${s?`&${s}`:""}${requestContextQueryString(t.requestContext,"&")}`:t.agentId?`/memory/threads/${e}/messages?agentId=${t.agentId}${s?`&${s}`:""}${requestContextQueryString(t.requestContext,"&")}`:`/memory/threads/${e}/messages${s?`?${s}`:""}${requestContextQueryString(t.requestContext,s?"&":"?")}`,this.request(r)}deleteThread(e,t={}){let r="";return t.agentId?r=`/memory/threads/${e}?agentId=${t.agentId}${requestContextQueryString(t.requestContext,"&")}`:t.networkId&&(r=`/memory/network/threads/${e}?networkId=${t.networkId}${requestContextQueryString(t.requestContext,"&")}`),this.request(r,{method:"DELETE"})}saveMessageToMemory(e){return this.request(`/memory/save-messages?agentId=${e.agentId}${requestContextQueryString(e.requestContext,"&")}`,{method:"POST",body:e})}getMemoryStatus(e,t,r){const s=new URLSearchParams({agentId:e});r?.resourceId&&s.set("resourceId",r.resourceId),r?.threadId&&s.set("threadId",r.threadId);const o=s.toString();return this.request(`/memory/status?${o}${requestContextQueryString(t,"&")}`)}getObservationalMemory(e){const t=new URLSearchParams({agentId:e.agentId});e.resourceId&&t.set("resourceId",e.resourceId),e.threadId&&t.set("threadId",e.threadId),e.from&&t.set("from",e.from instanceof Date?e.from.toISOString():e.from),e.to&&t.set("to",e.to instanceof Date?e.to.toISOString():e.to),null!=e.offset&&t.set("offset",String(e.offset)),null!=e.limit&&t.set("limit",String(e.limit));const r=t.toString();return this.request(`/memory/observational-memory?${r}${requestContextQueryString(e.requestContext,"&")}`)}awaitBufferStatus(e){return this.request(`/memory/observational-memory/buffer-status${requestContextQueryString(e.requestContext)}`,{method:"POST",body:{agentId:e.agentId,resourceId:e.resourceId,threadId:e.threadId}})}listTools(e){const t=base64RequestContext(parseClientRequestContext(e)),r=new URLSearchParams;t&&r.set("requestContext",t);const s=r.toString();return this.request("/tools"+(s?`?${s}`:""))}getTool(e){return new Tool(this.options,e)}listProcessors(e){const t=base64RequestContext(parseClientRequestContext(e)),r=new URLSearchParams;t&&r.set("requestContext",t);const s=r.toString();return this.request("/processors"+(s?`?${s}`:""))}getProcessor(e){return new Processor(this.options,e)}listWorkflows(e,t){const r=base64RequestContext(parseClientRequestContext(e)),s=new URLSearchParams;r&&s.set("requestContext",r),t&&s.set("partial","true");const o=s.toString();return this.request("/workflows"+(o?`?${o}`:""))}getWorkflow(e){return new Workflow(this.options,e)}getAgentBuilderActions(){return this.request("/agent-builder/")}getAgentBuilderAction(e){return new AgentBuilder(this.options,e)}getVector(e){return new Vector(this.options,e)}listLogs(e){const{transportId:t,fromDate:r,toDate:s,logLevel:o,filters:n,page:a,perPage:i}=e,d=n?Object.entries(n).map((([e,t])=>`${e}:${t}`)):[],u=new URLSearchParams;if(t&&u.set("transportId",t),r&&u.set("fromDate",r.toISOString()),s&&u.set("toDate",s.toISOString()),o&&u.set("logLevel",o),a&&u.set("page",String(a)),i&&u.set("perPage",String(i)),d)if(Array.isArray(d))for(const e of d)u.append("filters",e);else u.set("filters",d);return u.size?this.request(`/logs?${u}`):this.request("/logs")}getLogForRun(e){const{runId:t,transportId:r,fromDate:s,toDate:o,logLevel:n,filters:a,page:i,perPage:d}=e,u=a?Object.entries(a).map((([e,t])=>`${e}:${t}`)):[],c=new URLSearchParams;if(t&&c.set("runId",t),r&&c.set("transportId",r),s&&c.set("fromDate",s.toISOString()),o&&c.set("toDate",o.toISOString()),n&&c.set("logLevel",n),i&&c.set("page",String(i)),d&&c.set("perPage",String(d)),u)if(Array.isArray(u))for(const e of u)c.append("filters",e);else c.set("filters",u);return c.size?this.request(`/logs/${t}?${c}`):this.request(`/logs/${t}`)}listLogTransports(){return this.request("/logs/transports")}getMcpServers(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),void 0!==e?.limit&&t.set("limit",String(e.limit)),void 0!==e?.offset&&t.set("offset",String(e.offset));const r=t.toString();return this.request("/mcp/v0/servers"+(r?`?${r}`:""))}getMcpServerDetails(e,t){const r=new URLSearchParams;t?.version&&r.set("version",t.version);const s=r.toString();return this.request(`/mcp/v0/servers/${e}${s?`?${s}`:""}`)}getMcpServerTools(e){return this.request(`/mcp/${e}/tools`)}getMcpServerTool(e,t){return new MCPTool(this.options,e,t)}getA2A(e){return new A2A(this.options,e)}getWorkingMemory({agentId:e,threadId:t,resourceId:r,requestContext:s}){return this.request(`/memory/threads/${t}/working-memory?agentId=${e}&resourceId=${r}${requestContextQueryString(s,"&")}`)}searchMemory({agentId:e,resourceId:t,threadId:r,searchQuery:s,memoryConfig:o,requestContext:n}){const a=new URLSearchParams({searchQuery:s,resourceId:t,agentId:e});return r&&a.append("threadId",r),o&&a.append("memoryConfig",JSON.stringify(o)),this.request(`/memory/search?${a}${requestContextQueryString(n,"&")}`)}updateWorkingMemory({agentId:e,threadId:t,workingMemory:r,resourceId:s,requestContext:o}){return this.request(`/memory/threads/${t}/working-memory?agentId=${e}${requestContextQueryString(o,"&")}`,{method:"POST",body:{workingMemory:r,resourceId:s}})}listScorers(e){return this.request(`/scores/scorers${requestContextQueryString(e)}`)}getScorer(e){return this.request(`/scores/scorers/${encodeURIComponent(e)}`)}listScoresByScorerId(e){const{page:t,perPage:r,scorerId:s,entityId:o,entityType:n}=e,a=new URLSearchParams;o&&a.set("entityId",o),n&&a.set("entityType",n),void 0!==t&&a.set("page",String(t)),void 0!==r&&a.set("perPage",String(r));const i=a.toString();return this.request(`/scores/scorer/${encodeURIComponent(s)}${i?`?${i}`:""}`)}listScoresByRunId(e){const{runId:t,page:r,perPage:s}=e,o=new URLSearchParams;void 0!==r&&o.set("page",String(r)),void 0!==s&&o.set("perPage",String(s));const n=o.toString();return this.request(`/scores/run/${encodeURIComponent(t)}${n?`?${n}`:""}`)}listScoresByEntityId(e){const{entityId:t,entityType:r,page:s,perPage:o}=e,n=new URLSearchParams;void 0!==s&&n.set("page",String(s)),void 0!==o&&n.set("perPage",String(o));const a=n.toString();return this.request(`/scores/entity/${encodeURIComponent(r)}/${encodeURIComponent(t)}${a?`?${a}`:""}`)}saveScore(e){return this.request("/scores",{method:"POST",body:e})}getTrace(e){return this.observability.getTrace(e)}getTraceTrajectory(e){return this.observability.getTraceTrajectory(e)}getTraces(e){return this.observability.getTraces(e)}listTraces(e={}){return this.observability.listTraces(e)}listScoresBySpan(e){return this.observability.listScoresBySpan(e)}score(e){return this.observability.score(e)}listLogsVNext(e={}){return this.observability.listLogs(e)}listScores(e={}){return this.observability.listScores(e)}createScore(e){return this.observability.createScore(e)}getScoreAggregate(e){return this.observability.getScoreAggregate(e)}getScoreBreakdown(e){return this.observability.getScoreBreakdown(e)}getScoreTimeSeries(e){return this.observability.getScoreTimeSeries(e)}getScorePercentiles(e){return this.observability.getScorePercentiles(e)}listFeedback(e={}){return this.observability.listFeedback(e)}createFeedback(e){return this.observability.createFeedback(e)}getFeedbackAggregate(e){return this.observability.getFeedbackAggregate(e)}getFeedbackBreakdown(e){return this.observability.getFeedbackBreakdown(e)}getFeedbackTimeSeries(e){return this.observability.getFeedbackTimeSeries(e)}getFeedbackPercentiles(e){return this.observability.getFeedbackPercentiles(e)}getMetricAggregate(e){return this.observability.getMetricAggregate(e)}getMetricBreakdown(e){return this.observability.getMetricBreakdown(e)}getMetricTimeSeries(e){return this.observability.getMetricTimeSeries(e)}getMetricPercentiles(e){return this.observability.getMetricPercentiles(e)}getMetricNames(e={}){return this.observability.getMetricNames(e)}getMetricLabelKeys(e){return this.observability.getMetricLabelKeys(e)}getMetricLabelValues(e){return this.observability.getMetricLabelValues(e)}getEntityTypes(){return this.observability.getEntityTypes()}getEntityNames(e={}){return this.observability.getEntityNames(e)}getServiceNames(){return this.observability.getServiceNames()}getEnvironments(){return this.observability.getEnvironments()}getTags(e={}){return this.observability.getTags(e)}listStoredAgents(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),e?.orderBy&&(e.orderBy.field&&t.set("orderBy[field]",e.orderBy.field),e.orderBy.direction&&t.set("orderBy[direction]",e.orderBy.direction)),e?.authorId&&t.set("authorId",e.authorId),e?.metadata&&t.set("metadata",JSON.stringify(e.metadata));const r=t.toString();return this.request("/stored/agents"+(r?`?${r}`:""))}createStoredAgent(e){return this.request("/stored/agents",{method:"POST",body:e})}getStoredAgent(e){return new StoredAgent(this.options,e)}listStoredPromptBlocks(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),e?.orderBy&&(e.orderBy.field&&t.set("orderBy[field]",e.orderBy.field),e.orderBy.direction&&t.set("orderBy[direction]",e.orderBy.direction)),e?.authorId&&t.set("authorId",e.authorId),e?.status&&t.set("status",e.status),e?.metadata&&t.set("metadata",JSON.stringify(e.metadata));const r=t.toString();return this.request("/stored/prompt-blocks"+(r?`?${r}`:""))}createStoredPromptBlock(e){return this.request("/stored/prompt-blocks",{method:"POST",body:e})}getStoredPromptBlock(e){return new StoredPromptBlock(this.options,e)}listStoredScorers(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),e?.orderBy&&(e.orderBy.field&&t.set("orderBy[field]",e.orderBy.field),e.orderBy.direction&&t.set("orderBy[direction]",e.orderBy.direction)),e?.authorId&&t.set("authorId",e.authorId),e?.metadata&&t.set("metadata",JSON.stringify(e.metadata));const r=t.toString();return this.request("/stored/scorers"+(r?`?${r}`:""))}createStoredScorer(e){return this.request("/stored/scorers",{method:"POST",body:e})}getStoredScorer(e){return new StoredScorer(this.options,e)}listStoredMCPClients(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),e?.orderBy&&(e.orderBy.field&&t.set("orderBy[field]",e.orderBy.field),e.orderBy.direction&&t.set("orderBy[direction]",e.orderBy.direction)),e?.authorId&&t.set("authorId",e.authorId),e?.metadata&&t.set("metadata",JSON.stringify(e.metadata));const r=t.toString();return this.request("/stored/mcp-clients"+(r?`?${r}`:""))}createStoredMCPClient(e){return this.request("/stored/mcp-clients",{method:"POST",body:e})}getStoredMCPClient(e){return new StoredMCPClient(this.options,e)}listStoredSkills(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage)),e?.orderBy&&(e.orderBy.field&&t.set("orderBy[field]",e.orderBy.field),e.orderBy.direction&&t.set("orderBy[direction]",e.orderBy.direction)),e?.authorId&&t.set("authorId",e.authorId),e?.metadata&&t.set("metadata",JSON.stringify(e.metadata));const r=t.toString();return this.request("/stored/skills"+(r?`?${r}`:""))}createStoredSkill(e){return this.request("/stored/skills",{method:"POST",body:e})}getStoredSkill(e){return new StoredSkill(this.options,e)}listToolProviders(){return this.request("/tool-providers")}getToolProvider(e){return new ToolProvider(this.options,e)}getProcessorProviders(){return this.request("/processor-providers")}getProcessorProvider(e){return new ProcessorProvider(this.options,e)}getSystemPackages(){return this.request("/system/packages")}listWorkspaces(){return this.request("/workspaces")}getWorkspace(e){return new Workspace(this.options,e)}listVectors(){return this.request("/vectors")}listEmbedders(){return this.request("/embedders")}listDatasets(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage));const r=t.toString();return this.request("/datasets"+(r?`?${r}`:""))}getDataset(e){return this.request(`/datasets/${encodeURIComponent(e)}`)}createDataset(e){return this.request("/datasets",{method:"POST",body:e})}updateDataset(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}`,{method:"PATCH",body:r})}deleteDataset(e){return this.request(`/datasets/${encodeURIComponent(e)}`,{method:"DELETE"})}listDatasetItems(e,t){const r=new URLSearchParams;void 0!==t?.page&&r.set("page",String(t.page)),void 0!==t?.perPage&&r.set("perPage",String(t.perPage)),t?.search&&r.set("search",t.search),null!=t?.version&&r.set("version",String(t.version));const s=r.toString();return this.request(`/datasets/${encodeURIComponent(e)}/items${s?`?${s}`:""}`)}getDatasetItem(e,t){return this.request(`/datasets/${encodeURIComponent(e)}/items/${encodeURIComponent(t)}`)}addDatasetItem(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/items`,{method:"POST",body:r})}updateDatasetItem(e){const{datasetId:t,itemId:r,...s}=e;return this.request(`/datasets/${encodeURIComponent(t)}/items/${encodeURIComponent(r)}`,{method:"PATCH",body:s})}deleteDatasetItem(e,t){return this.request(`/datasets/${encodeURIComponent(e)}/items/${encodeURIComponent(t)}`,{method:"DELETE"})}batchInsertDatasetItems(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/items/batch`,{method:"POST",body:r})}batchDeleteDatasetItems(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/items/batch`,{method:"DELETE",body:r})}generateDatasetItems(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/generate-items`,{method:"POST",body:r})}clusterFailures(e){return this.request("/datasets/cluster-failures",{method:"POST",body:e})}getItemHistory(e,t){return this.request(`/datasets/${encodeURIComponent(e)}/items/${encodeURIComponent(t)}/history`)}getDatasetItemVersion(e,t,r){return this.request(`/datasets/${encodeURIComponent(e)}/items/${encodeURIComponent(t)}/versions/${r}`)}listDatasetVersions(e,t){const r=new URLSearchParams;void 0!==t?.page&&r.set("page",String(t.page)),void 0!==t?.perPage&&r.set("perPage",String(t.perPage));const s=r.toString();return this.request(`/datasets/${encodeURIComponent(e)}/versions${s?`?${s}`:""}`)}listExperiments(e){const t=new URLSearchParams;void 0!==e?.page&&t.set("page",String(e.page)),void 0!==e?.perPage&&t.set("perPage",String(e.perPage));const r=t.toString();return this.request("/experiments"+(r?`?${r}`:""))}getExperimentReviewSummary(){return this.request("/experiments/review-summary")}listDatasetExperiments(e,t){const r=new URLSearchParams;void 0!==t?.page&&r.set("page",String(t.page)),void 0!==t?.perPage&&r.set("perPage",String(t.perPage));const s=r.toString();return this.request(`/datasets/${encodeURIComponent(e)}/experiments${s?`?${s}`:""}`)}getDatasetExperiment(e,t){return this.request(`/datasets/${encodeURIComponent(e)}/experiments/${encodeURIComponent(t)}`)}listDatasetExperimentResults(e,t,r){const s=new URLSearchParams;void 0!==r?.page&&s.set("page",String(r.page)),void 0!==r?.perPage&&s.set("perPage",String(r.perPage));const o=s.toString();return this.request(`/datasets/${encodeURIComponent(e)}/experiments/${encodeURIComponent(t)}/results${o?`?${o}`:""}`)}updateDatasetExperimentResult(e){const{datasetId:t,experimentId:r,resultId:s,...o}=e;return this.request(`/datasets/${encodeURIComponent(t)}/experiments/${encodeURIComponent(r)}/results/${encodeURIComponent(s)}`,{method:"PATCH",body:o})}triggerDatasetExperiment(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/experiments`,{method:"POST",body:r})}updateExperimentResult(e){const{datasetId:t,experimentId:r,resultId:s,...o}=e;return this.request(`/datasets/${encodeURIComponent(t)}/experiments/${encodeURIComponent(r)}/results/${encodeURIComponent(s)}`,{method:"PATCH",body:o})}compareExperiments(e){const{datasetId:t,...r}=e;return this.request(`/datasets/${encodeURIComponent(t)}/compare`,{method:"POST",body:r})}},ClientTool=class{id;description;inputSchema;outputSchema;execute;constructor(e){this.id=e.id,this.description=e.description,this.inputSchema=e.inputSchema,this.outputSchema=e.outputSchema,this.execute=e.execute}};function createTool(e){return new ClientTool(e)}export{ClientTool,MastraClient,MastraClientError,createTool};
//# sourceMappingURL=/sm/95f0d290bd0a4697b623be8eeae5a61ee984bb34da40cb8f8154d760252c7dab.map