feat: use chat_stream for agent responses

Replace chat_postMessage with chat_stream for streaming agent responses
to Slack. Instant messages like errors and empty-mention replies still
use say. Feedback blocks are attached via streamer.stop().

Author: mwbrooks

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

@@ -27,8 +27,10 @@ async def handle_app_mentioned(
     """Handle @Casey mentions in channels."""
     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")
 
         # Strip the bot mention from the text
         cleaned_text = re.sub(r"<@[A-Z0-9]+>", "", text).strip()
@@ -70,21 +72,16 @@ async def handle_app_mentioned(
             cleaned_text, session_id=existing_session_id
         )
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": response_text,
-            },
-            *feedback_blocks,
-        ]
-        await client.chat_postMessage(
+        # 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,
-            text=response_text,
-            blocks=response_blocks,
         )
+        await streamer.append(markdown_text=response_text)
+        feedback_blocks = create_feedback_block()
+        await streamer.stop(blocks=feedback_blocks)
 
         # Store session ID for future context
         if new_session_id:

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

@@ -34,8 +34,10 @@ async def handle_message_im(
 
     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")
 
         # Set assistant thread status with loading messages
         await client.assistant_threads_setStatus(
@@ -67,21 +69,16 @@ async def handle_message_im(
             text, session_id=existing_session_id
         )
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": response_text,
-            },
-            *feedback_blocks,
-        ]
-        await client.chat_postMessage(
+        # 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,
-            text=response_text,
-            blocks=response_blocks,
         )
+        await streamer.append(markdown_text=response_text)
+        feedback_blocks = create_feedback_block()
+        await streamer.stop(blocks=feedback_blocks)
 
         # Store session ID for future context
         if new_session_id:

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

@@ -15,6 +15,7 @@ async def handle_issue_submission(
     await ack()
 
     try:
+        team_id = body["user"]["team_id"]
         user_id = body["user"]["id"]
         values = body["view"]["state"]["values"]
         category = values["category_block"]["category_select"]["selected_option"][
@@ -58,21 +59,16 @@ async def handle_issue_submission(
         # Run the agent
         response_text, new_session_id = await run_casey_agent(user_message)
 
-        # Post the response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": response_text,
-            },
-            *feedback_blocks,
-        ]
-        await client.chat_postMessage(
+        # Stream the 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,
-            text=response_text,
-            blocks=response_blocks,
         )
+        await streamer.append(markdown_text=response_text)
+        feedback_blocks = create_feedback_block()
+        await streamer.stop(blocks=feedback_blocks)
 
         # Store session ID for future context
         if new_session_id:

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

@@ -26,6 +26,7 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
     """Handle @Casey mentions in channels."""
     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,21 +80,16 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
         )
         result = Runner.run_sync(casey_agent, input=input_items, context=deps)
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.final_output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # 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,
-            text=result.final_output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.final_output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.to_input_list())

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

@@ -33,6 +33,7 @@ def handle_message_im(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,21 +78,16 @@ def handle_message_im(client: WebClient, event: dict, logger: Logger, say: Say):
         )
         result = Runner.run_sync(casey_agent, input=input_items, context=deps)
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.final_output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # 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,
-            text=result.final_output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.final_output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.to_input_list())

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

@@ -14,6 +14,7 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
     ack()
 
     try:
+        team_id = body["user"]["team_id"]
         user_id = body["user"]["id"]
         values = body["view"]["state"]["values"]
         category = values["category_block"]["category_select"]["selected_option"][
@@ -63,21 +64,16 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
         )
         result = Runner.run_sync(casey_agent, input=user_message, context=deps)
 
-        # Post the response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.final_output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # Stream the 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,
-            text=result.final_output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.final_output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.to_input_list())

pydantic-ai/listeners/events/app_mentioned.py

@@ -25,6 +25,7 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
     """Handle @Casey mentions in channels."""
     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"]
@@ -78,21 +79,16 @@ def handle_app_mentioned(client: WebClient, event: dict, logger: Logger, say: Sa
             message_history=history,
         )
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # 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,
-            text=result.output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.all_messages())

pydantic-ai/listeners/events/message_im.py

@@ -32,6 +32,7 @@ def handle_message_im(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"]
@@ -75,21 +76,16 @@ def handle_message_im(client: WebClient, event: dict, logger: Logger, say: Say):
             message_history=history,
         )
 
-        # Post response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # 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,
-            text=result.output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.all_messages())

pydantic-ai/listeners/views/issue_modal.py

@@ -13,6 +13,7 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
     ack()
 
     try:
+        team_id = body["user"]["team_id"]
         user_id = body["user"]["id"]
         values = body["view"]["state"]["values"]
         category = values["category_block"]["category_select"]["selected_option"][
@@ -62,21 +63,16 @@ def handle_issue_submission(ack: Ack, body: dict, client: WebClient, logger: Log
         )
         result = casey_agent.run_sync(user_message, model=DEFAULT_MODEL, deps=deps)
 
-        # Post the response in thread with feedback buttons
-        feedback_blocks = create_feedback_block()
-        response_blocks = [
-            {
-                "type": "markdown",
-                "text": result.output,
-            },
-            *feedback_blocks,
-        ]
-        client.chat_postMessage(
+        # Stream the 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,
-            text=result.output,
-            blocks=response_blocks,
         )
+        streamer.append(markdown_text=result.output)
+        feedback_blocks = create_feedback_block()
+        streamer.stop(blocks=feedback_blocks)
 
         # Store conversation history
         conversation_store.set_history(channel_id, thread_ts, result.all_messages())