fix: remove logs

Author: EvolveArt

Diff for: pragma-ingestor/src/db.rs

@@ -3,8 +3,7 @@ use pragma_entities::{
     Entry, FundingRate, FutureEntry, InfraError, NewEntry, NewFundingRate, NewFutureEntry,
 };
 use tokio::sync::mpsc;
-use tokio::time::{interval, Duration, Instant};
-use tracing::{debug, info};
+use tracing::debug;
 
 #[tracing::instrument(skip(pool, rx))]
 pub async fn process_spot_entries(pool: Pool, mut rx: mpsc::Receiver<NewEntry>) {
@@ -40,7 +39,6 @@ pub async fn process_spot_entries(pool: Pool, mut rx: mpsc::Receiver<NewEntry>)
 #[tracing::instrument(skip(pool, rx))]
 pub async fn process_future_entries(pool: Pool, mut rx: mpsc::Receiver<NewFutureEntry>) {
     const BUFFER_CAPACITY: usize = 100;
-    const FLUSH_TIMEOUT: Duration = Duration::from_millis(50);
 
     let mut buffer = Vec::with_capacity(BUFFER_CAPACITY);
 
@@ -102,25 +100,13 @@ pub async fn process_funding_rate_entries(pool: Pool, mut rx: mpsc::Receiver<New
 
 #[tracing::instrument(skip_all, fields(num_entries = new_entries.len()))]
 async fn insert_spot_entries(pool: &Pool, new_entries: Vec<NewEntry>) -> Result<(), InfraError> {
-    let start = Instant::now();
-    let len = new_entries.len();
     let conn = pool.get().await.map_err(InfraError::DbPoolError)?;
     let entries = conn
         .interact(move |conn| Entry::create_many(conn, new_entries))
         .await
         .map_err(InfraError::DbInteractionError)?
         .map_err(InfraError::DbResultError)?;
 
-    let duration = start.elapsed();
-    info!("insert_spot_entries took {:?} for {} entries", duration, len);
-    
-    for entry in &entries {
-        debug!(
-            "new spot entry created {} - {}({}) - {}",
-            entry.publisher, entry.pair_id, entry.price, entry.source
-        );
-    }
-
     Ok(())
 }
 
@@ -151,17 +137,11 @@ async fn insert_future_entries(
             .count()
     );
 
-    let entries = conn
+    conn
         .interact(move |conn| FutureEntry::create_many(conn, new_entries))
         .await
         .map_err(InfraError::DbInteractionError)?
         .map_err(InfraError::DbResultError)?;
-    for entry in &entries {
-        debug!(
-            "new perp entry created {} - {}({}) - {}",
-            entry.publisher, entry.pair_id, entry.price, entry.source
-        );
-    }
     Ok(())
 }