Start setting up Dart tests

Author: simolus3

dart/pubspec.lock

@@ -46,6 +46,22 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.1.2"
+  bson:
+    dependency: "direct main"
+    description:
+      name: bson
+      sha256: "9071b154b5cd96482c2e116b015e87acfdc8412630cc8f3aba60c539a8ef5442"
+      url: "https://pub.dev"
+    source: hosted
+    version: "5.0.5"
+  clock:
+    dependency: transitive
+    description:
+      name: clock
+      sha256: fddb70d9b5277016c77a80201021d40a2247104d9f4aa7bab7157b7e3f05b84b
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.1.2"
   collection:
     dependency: transitive
     description:
@@ -78,6 +94,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "3.0.6"
+  decimal:
+    dependency: transitive
+    description:
+      name: decimal
+      sha256: "28239b8b929c1bd8618702e6dbc96e2618cf99770bbe9cb040d6cf56a11e4ec3"
+      url: "https://pub.dev"
+    source: hosted
+    version: "3.2.1"
   ffi:
     dependency: transitive
     description:
@@ -94,6 +118,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "7.0.1"
+  fixnum:
+    dependency: transitive
+    description:
+      name: fixnum
+      sha256: b6dc7065e46c974bc7c5f143080a6764ec7a4be6da1285ececdc37be96de53be
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.1.1"
   frontend_server_client:
     dependency: transitive
     description:
@@ -126,6 +158,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "4.1.2"
+  intl:
+    dependency: transitive
+    description:
+      name: intl
+      sha256: "3df61194eb431efc39c4ceba583b95633a403f46c9fd341e550ce0bfa50e9aa5"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.20.2"
   io:
     dependency: transitive
     description:
@@ -198,6 +238,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.1.1"
+  packages_extensions:
+    dependency: transitive
+    description:
+      name: packages_extensions
+      sha256: "1fb328695a9828c80d275ce1650a2bb5947690070de082dfa1dfac7429378daf"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.1.1"
   path:
     dependency: transitive
     description:
@@ -214,6 +262,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.5.1"
+  power_extensions:
+    dependency: transitive
+    description:
+      name: power_extensions
+      sha256: ad0e8b2420090d996fe8b7fd32cdf02b9b924b6d4fc0fb0b559ff6aa5e24d5b0
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.2.3"
   pub_semver:
     dependency: transitive
     description:
@@ -222,6 +278,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.1.5"
+  rational:
+    dependency: transitive
+    description:
+      name: rational
+      sha256: cb808fb6f1a839e6fc5f7d8cb3b0a10e1db48b3be102de73938c627f0b636336
+      url: "https://pub.dev"
+    source: hosted
+    version: "2.2.3"
   shelf:
     dependency: transitive
     description:
@@ -278,6 +342,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.10.1"
+  sprintf:
+    dependency: transitive
+    description:
+      name: sprintf
+      sha256: "1fc9ffe69d4df602376b52949af107d8f5703b77cda567c4d7d86a0693120f23"
+      url: "https://pub.dev"
+    source: hosted
+    version: "7.0.0"
   sqlite3:
     dependency: "direct main"
     description:
@@ -350,6 +422,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.4.0"
+  uuid:
+    dependency: transitive
+    description:
+      name: uuid
+      sha256: a5be9ef6618a7ac1e964353ef476418026db906c4facdedaa299b7a2e71690ff
+      url: "https://pub.dev"
+    source: hosted
+    version: "4.5.1"
   vm_service:
     dependency: transitive
     description:

dart/pubspec.yaml

@@ -6,5 +6,6 @@ environment:
   sdk: ^3.4.0
 dependencies:
   sqlite3: ^2.4.5
+  bson: ^5.0.5
 dev_dependencies:
   test: ^1.25.0

dart/test/new_sync_test.dart

@@ -0,0 +1,69 @@
+import 'dart:convert';
+
+import 'package:bson/bson.dart';
+import 'package:sqlite3/common.dart';
+import 'package:test/test.dart';
+
+import 'utils/native_test_utils.dart';
+
+void main() {
+  group('text lines', () {
+    _syncTests(isBson: false);
+  });
+
+  group('bson lines', () {
+    _syncTests(isBson: true);
+  });
+}
+
+void _syncTests<T>({
+  required bool isBson,
+}) {
+  late CommonDatabase db;
+
+  setUp(() async {
+    db = openTestDatabase()
+      ..select('select powersync_init();')
+      ..select('select powersync_replace_schema(?)', [json.encode(_schema)]);
+  });
+
+  tearDown(() {
+    db.dispose();
+  });
+
+  List<Object?> invokeControl(String operation, Object? data) {
+    final [row] =
+        db.select('SELECT powersync_control(?, ?)', [operation, data]);
+    return jsonDecode(row.columnAt(0));
+  }
+
+  List<Object?> syncLine(Object? line) {
+    if (isBson) {
+      return invokeControl('line_binary', BsonCodec.serialize(line).byteList);
+    } else {
+      return invokeControl('line_text', jsonEncode(line));
+    }
+  }
+
+  test('starting stream', () {
+    final result = invokeControl('start', null);
+  });
+}
+
+const _schema = {
+  'tables': [
+    {
+      'name': 'items',
+      'columns': [
+        {'name': 'col', 'type': 'text'}
+      ],
+    }
+  ]
+};
+
+const _bucketDescriptions = {
+  'prio0': {'priority': 0},
+  'prio1': {'priority': 1},
+  'prio2': {'priority': 2},
+  'prio3': {'priority': 3},
+};