Illustrating fix for broadcasting loop.

Author: Chriztiaan

packages/web/src/db/adapters/wa-sqlite/WASQLiteConnection.ts

@@ -217,14 +217,14 @@ export class WASqliteConnection
         // Ignore messages from the same connection
         return;
       }
-      this.queueTableUpdate(data.changedTables);
+      this.queueTableUpdate(data.changedTables, true);
     });
   }
 
-  protected queueTableUpdate(tableNames: Set<string>) {
+  protected queueTableUpdate(tableNames: Set<string>, fromBroadcast = false) {
     tableNames.forEach((tableName) => this.updatedTables.add(tableName));
     if (this.updateTimer == null) {
-      this.updateTimer = setTimeout(() => this.fireUpdates(), 0);
+      this.updateTimer = setTimeout(() => this.fireUpdates(fromBroadcast), 0);
     }
   }
 
@@ -248,14 +248,16 @@ export class WASqliteConnection
     return this.options;
   }
 
-  fireUpdates() {
+  fireUpdates(fromBroadcast = false) {
     this.updateTimer = null;
     const event: BatchedUpdateNotification = { tables: [...this.updatedTables], groupedUpdates: {}, rawUpdates: [] };
     // Share to other connections
-    this.broadcastChannel!.postMessage({
-      changedTables: this.updatedTables,
-      connectionId: this.connectionId
-    } satisfies WASQLiteBroadCastTableUpdateEvent);
+    if (!fromBroadcast) {
+      this.broadcastChannel!.postMessage({
+        changedTables: this.updatedTables,
+        connectionId: this.connectionId
+      } satisfies WASQLiteBroadCastTableUpdateEvent);
+    }
     this.updatedTables.clear();
     this.iterateListeners((cb) => cb.tablesUpdated?.(event));
   }