renames

src/analytics/enrich_rms.rs

@@ -15,7 +15,7 @@ fn calculate_rms(data: &[f64]) -> f64 {
 }
 
 /// enrich swap struct with RMS data
-pub fn process_swaps(swaps: &mut [ExchangeOrder]) {
+pub fn include_rms_stats(swaps: &mut [ExchangeOrder]) {
     swaps.sort_by_key(|swap| swap.filled_at);
 
     let mut window_1hour: VecDeque<ExchangeOrder> = VecDeque::new();
@@ -249,7 +249,7 @@ fn test_rms_pipeline() {
         },
     ];
 
-    process_swaps(&mut swaps);
+    include_rms_stats(&mut swaps);
 
     let s0 = swaps.first().unwrap();
     assert!(s0.rms_hour == 0.0);

src/load_exchange_orders.rs

@@ -85,7 +85,7 @@ pub async fn impl_batch_tx_insert(pool: &Graph, batch_txs: &[ExchangeOrder]) ->
 pub async fn load_from_json(path: &Path, pool: &Graph, batch_size: usize) -> Result<(u64, u64)> {
     let mut orders = extract_exchange_orders::read_orders_from_file(path)?;
     // add RMS stats to each order
-    enrich_rms::process_swaps(&mut orders);
+    enrich_rms::include_rms_stats(&mut orders);
     // find likely shill bids
     enrich_rms::process_sell_order_shill(&mut orders);
     enrich_rms::process_buy_order_shill(&mut orders);

tests/test_enrich_exchange.rs

@@ -28,7 +28,7 @@ fn test_enrich_rms() {
     let mut orders = extract_exchange_orders::read_orders_from_file(buf).unwrap();
     assert!(orders.len() == 25450);
 
-    enrich_rms::process_swaps(&mut orders);
+    enrich_rms::include_rms_stats(&mut orders);
 
     let count_above_100_pct = orders.iter().fold(0, |mut acc, el| {
         if el.price_vs_rms_24hour > 2.0 {