Fix broken token invalidation on web

CHANGELOG.md

@@ -3,6 +3,38 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## 2025-03-11
+
+### Changes
+
+---
+
+Packages with breaking changes:
+
+ - There are no breaking changes in this release.
+
+Packages with other changes:
+
+ - [`powersync_core` - `v1.2.2`](#powersync_core---v122)
+ - [`powersync_attachments_helper` - `v0.6.18+4`](#powersync_attachments_helper---v06184)
+ - [`powersync_sqlcipher` - `v0.1.5+2`](#powersync_sqlcipher---v0152)
+ - [`powersync` - `v1.12.2`](#powersync---v1122)
+
+Packages with dependency updates only:
+
+> Packages listed below depend on other packages in this workspace that have had changes. Their versions have been incremented to bump the minimum dependency versions of the packages they depend upon in this project.
+
+ - `powersync_attachments_helper` - `v0.6.18+4`
+ - `powersync_sqlcipher` - `v0.1.5+2`
+ - `powersync` - `v1.12.2`
+
+---
+
+#### `powersync_core` - `v1.2.2`
+
+ - Fix handling token invalidation on the web.
+
+
 ## 2025-03-06
 
 ### Changes

demos/benchmarks/pubspec.yaml

@@ -10,7 +10,7 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   path: ^1.8.3
   logging: ^1.2.0

demos/django-todolist/pubspec.yaml

@@ -10,7 +10,7 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   path: ^1.8.3
   logging: ^1.2.0

demos/firebase-nodejs-todolist/pubspec.yaml

@@ -11,7 +11,7 @@ dependencies:
   flutter:
     sdk: flutter
 
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.1
   path: ^1.8.3

demos/supabase-anonymous-auth/pubspec.yaml

@@ -11,7 +11,7 @@ dependencies:
   flutter:
     sdk: flutter
 
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.2
   path: ^1.8.3

demos/supabase-edge-function-auth/pubspec.yaml

@@ -11,7 +11,7 @@ dependencies:
   flutter:
     sdk: flutter
 
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.2
   path: ^1.8.3

demos/supabase-simple-chat/pubspec.yaml

@@ -37,7 +37,7 @@ dependencies:
 
   supabase_flutter: ^2.0.2
   timeago: ^3.6.0
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   path: ^1.8.3
   logging: ^1.2.0

demos/supabase-todolist-drift/pubspec.yaml

@@ -9,8 +9,8 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
-  powersync_attachments_helper: ^0.6.18+3
-  powersync: ^1.12.1
+  powersync_attachments_helper: ^0.6.18+4
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.1
   path: ^1.8.3

demos/supabase-todolist-optional-sync/pubspec.yaml

@@ -10,7 +10,7 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.1
   path: ^1.8.3

demos/supabase-todolist/pubspec.yaml

@@ -10,8 +10,8 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
-  powersync_attachments_helper: ^0.6.18+3
-  powersync: ^1.12.1
+  powersync_attachments_helper: ^0.6.18+4
+  powersync: ^1.12.2
   path_provider: ^2.1.1
   supabase_flutter: ^2.0.1
   path: ^1.8.3

demos/supabase-trello/pubspec.yaml

@@ -36,7 +36,7 @@ dependencies:
   random_name_generator: ^1.5.0
   flutter_dotenv: ^5.2.1
   logging: ^1.3.0
-  powersync: ^1.12.1
+  powersync: ^1.12.2
   sqlite_async: ^0.11.0
   path_provider: ^2.1.5
   supabase_flutter: ^2.8.3

packages/powersync/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.12.2
+
+ - Update a dependency to the latest release.
+
 ## 1.12.1
 
  - Update a dependency to the latest release.

packages/powersync/pubspec.yaml

@@ -1,5 +1,5 @@
 name: powersync
-version: 1.12.1
+version: 1.12.2
 homepage: https://powersync.com
 repository: https://github.com/powersync-ja/powersync.dart
 description: PowerSync Flutter SDK - sync engine for building local-first apps.
@@ -12,7 +12,7 @@ dependencies:
     sdk: flutter
 
   sqlite3_flutter_libs: ^0.5.23
-  powersync_core: ^1.2.1
+  powersync_core: ^1.2.2
   powersync_flutter_libs: ^0.4.7
   collection: ^1.17.0
 

packages/powersync_attachments_helper/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 0.6.18+4
+
+ - Update a dependency to the latest release.
+
 ## 0.6.18+3
 
  - Update a dependency to the latest release.

packages/powersync_attachments_helper/pubspec.yaml

@@ -1,6 +1,6 @@
 name: powersync_attachments_helper
 description: A helper library for handling attachments when using PowerSync.
-version: 0.6.18+3
+version: 0.6.18+4
 repository: https://github.com/powersync-ja/powersync.dart
 homepage: https://www.powersync.com/
 environment:
@@ -10,7 +10,7 @@ dependencies:
   flutter:
     sdk: flutter
 
-  powersync_core: ^1.2.1
+  powersync_core: ^1.2.2
   logging: ^1.2.0
   sqlite_async: ^0.11.0
   path_provider: ^2.0.13

packages/powersync_core/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.2.2
+
+ - Fix handling token invalidation on the web.
+
 ## 1.2.1
 
  - Raise minimum version of core extension to 0.3.11.

packages/powersync_core/lib/src/database/web/web_powersync_database.dart

@@ -162,7 +162,7 @@ class PowerSyncDatabaseImpl
       sync = StreamingSyncImplementation(
         adapter: storage,
         credentialsCallback: connector.getCredentialsCached,
-        invalidCredentialsCallback: connector.fetchCredentials,
+        invalidCredentialsCallback: connector.prefetchCredentials,
         uploadCrud: () => connector.uploadData(this),
         crudUpdateTriggerStream: crudStream,
         retryDelay: Duration(seconds: 3),

packages/powersync_core/lib/src/version.dart

@@ -1 +1 @@
-const String libraryVersion = '1.2.1';
+const String libraryVersion = '1.2.2';

packages/powersync_core/lib/src/web/sync_controller.dart

@@ -48,7 +48,7 @@ class SyncWorkerHandle implements StreamingSync {
             await connector.uploadData(database);
             return (JSObject(), null);
           case SyncWorkerMessageType.invalidCredentialsCallback:
-            final credentials = await connector.fetchCredentials();
+            final credentials = await connector.prefetchCredentials();
             return (
               credentials != null
                   ? SerializedCredentials.from(credentials)

packages/powersync_core/pubspec.yaml

@@ -1,5 +1,5 @@
 name: powersync_core
-version: 1.2.1
+version: 1.2.2
 homepage: https://powersync.com
 repository: https://github.com/powersync-ja/powersync.dart
 description: PowerSync Dart SDK - sync engine for building local-first apps.
@@ -13,7 +13,7 @@ dependencies:
   # but right now we need a minimum of v2.4.6.
   sqlite3: ^2.4.6
   # We implement a database controller, which is an interface of sqlite3_web.
-  sqlite3_web: ^0.3.0
+  sqlite3_web: ^0.3.1
   universal_io: ^2.0.0
   meta: ^1.0.0
   http: ^1.1.0

packages/powersync_core/test/in_memory_sync_test.dart

@@ -20,22 +20,26 @@ void main() {
     late CommonDatabase raw;
     late PowerSyncDatabase database;
     late MockSyncService syncService;
-    late StreamingSyncImplementation syncClient;
+    late StreamingSync syncClient;
+    var credentialsCallbackCount = 0;
 
     setUp(() async {
+      credentialsCallbackCount = 0;
       final (client, server) = inMemoryServer();
       syncService = MockSyncService();
       server.mount(syncService.router.call);
 
       factory = await testUtils.testFactory();
       (raw, database) = await factory.openInMemoryDatabase();
       await database.initialize();
+
       syncClient = database.connectWithMockService(
         client,
         TestConnector(() async {
+          credentialsCallbackCount++;
           return PowerSyncCredentials(
             endpoint: server.url.toString(),
-            token: 'token not used here',
+            token: 'token$credentialsCallbackCount',
             expiresAt: DateTime.now(),
           );
         }),
@@ -312,18 +316,37 @@ void main() {
         },
       );
     });
+
+    test('reconnects when token expires', () async {
+      await waitForConnection();
+      expect(credentialsCallbackCount, 1);
+      // When the sync service says the token has expired
+      syncService
+        ..addLine({'token_expires_in': 0})
+        ..endCurrentListener();
+
+      final nextRequest = await syncService.waitForListener;
+      expect(nextRequest.headers['Authorization'], 'Token token2');
+      expect(credentialsCallbackCount, 2);
+    });
   });
 }
 
 TypeMatcher<SyncStatus> isSyncStatus(
-    {Object? downloading, Object? connected, Object? hasSynced}) {
+    {Object? downloading,
+    Object? connected,
+    Object? connecting,
+    Object? hasSynced}) {
   var matcher = isA<SyncStatus>();
   if (downloading != null) {
     matcher = matcher.having((e) => e.downloading, 'downloading', downloading);
   }
   if (connected != null) {
     matcher = matcher.having((e) => e.connected, 'connected', connected);
   }
+  if (connecting != null) {
+    matcher = matcher.having((e) => e.connecting, 'connecting', connecting);
+  }
   if (hasSynced != null) {
     matcher = matcher.having((e) => e.hasSynced, 'hasSynced', hasSynced);
   }

packages/powersync_core/test/server/sync_server/in_memory_sync_server.dart

@@ -6,15 +6,15 @@ import 'package:shelf_router/shelf_router.dart';
 
 final class MockSyncService {
   // Use a queued stream to make tests easier.
-  StreamController<String> _controller = StreamController<String>();
-  Completer<void> _listener = Completer();
+  StreamController<String> _controller = StreamController();
+  Completer<Request> _listener = Completer();
 
   final router = Router();
 
   MockSyncService() {
     router
       ..post('/sync/stream', (Request request) async {
-        _listener.complete();
+        _listener.complete(request);
         // Respond immediately with a stream
         return Response.ok(_controller.stream.transform(utf8.encoder),
             headers: {
@@ -33,7 +33,7 @@ final class MockSyncService {
       });
   }
 
-  Future<void> get waitForListener => _listener.future;
+  Future<Request> get waitForListener => _listener.future;
 
   // Queue events which will be sent to connected clients.
   void addRawEvent(String data) {
@@ -48,6 +48,12 @@ final class MockSyncService {
     addLine({'token_expires_in': tokenExpiresIn});
   }
 
+  void endCurrentListener() {
+    _controller.close();
+    _controller = StreamController();
+    _listener = Completer();
+  }
+
   // Clear events. We rely on a buffered controller here. Create a new controller
   // in order to clear the buffer.
   Future<void> clearEvents() async {

packages/powersync_sqlcipher/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 0.1.5+2
+
+ - Update a dependency to the latest release.
+
 ## 0.1.5+1
 
  - Update a dependency to the latest release.

packages/powersync_sqlcipher/pubspec.yaml

@@ -1,5 +1,5 @@
 name: powersync_sqlcipher
-version: 0.1.5+1
+version: 0.1.5+2
 homepage: https://powersync.com
 repository: https://github.com/powersync-ja/powersync.dart
 description: PowerSync Flutter SDK - sync engine for building local-first apps.
@@ -12,7 +12,7 @@ dependencies:
   flutter:
     sdk: flutter
 
-  powersync_core: ^1.2.1
+  powersync_core: ^1.2.2
   powersync_flutter_libs: ^0.4.7
   sqlcipher_flutter_libs: ^0.6.4
   sqlite3_web: ^0.3.0