mirror of
https://github.com/AgentSeal/codeburn.git
synced 2026-07-28 18:35:29 +00:00
e27fe36bd5
* cache: strict cross-process gate for the warm session-cache refresh transaction (#645) * lock: serialize the fence against the owner's own heartbeat verifyStillOwner and the heartbeat tick both take the takeover guard; without in-process serialization the fence could observe its own heartbeat's guard file, read it as displacement, and abort a legitimate publication. Fail-safe, but it discarded the parse the lock exists to protect (~6% of verifies at a 1ms heartbeat in the repro). Owner-side guard operations now run through one serializer; cross-process guard semantics are unchanged. Regression test at heartbeatMs 1, mutation- verified against the unserialized code. --------- Co-authored-by: Aditya Vikram Singh <247195684+avs-io@users.noreply.github.com> Co-authored-by: reviewer <review@local>
62 lines
2.2 KiB
TypeScript
62 lines
2.2 KiB
TypeScript
import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
|
|
import { mkdir, mkdtemp, readFile, rm, writeFile } from 'fs/promises'
|
|
import { tmpdir } from 'os'
|
|
import { join } from 'path'
|
|
|
|
vi.mock('../src/cache-refresh-lock.js', () => ({
|
|
acquireCacheRefreshLock: async () => ({ outcome: 'timed-out' as const }),
|
|
}))
|
|
|
|
import { clearSessionCache, parseAllSessions } from '../src/parser.js'
|
|
import { sessionCachePath } from '../src/session-cache.js'
|
|
|
|
let root: string
|
|
let sessionPath: string
|
|
|
|
function output(projects: Awaited<ReturnType<typeof parseAllSessions>>): number {
|
|
return projects.flatMap(p => p.sessions).flatMap(s => s.turns)
|
|
.flatMap(t => t.assistantCalls).reduce((sum, call) => sum + call.usage.outputTokens, 0)
|
|
}
|
|
|
|
async function writeSession(value: number): Promise<void> {
|
|
await writeFile(sessionPath, JSON.stringify({
|
|
type: 'assistant',
|
|
sessionId: 'sess',
|
|
timestamp: '2026-05-15T10:00:00Z',
|
|
cwd: '/tmp/proj',
|
|
message: {
|
|
id: `msg-${value}`, type: 'message', role: 'assistant', model: 'claude-sonnet-4-5',
|
|
content: [], usage: { input_tokens: 100, output_tokens: value },
|
|
},
|
|
}) + '\n')
|
|
}
|
|
|
|
beforeEach(async () => {
|
|
clearSessionCache()
|
|
root = await mkdtemp(join(tmpdir(), 'cb-refresh-timeout-'))
|
|
const home = join(root, 'home')
|
|
const project = join(home, 'projects', 'proj')
|
|
await mkdir(project, { recursive: true })
|
|
sessionPath = join(project, 'sess.jsonl')
|
|
process.env['CLAUDE_CONFIG_DIR'] = home
|
|
process.env['CODEBURN_CACHE_DIR'] = join(root, 'cache')
|
|
process.env['CODEBURN_DESKTOP_SESSIONS_DIR'] = join(home, 'desktop-sessions')
|
|
})
|
|
|
|
afterEach(async () => {
|
|
clearSessionCache()
|
|
await rm(root, { recursive: true, force: true })
|
|
})
|
|
|
|
describe('parseAllSessions warm refresh timeout', () => {
|
|
it('serves the prior complete snapshot and leaves the holder cache untouched', async () => {
|
|
await writeSession(50)
|
|
expect(output(await parseAllSessions(undefined, 'claude'))).toBe(50)
|
|
const before = await readFile(sessionCachePath(), 'utf-8')
|
|
|
|
await writeSession(5000)
|
|
clearSessionCache()
|
|
expect(output(await parseAllSessions(undefined, 'claude'))).toBe(50)
|
|
expect(await readFile(sessionCachePath(), 'utf-8')).toBe(before)
|
|
})
|
|
})
|