Restructure.

Author: rkistner

.github/workflows/packages.yml

@@ -0,0 +1,48 @@
+name: Packages check
+
+on:
+  push:
+    branches:
+      - "**"
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - name: Install Flutter
+        uses: subosito/flutter-action@v2
+        with:
+          flutter-version: "3.x"
+          channel: "stable"
+
+      - name: Install Melos
+        run: flutter pub global activate melos
+      - name: Install dependencies
+        run: melos bootstrap
+      - name: Check formatting
+        run: melos format:check:packages
+      - name: Lint
+        run: melos analyze:packages
+      - name: Publish dry-run
+        run: melos publish --dry-run --yes
+      - name: Check publish score
+        run: |
+          flutter pub global activate pana
+          ./.github/workflows/scripts/run-pana.sh
+
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - name: Install Flutter
+        uses: subosito/flutter-action@v2
+        with:
+          flutter-version: "3.x"
+          channel: "stable"
+      - name: Install melos
+        run: flutter pub global activate melos
+      - name: Install dependencies
+        run: melos bootstrap
+      - name: Run tests
+        run: melos test

.github/workflows/scripts/run-pana.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+set -e
+
+# Get the root directory of your project
+ROOT_DIR=$(pwd)
+
+# Specify the path to the packages folder
+PACKAGES_DIR="$ROOT_DIR/packages"
+
+# Iterate over each package folder
+for PACKAGE in "$PACKAGES_DIR"/*; do
+  # Check if it's a directory
+  if [ -d "$PACKAGE" ]; then
+    echo "Analyzing package in: $PACKAGE"
+
+    # Change into the package directory
+    cd "$PACKAGE" || exit
+
+    # Run the pana command
+    flutter pub global run pana --no-warning --exit-code-threshold 0
+
+    # Return to the root directory
+    cd "$ROOT_DIR" || exit
+  fi
+done

melos.yaml

@@ -3,3 +3,29 @@ name: drift_sqlite_async_monorepo
 packages:
   - demos/**
   - packages/**
+
+scripts:
+  format:
+    description: Format Dart code.
+    run: dart format .
+
+  format:check:packages:
+    description: Check formatting of Dart code in packages.
+    run: dart format --output none --set-exit-if-changed packages
+
+  analyze:packages:
+    description: Analyze Dart code in packages.
+    run: dart analyze packages --fatal-infos
+
+  test:
+    description: Run tests in a specific package.
+    run: dart test
+    exec:
+      concurrency: 1
+    packageFilters:
+      dirExists:
+        - test
+    # This tells Melos tests to ignore env variables passed to tests from `melos run test`
+    # as they could change the behaviour of how tests filter packages.
+    env:
+      MELOS_TEST: true

packages/drift_sqlite_async/lib/drift_sqlite_async.dart

@@ -1,3 +1,4 @@
 library drift_sqlite_async;
 
+export './src/connection.dart';
 export './src/executor.dart';

packages/drift_sqlite_async/lib/src/connection.dart

@@ -0,0 +1,34 @@
+import 'dart:async';
+
+import 'package:drift/drift.dart';
+import 'package:drift_sqlite_async/src/executor.dart';
+import 'package:sqlite_async/sqlite_async.dart';
+
+/// Wraps a sqlite_async [SqliteConnection] as a Drift [DatabaseConnection].
+///
+/// The SqliteConnection must be instantiated before constructing this, and
+/// is not closed when [SqliteAsyncDriftConnection.close] is called.
+///
+/// This class handles delegating Drift's queries and transactions to the
+/// [SqliteConnection], and passes on any table updates from the
+/// [SqliteConnection] to Drift.
+class SqliteAsyncDriftConnection extends DatabaseConnection {
+  late StreamSubscription _updateSubscription;
+
+  SqliteAsyncDriftConnection(SqliteConnection db)
+      : super(SqliteAsyncQueryExecutor(db)) {
+    _updateSubscription = (db as SqliteQueries).updates!.listen((event) {
+      var setUpdates = <TableUpdate>{};
+      for (var tableName in event.tables) {
+        setUpdates.add(TableUpdate(tableName));
+      }
+      super.streamQueries.handleTableUpdates(setUpdates);
+    });
+  }
+
+  @override
+  Future<void> close() async {
+    await _updateSubscription.cancel();
+    await super.close();
+  }
+}