mirror of
https://github.com/All-Hands-AI/OpenHands.git
synced 2026-01-07 22:14:03 -05:00
d9d19043f1
Co-authored-by: openhands <openhands@all-hands.dev> Co-authored-by: Rohit Malhotra <rohitvinodmalhotra@gmail.com>
86 lines
3.2 KiB
Python
86 lines
3.2 KiB
Python
# IMPORTANT: LEGACY V0 CODE
|
|
# This file is part of the legacy (V0) implementation of OpenHands and will be removed soon as we complete the migration to V1.
|
|
# OpenHands V1 uses the Software Agent SDK for the agentic core and runs a new application server. Please refer to:
|
|
# - V1 agentic core (SDK): https://github.com/OpenHands/software-agent-sdk
|
|
# - V1 application server (in this repo): openhands/app_server/
|
|
# Unless you are working on deprecation, please avoid extending this legacy file and consult the V1 codepaths above.
|
|
# Tag: Legacy-V0
|
|
# This module belongs to the old V0 web server. The V1 application server lives under openhands/app_server/.
|
|
import os
|
|
|
|
import socketio
|
|
from dotenv import load_dotenv
|
|
|
|
from openhands.core.config import load_openhands_config
|
|
from openhands.core.config.openhands_config import OpenHandsConfig
|
|
from openhands.server.config.server_config import ServerConfig, load_server_config
|
|
from openhands.server.conversation_manager.conversation_manager import (
|
|
ConversationManager,
|
|
)
|
|
from openhands.server.monitoring import MonitoringListener
|
|
from openhands.server.types import ServerConfigInterface
|
|
from openhands.storage import get_file_store
|
|
from openhands.storage.conversation.conversation_store import ConversationStore
|
|
from openhands.storage.files import FileStore
|
|
from openhands.storage.secrets.secrets_store import SecretsStore
|
|
from openhands.storage.settings.settings_store import SettingsStore
|
|
from openhands.utils.import_utils import get_impl
|
|
|
|
load_dotenv()
|
|
|
|
config: OpenHandsConfig = load_openhands_config()
|
|
server_config_interface: ServerConfigInterface = load_server_config()
|
|
assert isinstance(server_config_interface, ServerConfig), (
|
|
'Loaded server config interface is not a ServerConfig, despite this being assumed'
|
|
)
|
|
server_config: ServerConfig = server_config_interface
|
|
file_store: FileStore = get_file_store(
|
|
file_store_type=config.file_store,
|
|
file_store_path=config.file_store_path,
|
|
file_store_web_hook_url=config.file_store_web_hook_url,
|
|
file_store_web_hook_headers=config.file_store_web_hook_headers,
|
|
file_store_web_hook_batch=config.file_store_web_hook_batch,
|
|
)
|
|
|
|
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,
|
|
# Increase buffer size to 4MB (to handle 3MB files with base64 overhead)
|
|
max_http_buffer_size=4 * 1024 * 1024,
|
|
)
|
|
|
|
MonitoringListenerImpl = get_impl(
|
|
MonitoringListener,
|
|
server_config.monitoring_listener_class,
|
|
)
|
|
|
|
monitoring_listener = MonitoringListenerImpl.get_instance(config)
|
|
|
|
ConversationManagerImpl = get_impl(
|
|
ConversationManager,
|
|
server_config.conversation_manager_class,
|
|
)
|
|
|
|
conversation_manager = ConversationManagerImpl.get_instance(
|
|
sio, config, file_store, server_config, monitoring_listener
|
|
)
|
|
|
|
SettingsStoreImpl = get_impl(SettingsStore, server_config.settings_store_class)
|
|
|
|
SecretsStoreImpl = get_impl(SecretsStore, server_config.secret_store_class)
|
|
|
|
ConversationStoreImpl = get_impl(
|
|
ConversationStore,
|
|
server_config.conversation_store_class,
|
|
)
|