Time initial sync.

Author: rkistner

demos/benchmarks/lib/main.dart

@@ -67,7 +67,7 @@ class MyHomePage extends StatelessWidget {
   Widget build(BuildContext context) {
     return Scaffold(
       appBar: StatusAppBar(title: title),
-      body: Center(child: content),
+      body: content,
       floatingActionButton: floatingActionButton,
       drawer: Drawer(
         // Add a ListView to the drawer. This ensures the user can scroll

demos/benchmarks/lib/models/benchmark_item.dart

@@ -64,6 +64,12 @@ class BenchmarkItem {
     return BenchmarkItem.fromRow(results);
   }
 
+  static Future<void> deleteAll() async {
+    await db.execute(
+      'DELETE FROM benchmark_items',
+    );
+  }
+
   /// Delete this item.
   Future<void> delete() async {
     await db.execute('DELETE FROM benchmark_items WHERE id = ?', [id]);

demos/benchmarks/lib/powersync.dart

@@ -1,15 +1,14 @@
 // This file performs setup of the PowerSync database
 import 'dart:convert';
-import 'dart:io';
-
-import 'package:http/http.dart' as http;
 
 import 'package:flutter/foundation.dart';
+import 'package:http/http.dart' as http;
 import 'package:logging/logging.dart';
 import 'package:path/path.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:powersync/powersync.dart';
 import 'package:powersync_benchmarks/models/benchmark_item.dart';
+import 'package:powersync_benchmarks/sync_timer.dart';
 
 import './app_config.dart';
 import './models/schema.dart';
@@ -75,6 +74,7 @@ class BackendConnector extends PowerSyncBackendConnector {
 
 /// Global reference to the database
 late final PowerSyncDatabase db;
+SyncTimer timer = SyncTimer();
 
 Future<String> getDatabasePath() async {
   const dbFilename = 'powersync-benchmarks.db';
@@ -86,6 +86,16 @@ Future<String> getDatabasePath() async {
   return join(dir.path, dbFilename);
 }
 
+var currentConnector = BackendConnector();
+
+Future<void> resync() async {
+  await db.disconnectAndClear();
+  timer.start(db);
+  db.connect(
+      connector: currentConnector,
+      crudThrottleTime: const Duration(milliseconds: 1));
+}
+
 Future<void> openDatabase() async {
   // Open the local database
   db = PowerSyncDatabase(
@@ -94,8 +104,7 @@ Future<void> openDatabase() async {
 
   BenchmarkItem.updateItemBenchmarks();
 
-  var currentConnector = BackendConnector();
-
+  timer.start(db);
   db.connect(
       connector: currentConnector,
       crudThrottleTime: const Duration(milliseconds: 1));

demos/benchmarks/lib/sync_timer.dart

@@ -0,0 +1,33 @@
+import 'dart:async';
+
+import 'package:powersync/powersync.dart';
+
+class SyncTimer {
+  Stopwatch stopwatch = Stopwatch();
+  Duration? syncTime;
+  bool hasSynced = false;
+  StreamSubscription? subscription;
+
+  StreamSubscription start(PowerSyncDatabase db) {
+    hasSynced = false;
+    syncTime = null;
+    subscription?.cancel();
+    stopwatch.reset();
+
+    stopwatch.start();
+    subscription = db.statusStream.listen((data) {
+      if (hasSynced != true &&
+          data.hasSynced == true &&
+          data.connected == true &&
+          data.downloading == false) {
+        syncTime = stopwatch.elapsed;
+        hasSynced = true;
+      }
+    });
+    return subscription!;
+  }
+
+  Duration get elapsed {
+    return stopwatch.elapsed;
+  }
+}

demos/benchmarks/lib/widgets/benchmark_item_widget.dart

@@ -22,33 +22,18 @@ class ListItemWidget extends StatelessWidget {
         ? '${item.uploadLatency!.inMilliseconds}ms'
         : '';
 
-    String subtitle =
-        '$latency / $uploadLatency / ${item.serverCreatedAt?.toIso8601String() ?? ''}';
+    String subtitle = item.latency == null
+        ? 'Syncing...'
+        : 'Sync latency: $latency / upload: $uploadLatency';
     return Card(
       child: Column(
         mainAxisSize: MainAxisSize.min,
         children: <Widget>[
           ListTile(
-            leading: const Icon(Icons.list),
+            leading: const Icon(Icons.timer),
             title: Text(item.description),
             subtitle: Text(subtitle),
           ),
-          Row(
-            mainAxisAlignment: MainAxisAlignment.end,
-            children: <Widget>[
-              IconButton(
-                iconSize: 30,
-                icon: const Icon(
-                  Icons.delete,
-                  color: Colors.red,
-                ),
-                tooltip: 'Delete Item',
-                alignment: Alignment.centerRight,
-                onPressed: delete,
-              ),
-              const SizedBox(width: 8),
-            ],
-          ),
         ],
       ),
     );

demos/benchmarks/lib/widgets/benchmark_items_page.dart

@@ -7,16 +7,18 @@ import '../main.dart';
 import '../models/benchmark_item.dart';
 import '../powersync.dart';
 
+var itemIndex = 1;
+
 class BenchmarkItemsPage extends StatelessWidget {
   const BenchmarkItemsPage({super.key});
 
   @override
   Widget build(BuildContext context) {
     const content = BenchmarkItemsWidget();
 
-    final button = FloatingActionButton(
+    final addButton = FloatingActionButton(
       onPressed: () {
-        BenchmarkItem.create('Benchmarks');
+        BenchmarkItem.create('Latency test ${itemIndex++}');
       },
       tooltip: 'Create Item',
       child: const Icon(Icons.add),
@@ -25,7 +27,7 @@ class BenchmarkItemsPage extends StatelessWidget {
     final page = MyHomePage(
       title: 'Benchmarks',
       content: content,
-      floatingActionButton: button,
+      floatingActionButton: addButton,
     );
     return page;
   }
@@ -44,7 +46,9 @@ class _BenchmarkItemsWidgetState extends State<BenchmarkItemsWidget> {
   List<BenchmarkItem> _data = [];
   bool hasSynced = false;
   StreamSubscription? _subscription;
+  StreamSubscription? _countSubscription;
   StreamSubscription? _syncStatusSubscription;
+  int? count;
 
   _BenchmarkItemsWidgetState();
 
@@ -60,6 +64,15 @@ class _BenchmarkItemsWidgetState extends State<BenchmarkItemsWidget> {
         _data = data;
       });
     });
+    _countSubscription =
+        db.watch('select count() as count from ps_oplog').listen((data) {
+      if (!context.mounted) {
+        return;
+      }
+      setState(() {
+        count = data.first['count'];
+      });
+    });
     _syncStatusSubscription = db.statusStream.listen((status) {
       if (!context.mounted) {
         return;
@@ -75,17 +88,55 @@ class _BenchmarkItemsWidgetState extends State<BenchmarkItemsWidget> {
     super.dispose();
     _subscription?.cancel();
     _syncStatusSubscription?.cancel();
+    _countSubscription?.cancel();
   }
 
   @override
   Widget build(BuildContext context) {
-    return !hasSynced
-        ? const Text("Busy with sync...")
-        : ListView(
+    Duration? syncDuration = timer.syncTime ?? timer.elapsed;
+    if (!hasSynced) {
+      return Center(
+          child: Text(
+              "Busy with sync... ${syncDuration.inMilliseconds}ms / $count operations"));
+    }
+
+    final clearButton = TextButton.icon(
+        label: const Text('Delete all'),
+        onPressed: () {
+          BenchmarkItem.deleteAll();
+        },
+        icon: const Icon(Icons.delete));
+
+    final resyncButton = TextButton.icon(
+        label: const Text('Resync'),
+        onPressed: () async {
+          await resync();
+        },
+        icon: const Icon(Icons.sync));
+
+    var buttons = Padding(
+      padding: const EdgeInsets.all(8.0),
+      child: OverflowBar(
+        alignment: MainAxisAlignment.end,
+        spacing: 8.0,
+        overflowSpacing: 8.0,
+        children: <Widget>[
+          Text(
+              'First sync duration: ${syncDuration.inMilliseconds}ms / $count operations'),
+          resyncButton,
+          clearButton,
+        ],
+      ),
+    );
+    return Column(children: [
+      buttons,
+      Expanded(
+        child: ListView(
             padding: const EdgeInsets.symmetric(vertical: 8.0),
             children: _data.map((list) {
               return ListItemWidget(item: list);
-            }).toList(),
-          );
+            }).toList()),
+      )
+    ]);
   }
 }