import webPush from "web-push";

import {

broadcastWebPush,

clearWebPushSubscription,

clearWebPushSubscriptionByEndpoint,

listWebPushSubscriptions,

loadWebPushSubscription,

registerWebPushSubscription,

resolveVapidKeys,

sendWebPushNotification,

} from "./push-web.js";

type WebPushSubscription = NonNullable<Awaited<ReturnType<typeof loadWebPushSubscription>>>;

// Stub resolveStateDir so tests use a temp directory.

let tmpDir: string;

vi.mock("../config/paths.js", () => ({

},

}));

function expectLoadedSubscription(

loaded: Awaited<ReturnType<typeof loadWebPushSubscription>>,

): WebPushSubscription {

if (loaded === null) {

throw new Error("Expected loaded web push subscription");

}

expect(loaded.endpoint).not.toBe("");

return loaded;

}

beforeEach(async () => {

tmpDir = await fs.mkdtemp(path.join(os.tmpdir(), "push-web-test-"));

vi.clearAllMocks();

expect(sub2.keys.p256dh).toBe("new-p256dh");

});

it("loads a subscription by ID", async () => {

const sub = await registerWebPushSubscription({

endpoint,

keys,

baseDir: tmpDir,

});

const loaded = await loadWebPushSubscription(sub.subscriptionId, tmpDir);

expect(expectLoadedSubscription(loaded).endpoint).toBe(endpoint);

});

it("returns null for unknown subscription ID", async () => {

const loaded = await loadWebPushSubscription("nonexistent", tmpDir);

expect(loaded).toBeNull();

});

it("lists all subscriptions", async () => {

await registerWebPushSubscription({

endpoint: "https://push.example.com/a",

expect(list).toHaveLength(2);

});

it("clears a subscription by ID", async () => {

const sub = await registerWebPushSubscription({

endpoint,

keys,

baseDir: tmpDir,

});

const removed = await clearWebPushSubscription(sub.subscriptionId, tmpDir);

expect(removed).toBe(true);

const list = await listWebPushSubscriptions(tmpDir);

expect(list).toHaveLength(0);

});

it("clears a subscription by endpoint", async () => {

await registerWebPushSubscription({ endpoint, keys, baseDir: tmpDir });

const removed = await clearWebPushSubscriptionByEndpoint(endpoint, tmpDir);