fix: Reintroduce waitForFirstSync

Author: mugikhan

.github/workflows/release.yml

@@ -9,7 +9,7 @@ on:
       # This action is not compatible with tags such as `powersync-v1.1.1`
       # marvinpinto/action-automatic-releases struggles to generate changelogs
       # Be sure to manually tag the commit to trigger this action
-      - 'v*'
+      - "powersync-v[0-9]+.[0-9]+.[0-9]+"
 
 jobs:
   build:
@@ -22,8 +22,8 @@ jobs:
       - name: Install Flutter
         uses: subosito/flutter-action@v2
         with:
-          flutter-version: '3.x'
-          channel: 'stable'
+          flutter-version: "3.x"
+          channel: "stable"
 
       - name: Install Melos
         run: flutter pub global activate melos
@@ -32,10 +32,8 @@ jobs:
         run: melos prepare
 
       - name: Create Draft Release
-        uses: 'marvinpinto/action-automatic-releases@latest'
-        with:
-          repo_token: '${{ secrets.GITHUB_TOKEN }}'
-          prerelease: true # TODO update when out of alpha
-          draft: true
-          files: |
-            assets/powersync_db.worker.js
+        run: |
+          tag="${{ github.ref_name }}"
+          body="Release $tag"
+          gh release create --draft "$tag" --title "$tag" --notes "$body" --generate-notes --prerelease
+          gh release upload "${{ github.ref_name }}" assets/powersync_db.worker.js

melos.yaml

@@ -8,6 +8,11 @@ packages:
 ide:
   intellij: false
 
+command:
+  version:
+    packageFilters:
+      noPrivate: true
+
 scripts:
   prepare: melos bootstrap && dart ./scripts/compile_webworker.dart && dart ./scripts/init_sqlite_wasm.dart && dart ./scripts/init_powersync_core_binary.dart
 

packages/powersync/lib/src/database/powersync_db_mixin.dart

@@ -104,6 +104,18 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
     }
   }
 
+  /// Returns a [Future] which will resolve once the first full sync has completed.
+  Future<void> waitForFirstSync() async {
+    if (currentStatus.hasSynced ?? false) {
+      return;
+    }
+    await for (final result in statusStream) {
+      if (result.hasSynced ?? false) {
+        break;
+      }
+    }
+  }
+
   @protected
   void setStatus(SyncStatus status) {
     if (status != currentStatus) {