src/websocket.rs

@@ -105,11 +105,13 @@ pub async fn send_to_ipbl_websocket(
             Ok(_) => {}
             Err(e) => {
                 println!("err send read: {e:?}");
-                return handle_websocket_error(ws);
+                ws.close(None).unwrap_or(());
+                return false;
             }
         };
     } else {
-        return handle_websocket_error(ws);
+        ws.close(None).unwrap_or(());
+        return false;
     };
 
     if ws.can_read() {
@@ -117,19 +119,13 @@ pub async fn send_to_ipbl_websocket(
             Ok(_) => {}
             Err(e) => {
                 println!("err send read: {e:?}");
-                return handle_websocket_error(ws);
+                ws.close(None).unwrap_or(());
+                return false;
             }
         };
     } else {
-        return handle_websocket_error(ws);
+        ws.close(None).unwrap_or(());
+        return false;
     };
     true
 }
-
-fn handle_websocket_error(ws: &mut WebSocket<MaybeTlsStream<TcpStream>>) -> bool {
-    match ws.close(None) {
-        Ok(o) => {}
-        Err(e) => {}
-    };
-    return false;
-}