Durable Objects và realtime

// src/phong.js
export class PhongDonHang {
  constructor(state, env) {
    this.state = state;              // bộ nhớ riêng, bền
    this.env = env;
    this.ketNoi = new Set();
  }

  async fetch(request) {
    const url = new URL(request.url);

    if (url.pathname.endsWith("/ws")) return this.moWebSocket(request);

    if (url.pathname.endsWith("/them")) {
      const don = await request.json();
      const ds = (await this.state.storage.get("don")) || [];
      ds.push({ ...don, luc: Date.now() });
      await this.state.storage.put("don", ds.slice(-200));   // giữ 200 đơn gần nhất
      this.phatTin({ kieu: "don-moi", don });
      return new Response(JSON.stringify({ ok: true }));
    }

    const ds = (await this.state.storage.get("don")) || [];
    return new Response(JSON.stringify(ds));
  }

  phatTin(obj) {
    const s = JSON.stringify(obj);
    for (const ws of this.state.getWebSockets()) {
      try { ws.send(s); } catch (_) {}
    }
  }
}

[[durable_objects.bindings]]
name = "PHONG"
class_name = "PhongDonHang"

[[migrations]]
tag = "v1"
new_sqlite_classes = ["PhongDonHang"]

const id = env.PHONG.idFromName("quan-sam-son");   // tên ổn định = cùng một đối tượng
const phong = env.PHONG.get(id);
return phong.fetch(request);

  async moWebSocket(request) {
    const pair = new WebSocketPair();
    const [client, server] = Object.values(pair);

    // acceptWebSocket (KHÔNG phải server.accept()) mới cho phép ngủ đông
    this.state.acceptWebSocket(server);

    // Nhịp tim tự động: Cloudflare ping hộ, kết nối chết được dọn
    this.state.setWebSocketAutoResponse(
      new WebSocketRequestResponsePair("ping", "pong")
    );

    return new Response(null, { status: 101, webSocket: client });
  }

  // Khi ngủ đông, dùng handler này — KHÔNG dùng ws.addEventListener
  async webSocketMessage(ws, msg) {
    if (msg === "ping") return;
    // xử lý tin nhắn
  }

  async webSocketClose(ws, code, reason, wasClean) {
    // dọn dẹp nếu cần
  }

export class KhoHang {
  constructor(state) { this.state = state; }

  async fetch(request) {
    const { monId, soLuong } = await request.json();
    const ton = (await this.state.storage.get("ton:" + monId)) ?? 0;
    if (ton < soLuong) {
      return new Response(JSON.stringify({ ok: false, con: ton }), { status: 409 });
    }
    await this.state.storage.put("ton:" + monId, ton - soLuong);
    return new Response(JSON.stringify({ ok: true, con: ton - soLuong }));
  }
}