[Experimental] HTTP agent runtime

python/packages/autogen-core/src/autogen_core/__init__.py

@@ -44,6 +44,7 @@
 )
 from ._message_context import MessageContext
 from ._message_handler_context import MessageHandlerContext
+from ._runtime_impl_helpers import SubscriptionManager
 from ._routed_agent import RoutedAgent, event, message_handler, rpc
 from ._serialization import (
     JSON_DATA_CONTENT_TYPE as JSON_DATA_CONTENT_TYPE_ALIAS,
@@ -132,4 +133,5 @@
     "DropMessage",
     "InterventionHandler",
     "DefaultInterventionHandler",
+    "SubscriptionManager",
 ]

python/packages/autogen-ext/src/autogen_ext/runtimes/http/__init__.py

@@ -0,0 +1,9 @@
+from ._worker_runtime import HttpWorkerAgentRuntime
+from ._worker_runtime_server import HttpAgentServer
+from ._worker_runtime_service import HttpAgentService
+
+__all__ = [
+    "HttpWorkerAgentRuntime",
+    "HttpAgentServer",
+    "HttpAgentService",
+]

python/packages/autogen-ext/src/autogen_ext/runtimes/http/_json_rpc.py

@@ -0,0 +1,18 @@
+from __future__ import annotations
+from typing import Any, Literal
+from pydantic import BaseModel, Field
+
+
+class JsonRpcRequest(BaseModel):
+    jsonrpc: Literal["2.0"] = "2.0"
+    method: str
+    params: dict[str, Any] | None = None
+    id: str | int | None  # id == None → notification
+
+
+class JsonRpcResponse(BaseModel):
+    jsonrpc: Literal["2.0"] = "2.0"
+    # exactly one of result / error
+    result: Any | None = None
+    error: dict[str, Any] | None = None
+    id: str | int | None