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/index.js

@@ -20,7 +20,7 @@ class Scylla {
     static async initiate(dbConfig) {
         let scyllaManager = await ScyllaManager.initPgConfig(dbConfig);
         console.log("[SCYLA] dbConfig...", dbConfig);
-        console.log("[SCYLA] Scylla manager...", await scyllaManager.getTasks({ limit: 20 }));
+        // console.log("[SCYLA] Scylla manager...", await scyllaManager.getTasks({ limit: 20 }))
         let sc = new Scylla(scyllaManager);
         return sc;
     }

scylla_pg_client/index.ts

@@ -73,7 +73,7 @@ class Scylla {
   public static async initiate(dbConfig: DbConfig): Promise<Scylla> {
     let scyllaManager: ScyllaManager = await ScyllaManager.initPgConfig(dbConfig as JsDbConfig)
     console.log("[SCYLA] dbConfig...", dbConfig)
-    console.log("[SCYLA] Scylla manager...", await scyllaManager.getTasks({ limit: 20 }))
+    // console.log("[SCYLA] Scylla manager...", await scyllaManager.getTasks({ limit: 20 }))
     let sc = new Scylla(scyllaManager);
     return sc;
   }

scylla_pg_client/package.json

@@ -14,7 +14,7 @@
   "email": "asharmaanil@gmail.com",
   "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

@@ -50,8 +50,12 @@ impl ScyllaManager {
             pg_database: js_db_config.pg_database,
             pg_pool_size,
         };
+        println!(" Inside init_pg_config...... {pg_config:?}");
+        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>,