Merge embedded stream migration into v2 snapshot rollout

apps/web/tests/scaffold.ts

@@ -721,7 +721,7 @@ export async function launchWebScaffold(options: LaunchOptions = {}): Promise<We
       if (headerType !== 'session') {
         throw new Error('replayProvidersOnly fixture must open with a session header row')
       }
-      const recorded = parseSessionLog(fixtureText)
+      const recorded = parseSessionLogForReplay(fixtureText, replayFixture)
       const hasModelCall = recorded.some(event => (
         event.type === 'assistant/message' || event.type === 'assistant/attempt'
           || event.type === 'request/header' || event.type === 'tool/call'

apps/web/tests/schedule-after.e2e.ts

@@ -608,7 +608,7 @@ describe.skipIf(MODE === 'record')('web e2e: active Schedule catalog', () => {
     scaffold = await launchWebScaffold({
       extraOverlayPath: OVERLAY,
     })
-    await seedSession(scaffold, fixture, CATALOG_SESSION_ID, 'standard')
+    await seedSession(scaffold, fixture, CATALOG_SESSION_ID, 'standard', CATALOG_FIXTURE)
     const workspace = await scaffold.ctx.workspaceRegistry.create(scaffold.workspaceCwd)
     await workspace.attachSession(CATALOG_SESSION_ID)
 

packages/session/session-persistence-jsonl/tests/jsonl.spec.ts

@@ -682,7 +682,7 @@ describe('JsonlSessionPersistence: immutable format generations', () => {
     const highest = generationLogPath(root, header.cwd, header.id, 4, 'zstd')
     await writeFile(highest, 'newer')
 
-    await expect(ctx.sessionPersistence.list()).rejects.toThrow(highest)
+    await expect(ctx.sessionPersistence.list()).rejects.toThrow(JSON.stringify(highest))
   })
 
   it('surfaces a file occupying the targeted Session-directory path', async () => {