Fixed header defitinion.

Author: Chriztiaan

cpp/ConnectionPool.cpp

@@ -171,18 +171,15 @@ void ConnectionPool::closeAll() {
 std::future<void> ConnectionPool::refreshSchema() {
     std::vector<std::future<void>> futures;
 
-    // Collect the future from the write connection
     futures.push_back(writeConnection.refreshSchema());
 
-    // Collect the futures from the read connections
     for (unsigned int i = 0; i < maxReads; i++) {
         futures.push_back(readConnections[i]->refreshSchema());
     }
 
-    // Return a future that completes when all collected futures are done
     return std::async(std::launch::async, [futures = std::move(futures)]() mutable {
-        for (auto& fut : futures) {
-            fut.get(); // This will block until the future is ready and rethrow exceptions if any
+        for (auto& future : futures) {
+            future.get(); 
         }
     });
 }

cpp/ConnectionPool.h

@@ -130,7 +130,7 @@ class ConnectionPool {
   /**
    * Refreshes the schema for all connections.
    */
-  std::future<void> ConnectionPool::refreshSchema();
+  std::future<void> refreshSchema();
 
   /**
    * Attaches another database to all connections

cpp/ConnectionState.cpp

@@ -2,8 +2,6 @@
 #include "fileUtils.h"
 #include "sqlite3.h"
 
-
-
 const std::string EMPTY_LOCK_ID = "";
 
 SQLiteOPResult genericSqliteOpenDb(string const dbName, string const docPath,
@@ -65,7 +63,6 @@ std::future<void> ConnectionState::refreshSchema() {
     return future;
 }
 
-
 void ConnectionState::close() {
   waitFinished();
   // So that the thread can stop (if not already)

cpp/bindings.cpp

@@ -286,7 +286,6 @@ void osp::install(jsi::Runtime &rt,
     return {};
   });
 
-  
   auto refreshSchema = HOSTFN("refreshSchema", 1) {
     if (count == 0) {
         throw jsi::JSError(rt, "[react-native-quick-sqlite][refreshSchema] database name is required");
@@ -323,9 +322,7 @@ void osp::install(jsi::Runtime &rt,
             }).detach();
 
         } catch (const std::exception& exc) {
-            auto errorCtr = rt.global().getPropertyAsFunction(rt, "Error");
-            auto error = errorCtr.callAsConstructor(rt, jsi::String::createFromUtf8(rt, exc.what()));
-            reject->asObject(rt).asFunction(rt).call(rt, error);
+            invoker->invokeAsync([&rt, &exc] { jsi::JSError(rt, exc.what()); });
         }
 
         return {};

cpp/sqliteBridge.cpp

@@ -60,7 +60,6 @@ sqliteOpenDb(string const dbName, string const docPath,
   };
 }
 
-
 std::future<void> sqliteRefreshSchema(const std::string& dbName) {
     if (dbMap.count(dbName) == 0) {
         // Database not found, return a future that's already set
@@ -73,7 +72,6 @@ std::future<void> sqliteRefreshSchema(const std::string& dbName) {
     return connection->refreshSchema();
 }
 
-
 SQLiteOPResult sqliteCloseDb(string const dbName) {
   if (dbMap.count(dbName) == 0) {
     return generateNotOpenResult(dbName);