增加了后端api喵~
This commit is contained in:
1
src/api/__init__.py
Normal file
1
src/api/__init__.py
Normal file
@@ -0,0 +1 @@
|
|||||||
|
# This file makes src/api a Python package.
|
||||||
13
src/api/message_router.py
Normal file
13
src/api/message_router.py
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
from fastapi import APIRouter
|
||||||
|
from src.plugin_system.apis import message_api
|
||||||
|
|
||||||
|
router = APIRouter()
|
||||||
|
|
||||||
|
@router.get("/messages/recent")
|
||||||
|
async def get_recent_messages(chat_id: str, limit: int = 10):
|
||||||
|
"""
|
||||||
|
获取最近的聊天记录
|
||||||
|
"""
|
||||||
|
# 假设 message_api.get_recent_messages 是一个异步函数
|
||||||
|
messages = await message_api.get_recent_messages(chat_id=chat_id, limit=limit)
|
||||||
|
return {"chat_id": chat_id, "messages": messages}
|
||||||
10
src/main.py
10
src/main.py
@@ -245,6 +245,16 @@ MoFox_Bot(第三方修改版)
|
|||||||
# start_api_server()
|
# start_api_server()
|
||||||
# logger.info("API服务器启动成功")
|
# logger.info("API服务器启动成功")
|
||||||
|
|
||||||
|
# 注册API路由
|
||||||
|
try:
|
||||||
|
from src.api.message_router import router as message_router
|
||||||
|
self.server.register_router(message_router, prefix="/api")
|
||||||
|
logger.info("API路由注册成功")
|
||||||
|
except ImportError as e:
|
||||||
|
logger.error(f"导入API路由失败: {e}")
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(f"注册API路由时发生错误: {e}")
|
||||||
|
|
||||||
# 加载所有actions,包括默认的和插件的
|
# 加载所有actions,包括默认的和插件的
|
||||||
plugin_manager.load_all_plugins()
|
plugin_manager.load_all_plugins()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user