Update bot.py

bot.py

@@ -178,10 +178,30 @@ async def unban(update: Update, context: ContextTypes.DEFAULT_TYPE):
     try: user_id=int(context.args[0]); await bans_col.delete_one({"user_id":user_id}); await update.message.reply_text(f"Unbanned {user_id}")
     except: await update.message.reply_text("Provide user ID")
 
+async def notify_admin(bot):
+    """Send bot_started message safely with retries."""
+    import asyncio
+    import httpx
+    max_retries = 5
+    delay = 5  # seconds
+    for i in range(max_retries):
+        try:
+            await bot.send_message(chat_id=ADMIN_ID, text='{"status":"bot_started"}')
+            print("✅ Bot started message sent to admin")
+            break
+        except httpx.ConnectError as e:
+            print(f"⚠ Network error on attempt {i+1}: {e}. Retrying in {delay}s...")
+            await asyncio.sleep(delay)
+        except Exception as e:
+            print(f"⚠ Failed to send bot_started message: {e}")
+            break
+
 # --- Main ---
 async def main():
     await init_stats()
     app = Application.builder().token(BOT_TOKEN).build()
+
+    # --- Handlers ---
     app.add_handler(CommandHandler("start", start))
     app.add_handler(CommandHandler("encode", encode))
     app.add_handler(MessageHandler(filters.Document.ALL, handle_document))
@@ -191,11 +211,14 @@ async def main():
     app.add_handler(CommandHandler("ban", ban))
     app.add_handler(CommandHandler("unban", unban))
 
-    # Bot started message to admin
-    await app.bot.send_message(chat_id=ADMIN_ID, text='{"status":"bot_started"}')
-    
+    # --- Send bot_started safely ---
+    import asyncio
+    asyncio.create_task(notify_admin(app.bot))
+
+    # --- Start polling ---
     await app.run_polling()
 
+
 # --- Run Bot ---
 if __name__ == "__main__":
     import asyncio