diff --git a/agents/examples/agent/client.ts b/agents/examples/agent/client.ts deleted file mode 100644 index 4eb8f47e..00000000 --- a/agents/examples/agent/client.ts +++ /dev/null @@ -1,8 +0,0 @@ -import { createClient } from "rivetkit/client"; -import type { registry } from "./index"; - -const client = createClient("http://localhost:6420"); - -const agent = client.agent.getOrCreate(["agent-123"]).connect(); -agent.on("token", (delta: string) => process.stdout.write(delta)); -await agent.queue.send("message", { text: "hello!" }); diff --git a/agents/examples/agent/index.ts b/agents/examples/agent/index.ts deleted file mode 100644 index 7e87bf06..00000000 --- a/agents/examples/agent/index.ts +++ /dev/null @@ -1,28 +0,0 @@ -import { actor, setup } from "rivetkit"; -import { streamText, type ModelMessage } from "ai"; -import { openai } from "@ai-sdk/openai"; - -// One actor per agent: its transcript is durable state, its inbox is a queue, -// and its output streams to every connected client. -export const agent = actor({ - state: { messages: [] as ModelMessage[] }, - - run: async (c) => { - for await (const msg of c.queue.iter<{ text: string }>()) { - c.state.messages.push({ role: "user", content: msg.body.text }); - - const response = streamText({ - model: openai("gpt-5"), - messages: c.state.messages, - }); - - for await (const delta of response.textStream) { - c.broadcast("token", delta); - } - - c.state.messages.push({ role: "assistant", content: await response.text }); - } - }, -}); - -export const registry = setup({ use: { agent } });