From 25c12261c0564cd7f6ed62ff7480096808c396e4 Mon Sep 17 00:00:00 2001
From: 0o-de-lally <1364012+0o-de-lally@users.noreply.github.com>
Date: Fri, 13 Dec 2024 19:50:52 -0500
Subject: [PATCH] info prints

---
 src/load_exchange_orders.rs | 2 +-
 src/warehouse_cli.rs        | 6 +++++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/load_exchange_orders.rs b/src/load_exchange_orders.rs
index c0d0452..e17045d 100644
--- a/src/load_exchange_orders.rs
+++ b/src/load_exchange_orders.rs
@@ -99,7 +99,7 @@ pub async fn load_from_json(path: &Path, pool: &Graph, batch_size: usize) -> Res
     let mut balances = BalanceTracker::new();
     balances.replay_transactions(&mut orders)?;
     let ledger_inserts = balances.submit_ledger(pool).await?;
-    info!("exchange UserLedger relations inserted: {}", ledger_inserts);
+    info!("exchange UserLedger state inserted: {}", ledger_inserts);
 
     exchange_txs_batch(&orders, pool, batch_size).await
 }
diff --git a/src/warehouse_cli.rs b/src/warehouse_cli.rs
index 14cce96..0d75e7f 100644
--- a/src/warehouse_cli.rs
+++ b/src/warehouse_cli.rs
@@ -179,12 +179,16 @@ impl WarehouseCli {
                 let pool = try_db_connection_pool(self).await?;
                 neo4j_init::maybe_create_indexes(&pool).await?;
 
-                load_exchange_orders::load_from_json(
+                let (merged, ignored) = load_exchange_orders::load_from_json(
                     swap_record_json,
                     &pool,
                     batch_size.unwrap_or(250),
                 )
                 .await?;
+                info!(
+                    "SUCCESS: exchange transactions merged: {}, ignored: {}",
+                    merged, ignored
+                );
             }
             Sub::EnrichExchangeOnramp { onboarding_json } => {
                 info!("exchange onramp");