mirror of
https://github.com/langbot-app/LangBot.git
synced 2026-06-02 12:05:54 +00:00
135 lines
3.8 KiB
Python
135 lines
3.8 KiB
Python
from __future__ import annotations
|
|
|
|
import logging
|
|
import asyncio
|
|
import threading
|
|
import traceback
|
|
|
|
from ..platform import manager as im_mgr
|
|
from ..provider.session import sessionmgr as llm_session_mgr
|
|
from ..provider.modelmgr import modelmgr as llm_model_mgr
|
|
from ..provider.sysprompt import sysprompt as llm_prompt_mgr
|
|
from ..provider.tools import toolmgr as llm_tool_mgr
|
|
from ..provider import runnermgr
|
|
from ..config import manager as config_mgr
|
|
from ..config import settings as settings_mgr
|
|
from ..audit.center import v2 as center_mgr
|
|
from ..command import cmdmgr
|
|
from ..plugin import manager as plugin_mgr
|
|
from ..pipeline import pool
|
|
from ..pipeline import controller, stagemgr
|
|
from ..utils import version as version_mgr, proxy as proxy_mgr, announce as announce_mgr
|
|
from ..persistence import mgr as persistencemgr
|
|
from ..api.http.controller import main as http_controller
|
|
from ..utils import logcache
|
|
from . import taskmgr
|
|
|
|
|
|
class Application:
|
|
"""运行时应用对象和上下文"""
|
|
|
|
event_loop: asyncio.AbstractEventLoop = None
|
|
|
|
# asyncio_tasks: list[asyncio.Task] = []
|
|
task_mgr: taskmgr.AsyncTaskManager = None
|
|
|
|
platform_mgr: im_mgr.PlatformManager = None
|
|
|
|
cmd_mgr: cmdmgr.CommandManager = None
|
|
|
|
sess_mgr: llm_session_mgr.SessionManager = None
|
|
|
|
model_mgr: llm_model_mgr.ModelManager = None
|
|
|
|
prompt_mgr: llm_prompt_mgr.PromptManager = None
|
|
|
|
tool_mgr: llm_tool_mgr.ToolManager = None
|
|
|
|
runner_mgr: runnermgr.RunnerManager = None
|
|
|
|
settings_mgr: settings_mgr.SettingsManager = None
|
|
|
|
# ======= 配置管理器 =======
|
|
|
|
command_cfg: config_mgr.ConfigManager = None
|
|
|
|
pipeline_cfg: config_mgr.ConfigManager = None
|
|
|
|
platform_cfg: config_mgr.ConfigManager = None
|
|
|
|
provider_cfg: config_mgr.ConfigManager = None
|
|
|
|
system_cfg: config_mgr.ConfigManager = None
|
|
|
|
# ======= 元数据配置管理器 =======
|
|
|
|
sensitive_meta: config_mgr.ConfigManager = None
|
|
|
|
adapter_qq_botpy_meta: config_mgr.ConfigManager = None
|
|
|
|
plugin_setting_meta: config_mgr.ConfigManager = None
|
|
|
|
llm_models_meta: config_mgr.ConfigManager = None
|
|
|
|
# =========================
|
|
|
|
ctr_mgr: center_mgr.V2CenterAPI = None
|
|
|
|
plugin_mgr: plugin_mgr.PluginManager = None
|
|
|
|
query_pool: pool.QueryPool = None
|
|
|
|
ctrl: controller.Controller = None
|
|
|
|
stage_mgr: stagemgr.StageManager = None
|
|
|
|
ver_mgr: version_mgr.VersionManager = None
|
|
|
|
ann_mgr: announce_mgr.AnnouncementManager = None
|
|
|
|
proxy_mgr: proxy_mgr.ProxyManager = None
|
|
|
|
logger: logging.Logger = None
|
|
|
|
persistence_mgr: persistencemgr.PersistenceManager = None
|
|
|
|
http_ctrl: http_controller.HTTPController = None
|
|
|
|
log_cache: logcache.LogCache = None
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
async def initialize(self):
|
|
pass
|
|
|
|
async def run(self):
|
|
await self.plugin_mgr.initialize_plugins()
|
|
|
|
try:
|
|
|
|
# 后续可能会允许动态重启其他任务
|
|
# 故为了防止程序在非 Ctrl-C 情况下退出，这里创建一个不会结束的协程
|
|
async def never_ending():
|
|
while True:
|
|
await asyncio.sleep(1)
|
|
|
|
self.task_mgr.create_task(self.platform_mgr.run(), name="platform-manager")
|
|
self.task_mgr.create_task(self.ctrl.run(), name="query-controller")
|
|
self.task_mgr.create_task(self.http_ctrl.run(), name="http-api-controller")
|
|
self.task_mgr.create_task(never_ending(), name="never-ending-task")
|
|
|
|
await self.task_mgr.wait_all()
|
|
except asyncio.CancelledError:
|
|
pass
|
|
except Exception as e:
|
|
self.logger.error(f"应用运行致命异常: {e}")
|
|
self.logger.debug(f"Traceback: {traceback.format_exc()}")
|
|
|
|
async def scoped_shutdown(self, scopes: list[str]):
|
|
pass
|
|
|
|
async def shutdown(self):
|
|
for task in self.task_mgr.tasks:
|
|
task.cancel()
|