refactor: 优化kook pydantic数据类验证错误时的错误处理

Author: shuiping233

astrbot/core/platform/sources/kook/kook_adapter.py

@@ -2,8 +2,6 @@
 import json
 import re
 
-import pydantic
-
 from astrbot import logger
 from astrbot.api.event import MessageChain
 from astrbot.api.message_components import At, AtAll, Image, Plain
@@ -270,11 +268,7 @@ def _parse_card_message(self, data: KookMessageEvent) -> tuple[list, str]:
         if not isinstance(content, str):
             content = str(content)
 
-        try:
-            card_list = KookCardMessageContainer.from_dict(json.loads(content))
-
-        except pydantic.ValidationError:
-            raise
+        card_list = KookCardMessageContainer.from_dict(json.loads(content))
 
         text_parts: list[str] = []
         images: list[str] = []

astrbot/core/platform/sources/kook/kook_client.py

@@ -133,7 +133,8 @@ async def get_gateway_url(self, resume=False, sn=0, session_id=None):
 
         except pydantic.ValidationError as e:
             logger.error(f"[KOOK] 获取gateway失败, 响应数据格式错误: \n{e}")
-            logger.error(f"[KOOK] 响应内容: {await resp.text()}")
+            logger.error(f"[KOOK] 原始响应内容: {await resp.text()}")
+            return None
 
         except Exception as e:
             logger.error(f"[KOOK] 获取gateway异常: {e}")
@@ -204,7 +205,8 @@ async def listen(self):
 
                 except pydantic.ValidationError as e:
                     logger.error(f"[KOOK] 解析WebSocket事件数据格式失败: \n{e}")
-                    logger.error(f"[KOOK] 响应内容: {msg}")
+                    logger.error(f"[KOOK] 原始响应内容: {msg}")
+                    continue
 
                 except asyncio.TimeoutError:
                     # 超时检查，继续循环