Also test web

Author: simolus3

packages/powersync_sqlcipher/example/pubspec.lock

@@ -57,6 +57,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.19.1"
+  convert:
+    dependency: transitive
+    description:
+      name: convert
+      sha256: b30acd5944035672bc15c6b7a8b47d773e41e2f17de064350988c5d02adb1c68
+      url: "https://pub.dev"
+    source: hosted
+    version: "3.1.2"
   crypto:
     dependency: transitive
     description:
@@ -218,6 +226,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.16.0"
+  mime:
+    dependency: transitive
+    description:
+      name: mime
+      sha256: "41a20518f0cb1256669420fdba0cd90d21561e560ac240f26ef8322e45bb7ed6"
+      url: "https://pub.dev"
+    source: hosted
+    version: "2.0.0"
   mutex:
     dependency: transitive
     description:
@@ -343,6 +359,22 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.5.0"
+  shelf:
+    dependency: "direct dev"
+    description:
+      name: shelf
+      sha256: e7dd780a7ffb623c57850b33f43309312fc863fb6aa3d276a754bb299839ef12
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.4.2"
+  shelf_static:
+    dependency: "direct dev"
+    description:
+      name: shelf_static
+      sha256: c87c3875f91262785dade62d135760c2c69cb217ac759485334c5857ad89f6e3
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.1.3"
   sky_engine:
     dependency: transitive
     description: flutter
@@ -404,7 +436,7 @@ packages:
     source: hosted
     version: "1.12.1"
   stream_channel:
-    dependency: transitive
+    dependency: "direct dev"
     description:
       name: stream_channel
       sha256: "969e04c80b8bcdf826f8f16579c7b14d780458bd97f56d107d3950fdbeef059d"
@@ -484,7 +516,7 @@ packages:
     source: hosted
     version: "15.0.0"
   web:
-    dependency: transitive
+    dependency: "direct dev"
     description:
       name: web
       sha256: "868d88a33d8a87b18ffc05f9f030ba328ffefba92d6c127917a2ba740f9cfe4a"

packages/powersync_sqlcipher/example/pubspec.yaml

@@ -22,6 +22,10 @@ dev_dependencies:
     sdk: flutter
 
   flutter_lints: ^5.0.0
+  shelf: ^1.4.2
+  shelf_static: ^1.1.3
+  stream_channel: ^2.1.4
+  web: ^1.1.1
 
 flutter:
   uses-material-design: true

packages/powersync_sqlcipher/example/test/web_test.dart

@@ -0,0 +1,70 @@
+@TestOn('js')
+library;
+
+import 'dart:js_interop';
+
+import 'package:flutter_test/flutter_test.dart';
+import 'package:powersync_sqlcipher/powersync.dart';
+import 'package:powersync_sqlcipher/sqlite_async.dart';
+import 'package:web/web.dart' as web;
+
+void main() {
+  // We can't run integration tests on the web, so this is a small smoke test
+  // using the worker
+  test('can use encrypted database', () async {
+    final channel = spawnHybridUri('/test/worker_server.dart');
+    final port = (await channel.stream.first as num).toInt();
+    final sqliteWasmUri = 'http://localhost:$port/sqlite3mc.wasm';
+    // Cross origin workers are not supported, but we can supply a Blob
+    var sqliteUri = 'http://localhost:$port/db_worker.js';
+
+    final blob = web.Blob(
+      <web.BlobPart>['importScripts("$sqliteUri");'.toJS].toJS,
+      web.BlobPropertyBag(type: 'application/javascript'),
+    );
+    sqliteUri = _createObjectURL(blob);
+
+    final webOptions = SqliteOptions(
+      webSqliteOptions: WebSqliteOptions(
+        wasmUri: sqliteWasmUri.toString(),
+        workerUri: sqliteUri,
+      ),
+    );
+
+    final path = 'powersync-demo.db';
+
+    var db = PowerSyncDatabase.withFactory(
+      PowerSyncSQLCipherOpenFactory(
+        path: path,
+        key: 'demo-key',
+        sqliteOptions: webOptions,
+      ),
+      schema: schema,
+    );
+
+    await db.execute('INSERT INTO users (id, name) VALUES (uuid(), ?)', [
+      'My username',
+    ]);
+    await db.close();
+
+    expect(() async {
+      db = PowerSyncDatabase.withFactory(
+        PowerSyncSQLCipherOpenFactory(
+          path: path,
+          key: 'changed-key',
+          sqliteOptions: webOptions,
+        ),
+        schema: schema,
+      );
+
+      await db.initialize();
+    }, throwsA(anything));
+  });
+}
+
+@JS('URL.createObjectURL')
+external String _createObjectURL(web.Blob blob);
+
+final schema = Schema([
+  Table('users', [Column.text('name')]),
+]);

packages/powersync_sqlcipher/example/test/worker_server.dart

@@ -0,0 +1,52 @@
+import 'dart:io';
+
+import 'package:path/path.dart' as p;
+import 'package:shelf/shelf.dart';
+import 'package:shelf/shelf_io.dart' as io;
+import 'package:shelf_static/shelf_static.dart';
+import 'package:stream_channel/stream_channel.dart';
+
+const _corsHeaders = {'Access-Control-Allow-Origin': '*'};
+
+Middleware cors() {
+  Response? handleOptionsRequest(Request request) {
+    if (request.method == 'OPTIONS') {
+      return Response.ok(null, headers: _corsHeaders);
+    } else {
+      // Returning null will run the regular request handler
+      return null;
+    }
+  }
+
+  Response addCorsHeaders(Response response) {
+    return response.change(headers: _corsHeaders);
+  }
+
+  return createMiddleware(
+    requestHandler: handleOptionsRequest,
+    responseHandler: addCorsHeaders,
+  );
+}
+
+Future<void> hybridMain(StreamChannel<Object?> channel) async {
+  final sqliteOutputPath = p.join('web', 'sqlite3mc.wasm');
+
+  if (!(await File(sqliteOutputPath).exists())) {
+    throw AssertionError(
+      'sqlite3mc.wasm file should be present in the ./web folder',
+    );
+  }
+
+  final server = await HttpServer.bind('localhost', 0);
+
+  final handler = const Pipeline()
+      .addMiddleware(cors())
+      .addHandler(createStaticHandler('web'));
+  io.serveRequests(server, handler);
+
+  channel.sink.add(server.port);
+  await channel.stream.listen(null).asFuture<void>().then<void>((_) async {
+    print('closing server');
+    await server.close();
+  });
+}