override nodejs imports

Author: stevensJourney

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -429,11 +429,8 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
     }
     this._schema = schema;
 
-    console.log('updating schema', JSON.stringify(this.schema.toJSON()));
     await this.database.execute('SELECT powersync_replace_schema(?)', [JSON.stringify(this.schema.toJSON())]);
-    console.log('schema updated', JSON.stringify(this.schema.toJSON()));
     await this.database.refreshSchema();
-    console.log('schema refreshed', JSON.stringify(this.schema.toJSON()));
     this.iterateListeners(async (cb) => cb.schemaChanged?.(schema));
   }
 

packages/dev-adapter/package.json

@@ -28,12 +28,13 @@
     "test": "vitest"
   },
   "dependencies": {
-    "async-mutex": "^0.4.0",
-    "@powersync/common": "workspace:^"
+    "@powersync/common": "workspace:^",
+    "async-mutex": "^0.4.0"
   },
   "devDependencies": {
+    "@rollup/plugin-alias": "^5.1.0",
     "@types/sql.js": "^1.4.9",
-    "sql.js": "link:/Users/stevenontong/Documents/sql.js",
-    "rollup": "4.14.3"
+    "rollup": "4.14.3",
+    "sql.js": "link:/Users/stevenontong/Documents/sql.js"
   }
 }

packages/dev-adapter/rollup.config.mjs

@@ -1,5 +1,11 @@
+import alias from '@rollup/plugin-alias';
 import commonjs from '@rollup/plugin-commonjs';
 import nodeResolve from '@rollup/plugin-node-resolve';
+import path from 'path';
+import { fileURLToPath } from 'url';
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
 
 /**
  * @returns {import('rollup').RollupOptions}
@@ -17,7 +23,18 @@ export default (commandLineArgs) => {
       format: 'esm',
       sourcemap: sourceMap
     },
-    plugins: [nodeResolve({ preferBuiltins: false, browser: true }), commonjs({})],
+    plugins: [
+      nodeResolve({ preferBuiltins: false, browser: true }),
+      commonjs({}),
+      alias({
+        entries: [
+          { find: 'fs', replacement: path.resolve(__dirname, 'vendored/empty.js') },
+          { find: 'path', replacement: path.resolve(__dirname, 'vendored/empty.js') },
+          { find: 'crypto', replacement: path.resolve(__dirname, 'vendored/empty.js') }
+          // add others as needed
+        ]
+      })
+    ],
     external: ['@powersync/common']
   };
 };

packages/dev-adapter/src/SQLJSAdapter.ts

@@ -12,7 +12,7 @@ import {
 } from '@powersync/common';
 import { Mutex } from 'async-mutex';
 // This uses a pure JS version which avoids the need for WebAssembly, which is not supported in React Native.
-import SQLJs from 'sql.js/dist/sql-asm.js';
+import SQLJs from 'sql.js/dist/sql-asm-debug.js';
 
 export interface SQLJSPersister {
   readFile: () => Promise<ArrayLike<number> | Buffer | null>;
@@ -59,9 +59,11 @@ export class SQLJSDBAdapter extends BaseObserver<DBAdapterListener> implements D
     console.log('SQL.js loaded:');
     const existing = await this.options.persister.readFile();
     const db = new SQL.Database(existing);
-    (db as any).updateHook((operation, database, table) => {
-      this.tableUpdateCache.add(table);
-    });
+    // debugger;
+    // (db as any).updateHook(function (operation, database, table, rowId) {
+    //   console.log(`Update Hook: ${operation} on ${table}`);
+    //   this.tableUpdateCache.add(table);
+    // });
     this._db = db;
     return db;
   }
@@ -92,7 +94,7 @@ export class SQLJSDBAdapter extends BaseObserver<DBAdapterListener> implements D
           return Object.fromEntries(row.map((value, index) => [columnNames![index], value]));
         });
         return {
-          insertId: 0, // does not seem to be available in SQL.js??
+          insertId: (db as any).lastInsertId(), // does not seem to be available in SQL.js??
           rowsAffected: db.getRowsModified(),
           rows: {
             _array: rows,

packages/dev-adapter/vendored/empty.js

@@ -0,0 +1 @@
+export default {};