refactor: 移除未使用的 cli_sessions 变量,优化 ws.rs 中的代码
This commit is contained in:
parent
393052ae48
commit
a8267631b8
@ -13,15 +13,7 @@ impl CliSessionService {
|
|||||||
Self { store }
|
Self { store }
|
||||||
}
|
}
|
||||||
|
|
||||||
#[allow(dead_code)]
|
|
||||||
pub(crate) fn create(&self, title: Option<&str>) -> Result<SessionRecord, AgentError> {
|
|
||||||
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(
|
pub(crate) fn create_with_channel(
|
||||||
&self,
|
&self,
|
||||||
channel_name: &str,
|
channel_name: &str,
|
||||||
@ -31,58 +23,4 @@ impl CliSessionService {
|
|||||||
.create_session(channel_name, title)
|
.create_session(channel_name, title)
|
||||||
.map_err(|err| AgentError::Other(format!("create session error: {}", err)))
|
.map_err(|err| AgentError::Other(format!("create session error: {}", err)))
|
||||||
}
|
}
|
||||||
|
|
||||||
#[allow(dead_code)]
|
|
||||||
pub(crate) fn get(&self, session_id: &str) -> Result<Option<SessionRecord>, 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<Vec<SessionRecord>, 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<Vec<SessionRecord>, 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)))
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -390,7 +390,6 @@ async fn handle_inbound(
|
|||||||
};
|
};
|
||||||
|
|
||||||
// 创建命令路由器
|
// 创建命令路由器
|
||||||
let _cli_sessions = state.session_manager.cli_sessions();
|
|
||||||
let store = state.session_manager.store();
|
let store = state.session_manager.store();
|
||||||
let skills = state.session_manager.skills();
|
let skills = state.session_manager.skills();
|
||||||
let skills_for_handler = skills.clone();
|
let skills_for_handler = skills.clone();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user