test: enhance E2E tests for stream routes with timeout adjustments

Author: DSingh0304

e2e/pom/stream_routes.ts

@@ -24,27 +24,30 @@ const locator = {
 
 const assert = {
   isIndexPage: async (page: Page) => {
-    await expect(page).toHaveURL((url) =>
-      url.pathname.endsWith('/stream_routes')
+    await expect(page).toHaveURL(
+      (url) => url.pathname.endsWith('/stream_routes'),
+      { timeout: 15000 }
     );
     const title = page.getByRole('heading', { name: 'Stream Routes' });
-    await expect(title).toBeVisible();
+    await expect(title).toBeVisible({ timeout: 15000 });
   },
   isAddPage: async (page: Page) => {
-    await expect(page).toHaveURL((url) =>
-      url.pathname.endsWith('/stream_routes/add')
-    );
+    await expect(
+      page,
+      { timeout: 15000 }
+    ).toHaveURL((url) => url.pathname.endsWith('/stream_routes/add'));
     const title = page.getByRole('heading', { name: 'Add Stream Route' });
-    await expect(title).toBeVisible();
+    await expect(title).toBeVisible({ timeout: 15000 });
   },
   isDetailPage: async (page: Page) => {
-    await expect(page).toHaveURL((url) =>
-      url.pathname.includes('/stream_routes/detail')
-    );
+    await expect(
+      page,
+      { timeout: 20000 }
+    ).toHaveURL((url) => url.pathname.includes('/stream_routes/detail'));
     const title = page.getByRole('heading', {
       name: 'Stream Route Detail',
     });
-    await expect(title).toBeVisible();
+    await expect(title).toBeVisible({ timeout: 20000 });
   },
 };
 

src/apis/upstreams.ts

@@ -55,17 +55,36 @@ export const putUpstreamReq = (
 };
 
 export const deleteAllUpstreams = async (req: AxiosInstance) => {
-  const totalRes = await getUpstreamListReq(req, {
-    page: 1,
-    page_size: PAGE_SIZE_MIN,
-  });
+  const retry = async <T>(fn: () => Promise<T>, times = 3, delay = 500) => {
+    let lastErr: unknown;
+    for (let i = 0; i < times; i++) {
+      try {
+        return await fn();
+      } catch (err) {
+        lastErr = err;
+        // small backoff
+         
+        await new Promise((r) => setTimeout(r, delay));
+      }
+    }
+    throw lastErr;
+  };
+
+  const totalRes = await retry(() =>
+    getUpstreamListReq(req, {
+      page: 1,
+      page_size: PAGE_SIZE_MIN,
+    })
+  );
   const total = totalRes.total;
   if (total === 0) return;
   for (let times = Math.ceil(total / PAGE_SIZE_MAX); times > 0; times--) {
-    const res = await getUpstreamListReq(req, {
-      page: 1,
-      page_size: PAGE_SIZE_MAX,
-    });
+    const res = await retry(() =>
+      getUpstreamListReq(req, {
+        page: 1,
+        page_size: PAGE_SIZE_MAX,
+      })
+    );
     await Promise.all(
       res.list.map((d) => req.delete(`${API_UPSTREAMS}/${d.value.id}`))
     );