Publish a simple encrypted version for moor

extras/encryption/.gitignore

@@ -0,0 +1,11 @@
+# Files and directories created by pub
+.dart_tool/
+.packages
+# Remove the following pattern if you wish to check in your lock file
+pubspec.lock
+
+# Conventional directory for build outputs
+build/
+
+# Directory created by dartdoc
+doc/api/

extras/encryption/README.md

@@ -0,0 +1,19 @@
+Moor version that uses the
+[sqflite_sqlcipher](https://github.com/davidmartos96/sqflite_sqlcipher) instead of
+sqflite.
+
+## Using this
+For general notes on using moor, see [this guide](https://moor.simonbinder.eu/getting-started/).
+
+Instead of using `moor_flutter`, use this:
+```yaml
+dependencies:
+  moor: "$latest version"
+  encrypted_moor:
+   git:
+    url: https://github.com/simolus3/moor.git
+    path: extras/encryption 
+```
+
+Then, instead using a `FlutterQueryExecutor`, 
+`import 'package:encrypted_moor/encrypted_moor.dart'` and use the `EncryptedExecutor`.

extras/encryption/lib/encrypted_moor.dart

@@ -0,0 +1,131 @@
+/// Encryption support for moor, built with the [sqflite_sqlcipher](https://github.com/davidmartos96/sqflite_sqlcipher)
+/// library.
+library encrypted_moor;
+
+import 'dart:async';
+import 'package:meta/meta.dart';
+import 'package:path/path.dart';
+import 'package:moor/moor.dart';
+import 'package:moor/backends.dart';
+import 'package:sqflite/sqflite.dart' as s;
+
+class _SqfliteDelegate extends DatabaseDelegate with _SqfliteExecutor {
+  int _loadedSchemaVersion;
+  @override
+  s.Database db;
+
+  final bool inDbFolder;
+  final String path;
+  final String password;
+
+  _SqfliteDelegate(this.inDbFolder, this.path, this.password);
+
+  @override
+  DbVersionDelegate get versionDelegate {
+    return OnOpenVersionDelegate(() => Future.value(_loadedSchemaVersion));
+  }
+
+  @override
+  TransactionDelegate get transactionDelegate =>
+      _SqfliteTransactionDelegate(this);
+
+  @override
+  Future<bool> get isOpen => Future.value(db != null);
+
+  @override
+  Future<void> open([GeneratedDatabase db]) async {
+    String resolvedPath;
+    if (inDbFolder) {
+      resolvedPath = join(await s.getDatabasesPath(), path);
+    } else {
+      resolvedPath = path;
+    }
+
+    // default value when no migration happened
+    _loadedSchemaVersion = db.schemaVersion;
+
+    this.db = await s.openDatabase(
+      resolvedPath,
+      version: db.schemaVersion,
+      password: password,
+      onCreate: (db, version) {
+        _loadedSchemaVersion = 0;
+      },
+      onUpgrade: (db, from, to) {
+        _loadedSchemaVersion = from;
+      },
+    );
+  }
+}
+
+class _SqfliteTransactionDelegate extends SupportedTransactionDelegate {
+  final _SqfliteDelegate delegate;
+
+  _SqfliteTransactionDelegate(this.delegate);
+
+  @override
+  void startTransaction(Future<void> Function(QueryDelegate) run) {
+    delegate.db.transaction((transaction) async {
+      final executor = _SqfliteTransactionExecutor(transaction);
+      await run(executor);
+    });
+  }
+}
+
+class _SqfliteTransactionExecutor extends QueryDelegate with _SqfliteExecutor {
+  @override
+  final s.DatabaseExecutor db;
+
+  _SqfliteTransactionExecutor(this.db);
+}
+
+mixin _SqfliteExecutor on QueryDelegate {
+  s.DatabaseExecutor get db;
+
+  @override
+  Future<void> runBatched(List<BatchedStatement> statements) async {
+    final batch = db.batch();
+
+    for (var statement in statements) {
+      for (var boundVariables in statement.variables) {
+        batch.execute(statement.sql, boundVariables);
+      }
+    }
+
+    await batch.commit(noResult: true);
+  }
+
+  @override
+  Future<void> runCustom(String statement, List args) {
+    return db.execute(statement);
+  }
+
+  @override
+  Future<int> runInsert(String statement, List args) {
+    return db.rawInsert(statement, args);
+  }
+
+  @override
+  Future<QueryResult> runSelect(String statement, List args) async {
+    final result = await db.rawQuery(statement, args);
+    return QueryResult.fromRows(result);
+  }
+
+  @override
+  Future<int> runUpdate(String statement, List args) {
+    return db.rawUpdate(statement, args);
+  }
+}
+
+/// A query executor that uses sqflite_sqlcipher internally.
+class EncryptedExecutor extends DelegatedDatabase {
+  EncryptedExecutor(
+      {@required String path, @required String password, bool logStatements})
+      : super(_SqfliteDelegate(false, path, password),
+            logStatements: logStatements);
+
+  EncryptedExecutor.inDatabaseFolder(
+      {@required String path, @required String password, bool logStatements})
+      : super(_SqfliteDelegate(true, path, password),
+            logStatements: logStatements);
+}

extras/encryption/pubspec.yaml

@@ -0,0 +1,18 @@
+name: encrypted_moor
+description: Encryption support for moor, built with sqflite_sqlcipher
+version: 1.0.0
+author: Simon Binder <oss@simonbinder.eu>
+
+environment:
+  sdk: '>=2.4.0 <3.0.0'
+
+dependencies:
+  moor: ^1.6.0
+  sqflite:
+    git:
+      url: https://www.github.com/davidmartos96/sqflite_sqlcipher.git
+      path: sqflite
+
+dependency_overrides:
+  moor:
+    path: ../../moor

extras/mysql/pubspec.yaml

@@ -1,5 +1,7 @@
 name: moor_mysql
 description: MySQL support for moor
+version: 1.0.0
+author: Simon Binder <oss@simonbinder.eu>
 
 environment:
   sdk: '>=2.4.0 <3.0.0'