fix:消息发不出去

This commit is contained in:
SengokuCola
2025-05-01 18:26:30 +08:00
parent 299cf390ed
commit 31291935b2

View File

@@ -3,6 +3,7 @@ import asyncio
import time import time
from asyncio import Task from asyncio import Task
from typing import Union from typing import Union
from src.plugins.message.api import global_api
# from ...common.database import db # 数据库依赖似乎不需要了,注释掉 # from ...common.database import db # 数据库依赖似乎不需要了,注释掉
from .message import MessageSending, MessageThinking, MessageSet from .message import MessageSending, MessageThinking, MessageSet
@@ -20,7 +21,7 @@ logger = get_logger("sender")
async def send_via_ws(message: MessageSending) -> None: async def send_via_ws(message: MessageSending) -> None:
"""通过 WebSocket 发送消息""" """通过 WebSocket 发送消息"""
try: try:
await send_message(message) await global_api.send_message(message)
except Exception as e: except Exception as e:
logger.error(f"WS发送失败: {e}") logger.error(f"WS发送失败: {e}")
raise ValueError(f"未找到平台:{message.message_info.platform} 的url配置请检查配置文件") from e raise ValueError(f"未找到平台:{message.message_info.platform} 的url配置请检查配置文件") from e