chore: update deps and add more logs (#59)

* chore: update deps and add more logs

* add misc

Author: yjhmelody

Cargo.lock

@@ -10,5 +10,5 @@ max_cap_per_subscription = 64
 [nodes.polkadot]
 url = "wss://rpc.polkadot.io"
 # kusama config
-[nodes.kusama]
-url = "wss://kusama-rpc.polkadot.io"
+#[nodes.kusama]
+#url = "wss://kusama-rpc.polkadot.io"

bin/config-template.toml

@@ -2,12 +2,15 @@ pub mod cmd;
 pub mod compression;
 pub mod config;
 pub mod message;
+mod misc;
 pub mod rpc_client;
 pub mod session;
 pub mod substrate;
 pub mod websocket;
+
 use anyhow::Result;
 use futures::StreamExt;
+pub use misc::*;
 use serde::{Deserialize, Serialize};
 use std::{sync::Arc, time::Duration};
 use tokio::sync::RwLock;
@@ -205,14 +208,16 @@ async fn handle_connection(connection: WsConnection) {
                     Message::Binary(_) => {}
 
                     Message::Close(_) => {
-                        let _res = connection.send_close().await;
+                        let res = connection.send_close().await;
+                        handle_result(res, "handle close message");
                         break;
                     }
 
                     Message::Ping(_) => {
-                        let _res = connection
+                        let res = connection
                             .send_message(Message::Pong(b"pong".to_vec()))
                             .await;
+                        handle_result(res, "handle ping message");
                     }
 
                     Message::Text(s) => {

src/lib.rs

@@ -0,0 +1,7 @@
+use tokio_tungstenite::tungstenite;
+
+pub fn handle_result<T>(res: tungstenite::Result<T>, when: impl AsRef<str>) {
+    if let Err(err) = res {
+        log::warn!("Error occurred when {}: {:?}", when.as_ref(), err);
+    }
+}

src/misc.rs

@@ -99,7 +99,17 @@ impl RpcClient {
 
     #[inline]
     pub async fn is_alive(&self) -> bool {
-        self.system_health().await.is_ok()
+        let output = self.system_health().await;
+        match output {
+            Err(err) => {
+                log::info!("system_health failed for '{}': {:?}", self.chain, err);
+                false
+            }
+            Ok(output) => {
+                log::info!("system_health check for '{}': {}", self.chain, output);
+                true
+            }
+        }
     }
 
     // After `reconnect`ed, client need to re`subscribe`.