// 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);
  });
});