Fix tests

Author: simolus3

packages/sqlite_async/lib/src/impl/context.dart

@@ -139,18 +139,23 @@ final class ScopedWriteContext extends ScopedReadContext
     final (begin, commit, rollback) = _beginCommitRollback(transactionDepth);
     ScopedWriteContext? inner;
 
+    final innerContext = transactionDepth == 0
+        ? _context.interceptOutermostTransaction()
+        : _context;
+
     try {
       _isLocked = true;
 
       await _context.execute(begin, const []);
-      inner =
-          ScopedWriteContext(_context, transactionDepth: transactionDepth + 1);
+
+      inner = ScopedWriteContext(innerContext,
+          transactionDepth: transactionDepth + 1);
       final result = await callback(inner);
-      await _context.execute(commit, const []);
+      await innerContext.execute(commit, const []);
       return result;
     } catch (e) {
       try {
-        await _context.execute(rollback, const []);
+        await innerContext.execute(rollback, const []);
       } catch (e) {
         // In rare cases, a ROLLBACK may fail.
         // Safe to ignore.

packages/sqlite_async/lib/src/native/database/native_sqlite_connection_impl.dart

@@ -138,7 +138,7 @@ class SqliteConnectionImpl
     return _connectionMutex.lock(() async {
       final ctx = _context();
       try {
-        return ScopedReadContext.assumeReadLock(ctx, callback);
+        return await ScopedReadContext.assumeReadLock(ctx, callback);
       } finally {
         await ctx.close();
       }
@@ -161,7 +161,7 @@ class SqliteConnectionImpl
       return await _writeMutex.lock(() async {
         final ctx = _context();
         try {
-          return ScopedWriteContext.assumeWriteLock(ctx, callback);
+          return await ScopedWriteContext.assumeWriteLock(ctx, callback);
         } finally {
           await ctx.close();
         }

packages/sqlite_async/lib/src/web/database.dart

@@ -94,7 +94,7 @@ class WebDatabase
   Future<T> readLock<T>(Future<T> Function(SqliteReadContext tx) callback,
       {Duration? lockTimeout, String? debugContext}) async {
     if (_mutex case var mutex?) {
-      return await mutex.lock(timeout: lockTimeout, () async {
+      return await mutex.lock(timeout: lockTimeout, () {
         return ScopedReadContext.assumeReadLock(
             _UnscopedContext(this), callback);
       });
@@ -104,7 +104,7 @@ class WebDatabase
           CustomDatabaseMessage(CustomDatabaseMessageKind.requestSharedLock));
 
       try {
-        return ScopedReadContext.assumeReadLock(
+        return await ScopedReadContext.assumeReadLock(
             _UnscopedContext(this), callback);
       } finally {
         await _database.customRequest(
@@ -124,7 +124,11 @@ class WebDatabase
       bool? flush}) {
     return writeLock((writeContext) {
       return ScopedWriteContext.assumeWriteLock(
-          _UnscopedContext(this), callback);
+        _UnscopedContext(this),
+        (ctx) async {
+          return await ctx.writeTransaction(callback);
+        },
+      );
     },
         debugContext: 'writeTransaction()',
         lockTimeout: lockTimeout,

packages/sqlite_async/test/basic_test.dart

@@ -122,7 +122,7 @@ void main() {
             ['Test Data']);
         expect(rs.rows[0], equals(['Test Data']));
       });
-      expect(await savedTx!.getAutoCommit(), equals(true));
+      expect(await db.getAutoCommit(), equals(true));
       expect(savedTx!.closed, equals(true));
     });