|
|
@@ -1,6 +1,9 @@
|
|
|
import { readFileSync, readdirSync } from 'node:fs'
|
|
|
import { join, relative, resolve } from 'node:path'
|
|
|
import { describe, expect, it } from 'vitest'
|
|
|
+import { SESSION_FORMAT_VERSION } from '@deepseek-ai/dsh-session'
|
|
|
+import { SessionFormatUnsupportedMigrationError } from '@deepseek-ai/dsh-session-format-catalog'
|
|
|
+import { expectedUnsupported, unversionedProtocolFixtures } from './session-format-corpus-inventory.ts'
|
|
|
import { parseSessionLog } from '../src/index.ts'
|
|
|
|
|
|
const repoRoot = resolve(import.meta.dirname, '../../../..')
|
|
|
@@ -37,21 +40,97 @@ function filenameFormatVersion(path: string): number {
|
|
|
return match[1] === undefined ? 0 : Number(match[1])
|
|
|
}
|
|
|
|
|
|
+type Unsupported = { sourceVersion: number; reason: string }
|
|
|
+
|
|
|
+function assertRestoration(
|
|
|
+ key: string,
|
|
|
+ sourceVersion: number,
|
|
|
+ restore: () => unknown,
|
|
|
+ unsupported: Unsupported | undefined,
|
|
|
+): void {
|
|
|
+ if (unsupported === undefined) {
|
|
|
+ expect(restore, key + ': current-format restoration').not.toThrow()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ expect(sourceVersion, key + ': current-generation fixtures cannot be unsupported').toBeLessThan(SESSION_FORMAT_VERSION)
|
|
|
+ expect(sourceVersion, key + ': inventoried source generation').toBe(unsupported.sourceVersion)
|
|
|
+ let refusal: unknown
|
|
|
+ try {
|
|
|
+ restore()
|
|
|
+ } catch (error) {
|
|
|
+ refusal = error
|
|
|
+ }
|
|
|
+ expect(refusal, key + ': expected unsupported migration').toBeInstanceOf(SessionFormatUnsupportedMigrationError)
|
|
|
+ expect((refusal as Error).message, key + ': exact refusal reason').toBe(unsupported.reason)
|
|
|
+}
|
|
|
+
|
|
|
+const fixtures = ['snapshots', 'packages', 'scripts/snapshots/python-sdk-single-exe']
|
|
|
+ .flatMap(root => committedSessionFixtures(join(repoRoot, root)))
|
|
|
+ .map(file => ({ file, key: relative(repoRoot, file).split('\\').join('/') }))
|
|
|
+ .sort((a, b) => a.key.localeCompare(b.key))
|
|
|
+
|
|
|
describe('committed Session format corpus', () => {
|
|
|
- it('restores every versioned fixture through the current format catalog', () => {
|
|
|
- const files = ['snapshots', 'packages', 'scripts/snapshots/python-sdk-single-exe']
|
|
|
- .flatMap(root => committedSessionFixtures(join(repoRoot, root)))
|
|
|
- .sort()
|
|
|
-
|
|
|
- for (const file of files) {
|
|
|
- const source = readFileSync(file, 'utf8')
|
|
|
- if (!declaresFormat(source)) continue
|
|
|
- const key = relative(repoRoot, file).split('\\').join('/')
|
|
|
+ it('keeps every exception tied to an existing fixture', () => {
|
|
|
+ const keys = new Set(fixtures.map(({ key }) => key))
|
|
|
+ for (const key of [...Object.keys(expectedUnsupported), ...unversionedProtocolFixtures]) {
|
|
|
+ expect(keys.has(key), key).toBe(true)
|
|
|
+ }
|
|
|
+ })
|
|
|
+
|
|
|
+ it.each(fixtures)('$key', ({ file, key }) => {
|
|
|
+ const bytes = readFileSync(file)
|
|
|
+ const source = bytes.toString('utf8')
|
|
|
+ try {
|
|
|
+ if (unversionedProtocolFixtures.has(key)) {
|
|
|
+ expect(declaresFormat(source), key + ': protocol fixture must remain unversioned').toBe(false)
|
|
|
+ expect(filenameFormatVersion(file), key + ': protocol fixture filename').toBe(0)
|
|
|
+ expect(expectedUnsupported[key], key + ': protocol fixture is not an unsupported migration').toBeUndefined()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ expect(declaresFormat(source), key + ': Session header must declare its format').toBe(true)
|
|
|
const header = JSON.parse(source.split(/\r?\n/u).find(line => line.trim().length > 0) ?? '{}') as {
|
|
|
- version?: unknown
|
|
|
+ version: number
|
|
|
}
|
|
|
- expect(header.version, `${key}: filename/header Session generation`).toBe(filenameFormatVersion(file))
|
|
|
- expect(() => parseSessionLog(source), `${key}: current-format restoration`).not.toThrow()
|
|
|
+ expect(header.version, key + ': filename/header Session generation').toBe(filenameFormatVersion(file))
|
|
|
+ assertRestoration(key, header.version, () => parseSessionLog(source), expectedUnsupported[key])
|
|
|
+ } finally {
|
|
|
+ expect(readFileSync(file), key + ': source bytes remain unchanged').toEqual(bytes)
|
|
|
}
|
|
|
})
|
|
|
})
|
|
|
+
|
|
|
+describe('corpus unsupported policy', () => {
|
|
|
+ const refusal = { sourceVersion: 2, reason: 'deliberate historical refusal' }
|
|
|
+ const refused = (): never => { throw new SessionFormatUnsupportedMigrationError(refusal.reason) }
|
|
|
+
|
|
|
+ it('rejects an unlisted migration refusal', () => {
|
|
|
+ expect(() => assertRestoration('unlisted', 2, refused, undefined)).toThrow('current-format restoration')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('rejects an exception that starts restoring successfully', () => {
|
|
|
+ expect(() => assertRestoration('supported', 2, () => [], refusal)).toThrow('expected unsupported migration')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('rejects a changed refusal reason', () => {
|
|
|
+ expect(() => assertRestoration('changed', 2, refused, { ...refusal, reason: 'different' })).toThrow('exact refusal reason')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('rejects corruption masquerading as an unsupported migration', () => {
|
|
|
+ expect(() => assertRestoration('corrupt', 2, () => { throw new Error(refusal.reason) }, refusal))
|
|
|
+ .toThrow('expected unsupported migration')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('rejects a mismatched source generation', () => {
|
|
|
+ expect(() => assertRestoration('wrong-version', 1, refused, refusal)).toThrow('inventoried source generation')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('never exempts a current-generation fixture', () => {
|
|
|
+ expect(() => assertRestoration('current', SESSION_FORMAT_VERSION, refused, {
|
|
|
+ ...refusal, sourceVersion: SESSION_FORMAT_VERSION,
|
|
|
+ })).toThrow('current-generation fixtures cannot be unsupported')
|
|
|
+ })
|
|
|
+
|
|
|
+ it('accepts only the exact typed historical refusal', () => {
|
|
|
+ expect(() => assertRestoration('historical', 2, refused, refusal)).not.toThrow()
|
|
|
+ })
|
|
|
+})
|
Tianyi Cui