zhaoshang_client_ui/harness/tools/verify-dms-payload-fields.mjs

/**
 * 验证写 DMS 时**到底发了哪些字段**（不需要 token，也不碰真实 DMS）。
 *
 * 为什么要单独测这个：用户明确要求 —— **「我的需求是传 title，不要传类似于 summary
 * 的多余的字段」**。字段多发/少发是很容易在后续改动里被"顺手"改掉的，
 * 而且它不像业务逻辑那样有直观的行为反馈，所以直接把请求体抓下来断言。
 *
 * 做法：把 `globalThis.fetch` 打桩，捕获模块真实发出的 form body，
 * 解析出 `content` 的键集合，断言「不多不少」。
 *
 * 怎么跑（在项目根目录）：
 *   npx esbuild harness/tools/_entry-dms.ts --bundle --format=esm \
 *     --outfile=harness/tools/_dms.mjs --alias:@=./src --define:import.meta.env='{}'
 *   node harness/tools/verify-dms-payload-fields.mjs
 */

globalThis.VITE_DMS_API = 'http://dms.invalid/dms'; // 只为让 base 非空；请求会被打桩拦住

// ── 打桩 fetch：捕获请求，返回可控响应 ────────────────────────────────
const captured = [];
const json = (obj) => new Response(JSON.stringify(obj), { status: 200, headers: { 'Content-Type': 'application/json' } });

globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });

  if (String(url).includes('/content/selectContentList')) {
    return json({ code: 202, message: '数据不存在', content: '数据不存在' }); // 空 → 走新增分支
  }
  if (String(url).includes('/content/addContent')) {
    return json({ code: 200, message: '成功', content: 'stub-uuid-0001' });
  }
  if (String(url).includes('/content/updateContent')) {
    return json({ code: 200, message: '成功', content: '执行成功' });
  }
  return json({ code: 200, message: '成功', content: '' });
};

const { upsertDmsSession, upsertDmsRecord } = await import('./_dms.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);
  }
};

/** 取出最近一次某端点的请求体里 content 的字段名（排序后） */
const keysOfLast = (endpoint) => {
  const hit = [...captured].reverse().find((c) => c.url.includes(endpoint));
  if (!hit) return null;
  const params = new URLSearchParams(hit.body);
  const content = JSON.parse(params.get('content') || '{}');
  return Object.keys(content).sort();
};

const DISALLOWED = ['summary', 'qpyszx', 'qyzt', 'rzqpyx'];

console.log('\n【1】会话新增：字段必须「不多不少」');
await upsertDmsSession({ sessionId: 'sess-A', title: '会话标题甲', creditCode: '91310118TEST' });
let keys = keysOfLast('/content/addContent');
const EXPECT_SESSION_ADD = ['c_created_at', 'c_credit_code', 'c_session_id', 'c_source', 'c_title', 'c_updated_at', 'title'].sort();
check('字段集合与预期完全一致', JSON.stringify(keys) === JSON.stringify(EXPECT_SESSION_ADD), `实际 ${JSON.stringify(keys)}`);
check('**带 title**（用户需求）', keys?.includes('title') === true);
check('不含 summary/qpyszx/qyzt/rzqpyx 等多余字段', !DISALLOWED.some((k) => keys?.includes(k)), JSON.stringify(keys));

console.log('\n【2】会话改名（更新）：也要带 title');
captured.length = 0;
// 让这次走「更新」分支：先让 search 返回一行
globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });
  if (String(url).includes('/content/selectContentList')) {
    return json({ code: 200, message: '成功', content: { data: [{ id: 'row-uuid', c_session_id: 'sess-A' }], count: 1 } });
  }
  return json({ code: 200, message: '成功', content: '执行成功' });
};
await upsertDmsSession({ sessionId: 'sess-A', title: '会话标题乙', creditCode: '91310118TEST' });
keys = keysOfLast('/content/updateContent');
check('更新走的是 updateContent', keys !== null);
check('**更新也带 title**（原先不带，改名后 DMS 里标题不变）', keys?.includes('title') === true, JSON.stringify(keys));
check('更新不带多余的运营字段', !DISALLOWED.some((k) => keys?.includes(k)), JSON.stringify(keys));

console.log('\n【3】问答记录新增：title = 问题文本，且不多发字段');
captured.length = 0;
globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });
  if (String(url).includes('/content/selectContentList')) return json({ code: 202, message: '数据不存在', content: '数据不存在' });
  if (String(url).includes('/content/addContent')) return json({ code: 200, message: '成功', content: 'stub-uuid-0002' });
  return json({ code: 200, message: '成功', content: '' });
};
await upsertDmsRecord({ recordId: 'rec-A', sessionId: 'sess-A', creditCode: '91310118TEST', question: '这是问题文本' });
keys = keysOfLast('/content/addContent');
const EXPECT_RECORD_ADD = ['c_created_at', 'c_credit_code', 'c_question', 'c_record_id', 'c_session_id', 'c_source', 'title'].sort();
check('字段集合与预期完全一致', JSON.stringify(keys) === JSON.stringify(EXPECT_RECORD_ADD), `实际 ${JSON.stringify(keys)}`);
check('不含 summary 等多余字段', !DISALLOWED.some((k) => keys?.includes(k)), JSON.stringify(keys));

const hit = [...captured].reverse().find((c) => c.url.includes('/content/addContent'));
const content = JSON.parse(new URLSearchParams(hit.body).get('content'));
check('**title 的值就是问题文本**', content.title === '这是问题文本', JSON.stringify(content.title));

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