From d186099afede52316789502ee9bb8b14db5dd914 Mon Sep 17 00:00:00 2001 From: Alina Hagan Date: Sat, 10 Aug 2024 00:10:15 +0100 Subject: Some tuning, cleaned up extraneous error! macros, some INFO's downgraded to DEBUG's --- src/error.rs | 2 -- src/ls_client.rs | 12 ++++++------ 2 files changed, 6 insertions(+), 8 deletions(-) diff --git a/src/error.rs b/src/error.rs index fdec096..0888818 100644 --- a/src/error.rs +++ b/src/error.rs @@ -7,7 +7,6 @@ pub struct IllegalArgumentException(String); impl IllegalArgumentException { pub fn new(msg: &str) -> IllegalArgumentException { - error!(msg); IllegalArgumentException(msg.to_string()) } } @@ -31,7 +30,6 @@ pub struct IllegalStateException { impl IllegalStateException { pub fn new(msg: &str) -> IllegalStateException { - error!(msg); IllegalStateException { details: msg.to_string(), } diff --git a/src/ls_client.rs b/src/ls_client.rs index a496743..f4f72db 100644 --- a/src/ls_client.rs +++ b/src/ls_client.rs @@ -355,8 +355,8 @@ impl LightstreamerClient { // "conok" => { if let Some(session_id) = submessage_fields.get(1).as_deref() { - self.make_log( Level::INFO, &format!("Session creation confirmed by server: {}", clean_text) ); - self.make_log( Level::INFO, &format!("Session created with ID: {:?}", session_id) ); + self.make_log( Level::DEBUG, &format!("Session creation confirmed by server: {}", clean_text) ); + self.make_log( Level::DEBUG, &format!("Session created with ID: {:?}", session_id) ); // // Subscribe to the desired items. // @@ -443,10 +443,10 @@ impl LightstreamerClient { // Don't do anything with these notifications for now. }, "probe" => { - self.make_log( Level::INFO, &format!("Received probe message from server: {}", clean_text ) ); + self.make_log( Level::DEBUG, &format!("Received probe message from server: {}", clean_text ) ); }, "reqok" => { - self.make_log( Level::INFO, &format!("Received reqok message from server: '{}'", clean_text ) ); + self.make_log( Level::DEBUG, &format!("Received reqok message from server: '{}'", clean_text ) ); }, // // Subscription confirmation from server. @@ -714,7 +714,7 @@ impl LightstreamerClient { write_stream .send(Message::Text(format!("create_session\r\n{}\n", encoded_params))) .await?; - self.make_log( Level::INFO, &format!("Sent create session request: '{}'", encoded_params) ); + self.make_log( Level::DEBUG, &format!("Sent create session request: '{}'", encoded_params) ); }, unexpected_message => { return Err(Box::new(std::io::Error::new( @@ -744,7 +744,7 @@ impl LightstreamerClient { ))); }, None => { - self.make_log( Level::INFO, "No more messages from server" ); + self.make_log( Level::DEBUG, "No more messages from server" ); break; }, } -- cgit v1.2.3