Skip to content

Commit

Permalink
info prints
Browse files Browse the repository at this point in the history
  • Loading branch information
0o-de-lally committed Dec 14, 2024
1 parent 03df6b8 commit 25c1226
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/load_exchange_orders.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
6 changes: 5 additions & 1 deletion src/warehouse_cli.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down

0 comments on commit 25c1226

Please sign in to comment.