agentOS Apps

import { actor, setup } from "rivetkit";
import { db } from "rivetkit/db";

const notes = actor({
	db: db({
		async onMigrate(database) {
			await database.execute(`
				CREATE TABLE IF NOT EXISTS notes (
					id INTEGER PRIMARY KEY AUTOINCREMENT,
					body TEXT NOT NULL
				)
			`);
		},
	}),
	actions: {
		async add(c, body: string) {
			await c.db.execute("INSERT INTO notes (body) VALUES (?)", body);
		},
		async list(c) {
			return c.db.execute("SELECT id, body FROM notes ORDER BY id");
		},
	},
});

export const registry = setup({
	use: { notes },
});

registry.start();

export default function fetch() {
	return Response.json({
		app: "sqlite-notes",
		message: "Use the RivetKit client to add and list notes.",
	});
}

import type { Deployment } from "@rivet-dev/agentos-apps";
import { createClient } from "rivetkit/client";
import type { registry as appRegistry } from "../fixtures/app/src/index.js";

const response = await fetch("http://localhost:3000/deploy/sqlite-notes", {
	method: "POST",
});
if (!response.ok) {
	throw new Error(`deployment failed: ${response.status} ${await response.text()}`);
}
const deployment = (await response.json()) as Deployment;

const client = createClient<typeof appRegistry>({
	namespace: deployment.namespace,
	poolName: deployment.pool,
});

try {
	const notes = client.notes.getOrCreate(["shared"]);
	await notes.add("Hello from the RivetKit client");
	console.log(await notes.list());
} finally {
	await client.dispose();
}

import { actor, setup } from "rivetkit";
import { workflow } from "rivetkit/workflow";

const job = actor({
	state: {
		id: "",
		status: "queued" as "queued" | "running" | "complete",
	},
	onCreate(c) {
		c.state.id = c.key[0] ?? "";
	},
	actions: {
		inspect: (c) => c.state,
	},
	run: workflow(async (workflowContext) => {
		await workflowContext.step("start", async (c) => {
			c.state.status = "running";
		});
		await workflowContext.sleep("work", 1_000);
		await workflowContext.step("finish", async (c) => {
			c.state.status = "complete";
		});
	}),
});

export const registry = setup({
	use: { job },
});

registry.start();

export default function fetch() {
	return Response.json({
		app: "durable-workflow",
		message: "Use the RivetKit client to create and inspect jobs.",
	});
}

import type { Deployment } from "@rivet-dev/agentos-apps";
import { createClient } from "rivetkit/client";
import type { registry as appRegistry } from "../fixtures/app/src/index.js";

const response = await fetch("http://localhost:3000/deploy/durable-workflow", {
	method: "POST",
});
if (!response.ok) {
	throw new Error(`deployment failed: ${response.status} ${await response.text()}`);
}
const deployment = (await response.json()) as Deployment;

const client = createClient<typeof appRegistry>({
	namespace: deployment.namespace,
	poolName: deployment.pool,
});

try {
	const job = client.job.getOrCreate(["example-job"]);
	console.log(await job.inspect());
} finally {
	await client.dispose();
}

import { actor, event, setup } from "rivetkit";

type Position = { x: number; y: number };

const room = actor({
	state: {
		players: {} as Record<string, Position>,
	},
	events: {
		changed: event(),
	},
	actions: {
		join(c, player: string) {
			c.state.players[player] ??= { x: 0, y: 0 };
			c.broadcast("changed", c.state.players);
			return c.state.players;
		},
		move(c, player: string, x: number, y: number) {
			c.state.players[player] = { x, y };
			c.broadcast("changed", c.state.players);
			return c.state.players;
		},
		inspect(c) {
			return c.state.players;
		},
	},
});

export const registry = setup({
	use: { room },
});

registry.start();

export default function fetch() {
	return Response.json({
		app: "multiplayer-room",
		message: "Use the RivetKit client to join and move in a room.",
	});
}

import type { Deployment } from "@rivet-dev/agentos-apps";
import { createClient } from "rivetkit/client";
import type { registry as appRegistry } from "../fixtures/app/src/index.js";

const response = await fetch("http://localhost:3000/deploy/multiplayer-room", {
	method: "POST",
});
if (!response.ok) {
	throw new Error(`deployment failed: ${response.status} ${await response.text()}`);
}
const deployment = (await response.json()) as Deployment;

const client = createClient<typeof appRegistry>({
	namespace: deployment.namespace,
	poolName: deployment.pool,
});

try {
	const room = client.room.getOrCreate(["lobby"]);
	await room.join("alice");
	console.log(await room.move("alice", 4, 8));
} finally {
	await client.dispose();
}