names

src/load_exchange_orders.rs

@@ -10,7 +10,7 @@ use crate::{
     schema_exchange_orders::ExchangeOrder,
 };
 
-pub async fn swap_batch(
+pub async fn exchange_txs_batch(
     txs: &[ExchangeOrder],
     pool: &Graph,
     batch_size: usize,
@@ -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 ledger relations inserted: {}", ledger_inserts);
+    info!("exchange UserLedger relations inserted: {}", ledger_inserts);
 
-    swap_batch(&orders, pool, batch_size).await
+    exchange_txs_batch(&orders, pool, batch_size).await
 }

tests/test_analytics.rs

@@ -30,7 +30,7 @@ async fn test_rms_single() -> Result<()> {
     assert!(orders.len() == 25450);
 
     // load 1000 orders
-    load_exchange_orders::swap_batch(&orders[..1000], &graph, 1000).await?;
+    load_exchange_orders::exchange_txs_batch(&orders[..1000], &graph, 1000).await?;
 
     // get just one analytics result, never more than one (but can be empty)
     let list = analytics::exchange_stats::query_rms_analytics_chunk(&graph, 900, 1, false).await?;
@@ -60,7 +60,7 @@ async fn test_rms_single_persist() -> Result<()> {
     assert!(orders.len() == 25450);
 
     // load 1000 orders
-    load_exchange_orders::swap_batch(&orders[..1000], &graph, 1000).await?;
+    load_exchange_orders::exchange_txs_batch(&orders[..1000], &graph, 1000).await?;
 
     // get just one analytics result, never more than one (but can be empty)
     let list = analytics::exchange_stats::query_rms_analytics_chunk(&graph, 900, 1, true).await?;
@@ -90,7 +90,7 @@ async fn test_rms_batch() -> Result<()> {
     assert!(orders.len() == 25450);
 
     // load 1000 orders
-    load_exchange_orders::swap_batch(&orders[..1000], &graph, 1000).await?;
+    load_exchange_orders::exchange_txs_batch(&orders[..1000], &graph, 1000).await?;
 
     let list = analytics::exchange_stats::query_rms_analytics_concurrent(&graph, None, None, false)
         .await?;

tests/test_enrich_exchange.rs

@@ -141,7 +141,7 @@ async fn e2e_swap_data() -> Result<()> {
     assert!(orders.len() == 25450);
 
     // load 1000 orders
-    load_exchange_orders::swap_batch(&orders[..1000], &graph, 1000).await?;
+    load_exchange_orders::exchange_txs_batch(&orders[..1000], &graph, 1000).await?;
 
     // now check data was loaded
     let mut result = graph