gitfor/platform

import { describe, expect, test } from "bun:test";
import { fakeStorage } from "../do-test-storage";
import { Coordination } from "./coordination";

describe("Coordination.allSubscribers", () => {
  test("drops expired subscriptions like subscribersFor does", () => {
    const coordination = new Coordination(fakeStorage().sql as never);
    coordination.subscribe("live", ["*"], 60_000);
    coordination.subscribe("stale", ["*"], -1);
    expect(coordination.allSubscribers()).toEqual(["live"]);
  });
});