Use forked better-sqlite3

Author: simolus3

package.json

@@ -40,11 +40,5 @@
     "prettier": "^3.2.5",
     "typescript": "^5.7.2",
     "vitest": "^3.0.5"  
-  },
-  "pnpm": {
-    "overrides": {
-      "better-sqlite3": "github:spinda/better-sqlite3#flexwash",
-      "@types/better-sqlite3": "github:spinda/DefinitelyTyped#flexwash&path:/types/better-sqlite3"
-    }
   }
 }

packages/node/package.json

@@ -20,7 +20,7 @@
     "build:prod": "tsc -b --sourceMap false",
     "clean": "rm -rf lib dist tsconfig.tsbuildinfo dist",
     "watch": "tsc -b -w",
-    "_test": "vitest"
+    "test": "vitest"
   },
   "type": "module",
   "repository": {
@@ -35,12 +35,7 @@
   "homepage": "https://docs.powersync.com/",
   "peerDependencies": {
     "@powersync/common": "workspace:^1.22.0",
-    "better-sqlite3": "github:spinda/better-sqlite3#flexwash"
-  },
-  "peerDependenciesMeta": {
-    "better-sqlite3": {
-      "optional": true
-    }
+    "@powersync/better-sqlite3": "^0.1.0"
   },
   "dependencies": {
     "@powersync/common": "workspace:*",

packages/node/src/db/SqliteWorker.ts

@@ -1,6 +1,6 @@
-import BetterSQLite3Database, { Database } from 'better-sqlite3';
+import BetterSQLite3Database, { Database } from '@powersync/better-sqlite3';
 import * as Comlink from 'comlink';
-import { MessagePort, parentPort, threadId } from 'node:worker_threads';
+import { parentPort, threadId } from 'node:worker_threads';
 import OS from 'node:os';
 import url from 'node:url';
 import { AsyncDatabase, AsyncDatabaseOpener } from './AsyncDatabase.js';
@@ -24,19 +24,19 @@ class BlockingAsyncDatabase implements AsyncDatabase {
   }
 
   installUpdateHooks() {
-    this.db.updateHook((_op: string, _dbName: string, tableName: string, _rowid: bigint) => {
+    (this.db as any).updateHook((_op: string, _dbName: string, tableName: string, _rowid: bigint) => {
       this.uncommittedUpdatedTables.add(tableName);
     });
 
-    this.db.commitHook(() => {
+    (this.db as any).commitHook(() => {
       for (const tableName of this.uncommittedUpdatedTables) {
         this.committedUpdatedTables.add(tableName);
       }
       this.uncommittedUpdatedTables.clear();
       return true;
     });
 
-    this.db.rollbackHook(() => {
+    (this.db as any).rollbackHook(() => {
       this.uncommittedUpdatedTables.clear();
     });
   }
@@ -110,7 +110,7 @@ const loadExtension = (db: Database) => {
   }
 
   const resolved = url.fileURLToPath(new URL(`../${extensionPath}`, import.meta.url));
-  db.loadExtension(resolved, 'sqlite3_powersync_init');
+  (db as any).loadExtension(resolved, 'sqlite3_powersync_init');
 };
 
 Comlink.expose(new BetterSqliteWorker(), parentPort! as Comlink.Endpoint);

packages/node/tests/PowerSyncDatabase.test.ts

@@ -1,4 +1,4 @@
-import { vi, expect } from 'vitest';
+import { vi, expect, test } from 'vitest';
 import { databaseTest } from './utils';
 
 databaseTest('links powersync', async ({ database }) => {