test

Author: stevensJourney

packages/web/tests/stream.test.ts

@@ -5,46 +5,48 @@ import { ConnectedDatabaseUtils, generateConnectedDatabase } from './utils/gener
 
 const UPLOAD_TIMEOUT_MS = 3000;
 
-describe(
-  'Streaming - With Web Workers',
-  {
-    sequential: true
-  },
-  describeStreamingTests(() => generateConnectedDatabase())
-);
-
-describe(
-  'Streaming - Without Web Workers',
-  {
-    sequential: true
-  },
-  describeStreamingTests(() =>
-    generateConnectedDatabase({
-      powerSyncOptions: {
-        flags: {
-          useWebWorker: false
+describe('Streaming', { sequential: true }, () => {
+  describe(
+    'Streaming - With Web Workers',
+    {
+      sequential: true
+    },
+    describeStreamingTests(() => generateConnectedDatabase())
+  );
+
+  describe(
+    'Streaming - Without Web Workers',
+    {
+      sequential: true
+    },
+    describeStreamingTests(() =>
+      generateConnectedDatabase({
+        powerSyncOptions: {
+          flags: {
+            useWebWorker: false
+          }
         }
-      }
-    })
-  )
-);
-
-describe(
-  'Streaming - With OPFS',
-  {
-    sequential: true
-  },
-  describeStreamingTests(() =>
-    generateConnectedDatabase({
-      powerSyncOptions: {
-        database: new WASQLiteOpenFactory({
-          dbFilename: 'streaming-opfs.sqlite',
-          vfs: WASQLiteVFS.OPFSCoopSyncVFS
-        })
-      }
-    })
-  )
-);
+      })
+    )
+  );
+
+  describe(
+    'Streaming - With OPFS',
+    {
+      sequential: true
+    },
+    describeStreamingTests(() =>
+      generateConnectedDatabase({
+        powerSyncOptions: {
+          database: new WASQLiteOpenFactory({
+            dbFilename: 'streaming-opfs.sqlite',
+            vfs: WASQLiteVFS.OPFSCoopSyncVFS
+          })
+        }
+      })
+    )
+  );
+});
 
 function describeStreamingTests(createConnectedDatabase: () => Promise<ConnectedDatabaseUtils>) {
   return () => {

packages/web/tests/uploads.test.ts

@@ -13,7 +13,7 @@ describe(
   { sequential: true },
   describeCrudUploadTests(() => ({
     database: {
-      dbFilename: `crud-uploads-test-${v4()}.db`
+      dbFilename: `${v4()}.db`
     },
     schema: DEFAULT_CONNECTED_POWERSYNC_OPTIONS.powerSyncOptions.schema,
     crudUploadThrottleMs: 1_000,

packages/web/tests/utils/generateConnectedDatabase.ts

@@ -1,6 +1,6 @@
 import { Schema, Table, column } from '@powersync/common';
 import { WebPowerSyncOpenFactoryOptions } from '@powersync/web';
-import { v4 as uuid } from 'uuid';
+import { v4 as uuid, v4 } from 'uuid';
 import { onTestFinished, vi } from 'vitest';
 import { MockRemote, MockStreamOpenFactory, TestConnector } from './MockStreamOpenFactory';
 
@@ -13,24 +13,26 @@ export type GenerateConnectedDatabaseOptions = {
 
 export type ConnectedDBGenerator = typeof generateConnectedDatabase;
 
-export const DEFAULT_CONNECTED_POWERSYNC_OPTIONS = {
-  powerSyncOptions: {
-    dbFilename: 'test-stream-connection.db',
-    flags: {
-      enableMultiTabs: false,
-      useWebWorker: true
-    },
-    // Makes tests faster
-    crudUploadThrottleMs: 0,
-    schema: new Schema({
-      users: new Table({ name: column.text })
-    })
-  }
-};
+export const DEFAULT_CONNECTED_POWERSYNC_OPTIONS = generateDefaultOptions();
+
+function generateDefaultOptions() {
+  return {
+    powerSyncOptions: {
+      dbFilename: `${v4()}.db`,
+      flags: {
+        enableMultiTabs: false,
+        useWebWorker: true
+      },
+      // Makes tests faster
+      crudUploadThrottleMs: 0,
+      schema: new Schema({
+        users: new Table({ name: column.text })
+      })
+    }
+  };
+}
 
-export async function generateConnectedDatabase(
-  options: GenerateConnectedDatabaseOptions = DEFAULT_CONNECTED_POWERSYNC_OPTIONS
-) {
+export async function generateConnectedDatabase(options: GenerateConnectedDatabaseOptions = generateDefaultOptions()) {
   const { powerSyncOptions } = options;
   const { powerSyncOptions: defaultPowerSyncOptions } = DEFAULT_CONNECTED_POWERSYNC_OPTIONS;
   /**