mirror of
https://github.com/All-Hands-AI/OpenHands.git
synced 2026-01-09 14:57:59 -05:00
d9d19043f1
Co-authored-by: openhands <openhands@all-hands.dev> Co-authored-by: Rohit Malhotra <rohitvinodmalhotra@gmail.com>
75 lines
2.6 KiB
Python
75 lines
2.6 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 asyncio
|
|
|
|
from openhands.core.config import OpenHandsConfig
|
|
from openhands.events.stream import EventStream
|
|
from openhands.llm.llm_registry import LLMRegistry
|
|
from openhands.runtime import get_runtime_cls
|
|
from openhands.runtime.base import Runtime
|
|
from openhands.storage.files import FileStore
|
|
from openhands.utils.async_utils import call_sync_from_async
|
|
|
|
|
|
class ServerConversation:
|
|
sid: str
|
|
file_store: FileStore
|
|
event_stream: EventStream
|
|
runtime: Runtime
|
|
user_id: str | None
|
|
_attach_to_existing: bool = False
|
|
|
|
def __init__(
|
|
self,
|
|
sid: str,
|
|
file_store: FileStore,
|
|
config: OpenHandsConfig,
|
|
user_id: str | None,
|
|
event_stream: EventStream | None = None,
|
|
runtime: Runtime | None = None,
|
|
):
|
|
self.sid = sid
|
|
self.config = config
|
|
self.file_store = file_store
|
|
self.user_id = user_id
|
|
|
|
if event_stream is None:
|
|
event_stream = EventStream(sid, file_store, user_id)
|
|
self.event_stream = event_stream
|
|
|
|
if runtime:
|
|
self._attach_to_existing = True
|
|
else:
|
|
runtime_cls = get_runtime_cls(self.config.runtime)
|
|
runtime = runtime_cls(
|
|
llm_registry=LLMRegistry(self.config),
|
|
config=config,
|
|
event_stream=self.event_stream,
|
|
sid=self.sid,
|
|
attach_to_existing=True,
|
|
headless_mode=False,
|
|
)
|
|
self.runtime = runtime
|
|
|
|
@property
|
|
def security_analyzer(self):
|
|
"""Access security analyzer through runtime."""
|
|
return self.runtime.security_analyzer
|
|
|
|
async def connect(self) -> None:
|
|
if not self._attach_to_existing:
|
|
await self.runtime.connect()
|
|
|
|
async def disconnect(self) -> None:
|
|
if self._attach_to_existing:
|
|
return
|
|
if self.event_stream:
|
|
self.event_stream.close()
|
|
asyncio.create_task(call_sync_from_async(self.runtime.close))
|