83 lines
4.1 KiB
TypeScript
83 lines
4.1 KiB
TypeScript
import 'fake-indexeddb/auto'
|
|
import { bindDatabase, WorklogDB } from '../src/db/schema'
|
|
|
|
// node 环境的 localStorage 垫片（引擎的纪元/idMap 存取需要）
|
|
const lsMap = new Map<string, string>()
|
|
;(globalThis as any).localStorage = {
|
|
getItem: (k: string) => (lsMap.has(k) ? lsMap.get(k)! : null),
|
|
setItem: (k: string, v: string) => { lsMap.set(k, String(v)) },
|
|
removeItem: (k: string) => { lsMap.delete(k) }
|
|
}
|
|
|
|
const BASE = 'http://127.0.0.1:3780'
|
|
let pass = 0
|
|
let fail = 0
|
|
function check(name: string, ok: boolean, detail?: string): void {
|
|
if (ok) { pass++; console.log(' PASS ' + name) }
|
|
else { fail++; console.log(' FAIL ' + name + (detail ? ' -> ' + detail : '')) }
|
|
}
|
|
|
|
async function main() {
|
|
await fetch(BASE + '/api/auth/register', {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify({ username: 'restore', password: 'dev123456' })
|
|
}).catch(() => { /* 已存在忽略 */ })
|
|
|
|
const engine = await import('../src/sync/engine')
|
|
const CONF = { baseUrl: BASE, username: 'restore', password: 'dev123456' }
|
|
|
|
// ===== 设备 A：备忘录 x3 + 密码库密文 x1 + 设置 =====
|
|
bindDatabase(new WorklogDB('restore_a'))
|
|
const a = (await import('../src/db/schema')).db
|
|
const now = '2026-10-26T10:00:00'
|
|
await a.memo.bulkAdd([
|
|
{ title: '备忘一', content: '内容一', created_at: now, updated_at: now },
|
|
{ title: '备忘二', content: '内容二', created_at: now, updated_at: now },
|
|
{ title: '备忘三', content: '内容三', created_at: now, updated_at: now }
|
|
])
|
|
await a.credential.bulkAdd([
|
|
{ system: '企业邮箱', account: 'dev@x.com', password: 'enc:v1:FAKECIPHER', remark: '', created_at: now, updated_at: now }
|
|
])
|
|
await a.setting.bulkAdd([
|
|
{ key: 'work_start', value: '09:00' },
|
|
{ key: 'pwd_salt', value: 'SALTSALT' },
|
|
{ key: 'pwd_verifier', value: 'enc:v1:VERIFIER' }
|
|
])
|
|
const rA = await engine.runSync(CONF)
|
|
console.log('设备A 首次推送:', JSON.stringify({ p: rA.pushed, e: rA.errors }))
|
|
|
|
// ===== 灾难：服务器用户数据文件被删（模拟 rm -rf data / 目录重建）=====
|
|
const fsx = await import('fs')
|
|
const usersDir = 'server/data/users'
|
|
for (const f of fsx.readdirSync(usersDir)) fsx.rmSync(usersDir + '/' + f)
|
|
console.log('已删除服务器用户数据文件')
|
|
|
|
// ===== 设备 A 再次同步：应触发二道防线，自动全量重推自救 =====
|
|
// （设备 A 此前从未存过纪元 —— 恰好覆盖「首次升级即遇到灾难」的窗口）
|
|
const rA2 = await engine.runSync(CONF)
|
|
console.log('设备A 自救同步:', JSON.stringify({ p: rA2.pushed, e: rA2.errors }))
|
|
check('自救时自动重推了全部本地数据(pushed>=7)', rA2.pushed >= 7, 'pushed=' + rA2.pushed)
|
|
const aMemo = await a.memo.toArray()
|
|
const aCred = await a.credential.toArray()
|
|
check('设备A 本地数据未被清空(备忘录仍 3 条)', aMemo.length === 3, 'len=' + aMemo.length)
|
|
check('设备A 本地密码库未被清空(仍 1 条)', aCred.length === 1, 'len=' + aCred.length)
|
|
|
|
// ===== 全新设备 C：拉取验证服务器已被 A 恢复 =====
|
|
bindDatabase(new WorklogDB('restore_c'))
|
|
const c = (await import('../src/db/schema')).db
|
|
const rC = await engine.runSync(CONF)
|
|
console.log('设备C 拉取:', JSON.stringify({ p: rC.pushed, e: rC.errors }))
|
|
const cMemo = await c.memo.toArray()
|
|
const cCred = await c.credential.toArray()
|
|
const cSet = await c.setting.toArray()
|
|
check('设备C 拉到 3 条备忘录', cMemo.length === 3, 'len=' + cMemo.length)
|
|
check('设备C 拉到密码库密文', cCred.length === 1 && cCred[0].system === '企业邮箱', 'len=' + cCred.length)
|
|
check('设备C 拉到主密码盐与校验值(密码库可解锁前提)', cSet.some(s => s.key === 'pwd_salt' && s.value === 'SALTSALT') && cSet.some(s => s.key === 'pwd_verifier'))
|
|
check('设备C 拉到考勤规则', cSet.some(s => s.key === 'work_start' && s.value === '09:00'))
|
|
|
|
console.log('RESULT: ' + (fail === 0 ? 'ALL PASS ' + pass : 'FAIL ' + fail + '/' + (pass + fail)))
|
|
if (fail > 0) process.exit(1)
|
|
}
|
|
main().catch(e => { console.error('SMOKE ERROR', e); process.exit(1) })
|