Core Package

npm install @rivet-dev/agent-os-core

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({
  software: [common],
});

// Run a command
const result = await vm.exec("echo hello");
console.log(result.stdout); // "hello\n"

await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

await vm.writeFile("/home/user/hello.txt", "Hello, world!");
const content = await vm.readFile("/home/user/hello.txt");
console.log(new TextDecoder().decode(content));

await vm.mkdir("/home/user/src");
await vm.writeFiles([
  { path: "/home/user/src/index.ts", content: "console.log('hi');" },
  { path: "/home/user/src/utils.ts", content: "export const add = (a: number, b: number) => a + b;" },
]);

const entries = await vm.readdirRecursive("/home/user");
for (const entry of entries) {
  console.log(entry.type, entry.path);
}

await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

// One-shot execution
const result = await vm.exec("ls -la /home/user");
console.log(result.stdout);

// Long-running process with streaming output
await vm.writeFile("/tmp/server.mjs", 'import http from "http"; http.createServer((req, res) => res.end("ok")).listen(3000); console.log("listening");');
const proc = vm.spawn("node", ["/tmp/server.mjs"]);
vm.onProcessStdout(proc.pid, (data) => {
  console.log("stdout:", new TextDecoder().decode(data));
});
vm.onProcessExit(proc.pid, (code) => {
  console.log("exited:", code);
});

// Write to stdin
vm.writeProcessStdin(proc.pid, "some input\n");

// Stop or kill
vm.stopProcess(proc.pid);

await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

const { sessionId } = await vm.createSession("pi", {
  env: { ANTHROPIC_API_KEY: process.env.ANTHROPIC_API_KEY! },
});

// Stream events
vm.onSessionEvent(sessionId, (event) => {
  console.log(event.method, event.params);
});

// Handle permissions
vm.onPermissionRequest(sessionId, (request) => {
  console.log("Permission:", request.description);
  vm.respondPermission(sessionId, request.permissionId, "once");
});

// Send a prompt
const response = await vm.prompt(sessionId, "Write a hello world script");
console.log(response);

// Configure the session
await vm.setSessionModel(sessionId, "claude-sonnet-4-6");
await vm.setSessionMode(sessionId, "plan");

// Event history (returns SequencedEvent[] with .sequenceNumber and .notification)
const events = vm.getSessionEvents(sessionId);
for (const event of events) {
  console.log(event.sequenceNumber, event.notification.method);
}

vm.closeSession(sessionId);
await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

const { shellId } = vm.openShell();

vm.onShellData(shellId, (data) => {
  process.stdout.write(new TextDecoder().decode(data));
});

vm.writeShell(shellId, "echo hello from shell\n");

// Resize terminal
vm.resizeShell(shellId, 120, 40);

vm.closeShell(shellId);
await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

// Start a server inside the VM
await vm.writeFile("/tmp/app.mjs", 'import http from "http"; http.createServer((req, res) => res.end("hello")).listen(3000);');
vm.spawn("node", ["/tmp/app.mjs"]);

// Fetch from it
const response = await vm.fetch(3000, new Request("http://localhost/"));
console.log(await response.text());

await vm.dispose();

import { AgentOs } from "@rivet-dev/agent-os-core";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({ software: [common] });

const job = vm.scheduleCron({
  id: "cleanup",
  schedule: "0 * * * *",
  action: { type: "exec", command: "rm", args: ["-rf", "/tmp/cache"] },
});

// Or use a callback (not available in the actor wrapper)
vm.scheduleCron({
  schedule: "*/5 * * * *",
  action: {
    type: "callback",
    fn: async () => {
      console.log("Custom logic every 5 minutes");
    },
  },
});

vm.onCronEvent((event) => {
  if (event.type === "cron:fire") console.log("Job fired:", event.jobId);
  if (event.type === "cron:complete") console.log("Job done:", event.jobId, event.durationMs, "ms");
  if (event.type === "cron:error") console.error("Job error:", event.error);
});

console.log(vm.listCronJobs());
job.cancel();

await vm.dispose();

import { AgentOs, createHostDirBackend, createInMemoryFileSystem } from "@rivet-dev/agent-os-core";
import { createS3Backend } from "@rivet-dev/agent-os-s3";
import common from "@rivet-dev/agent-os-common";

const vm = await AgentOs.create({
  software: [common],
  mounts: [
    // Host directory (read-only)
    { path: "/mnt/code", driver: createHostDirBackend({ hostPath: "/path/to/repo" }), readOnly: true },
    // S3 bucket
    { path: "/mnt/data", driver: createS3Backend({ bucket: "my-bucket", prefix: "agent/" }) },
    // In-memory scratch space
    { path: "/mnt/scratch", driver: createInMemoryFileSystem() },
  ],
});

const files = await vm.readdir("/mnt/code");
console.log(files);

await vm.dispose();