listWebPushSubscriptions,

registerWebPushSubscription,

resolveVapidKeys,

sendWebPushNotification,

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

// Stub resolveStateDir so tests use a temp directory.

describe("sending", () => {

const keys = { p256dh: "p256dh-key", auth: "auth-key" };

it("configures VAPID details for direct sends", async () => {

const sub = await registerWebPushSubscription({

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

keys,

baseDir: tmpDir,

});

const result = await sendWebPushNotification(sub, { title: "Direct" });

expect(result.ok).toBe(true);

expect(vi.mocked(webPush.setVapidDetails)).toHaveBeenCalledTimes(1);

expect(vi.mocked(webPush.setVapidDetails)).toHaveBeenCalledWith(

"https://openclaw.ai",

"test-public-key-base64url",

"test-private-key-base64url",

);

expect(vi.mocked(webPush.sendNotification)).toHaveBeenCalledTimes(1);

});

it("configures VAPID details once before broadcasting to subscribers", async () => {

await registerWebPushSubscription({

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

webPush.setVapidDetails(keys.subject, keys.publicKey, keys.privateKey);

}

export async function sendWebPushNotification(

subscription: WebPushSubscription,

payload: WebPushPayload,

vapidKeys?: VapidKeyPair,

): Promise<WebPushSendResult> {

const keys = vapidKeys ?? (await resolveVapidKeys());

const webPush = await loadWebPushRuntime();

applyVapidDetails(webPush, keys);

return sendPreparedWebPushNotification(webPush, subscription, payload);

}

async function sendPreparedWebPushNotification(

webPush: WebPushRuntime,

subscription: WebPushSubscription,