|
|
@@ -0,0 +1,109 @@
|
|
|
+/**
|
|
|
+ * 验证写 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);
|
