Format

Author: simolus3

packages/node/src/db/BetterSQLite3DBAdapter.ts

@@ -10,7 +10,7 @@ import {
   LockContext,
   Transaction,
   DBLockOptions,
-  QueryResult,
+  QueryResult
 } from '@powersync/common';
 import { Remote } from 'comlink';
 import { AsyncResource } from 'node:async_hooks';

packages/node/src/db/PowerSyncDatabase.ts

@@ -18,7 +18,7 @@ import { NodeSQLOpenOptions } from './options.js';
 
 export type NodePowerSyncDatabaseOptions = PowerSyncDatabaseOptions & {
   database: DBAdapter | SQLOpenFactory | NodeSQLOpenOptions;
-}
+};
 
 /**
  * A PowerSync database which provides SQLite functionality

packages/node/src/db/options.ts

@@ -1,22 +1,22 @@
 import { type Worker } from 'node:worker_threads';
-import { SQLOpenOptions } from "@powersync/common";
+import { SQLOpenOptions } from '@powersync/common';
 
 /**
  * The {@link SQLOpenOptions} available across all PowerSync SDKs for JavaScript extended with
  * Node.JS-specific options.
  */
 export interface NodeSQLOpenOptions extends SQLOpenOptions {
-    /**
-     * The Node.JS SDK will use one worker to run writing queries and additional workers to run reads.
-     * This option controls how many workers to use for reads.
-     */
-        readWorkers?: number,
-    /**
-     * A callback to allow customizing how the Node.JS SDK loads workers. This can be customized to
-     * use workers at different paths.
-     * 
-     * @param args The arguments that would otherwise be passed to the {@link Worker} constructor.
-     * @returns the resolved worker.
-     */
-    openWorker?: (...args: ConstructorParameters<typeof Worker>) => InstanceType<typeof Worker>,
+  /**
+   * The Node.JS SDK will use one worker to run writing queries and additional workers to run reads.
+   * This option controls how many workers to use for reads.
+   */
+  readWorkers?: number;
+  /**
+   * A callback to allow customizing how the Node.JS SDK loads workers. This can be customized to
+   * use workers at different paths.
+   *
+   * @param args The arguments that would otherwise be passed to the {@link Worker} constructor.
+   * @returns the resolved worker.
+   */
+  openWorker?: (...args: ConstructorParameters<typeof Worker>) => InstanceType<typeof Worker>;
 }

packages/node/tests/PowerSyncDatabase.test.ts

@@ -11,32 +11,32 @@ test('validates options', async () => {
       schema: AppSchema,
       database: {
         dbFilename: '/dev/null',
-        readWorkers: 0,
+        readWorkers: 0
       }
     });
     await database.init();
   }).rejects.toThrowError('Needs at least one worker for reads');
 });
 
 test('can customize loading workers', async () => {
-    const directory = await createTempDir();
-    const openFunction = vi.fn((...args: ConstructorParameters<typeof Worker>) => new Worker(...args));
-
-    const database = new PowerSyncDatabase({
-      schema: AppSchema,
-      database: {
-        dbFilename: 'test.db',
-        dbLocation: directory,
-        openWorker: openFunction as any,
-        readWorkers: 2,
-      }
-    });
+  const directory = await createTempDir();
+  const openFunction = vi.fn((...args: ConstructorParameters<typeof Worker>) => new Worker(...args));
+
+  const database = new PowerSyncDatabase({
+    schema: AppSchema,
+    database: {
+      dbFilename: 'test.db',
+      dbLocation: directory,
+      openWorker: openFunction as any,
+      readWorkers: 2
+    }
+  });
 
-    await database.get('SELECT 1;'); // Make sure the database is ready and works
-    expect(openFunction).toHaveBeenCalledTimes(3); // One writer, two readers
-    await database.close();
+  await database.get('SELECT 1;'); // Make sure the database is ready and works
+  expect(openFunction).toHaveBeenCalledTimes(3); // One writer, two readers
+  await database.close();
 
-    onTestFinished(async () => fs.rm(directory, { recursive: true }));
+  onTestFinished(async () => fs.rm(directory, { recursive: true }));
 });
 
 databaseTest('links powersync', async ({ database }) => {