add a backoff retry, fix test cleanup

Author: trean

src/components/Collections/Optimizations/Optimizations.jsx

@@ -8,6 +8,8 @@ import OptimizationsTree from './Tree/OptimizationsTree';
 
 /** Poll interval while at least one optimization is running and the tab is visible (2–5s range). */
 const POLL_ACTIVE_MS = 4000;
+/** Max delay between retries after a failed poll (exponential backoff cap). */
+const POLL_ERROR_RETRY_MAX_MS = 32000;
 
 function isRequestCanceled(error) {
   return error?.code === 'ERR_CANCELED' || error?.name === 'CanceledError';
@@ -23,6 +25,7 @@ const Optimizations = ({ collectionName }) => {
   const pollTimeoutRef = useRef(null);
   const lastRunningRef = useRef(false);
   const mountedRef = useRef(true);
+  const pollErrorBackoffMsRef = useRef(POLL_ACTIVE_MS);
 
   const runFetch = useCallback(
     async ({ preserveSelection = false } = {}) => {
@@ -34,6 +37,7 @@ const Optimizations = ({ collectionName }) => {
       abortRef.current = ac;
 
       if (!preserveSelection) {
+        pollErrorBackoffMsRef.current = POLL_ACTIVE_MS;
         setIsRefreshing(true);
         setSelectedOptimization(null);
       }
@@ -52,6 +56,7 @@ const Optimizations = ({ collectionName }) => {
         const result = next?.result;
         const hasRunning = Array.isArray(result?.running) && result.running.length > 0;
         lastRunningRef.current = hasRunning;
+        pollErrorBackoffMsRef.current = POLL_ACTIVE_MS;
 
         clearTimeout(pollTimeoutRef.current);
         if (hasRunning && !document.hidden) {
@@ -63,6 +68,14 @@ const Optimizations = ({ collectionName }) => {
       } catch (error) {
         if (isRequestCanceled(error)) return;
         console.error('Error fetching optimizations:', error);
+        if (mountedRef.current && lastRunningRef.current && !document.hidden) {
+          const delay = pollErrorBackoffMsRef.current;
+          pollErrorBackoffMsRef.current = Math.min(pollErrorBackoffMsRef.current * 2, POLL_ERROR_RETRY_MAX_MS);
+          pollTimeoutRef.current = window.setTimeout(() => {
+            pollTimeoutRef.current = null;
+            void runFetch({ preserveSelection: true });
+          }, delay);
+        }
       } finally {
         if (!preserveSelection && mountedRef.current) {
           setIsRefreshing(false);

src/components/Collections/Optimizations/Optimizations.test.jsx

@@ -17,13 +17,20 @@ const apiResponse = (running = []) => ({
 });
 
 describe('Optimizations polling', () => {
+  const originalHiddenDescriptor = Object.getOwnPropertyDescriptor(Document.prototype, 'hidden');
+
   beforeEach(() => {
     vi.useFakeTimers();
     getMock.mockReset();
   });
 
   afterEach(() => {
     vi.useRealTimers();
+    if (originalHiddenDescriptor) {
+      Object.defineProperty(document, 'hidden', originalHiddenDescriptor);
+    } else {
+      delete document.hidden;
+    }
   });
 
   it('polls while running is non-empty and stops when empty', async () => {
@@ -52,6 +59,31 @@ describe('Optimizations polling', () => {
     expect(getMock).toHaveBeenCalledTimes(3);
   });
 
+  it('resumes polling after a transient error while optimizations are running', async () => {
+    getMock
+      .mockResolvedValueOnce(apiResponse([{ id: 1 }]))
+      .mockRejectedValueOnce(new Error('network'))
+      .mockResolvedValueOnce(apiResponse([{ id: 1 }]))
+      .mockResolvedValueOnce(apiResponse([]));
+
+    await act(async () => {
+      render(<Optimizations collectionName="test" />);
+    });
+    expect(getMock).toHaveBeenCalledTimes(1);
+
+    await act(async () => vi.advanceTimersByTime(4000));
+    expect(getMock).toHaveBeenCalledTimes(2);
+
+    await act(async () => vi.advanceTimersByTime(4000));
+    expect(getMock).toHaveBeenCalledTimes(3);
+
+    await act(async () => vi.advanceTimersByTime(4000));
+    expect(getMock).toHaveBeenCalledTimes(4);
+
+    await act(async () => vi.advanceTimersByTime(8000));
+    expect(getMock).toHaveBeenCalledTimes(4);
+  });
+
   it('pauses polling when document is hidden and resumes on visibility', async () => {
     getMock.mockResolvedValue(apiResponse([{ id: 1 }]));