fix build

OxfordAbstracts · Oct 22, 2024 · a37aeef · a37aeef
1 parent 64cda3e
commit a37aeef
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/metrics/src/logprocessor.rs b/metrics/src/logprocessor.rs
@@ -189,7 +189,7 @@ async fn handle_websocket_log(log: &BaseLog, metric_obj: &Telemetry) {
 }
 
 pub async fn log_processor(logline: &String, metric_obj: &Telemetry, tracer: &trace::Tracer) {
-    println!("{}", logline); // TODO: strip blank lines?
+    println!("{}", logline);
     metric_obj.LOG_LINES_COUNTER_TOTAL.inc();
     let log_result = from_str::<BaseLog>(logline);
     match log_result {
@@ -206,11 +206,11 @@ pub async fn log_processor(logline: &String, metric_obj: &Telemetry, tracer: &tr
                 }
                 _ => {}
             };
-            
+
             //Send log to opentel:
             // tracer.in_span("hasura-log", |cx| {
             //     let span = cx.span();
-            //     span.add_event(                            
+            //     span.add_event(
             //         logline.clone(),
             //         vec![],
             //     );

diff --git a/metrics/src/logreceiver.rs b/metrics/src/logreceiver.rs
@@ -17,7 +17,7 @@ async fn receive_log(
     rt::spawn(async move {
         while let Some(msg) = stream.next().await {
             if let Ok(Message::Text(text)) = msg {
-                let _ = logprocessor::log_processor(&text.to_string().trim(), &metric_obj, &tracer).await;
+                let _ = logprocessor::log_processor(&text.trim().to_string(), &metric_obj, &tracer).await;
                 session.text("{\"success\": true}").await.unwrap();
             }
             // TODO: log if failed