Update app.py

app.py

@@ -299,23 +299,25 @@ async def health_handler(request: Request):
     return JSONResponse({"status": "ok"})
 
 # =========================================================
-# Initialize Telegram on a dedicated loop and set webhook
+# Async startup handler — runs on FastAPI's own event loop
 # =========================================================
-def init_telegram_blocking():
-    async def _init():
-        init_db()
-        await telegram_app.initialize()
-        await telegram_app.start()
-        webhook_url = f"{WEBHOOK_URL}/webhook/{TELEGRAM_BOT_TOKEN}"
-        await telegram_app.bot.set_webhook(url=webhook_url, drop_pending_updates=True)
-        logger.info(f"✅ Webhook set: {webhook_url}")
-    asyncio.run(_init())
+async def on_startup():
+    """Initialize Telegram on the same loop that Uvicorn uses."""
+    init_db()
+    await telegram_app.initialize()
+    await telegram_app.start()
+    webhook_url = f"{WEBHOOK_URL}/webhook/{TELEGRAM_BOT_TOKEN}"
+    await telegram_app.bot.set_webhook(url=webhook_url, drop_pending_updates=True)
+    logger.info(f"✅ Webhook set: {webhook_url}")
+
+# Register the startup handler on the underlying FastAPI app
+demo.app.add_event_handler("startup", on_startup)
 
 # =========================================================
 # Main
 # =========================================================
 if __name__ == "__main__":
-    # 1. Launch Gradio: no SSR (avoids Node proxy on 7860), no threading lock (so we can inject routes)
+    # 1. Launch Gradio: no SSR (avoids Node proxy on 7860), no threading lock
     demo.launch(
         server_name="0.0.0.0",
         server_port=7860,
@@ -334,8 +336,6 @@ if __name__ == "__main__":
     )
     live_app.build_middleware_stack()
 
-    # 3. Initialize Telegram + set webhook (safe: no polling thread)
-    init_telegram_blocking()
-
-    # 4. Keep process alive
+    # 3. Keep process alive — the startup handler (on_startup) will fire
+    #    automatically on Uvicorn's event loop and set the webhook.
     demo.block_thread()