From a8267631b823da6041d407fab947d8249492262e Mon Sep 17 00:00:00 2001 From: oudecheng <13802883547@139.com> Date: Wed, 8 Jul 2026 09:45:20 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=E6=9C=AA?= =?UTF-8?q?=E4=BD=BF=E7=94=A8=E7=9A=84=20cli=5Fsessions=20=E5=8F=98?= =?UTF-8?q?=E9=87=8F=EF=BC=8C=E4=BC=98=E5=8C=96=20ws.rs=20=E4=B8=AD?= =?UTF-8?q?=E7=9A=84=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gateway/cli_session.rs | 62 -------------------------------------- src/gateway/ws.rs | 1 - 2 files changed, 63 deletions(-) diff --git a/src/gateway/cli_session.rs b/src/gateway/cli_session.rs index 238ef23..81cee67 100644 --- a/src/gateway/cli_session.rs +++ b/src/gateway/cli_session.rs @@ -13,15 +13,7 @@ impl CliSessionService { Self { store } } - #[allow(dead_code)] - pub(crate) fn create(&self, title: Option<&str>) -> Result { - self.store - .create_cli_session(title) - .map_err(|err| AgentError::Other(format!("create session error: {}", err))) - } - /// 创建指定通道的会话 - #[allow(dead_code)] pub(crate) fn create_with_channel( &self, channel_name: &str, @@ -31,58 +23,4 @@ impl CliSessionService { .create_session(channel_name, title) .map_err(|err| AgentError::Other(format!("create session error: {}", err))) } - - #[allow(dead_code)] - pub(crate) fn get(&self, session_id: &str) -> Result, AgentError> { - self.store - .get_session(session_id) - .map_err(|err| AgentError::Other(format!("get session error: {}", err))) - } - - #[allow(dead_code)] - pub(crate) fn list(&self, include_archived: bool) -> Result, AgentError> { - self.store - .list_sessions("cli", include_archived) - .map_err(|err| AgentError::Other(format!("list sessions error: {}", err))) - } - - /// 列出指定通道的会话 - #[allow(dead_code)] - pub(crate) fn list_by_channel( - &self, - channel_name: &str, - include_archived: bool, - ) -> Result, AgentError> { - self.store - .list_sessions(channel_name, include_archived) - .map_err(|err| AgentError::Other(format!("list sessions error: {}", err))) - } - - #[allow(dead_code)] - pub(crate) fn rename(&self, session_id: &str, title: &str) -> Result<(), AgentError> { - self.store - .rename_session(session_id, title) - .map_err(|err| AgentError::Other(format!("rename session error: {}", err))) - } - - #[allow(dead_code)] - pub(crate) fn archive(&self, session_id: &str) -> Result<(), AgentError> { - self.store - .archive_session(session_id) - .map_err(|err| AgentError::Other(format!("archive session error: {}", err))) - } - - #[allow(dead_code)] - pub(crate) fn delete(&self, session_id: &str) -> Result<(), AgentError> { - self.store - .delete_session(session_id) - .map_err(|err| AgentError::Other(format!("delete session error: {}", err))) - } - - #[allow(dead_code)] - pub(crate) fn clear_messages(&self, session_id: &str) -> Result<(), AgentError> { - self.store - .clear_messages(session_id) - .map_err(|err| AgentError::Other(format!("clear session error: {}", err))) - } } diff --git a/src/gateway/ws.rs b/src/gateway/ws.rs index 9cd5569..f892407 100644 --- a/src/gateway/ws.rs +++ b/src/gateway/ws.rs @@ -390,7 +390,6 @@ async fn handle_inbound( }; // 创建命令路由器 - let _cli_sessions = state.session_manager.cli_sessions(); let store = state.session_manager.store(); let skills = state.session_manager.skills(); let skills_for_handler = skills.clone();