Update branch

Author: stevensJourney

packages/node/download_core.js

@@ -48,7 +48,7 @@ const downloadAsset = async (asset, destination) => {
 
   // Check if file exists and has correct hash
   const currentHash = await hashLocal(destinationPath);
-  if (currentHash === expectedHash) {
+  if (currentHash == expectedHash) {
     console.debug(`${destination} is up-to-date, skipping download`);
     return;
   }
@@ -83,7 +83,7 @@ const checkAsset = async (asset, destination) => {
     expectedHash,
     currentHash,
     exists: currentHash !== null,
-    isValid: currentHash === expectedHash
+    isValid: currentHash == expectedHash
   };
 };
 

packages/node/src/db/NodeSqliteWorker.ts

@@ -1,9 +1,9 @@
-import { threadId } from 'node:worker_threads';
 import type { DatabaseSync } from 'node:sqlite';
+import { threadId } from 'node:worker_threads';
 
+import { dynamicImport } from '../utils/modules.js';
 import { AsyncDatabase, AsyncDatabaseOpenOptions } from './AsyncDatabase.js';
 import { PowerSyncWorkerOptions } from './SqliteWorker.js';
-import { dynamicImport } from '../utils/modules.js';
 
 class BlockingNodeDatabase implements AsyncDatabase {
   private readonly db: DatabaseSync;
@@ -57,7 +57,7 @@ export async function openDatabase(worker: PowerSyncWorkerOptions, options: Asyn
   const { DatabaseSync } = await dynamicImport('node:sqlite');
 
   const baseDB = new DatabaseSync(options.path, { allowExtension: true });
-  baseDB.loadExtension(worker.extensionPath());
+  baseDB.loadExtension(worker.extensionPath(), 'sqlite3_powersync_init');
 
   return new BlockingNodeDatabase(baseDB, options.isWriter);
 }

packages/node/src/db/SqliteWorker.ts

@@ -35,26 +35,28 @@ export function startPowerSyncWorker(options?: Partial<PowerSyncWorkerOptions>)
         if (arch == 'x64') {
           extensionPath = 'powersync.dll';
         } else {
-          throw 'Windows platform only supports x64 architecture.';
+          throw new Error('Windows platform only supports x64 architecture.');
         }
       } else if (platform == 'linux') {
         if (arch == 'x64') {
           extensionPath = 'libpowersync.so';
         } else if (arch == 'arm64') {
           extensionPath = 'libpowersync-aarch64.so';
         } else {
-          throw 'Linux platform only supports x64 and arm64 architectures.';
+          throw new Error('Linux platform only supports x64 and arm64 architectures.');
         }
       } else if (platform == 'darwin') {
         if (arch == 'x64') {
           extensionPath = 'libpowersync.dylib';
         } else if (arch == 'arm64') {
           extensionPath = 'libpowersync-aarch64.dylib';
         } else {
-          throw 'macOS platform only supports x64 and arm64 architectures.';
+          throw new Error('macOS platform only supports x64 and arm64 architectures.');
         }
       } else {
-        throw 'Unknown platform, PowerSync for Node.js currently supports Windows, Linux and macOS.';
+        throw new Error(
+          `Unknown platform: ${platform}, PowerSync for Node.js currently supports Windows, Linux and macOS.`
+        );
       }
 
       let resolved: string;

packages/node/tests/utils.ts

@@ -1,8 +1,10 @@
-import os from 'node:os';
 import fs from 'node:fs/promises';
+import os from 'node:os';
 import path from 'node:path';
 import { ReadableStream, TransformStream } from 'node:stream/web';
 
+import { createLogger } from '@powersync/common';
+import Logger from 'js-logger';
 import { onTestFinished, test } from 'vitest';
 import {
   AbstractPowerSyncDatabase,
@@ -18,8 +20,6 @@ import {
   SyncStatus,
   Table
 } from '../lib';
-import { createLogger } from '@powersync/common';
-import Logger from 'js-logger';
 
 export async function createTempDir() {
   const ostmpdir = os.tmpdir();
@@ -70,7 +70,10 @@ export async function createDatabase(
       dbLocation: tmpdir,
       // Using a single read worker (instead of multiple, the default) seems to improve the reliability of tests in GH
       // actions. So far, we've not been able to reproduce these failures locally.
-      readWorkerCount: 1
+      readWorkerCount: 1,
+      implementation: {
+        type: 'node:sqlite'
+      }
     },
     logger: defaultLogger,
     ...options