// node modules/test/test-delegation-reporting.js
// A delegated task must report the worker's answer, and must report FAILURE when there is
// no answer. Three places used to substitute the literal "completed": delegateTask's
// outbox, the delegate_task tool, and orchestrate-parallel's per-sub-task summary.
const fs = require('fs'), path = require('path');
const ROOT = __dirname + '/../core';
const store = {};
global.localStorage = { getItem: k => (k in store ? store[k] : null), setItem: (k, v) => { store[k] = String(v); }, removeItem: k => { delete store[k]; } };
global.indexedDB = { open() { throw new Error('no idb'); }, deleteDatabase() { throw new Error('no idb'); } };
global.window = global;
global.addEventListener = () => {};

const AI = new Function(fs.readFileSync(path.join(ROOT, 'module-aiassist.js'), 'utf8') + '\nreturn WebX11AIAssistantModule;')();

let fails = 0, passes = 0;
const ok = (n, c, d) => { if (c) { passes++; return; } fails++; console.log('FAIL ' + n + (d ? ' — ' + d : '')); };

function mk(orch) {
    const stub = {
        print: () => {}, log: () => {}, setAiBusy: () => {}, markDirty: () => {},
        setPrompt: () => {}, clearInput: () => {}, scrollToBottom: () => {}, refreshPrompt: () => {},
        ollamaManager: null,
        fs: { mkdirRecursive: () => {}, writeFile: () => true, readFile: () => null, exists: () => false, list: () => [] },
        addEventListener: () => {}, removeEventListener: () => {},
    };
    stub.moduleManager = { modules: { OrchestratorModule: orch } };
    const ai = new AI();
    ai.terminal = stub;
    return ai;
}

(async () => {
    // D1/D2: an answer comes back as the answer, and success is true
    const withAnswer = mk({ delegateTask: async () => 'the worker answer' });
    const r1 = JSON.parse(await withAnswer.runTool('delegate_task', JSON.stringify({ task: 'do a thing' })));
    ok('D1 the answer is the worker answer', r1.result === 'the worker answer', JSON.stringify(r1));
    ok('D2 success is true when there is an answer', r1.success === true, JSON.stringify(r1.success));

    // D3/D4: no answer must NOT be reported as completed
    const silent = mk({ delegateTask: async () => '' });
    const r2 = JSON.parse(await silent.runTool('delegate_task', JSON.stringify({ task: 'do a thing' })));
    ok('D3 an empty answer reports success=false', r2.success === false, JSON.stringify(r2));
    ok('D4 an empty answer is not called "completed"', r2.result === null && /no answer/i.test(r2.error || ''), JSON.stringify(r2));

    // D5: undefined (an older orchestrator, or a rejected internal path) is also not success
    const undef = mk({ delegateTask: async () => undefined });
    const r3 = JSON.parse(await undef.runTool('delegate_task', JSON.stringify({ task: 'do a thing' })));
    ok('D5 undefined is a failure, not a completion', r3.success === false, JSON.stringify(r3));

    // D6: an object answer (the shape chat() now returns) is unwrapped, not stringified
    const objAnswer = mk({ delegateTask: async () => 'plain string from orchestrator' });
    const r4 = JSON.parse(await objAnswer.runTool('delegate_task', JSON.stringify({ task: 'x' })));
    ok('D6 the tool keeps the answer verbatim', r4.result === 'plain string from orchestrator', JSON.stringify(r4));

    console.log('test-delegation-reporting: ' + passes + ' passed, ' + fails + ' failed');
    process.exit(fails ? 1 : 0);
})();