Coder/deepseek-harness
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: cold-load persisted session metadata

Browse Source
This commit is contained in:
_Kerman
2026-07-23 19:27:37 +08:00
parent 7f5ba286fe
commit d2fcf385e8
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
packages/session-persistence/session-persistence/tests/coordinator-contract.ts
View File

@@ -140,9 +140,13 @@ export function runCoordinatorContract(name: string, makeFixture: () => Promise<
const fix = await makeFixture() const fix = await makeFixture()
const { ctx, fiber } = await freshCtx(fix) const { ctx, fiber } = await freshCtx(fix)
try { try {
const session = ctx.sessions.create(SessionId('forked-child'), { meta: { cwd: WORK, seedLength: 3 } }) let session!: Session
const sessionFiber = await ctx.plugin(Object.assign((inner: Context) => {
session = inner.sessions.create(SessionId('forked-child'), { meta: { cwd: WORK, seedLength: 3 } })
}, { inject: ['sessions'] }))
send(session, oneTurnLog()) send(session, oneTurnLog())
await ctx.sessions.flush(session) await ctx.sessions.flush(session)
await sessionFiber.dispose()
const loaded = await ctx.sessionPersistence.load(SessionId('forked-child')) const loaded = await ctx.sessionPersistence.load(SessionId('forked-child'))
expect(loaded.meta.seedLength).toBe(3) expect(loaded.meta.seedLength).toBe(3)
@@ -159,11 +163,15 @@ export function runCoordinatorContract(name: string, makeFixture: () => Promise<
const fix = await makeFixture() const fix = await makeFixture()
const { ctx, fiber } = await freshCtx(fix) const { ctx, fiber } = await freshCtx(fix)
try { try {
const session = ctx.sessions.create(SessionId('delegated-child'), { let session!: Session
meta: { cwd: WORK, parentSession: SessionId('root'), delegationDepth: 2 }, const sessionFiber = await ctx.plugin(Object.assign((inner: Context) => {
}) session = inner.sessions.create(SessionId('delegated-child'), {
meta: { cwd: WORK, parentSession: SessionId('root'), delegationDepth: 2 },
})
}, { inject: ['sessions'] }))
send(session, oneTurnLog()) send(session, oneTurnLog())
await ctx.parallel('session/flush', session) await ctx.parallel('session/flush', session)
await sessionFiber.dispose()
const loaded = await ctx.sessionPersistence.load(SessionId('delegated-child')) const loaded = await ctx.sessionPersistence.load(SessionId('delegated-child'))
expect(loaded.meta.delegationDepth).toBe(2) expect(loaded.meta.delegationDepth).toBe(2)