chore: Add logging to Replicator JS

kindredgroup · Sep 13, 2023 · 7de322d · 7de322d
1 parent 11f1e03
commit 7de322d
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/cohort_banking_replicator_js/src/cfg/config-kafka.ts b/cohort_banking_replicator_js/src/cfg/config-kafka.ts
@@ -3,8 +3,8 @@ import { JsKafkaConfig } from "cohort_sdk_js"
 const kafkaConfig: JsKafkaConfig = {
     brokers: ["127.0.0.1:9092"],
     topic: "dev.ksp.certification",
-    clientId: "cohort-replicator-js3",
-    groupId: "cohort-replicator-js3",
+    clientId: "cohort-replicator-js",
+    groupId: "cohort-replicator-js",
     producerSendTimeoutMs: 10,
     logLevel: "info",
     producerConfigOverrides: {},

diff --git a/packages/cohort_sdk_js/Cargo.toml b/packages/cohort_sdk_js/Cargo.toml
@@ -21,16 +21,13 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 uuid = { version = "1", features = ["serde"] }
 chrono = { version = "0.4.19", features = ["serde"] }
-# Logging
-log = { version = "0.4", features = [
-    "kv_unstable",
-    "std",
-    "kv_unstable_serde",
-] }
 
 # db migrations
 #refinery = {version="0.8", features=["tokio-postgres"]}
 # crate depencies
+env_logger = { workspace = true }
+log = { workspace = true }
+
 cohort_sdk = { path = "../cohort_sdk" }
 tokio = { workspace = true, features = ["full"] }
 talos_cohort_replicator = { path = "../../packages/talos_cohort_replicator" }

diff --git a/packages/cohort_sdk_js/src/installer/mod.rs b/packages/cohort_sdk_js/src/installer/mod.rs
@@ -84,6 +84,8 @@ impl Replicator {
         config: JsReplicatorConfig,
         // statemap_installer_callback: ThreadsafeFunction<JsStatemapAndSnapshot>,
     ) -> napi::Result<Replicator> {
+        env_logger::builder().format_timestamp_millis().init();
+
         Ok(Replicator {
             kafka_config,
             config,