zhaoshang_client_ui/harness/tools/verify-company-info-passthrough.mjs

/**
 * 验证适配层把 `result` 事件里的 **company_info 原样带出**（不解析、不渲染进正文）。
 *
 * 为什么必须测：企业信息同步的第一步就是「拿到 company_info」——
 * 原先 `case 'result'` 是个**空分支**，整个 data 被丢弃；本次改成暂存并在 done 时
 * 随 `totalResponse` 交给应用侧。这条通路没有别的地方能覆盖（DMS 侧验证是从
 * 「已经拿到分类结果」开始的），所以用假 SSE 流喂真实协调器来钉住。
 *
 * 不联网：把 `globalThis.fetch` 打桩成返回一段构造好的 SSE 流。
 *
 * 怎么跑（先按 _entry-coordinator.ts 的说明重新打包）：
 *   npx esbuild harness/tools/_entry-coordinator.ts --bundle --format=esm \
 *     --outfile=harness/tools/_coordinator.mjs --alias:@=./src --define:import.meta.env='{}'
 *   node harness/tools/verify-company-info-passthrough.mjs
 */

import { ApiChatCoordinator } from './_coordinator.mjs';

let pass = 0;
let fail = 0;
const check = (name, cond, extra = '') => {
  if (cond) {
    pass++;
    console.log(`  ok   ${name}`);
  } else {
    fail++;
    console.log(`  FAIL ${name}${extra === '' ? '' : ` → ${JSON.stringify(extra)}`}`);
  }
};

const COMPANY_INFO = {
  company: { KeyNo: 'k1', Name: '上海测试科技有限公司', CreditCode: 'TESTCODE1', OperName: '张三' },
  profile: { data: { Name: '上海测试科技有限公司', CreditCode: 'TESTCODE1', OperName: '张三' }, source: { provider: '企查查' } },
  honors: { records: [], sources: [], complete: true, error: null },
};

const sse = (events) =>
  events
    .map(([event, data]) => `event: ${event}\ndata: ${JSON.stringify({ thread_id: 't1', request_id: 'r1', data })}\n\n`)
    .join('');

/** 把一段 SSE 文本打桩成 fetch 的响应 */
const stubFetchWith = (sseText) => {
  globalThis.fetch = async () => {
    const stream = new ReadableStream({
      start(controller) {
        controller.enqueue(new TextEncoder().encode(sseText));
        controller.close();
      },
    });
    return new Response(stream, { status: 200, headers: { 'Content-Type': 'text/event-stream' } });
  };
};

const runTurn = async (events) => {
  stubFetchWith(sse(events));
  const coordinator = new ApiChatCoordinator({ baseUrl: 'http://stub', threadId: 't1' });
  const seen = { totalResponse: null, messages: [] };
  coordinator.addEventListener('totalResponse', (payload) => (seen.totalResponse = payload));
  coordinator.addEventListener('message', (msg) => seen.messages.push(msg));
  await coordinator.generateAnswer('测试问题');
  // flushContent 会等两帧再 emit totalResponse，给它一点时间
  await new Promise((resolve) => setTimeout(resolve, 60));
  return seen;
};

const BASE_EVENTS = [
  ['accepted', { message: '收到' }],
  ['answer', { text: '这是回答正文。' }],
];

console.log('【1】result 带 company_info → totalResponse 原样带出');
{
  const seen = await runTurn([
    ...BASE_EVENTS,
    ['result', { response: '这是回答正文。', company_info: COMPANY_INFO, recommendation: null, errors: [] }],
    ['done', { status: 'completed' }],
  ]);

  check('收到了 totalResponse', !!seen.totalResponse, seen.totalResponse);
  check('payload 里有 company_info', !!seen.totalResponse?.company_info);
  check(
    '内容与后端下发**逐字段一致**（含嵌套的 company/profile/honors）',
    JSON.stringify(seen.totalResponse?.company_info) === JSON.stringify(COMPANY_INFO),
    seen.totalResponse?.company_info
  );
  check(
    '**没有混进渲染内容**（消息里不应出现 credit code）',
    !seen.messages.join('').includes('TESTCODE1'),
    seen.messages.map((m) => m.slice(0, 60))
  );
}

console.log('\n【2】result 不带 company_info → payload 里也不该有这个键');
{
  const seen = await runTurn([
    ...BASE_EVENTS,
    ['result', { response: '这是回答正文。', recommendation: null, errors: [] }],
    ['done', { status: 'completed' }],
  ]);
  check('没有 company_info 键（而不是 null）', seen.totalResponse && !('company_info' in seen.totalResponse), seen.totalResponse);
}

console.log('\n【3】company_info 为 null / 空对象 → 不往下传（省得白跑一次分类）');
{
  const seenNull = await runTurn([
    ...BASE_EVENTS,
    ['result', { response: 'x', company_info: null }],
    ['done', { status: 'completed' }],
  ]);
  check('company_info=null → 不传', seenNull.totalResponse && !('company_info' in seenNull.totalResponse));

  const seenEmpty = await runTurn([
    ...BASE_EVENTS,
    ['result', { response: 'x', company_info: {} }],
    ['done', { status: 'completed' }],
  ]);
  // 空对象会带出去（适配层不做业务判断），但下游的 isCompanyInfoUsable 会静默跳过
  check('company_info={} → 带出去交给下游判断', !!seenEmpty.totalResponse?.company_info, seenEmpty.totalResponse?.company_info);
}

console.log('\n【4】跨轮不串：上一轮有 company_info，下一轮没有 → 不该沿用');
{
  stubFetchWith(
    sse([
      ...BASE_EVENTS,
      ['result', { response: 'x', company_info: COMPANY_INFO }],
      ['done', { status: 'completed' }],
    ])
  );
  const coordinator = new ApiChatCoordinator({ baseUrl: 'http://stub', threadId: 't1' });
  const payloads = [];
  coordinator.addEventListener('totalResponse', (payload) => payloads.push(payload));
  await coordinator.generateAnswer('第一轮');
  await new Promise((resolve) => setTimeout(resolve, 60));

  stubFetchWith(
    sse([
      ...BASE_EVENTS,
      ['result', { response: 'x' }], // 这一轮没有 company_info
      ['done', { status: 'completed' }],
    ])
  );
  await coordinator.generateAnswer('第二轮');
  await new Promise((resolve) => setTimeout(resolve, 60));

  check('两轮各收到一次 totalResponse', payloads.length === 2, payloads.length);
  check('第一轮带 company_info', !!payloads[0]?.company_info);
  check('第二轮**没有**沿用上一轮的 company_info（resetTurnContent 生效）', !('company_info' in (payloads[1] || {})), payloads[1]);
}

console.log(`\n===== 通过 ${pass} 项，失败 ${fail} 项 =====`);
process.exit(fail ? 1 : 0);