56 lines
4.5 KiB
JavaScript
56 lines
4.5 KiB
JavaScript
import test from 'node:test';
|
|
import { DatabaseSync } from 'node:sqlite';
|
|
import assert from 'node:assert/strict';
|
|
import { mkdirSync, writeFileSync } from 'node:fs';
|
|
import { join } from 'node:path';
|
|
import { startBroker } from '../src/runtime.mjs';
|
|
import { bootConfig, loadSystem } from '../../cli/src/config.mjs';
|
|
import { fixture, tmp } from '../../cli/tests/helpers.mjs';
|
|
import { prdFixture, git } from '../../project/tests/prd-fixture.mjs';
|
|
import { createRequestStore } from '../src/request-store.mjs';
|
|
|
|
export async function requestFixture(t, mode = 'autonomous', beforeBootstrap = null, threaded = false) {
|
|
const root = tmp(t, 'activation-'), f = fixture(root, 'demo', d => { d.launch.instances.push('pm'); if (threaded) d.roles.assistant = { definition: 'assistant' }; return d; });
|
|
const source = join(root, 'project'); mkdirSync(join(source, '.mosaic'), { recursive: true });
|
|
writeFileSync(join(source, '.mosaic/project.json'), JSON.stringify({ projectVersion: 1, id: 'stack', vars: { 'tracker.project': 1 } }));
|
|
git(source, 'init', '-qb', 'main'); git(source, 'add', '-A'); git(source, 'commit', '-qm', 'Factory');
|
|
const system = loadSystem({ env: f.env });
|
|
const boot = async () => {
|
|
const config = bootConfig({ system, businessId: 'demo', env: f.env, warn: () => {} });
|
|
const bus = await startBroker(config); t.after(() => bus.close().catch(() => {})); return bus;
|
|
};
|
|
const bus = await boot(), caps = {};
|
|
const db = new DatabaseSync(join(f.dataRoot, 'bus/bus.sqlite'), { readOnly: true }); t.after(() => db.close());
|
|
const store = { get: (sql, ...a) => db.prepare(sql).get(...a), all: (sql, ...a) => db.prepare(sql).all(...a) };
|
|
const bind = b => {
|
|
caps.human = b.bindHuman({ business: 'demo', human: 'jason', via: 'cli', outsideAgent: true });
|
|
caps.console = b.bindConsole({ business: 'demo', human: 'jason', subject: { provider: 'test', iss: 'test', sub: 'owner' } });
|
|
caps.reader = b.bindReader({ business: 'demo' });
|
|
for (const role of ['pm','cto','coder','reviewer','chief']) { caps[role] = b.bindLaunch({ business: 'demo', role, run: role + '-run', harness: 'pi' }); b.request(caps[role], { verb: 'role.claim' }); }
|
|
};
|
|
bind(bus.broker);
|
|
const call = (who, verb, args = {}) => bus.broker.request(caps[who], { verb, args });
|
|
await beforeBootstrap?.({ f, bus, caps, call, system });
|
|
let sent;
|
|
if (threaded) {
|
|
const project = call('human', 'project.create', { name: 'Intake' }).id;
|
|
const thread = call('human', 'thread.create', { project, name: 'Timer' }).id;
|
|
caps.assistant = bus.broker.bindLaunch({ business: 'demo', role: 'assistant', run: 'assistant-run', harness: 'pi', thread });
|
|
call('assistant', 'role.claim');
|
|
sent = call('human', 'thread.send', { thread, body: 'Build a timer.\n' });
|
|
const relay = call('assistant', 'message.send', { to: 'chief', in_reply_to: sent.id, body: 'Original request ' + sent.request });
|
|
call('chief', 'message.send', { to: 'pm', in_reply_to: relay.id, body: 'Open original request ' + sent.request });
|
|
} else sent = call('human', 'message.send', { to: 'pm', body: 'Build a timer.\n' });
|
|
let state = await call('pm', 'request.open', { request: sent.request });
|
|
state = await call('pm', 'request.propose', { request: sent.request, revision: state.revision, op: 'plan', source_project: 'stack', project: 'timer', name: 'Timer', tracker_project: 2 });
|
|
call('human', 'decision.resolve', { id: state.selection.decision, choice: mode });
|
|
state = await bus.requestLifecycle.resume('demo', sent.request);
|
|
const context = { business: { id: 'demo', human: 'jason', projects: { timer: { root: join(f.dataRoot, 'products/demo/timer/code') } } }, project: 'timer', dataRoot: f.dataRoot };
|
|
const p = await prdFixture(t, context);
|
|
const args = { request: sent.request, revision: state.revision, op: 'prd1', prd_version: '1.0', records_commit: p.args.records_commit, prd_path: p.args.prd_path, requirement_ids: p.args.requirement_ids };
|
|
const submit = () => call('pm', 'prd.submit', args);
|
|
const approve = (submission, who = mode === 'guided' ? 'human' : 'cto') => call(who, 'decision.resolve', { id: submission.decision.id, choice: 'yes' });
|
|
const activate = submission => bus.requirementCatalog.activate({ request: sent.request, decision: submission.decision.id });
|
|
return { ...p, f, bus, system, caps, call, source: sent, state, request: sent.request, args, submit, approve, activate, boot, bind, config: bootConfig({ system, businessId: 'demo', env: f.env, warn: () => {} }), store, journal: createRequestStore(store) };
|
|
}
|