Start setting up Dart tests

Author: simolus3

dart/pubspec.lock

@@ -41,6 +41,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.1.2"
+  bson:
+    dependency: "direct main"
+    description:
+      name: bson
+      sha256: "9b761248a3494fea594aecf5d6f369b5f04d7b082aa2b8c06579ade77f1a7e47"
+      url: "https://pub.dev"
+    source: hosted
+    version: "5.0.6"
   cli_config:
     dependency: transitive
     description:
@@ -89,6 +97,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"
   fake_async:
     dependency: "direct dev"
     description:
@@ -113,6 +129,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:
@@ -145,6 +169,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:
@@ -209,6 +241,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.2.0"
+  packages_extensions:
+    dependency: transitive
+    description:
+      name: packages_extensions
+      sha256: "1fb328695a9828c80d275ce1650a2bb5947690070de082dfa1dfac7429378daf"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.1.1"
   path:
     dependency: transitive
     description:
@@ -225,6 +265,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:
@@ -233,6 +281,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.2.0"
+  rational:
+    dependency: transitive
+    description:
+      name: rational
+      sha256: cb808fb6f1a839e6fc5f7d8cb3b0a10e1db48b3be102de73938c627f0b636336
+      url: "https://pub.dev"
+    source: hosted
+    version: "2.2.3"
   shelf:
     dependency: transitive
     description:
@@ -289,6 +345,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:
@@ -369,6 +433,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,6 +6,7 @@ environment:
   sdk: ^3.4.0
 dependencies:
   sqlite3: ^2.4.5
+  bson: ^5.0.5
 dev_dependencies:
   test: ^1.25.0
   file: ^7.0.1

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},
+};