From 2b60f617cb5e768b01f6b8d50b6b0ebb3f6bed2c Mon Sep 17 00:00:00 2001
From: InfinityPacer <160988576+InfinityPacer@users.noreply.github.com>
Date: Sun, 23 Aug 2026 18:17:24 +0800
Subject: [PATCH] refactor(application): remove unused sync service methods
 (#6417)

---
 app/application/messaging/chat.py | 39 -------------------------------
 app/application/site/query.py     | 11 ---------
 2 files changed, 50 deletions(-)

diff --git a/app/application/messaging/chat.py b/app/application/messaging/chat.py
index 5a8b3cb22..80cfe1287 100644
--- a/app/application/messaging/chat.py
+++ b/app/application/messaging/chat.py
@@ -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,
diff --git a/app/application/site/query.py b/app/application/site/query.py
index 09db872f7..800f2b833 100644
--- a/app/application/site/query.py
+++ b/app/application/site/query.py
@@ -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)