Enable statement vtab

Author: simolus3

dart/pubspec.lock

@@ -17,14 +17,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "10.0.0"
-  archive:
-    dependency: "direct dev"
-    description:
-      name: archive
-      sha256: "2fde1607386ab523f7a36bb3e7edb43bd58e6edaf2ffb29d8a6d578b297fdbbd"
-      url: "https://pub.dev"
-    source: hosted
-    version: "4.0.7"
   args:
     dependency: transitive
     description:
@@ -177,14 +169,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.0.0"
-  http:
-    dependency: "direct dev"
-    description:
-      name: http
-      sha256: "87721a4a50b19c7f1d49001e51409bddc46303966ce89a65af4f4e6004896412"
-      url: "https://pub.dev"
-    source: hosted
-    version: "1.6.0"
   http_multi_server:
     dependency: transitive
     description:
@@ -297,14 +281,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.5.2"
-  posix:
-    dependency: transitive
-    description:
-      name: posix
-      sha256: "6323a5b0fa688b6a010df4905a56b00181479e6d10534cecfecede2aa55add61"
-      url: "https://pub.dev"
-    source: hosted
-    version: "6.0.3"
   power_extensions:
     dependency: transitive
     description:

dart/pubspec.yaml

@@ -4,6 +4,7 @@ version: 0.0.1
 description: Tests for powersync-sqlite-core
 environment:
   sdk: ^3.4.0
+
 dependencies:
   sqlite3: ^3.0.0
   bson: ^5.0.5
@@ -17,5 +18,14 @@ dev_dependencies:
   convert: ^3.1.2
   meta: ^1.16.0
   path: ^1.9.1
-  http: ^1.5.0
-  archive: ^4.0.7
+
+# See https://pub.dev/documentation/sqlite3/latest/topics/hook-topic.html
+hooks:
+  user_defines:
+    sqlite3:
+      source: source
+      path: ../crates/sqlite/sqlite/sqlite3.c
+      # Used in sync_test.dart to ensure the core extension dosn't leave any
+      # busy statements behind.
+      defines:
+        - SQLITE_ENABLE_STMTVTAB

dart/test/error_test.dart

@@ -55,6 +55,7 @@ void main() {
             'powersync_control: Sync protocol error: invalid text line. cause: expected value at line 1 column 1',
           )),
         );
+        control.close();
       });
     });
   });

dart/test/js_key_encoding_test.dart

@@ -1,27 +1,15 @@
 import 'dart:convert';
 
-import 'package:file/local.dart';
 import 'package:sqlite3/common.dart';
-import 'package:sqlite3/sqlite3.dart';
-import 'package:sqlite3_test/sqlite3_test.dart';
 import 'package:test/test.dart';
 
 import 'utils/native_test_utils.dart';
 
 void main() {
-  // Needs an unique name per test file to avoid concurrency issues
-  final vfs = TestSqliteFileSystem(
-      fs: const LocalFileSystem(), name: 'js-key-encoding-test-vfs');
   late CommonDatabase db;
 
-  setUpAll(() {
-    loadExtension();
-    sqlite3.registerVirtualFileSystem(vfs, makeDefault: false);
-  });
-  tearDownAll(() => sqlite3.unregisterVirtualFileSystem(vfs));
-
   setUp(() async {
-    db = openTestDatabase(vfs: vfs)
+    db = openTestDatabase()
       ..select('select powersync_init();')
       ..select('select powersync_replace_schema(?)', [json.encode(_schema)]);
   });

dart/test/sync_local_performance_test.dart

@@ -33,8 +33,8 @@ void testFilesystemOperations(
 
   setUp(() async {
     // Needs an unique name per test file to avoid concurrency issues
-    vfs = new TrackingFileSystem(
-        parent: new InMemoryFileSystem(), name: 'perf-test-vfs');
+    vfs =
+        TrackingFileSystem(parent: InMemoryFileSystem(), name: 'perf-test-vfs');
     sqlite3.registerVirtualFileSystem(vfs, makeDefault: false);
     db = openTestDatabase(vfs: vfs, fileName: 'test.db');
   });

dart/test/sync_test.dart

@@ -50,10 +50,9 @@ void _syncTests<T>({
 
       // Make sure that powersync_control doesn't leave any busy statements
       // behind.
-      // TODO: Re-enable after we can guarantee sqlite_stmt being available
-      // const statement = 'SELECT * FROM sqlite_stmt WHERE busy AND sql != ?;';
-      // final busy = db.select(statement, [statement]);
-      // expect(busy, isEmpty);
+      const statement = 'SELECT * FROM sqlite_stmt WHERE busy AND sql != ?;';
+      final busy = db.select(statement, [statement]);
+      expect(busy, isEmpty);
     } catch (e) {
       db.execute('rollback');
       rethrow;