Quickstart: Mastra

// src/lib/vendo.ts
import type { Principal } from "@vendoai/core";
import { createVendo, type Vendo } from "@vendoai/vendo/server";
import { getWeather, sendTripReport } from "./vendo-actions";

/** The demo runs as one fixed user. A real host resolves the principal from
 *  its own session, or passes an auth preset. */
export const DEMO_PRINCIPAL: Principal = { kind: "user", subject: "demo-user" };

export const vendo = createVendo({
  principal: async () => DEMO_PRINCIPAL,
  // "cautious" runs reads and asks before write/destructive calls. That is
  // what parks vendo_send_trip_report on the approval embed in the demo.
  policy: "cautious",
  // The registration map for .vendo/tools.json's server-action bindings.
  serverActions: {
    "src/lib/vendo-actions.ts#getWeather": getWeather,
    "src/lib/vendo-actions.ts#sendTripReport": sendTripReport,
  },
  // No model key here: app generation resolves ANTHROPIC_API_KEY /
  // OPENAI_API_KEY / VENDO_API_KEY from the environment.
});

// src/app/api/vendo/[...vendo]/route.ts
import { nextVendoHandler } from "@vendoai/vendo/server";
import { vendo } from "@/lib/vendo";

export const runtime = "nodejs";
export const dynamic = "force-dynamic";

export const { GET, POST, PUT, PATCH, DELETE } = nextVendoHandler(vendo);

// src/mastra/agents/weather-agent.ts
import { Agent } from '@mastra/core/agent';
import { Memory } from '@mastra/memory';
import { vendoMastraTools } from '@vendoai/vendo/mastra';
import { vendo } from '../../lib/vendo';
import { weatherTool } from '../tools/weather-tool';

export const weatherAgent = new Agent({
  id: 'weather-agent',
  name: 'Weather Agent',
  instructions: `…the starter's instructions, plus a short note telling the
model about its vendo_* tools…`,
  model: 'openai/gpt-4.1-mini',
  // The starter's weatherTool plus the guard-wrapped pack: vendo_get_weather,
  // vendo_send_trip_report, vendo_create_app, vendo_delegate.
  tools: async () => ({ weatherTool, ...(await vendoMastraTools(vendo)) }),
  memory: new Memory(),
});

// src/app/api/chat/route.ts
import { handleChatStream } from '@mastra/ai-sdk';
import { RequestContext } from '@mastra/core/request-context';
import { createUIMessageStreamResponse } from 'ai';
import { mastra } from '@/mastra';
import { VENDO_PRINCIPAL_KEY } from '@vendoai/vendo/mastra';
import { DEMO_PRINCIPAL, vendo } from '@/lib/vendo';

export async function POST(req: Request) {
  const params = await req.json();

  await vendo.store.ensureSchema();
  const requestContext = new RequestContext();
  requestContext.set(VENDO_PRINCIPAL_KEY, DEMO_PRINCIPAL);

  const stream = await handleChatStream({
    version: 'v6',
    mastra,
    agentId: 'weather-agent',
    params: { ...params, requestContext },
  });
  return createUIMessageStreamResponse({ stream });
}

// src/app/page.tsx (the tool-part branch)
if (part.type === "dynamic-tool" || part.type.startsWith("tool-")) {
  const tool = part as ToolLikePart;
  return tool.state === "output-available"
    ? <VendoToolResult output={tool.output} />
    : <span>Running {tool.toolName ?? part.type.slice("tool-".length)}…</span>;
}

cd examples/mastra-agent
pnpm install
cp .env.example .env   # add OPENAI_API_KEY (the starter agent's model)
pnpm dev               # http://localhost:3000