53 lines
3.7 KiB
JavaScript
53 lines
3.7 KiB
JavaScript
// 表结构自愈冒烟：数组形态 + null 行 + 合法行混合 → 同步一次 → 治愈为 uuid 键对象且数据完整
|
||
const BASE = 'http://127.0.0.1:3780'
|
||
let pass = 0, fail = 0
|
||
function check(name, ok, detail) {
|
||
if (ok) { pass++; console.log(' PASS ' + name) } else { fail++; console.log(' FAIL ' + name + (detail ? ' -> ' + detail : '')) }
|
||
}
|
||
async function j(path, body, token) {
|
||
const r = await fetch(BASE + path, { method: 'POST', headers: { 'Content-Type': 'application/json', ...(token ? { Authorization: 'Bearer ' + token } : {}) }, body: body ? JSON.stringify(body) : undefined })
|
||
return { status: r.status, json: await r.json().catch(() => ({})) }
|
||
}
|
||
async function main() {
|
||
const fsp = await import('fs')
|
||
const reg = await j('/api/auth/register', { username: 'healtest', password: 'test123456' })
|
||
const tok = reg.json.token
|
||
const file = 'server/data/users/' + reg.json.userId + '.json'
|
||
// 构造坏文件：work_log 是数组 + 含 null 槽位；attendance 数组含 null；memo 正常对象但混入 null 行
|
||
const bad = {
|
||
userId: reg.json.userId, cursor: 0,
|
||
created_at: '2026-10-26T12:00:00.000Z',
|
||
tables: {
|
||
work_log: [ { uuid: 'wl1', date: '2026-10-20', created_at: '2026-10-20T00:00:00', updated_at: '2026-10-20T00:00:00' }, null, { uuid: 'wl2', date: '2026-10-21', created_at: '2026-10-21T00:00:00', updated_at: '2026-10-21T00:00:00' } ],
|
||
attendance: [ null, { uuid: 'at1', date: '2026-10-20', created_at: '2026-10-20T00:00:00', updated_at: '2026-10-20T00:00:00' } ],
|
||
memo: { m1: { uuid: 'm1', title: '幸存备忘', content: '', created_at: '2026-10-20T00:00:00', updated_at: '2026-10-20T00:00:00' }, bad: null },
|
||
plan: []
|
||
},
|
||
tombstones: { memo: { g1: null }, work_log: {} }
|
||
}
|
||
fsp.mkdirSync('server/data/users', { recursive: true })
|
||
fsp.writeFileSync(file, JSON.stringify(bad))
|
||
|
||
// 推送一行 work_log（自然键 date 扫描会遍历表）→ 修复前这里 500，修复后应 200
|
||
const r1 = await j('/api/sync', { device: 't', tables: { work_log: [ { uuid: 'wl3', date: '2026-10-22', created_at: '2026-10-22T00:00:00', updated_at: '2026-10-22T00:00:00' } ] }, tombstones: [] }, tok)
|
||
check('同步 200（不再读 null.date）', r1.status === 200, 'status=' + r1.status)
|
||
|
||
const healed = JSON.parse(fsp.readFileSync(file, 'utf8'))
|
||
check('work_log 已转 uuid 键对象', !Array.isArray(healed.tables.work_log) && !!healed.tables.work_log.wl1 && !!healed.tables.work_log.wl3)
|
||
check('null 行已剔除', !('1' in (healed.tables.work_log || {})) && !healed.tables.attendance['0'])
|
||
check('attendance 幸存行保留', healed.tables.attendance && healed.tables.attendance.at1)
|
||
check('memo 正常对象保留', healed.tables.memo && healed.tables.memo.m1)
|
||
check('null 墓碑已清理', !healed.tombstones.memo || !healed.tombstones.memo.g1)
|
||
check('全表均为对象形态', Object.values(healed.tables).every(x => x && !Array.isArray(x) && typeof x === 'object'))
|
||
|
||
// 推送 m1 更新（memo 无自然键）→ 再拉全量，快照中不得出现 null
|
||
await j('/api/sync', { device: 't', tables: { memo: [ { uuid: 'm2', title: '新备忘', content: '', created_at: '2026-10-26T00:00:00', updated_at: '2026-10-26T00:00:00' } ] }, tombstones: [] }, tok)
|
||
const r3 = await j('/api/sync', { device: 't', tables: {}, tombstones: [] }, tok)
|
||
const flat = Object.values(r3.json.tables || {}).flat()
|
||
check('权威快照不含 null/无uuid行', r3.status === 200 && flat.every(x => x && typeof x === 'object' && x.uuid), JSON.stringify(flat.filter(x => !x || !x.uuid)).slice(0, 100))
|
||
|
||
console.log('RESULT: ' + (fail === 0 ? 'ALL PASS ' + pass : 'FAIL ' + fail + '/' + (pass + fail)))
|
||
if (fail) process.exit(1)
|
||
}
|
||
main().catch(e => { console.error('SMOKE ERROR', e); process.exit(1) })
|