feat: use BoltAgent for chat_stream in all implementations

Author: mwbrooks

claude-agent-sdk/listeners/events/app_mentioned.py

@@ -2,6 +2,7 @@
 import re
 from logging import Logger
 
+from slack_bolt.agent.async_agent import AsyncBoltAgent
 from slack_bolt.context.say.async_say import AsyncSay
 from slack_sdk.web.async_client import AsyncWebClient
 
@@ -22,7 +23,7 @@
 
 
 async def handle_app_mentioned(
-    client: AsyncWebClient, event: dict, logger: Logger, say: AsyncSay
+    client: AsyncWebClient, event: dict, agent: AsyncBoltAgent, logger: Logger, say: AsyncSay
 ):
     """Handle @Casey mentions in channels."""
     try:
@@ -73,9 +74,9 @@ async def handle_app_mentioned(
         )
 
         # Stream response in thread with feedback buttons
-        streamer = await client.chat_stream(
+        streamer = await agent.chat_stream(
             channel=channel_id,
-            recipient_team_id=team_id,
+            recipient_team_id=team_id, # chat_stream helper cannot infer event["team"] from client
             recipient_user_id=user_id,
             thread_ts=thread_ts,
         )

claude-agent-sdk/listeners/events/message.py

@@ -1,6 +1,7 @@
 import random
 from logging import Logger
 
+from slack_bolt.agent.async_agent import AsyncBoltAgent
 from slack_bolt.context.say.async_say import AsyncSay
 from slack_sdk.web.async_client import AsyncWebClient
 
@@ -21,7 +22,7 @@
 
 
 async def handle_message(
-    client: AsyncWebClient, event: dict, logger: Logger, say: AsyncSay
+    client: AsyncWebClient, event: dict, agent: AsyncBoltAgent, logger: Logger, say: AsyncSay
 ):
     """Handle direct messages sent to Casey."""
     # Skip bot messages and message subtypes (edits, deletes, etc.)
@@ -34,7 +35,6 @@ async def handle_message(
 
     try:
         channel_id = event["channel"]
-        team_id = event.get("team")
         text = event.get("text", "")
         thread_ts = event.get("thread_ts") or event["ts"]
         user_id = event.get("user")
@@ -70,12 +70,7 @@ async def handle_message(
         )
 
         # Stream response in thread with feedback buttons
-        streamer = await client.chat_stream(
-            channel=channel_id,
-            recipient_team_id=team_id,
-            recipient_user_id=user_id,
-            thread_ts=thread_ts,
-        )
+        streamer = await agent.chat_stream()
         await streamer.append(markdown_text=response_text)
         feedback_blocks = create_feedback_block()
         await streamer.stop(blocks=feedback_blocks)

claude-agent-sdk/listeners/views/issue_modal.py

@@ -1,6 +1,7 @@
 from logging import Logger
 
 from slack_bolt import Ack
+from slack_bolt.agent.async_agent import AsyncBoltAgent
 from slack_sdk.web.async_client import AsyncWebClient
 
 from agent import run_casey_agent
@@ -9,7 +10,7 @@
 
 
 async def handle_issue_submission(
-    ack: Ack, body: dict, client: AsyncWebClient, logger: Logger
+    ack: Ack, body: dict, client: AsyncWebClient, agent: AsyncBoltAgent, logger: Logger
 ):
     """Handle modal submission: open DM, post issue, and run Casey agent."""
     await ack()
@@ -60,7 +61,7 @@ async def handle_issue_submission(
         response_text, new_session_id = await run_casey_agent(user_message)
 
         # Stream the response in thread with feedback buttons
-        streamer = await client.chat_stream(
+        streamer = await agent.chat_stream(
             channel=channel_id,
             recipient_team_id=team_id,
             recipient_user_id=user_id,

openai-agents-sdk/listeners/events/app_mentioned.py

@@ -3,7 +3,7 @@
 from logging import Logger
 
 from agents import Runner
-from slack_bolt import Say
+from slack_bolt import BoltAgent, Say
 from slack_sdk import WebClient
 
 from agent import CaseyDeps, casey_agent
@@ -22,7 +22,7 @@
 CONTEXTUAL_EMOJIS = ["+1", "raised_hands", "rocket", "tada", "bulb", "fire"]
 
 
-def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Say):
+def handle_app_mentioned(client: WebClient, event: dict, agent: BoltAgent, logger: Logger, say: Say):
     """Handle @Casey mentions in channels."""
     try:
         channel_id = event["channel"]
@@ -81,9 +81,9 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
         result = Runner.run_sync(casey_agent, input=input_items, context=deps)
 
         # Stream response in thread with feedback buttons
-        streamer = client.chat_stream(
+        streamer = agent.chat_stream(
             channel=channel_id,
-            recipient_team_id=team_id,
+            recipient_team_id=team_id, # chat_stream helper cannot infer event["team"] from client
             recipient_user_id=user_id,
             thread_ts=thread_ts,
         )

openai-agents-sdk/listeners/events/message.py

@@ -2,7 +2,7 @@
 from logging import Logger
 
 from agents import Runner
-from slack_bolt import Say
+from slack_bolt import BoltAgent, Say
 from slack_sdk import WebClient
 
 from agent import CaseyDeps, casey_agent
@@ -21,7 +21,7 @@
 CONTEXTUAL_EMOJIS = ["+1", "raised_hands", "rocket", "tada", "bulb", "fire"]
 
 
-def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
+def handle_message(client: WebClient, event: dict, agent: BoltAgent, logger: Logger, say: Say):
     """Handle direct messages sent to Casey."""
     # Skip bot messages and message subtypes (edits, deletes, etc.)
     if event.get("bot_id") or event.get("subtype"):
@@ -33,7 +33,6 @@ def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
 
     try:
         channel_id = event["channel"]
-        team_id = event.get("team")
         text = event.get("text", "")
         thread_ts = event.get("thread_ts") or event["ts"]
         user_id = event["user"]
@@ -79,12 +78,7 @@ def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
         result = Runner.run_sync(casey_agent, input=input_items, context=deps)
 
         # Stream response in thread with feedback buttons
-        streamer = client.chat_stream(
-            channel=channel_id,
-            recipient_team_id=team_id,
-            recipient_user_id=user_id,
-            thread_ts=thread_ts,
-        )
+        streamer = agent.chat_stream()
         streamer.append(markdown_text=result.final_output)
         feedback_blocks = create_feedback_block()
         streamer.stop(blocks=feedback_blocks)

openai-agents-sdk/listeners/views/issue_modal.py

@@ -1,15 +1,15 @@
 from logging import Logger
 
 from agents import Runner
-from slack_bolt import Ack
+from slack_bolt import Ack, BoltAgent
 from slack_sdk import WebClient
 
 from agent import CaseyDeps, casey_agent
 from conversation import conversation_store
 from listeners.views.feedback_block import create_feedback_block
 
 
-def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Logger):
+def handle_issue_submission(ack: Ack, body: dict, client: WebClient, agent: BoltAgent, logger: Logger):
     """Handle modal submission: open DM, post issue, and run Casey agent."""
     ack()
 
@@ -65,7 +65,7 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
         result = Runner.run_sync(casey_agent, input=user_message, context=deps)
 
         # Stream the response in thread with feedback buttons
-        streamer = client.chat_stream(
+        streamer = agent.chat_stream(
             channel=channel_id,
             recipient_team_id=team_id,
             recipient_user_id=user_id,

pydantic-ai/listeners/events/app_mentioned.py

@@ -2,7 +2,7 @@
 import re
 from logging import Logger
 
-from slack_bolt import Say
+from slack_bolt import BoltAgent, Say
 from slack_sdk import WebClient
 
 from agent import DEFAULT_MODEL, CaseyDeps, casey_agent
@@ -21,7 +21,7 @@
 CONTEXTUAL_EMOJIS = ["+1", "raised_hands", "rocket", "tada", "bulb", "fire"]
 
 
-def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Say):
+def handle_app_mentioned(client: WebClient, event: dict, agent: BoltAgent, logger: Logger, say: Say):
     """Handle @Casey mentions in channels."""
     try:
         channel_id = event["channel"]
@@ -80,9 +80,9 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
         )
 
         # Stream response in thread with feedback buttons
-        streamer = client.chat_stream(
+        streamer = agent.chat_stream(
             channel=channel_id,
-            recipient_team_id=team_id,
+            recipient_team_id=team_id, # chat_stream helper cannot infer event["team"] from client
             recipient_user_id=user_id,
             thread_ts=thread_ts,
         )

pydantic-ai/listeners/events/message.py

@@ -1,7 +1,7 @@
 import random
 from logging import Logger
 
-from slack_bolt import Say
+from slack_bolt import BoltAgent, Say
 from slack_sdk import WebClient
 
 from agent import DEFAULT_MODEL, CaseyDeps, casey_agent
@@ -20,7 +20,7 @@
 CONTEXTUAL_EMOJIS = ["+1", "raised_hands", "rocket", "tada", "bulb", "fire"]
 
 
-def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
+def handle_message(client: WebClient, event: dict, agent: BoltAgent, logger: Logger, say: Say):
     """Handle direct messages sent to Casey."""
     # Skip bot messages and message subtypes (edits, deletes, etc.)
     if event.get("bot_id") or event.get("subtype"):
@@ -32,7 +32,6 @@ def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
 
     try:
         channel_id = event["channel"]
-        team_id = event.get("team")
         text = event.get("text", "")
         thread_ts = event.get("thread_ts") or event["ts"]
         user_id = event["user"]
@@ -77,12 +76,7 @@ def handle_message(client: WebClient, event: dict, logger: Logger, say: Say):
         )
 
         # Stream response in thread with feedback buttons
-        streamer = client.chat_stream(
-            channel=channel_id,
-            recipient_team_id=team_id,
-            recipient_user_id=user_id,
-            thread_ts=thread_ts,
-        )
+        streamer = agent.chat_stream()
         streamer.append(markdown_text=result.output)
         feedback_blocks = create_feedback_block()
         streamer.stop(blocks=feedback_blocks)

pydantic-ai/listeners/views/issue_modal.py

@@ -1,14 +1,14 @@
 from logging import Logger
 
-from slack_bolt import Ack
+from slack_bolt import Ack, BoltAgent
 from slack_sdk import WebClient
 
 from agent import DEFAULT_MODEL, CaseyDeps, casey_agent
 from conversation import conversation_store
 from listeners.views.feedback_block import create_feedback_block
 
 
-def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Logger):
+def handle_issue_submission(ack: Ack, body: dict, client: WebClient, agent: BoltAgent, logger: Logger):
     """Handle modal submission: open DM, post issue, and run Casey agent."""
     ack()
 
@@ -64,7 +64,7 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
         result = casey_agent.run_sync(user_message, model=DEFAULT_MODEL, deps=deps)
 
         # Stream the response in thread with feedback buttons
-        streamer = client.chat_stream(
+        streamer = agent.chat_stream(
             channel=channel_id,
             recipient_team_id=team_id,
             recipient_user_id=user_id,