44 lines
2.8 KiB
JavaScript
44 lines
2.8 KiB
JavaScript
import test from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import { mkdtempSync, readFileSync, rmSync } from 'node:fs';
|
|
import { join } from 'node:path';
|
|
import { tmpdir } from 'node:os';
|
|
import { Broker } from '../src/broker.mjs';
|
|
import { Store } from '../src/store.mjs';
|
|
import { citationWorld, citedBody, fixtureCite } from './citation-helpers.mjs';
|
|
|
|
test('C2-10c room.read carries exactly the thread check and current file last', async t => {
|
|
const f = citationWorld(t, { definition: 'companion' });
|
|
const room = f.call(f.human, 'room.open', { project: f.store.get('SELECT id FROM projects').id });
|
|
const thread = room.threads[0].id;
|
|
const agent = f.broker.bindLaunch({ ...f.launch, run: 'room-agent', thread });
|
|
f.call(agent, 'role.claim');
|
|
const sent = await f.call(agent, 'message.send', { to: 'human', body: citedBody([fixtureCite(f.commit)]) });
|
|
const [single] = await f.call(f.human, 'thread.messages', { thread });
|
|
const merged = await f.call(f.human, 'room.read', { project: room.project });
|
|
const same = merged.find(m => m.id === sent.id);
|
|
assert.deepEqual(same.check, single.check);
|
|
assert.deepEqual(same.check.citations, [{ scope: 'canon', agent: null, file: f.commit, last: f.commit }]);
|
|
assert.equal(f.reads.length, 2, 'both read verbs route through last hydration');
|
|
});
|
|
|
|
test('C2-10c check hydration preserves unchecked rows and one broadcast with two addressees', t => {
|
|
const root = mkdtempSync(join(tmpdir(), 'room-check-')), store = new Store(root);
|
|
t.after(() => { store.close(); rmSync(root, { recursive: true, force: true }); });
|
|
const messaging = JSON.parse(readFileSync(new URL('../../../roles/companion.json', import.meta.url))).messaging;
|
|
const role = { definition: 'companion', authority: { withinRole: ['message.send'], crossRole: [] } };
|
|
const broker = new Broker({ store, businesses: { demo: { id: 'demo', human: 'jason', vars: {},
|
|
arbiters: { technical: 'chief', delivery: 'chief' }, roles: {chief: { definition: 'chief-of-staff', authority: { withinRole: ['decision.resolve.technical', 'decision.resolve.delivery'], crossRole: [] } }, bean: role, chet: role }, definitions: { companion: { messaging } } } } });
|
|
const human = broker.bindHuman({ business: 'demo', human: 'jason', via: 'cli', outsideAgent: true });
|
|
const call = (verb, args) => broker.request(human, { verb, args });
|
|
const project = call('project.create', { name: 'Room' }).id;
|
|
call('room.open', { project });
|
|
const receipt = call('room.send', { project, body: 'One broadcast.' });
|
|
const rows = call('room.read', { project });
|
|
assert.equal(rows.length, 1);
|
|
assert.deepEqual(rows[0].ids, receipt.ids);
|
|
assert.deepEqual(rows[0].to, ['bean', 'chet']);
|
|
assert.equal(Object.hasOwn(rows[0], 'check'), false);
|
|
assert.equal(rows[0].body, 'One broadcast.');
|
|
});
|