use force flush test util

Author: mydea

packages/integration-tests/suites/replay/errors/droppedError/test.ts

@@ -5,7 +5,7 @@ import { getReplaySnapshot, shouldSkipReplayTest } from '../../../../utils/repla
 
 sentryTest(
   '[error-mode] should not start recording if an error occurred when the error was dropped',
-  async ({ getLocalTestPath, page }) => {
+  async ({ getLocalTestPath, page, forceFlushReplay }) => {
     if (shouldSkipReplayTest()) {
       sentryTest.skip();
     }
@@ -25,14 +25,13 @@ sentryTest(
     const url = await getLocalTestPath({ testDir: __dirname });
 
     await page.goto(url);
-    await page.click('#go-background');
+    await forceFlushReplay();
     expect(callsToSentry).toEqual(0);
 
     await page.click('#error');
 
-    await page.click('#go-background');
     await page.click('#log');
-    await page.click('#go-background');
+    await forceFlushReplay();
 
     expect(callsToSentry).toEqual(0);
 

packages/integration-tests/suites/replay/errors/errorModeCustomTransport/test.ts

@@ -3,37 +3,40 @@ import { expect } from '@playwright/test';
 import { sentryTest } from '../../../../utils/fixtures';
 import { getReplaySnapshot, shouldSkipReplayTest, waitForReplayRequest } from '../../../../utils/replayHelpers';
 
-sentryTest('[error-mode] should handle errors with custom transport', async ({ getLocalTestPath, page }) => {
-  if (shouldSkipReplayTest()) {
-    sentryTest.skip();
-  }
+sentryTest(
+  '[error-mode] should handle errors with custom transport',
+  async ({ getLocalTestPath, page, forceFlushReplay }) => {
+    if (shouldSkipReplayTest()) {
+      sentryTest.skip();
+    }
 
-  const promiseReq0 = waitForReplayRequest(page, 0);
-  const promiseReq1 = waitForReplayRequest(page, 1);
+    const promiseReq0 = waitForReplayRequest(page, 0);
+    const promiseReq1 = waitForReplayRequest(page, 1);
 
-  let callsToSentry = 0;
+    let callsToSentry = 0;
 
-  await page.route('https://dsn.ingest.sentry.io/**/*', route => {
-    callsToSentry++;
+    await page.route('https://dsn.ingest.sentry.io/**/*', route => {
+      callsToSentry++;
 
-    return route.fulfill({
-      // Only error out for error, then succeed
-      status: callsToSentry === 1 ? 422 : 200,
+      return route.fulfill({
+        // Only error out for error, then succeed
+        status: callsToSentry === 1 ? 422 : 200,
+      });
     });
-  });
 
-  const url = await getLocalTestPath({ testDir: __dirname });
+    const url = await getLocalTestPath({ testDir: __dirname });
 
-  await page.goto(url);
-  await page.click('#go-background');
-  expect(callsToSentry).toEqual(0);
+    await page.goto(url);
+    await forceFlushReplay();
+    expect(callsToSentry).toEqual(0);
 
-  await page.click('#error');
-  await promiseReq0;
+    await page.click('#error');
+    await promiseReq0;
 
-  await page.click('#go-background');
-  await promiseReq1;
+    await forceFlushReplay();
+    await promiseReq1;
 
-  const replay = await getReplaySnapshot(page);
-  expect(replay.recordingMode).toBe('session');
-});
+    const replay = await getReplaySnapshot(page);
+    expect(replay.recordingMode).toBe('session');
+  },
+);

packages/integration-tests/suites/replay/errors/errorNotSent/test.ts

@@ -5,7 +5,7 @@ import { getReplaySnapshot, shouldSkipReplayTest } from '../../../../utils/repla
 
 sentryTest(
   '[error-mode] should handle errors that result in API error response',
-  async ({ getLocalTestPath, page }) => {
+  async ({ getLocalTestPath, page, forceFlushReplay }) => {
     if (shouldSkipReplayTest()) {
       sentryTest.skip();
     }
@@ -24,14 +24,13 @@ sentryTest(
     const url = await getLocalTestPath({ testDir: __dirname });
 
     await page.goto(url);
-    await page.click('#go-background');
+    await forceFlushReplay();
     expect(callsToSentry).toEqual(0);
 
     await page.click('#error');
 
-    await page.click('#go-background');
     await page.click('#log');
-    await page.click('#go-background');
+    await forceFlushReplay();
 
     // Only sent once, but since API failed we do not go into session mode
     expect(callsToSentry).toEqual(1);