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)
|
|
})
|
|
})
|