soaos/lightstreamer-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Some tuning, cleaned up extraneous error! macros, some INFO's downgraded to DEBUG's

Browse Source
This commit is contained in:
Alina Hagan 2024-08-10 00:10:15 +01:00
parent 4a1625a311
commit d186099afe
2 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/error.rs
View File

@ -7,7 +7,6 @@ pub struct IllegalArgumentException(String);
impl IllegalArgumentException { impl IllegalArgumentException {
pub fn new(msg: &str) -> IllegalArgumentException { pub fn new(msg: &str) -> IllegalArgumentException {
error!(msg);
IllegalArgumentException(msg.to_string()) IllegalArgumentException(msg.to_string())
} }
} }
@ -31,7 +30,6 @@ pub struct IllegalStateException {
impl IllegalStateException { impl IllegalStateException {
pub fn new(msg: &str) -> IllegalStateException { pub fn new(msg: &str) -> IllegalStateException {
error!(msg);
IllegalStateException { IllegalStateException {
details: msg.to_string(), details: msg.to_string(),
} }

12
src/ls_client.rs
View File

@ -355,8 +355,8 @@ impl LightstreamerClient {
// //
"conok" => { "conok" => {
if let Some(session_id) = submessage_fields.get(1).as_deref() { 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::DEBUG, &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 created with ID: {:?}", session_id) );
// //
// Subscribe to the desired items. // Subscribe to the desired items.
// //
@ -443,10 +443,10 @@ impl LightstreamerClient {
// Don't do anything with these notifications for now. // Don't do anything with these notifications for now.
}, },
"probe" => { "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" => { "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. // Subscription confirmation from server.
@ -714,7 +714,7 @@ impl LightstreamerClient {
write_stream write_stream
.send(Message::Text(format!("create_session\r\n{}\n", encoded_params))) .send(Message::Text(format!("create_session\r\n{}\n", encoded_params)))
.await?; .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 => { unexpected_message => {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::new(
@ -744,7 +744,7 @@ impl LightstreamerClient {
))); )));
}, },
None => { None => {
self.make_log( Level::INFO, "No more messages from server" ); self.make_log( Level::DEBUG, "No more messages from server" );
break; break;
}, },
} }