Update telegram_bot.py

telegram_bot.py

@@ -88,26 +88,38 @@ async def handle_streaming_message(update: Update, context: ContextTypes.DEFAULT
         await status_msg.edit_text(f"❌ Error: {str(e)}")
 
 def start_telegram_bot(shared_agent, token="8634464564:AAGL7FzFkMN-Uktf97NKtDs1RFPGxec-HFI"):
-    """Start the Telegram bot with a shared agent instance
+    """Start the Telegram bot with a shared agent instance in a thread-safe way
     
     Args:
         shared_agent: The CodeAgent instance to use for processing messages
         token: Telegram bot token (default provided, can be overridden)
     """
+    import asyncio
+    
     global agent
     agent = shared_agent
     
-    # Create application
-    application = Application.builder().token(token).build()
-    
-    # Register handlers
-    application.add_handler(CommandHandler("start", start))
-    application.add_handler(CommandHandler("help", help_command))
-    application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
+    # Create a new event loop for this thread
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
     
-    # Start bot
-    logger.info("Telegram Bot started!")
-    application.run_polling(allowed_updates=Update.ALL_TYPES)
+    try:
+        # Create application
+        application = Application.builder().token(token).build()
+        
+        # Register handlers
+        application.add_handler(CommandHandler("start", start))
+        application.add_handler(CommandHandler("help", help_command))
+        application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
+        
+        # Start bot with stop_signals=None to avoid signal handler issues in threads
+        logger.info("Telegram Bot started!")
+        application.run_polling(
+            allowed_updates=Update.ALL_TYPES,
+            stop_signals=None  # Disable signal handlers for thread safety
+        )
+    finally:
+        loop.close()
 
 def main():
     """Standalone entry point (for backward compatibility)"""