feat(bots): fix asyncio error and add thread configuration

- Fix asyncio.run() error by using run_in_executor() for sync agent.chat()
- Add reply_in_thread config option (default: False for inline replies)
- Add thread_threshold for auto-threading long responses (default: 500 chars)
- Add INFO logging for message received/sent flow

Author: MervinPraison

src/praisonai-agents/praisonaiagents/bots/config.py

@@ -40,6 +40,8 @@ class BotConfig:
     max_message_length: int = 4096
     retry_attempts: int = 3
     timeout: int = 30
+    reply_in_thread: bool = False  # Default to inline, set True for thread replies
+    thread_threshold: int = 500  # Auto-thread responses longer than this (0 = disabled)
     metadata: Dict[str, Any] = field(default_factory=dict)
 
     def to_dict(self) -> Dict[str, Any]:
@@ -57,6 +59,8 @@ def to_dict(self) -> Dict[str, Any]:
             "max_message_length": self.max_message_length,
             "retry_attempts": self.retry_attempts,
             "timeout": self.timeout,
+            "reply_in_thread": self.reply_in_thread,
+            "thread_threshold": self.thread_threshold,
             "metadata": self.metadata,
         }
 

src/praisonai/praisonai/bots/slack.py

@@ -159,8 +159,21 @@ async def handle_message(event, say):
 
             if should_respond and self._agent:
                 try:
-                    response = self._agent.chat(text)
-                    await self._send_long_message(say, response, thread_ts=event.get("thread_ts") or event.get("ts"))
+                    logger.info(f"Message received: {text[:100]}...")
+                    # Run sync agent.chat() in executor to avoid asyncio.run() conflicts
+                    loop = asyncio.get_event_loop()
+                    response = await loop.run_in_executor(None, self._agent.chat, text)
+                    logger.info(f"Response sent: {response[:100]}...")
+                    
+                    # Determine if we should reply in thread
+                    thread_ts = None
+                    if self.config.reply_in_thread:
+                        thread_ts = event.get("thread_ts") or event.get("ts")
+                    elif self.config.thread_threshold > 0 and len(response) > self.config.thread_threshold:
+                        # Auto-thread long responses
+                        thread_ts = event.get("thread_ts") or event.get("ts")
+                    
+                    await self._send_long_message(say, response, thread_ts=thread_ts)
                 except Exception as e:
                     logger.error(f"Agent error: {e}")
                     await say(f"Error: {str(e)}")
@@ -176,8 +189,21 @@ async def handle_mention(event, say):
 
             if self._agent:
                 try:
-                    response = self._agent.chat(text)
-                    await self._send_long_message(say, response, thread_ts=event.get("thread_ts") or event.get("ts"))
+                    logger.info(f"@mention received: {text[:100]}...")
+                    # Run sync agent.chat() in executor to avoid asyncio.run() conflicts
+                    loop = asyncio.get_event_loop()
+                    response = await loop.run_in_executor(None, self._agent.chat, text)
+                    logger.info(f"Response sent: {response[:100]}...")
+                    
+                    # Determine if we should reply in thread
+                    thread_ts = None
+                    if self.config.reply_in_thread:
+                        thread_ts = event.get("thread_ts") or event.get("ts")
+                    elif self.config.thread_threshold > 0 and len(response) > self.config.thread_threshold:
+                        # Auto-thread long responses
+                        thread_ts = event.get("thread_ts") or event.get("ts")
+                    
+                    await self._send_long_message(say, response, thread_ts=thread_ts)
                 except Exception as e:
                     logger.error(f"Agent error: {e}")
                     await say(f"Error: {str(e)}")