db-ingest: Remove unused

OpenSource-Deadlock-Tools · Oct 11, 2024 · 43930bf · 43930bf
1 parent 27a7b10
commit 43930bf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 20 deletions.
diff --git a/db-ingest/src/main.rs b/db-ingest/src/main.rs
@@ -44,7 +44,7 @@ async fn main() {
                 });
             }
             Err(e) => {
-                println!("Error receiving message: {:?}", e);
+                error!("Error receiving message: {:?}", e);
                 continue;
             }
         }
@@ -54,18 +54,11 @@ async fn main() {
 async fn process_message(message: Delivery) {
     match try_process_message(&message).await {
         Ok(_) => {
-            debug!(
-                "Message processed successfully: {:?}",
-                String::from_utf8_lossy(&message.data)
-            );
+            debug!("Message processed successfully");
             message.ack(BasicAckOptions::default()).await.unwrap();
         }
         Err(e) => {
-            error!(
-                "Error processing message {:?} -> {:?}",
-                String::from_utf8_lossy(&message.data),
-                e
-            );
+            error!("Error processing message: {:?}", e);
             message.reject(BasicRejectOptions::default()).await.unwrap();
         }
     }

diff --git a/db-ingest/src/parsers/active_matches_json_lines_parser.rs b/db-ingest/src/parsers/active_matches_json_lines_parser.rs
@@ -5,7 +5,6 @@ use crate::models::file_data::FileData;
 use crate::models::file_type::FileType;
 use crate::models::parse_result::ParseResult;
 use crate::parsers::parser::Parser;
-use log::{debug, warn};
 
 #[derive(Default, Debug)]
 pub struct ActiveMatchesJsonLinesParser;
@@ -17,15 +16,6 @@ impl Parser<Vec<Vec<ActiveMatch>>> for ActiveMatchesJsonLinesParser {
         data: &[u8],
     ) -> Result<ParseResult<Vec<Vec<ActiveMatch>>>, ParseError> {
         let data_str = String::from_utf8_lossy(data);
-        debug!("Data: {}", data_str);
-        for line in data_str.lines() {
-            match serde_json::from_str::<Vec<ActiveMatch>>(line) {
-                Ok(_) => {}
-                Err(e) => {
-                    warn!("Error parsing line: {}", e);
-                }
-            }
-        }
         let parsed_data = data_str
             .lines()
             .filter_map(|l| serde_json::from_str::<Vec<ActiveMatch>>(l).ok())