mirror of
https://github.com/langbot-app/LangBot.git
synced 2025-11-25 19:37:36 +08:00
78 lines
2.1 KiB
Python
78 lines
2.1 KiB
Python
from __future__ import annotations
|
|
|
|
import logging
|
|
import asyncio
|
|
|
|
from ..platform import manager as im_mgr
|
|
from ..provider.session import sessionmgr as llm_session_mgr
|
|
from ..provider.requester 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 ..config import manager as config_mgr
|
|
# from ..utils.center import v2 as center_mgr
|
|
from ..command import cmdmgr
|
|
from ..plugin import manager as plugin_mgr
|
|
from . import pool, controller
|
|
from ..pipeline import stagemgr
|
|
from ..utils import version as version_mgr, proxy as proxy_mgr
|
|
|
|
|
|
class Application:
|
|
im_mgr: im_mgr.QQBotManager = 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
|
|
|
|
cfg_mgr: config_mgr.ConfigManager = None
|
|
|
|
tips_mgr: 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
|
|
|
|
proxy_mgr: proxy_mgr.ProxyManager = None
|
|
|
|
logger: logging.Logger = None
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
async def initialize(self):
|
|
pass
|
|
|
|
# 把现有的所有内容函数加到toolmgr里
|
|
# for func in plugin_host.__callable_functions__:
|
|
# self.tool_mgr.register_legacy_function(
|
|
# name=func['name'],
|
|
# description=func['description'],
|
|
# parameters=func['parameters'],
|
|
# func=plugin_host.__function_inst_map__[func['name']]
|
|
# )
|
|
|
|
async def run(self):
|
|
await self.plugin_mgr.load_plugins()
|
|
await self.plugin_mgr.initialize_plugins()
|
|
|
|
tasks = [
|
|
asyncio.create_task(self.im_mgr.run()),
|
|
asyncio.create_task(self.ctrl.run())
|
|
]
|
|
|
|
await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
|