diff --git a/e2e/README.md b/e2e/README.md index 02256dc..eac4c46 100644 --- a/e2e/README.md +++ b/e2e/README.md @@ -2,135 +2,53 @@ ## 现有用例 -| 文件 | 说明 | 默认是否执行 | -| --------------------------- | ------------------------------------------------------------------------- | ----------------- | -| `smoke.spec.ts` | A0 冒烟：登录、模块切换、403 / 404 | 是 | -| `a1-identity.spec.ts` | A1-QA-01 账号生命周期（①–⑥） | 否，需 `A1_E2E=1` | -| `a2-roles.spec.ts` | A2-QA-01 角色管理 / 权限三态 / SoD / 即时生效 | 否，需 `A2_E2E=1` | -| `a3-client.spec.ts` | A3-QA-01 客户与行业六页可访问 / 数据加载 | 否，需 `A3_E2E=1` | -| `a4-dicts-settings.spec.ts` | A4-QA-01 数据字典 / 三层合并 / 编码只读 / 系统配置 / 阈值确认 / 变更记录 | 否，需 `A4_E2E=1` | -| `a5-audit-logs.spec.ts` | A5-QA-01 操作日志列表 / 筛选 / 详情 diff / 导出闭环 / 权限三态 / 运行日志 | 否，需 `A5_E2E=1` | +| 文件 | 说明 | 默认是否执行 | +| --------------------------- | ------------------------------------------------------------------------------- | ----------------- | +| `smoke.spec.ts` | A0 冒烟：登录、模块切换、403 / 404 | 是 | +| `a1-identity.spec.ts` | A1-QA-01 账号生命周期（①–⑥） | 否，需 `A1_E2E=1` | +| `a2-roles.spec.ts` | A2-QA-01 角色管理 / 权限三态 / SoD / 即时生效 | 否，需 `A2_E2E=1` | +| `a3-client.spec.ts` | A3-QA-01 客户与行业六页可访问 / 数据加载 | 否，需 `A3_E2E=1` | +| `a4-dicts-settings.spec.ts` | A4-QA-01 数据字典 / 三层合并 / 编码只读 / 系统配置 / 阈值确认 / 变更记录 | 否，需 `A4_E2E=1` | +| `a5-audit-logs.spec.ts` | A5-QA-01 操作日志列表 / 筛选 / 详情 diff / 导出闭环 / 权限三态 / 运行日志 | 否，需 `A5_E2E=1` | +| `a6-tasks.spec.ts` | A6-QA-01 任务提交 / SSE 进度 / 取消 / 仅重试失败项 / 幂等 / 断点续推 / 权限三态 | 否，需 `A6_E2E=1` | -## A1 账号生命周期用例 +## A6 任务中心用例（A6-QA-01） -覆盖 6 类：首登强改 → 重登 → `/users`；刷新页面单飞刷新；登出后 refresh 失效；停用后旧会话与再登录被拒；角色变更下一次请求生效；无 `user:view` 访问 `/users` 显示 403。 +覆盖： + +1. 提交演练任务（混合模式）→ 列表出现 → 详情 SSE 推进至「部分失败」→ 只重试失败项 → 状态回排队 / 生成中； +2. 顶栏任务角标显示进行中数量，点开面板可进入任务详情； +3. 提交后立即在详情取消任务 → 状态「已取消」，未开始项显示「已跳过」； +4. 同一 `Idempotency-Key` + 同一 body 重复提交返回同一 taskId（API 断言）； +5. SSE `Last-Event-ID` 续推：先读一段事件流记录 seq，再按 `Last-Event-ID` 重连，断言首帧 seq 更大、不重发历史； +6. 权限三态：无 `material:render` 只有 `material:read` → 不渲染提交 / 取消 / 重试；无 `material:read` → `/403`。 ### 前置 -1. API：`pnpm --filter @lingxi/api dev`（`http://127.0.0.1:3000/api/v1`，真实 PG + Redis，已 `pnpm db:init`；**不要执行 `db:reset`**，会清空本地账号密码）。 -2. Web：`pnpm --filter @lingxi/web dev`（`http://127.0.0.1:5173`，需 `VITE_PUBLIC_DEMO_SESSION=false`，否则登录走演示会话）。 -3. 管理员 actor：默认用种子超管 `jiang.lan`（首登会把初始密码 `lingxi2026` 改成 `QaE2eAdmin2026`，之后复用）。 - 若本地已改密或想换账号，覆盖：`A1_E2E_ACTOR_ACCOUNT` / `A1_E2E_ACTOR_PASSWORD`。 - ⚠️ 不要用 `admin`：本地 `admin` 密码可能已被人工修改或触发登录锁定。 - ⚠️ e2e 会把 actor 密码改成 `QaE2eAdmin2026`（之后复用），请用专用测试账号/测试库，不要指向日常在用的账号。 +1. API：`pnpm --filter @lingxi/api dev`（`http://127.0.0.1:3000/api/v1`，真实 PG + Redis，已 `pnpm db:init`；**不要执行 `db:reset`**）。 +2. Worker：`pnpm --filter @lingxi/worker dev`（`QUEUE=all` 或至少 `QUEUE=verify`；demo 任务走 `media:verify` 队列，不启动 worker 时进度不会推进）。 +3. Web：`pnpm --filter @lingxi/web dev`（`http://127.0.0.1:5173`）。 +4. 本地浏览器：默认用系统 Chrome（`PLAYWRIGHT_CHANNEL` 未设置时）；若使用 Playwright 自带 Chromium，先 + `PLAYWRIGHT_BROWSERS_PATH=.dev/playwright-browsers pnpm exec playwright install chromium`，再设置 + `PLAYWRIGHT_CHANNEL=''`。 + +### 数据自建自清 + +`beforeAll` 直接经 Prisma 创建三个临时账号（密码 `lingxi2026`）： + +- `qa6.tasks.e2e`（`super_admin`）：提交 / 取消 / 重试全流程； +- `qa6.tasks.ro`（临时角色 `a6e2e_task_viewer`，仅 `material:read` + 全部数据范围）：只读三态； +- `qa6.tasks.none`（临时角色 `a6e2e_no_material`，仅 `delivery:read`）：访问列表 → 403。 + +`afterAll` 删除临时账号、角色、临时任务的 task_events / media_items / media_tasks、幂等键与 outbox 事件； +审计日志 append-only，产生的记录不删除（预期留痕）。 ### 运行 ```bash -A1_E2E=1 pnpm exec playwright test e2e/a1-identity.spec.ts --reporter=list +A6_E2E=1 pnpm exec playwright test e2e/a6-tasks.spec.ts --reporter=list ``` -- 可选覆盖：`A1_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A1_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）。 -- 截图：`design/a1-ui-v1/shots/impl/e2e/`（`01-*` … `06-*`）。 -- 数据自建自清：用管理员 token 通过 API 创建 `qa.first.* / qa.main.* / qa.noperm.* / qa.disable.*` 四个用户，结束后统一停用（不删除，便于审计回看）；不改 admin 密码。 - -### 说明 - -- 门控未开启（无 `A1_E2E=1`）时整文件 `test.skip`，`pnpm test:e2e` 与 CI 行为不变。 -- 若在 `vite preview`（4173）上执行，需把 API 的 `WEB_ORIGIN` 同时包含 `http://127.0.0.1:4173`，否则跨域请求被拦；本用例默认打 5173 dev，避免改动 API 配置。 - -## A2 角色管理用例（A2-QA-01） - -覆盖一条完整旅程（真实 API + 真实 PG/Redis + 真实浏览器）： - -1. 管理员登录 → `/system/roles` → 新建角色（名称、2 个普通权限、数据范围「本部门」）→ 保存进入编辑器。 -2. 编辑器改权限点；授予特殊权限（`delivery:export` 开关）触发**二次确认**，保存前再确认一次（特殊权限双确认）。 -3. SoD 冲突：同时勾选 `script:write` × `script:review` → 顶部「命中职责互斥」拦截 + 底部「存在职责互斥，保存不可用」且保存按钮禁用；解除后恢复可保存。 -4. 用 API 断言**权限即时生效**：绑定用户同一 access token 的 `/me` 在下一次请求即包含 `user:view` 与 `delivery:export`，`GET /users` 由 403 → 200；`GET /roles/{id}` 的普通权限与特殊权限分桶正确。 -5. 权限三态（UI 侧）：该用户有 `user:view` 但无 `role:view`，访问 `/system/roles` 显示 403 页。 -6. 停用确认（勾选知晓 + 停用原因）→ 编辑器状态变「停用」；API 断言 `/me` 权限清空、`GET /users` 返回 403 `40301`；列表「停用」筛选下可见该角色且行内标记「停用」。 -7. 数据自建自清：`beforeAll` 按前缀清理上次异常中断的遗留角色/用户；`afterAll` 解绑并停用 `qa2.roles.*` 用户、删除 `A2E2E-角色-*` 角色（不停用 admin、不改 admin 密码）。 - -### 前置与运行 - -前置与 A1 相同（API `http://127.0.0.1:3000/api/v1`、Web `http://127.0.0.1:5173` 非 demo 会话、已 `pnpm db:init`）： - -```bash -A2_E2E=1 pnpm exec playwright test e2e/a2-roles.spec.ts --reporter=list -``` - -- 门控未开启（无 `A2_E2E=1`）时整文件 `test.skip`，`pnpm test:e2e` / CI 行为不变。 -- 可选覆盖：`A2_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A2_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）、`A2_E2E_ACTOR_ACCOUNT` / `A2_E2E_ACTOR_PASSWORD`（缺省 `jiang.lan` / `QaE2eAdmin2026`，首跑用种子口令 `lingxi2026` 自动完成首登改密）。 -- 截图：`design/a2-ui-v1/shots/impl/e2e/`（`01-roles-list` … `11-roles-list-disabled`，共 11 张 1440×900）。 -- 说明：用户按 A1 口径只停用不删除（用户不可删）；角色在解绑后删除，可重复运行。 - -## A3 客户与行业用例（A3-QA-01） - -覆盖：登录注入 → 行业管理 / 客户列表 / 新建客户 / 客户组 / 字段审批五页标题 → 客户列表有数据 → 点击行进入客户详情深链。 - -### 前置与运行 - -1. API 3000 + Web 5173（`pnpm dev`，真实 PG；已执行 `pnpm db:init`）。 -2. 用例自建临时超管 `qa3.e2e`（Prisma 写入，结束后删除），不依赖本地账号密码。 - -```bash -A3_E2E=1 pnpm exec playwright test e2e/a3-client.spec.ts --reporter=list -``` - -- 可选覆盖：`A3_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A3_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）。 -- 截图：`design/a3-ui-v1/impl/`（实施报告引用）。 - -## A4 数据字典与系统配置用例（A4-QA-01） - -覆盖 7 条： - -1. `/system/dicts` 主从页：h1、左侧「字典类型」、右栏 `script_direction` 类型头、三层 chips（通用 5 + 父行业 2 + 本行业 1 = 生效 7）、默认行业「电商 / 服饰鞋包」、种草短视频（已覆盖）/ 直播切片 / 穿搭教程；树 ↔ 词表切换（`?view=tree|list`）；行业作用域切全平台（生效 5）再切回。 -2. 条目：新增 SideSheet → 列表出现 → 编辑态编码 disabled 且值锁定 → Modal.confirm 停用 / 启用 → 行状态变化。 -3. 类型：新建（`a4e2e_` 唯一 code + 名称 + 分组 + 形态树）→ 左侧类型列表可见 → 编辑类型编码 / 形态只读。 -4. `/system/settings`：6 组导航、6 个占位符 chips、实时预览「电商-花间集-口播-20261104-01」、模板行内编辑与放弃恢复。 -5. 阈值：客户基础字段上限改 12 → 保存全部更改 → 二次确认 → toast / Prisma 断言版本 +1 / 变更记录抽屉含前后值与原因。 -6. 只读态：无 `dict:manage` / `system:configure` 账号访问两页 → `/403`。 -7. 未登录访问 `/system/dicts` → 重定向登录页。 - -### 前置与运行 - -1. API 3000 + Web 5173（`pnpm dev`，真实 PG；已执行 `pnpm db:init`）。 -2. 用例自建临时超管 `qa4.dicts.e2e` 与只读账号 `qa4.dicts.ro`（Prisma 写入，结束后删除）；字典类型 / 条目按 `a4e2e_` 前缀清理；系统配置保存后恢复原值并删除本次 history。 - -```bash -A4_E2E=1 pnpm exec playwright test e2e/a4-dicts-settings.spec.ts --reporter=list -``` - -- 可选覆盖：`A4_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A4_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）。 -- 结果：7 passed（约 1.1m）。 -- 截图：不生成常驻截图；失败时 Playwright 默认 `only-on-failure` 落 `test-results/`。 - -### 选择器校准（Semi） - -- Semi Select 选项可访问名含图标 aria-label（tick），精确匹配不到，使用 `.semi-select-option` 文本点击。 -- `Modal.confirm` 的确认 / 取消按钮 `aria-label` 固定为 `confirm` / `cancel`，不要按 `okText` 文本定位。 -- `RadioGroup` 隐藏 input 被 addon 拦截，点可见文本或 `.semi-radio-addon-buttonRadio`。 - -## A5 审计与日志用例（A5-QA-01） - -覆盖 5 条： - -1. `/system/audit-logs` 列表可见：h1「操作日志」、副标题、查看留痕提示条（`audit.log.view`）、表格有数据、导出按钮（超管）。 -2. 筛选：动作分类「权限与角色」→ URL `?category=permission` 且结果变化；「重置」恢复默认。 -3. 详情：点击「修改角色权限」行 → `/system/audit-logs/{id}`；变更对比含「权限点」；元信息含 trace_id / IP / 请求 / 耗时；切换「原始 JSON」可看到完整记录（occurred_at / actor / action / target / before / after）；只读说明存在。 -4. 导出闭环：打开 560 抽屉 → 创建导出任务 → 轮询到「导出完成」→ 导出历史出现「已完成」任务 → API 断言 `download_token` 存在且签名下载返回 200 CSV → 关闭抽屉并重置筛选后，列表出现 `audit.export` 记录（导出自身留痕）。 -5. 权限三态：无 `audit:read` 账号访问 `/system/audit-logs` → `/403`；仅有 `audit:read`（自定义角色，无 `audit:export`）→ 页面显示「只读 · 无 audit:export 权限」且不渲染导出按钮。 -6. 运行日志：`audit.logs_platform_url` 置空 → 空态 + 「前往系统配置」；写入示例地址后刷新 → 外链与平台入口卡存在；结束后还原配置。 - -### 前置与运行 - -1. API 3000 + Web 5173（`pnpm dev`，真实 PG；已执行 `pnpm db:init`）。 -2. 用例自建临时账号 `qa5.audit.e2e`（超管）、`qa5.audit.viewer`（仅 `audit:read`）、`qa5.audit.ro`（素材运营，无 `audit:read`）与自定义角色 `a5e2e_audit_viewer`；结束后删除账号 / 角色并还原 `audit.logs_platform_url`。 -3. ⚠️ 审计表 append-only：用例产生的登录 / 查看 / 导出 / 下载审计记录**不删除**，属预期留痕。 - -```bash -A5_E2E=1 pnpm exec playwright test e2e/a5-audit-logs.spec.ts --reporter=list -``` - -- 可选覆盖：`A5_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A5_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）。 -- 用例不点击外网链接；运行日志只断言外链 href 存在。 +- 可选覆盖：`A6_E2E_BASE_URL`（缺省 `http://127.0.0.1:5173`）、`A6_E2E_API_BASE_URL`（缺省 `http://127.0.0.1:3000/api/v1`）。 +- 截图：`design/a6-ui-v1/shots/impl/e2e/`。 +- 门控未开启（无 `A6_E2E=1`）时整文件 `test.skip`，`pnpm test:e2e` 与 CI 行为不变。 diff --git a/e2e/a6-tasks.spec.ts b/e2e/a6-tasks.spec.ts new file mode 100644 index 0000000..ece57f6 --- /dev/null +++ b/e2e/a6-tasks.spec.ts @@ -0,0 +1,562 @@ +/// +/** + * A6-QA-01 · 任务中心端到端用例（真实 API + 真实 worker + 真实浏览器） + * + * 覆盖： + * ① 提交演练任务（混合模式）→ 列表出现 → 详情 SSE 推进到「部分失败」→ 仅重试失败项； + * ② 顶栏任务角标显示进行中数量，面板可进入任务详情； + * ③ 提交后立即取消 → 状态「已取消」，未开始项「已跳过」； + * ④ 同一 Idempotency-Key + 同一 body 返回同一 taskId，不同 body 40902（API 断言）； + * ⑤ SSE Last-Event-ID 断点续推：重连首帧 seq 更大、不重发历史； + * ⑥ 权限三态：仅 material:read 不渲染写操作；无 material:read → /403。 + * + * 门控：仅 A6_E2E=1 时执行；默认 skip，不影响 smoke / CI。 + * 前置：API 3000、Web 5173、worker（QUEUE=all 或 verify）与真实 PG / Redis，已 `pnpm db:init`。 + * 数据自建自清：临时账号 qa6.tasks.e2e / qa6.tasks.ro / qa6.tasks.none + 两个临时角色； + * 结束后删除临时任务（级联任务项 / 事件）、幂等键、outbox 事件、账号与角色；审计记录保留（预期留痕）。 + * + * 运行：A6_E2E=1 pnpm exec playwright test e2e/a6-tasks.spec.ts --reporter=list + */ +import { randomBytes } from 'node:crypto'; + +import { type APIRequestContext, expect, type Page, request, test } from '@playwright/test'; +import { PrismaClient } from '@prisma/client'; + +const API_BASE = process.env.A6_E2E_API_BASE_URL ?? 'http://127.0.0.1:3000/api/v1'; +const WEB_BASE = process.env.A6_E2E_BASE_URL ?? 'http://127.0.0.1:5173'; +const ENABLED = process.env.A6_E2E === '1'; + +const PASSWORD = 'lingxi2026'; +/** 与 a1 / a3 / a4 / a5 共用（明文 lingxi2026） */ +const PASSWORD_HASH = + '$argon2id$v=19$m=65536,p=4,t=3$Osdgg3Fz53AwcoC2kyGiGg$QVbxW7Ok/SlCNbML95go2J/6GMSfE1EG3jBTJgR4zO4'; + +const ADMIN_ACCOUNT = 'qa6.tasks.e2e'; +const ADMIN_NAME = 'A6 E2E 超管'; +const READONLY_ACCOUNT = 'qa6.tasks.ro'; +const READONLY_NAME = 'A6 E2E 只读'; +const NONE_ACCOUNT = 'qa6.tasks.none'; +const NONE_NAME = 'A6 E2E 无权限'; +const READONLY_ROLE_CODE = 'a6e2e_task_viewer'; +const READONLY_ROLE_ID = '01HZZZZZZZZZZZZZZZZZZZA6E1'; +const NONE_ROLE_CODE = 'a6e2e_no_material'; +const NONE_ROLE_ID = '01HZZZZZZZZZZZZZZZZZZZA6E2'; + +const ENCODING = '0123456789ABCDEFGHJKMNPQRSTVWXYZ'; +const prisma = new PrismaClient(); + +let apiContext: APIRequestContext | null = null; +let adminSession: QaSession | null = null; +let readonlySession: QaSession | null = null; +let noneSession: QaSession | null = null; +let customerId = ''; +let adminUserId = ''; +let readonlyUserId = ''; +let noneUserId = ''; +const createdTaskIds: string[] = []; + +interface QaSession { + accessToken: string; + refreshToken: string; + user: { id: string; name: string; account: string }; + permissions: string[]; + mustChangePassword: boolean; +} + +interface TaskDetail { + id: string; + status: string; + itemFailed: number; + itemSkipped: number; +} + +test.skip(!ENABLED, 'A6_E2E=1 才运行任务中心 e2e（依赖 API :3000 + worker + web :5173 + PG）'); + +test.use({ baseURL: WEB_BASE, viewport: { width: 1440, height: 900 } }); + +// --------------------------------------------------------------------------- +// 基础工具 +// --------------------------------------------------------------------------- + +function ulid(): string { + let time = Date.now(); + const timeChars = new Array(10); + for (let index = 9; index >= 0; index -= 1) { + timeChars[index] = ENCODING[time % 32] ?? '0'; + time = Math.floor(time / 32); + } + const random = randomBytes(16); + return `${timeChars.join('')}${Array.from(random, (byte) => ENCODING[byte & 31] ?? '0').join('')}`; +} + +function isRecord(value: unknown): value is Record { + return typeof value === 'object' && value !== null && !Array.isArray(value); +} + +function requireRecord(value: unknown, label: string): Record { + if (!isRecord(value)) throw new Error(`${label} 不是 JSON 对象`); + return value; +} + +function stringArray(value: unknown): string[] { + return Array.isArray(value) + ? value.filter((item): item is string => typeof item === 'string') + : []; +} + +function requireApi(): APIRequestContext { + if (apiContext === null) throw new Error('APIRequestContext 未初始化'); + return apiContext; +} + +function requireAdminSession(): QaSession { + if (adminSession === null) throw new Error('超管会话未就绪'); + return adminSession; +} + +function requireReadonlySession(): QaSession { + if (readonlySession === null) throw new Error('只读会话未就绪'); + return readonlySession; +} + +function requireNoneSession(): QaSession { + if (noneSession === null) throw new Error('无权限会话未就绪'); + return noneSession; +} + +async function injectSession(page: Page, session: QaSession): Promise { + const persisted = { + accessToken: session.accessToken, + refreshToken: session.refreshToken, + user: session.user, + permissions: session.permissions, + mustChangePassword: session.mustChangePassword, + }; + await page.addInitScript((value: unknown) => { + window.localStorage.setItem('lingxi.auth.session', JSON.stringify(value)); + }, persisted); +} + +async function loginViaApi(account: string): Promise { + const context = requireApi(); + const login = await context.post(`${API_BASE}/auth/login`, { + data: { account, password: PASSWORD }, + }); + expect(login.status(), `POST /auth/login ${account}`).toBe(200); + const rawLogin = (await login.text()) || '{}'; + const body = requireRecord(JSON.parse(rawLogin) as unknown, '登录响应'); + if (typeof body.accessToken !== 'string' || body.accessToken === '') { + throw new Error( + `登录响应缺少 accessToken：HTTP ${String(login.status())} body=${rawLogin.slice(0, 300)}`, + ); + } + const accessToken = body.accessToken; + const refreshToken = String(body.refreshToken); + const meResponse = await context.get(`${API_BASE}/me`, { + headers: { authorization: `Bearer ${accessToken}` }, + }); + expect(meResponse.status(), `GET /me ${account}`).toBe(200); + const rawMe = (await meResponse.text()) || '{}'; + const me = requireRecord(JSON.parse(rawMe) as unknown, '/me 响应'); + const user = requireRecord(me.user, '/me.user'); + return { + accessToken, + refreshToken, + user: { + id: String(user.id), + name: String(user.name), + account: String(user.account), + }, + permissions: stringArray(me.permissions), + mustChangePassword: me.mustChangePassword === true, + }; +} + +async function createRole( + code: string, + id: string, + name: string, + permissions: string[], +): Promise { + await prisma.role.deleteMany({ where: { code } }); + await prisma.role.create({ + data: { + id, + code, + name, + description: 'A6 e2e 临时角色', + isSystem: false, + status: 'ACTIVE', + permissions: { create: permissions.map((permissionCode) => ({ permissionCode })) }, + dataScopes: { create: [{ id: ulid(), scopeType: 'all' }] }, + }, + }); +} + +async function createUser( + account: string, + name: string, + roleCodes: readonly string[], +): Promise { + const [department, roles] = await Promise.all([ + prisma.department.findUniqueOrThrow({ where: { code: 'content-g1' } }), + prisma.role.findMany({ where: { code: { in: [...roleCodes] } }, select: { id: true } }), + ]); + await prisma.user.deleteMany({ where: { account } }); + const userId = ulid(); + await prisma.user.create({ + data: { + id: userId, + name, + account, + email: `${account}@lingxi.cn`, + phone: `139${randomBytes(4).readUInt32BE(0).toString().padStart(8, '0').slice(-8)}`, + passwordHash: PASSWORD_HASH, + departmentId: department.id, + mustChangePassword: false, + roles: { create: roles.map((role) => ({ roleId: role.id })) }, + }, + }); + return userId; +} + +async function createTaskViaApi( + token: string, + input: { itemCount: number; mode: 'success' | 'mixed' | 'fail' }, + idempotencyKey: string, +): Promise<{ status: number; taskId: string | null }> { + const response = await fetch(`${API_BASE}/media-tasks`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + Authorization: `Bearer ${token}`, + 'Idempotency-Key': idempotencyKey, + }, + body: JSON.stringify({ + type: 'demo', + customerId, + itemCount: input.itemCount, + mode: input.mode, + }), + }); + const body: unknown = await response.json().catch(() => null); + const taskId = isRecord(body) && typeof body.taskId === 'string' ? body.taskId : null; + return { status: response.status, taskId }; +} + +async function fetchTaskDetail(token: string, taskId: string): Promise { + const response = await fetch(`${API_BASE}/media-tasks/${taskId}`, { + headers: { Authorization: `Bearer ${token}` }, + }); + expect(response.ok, `GET /media-tasks/${taskId}`).toBe(true); + const rawDetail = (await response.text()) || '{}'; + const body = requireRecord(JSON.parse(rawDetail) as unknown, '任务详情'); + return { + id: String(body.id), + status: String(body.status), + itemFailed: typeof body.itemFailed === 'number' ? body.itemFailed : 0, + itemSkipped: typeof body.itemSkipped === 'number' ? body.itemSkipped : 0, + }; +} + +/** 读取 SSE 首个事件帧的 id（用于 Last-Event-ID 续推验证），读完即断开 */ +async function readSseFirstEventId( + taskId: string, + token: string, + lastEventId?: string, +): Promise { + const controller = new AbortController(); + const timer = setTimeout(() => { + controller.abort(); + }, 20_000); + try { + const query = + lastEventId === undefined ? '' : `?last_event_id=${encodeURIComponent(lastEventId)}`; + const response = await fetch(`${API_BASE}/media-tasks/${taskId}/events${query}`, { + headers: { Authorization: `Bearer ${token}`, Accept: 'text/event-stream' }, + signal: controller.signal, + }); + expect(response.ok, 'SSE 响应').toBe(true); + const reader = response.body?.getReader(); + if (reader === undefined) throw new Error('SSE 响应无 body'); + const decoder = new TextDecoder(); + let buffer = ''; + for (;;) { + const { done, value } = await reader.read(); + if (done) break; + buffer += decoder.decode(value, { stream: true }); + const match = /^id:\s*(\d+)$/m.exec(buffer); + if (match?.[1] !== undefined) { + await reader.cancel().catch(() => undefined); + return match[1]; + } + } + throw new Error('SSE 未收到带 id 的事件'); + } finally { + clearTimeout(timer); + controller.abort(); + } +} + +async function waitToast(page: Page, text: RegExp): Promise { + await expect(page.locator('[role="alert"]').filter({ hasText: text }).first()).toBeVisible({ + timeout: 15_000, + }); +} + +// --------------------------------------------------------------------------- +// 全局编排 +// --------------------------------------------------------------------------- + +test.beforeAll(async () => { + if (!ENABLED) return; + apiContext = await request.newContext(); + try { + const web = await apiContext.get(`${WEB_BASE}/`); + expect(web.status(), `web 未就绪：请在 ${WEB_BASE} 启动前端`).toBe(200); + + const customer = await prisma.customer.findFirst({ + where: { status: 'ACTIVE' }, + select: { id: true }, + orderBy: { createdAt: 'asc' }, + }); + if (customer === null) throw new Error('缺少可提交任务的启用客户，请先执行 seed'); + customerId = customer.id; + + // 清理上次异常中断的遗留（按临时账号名 / 角色 code） + await prisma.mediaTask.deleteMany({ where: { createdByName: { in: [ADMIN_NAME] } } }); + await createRole(READONLY_ROLE_CODE, READONLY_ROLE_ID, 'A6 端到端任务只读', ['material:read']); + await createRole(NONE_ROLE_CODE, NONE_ROLE_ID, 'A6 端到端无任务权限', ['delivery:read']); + adminUserId = await createUser(ADMIN_ACCOUNT, ADMIN_NAME, ['super_admin']); + readonlyUserId = await createUser(READONLY_ACCOUNT, READONLY_NAME, [READONLY_ROLE_CODE]); + noneUserId = await createUser(NONE_ACCOUNT, NONE_NAME, [NONE_ROLE_CODE]); + + adminSession = await loginViaApi(ADMIN_ACCOUNT); + readonlySession = await loginViaApi(READONLY_ACCOUNT); + noneSession = await loginViaApi(NONE_ACCOUNT); + } catch (error) { + throw error instanceof Error ? error : new Error(String(error)); + } +}); + +test.afterAll(async () => { + if (!ENABLED) { + await prisma.$disconnect(); + return; + } + const ids = createdTaskIds.filter((id) => id !== ''); + try { + await prisma.outboxEvent.deleteMany({ + where: { aggregateType: 'media_task', aggregateId: { in: ids } }, + }); + await prisma.mediaTask.deleteMany({ where: { id: { in: ids } } }); + await prisma.mediaTask.deleteMany({ + where: { + createdBy: { in: [adminUserId, readonlyUserId, noneUserId].filter((id) => id !== '') }, + }, + }); + await prisma.idempotencyKey.deleteMany({ where: { key: { startsWith: 'a6e2e-' } } }); + await prisma.user.deleteMany({ + where: { account: { in: [ADMIN_ACCOUNT, READONLY_ACCOUNT, NONE_ACCOUNT] } }, + }); + await prisma.role.deleteMany({ where: { code: { in: [READONLY_ROLE_CODE, NONE_ROLE_CODE] } } }); + } finally { + await apiContext?.dispose(); + await prisma.$disconnect(); + } +}); + +// --------------------------------------------------------------------------- +// 用例 +// --------------------------------------------------------------------------- + +test('① 提交演练任务 → 列表 → 详情 SSE → 部分失败 → 仅重试失败项', async ({ page }) => { + const session = requireAdminSession(); + await injectSession(page, session); + await page.goto('/material/tasks'); + + await expect(page.getByRole('heading', { name: '任务中心', level: 1 })).toBeVisible(); + await expect(page.getByRole('button', { name: /提交演练任务/ }).first()).toBeVisible(); + + await page + .getByRole('button', { name: /提交演练任务/ }) + .first() + .click(); + const submitModal = page.locator('.semi-modal').filter({ hasText: '提交演练任务' }); + await expect(submitModal).toBeVisible(); + + // 客户：选第一个可选项；条数 8；混合模式 + await submitModal.locator('.semi-select').first().click(); + await page.locator('.semi-select-option').first().click(); + await submitModal.locator('.semi-input-number input').fill('8'); + await submitModal.getByRole('button', { name: /混合成功/ }).click(); + + const submitResponsePromise = page.waitForResponse( + (response) => + response.request().method() === 'POST' && + new URL(response.url()).pathname.endsWith('/media-tasks'), + ); + await submitModal.getByRole('button', { name: '提交演练任务' }).click(); + const submitResponse = await submitResponsePromise; + expect(submitResponse.status()).toBe(202); + const submitBody = requireRecord((await submitResponse.json()) as unknown, '提交响应'); + const taskId = String(submitBody.taskId); + if (taskId === '' || taskId === 'undefined') { + throw new Error(`提交响应缺少 taskId：${JSON.stringify(submitBody).slice(0, 300)}`); + } + createdTaskIds.push(taskId); + await waitToast(page, /已提交/); + + const taskNo = `T-${taskId.slice(-6).toUpperCase()}`; + await expect( + page.locator('.semi-table-tbody tr').filter({ hasText: taskNo }).first(), + ).toBeVisible({ timeout: 15_000 }); + + // 顶栏角标出现进行中任务，面板可打开 + await page.locator('.lx-task-badge-trigger button').click(); + await expect(page.getByText('进行中的任务').first()).toBeVisible({ timeout: 10_000 }); + await expect(page.locator('.lx-task-badge-row').filter({ hasText: /演练/ }).first()).toBeVisible({ + timeout: 10_000, + }); + await page.keyboard.press('Escape'); + + await page.goto(`/material/tasks/${taskId}`); + await expect(page.getByRole('heading', { level: 1 })).toContainText('项'); + await expect + .poll(async () => (await fetchTaskDetail(session.accessToken, taskId)).status, { + timeout: 40_000, + message: '等待演练任务收敛为部分失败', + }) + .toBe('partial_failed'); + await expect(page.getByText('部分失败').first()).toBeVisible({ timeout: 15_000 }); + await expect(page.getByText('演练模拟失败').first()).toBeVisible({ timeout: 15_000 }); + + const retryButton = page.getByRole('button', { name: /重试失败项/ }).first(); + await expect(retryButton).toBeVisible(); + await retryButton.click(); + const confirmModal = page.locator('.semi-modal').filter({ hasText: '重试失败项' }); + await expect(confirmModal).toBeVisible(); + await confirmModal.getByRole('button', { name: /重试 \d+ 项/ }).click(); + await waitToast(page, /已提交重试/); + + await expect + .poll(async () => (await fetchTaskDetail(session.accessToken, taskId)).status, { + timeout: 40_000, + message: '等待重试后的任务再次收敛', + }) + .toBe('partial_failed'); +}); + +test('② 提交后立即取消 → 已取消且未开始项跳过', async ({ page }) => { + const session = requireAdminSession(); + const { status, taskId } = await createTaskViaApi( + session.accessToken, + { itemCount: 20, mode: 'success' }, + `a6e2e-cancel-${Date.now().toString(36)}-${randomBytes(3).toString('hex')}`, + ); + expect(status).toBe(202); + if (taskId === null) throw new Error('取消用例未拿到 taskId'); + createdTaskIds.push(taskId); + + await injectSession(page, session); + await page.goto(`/material/tasks/${taskId}`); + await expect(page.getByRole('button', { name: '取消任务' }).first()).toBeVisible({ + timeout: 15_000, + }); + await page.getByRole('button', { name: '取消任务' }).first().click(); + const confirmModal = page.locator('.semi-modal').filter({ hasText: '取消后不可恢复' }); + await expect(confirmModal).toBeVisible(); + await confirmModal.getByRole('button', { name: '取消任务' }).click(); + await waitToast(page, /任务已取消/); + + await expect + .poll(async () => (await fetchTaskDetail(session.accessToken, taskId)).status, { + timeout: 30_000, + message: '等待任务取消', + }) + .toBe('canceled'); + await expect(page.getByText('已取消').first()).toBeVisible({ timeout: 15_000 }); + const detail = await fetchTaskDetail(session.accessToken, taskId); + expect(detail.itemSkipped).toBeGreaterThan(0); +}); + +test('③ 同一 Idempotency-Key 重复提交返回同一任务，不同 body 冲突', async () => { + const session = requireAdminSession(); + const key = `a6e2e-idem-${Date.now().toString(36)}-${randomBytes(3).toString('hex')}`; + const first = await createTaskViaApi(session.accessToken, { itemCount: 3, mode: 'success' }, key); + const second = await createTaskViaApi( + session.accessToken, + { itemCount: 3, mode: 'success' }, + key, + ); + expect(first.status).toBe(202); + expect(second.status).toBe(202); + expect(second.taskId).toBe(first.taskId); + if (first.taskId !== null) createdTaskIds.push(first.taskId); + + const fetchConflict = await fetch(`${API_BASE}/media-tasks`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + Authorization: `Bearer ${session.accessToken}`, + 'Idempotency-Key': key, + }, + body: JSON.stringify({ type: 'demo', customerId, itemCount: 4, mode: 'success' }), + }); + expect(fetchConflict.status).toBe(409); + const conflictBody = requireRecord((await fetchConflict.json()) as unknown, '冲突响应'); + expect(conflictBody.code).toBe(40902); +}); + +test('④ SSE Last-Event-ID 断点续推不重发历史', async () => { + const session = requireAdminSession(); + const { status, taskId } = await createTaskViaApi( + session.accessToken, + { itemCount: 20, mode: 'success' }, + `a6e2e-sse-${Date.now().toString(36)}-${randomBytes(3).toString('hex')}`, + ); + expect(status).toBe(202); + if (taskId === null) throw new Error('SSE 用例未拿到 taskId'); + createdTaskIds.push(taskId); + + const firstId = await readSseFirstEventId(taskId, session.accessToken); + const secondId = await readSseFirstEventId(taskId, session.accessToken, firstId); + expect(Number(secondId)).toBeGreaterThan(Number(firstId)); +}); + +test('⑤ 只读用户不渲染提交 / 取消 / 重试', async ({ page }) => { + const admin = requireAdminSession(); + const readonly = requireReadonlySession(); + const { status, taskId } = await createTaskViaApi( + admin.accessToken, + { itemCount: 4, mode: 'mixed' }, + `a6e2e-ro-${Date.now().toString(36)}-${randomBytes(3).toString('hex')}`, + ); + expect(status).toBe(202); + if (taskId === null) throw new Error('只读用例未拿到 taskId'); + createdTaskIds.push(taskId); + // 等任务执行结束，保证详情页展示的是可取消 / 可重试的状态而不是排队中 + await expect + .poll(async () => (await fetchTaskDetail(admin.accessToken, taskId)).status, { + timeout: 40_000, + }) + .not.toBe('queued'); + + await injectSession(page, readonly); + await page.goto('/material/tasks'); + await expect(page.getByRole('heading', { name: '任务中心', level: 1 })).toBeVisible(); + await expect(page.getByRole('button', { name: /提交演练任务/ })).toHaveCount(0); + await expect(page.getByText(/只读权限/).first()).toBeVisible({ timeout: 10_000 }); + + await page.goto(`/material/tasks/${taskId}`); + await expect(page.getByRole('heading', { level: 1 })).toContainText('项'); + await expect(page.getByRole('button', { name: '取消任务' })).toHaveCount(0); + await expect(page.getByRole('button', { name: /重试失败项/ })).toHaveCount(0); +}); + +test('⑥ 无 material:read 用户访问任务中心 → 403', async ({ page }) => { + const none = requireNoneSession(); + await injectSession(page, none); + await page.goto('/material/tasks'); + await expect(page).toHaveURL(/\/403$/, { timeout: 15_000 }); +}); diff --git a/eslint.config.mjs b/eslint.config.mjs index 24bdbb8..950b991 100644 --- a/eslint.config.mjs +++ b/eslint.config.mjs @@ -24,6 +24,7 @@ export default tseslint.config( '**/coverage/**', '**/.turbo/**', '.tools/**', + '.dev/**', 'design/**', 'docs/**', 'openapi/**', diff --git a/playwright.config.ts b/playwright.config.ts index c9427de..3afedeb 100644 --- a/playwright.config.ts +++ b/playwright.config.ts @@ -1,6 +1,12 @@ import { defineConfig, devices } from '@playwright/test'; -const channel = process.env.CI ? undefined : 'chrome'; +// 本地默认用系统 Chrome；CI / 显式 PLAYWRIGHT_CHANNEL='' 时使用 Playwright 自带 Chromium +const channel = + process.env.PLAYWRIGHT_CHANNEL === undefined + ? process.env.CI + ? undefined + : 'chrome' + : process.env.PLAYWRIGHT_CHANNEL || undefined; export default defineConfig({ testDir: './e2e',