feat(runtime_context): pass Request to extension point (EVO-1626 followup)

src/api/a2a_routes.py

@@ -1057,6 +1057,7 @@ async def handle_message_send(
             files=files if files else None,
             metadata=metadata,
             user_id=user_id,  # Pass contact_id as user_id
+            request=request,
         )
 
         final_response = result.get("final_response", "No response")

src/api/chat_routes.py

@@ -646,6 +646,7 @@ async def chat(
             db,
             session_id=session_id,
             files=payload.files,
+            request=request,
         )
 
         return success_response(

src/services/adk/agent_runner.py

@@ -34,7 +34,7 @@
 from src.services.adk.runners.streaming_runner import StreamingRunner
 from src.services.adk.runners.live_runner import LiveRunner
 from sqlalchemy.orm import Session
-from typing import Optional, AsyncGenerator, Dict, Any
+from typing import Any, AsyncGenerator, Dict, Optional
 
 
 async def run_agent(
@@ -50,6 +50,7 @@ async def run_agent(
     files: Optional[list] = None,
     metadata: Optional[Dict[str, Any]] = None,
     user_id: Optional[str] = None,
+    request: Any = None,
 ) -> Dict[str, Any]:
     """Execute a non-streaming agent request."""
     runner = StandardRunner(db)
@@ -65,6 +66,7 @@ async def run_agent(
         files=files,
         metadata=metadata,
         user_id=user_id,
+        request=request,
     )
 
 

src/services/adk/runners/standard_runner.py

@@ -69,6 +69,7 @@ async def run_agent(
         files: Optional[list] = None,
         metadata: Optional[Dict[str, Any]] = None,
         user_id: Optional[str] = None,
+        request: Any = None,
     ) -> Dict[str, Any]:
         """Execute a non-streaming agent request."""
         try:
@@ -97,7 +98,7 @@ async def run_agent(
             # Extension point: runtime context resolution. Default returns
             # None; consumer overrides return an operational context id that
             # is logged here and (in a follow-up) propagated into metrics.
-            context_id = runtime_context.current_context_id(metadata)
+            context_id = runtime_context.current_context_id(request if request is not None else metadata)
             if context_id:
                 logger.info(
                     f"runtime_context resolved id={context_id!r}"