diff --git a/packages/cli/tests/thread-launch.test.mjs b/packages/cli/tests/thread-launch.test.mjs index 84f8ed088..fa3adb866 100644 --- a/packages/cli/tests/thread-launch.test.mjs +++ b/packages/cli/tests/thread-launch.test.mjs @@ -486,8 +486,10 @@ test('C2-09a: creative thread messages start distinct runs and keep each instanc assert.deepEqual((await send(bean, 'bean', 'Bean input')).before, []); assert.deepEqual((await send(chet, 'chet', 'Chet input')).before, []); assert.deepEqual((await send(bean, 'bean', 'Bean again')).before, ['Bean input']); - assert.equal(readFileSync(join(f.dataRoot, 'threads', 'acme', bean, 'session', 'history'), 'utf8'), 'Bean input\nBean again\n'); - assert.equal(readFileSync(join(f.dataRoot, 'threads', 'acme', chet, 'session', 'history'), 'utf8'), 'Chet input\n'); + assert.equal(readFileSync(join(f.dataRoot, 'threads', 'acme', bean, 'sessions', host.runtime.threadsState('acme').find(x => x.thread === bean).session, 'session', 'history'), 'utf8'), 'Bean input\nBean again\n'); + assert.equal(readFileSync(join(f.dataRoot, 'threads', 'acme', chet, 'sessions', host.runtime.threadsState('acme').find(x => x.thread === chet).session, 'session', 'history'), 'utf8'), 'Chet input\n'); + assert.equal(existsSync(join(f.dataRoot, 'threads', 'acme', bean, 'session')), false); + assert.equal(existsSync(join(f.dataRoot, 'threads', 'acme', chet, 'session')), false); const launches = launchLog(f).filter(row => row.event === 'launch'); assert.ok(launches.some(row => row.instance === 'bean' && row.thread === bean)); assert.ok(launches.some(row => row.instance === 'chet' && row.thread === chet));