Create bot.py

bot.py

@@ -0,0 +1,48 @@
+import os, io, tempfile, random, shutil, base64, subprocess, sys, zipfile
+from pathlib import Path
+from fastapi import FastAPI, Request
+from telegram import Update
+from telegram.ext import Application, CommandHandler, MessageHandler, filters
+from motor.motor_asyncio import AsyncIOMotorClient
+import uvicorn
+from config import BOT_TOKEN, ADMIN_ID, MONGO_URI, DB_NAME
+
+# --- MongoDB ---
+mongo_client = AsyncIOMotorClient(MONGO_URI)
+db = mongo_client[DB_NAME]
+stats_col = db["stats"]
+
+async def init_stats():
+    if not await stats_col.find_one({"_id":"encryption_count"}):
+        await stats_col.insert_one({"_id":"encryption_count","count":0})
+
+# --- Bot setup ---
+app = FastAPI()
+bot_app = Application.builder().token(BOT_TOKEN).build()
+
+# --- Handlers ---
+async def start(update, context):
+    await update.message.reply_text("🤖 Hello! Bot is running via Cloudflare Worker + FastAPI")
+
+async def echo_doc(update, context):
+    await update.message.reply_text("📄 Got your document!")
+
+bot_app.add_handler(CommandHandler("start", start))
+bot_app.add_handler(MessageHandler(filters.Document.ALL, echo_doc))
+
+# --- /poll route (used by Worker) ---
+@app.post("/poll")
+async def poll_endpoint(request: Request):
+    data = await request.json()
+    update = Update.de_json(data, bot_app.bot)
+    await bot_app.update_queue.put(update)
+    return {"ok": True}
+
+@app.get("/")
+async def home():
+    return {"ok": True, "message": "Backend online!"}
+
+if __name__ == "__main__":
+    import asyncio
+    asyncio.run(init_stats())
+    uvicorn.run(app, host="0.0.0.0", port=int(os.environ.get("PORT", 7860)))