chore: with further debugging

.gitignore

@@ -10,7 +10,7 @@ coverage
 .env
 #### node ####
 node_modules
-*.node
+# *.node
 .yarn/
 dist/
 

scylla_operations/src/task.rs

@@ -23,7 +23,7 @@ impl ScyllaOperations {
     }
 }
 #[async_trait]
-pub trait Persistence
+pub trait Persistence: std::fmt::Debug
 where
     Self::PersistenceError: From<ScyllaOperationsError>,
 {

scylla_pg_client/package.json

@@ -14,7 +14,7 @@
   "email": "[email protected]",
   "license": "MIT",
   "dependencies": {
-    "scylla_pg_js": "0.1.24"
+    "scylla_pg_js": "file:../scylla_pg_js"
   },
   "devDependencies": {
     "@ava/typescript": "^4.1.0",
@@ -37,4 +37,4 @@
     "build": "tsc",
     "test": "ava"
   }
-}
+}

scylla_pg_js/src/lib.rs

@@ -40,6 +40,7 @@ impl ScyllaManager {
     /// Convert rust error into `napi::Error`
     #[napi]
     pub fn init_pg_config(js_db_config: JsDbConfig) -> napi::Result<ScyllaManager> {
+        println!(" Inside init_pg_config......");
         let port = validate_port(js_db_config.pg_port)?;
         let pg_pool_size = validate_pool_size(js_db_config.pg_pool_size)?;
         let pg_config = PGConfig {
@@ -50,8 +51,10 @@ impl ScyllaManager {
             pg_database: js_db_config.pg_database,
             pg_pool_size,
         };
+        let pg_manager = PgManager::from_config(&pg_config);
+        println!("pg_manager....\n\n {pg_manager:?}",);
         Ok(Self {
-            pg_manager: PgManager::from_config(&pg_config).map_err(map_error_to_napi_error)?,
+            pg_manager: pg_manager.map_err(map_error_to_napi_error)?,
         })
     }
     /// # Errors

scylla_pg_lib/src/adapter.rs

@@ -51,6 +51,7 @@ const DELETE_BATCH_TASK_SQL: &str = "
     DELETE from task where data ->> 'status' in ('completed', 'cancelled', 'aborted') AND data ->> 'updated' < $1
 ";
 
+#[derive(Debug)]
 pub struct PgAdapter {
     pub pool: Pool,
 }

scylla_pg_lib/src/manager.rs

@@ -1,11 +1,15 @@
 //! PG Manager used by external crates to deal with Database operations. `PGAdapter` is not accessible without `PGManager`
+
+use std::fmt::Debug;
+
 use crate::adapter::PgAdapter;
 use crate::error::PgAdapterError;
 use scylla_models::{AddTaskModel, GetTaskModel, Task, TaskError, TaskStatus, UpdateOperation, UpdateTaskModel};
 use scylla_operations::task::{Persistence, ScyllaOperations};
 use scylla_pg_core::config::PGConfig;
 use scylla_pg_core::connection::get_pool;
 
+#[derive(Debug)]
 pub struct PgManager {
     pg_adapter: Box<dyn Persistence<PersistenceError = PgAdapterError> + Send + Sync>,
 }

scylla_pg_lib/src/manager/tests.rs

@@ -8,6 +8,7 @@ use super::PgManager;
 use async_trait::async_trait;
 use scylla_models::*;
 
+#[derive(Debug)]
 struct MockPgAdapter {
     insert: fn(Task) -> Result<Task, PgAdapterError>,
     update: fn(Task) -> Result<Task, PgAdapterError>,