Test watching queries and uploads

Author: simolus3

demos/example-node/src/main.ts

@@ -24,20 +24,36 @@ const main = async () => {
   });
 
   await db.connect(new DemoConnector());
-
   await db.waitForFirstSync();
-  console.log(await db.getAll('SELECT * FROM lists;'));
+
+  let hasFirstRow: ((value: any) => void) | null = null;
+  const firstRow = new Promise((resolve) => hasFirstRow = resolve);
+  const watchLists = async () => {
+    for await (const rows of db.watch('SELECT * FROM lists')) {
+      if (hasFirstRow) {
+        hasFirstRow(null);
+        hasFirstRow = null;
+      }
+      console.log('Has todo items', rows.rows?._array);
+    }
+  };
+
+  watchLists();
+  await firstRow;
+
+//  await db.execute("INSERT INTO lists (id, created_at, name, owner_id) VALUEs (uuid(), 'test', 'test', 'test');");
 };
 
 class DemoConnector implements PowerSyncBackendConnector {
   async fetchCredentials() {
     return {
-      endpoint: '', // todo
-      token: '' // todo
+      endpoint: 'https://678775966cf706da85f4e447.powersync.journeyapps.com', // todo
+      token: 'eyJhbGciOiJSUzI1NiIsImtpZCI6InBvd2Vyc3luYy1kZXYtMzIyM2Q0ZTMifQ.eyJzdWIiOiI5MGQ5MzBhZi1iYmVkLTQ0NDgtOWM0NS1kYWQyZGYzMDAwNWYiLCJpYXQiOjE3NDEwMTU4NjUsImlzcyI6Imh0dHBzOi8vcG93ZXJzeW5jLWFwaS5qb3VybmV5YXBwcy5jb20iLCJhdWQiOiJodHRwczovLzY3ODc3NTk2NmNmNzA2ZGE4NWY0ZTQ0Ny5wb3dlcnN5bmMuam91cm5leWFwcHMuY29tIiwiZXhwIjoxNzQxMDU5MDY1fQ.aQqLOulvaOMKFtOUfbYuywLRjxmhs1J9hpdlkoSjw2m1_OTmnoVJkMRFKvO45k2I_ZD1GLg2sb6HoV2KNQHJPp2yMeL5eBENXt1HEy-WKU5ObrbwoQT0knkHnwZRmbGNwPYz3R21GibKDdD8chILVtNkSXoy3LjAUmywdzzhMBmmJwiIxP5Ew_K4XAxBU2pDyjX3FNvISHdB60IPgGBQUz3Ke_t-4ZD-k-EUHVLDufhxsDRSwhIKG26PPUqJdZ4YPlqwtjjZrVHy_B4XQBtRsAjqhf61ZLFEx6xeHcze-xZRNVsTw3qTmAFC4Vf9Ezka5jhMppM_HAtPn_wyzWUauA' // todo
     };
   }
 
   async uploadData(database: AbstractPowerSyncDatabase) {
+    await new Promise((resolve) => setTimeout(resolve, 10_000));
     throw 'not implemented: DemoConnector.uploadData';
   }
 }

packages/node/src/db/PowerSyncDatabase.ts

@@ -53,7 +53,7 @@ export class PowerSyncDatabase extends AbstractPowerSyncDatabase {
         await this.waitForReady();
         await connector.uploadData(this);
       },
-      retryDelayMs: this.options.retryDelay,
+      retryDelayMs: this.options.retryDelayMs,
       crudUploadThrottleMs: this.options.crudUploadThrottleMs,
       identifier: this.database.name
     });