Дмитрий
56 lines
3.1 KiB
JavaScript
56 lines
3.1 KiB
JavaScript
// tools/on-plan-write.test.mjs
|
|
import { describe, it, expect } from 'vitest';
|
|
import { onPlanWrite } from './on-plan-write.mjs';
|
|
import { planId } from './plan-lock.mjs';
|
|
|
|
const STEPS = [{ n: 1, op: 'Write', object: 'tools/a.mjs' }];
|
|
const goodVerdict = { plan_points_addressed: ['шаг 1 ок'], reasoning: 'разбор', recommendation: 'ок', confidence: 0.8 };
|
|
const llmOk = async () => goodVerdict;
|
|
|
|
describe('onPlanWrite (W3, A0 — нах.F5/C-1)', () => {
|
|
it('первый план → task-id присвоен из planId(steps) и персистнут', async () => {
|
|
const persisted = [];
|
|
const r = await onPlanWrite({ planSteps: STEPS, existingTaskId: null, persistTaskIdImpl: (id) => persisted.push(id), llmCall: llmOk, journalKey: 'k', nowMs: 1 });
|
|
expect(r.taskId).toBe(`task:${planId(STEPS)}`);
|
|
expect(persisted).toEqual([r.taskId]);
|
|
});
|
|
it('re-issue плана с новым хешем НЕ сбрасывает task-id (✅O17)', async () => {
|
|
const NEW_STEPS = [{ n: 1, op: 'Write', object: 'tools/b.mjs' }];
|
|
const r = await onPlanWrite({ planSteps: NEW_STEPS, existingTaskId: 'task:OLD', llmCall: llmOk, journalKey: 'k', nowMs: 1 });
|
|
expect(r.taskId).toBe('task:OLD');
|
|
});
|
|
it('вердикт произведён и привязан: verdict.plan_hash === planId(steps) (нах.F4)', async () => {
|
|
const r = await onPlanWrite({ planSteps: STEPS, llmCall: llmOk, journalKey: 'k', nowMs: 1 });
|
|
expect(r.ok).toBe(true);
|
|
expect(r.wired).toBe(true);
|
|
expect(r.verdict.plan_hash).toBe(planId(STEPS));
|
|
});
|
|
it('журнал переговоров пишется (side=mentor, круг 1, task-id-bound)', async () => {
|
|
const r = await onPlanWrite({ planSteps: STEPS, llmCall: llmOk, journalKey: 'k', nowMs: 1 });
|
|
expect(r.journalOk).toBe(true);
|
|
expect(r.journal.entries.length).toBe(1);
|
|
const p = r.journal.entries[0].payload;
|
|
expect(p.side).toBe('mentor');
|
|
expect(p.round).toBe(1);
|
|
expect(p.task_id).toBe(r.taskId);
|
|
});
|
|
it('SE10: сбой журнала НЕ крашит круг — journalOk:false, вердикт/task-id целы', async () => {
|
|
const boom = () => { throw new Error('журнал упал'); };
|
|
const r = await onPlanWrite({ planSteps: STEPS, llmCall: llmOk, journalKey: 'k', nowMs: 1, appendNegotiationImpl: boom });
|
|
expect(r.journalOk).toBe(false);
|
|
expect(r.taskId).toBe(`task:${planId(STEPS)}`);
|
|
expect(r.verdict.plan_hash).toBe(planId(STEPS));
|
|
});
|
|
it('сбой персиста task-id НЕ крашит — taskIdPersisted:false', async () => {
|
|
const r = await onPlanWrite({ planSteps: STEPS, persistTaskIdImpl: () => { throw new Error('disk'); }, llmCall: llmOk, journalKey: 'k', nowMs: 1 });
|
|
expect(r.taskIdPersisted).toBe(false);
|
|
expect(r.taskId).toBe(`task:${planId(STEPS)}`);
|
|
});
|
|
it('сбой вызова наставника → ok:false, wired:false (SE-R6-6), без краша', async () => {
|
|
const r = await onPlanWrite({ planSteps: STEPS, llmCall: async () => { throw new Error('сеть'); }, journalKey: 'k', nowMs: 1 });
|
|
expect(r.ok).toBe(false);
|
|
expect(r.wired).toBe(false);
|
|
expect(r.verdict).toBe(null);
|
|
});
|
|
});
|