More logs

Author: simolus3

demos/example-node/README.md

@@ -16,4 +16,4 @@ Once you have these ready:
 2. Then run the following, inserting your instance URL and developer token:
 ```DEMO_ENDPOINT=https://yourinstance.powersync.journeyapps.com DEMO_TOKEN=YOURTOKEN pnpm run start
 ```
-This opens the local database, connects to PowerSync, waits for a first sync and then runs a simple query.
+This opens the local database, connects to PowerSync, waits for a first sync and then runs a simple query.

demos/example-node/src/main.ts

@@ -4,6 +4,7 @@ import {
   PowerSyncBackendConnector,
   PowerSyncDatabase,
   Schema,
+  SyncStreamConnectionMethod,
   Table
 } from '@powersync/node';
 import Logger from 'js-logger';
@@ -28,8 +29,9 @@ const main = async () => {
     }
   });
 
-  await db.connect(new DemoConnector());
+  await db.connect(new DemoConnector(), {connectionMethod: SyncStreamConnectionMethod.HTTP});
   await db.waitForFirstSync();
+  console.log('First sync complete!');
 
   let hasFirstRow: ((value: any) => void) | null = null;
   const firstRow = new Promise((resolve) => (hasFirstRow = resolve));
@@ -51,6 +53,8 @@ const main = async () => {
 
 class DemoConnector implements PowerSyncBackendConnector {
   async fetchCredentials() {
+    console.log('fetchCredentials called');
+
     return {
       endpoint: process.env.DEMO_ENDPOINT!,
       token: process.env.DEMO_TOKEN!,

packages/node/src/db/BetterSQLite3DBAdapter.ts

@@ -53,7 +53,7 @@ export class BetterSQLite3DBAdapter extends BaseObserver<DBAdapterListener> impl
     }
 
     const openWorker = async (isWriter: boolean) => {
-      const worker = new Worker(new URL('./SqliteWorker.js', import.meta.url));
+      const worker = new Worker(new URL('./SqliteWorker.js', import.meta.url), {name: isWriter ? `write ${dbFilePath}` : `read ${dbFilePath}`});
       const listeners = new WeakMap<EventListenerOrEventListenerObject, (e: any) => void>();
 
       const comlink = Comlink.wrap<AsyncDatabaseOpener>({