Lucas Berger
982438dc10
Mechanical reformat — no logic changes. 398 files changed, 19125 insertions(+), 16457 deletions(-). Prettier 3.8.4 with .prettierrc (singleQuote:true, semi:true, tabWidth:2, trailingComma:all, printWidth:100). Isolated per D-13-08 for reviewability.
101 lines
3.4 KiB
TypeScript
101 lines
3.4 KiB
TypeScript
/**
|
|
* RED scaffold — pushDispatcher (Plan 05-02 turns this GREEN).
|
|
*
|
|
* Asserts that dispatchPush:
|
|
* - Deletes the push_subscriptions row when the push service returns 410 (Gone)
|
|
* - Deletes the push_subscriptions row when the push service returns 404 (Not Found)
|
|
* - Does NOT delete the row on 201 (success)
|
|
* - Does NOT delete the row on transient 5xx errors
|
|
*
|
|
* These tests fail now because pushDispatcher.ts does not yet exist.
|
|
* Run: pnpm --filter @familysync/api exec vitest run tests/lib/pushDispatcher.test.ts
|
|
*/
|
|
|
|
import { describe, it, expect, vi, beforeEach } from 'vitest';
|
|
import type { PushSubscription } from '../../src/lib/pushDispatcher.js';
|
|
|
|
// Mock web-push so no real network calls occur
|
|
vi.mock('web-push', () => ({
|
|
default: {
|
|
sendNotification: vi.fn(),
|
|
setVapidDetails: vi.fn(),
|
|
},
|
|
}));
|
|
|
|
// Mock the DB module so we can assert on deletes without a real database
|
|
vi.mock('../../src/db/client.js', () => ({
|
|
db: {
|
|
delete: vi.fn().mockReturnValue({
|
|
where: vi.fn().mockResolvedValue(undefined),
|
|
}),
|
|
},
|
|
}));
|
|
|
|
const FAKE_SUB: PushSubscription = {
|
|
id: 1,
|
|
userId: 42,
|
|
endpoint: 'https://push.example.com/sub/abc',
|
|
p256dh: 'fake_p256dh',
|
|
auth: 'fake_auth',
|
|
};
|
|
|
|
describe('pushDispatcher — 410/404 subscription pruning', () => {
|
|
beforeEach(() => {
|
|
vi.clearAllMocks();
|
|
});
|
|
|
|
it('deletes the subscription row when the push service returns 410 (Gone)', async () => {
|
|
const webpush = (await import('web-push')).default;
|
|
const { db } = await import('../../src/db/client.js');
|
|
vi.mocked(webpush.sendNotification).mockRejectedValueOnce(
|
|
Object.assign(new Error('Gone'), { statusCode: 410 }),
|
|
);
|
|
|
|
const { dispatchPush } = await import('../../src/lib/pushDispatcher.js');
|
|
await dispatchPush(FAKE_SUB, { title: 'Test', body: 'Hello' });
|
|
|
|
expect(vi.mocked(db.delete)).toHaveBeenCalled();
|
|
});
|
|
|
|
it('deletes the subscription row when the push service returns 404 (Not Found)', async () => {
|
|
const webpush = (await import('web-push')).default;
|
|
const { db } = await import('../../src/db/client.js');
|
|
vi.mocked(webpush.sendNotification).mockRejectedValueOnce(
|
|
Object.assign(new Error('Not Found'), { statusCode: 404 }),
|
|
);
|
|
|
|
const { dispatchPush } = await import('../../src/lib/pushDispatcher.js');
|
|
await dispatchPush(FAKE_SUB, { title: 'Test', body: 'Hello' });
|
|
|
|
expect(vi.mocked(db.delete)).toHaveBeenCalled();
|
|
});
|
|
|
|
it('does NOT delete the row on 201 success', async () => {
|
|
const webpush = (await import('web-push')).default;
|
|
const { db } = await import('../../src/db/client.js');
|
|
vi.mocked(webpush.sendNotification).mockResolvedValueOnce({
|
|
statusCode: 201,
|
|
body: '',
|
|
headers: {},
|
|
});
|
|
|
|
const { dispatchPush } = await import('../../src/lib/pushDispatcher.js');
|
|
await dispatchPush(FAKE_SUB, { title: 'Test', body: 'Hello' });
|
|
|
|
expect(vi.mocked(db.delete)).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('does NOT delete the row on transient 5xx error', async () => {
|
|
const webpush = (await import('web-push')).default;
|
|
const { db } = await import('../../src/db/client.js');
|
|
vi.mocked(webpush.sendNotification).mockRejectedValueOnce(
|
|
Object.assign(new Error('Service Unavailable'), { statusCode: 503 }),
|
|
);
|
|
|
|
const { dispatchPush } = await import('../../src/lib/pushDispatcher.js');
|
|
await dispatchPush(FAKE_SUB, { title: 'Test', body: 'Hello' });
|
|
|
|
expect(vi.mocked(db.delete)).not.toHaveBeenCalled();
|
|
});
|
|
});
|