Streaming

const stream = privata.streamOrder(orderId);

for await (const event of stream) {
  console.log(event.status, event.eventId);
  if (["completed", "failed", "expired", "refunded"].includes(event.status)) {
    break;
  }
}

interface StreamEvent {
  orderId: string;
  status: OrderStatus;
  eventId: string;     // "<order_id>:<status>:<unix_ms>"
  ts: string;          // ISO
  raw: any;            // full payload
}

const stream = privata.streamOrder(orderId);

stream.on("status", (e) => updateUi(e.status));
stream.on("resume", (source, gapMs) => {
  if (source === "snapshot") log.warn("SSE snapshot fallback, gap=" + gapMs);
});
stream.on("degraded", () => log.warn("Stream degraded to polling"));
stream.on("error", (err) => log.error(err));
stream.on("close", () => log.info("Stream closed"));

privata.streamOrder(orderId, { fallbackPollingMs: 0 });

const stream = privata.streamOrder(orderId);
stream.close();   // idempotent