feat: remove async, keep stream

Author: kieran-wilkinson-4

packages/slackBotFunction/app/handler.py

@@ -6,7 +6,6 @@
 2. Processes async operations when invoked by itself to avoid timeouts
 """
 
-import asyncio
 from slack_bolt.adapter.aws_lambda import SlackRequestHandler
 from aws_lambda_powertools.utilities.typing import LambdaContext
 
@@ -42,10 +41,9 @@ def handler(event: dict, context: LambdaContext) -> dict:
     When subsequent actions or events are processed, this is looked up, and if it exists, then the pull request lambda
     is triggered with either pull_request_event or pull_request_action
     """
-    loop = asyncio.get_event_loop()
     # direct invocation bypasses slack infrastructure entirely
     if event.get("invocation_type") == "direct":
-        return loop.run_until_complete(handle_direct_invocation(event, context))
+        return handle_direct_invocation(event, context)
 
     app = get_app(logger=logger)
     # handle pull request processing requests
@@ -68,10 +66,10 @@ def handler(event: dict, context: LambdaContext) -> dict:
 
     # handle Slack webhook requests
     slack_handler = SlackRequestHandler(app=app)
-    return loop.run_until_complete(slack_handler.handle(event=event, context=context))
+    return slack_handler.handle(event=event, context=context)
 
 
-async def handle_direct_invocation(event: dict[str, Any], context: LambdaContext) -> DirectInvocationResponse:
+def handle_direct_invocation(event: dict[str, Any], context: LambdaContext) -> DirectInvocationResponse:
     """direct lambda invocation for ai assistance - bypasses slack entirely"""
     try:
         # validate request structure using type guard
@@ -84,7 +82,7 @@ async def handle_direct_invocation(event: dict[str, Any], context: LambdaContext
         # shared logic: same AI processing as slack handlers use
         from app.services.ai_processor import process_ai_query
 
-        ai_response = await process_ai_query(query, session_id)
+        ai_response = process_ai_query(query, session_id)
 
         return create_success_response(
             text=ai_response["text"],

packages/slackBotFunction/app/services/ai_processor.py

@@ -13,7 +13,7 @@
 logger = get_logger()
 
 
-async def process_ai_query(user_query: str, session_id: str | None = None) -> AIProcessorResponse:
+def process_ai_query(user_query: str, session_id: str | None = None) -> AIProcessorResponse:
     """shared AI processing logic for both slack and direct invocation"""
     # reformulate: improves vector search quality in knowledge base
     reformulated_query = reformulate_query(user_query)
@@ -29,7 +29,7 @@ async def process_ai_query(user_query: str, session_id: str | None = None) -> AI
     session_id_from_response = bedrock_response.get("sessionId")
 
     # iterate through bedrock stream events to build complete response
-    async for event in bedrock_response["stream"]:
+    for event in bedrock_response["stream"]:
         logger.info(
             "[New] response from bedrock",
             extra={"session_id": session_id_from_response, "event": event},