diff --git a/tests/e2e/scenarios/employees.steps.ts b/tests/e2e/scenarios/employees.steps.ts new file mode 100644 index 0000000..61c6c6a --- /dev/null +++ b/tests/e2e/scenarios/employees.steps.ts @@ -0,0 +1,206 @@ +/** + * Step-handlers для employees. + * + * Центральная проверка безопасности (ТЗ 0.4): увольнение/удаление сотрудника + * обязано гасить логин связанного User. Состояние Employee.IsActive и + * Employee.IsDeleted не должно расходиться с User.IsActive, иначе уволенный + * сотрудник продолжает входить в систему и обновлять токены. + */ +import { login, makeClient } from '../lib/api.js' +import { psql } from '../lib/db.js' +import type { CheckResult, Step, Report } from '../lib/report.js' +import axios from 'axios' +import { Agent as HttpsAgent } from 'node:https' + +const TS = Date.now() +const httpsAgent = new HttpsAgent({ rejectUnauthorized: false }) +const BASE = process.env.E2E_ADMIN_URL ?? 'https://admin.food-market.kz' + +interface Ctx { + apiOnly: boolean + superToken?: string + adminToken?: string + orgId?: string + roleId?: string + empId?: string + empEmail?: string + empPwd?: string + empRefresh?: string + bEmpId?: string +} +interface StepCtx { ctx: Ctx; step: Step; report: Report } + +function check(step: Step, c: CheckResult) { step.checks.push(c) } +function asString(x: unknown): string { + if (x == null) return '' + if (typeof x === 'string') return x + try { return JSON.stringify(x).slice(0, 200) } catch { return String(x) } +} +function q1(sql: string): string { return (psql(sql).trim().split('\n')[0] ?? '').trim() } + +async function rawToken(body: Record) { + const res = await axios.post(`${BASE}/connect/token`, new URLSearchParams(body), + { httpsAgent, headers: { 'Content-Type': 'application/x-www-form-urlencoded' }, validateStatus: () => true }) + return { status: res.status, data: res.data } +} +const loginRaw = (email: string, pwd: string) => rawToken({ + grant_type: 'password', username: email, password: pwd, + client_id: 'food-market-web', scope: 'openid profile email roles api offline_access', +}) +const refreshRaw = (rt: string) => rawToken({ + grant_type: 'refresh_token', refresh_token: rt, client_id: 'food-market-web', + scope: 'openid profile email roles api offline_access', +}) + +async function ensureSuper(ctx: Ctx): Promise { + if (!ctx.superToken) ctx.superToken = (await login('admin@food-market.local', 'Admin12345!')).accessToken + return ctx.superToken +} + +async function createOrg(saToken: string, label: string) { + const r = await makeClient(saToken).post('/api/super-admin/organizations', { + org: { name: `Emp ${label} ${TS}`, countryCode: 'KZ', bin: null, address: null, phone: null, email: null, defaultCurrencyId: null, accountOwnerUserId: null }, + adminLastName: label, adminFirstName: 'Admin', adminEmail: `emp-${label.toLowerCase()}-${TS}@example.kz`, adminPosition: null, + }) + return r +} + +// --------------------------------------------------------------------------- + +export async function step01_bootstrap({ ctx, step, report }: StepCtx) { + const sa = await ensureSuper(ctx) + const orgRes = await createOrg(sa, 'A') + if (orgRes.status !== 200) { report.bug({ step: '01', severity: 'critical', title: 'bootstrap орг', detail: asString(orgRes.data) }); return } + ctx.orgId = orgRes.data.organization.id + ctx.adminToken = (await login(orgRes.data.adminEmail, orgRes.data.adminTempPassword)).accessToken + const api = makeClient(ctx.adminToken) + const roles = await api.get('/api/organization/employee-roles') + const list = roles.data?.items ?? roles.data ?? [] + const role = list.find((r: { name: string }) => r.name !== 'Администратор') ?? list[0] + ctx.roleId = role?.id + check(step, { kind: 'api', description: 'Орг A + не-админская роль найдены', ok: !!ctx.orgId && !!ctx.roleId, detail: `role=${role?.name}` }) +} + +export async function step02_create_without_account({ ctx, step }: StepCtx) { + if (!ctx.roleId) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + const r = await api.post('/api/organization/employees', { + lastName: 'Безучётный', firstName: 'Иван', roleId: ctx.roleId, isActive: true, createAccount: false, + }) + check(step, { kind: 'api', description: 'Создан без учётки → 200/201', ok: r.status === 200 || r.status === 201, detail: `status=${r.status}` }) + check(step, { kind: 'api', description: 'UserId = null', ok: r.data?.employee?.userId == null, detail: `userId=${r.data?.employee?.userId}` }) + check(step, { kind: 'api', description: 'generatedPassword отсутствует', ok: !r.data?.generatedPassword }) +} + +export async function step03_create_with_account({ ctx, step, report }: StepCtx) { + if (!ctx.roleId) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + ctx.empEmail = `worker-${TS}@example.kz` + const r = await api.post('/api/organization/employees', { + lastName: 'Сотрудников', firstName: 'Пётр', roleId: ctx.roleId, isActive: true, + createAccount: true, email: ctx.empEmail, + }) + check(step, { kind: 'api', description: 'Создан с учёткой → 200/201', ok: r.status === 200 || r.status === 201, detail: `status=${r.status}` }) + ctx.empId = r.data?.employee?.id + ctx.empPwd = r.data?.generatedPassword + check(step, { kind: 'api', description: 'Temp password возвращён один раз', ok: !!ctx.empPwd }) + check(step, { kind: 'api', description: 'UserId присвоен', ok: !!r.data?.employee?.userId, detail: `userId=${r.data?.employee?.userId}` }) + if (!ctx.empId || !ctx.empPwd) report.bug({ step: '03', severity: 'high', title: 'Учётка сотрудника не создана', detail: asString(r.data) }) +} + +export async function step04_email_required({ ctx, step }: StepCtx) { + if (!ctx.roleId) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + const r = await api.post('/api/organization/employees', { + lastName: 'Безмыла', firstName: 'Анна', roleId: ctx.roleId, isActive: true, createAccount: true, email: '', + }) + check(step, { kind: 'api', description: 'createAccount=true без email → 400', ok: r.status === 400, detail: `status=${r.status}` }) +} + +export async function step05_duplicate_email({ ctx, step }: StepCtx) { + if (!ctx.roleId || !ctx.empEmail) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + const r = await api.post('/api/organization/employees', { + lastName: 'Дубль', firstName: 'Мария', roleId: ctx.roleId, isActive: true, createAccount: true, email: ctx.empEmail, + }) + check(step, { kind: 'api', description: 'Дубль email → 4xx (rejected)', ok: r.status >= 400 && r.status < 500, detail: `status=${r.status}` }) +} + +export async function step06_account_can_login({ ctx, step, report }: StepCtx) { + if (!ctx.empEmail || !ctx.empPwd) { step.status = 'skip'; return } + const r = await loginRaw(ctx.empEmail, ctx.empPwd) + check(step, { kind: 'api', description: 'Логин новым сотрудником → 200', ok: r.status === 200, detail: `status=${r.status}` }) + ctx.empRefresh = r.data?.refresh_token + if (r.status !== 200) report.bug({ step: '06', severity: 'high', title: 'Созданный сотрудник не может войти', detail: asString(r.data) }) +} + +export async function step07_fire_blocks_login({ ctx, step, report }: StepCtx) { + if (!ctx.empId || !ctx.empEmail || !ctx.empPwd) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + const del = await api.delete(`/api/organization/employees/${ctx.empId}`) + check(step, { kind: 'api', description: 'Увольнение (DELETE) → 204', ok: del.status === 204, detail: `status=${del.status}` }) + // Состояние в БД: уволен, не удалён. + const empActive = q1(`SELECT "IsActive" FROM employees WHERE "Id"='${ctx.empId}'`) + check(step, { kind: 'db', description: 'Employee.IsActive=false (уволен)', ok: empActive === 'f' || empActive === 'false', detail: `IsActive=${empActive}` }) + const userActive = q1(`SELECT u."IsActive" FROM users u JOIN employees e ON e."UserId"=u."Id" WHERE e."Id"='${ctx.empId}'`) + check(step, { kind: 'db', description: 'User.IsActive=false (логин погашен)', ok: userActive === 'f' || userActive === 'false', detail: `User.IsActive=${userActive}` }) + + // Главное: уволенный больше НЕ логинится и НЕ обновляет токен. + const reLogin = await loginRaw(ctx.empEmail, ctx.empPwd) + check(step, { kind: 'api', description: 'Повторный login уволенного → 4xx', ok: reLogin.status >= 400 && reLogin.status < 500, detail: `status=${reLogin.status}` }) + if (reLogin.status === 200) report.bug({ step: '07', severity: 'critical', + title: 'Уволенный сотрудник продолжает логиниться', + detail: 'DELETE сотрудника не гасит User.IsActive — уволенный сохраняет полный доступ (ТЗ 0.4).' }) + if (ctx.empRefresh) { + const ref = await refreshRaw(ctx.empRefresh) + check(step, { kind: 'api', description: 'Refresh уволенного → 4xx', ok: ref.status >= 400 && ref.status < 500, detail: `status=${ref.status}` }) + if (ref.status === 200) report.bug({ step: '07', severity: 'critical', + title: 'Старый refresh уволенного всё ещё рабочий', detail: 'Увольнение не отзывает активные сессии.' }) + } +} + +export async function step08_two_step_delete({ ctx, step }: StepCtx) { + if (!ctx.empId) { step.status = 'skip'; return } + const api = makeClient(ctx.adminToken!) + const del2 = await api.delete(`/api/organization/employees/${ctx.empId}`) + check(step, { kind: 'api', description: 'Второй DELETE → 204 (soft-delete)', ok: del2.status === 204, detail: `status=${del2.status}` }) + const isDeleted = q1(`SELECT "IsDeleted" FROM employees WHERE "Id"='${ctx.empId}'`) + check(step, { kind: 'db', description: 'Employee.IsDeleted=true', ok: isDeleted === 't' || isDeleted === 'true', detail: `IsDeleted=${isDeleted}` }) + const del3 = await api.delete(`/api/organization/employees/${ctx.empId}`) + check(step, { kind: 'api', description: 'Третий DELETE → 409 (уже удалён)', ok: del3.status === 409, detail: `status=${del3.status}` }) +} + +export async function step09_owner_self_protected({ ctx, step }: StepCtx) { + const api = makeClient(ctx.adminToken!) + const list = await api.get('/api/organization/employees?status=all') + const items = list.data?.items ?? list.data ?? [] + const owner = items.find((e: { isOwner: boolean }) => e.isOwner) + check(step, { kind: 'api', description: 'Главный администратор найден в списке', ok: !!owner, detail: `owner=${owner?.id}` }) + if (!owner) return + const r = await api.delete(`/api/organization/employees/${owner.id}`) + check(step, { kind: 'api', description: 'DELETE главного администратора (он же self) → 403', ok: r.status === 403, detail: `status=${r.status}` }) +} + +export async function step10_tenant_isolation({ ctx, step, report }: StepCtx) { + const sa = await ensureSuper(ctx) + const orgB = await createOrg(sa, 'B') + if (orgB.status !== 200) { step.status = 'skip'; return } + const bAdmin = (await login(orgB.data.adminEmail, orgB.data.adminTempPassword)).accessToken + const bApi = makeClient(bAdmin) + const bRoles = await bApi.get('/api/organization/employee-roles') + const bRoleId = (bRoles.data?.items ?? bRoles.data ?? []).find((r: { name: string }) => r.name !== 'Администратор')?.id + const bEmp = await bApi.post('/api/organization/employees', { + lastName: 'ЧужойB', firstName: 'Орг', roleId: bRoleId, isActive: true, createAccount: false, + }) + ctx.bEmpId = bEmp.data?.employee?.id + check(step, { kind: 'api', description: 'Сотрудник в орг B создан', ok: !!ctx.bEmpId }) + if (!ctx.bEmpId) return + + const api = makeClient(ctx.adminToken!) + const get = await api.get(`/api/organization/employees/${ctx.bEmpId}`) + check(step, { kind: 'api', description: 'GET чужого сотрудника (орг B) из орг A → 404', ok: get.status === 404, detail: `status=${get.status}` }) + const del = await api.delete(`/api/organization/employees/${ctx.bEmpId}`) + check(step, { kind: 'api', description: 'DELETE чужого сотрудника → 404', ok: del.status === 404, detail: `status=${del.status}` }) + if (get.status === 200 || del.status === 204) report.bug({ step: '10', severity: 'critical', + title: 'Multi-tenant утечка: доступ к сотрудникам чужой организации', detail: `GET=${get.status} DELETE=${del.status}` }) +} diff --git a/tests/e2e/scenarios/employees.yml b/tests/e2e/scenarios/employees.yml new file mode 100644 index 0000000..e4cc3a0 --- /dev/null +++ b/tests/e2e/scenarios/employees.yml @@ -0,0 +1,33 @@ +name: employees +description: | + Сотрудники (ТЗ 2.7.1): CRUD, создание учётки с временным паролем, + двухступенчатое удаление (увольнение → soft-delete), защита главного + администратора и самого себя, tenant-изоляция. Критично (ТЗ 0.4): + уволенный/удалённый сотрудник НЕ должен иметь возможности залогиниться — + состояние Employee.IsActive обязано гасить логин связанного User. + +preconditions: + reset_db: true + smoke_login_super_admin: true + +steps: + - id: step01_bootstrap + title: "Орг A + логин админа + выбор не-админской роли" + - id: step02_create_without_account + title: "Создание сотрудника без учётки (createAccount=false) → UserId=null" + - id: step03_create_with_account + title: "Создание сотрудника с учёткой → temp password в ответе, User создан" + - id: step04_email_required + title: "createAccount=true без email → 400" + - id: step05_duplicate_email + title: "Дубль email при createAccount → 4xx" + - id: step06_account_can_login + title: "Новый сотрудник логинится временным паролем → 200" + - id: step07_fire_blocks_login + title: "Увольнение (DELETE) гасит логин: повторный login и refresh → 4xx" + - id: step08_two_step_delete + title: "Второй DELETE → soft-delete (IsDeleted), третий → 409" + - id: step09_owner_self_protected + title: "DELETE главного администратора (он же self) → 403" + - id: step10_tenant_isolation + title: "Админ орг A не видит и не удаляет сотрудника орг B → 404"