refactor(application): remove unused sync service methods (#6417)

This commit is contained in:
InfinityPacer
2026-08-23 18:17:24 +08:00
committed by GitHub
parent f7f5a7e107
commit 2b60f617cb
2 changed files with 0 additions and 50 deletions
-39
View File
@@ -77,20 +77,6 @@ class AsyncAgentChatRepository(Protocol):
"""同步读取服务端会话。"""
...
def save_display_messages(
self,
session_id: str,
user_id: Optional[str] = None,
messages: Optional[list[dict]] = None,
username: Optional[str] = None,
channel: Optional[Any] = None,
source: Optional[str] = None,
original_chat_id: Optional[str] = None,
client_session_id: Optional[str] = None,
) -> Optional[Any]:
"""同步保存用户可见会话消息。"""
...
class SyncAgentChatRepository(Protocol):
"""仅包含 Agent 编排所需同步持久化方法的适配器端口。"""
@@ -267,31 +253,6 @@ class AgentChatService:
record = self._repository.get(session_id=session_id)
return self._project(record) if record is not None else None
def save_display_sync(
self,
*,
session_id: str,
user_id: Optional[str] = None,
messages: Optional[list[dict]] = None,
username: Optional[str] = None,
channel: Optional[Any] = None,
source: Optional[str] = None,
original_chat_id: Optional[str] = None,
client_session_id: Optional[str] = None,
) -> Optional[AgentChatRecord]:
"""同步保存用户可见消息并返回最新投影。"""
record = self._repository.save_display_messages(
session_id=session_id,
user_id=user_id,
messages=messages,
username=username,
channel=channel,
source=source,
original_chat_id=original_chat_id,
client_session_id=client_session_id,
)
return self._project(record) if record is not None else None
@staticmethod
def can_access(
record: AgentChatRecord,
-11
View File
@@ -59,10 +59,6 @@ class SiteQueryRepository(Protocol):
"""同步读取全部站点。"""
...
def list_order_by_pri(self) -> list[Any]:
"""同步按优先级读取站点。"""
...
def get_userdata_latest(self) -> list[Any]:
"""同步读取各站点最新用户数据。"""
...
@@ -93,13 +89,6 @@ class SiteQueryService:
item = self._repository.get(site_id)
return Site.model_validate(item) if item else None
def list_sync(self) -> list[Site]:
"""同步返回全部站点配置 DTO。"""
return [
Site.model_validate(item)
for item in self._repository.list_order_by_pri()
]
async def get_by_domain(self, domain: str) -> Optional[Site]:
"""按域名返回站点配置 DTO。"""
item = await self._repository.async_get_by_domain(domain)