chore: bump tauri-plugin-mihomo to 0.1.8

src-tauri/src/core/tray/speed_task.rs

@@ -6,7 +6,7 @@ use parking_lot::Mutex;
 use std::sync::Arc;
 use std::time::Duration;
 use tauri::async_runtime::JoinHandle;
-use tauri_plugin_mihomo::models::ConnectionId;
+use tauri_plugin_mihomo::models::WebSocketConnectionId;
 
 /// 托盘速率流异常后的重连间隔。
 const TRAY_SPEED_RETRY_DELAY: Duration = Duration::from_secs(1);
@@ -19,7 +19,7 @@ const TRAY_SPEED_STALE_TIMEOUT: Duration = Duration::from_secs(5);
 #[derive(Clone)]
 pub struct TraySpeedController {
     speed_task: Arc<Mutex<Option<JoinHandle<()>>>>,
-    speed_connection_id: Arc<Mutex<Option<ConnectionId>>>,
+    speed_connection_id: Arc<Mutex<Option<WebSocketConnectionId>>>,
 }
 
 impl Default for TraySpeedController {
@@ -162,17 +162,19 @@ impl TraySpeedController {
     }
 
     fn set_speed_connection_id(
-        speed_connection_id: &Arc<Mutex<Option<ConnectionId>>>,
-        connection_id: Option<ConnectionId>,
+        speed_connection_id: &Arc<Mutex<Option<WebSocketConnectionId>>>,
+        connection_id: Option<WebSocketConnectionId>,
     ) {
         *speed_connection_id.lock() = connection_id;
     }
 
-    fn take_speed_connection_id(speed_connection_id: &Arc<Mutex<Option<ConnectionId>>>) -> Option<ConnectionId> {
+    fn take_speed_connection_id(
+        speed_connection_id: &Arc<Mutex<Option<WebSocketConnectionId>>>,
+    ) -> Option<WebSocketConnectionId> {
         speed_connection_id.lock().take()
     }
 
-    async fn disconnect_speed_connection(speed_connection_id: &Arc<Mutex<Option<ConnectionId>>>) {
+    async fn disconnect_speed_connection(speed_connection_id: &Arc<Mutex<Option<WebSocketConnectionId>>>) {
         if let Some(connection_id) = Self::take_speed_connection_id(speed_connection_id) {
             connections_stream::disconnect_connection(connection_id).await;
         }

src-tauri/src/lib.rs

@@ -24,7 +24,6 @@ use tauri::{AppHandle, Manager as _};
 #[cfg(target_os = "macos")]
 use tauri_plugin_autostart::MacosLauncher;
 use tauri_plugin_deep_link::DeepLinkExt as _;
-use tauri_plugin_mihomo::RejectPolicy;
 
 pub static APP_HANDLE: OnceCell<AppHandle> = OnceCell::new();
 /// Application initialization helper functions
@@ -59,15 +58,6 @@ mod app_init {
                 tauri_plugin_mihomo::Builder::new()
                     .protocol(tauri_plugin_mihomo::models::Protocol::LocalSocket)
                     .socket_path(crate::config::IClashTemp::guard_external_controller_ipc())
-                    .pool_config(
-                        tauri_plugin_mihomo::IpcPoolConfigBuilder::new()
-                            .min_connections(3)
-                            .max_connections(32)
-                            .idle_timeout(std::time::Duration::from_secs(60))
-                            .health_check_interval(std::time::Duration::from_secs(60))
-                            .reject_policy(RejectPolicy::Wait)
-                            .build(),
-                    )
                     .build(),
             );
 

src-tauri/src/utils/connections_stream.rs

@@ -3,7 +3,7 @@ use anyhow::Result;
 use serde::Deserialize;
 use serde_json::Value;
 use std::time::Duration;
-use tauri_plugin_mihomo::models::{ConnectionId, WebSocketMessage};
+use tauri_plugin_mihomo::models::{WebSocketConnectionId, WebSocketMessage};
 use tokio::sync::mpsc;
 use tokio::time::Instant;
 
@@ -39,7 +39,7 @@ enum InternalWsEvent<T> {
 /// Mihomo WebSocket 订阅句柄（通用事件流）。
 pub struct MihomoWsEventStream<T> {
     /// 当前订阅连接 ID，用于主动断开。
-    pub connection_id: ConnectionId,
+    pub connection_id: WebSocketConnectionId,
     /// 当前订阅消息接收器。
     receiver: mpsc::Receiver<InternalWsEvent<T>>,
     /// 最近一次收到有效事件的时间戳。
@@ -162,7 +162,7 @@ impl<T> MihomoWsEventStream<T> {
 ///
 /// # Arguments
 /// * `connection_id` - 目标连接 ID
-pub async fn disconnect_connection(connection_id: ConnectionId) {
+pub async fn disconnect_connection(connection_id: WebSocketConnectionId) {
     if let Err(err) = handle::Handle::mihomo()
         .await
         .disconnect(connection_id, Some(MIHOMO_WS_STREAM_CLOSE_CODE))