Skip to content

Commit 31637a8

Browse files
committed
fix: 优化 WebSocket 消息处理逻辑,简化未知消息类型的处理
1 parent 4c10bdd commit 31637a8

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

send_message.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -109,15 +109,15 @@ async def send_message(
109109
# 处理消息类型
110110
if response.type == aiohttp.WSMsgType.TEXT:
111111
return json.loads(response.data)
112-
elif response.type == aiohttp.WSMsgType.CLOSED:
112+
if response.type == aiohttp.WSMsgType.CLOSED:
113113
logger.debug("WebSocket 连接已关闭")
114114
return {"status": "ok", "retcode": 0, "data": {"message_id": -1}}
115-
elif response.type == aiohttp.WSMsgType.ERROR:
115+
if response.type == aiohttp.WSMsgType.ERROR:
116116
logger.error("WebSocket 连接错误: %s", ws.exception())
117117
raise WSConnectionException("WebSocket 连接错误")
118-
else:
119-
logger.warning("收到未知类型的消息: %s", response.type)
120-
return {"status": "error", "retcode": -1, "message": f"未知响应类型: {response.type}"} # pylint: disable=line-too-long
118+
119+
logger.warning("收到未知类型的消息: %s", response.type)
120+
return {"status": "error", "retcode": -1, "message": f"未知响应类型: {response.type}"} # pylint: disable=line-too-long
121121

122122
except aiohttp.ClientError as e:
123123
logger.error("aiohttp 客户端错误: %s", e)

0 commit comments

Comments
 (0)