Agent Structure

import { convertToModelMessages, streamText, tool } from "ai";
import * as blink from "blink";
import { z } from "zod";

const agent = new blink.Agent();

agent.on("chat", async ({ messages }) => {
  return streamText({
    model: "anthropic/claude-sonnet-4.5",
    system: "You are a helpful assistant.",
    messages: convertToModelMessages(messages),
    tools: {
      get_favorite_number: tool({
        inputSchema: z.object({}),
        execute() {
          return 42;
        },
      }),
    },
  });
});

agent.serve();

agent.on("chat", async ({ messages, id, abortSignal }) => {
  return streamText({
    // ... configuration
  });
});

// Create or get existing chat with a unique key
const chat = await agent.chat.upsert("unique-key");

// Or use structured keys
const chat = await agent.chat.upsert(["slack", teamId, channelId, threadTs]);

await agent.chat.sendMessages(
  chat.id,
  [
    {
      role: "user",
      parts: [{ type: "text", text: "Hello!" }],
    },
  ],
  {
    behavior: "interrupt", // or "enqueue" or "append"
  }
);

agent.on("request", async (request) => {
  return new Response("Hello, world!", { status: 200 });
});

agent.on("request", async (request) => {
  const { chatName, message } = await request.json();
  const chat = await agent.chat.upsert([chatName]);
  await agent.chat.sendMessages(chat.id, [
    {
      role: "user",
      parts: [{ type: "text", text: message }],
    },
  ]);
  return new Response("Message sent", { status: 200 });
});

// Store data
await agent.store.set("user-preferences", {
  theme: "dark",
  notifications: true,
});

// Retrieve data
const prefs = await agent.store.get("user-preferences");

// Delete data
await agent.store.delete("user-preferences");

// List keys by prefix
const keys = await agent.store.list("user-", { limit: 100 });

tools: {
  // Safe tools - no approval needed
  read_file: tool({ /* ... */ }),

  // Destructive tools - require approval
  ...blink.tools.withApproval({
    messages,
    tools: {
      delete_file: tool({ /* ... */ }),
      run_command: tool({ /* ... */ }),
    },
  }),
}