Durable Objects

{
  "name": "counter-api",
  "main": "worker.js",
  "compatibility_date": "2026-08-27",
  "durable_objects": {
    "bindings": [{ "name": "COUNTER", "class_name": "Counter" }]
  },
  "migrations": [
    { "tag": "v1", "new_sqlite_classes": ["Counter"] }
  ]
}

import { DurableObject } from "cloudflare:workers";

export class Counter extends DurableObject {
  constructor(ctx, env) {
    super(ctx, env);
    this.ctx.storage.sql.exec(`
      CREATE TABLE IF NOT EXISTS counters (
        name TEXT PRIMARY KEY,
        value INTEGER NOT NULL
      )
    `);
  }

  async fetch(request) {
    const name = new URL(request.url).searchParams.get("name") ?? "default";
    this.ctx.storage.sql.exec(
      `INSERT INTO counters (name, value) VALUES (?, 1)
       ON CONFLICT(name) DO UPDATE SET value = value + 1`,
      name,
    );
    const row = this.ctx.storage.sql
      .exec("SELECT value FROM counters WHERE name = ?", name)
      .one();
    return Response.json(row);
  }
}

export default {
  async fetch(request, env) {
    const id = env.COUNTER.idFromName("global");
    return env.COUNTER.get(id).fetch(request);
  },
};

await this.ctx.storage.put("status", { state: "ready" });
const status = await this.ctx.storage.get("status");
await this.ctx.storage.delete("status");

const rows = this.ctx.storage.sql
  .exec("SELECT * FROM jobs WHERE status = ?", "ready")
  .toArray();

export class Reminder extends DurableObject {
  async fetch() {
    await this.ctx.storage.setAlarm(Date.now() + 60_000);
    return new Response(null, { status: 202 });
  }

  async alarm() {
    await this.flushPendingWork();
  }
}