cleanup

Author: davidmartos96

.DS_Store

@@ -50,11 +50,6 @@ class SyncSqliteConnection extends SqliteConnection with SqliteQueries {
   Future<bool> getAutoCommit() async {
     return db.autocommit;
   }
-
-  @override
-  int getNumConnections() {
-    return -1;
-  }
 }
 
 class SyncReadContext implements SqliteReadContext {

packages/sqlite_async/lib/src/common/connection/sync_sqlite_connection.dart

@@ -63,11 +63,6 @@ final class SingleConnectionDatabase
     return [connection];
   }
 
-  @override
-  int getNumConnections() {
-    return 1;
-  }
-
   @override
   int get numConnections => 1;
 }

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

@@ -68,11 +68,6 @@ class SqliteDatabaseImpl
   @override
   int get numConnections => throw UnimplementedError();
 
-  @override
-  int getNumConnections() {
-    throw UnimplementedError();
-  }
-
   @override
   List<SqliteConnection> getAllConnections() {
     throw UnimplementedError();

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

@@ -243,8 +243,8 @@ class SqliteConnectionPool with SqliteQueries implements SqliteConnection {
   }
 
   int getNumConnections() {
-    print(
-        "TESTING READ: ${_allReadConnections.length} WRITE: ${_writeConnection == null ? 0 : 1}");
+    // print(
+    //     "TESTING READ: ${_allReadConnections.length} WRITE: ${_writeConnection == null ? 0 : 1}");
     return _allReadConnections.length + (_writeConnection == null ? 0 : 1);
   }
 }

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

@@ -95,7 +95,7 @@ class SqliteConnectionImpl
 
   @override
   Future<void> close() async {
-    print("Closing native sqlite Connection ${StackTrace.current}");
+    // print("Closing native sqlite Connection ${StackTrace.current}");
     eventsPort?.close();
     await _connectionMutex.lock(() async {
       if (readOnly) {
@@ -159,11 +159,6 @@ class SqliteConnectionImpl
       });
     }, timeout: lockTimeout);
   }
-
-  @override
-  int getNumConnections() {
-    return -1;
-  }
 }
 
 int _nextCtxId = 1;

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

@@ -40,9 +40,6 @@ class SqliteDatabaseImpl
   late final SqliteConnectionImpl _internalConnection;
   late final SqliteConnectionPool _pool;
 
-  @override
-  int get numConnections => _pool.getNumConnections();
-
   final StreamController<UpdateNotification> updatesController =
       StreamController.broadcast();
 
@@ -176,9 +173,7 @@ class SqliteDatabaseImpl
   }
 
   @override
-  int getNumConnections() {
-    return -1;
-  }
+  int get numConnections => _pool.getNumConnections();
 
   @override
   List<SqliteConnection> getAllConnections() {

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

@@ -157,8 +157,6 @@ abstract class SqliteConnection extends SqliteWriteContext {
   /// Queries and watch calls can potentially use outdated schema information after a schema update.
   Future<void> refreshSchema();
 
-  int getNumConnections();
-
   /// Returns true if the connection is closed
   @override
   bool get closed;

packages/sqlite_async/lib/src/sqlite_connection.dart

@@ -170,12 +170,8 @@ class WebDatabase
     return _database.fileSystem.flush();
   }
   @override
-  int get numConnections => 0;
+  int get numConnections => throw UnimplementedError();
 
-  @override
-  int getNumConnections() {
-    return -1;
-  }
 
   @override
   List<SqliteConnection> getAllConnections() {

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

@@ -181,16 +181,11 @@ class SqliteDatabaseImpl
     return await _connection.exposeEndpoint();
   }
   @override
-  int get numConnections => 0;
-
-  @override
-  int getNumConnections() {
-    return -1;
-  }
+  int get numConnections => 1;
 
   @override
   List<SqliteConnection> getAllConnections() {
-    throw UnimplementedError();
+    return [_connection];
   }