mirror of
https://wget.la/https://github.com/Wxw-Gu/WechatExplorer
synced 2026-10-04 03:01:42 +08:00
297 lines
11 KiB
TypeScript
297 lines
11 KiB
TypeScript
import { describe, expect, it } from 'vitest'
|
||
|
||
import {
|
||
planScheduledReportMigration,
|
||
planScheduledReportMigrationBatch,
|
||
scheduledReportMigrationRuleId,
|
||
type LegacyScheduledReportTask
|
||
} from '../../src/main/services/scheduled-report-migration'
|
||
import { SCHEDULED_REPORT_DEFAULT_MEMBER_NAME_MODE } from '../../src/shared/automation'
|
||
|
||
/**
|
||
* 旧「定时日报任务」→ `AutomationRule(ruleType='scheduled_report')` 的映射器。
|
||
*
|
||
* 这是本次迁移里**唯一会改变用户既有行为**的地方，所以每条断言都对应一条产品约束：
|
||
* - Rule ID 优先复用旧 taskId（不许拿显示名当稳定 ID）；
|
||
* - 配置无损映射（时间 / 范围 / 消息类型 / 模板 / 成员名口径 / 超时）；
|
||
* - 只有"能证明是同一个群"才无损映射成 `source_chat`；
|
||
* 历史行为事实上支持"生成 A 群日报 → 发 B 群"，新产品不支持 ⇒ 必须 `targetNeedsReview`
|
||
* 且 **enabled = false**，绝不自动改写、绝不静默丢掉目标；
|
||
* - 解析不到群标识时**保留原值**，运行期如实失败，而不是在这里猜一个群；
|
||
* - 批次按 id 去重 ⇒ 幂等（同一份文件跑两次结果一致）。
|
||
*/
|
||
|
||
const NOW = Date.parse('2026-08-27T10:00:00+08:00')
|
||
|
||
/** 假联系人表：md5 / 群名 → roomId。 */
|
||
const CONTACTS: Record<string, string> = {
|
||
'tech-md5': 'tech@chatroom',
|
||
'product-md5': 'product@chatroom',
|
||
'技术交流群': 'tech@chatroom'
|
||
}
|
||
|
||
/**
|
||
* 与 main 侧 `setLegacyConversationResolver` 注入的真实解析器**同口径**：
|
||
* - 以 `@chatroom` 结尾 ⇒ 原样返回（旧 UI 的 `target` 存的就是 roomId，
|
||
* 而 `chat.resolveMd5` 对 roomId 是查不到的，所以这条 pass-through 是必需的）；
|
||
* - 否则按 md5 / 群名查联系人表。
|
||
*/
|
||
const resolve = (raw: string): string | undefined => {
|
||
const key = raw.trim()
|
||
if (!key) return undefined
|
||
if (key.endsWith('@chatroom')) return key
|
||
return CONTACTS[key]
|
||
}
|
||
|
||
const task = (overrides: LegacyScheduledReportTask = {}): LegacyScheduledReportTask => ({
|
||
id: 'scheduled_report_old_1',
|
||
name: '技术交流群 · 每日日报',
|
||
group: 'tech-md5',
|
||
target: 'tech@chatroom',
|
||
scheduleTime: '09:15',
|
||
reportRange: 'yesterday',
|
||
messageTypes: ['text', 'image'],
|
||
templateId: 'v1',
|
||
memberNameMode: 'wechatNickname',
|
||
timeoutSeconds: 600,
|
||
enabled: true,
|
||
createdAt: '2026-08-01T01:00:00.000Z',
|
||
updatedAt: '2026-08-20T01:00:00.000Z',
|
||
...overrides
|
||
})
|
||
|
||
describe('定时日报迁移 · Rule ID', () => {
|
||
it('优先原样复用旧 taskId（不拿显示名当稳定 ID）', () => {
|
||
expect(scheduledReportMigrationRuleId(task())).toBe('scheduled_report_old_1')
|
||
|
||
// 改名字不影响 id —— 显示名不是身份。
|
||
expect(scheduledReportMigrationRuleId(task({ name: '换个名字' }))).toBe(
|
||
'scheduled_report_old_1'
|
||
)
|
||
})
|
||
|
||
it('旧 id 缺失时退化成由稳定字段派生的确定性 id（重复迁移不产生新规则）', () => {
|
||
const broken = task({ id: undefined })
|
||
const first = scheduledReportMigrationRuleId(broken)
|
||
const second = scheduledReportMigrationRuleId({ ...broken })
|
||
|
||
expect(first).toMatch(/^scheduled-report:[0-9a-f]{32}$/)
|
||
expect(second).toBe(first)
|
||
})
|
||
|
||
it('id 全是空白字符时同样走派生路径', () => {
|
||
expect(scheduledReportMigrationRuleId(task({ id: ' ' }))).toMatch(/^scheduled-report:/)
|
||
})
|
||
})
|
||
|
||
describe('定时日报迁移 · 逐字段无损映射', () => {
|
||
it('配置字段一个不丢（不是"看起来差不多"）', () => {
|
||
const plan = planScheduledReportMigration(task(), resolve, NOW)
|
||
|
||
expect(plan.outcome).toBe('lossless_source_chat')
|
||
expect(plan.name).toBe('技术交流群 · 每日日报')
|
||
expect(plan.enabled).toBe(true)
|
||
expect(plan.config.schedule).toEqual({ time: '09:15' })
|
||
expect(plan.config.report).toEqual({
|
||
// 来源群存**稳定会话 id**：旧值 'tech-md5' 被解析成 roomId。
|
||
sourceConversationId: 'tech@chatroom',
|
||
range: 'yesterday',
|
||
messageTypes: ['text', 'image'],
|
||
templateId: 'v1',
|
||
memberNameMode: 'wechatNickname',
|
||
timeoutSeconds: 600
|
||
})
|
||
expect(plan.config.target).toEqual({ type: 'source_chat' })
|
||
expect(plan.config.targetNeedsReview).toBeUndefined()
|
||
expect(plan.config.legacyTarget).toBeUndefined()
|
||
// 来源群被改写过 ⇒ 留下原文方便用户核对。
|
||
expect(plan.config.legacySourceGroup).toBe('tech-md5')
|
||
})
|
||
|
||
it('createdAt / updatedAt 继承旧值（ISO → 毫秒），非法值回落迁移时刻', () => {
|
||
const plan = planScheduledReportMigration(task(), resolve, NOW)
|
||
expect(plan.createdAt).toBe(Date.parse('2026-08-01T01:00:00.000Z'))
|
||
expect(plan.updatedAt).toBe(Date.parse('2026-08-20T01:00:00.000Z'))
|
||
|
||
const broken = planScheduledReportMigration(
|
||
task({ createdAt: '不是时间', updatedAt: undefined }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
expect(broken.createdAt).toBe(NOW)
|
||
expect(broken.updatedAt).toBe(NOW)
|
||
})
|
||
|
||
it('继承调度游标（lastRunAt / lastScheduledSlot），避免迁移后重复补跑', () => {
|
||
const slot = new Date('2026-08-26T09:15:00+08:00').toISOString()
|
||
const plan = planScheduledReportMigration(
|
||
task({ lastRunAt: '2026-08-26T01:15:00.000Z', lastScheduledSlot: slot }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
|
||
expect(plan.config.lastRunAt).toBe('2026-08-26T01:15:00.000Z')
|
||
expect(plan.config.lastScheduledSlot).toBe(slot)
|
||
})
|
||
|
||
it('脏值一律收敛到合法默认值，绝不落一条跑不起来的规则', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({
|
||
scheduleTime: '99:99',
|
||
reportRange: '一个不存在的范围',
|
||
messageTypes: ['不存在的类型'],
|
||
templateId: '不存在的模板',
|
||
memberNameMode: '不存在的口径',
|
||
timeoutSeconds: 999999
|
||
}),
|
||
resolve,
|
||
NOW
|
||
)
|
||
|
||
expect(plan.config.schedule.time).toBe('18:30')
|
||
expect(plan.config.report.range).toBe('today')
|
||
expect(plan.config.report.messageTypes).toEqual(['text'])
|
||
expect(plan.config.report.templateId).toBe('v1')
|
||
expect(plan.config.report.memberNameMode).toBe(SCHEDULED_REPORT_DEFAULT_MEMBER_NAME_MODE)
|
||
expect(plan.config.report.timeoutSeconds).toBe(1800)
|
||
})
|
||
|
||
it('名字缺失时回落到「定时日报」，不会留一条空名字的规则', () => {
|
||
expect(planScheduledReportMigration(task({ name: ' ' }), resolve, NOW).name).toBe('定时日报')
|
||
})
|
||
})
|
||
|
||
describe('定时日报迁移 · 发送目标（唯一会改变行为的地方）', () => {
|
||
it('target 为空 ⇒ 旧系统本就回落到来源群，等价于 source_chat', () => {
|
||
const plan = planScheduledReportMigration(task({ target: '' }), resolve, NOW)
|
||
expect(plan.outcome).toBe('lossless_source_chat')
|
||
expect(plan.config.target).toEqual({ type: 'source_chat' })
|
||
expect(plan.config.targetNeedsReview).toBeUndefined()
|
||
})
|
||
|
||
it('target 与 group 文本相同 ⇒ 无损映射（不依赖能否解析）', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({ group: 'tech-md5', target: 'tech-md5' }),
|
||
() => undefined,
|
||
NOW
|
||
)
|
||
expect(plan.outcome).toBe('lossless_source_chat')
|
||
expect(plan.config.targetNeedsReview).toBeUndefined()
|
||
})
|
||
|
||
it('两者都解析到同一个 roomId ⇒ 无损映射（旧 UI 的常态：group=md5, target=roomId）', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({ group: 'tech-md5', target: 'tech@chatroom' }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
expect(plan.outcome).toBe('lossless_source_chat')
|
||
|
||
// 这条无损判定**依赖**解析器对 `@chatroom` 的 pass-through：
|
||
// 少了它，旧 UI 里每一组 (md5, roomId) 都会退化成 needs_review，
|
||
// 等于把所有用户的定时日报全部停用。
|
||
expect(resolve('tech@chatroom')).toBe('tech@chatroom')
|
||
})
|
||
|
||
it('target 指向**另一个群** ⇒ needs_review + 强制停用 + 保留旧目标原文', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({ group: 'tech-md5', target: 'product@chatroom' }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
|
||
expect(plan.outcome).toBe('needs_review')
|
||
// 不能自动改写目标，也不能在用户确认前就被定时发出去。
|
||
expect(plan.enabled).toBe(false)
|
||
expect(plan.config.targetNeedsReview).toBe(true)
|
||
expect(plan.config.legacyTarget).toBe('product@chatroom')
|
||
})
|
||
|
||
it('target 无法解析 ⇒ 一律 needs_review（拿不到证据就不自动改写）', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({ group: 'tech-md5', target: 'unknown-id' }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
expect(plan.outcome).toBe('needs_review')
|
||
expect(plan.enabled).toBe(false)
|
||
expect(plan.config.legacyTarget).toBe('unknown-id')
|
||
})
|
||
|
||
it('needs_review 的规则即使旧任务是启用的也必须停用', () => {
|
||
const plan = planScheduledReportMigration(
|
||
task({ target: 'product@chatroom', enabled: true, group: 'tech-md5' }),
|
||
resolve,
|
||
NOW
|
||
)
|
||
expect(plan.enabled).toBe(false)
|
||
})
|
||
|
||
it('来源群解析不到 ⇒ 保留原值，不在迁移期猜一个群', () => {
|
||
const plan = planScheduledReportMigration(task({ group: '未知群', target: '' }), resolve, NOW)
|
||
// 原值留着 —— 运行期会如实失败，比"悄悄换一个群发"安全得多。
|
||
expect(plan.config.report.sourceConversationId).toBe('未知群')
|
||
expect(plan.config.legacySourceGroup).toBeUndefined()
|
||
})
|
||
})
|
||
|
||
describe('定时日报迁移 · 批次幂等', () => {
|
||
const tasks: LegacyScheduledReportTask[] = [
|
||
task({ id: 'scheduled_report_a', name: 'A', group: 'tech-md5', target: 'tech@chatroom' }),
|
||
task({ id: 'scheduled_report_b', name: 'B', group: 'product-md5', target: 'product@chatroom' }),
|
||
task({ id: 'scheduled_report_c', name: 'C', group: 'tech-md5', target: 'product@chatroom' })
|
||
]
|
||
|
||
it('3 条旧任务 ⇒ 3 条规则，并给出判定分布', () => {
|
||
const { plans, summary } = planScheduledReportMigrationBatch(tasks, resolve, NOW)
|
||
|
||
expect(plans.map((plan) => plan.ruleId)).toEqual([
|
||
'scheduled_report_a',
|
||
'scheduled_report_b',
|
||
'scheduled_report_c'
|
||
])
|
||
expect(summary).toEqual({
|
||
total: 3,
|
||
migrated: 3,
|
||
lossless: 2,
|
||
needsReview: 1,
|
||
duplicatesSkipped: 0
|
||
})
|
||
})
|
||
|
||
it('重复执行结果完全一致（幂等，不是"看起来没多"）', () => {
|
||
const first = planScheduledReportMigrationBatch(tasks, resolve, NOW)
|
||
const second = planScheduledReportMigrationBatch(tasks, resolve, NOW)
|
||
expect(second).toEqual(first)
|
||
})
|
||
|
||
it('同一 id 出现两次只迁一条，并如实计入 duplicatesSkipped', () => {
|
||
const { plans, summary } = planScheduledReportMigrationBatch(
|
||
[tasks[0], task({ id: 'scheduled_report_a', name: '重复' })],
|
||
resolve,
|
||
NOW
|
||
)
|
||
|
||
expect(plans).toHaveLength(1)
|
||
expect(plans[0].name).toBe('A')
|
||
expect(summary.total).toBe(2)
|
||
expect(summary.migrated).toBe(1)
|
||
expect(summary.duplicatesSkipped).toBe(1)
|
||
})
|
||
|
||
it('文件里混进非对象元素时跳过而不是崩掉', () => {
|
||
const { plans } = planScheduledReportMigrationBatch(
|
||
[tasks[0], null as unknown as LegacyScheduledReportTask, 'x' as unknown as LegacyScheduledReportTask],
|
||
resolve,
|
||
NOW
|
||
)
|
||
expect(plans).toHaveLength(1)
|
||
})
|
||
|
||
it('空文件 ⇒ 0 条规则（全新安装路径）', () => {
|
||
const { plans, summary } = planScheduledReportMigrationBatch([], resolve, NOW)
|
||
expect(plans).toHaveLength(0)
|
||
expect(summary.migrated).toBe(0)
|
||
})
|
||
})
|