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();