mirror of
https://github.com/OpenHands/OpenHands.git
synced 2025-12-26 05:48:36 +08:00
65 lines
2.0 KiB
Python
65 lines
2.0 KiB
Python
import inspect
|
|
import os
|
|
|
|
import socketio
|
|
from dotenv import load_dotenv
|
|
|
|
from openhands.core.config import load_app_config
|
|
from openhands.server.config.server_config import load_server_config
|
|
from openhands.server.conversation_manager.conversation_manager import (
|
|
ConversationManager,
|
|
)
|
|
from openhands.server.monitoring import MonitoringListener
|
|
from openhands.storage import get_file_store
|
|
from openhands.storage.conversation.conversation_store import ConversationStore
|
|
from openhands.storage.settings.settings_store import SettingsStore
|
|
from openhands.utils.import_utils import get_impl
|
|
|
|
load_dotenv()
|
|
|
|
config = load_app_config()
|
|
server_config = load_server_config()
|
|
file_store = get_file_store(config.file_store, config.file_store_path)
|
|
|
|
client_manager = None
|
|
redis_host = os.environ.get('REDIS_HOST')
|
|
if redis_host:
|
|
client_manager = socketio.AsyncRedisManager(
|
|
f'redis://{redis_host}',
|
|
redis_options={'password': os.environ.get('REDIS_PASSWORD')},
|
|
)
|
|
|
|
|
|
sio = socketio.AsyncServer(
|
|
async_mode='asgi', cors_allowed_origins='*', client_manager=client_manager
|
|
)
|
|
|
|
MonitoringListenerImpl = get_impl(
|
|
MonitoringListener,
|
|
server_config.monitoring_listener_class,
|
|
)
|
|
|
|
monitoring_listener = MonitoringListenerImpl.get_instance(config)
|
|
|
|
ConversationManagerImpl = get_impl(
|
|
ConversationManager, # type: ignore
|
|
server_config.conversation_manager_class,
|
|
)
|
|
|
|
if len(inspect.signature(ConversationManagerImpl.get_instance).parameters) == 3:
|
|
# This conditional prevents a breaking change in February 2025.
|
|
# It should be safe to remove by April.
|
|
conversation_manager = ConversationManagerImpl.get_instance(sio, config, file_store)
|
|
else:
|
|
# This is the new signature.
|
|
conversation_manager = ConversationManagerImpl.get_instance( # type: ignore
|
|
sio, config, file_store, monitoring_listener
|
|
)
|
|
|
|
SettingsStoreImpl = get_impl(SettingsStore, server_config.settings_store_class) # type: ignore
|
|
|
|
ConversationStoreImpl = get_impl(
|
|
ConversationStore, # type: ignore
|
|
server_config.conversation_store_class,
|
|
)
|