Merge candidate 20260906T082503Z-web-product

Change-source: pulse-maintainer

frontend-modern/src/features/alerts/__tests__/useNotificationDeliveryLog.test.tsx

@@ -1,6 +1,8 @@
 import { createRoot } from 'solid-js';
 import { beforeEach, describe, expect, it, vi } from 'vitest';
 
+import { AlertsAPI } from '@/api/alerts';
+import type { NotificationDeliveryLog } from '@/api/notifications';
 import { NotificationsAPI } from '@/api/notifications';
 
 import { useNotificationDeliveryLog } from '../useNotificationDeliveryLog';
@@ -9,9 +11,31 @@ vi.mock('@/api/notifications', () => ({
   NotificationsAPI: { getDeliveryLog: vi.fn() },
 }));
 
+vi.mock('@/api/alerts', () => ({
+  AlertsAPI: { getEvents: vi.fn() },
+}));
+
+function deferred<T>() {
+  let resolve!: (value: T) => void;
+  let reject!: (reason: Error) => void;
+  const promise = new Promise<T>((res, rej) => {
+    resolve = res;
+    reject = rej;
+  });
+  return { promise, resolve, reject };
+}
+
+const emptyLog: NotificationDeliveryLog = {
+  entries: [],
+  windowDays: 30,
+  completedRetentionDays: 7,
+  deadLetterRetentionDays: 30,
+};
+
 describe('useNotificationDeliveryLog', () => {
   beforeEach(() => {
     vi.mocked(NotificationsAPI.getDeliveryLog).mockReset();
+    vi.mocked(AlertsAPI.getEvents).mockReset().mockResolvedValue([]);
   });
 
   it('exposes the loaded log and clears the unavailable flag', () =>
@@ -71,4 +95,84 @@ describe('useNotificationDeliveryLog', () => {
       expect(state.deliveryLog()?.entries).toHaveLength(0);
       dispose();
     }));
+
+  it('does not wait for held events before completing the delivery read', () =>
+    createRoot(async (dispose) => {
+      const held = deferred<Awaited<ReturnType<typeof AlertsAPI.getEvents>>>();
+      vi.mocked(AlertsAPI.getEvents).mockReturnValue(held.promise);
+      vi.mocked(NotificationsAPI.getDeliveryLog).mockResolvedValue(emptyLog);
+      const state = useNotificationDeliveryLog();
+      try {
+        await state.loadDeliveryLog();
+        expect(state.deliveryLog()).toEqual(emptyLog);
+        expect(state.refreshingDeliveryLog()).toBe(false);
+        expect(state.heldEvents()).toEqual([]);
+      } finally {
+        held.resolve([]);
+        dispose();
+      }
+    }));
+
+  // Known defect: mount and queue-action refreshes can overlap. Keep the
+  // desired invariant executable until the governed runtime repair lands;
+  // Vitest fails these tests if the invariant starts passing unexpectedly.
+  it.fails('keeps the newest successful read when an older read fails', () =>
+    createRoot(async (dispose) => {
+      const older = deferred<NotificationDeliveryLog>();
+      vi.mocked(NotificationsAPI.getDeliveryLog)
+        .mockReturnValueOnce(older.promise)
+        .mockResolvedValueOnce(emptyLog);
+      const state = useNotificationDeliveryLog();
+      try {
+        const first = state.loadDeliveryLog();
+        await state.loadDeliveryLog();
+        older.reject(new Error('old read failed'));
+        await first;
+        expect(state.deliveryLogUnavailable()).toBe(false);
+        expect(state.deliveryLog()).toEqual(emptyLog);
+      } finally {
+        dispose();
+      }
+    }));
+
+  it.fails('does not replace a newer unavailable result with an older success', () =>
+    createRoot(async (dispose) => {
+      const older = deferred<NotificationDeliveryLog>();
+      vi.mocked(NotificationsAPI.getDeliveryLog)
+        .mockReturnValueOnce(older.promise)
+        .mockRejectedValueOnce(new Error('new read failed'));
+      const state = useNotificationDeliveryLog();
+      try {
+        const first = state.loadDeliveryLog();
+        await state.loadDeliveryLog();
+        older.resolve(emptyLog);
+        await first;
+        expect(state.deliveryLogUnavailable()).toBe(true);
+        expect(state.deliveryLog()).toBeNull();
+      } finally {
+        dispose();
+      }
+    }));
+
+  it.fails('keeps refreshing true while the newest read remains pending', () =>
+    createRoot(async (dispose) => {
+      const older = deferred<NotificationDeliveryLog>();
+      const newer = deferred<NotificationDeliveryLog>();
+      vi.mocked(NotificationsAPI.getDeliveryLog)
+        .mockReturnValueOnce(older.promise)
+        .mockReturnValueOnce(newer.promise);
+      const state = useNotificationDeliveryLog();
+      const first = state.loadDeliveryLog();
+      const second = state.loadDeliveryLog();
+      try {
+        older.resolve(emptyLog);
+        await first;
+        expect(state.refreshingDeliveryLog()).toBe(true);
+      } finally {
+        newer.resolve(emptyLog);
+        await second;
+        dispose();
+      }
+    }));
+
 });