1111 from starlette .requests import Request
1212
1313 from a2a .server .request_handlers .request_handler import RequestHandler
14- from a2a .server .routes import CallContextBuilder
1514
1615 _package_starlette_installed = True
1716else :
3635from a2a .server .jsonrpc_models import (
3736 JSONRPCError as CoreJSONRPCError ,
3837)
38+ from a2a .server .routes .common import (
39+ DefaultServerCallContextBuilder ,
40+ ServerCallContextBuilder ,
41+ )
3942from a2a .utils import constants
4043from a2a .utils .helpers import validate_version
4144
@@ -56,18 +59,20 @@ class JSONRPC03Adapter:
5659 'tasks/pushNotificationConfig/list' : types_v03 .ListTaskPushNotificationConfigRequest ,
5760 'tasks/pushNotificationConfig/delete' : types_v03 .DeleteTaskPushNotificationConfigRequest ,
5861 'tasks/resubscribe' : types_v03 .TaskResubscriptionRequest ,
59- 'agent/authenticatedExtendedCard ' : types_v03 .GetAuthenticatedExtendedCardRequest ,
62+ 'agent/getAuthenticatedExtendedCard ' : types_v03 .GetAuthenticatedExtendedCardRequest ,
6063 }
6164
6265 def __init__ (
6366 self ,
6467 http_handler : 'RequestHandler' ,
65- context_builder : 'CallContextBuilder | None' = None ,
68+ context_builder : 'ServerCallContextBuilder | None' = None ,
6669 ):
6770 self .handler = RequestHandler03 (
6871 request_handler = http_handler ,
6972 )
70- self ._context_builder = context_builder
73+ self ._context_builder = (
74+ context_builder or DefaultServerCallContextBuilder ()
75+ )
7176
7277 def supports_method (self , method : str ) -> bool :
7378 """Returns True if the v0.3 adapter supports the given method name."""
@@ -115,11 +120,7 @@ async def handle_request(
115120 CoreInvalidRequestError (data = str (e )),
116121 )
117122
118- call_context = (
119- self ._context_builder .build (request )
120- if self ._context_builder
121- else ServerCallContext ()
122- )
123+ call_context = self ._context_builder .build (request )
123124 call_context .tenant = (
124125 getattr (specific_request .params , 'tenant' , '' )
125126 if hasattr (specific_request , 'params' )
@@ -214,7 +215,7 @@ async def _process_non_streaming_request(
214215 id = request_id , result = None
215216 )
216217 )
217- elif method == 'agent/authenticatedExtendedCard ' :
218+ elif method == 'agent/getAuthenticatedExtendedCard ' :
218219 res_card = await self .handler .on_get_extended_agent_card (
219220 request_obj , context
220221 )
0 commit comments