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.
77 lines
2.5 KiB
TypeScript
77 lines
2.5 KiB
TypeScript
/**
|
|
* RED scaffold — pushCoalescer (Plan 05-03 turns this GREEN).
|
|
*
|
|
* Asserts that coalesceListPush:
|
|
* - Fires the dispatch function exactly ONCE when N calls arrive within the coalesce window
|
|
* - Passes the correct count (N) to the dispatch function
|
|
* - Passes the actor's own userId as excludeUserId to suppress self-notifications (D-03)
|
|
*
|
|
* These tests fail now because pushCoalescer.ts does not yet exist.
|
|
* Run: pnpm --filter @familysync/api exec vitest run tests/lib/pushCoalescer.test.ts
|
|
*/
|
|
|
|
import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';
|
|
|
|
describe('pushCoalescer — list-change burst coalescing (D-01)', () => {
|
|
beforeEach(() => {
|
|
vi.useFakeTimers();
|
|
vi.resetModules();
|
|
});
|
|
|
|
afterEach(() => {
|
|
vi.useRealTimers();
|
|
});
|
|
|
|
it('collapses N rapid coalesceListPush calls into a single dispatch with count=N', async () => {
|
|
const dispatch = vi.fn().mockResolvedValue(undefined);
|
|
const { coalesceListPush } = await import('../../src/lib/pushCoalescer.js');
|
|
|
|
const listId = 1;
|
|
const actorId = 10;
|
|
const N = 5;
|
|
|
|
for (let i = 0; i < N; i++) {
|
|
coalesceListPush(listId, actorId, dispatch);
|
|
}
|
|
|
|
// Advance time past the coalesce window
|
|
await vi.runAllTimersAsync();
|
|
|
|
expect(dispatch).toHaveBeenCalledTimes(1);
|
|
const [calledListId, calledActorId, calledCount] = dispatch.mock.calls[0];
|
|
expect(calledListId).toBe(listId);
|
|
expect(calledActorId).toBe(actorId);
|
|
expect(calledCount).toBe(N);
|
|
});
|
|
|
|
it('passes the actor userId as excludeUserId so the actor does not notify themselves (D-03)', async () => {
|
|
const dispatch = vi.fn().mockResolvedValue(undefined);
|
|
const { coalesceListPush } = await import('../../src/lib/pushCoalescer.js');
|
|
|
|
const listId = 2;
|
|
const actorId = 99;
|
|
|
|
coalesceListPush(listId, actorId, dispatch);
|
|
await vi.runAllTimersAsync();
|
|
|
|
expect(dispatch).toHaveBeenCalledTimes(1);
|
|
const [, calledActorId] = dispatch.mock.calls[0];
|
|
expect(calledActorId).toBe(actorId);
|
|
});
|
|
|
|
it('fires separate dispatches for different lists independently', async () => {
|
|
const dispatch = vi.fn().mockResolvedValue(undefined);
|
|
const { coalesceListPush } = await import('../../src/lib/pushCoalescer.js');
|
|
|
|
coalesceListPush(1, 10, dispatch);
|
|
coalesceListPush(1, 10, dispatch);
|
|
coalesceListPush(2, 10, dispatch); // different list
|
|
coalesceListPush(2, 10, dispatch);
|
|
|
|
await vi.runAllTimersAsync();
|
|
|
|
// Two separate dispatches — one per distinct listId
|
|
expect(dispatch).toHaveBeenCalledTimes(2);
|
|
});
|
|
});
|