mengzhx/deepseek-harness
1
0
Fork 0
mirror of https://github.com/deepseek-ai/deepseek-harness.git synced 2026-08-29 04:26:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(session-projection-cache): drive interval deterministically

Browse Source
This commit is contained in:
imccyu
2026-08-26 14:52:54 +08:00
parent b8360cac53
commit 459919d21d
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/session/session-projection-cache/tests/cache.spec.ts
+8 -5
View File
@@ -196,13 +196,16 @@ describe('SessionProjectionCache write policy', () => {
})
it('flushes on the configured interval when the count threshold is not reached', async () => {
const { ctx, root } = await harness({ config: { writeEveryEvents: 100, writeIntervalMs: 20 } })
const { ctx, cache } = await harness({ config: { writeEveryEvents: 100, writeIntervalMs: 20 } })
const write = vi.spyOn(cache, 'write').mockResolvedValue()
vi.useFakeTimers()
const session = ctx.sessions.create(SessionId('interval'))
write.mockClear()
mark(session, ['slow'])
await new Promise(resolve => setTimeout(resolve, 10)) // before the interval
expect((await storedRows(root, session.id))?.['cache-test/marks']?.seq).toBe(-1) // still the creation cut
await settle() // past the interval; the fire-and-forget write lands
expect((await storedRows(root, session.id))?.['cache-test/marks']?.val).toEqual({ marks: ['slow'] })
await vi.advanceTimersByTimeAsync(19)
expect(write).not.toHaveBeenCalled()
await vi.advanceTimersByTimeAsync(1)
expect(write).toHaveBeenCalledExactlyOnceWith(session)
})
it('write() on a never-dirty session checkpoints directly and rejects a non-JSON unit state', async () => {