|
11 | 11 | from a2a.compat.v0_3.grpc_handler import CompatGrpcHandler |
12 | 12 | from a2a.server.agent_execution.agent_executor import AgentExecutor |
13 | 13 | from a2a.server.agent_execution.context import RequestContext |
14 | | -from a2a.server.apps import A2AFastAPIApplication, A2ARESTFastAPIApplication |
| 14 | +from a2a.server.apps import A2ARESTFastAPIApplication |
15 | 15 | from a2a.server.events.event_queue import EventQueue |
16 | 16 | from a2a.server.request_handlers import GrpcHandler |
17 | 17 | from a2a.server.request_handlers.default_request_handler import ( |
18 | 18 | DefaultRequestHandler, |
19 | 19 | ) |
| 20 | +from a2a.server.routes import AgentCardRoutes, JsonRpcRoutes |
20 | 21 | from a2a.server.tasks.inmemory_task_store import InMemoryTaskStore |
21 | 22 | from a2a.server.tasks.task_updater import TaskUpdater |
22 | 23 | from a2a.types import ( |
@@ -197,14 +198,17 @@ async def serve( |
197 | 198 | ) |
198 | 199 | rest_app = rest_app_builder.build() |
199 | 200 |
|
200 | | - jsonrpc_app_builder = A2AFastAPIApplication( |
| 201 | + jsonrpc_routes = JsonRpcRoutes( |
| 202 | + agent_card=agent_card, |
| 203 | + request_handler=request_handler, |
| 204 | + rpc_url='/a2a/jsonrpc/', |
| 205 | + ) |
| 206 | + agent_card_routes = AgentCardRoutes( |
201 | 207 | agent_card=agent_card, |
202 | | - http_handler=request_handler, |
203 | | - enable_v0_3_compat=True, |
204 | 208 | ) |
205 | | - |
206 | 209 | app = FastAPI() |
207 | | - jsonrpc_app_builder.add_routes_to_app(app, rpc_url='/a2a/jsonrpc/') |
| 210 | + app.routes.extend(jsonrpc_routes.routes) |
| 211 | + app.routes.extend(agent_card_routes.routes) |
208 | 212 | app.mount('/a2a/rest', rest_app) |
209 | 213 |
|
210 | 214 | grpc_server = grpc.aio.server() |
|
0 commit comments