Serverless
с памятью

import { DurableObject } from "cloudflare:workers";

export class Flight extends DurableObject {
  // Обычный метод. Вызовы выстраиваются в очередь.
  buy() {                                                        //!
    const sql = this.ctx.storage.sql;                            //!
    const { free } = sql.exec("SELECT free FROM seats").one();   //!
    if (free === 0) return "мест нет";                           //!
    sql.exec("UPDATE seats SET free = free - 1");                //!
    return "билет ваш";                                          //!
  }                                                              //!
}

export default {
  async fetch(request, env) {
    const flight = env.FLIGHT.getByName("SU-42");  // адрес по имени
    return new Response(await flight.buy());
  },
};

export class Room extends DurableObject {
  async fetch(request) {
    const [client, server] = Object.values(new WebSocketPair());
    this.ctx.acceptWebSocket(server);       // сокет переживёт сон актора  //!
    server.serializeAttachment({ name });   // и это тоже
    server.send(JSON.stringify({ type: "history", history: this.last(50) }));
    return new Response(null, { status: 101, webSocket: client });
  }

  // Платформа будит актор на каждое сообщение
  async webSocketMessage(ws, raw) {                                       //!
    const { name } = ws.deserializeAttachment();
    const { text } = JSON.parse(raw);
    this.ctx.storage.sql.exec(
      "INSERT INTO messages(at, name, text) VALUES (?, ?, ?)",
      Date.now(), name, text);
    for (const peer of this.ctx.getWebSockets())  // все, кто в комнате    //!
      peer.send(JSON.stringify({ type: "msg", name, text }));
  }
}

examples/chat/src/index.js, сокращено

export class City extends DurableObject {
  async fetch(request) {
    const [client, server] = Object.values(new WebSocketPair());
    this.ctx.acceptWebSocket(server);
    if (this.snapshot) server.send(JSON.stringify(this.snapshot));
    // Первый зритель заводит будильник
    if ((await this.ctx.storage.getAlarm()) === null)       //!
      await this.ctx.storage.setAlarm(Date.now() + 50);     //!
    return new Response(null, { status: 101, webSocket: client });
  }

  async alarm() {
    const viewers = this.ctx.getWebSockets();
    if (viewers.length === 0) return;   // все ушли: засыпаем   //!
    const res = await fetch("https://rnd.don.su/get_bus", {
      method: "POST", body: JSON.stringify({ bus: this.routes }) });
    this.snapshot = compact(await res.json());   // 55 КБ → 10 КБ
    const frame = JSON.stringify(this.snapshot);
    for (const ws of viewers) ws.send(frame);
    await this.ctx.storage.setAlarm(Date.now() + 5000);     //!
  }
}

export class Assistant extends DurableObject {
  ai = createAI({ binding: this.env.AI });
  registry = createRegistry();
  harness = new PiHarness({                                    //!
    harness: ({ storage, context, onWake }) => {
      const models = createModels();
      models.setProvider(this.ai.provider);
      return Harness.open(storage,                 // SQLite актора
        { models, registry: this.registry, onWake }, context);
    },
    defaults: { model: this.ai("@cf/google/gemma-4-26b-a4b-it") },
  });
  lifecycle = Lifecycle.install(this).use(this.harness);       //!
  constructor(ctx, env) {
    super(ctx, env);
    this.registry.install({ name: "talk-demo", tools: [{
      name: "save_note",
      description: "Сохранить заметку в долговременную память.",
      parameters: obj({ text: str() }),
      async execute({ text }) {                                //!
        ctx.storage.sql.exec("INSERT INTO notes(text) VALUES (?)", text);
        return { output: [{ type: "text", text: "сохранено" }] };
      },
    }]});
  }
}

export class BuyTicket extends WorkflowEntrypoint {
  async run(event, step) {
    const { flight, user, card } = event.payload;

    await step.do("занять место",
      () => this.env.FLIGHT.getByName(flight).hold(user),
      { rollback: () => this.env.FLIGHT.getByName(flight).release(user) }); //!

    const { chargeId } = await step.do("списать деньги",
      { retries: { limit: 3, delay: "5 seconds", backoff: "exponential" } },
      () => bank.charge(card, 4200),
      { rollback: ({ output }) => bank.refund(output.chargeId) });          //!

    await step.do("выпустить билет",
      () => this.env.PASSENGER.getByName(user).issue(flight, chargeId));

    await step.sleep("перед письмом", "1 minute");   // хоть на месяц
    await step.do("отправить письмо", () => mail.send(user, flight));
  }
}

Результат каждого шага сохраняется. После сбоя выполнение продолжится с первого незавершённого.

import { actor, event, setup } from "rivetkit";
import { db } from "rivetkit/db";
export const room = actor({
  db: db({ onMigrate: (db) => db.execute(
    "CREATE TABLE IF NOT EXISTS messages(at, name, text)") }),
  events: { msg: event<Msg>() },                 // типы до клиента   //!
  onConnect: (c, conn) => {
    c.broadcast("join", { online: c.conns.size });
  },
  actions: {
    say: async (c, text: string) => {                               //!
      const m = { at: Date.now(), name: nameOf(c), text };
      await c.db.execute(
        "INSERT INTO messages VALUES (?, ?, ?)", m.at, m.name, m.text);
      c.broadcast("msg", m);                                        //!
    },
  },
});
export const registry = setup({ use: { room } });

lab/rivet/app/index.ts, сокращено. RivetKit 3.0.7, Apache 2.0