// apps/web/e2e/flows/alert-flow.spec.ts
import { test, expect } from '../fixtures/auth.fixture';
import { makePatient, makeVitalSigns, makeAlertRule } from '../fixtures/test-data';

test.describe('@flow 告警处理链路', () => {
  const cleanup: Array<() => Promise<void>> = [];

  test.afterEach(async () => {
    for (const fn of cleanup.reverse()) {
      await fn().catch(() => {});
    }
    cleanup.length = 0;
  });

  test('创建规则 → 触发告警 → 查看列表 → 确认处理', async ({ api, authenticatedPage: page }) => {
    const patient = await api.createPatient(makePatient());
    cleanup.push(() => api.deletePatient(patient.id, patient.version));

    const rule = await api.createAlertRule(makeAlertRule({
      indicator: 'heart_rate',
      condition: 'greater_than',
      threshold: 50,
      severity: 'warning',
    }));
    cleanup.push(() => api.deleteAlertRule(rule.id, rule.version));

    const vitalSigns = await api.createVitalSigns(patient.id, makeVitalSigns({
      heart_rate: 110,
    }));
    cleanup.push(() => api.deleteVitalSigns(patient.id, vitalSigns.id, vitalSigns.version));

    let alert: Record<string, unknown> | undefined;
    await expect(async () => {
      const alerts = await api.listAlerts();
      alert = alerts.find((a) => (a as Record<string, unknown>).patient_id === patient.id);
      expect(alert).toBeDefined();
    }).toPass({ timeout: 15000 });

    if (!alert!) throw new Error('告警未生成');

    await page.goto('/#/health/alerts');
    await page.waitForSelector('.ant-table', { timeout: 10000 });

    const updated = await api.acknowledgeAlert(alert.id as string, alert.version as number);
    await api.resolveAlert(updated.id, updated.version);
  });
});