More cleanup

Author: simolus3

packages/powersync_core/lib/src/sync/bucket_storage.dart

@@ -365,22 +365,6 @@ UPDATE ps_buckets SET count_since_last = 0, count_at_last = ?1->name
         });
   }
 
-  Future<String> control(String op, [Object? payload]) async {
-    return await writeTransaction(
-      (tx) async {
-        final [row] =
-            await tx.execute('SELECT powersync_control(?, ?)', [op, payload]);
-        return row.columnAt(0) as String;
-      },
-      // We flush when powersync_control yields an instruction to do so.
-      flush: false,
-    );
-  }
-
-  Future<void> flushFileSystem() async {
-    // Noop outside of web.
-  }
-
   /// Note: The asynchronous nature of this is due to this needing a global
   /// lock. The actual database operations are still synchronous, and it
   /// is assumed that multiple functions on this instance won't be called

packages/powersync_core/lib/src/sync/sync_status.dart

@@ -189,9 +189,6 @@ extension type const BucketPriority._(int priorityNumber) {
   /// A [Comparator] instance suitable for comparing [BucketPriority] values.
   static int comparator(BucketPriority a, BucketPriority b) =>
       -a.priorityNumber.compareTo(b.priorityNumber);
-
-  /// The priority used by PowerSync to indicate that a full sync was completed.
-  static const fullSyncPriority = BucketPriority._(2147483647);
 }
 
 /// Partial information about the synchronization status for buckets within a

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

@@ -71,7 +71,10 @@ class _ConnectedClient {
             final recoveredOptions = SyncOptions(
               crudThrottleTime:
                   Duration(milliseconds: request.crudThrottleTimeMs),
-              retryDelay: Duration(milliseconds: request.retryDelayMs),
+              retryDelay: switch (request.retryDelayMs) {
+                null => null,
+                final retryDelay => Duration(milliseconds: retryDelay),
+              },
               params: switch (request.syncParamsEncoded) {
                 null => null,
                 final encodedParams =>

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

@@ -69,14 +69,14 @@ extension type StartSynchronization._(JSObject _) implements JSObject {
     required String databaseName,
     required int crudThrottleTimeMs,
     required int requestId,
-    required int retryDelayMs,
+    required int? retryDelayMs,
     String? syncParamsEncoded,
   });
 
   external String get databaseName;
   external int get requestId;
   external int get crudThrottleTimeMs;
-  external int get retryDelayMs;
+  external int? get retryDelayMs;
   external String? get syncParamsEncoded;
 }
 

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

@@ -17,9 +17,4 @@ class WebBucketStorage extends BucketStorage {
     return _webDb.writeTransaction(callback,
         lockTimeout: lockTimeout, flush: flush);
   }
-
-  @override
-  Future<void> flushFileSystem() {
-    return _webDb.flush();
-  }
 }