From 853aaa1ac0efb7c25c84d983e764ac5b34988f76 Mon Sep 17 00:00:00 2001
From: Simon Binder <simon@journeyapps.com>
Date: Wed, 26 Feb 2025 17:52:21 +0100
Subject: [PATCH] Warn on missing updates stream

---
 packages/powersync_core/lib/src/web/sync_worker.dart | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/packages/powersync_core/lib/src/web/sync_worker.dart b/packages/powersync_core/lib/src/web/sync_worker.dart
index ebe6d586..c4d0ba2d 100644
--- a/packages/powersync_core/lib/src/web/sync_worker.dart
+++ b/packages/powersync_core/lib/src/web/sync_worker.dart
@@ -20,7 +20,7 @@ import 'package:web/web.dart' hide RequestMode;
 import 'sync_worker_protocol.dart';
 import 'web_bucket_storage.dart';
 
-final _logger = autoLogger;
+final _logger = debugLogger;
 
 void main() {
   _SyncWorker().start();
@@ -244,14 +244,18 @@ class _SyncRunner {
     final crudThrottleTime = Duration(milliseconds: crudThrottleTimeMs);
     Stream<UpdateNotification> crudStream =
         powerSyncUpdateNotifications(Stream.empty());
-    if (database.updates != null) {
-      final filteredStream = database.updates!
-          .transform(UpdateNotification.filterTablesTransformer(tables));
+    if (database.updates case final updates?) {
+      final filteredStream =
+          updates.transform(UpdateNotification.filterTablesTransformer(tables));
       crudStream = UpdateNotification.throttleStream(
         filteredStream,
         crudThrottleTime,
         addOne: UpdateNotification.empty(),
       );
+    } else {
+      _logger.warning(
+          'Database is missing updates stream, sync worker will not upload '
+          'reliably.');
     }
 
     final syncParams = syncParamsEncoded == null