feat: add assistant_thread_started event listener with suggested prompts

Author: mwbrooks

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

@@ -2,10 +2,12 @@
 
 from .app_home_opened import handle_app_home_opened
 from .app_mentioned import handle_app_mentioned
+from .assistant_thread_started import handle_assistant_thread_started
 from .message_im import handle_message_im
 
 
 def register(app: AsyncApp):
     app.event("app_home_opened")(handle_app_home_opened)
     app.event("app_mention")(handle_app_mentioned)
+    app.event("assistant_thread_started")(handle_assistant_thread_started)
     app.event("message")(handle_message_im)

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

@@ -0,0 +1,28 @@
+from logging import Logger
+
+from slack_sdk.web.async_client import AsyncWebClient
+
+SUGGESTED_PROMPTS = [
+    {"title": "Reset Password", "message": "I need to reset my password"},
+    {"title": "Request Access", "message": "I need access to a system or tool"},
+    {"title": "Network Issues", "message": "I'm having network connectivity issues"},
+]
+
+
+async def handle_assistant_thread_started(
+    client: AsyncWebClient, event: dict, logger: Logger
+):
+    """Handle assistant thread started events by setting suggested prompts."""
+    assistant_thread = event.get("assistant_thread", {})
+    channel_id = assistant_thread.get("channel_id")
+    thread_ts = assistant_thread.get("thread_ts")
+
+    try:
+        await client.assistant_threads_setSuggestedPrompts(
+            channel_id=channel_id,
+            thread_ts=thread_ts,
+            title="How can I help you today?",
+            prompts=SUGGESTED_PROMPTS,
+        )
+    except Exception as e:
+        logger.exception(f"Failed to handle assistant thread started: {e}")

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

@@ -2,10 +2,12 @@
 
 from .app_home_opened import handle_app_home_opened
 from .app_mentioned import handle_app_mentioned
+from .assistant_thread_started import handle_assistant_thread_started
 from .message_im import handle_message_im
 
 
 def register(app: App):
     app.event("app_home_opened")(handle_app_home_opened)
     app.event("app_mention")(handle_app_mentioned)
+    app.event("assistant_thread_started")(handle_assistant_thread_started)
     app.event("message")(handle_message_im)

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

@@ -0,0 +1,26 @@
+from logging import Logger
+
+from slack_sdk import WebClient
+
+SUGGESTED_PROMPTS = [
+    {"title": "Reset Password", "message": "I need to reset my password"},
+    {"title": "Request Access", "message": "I need access to a system or tool"},
+    {"title": "Network Issues", "message": "I'm having network connectivity issues"},
+]
+
+
+def handle_assistant_thread_started(client: WebClient, event: dict, logger: Logger):
+    """Handle assistant thread started events by setting suggested prompts."""
+    assistant_thread = event.get("assistant_thread", {})
+    channel_id = assistant_thread.get("channel_id")
+    thread_ts = assistant_thread.get("thread_ts")
+
+    try:
+        client.assistant_threads_setSuggestedPrompts(
+            channel_id=channel_id,
+            thread_ts=thread_ts,
+            title="How can I help you today?",
+            prompts=SUGGESTED_PROMPTS,
+        )
+    except Exception as e:
+        logger.exception(f"Failed to handle assistant thread started: {e}")

pydantic-ai/listeners/events/__init__.py

@@ -2,10 +2,12 @@
 
 from .app_home_opened import handle_app_home_opened
 from .app_mentioned import handle_app_mentioned
+from .assistant_thread_started import handle_assistant_thread_started
 from .message_im import handle_message_im
 
 
 def register(app: App):
     app.event("app_home_opened")(handle_app_home_opened)
     app.event("app_mention")(handle_app_mentioned)
+    app.event("assistant_thread_started")(handle_assistant_thread_started)
     app.event("message")(handle_message_im)

pydantic-ai/listeners/events/assistant_thread_started.py

@@ -0,0 +1,26 @@
+from logging import Logger
+
+from slack_sdk import WebClient
+
+SUGGESTED_PROMPTS = [
+    {"title": "Reset Password", "message": "I need to reset my password"},
+    {"title": "Request Access", "message": "I need access to a system or tool"},
+    {"title": "Network Issues", "message": "I'm having network connectivity issues"},
+]
+
+
+def handle_assistant_thread_started(client: WebClient, event: dict, logger: Logger):
+    """Handle assistant thread started events by setting suggested prompts."""
+    assistant_thread = event.get("assistant_thread", {})
+    channel_id = assistant_thread.get("channel_id")
+    thread_ts = assistant_thread.get("thread_ts")
+
+    try:
+        client.assistant_threads_setSuggestedPrompts(
+            channel_id=channel_id,
+            thread_ts=thread_ts,
+            title="How can I help you today?",
+            prompts=SUGGESTED_PROMPTS,
+        )
+    except Exception as e:
+        logger.exception(f"Failed to handle assistant thread started: {e}")