Spaces:

neop3
/

uploaderbot

Runtime error

App Files Files Community

neop3 commited on Mar 8

Commit

b4e5fe0

verified ·

1 Parent(s): fbb5abb

Update app.py

Browse files

Files changed (1) hide show

app.py +12 -337

app.py CHANGED Viewed

@@ -1,344 +1,19 @@
-import collections
-import collections.abc
-if not hasattr(collections, "Iterable"):
-    collections.Iterable = collections.abc.Iterable
-import os
-import sys
-import json
-import logging
-import tempfile
-import asyncio
-import threading
-import time
-import traceback
 from http.server import HTTPServer, BaseHTTPRequestHandler
-from datetime import datetime, timedelta
-# ──────────────────────────────────────────────
-#  LOGGING - En başta olsun
-# ──────────────────────────────────────────────
-logging.basicConfig(
-    format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",
-    level=logging.INFO,
-)
 logger = logging.getLogger(__name__)
-# ──────────────────────────────────────────────
-#  HEALTH CHECK - HER ŞEYDEN ÖNCE BAŞLAT
-# ──────────────────────────────────────────────
-bot_status = "starting"
-class HealthHandler(BaseHTTPRequestHandler):
     def do_GET(self):
         self.send_response(200)
-        self.send_header("Content-Type", "text/html")
-        self.end_headers()
-        html = f"""
-        <html>
-        <head><title>Bot Status</title></head>
-        <body>
-            <h1>Bot Status: {bot_status}</h1>
-            <p>Time: {datetime.now().isoformat()}</p>
-        </body>
-        </html>
-        """
-        self.wfile.write(html.encode())
-    def do_HEAD(self):
-        self.send_response(200)
         self.end_headers()
-    def log_message(self, format, *args):
-        pass  # Sustur
-def start_health_server():
-    port = int(os.environ.get("PORT", 7860))
-    server = HTTPServer(("0.0.0.0", port), HealthHandler)
-    logger.info(f"Health check server started on 0.0.0.0:{port}")
-    server.serve_forever()
-# ★★★ HEALTH SERVER'I HEMEN BAŞLAT ★★★
-# Bu satır modül yüklenirken çalışır - HF bunu görür ve "Running" yapar
-health_thread = threading.Thread(target=start_health_server, daemon=True)
-health_thread.start()
-time.sleep(1)  # Bind olmasını garantile
-logger.info("✅ Health check server is UP")
-# ──────────────────────────────────────────────
-#  ŞİMDİ GERİ KALAN İMPORTLAR
-# ──────────────────────────────────────────────
-try:
-    from pySmartDL import SmartDL
-    from pydrive2.auth import GoogleAuth
-    from pydrive2.drive import GoogleDrive
-    from oauth2client.service_account import ServiceAccountCredentials
-    from telegram import Update
-    from telegram.ext import (
-        ApplicationBuilder,
-        CommandHandler,
-        MessageHandler,
-        filters,
-        ContextTypes,
-    )
-    from apscheduler.schedulers.asyncio import AsyncIOScheduler
-    logger.info("✅ All imports successful")
-except Exception as e:
-    logger.error(f"❌ Import error: {e}")
-    traceback.print_exc()
-    # Health server hala çalışıyor, en azından HF "Running" gösterir
-    bot_status = f"import_error: {e}"
-    while True:
-        time.sleep(3600)
-# ──────────────────────────────────────────────
-#  ENV VARIABLES
-# ──────────────────────────────────────────────
-BOT_TOKEN = os.getenv("BOT_TOKEN")
-GDRIVE_SERVICE_ACCOUNT_JSON = os.getenv("GDRIVE_SERVICE_ACCOUNT_JSON")
-GDRIVE_FOLDER_ID = os.getenv("GDRIVE_FOLDER_ID")
-AUTHORIZED_USER_ID = os.getenv("AUTHORIZED_USER_ID")
-if AUTHORIZED_USER_ID:
-    try:
-        AUTHORIZED_USER_ID = int(AUTHORIZED_USER_ID)
-    except ValueError:
-        logger.error("AUTHORIZED_USER_ID is not a valid integer")
-        AUTHORIZED_USER_ID = None
-logger.info(f"BOT_TOKEN set: {bool(BOT_TOKEN)}")
-logger.info(f"GDRIVE_SERVICE_ACCOUNT_JSON set: {bool(GDRIVE_SERVICE_ACCOUNT_JSON)}")
-logger.info(f"GDRIVE_FOLDER_ID set: {bool(GDRIVE_FOLDER_ID)}")
-logger.info(f"AUTHORIZED_USER_ID: {AUTHORIZED_USER_ID}")
-# ──────────────────────────────────────────────
-#  GLOBALS
-# ──────────────────────────────────────────────
-drive_client = None
-processing_lock = None
-scheduler = None
-# ───────────────────────────────────────���──────
-#  GOOGLE DRIVE AUTH
-# ──────────────────────────────────────────────
-def get_gdrive_client():
-    global drive_client
-    if not GDRIVE_SERVICE_ACCOUNT_JSON:
-        logger.error("GDRIVE_SERVICE_ACCOUNT_JSON is empty")
-        return None
-    try:
-        with tempfile.NamedTemporaryFile(mode="w", delete=False, suffix=".json") as tmp:
-            tmp.write(GDRIVE_SERVICE_ACCOUNT_JSON)
-            tmp_path = tmp.name
-        scope = ["https://www.googleapis.com/auth/drive"]
-        gauth = GoogleAuth()
-        gauth.auth_method = "service"
-        gauth.credentials = ServiceAccountCredentials.from_json_keyfile_name(tmp_path, scope)
-        drive_client = GoogleDrive(gauth)
-        os.unlink(tmp_path)
-        logger.info("✅ Google Drive authenticated")
-        return drive_client
-    except Exception as e:
-        logger.error(f"❌ Google Drive auth error: {e}")
-        traceback.print_exc()
-        return None
-# ──────────────────────────────────────────────
-#  AUTO DELETE
-# ──────────────────────────────────────────────
-async def delete_from_drive(file_id: str):
-    try:
-        global drive_client
-        if not drive_client:
-            drive_client = await asyncio.to_thread(get_gdrive_client)
-        if drive_client:
-            gfile = await asyncio.to_thread(drive_client.CreateFile, {"id": file_id})
-            await asyncio.to_thread(gfile.Delete)
-            logger.info(f"🗑 Deleted {file_id} from Drive")
-    except Exception as e:
-        logger.error(f"Delete error ({file_id}): {e}")
-# ──────────────────────────────────────────────
-#  DOWNLOAD & UPLOAD
-# ──────────────────────────────────────────────
-def download_file(url, dest_dir):
-    obj = SmartDL(url, dest_dir, progress_bar=False, timeout=120)
-    obj.start()
-    return obj
-def upload_file(file_path, file_name):
-    global drive_client
-    if not drive_client:
-        drive_client = get_gdrive_client()
-    if not drive_client:
-        raise RuntimeError("Drive client not available")
-    metadata = {"title": file_name}
-    if GDRIVE_FOLDER_ID:
-        metadata["parents"] = [{"id": GDRIVE_FOLDER_ID}]
-    gfile = drive_client.CreateFile(metadata)
-    gfile.SetContentFile(file_path)
-    gfile.Upload()
-    return gfile
-# ──────────────────────────────────────────────
-#  TELEGRAM HANDLERS
-# ──────────────────────────────────────────────
-async def cmd_start(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    if AUTHORIZED_USER_ID and update.effective_user.id != AUTHORIZED_USER_ID:
-        return
-    await update.message.reply_text(
-        "Merhaba! Bana bir direkt indirme linki gönder, "
-        "senin için Google Drive'a yükleyeyim. 🚀"
-    )
-async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    global processing_lock, scheduler
-    if AUTHORIZED_USER_ID and update.effective_user.id != AUTHORIZED_USER_ID:
-        return
-    url = update.message.text.strip()
-    if not url.startswith(("http://", "https://")):
-        await update.message.reply_text("⛔ Geçersiz link.")
-        return
-    async with processing_lock:
-        status_msg = await update.message.reply_text("⏳ Başlatılıyor...")
-        file_path = None
-        try:
-            dest = os.path.join(os.getcwd(), "downloads")
-            os.makedirs(dest, exist_ok=True)
-            await status_msg.edit_text("📥 İndiriliyor...")
-            obj = await asyncio.to_thread(download_file, url, dest)
-            if not obj.isSuccessful():
-                await status_msg.edit_text("❌ İndirme başarısız.")
-                return
-            file_path = obj.get_dest()
-            file_name = os.path.basename(file_path)
-            file_size = os.path.getsize(file_path)
-            if file_size > 5 * 1024 * 1024 * 1024:
-                await status_msg.edit_text(
-                    f"⚠️ Dosya çok büyük ({file_size / (1024**3):.2f} GB). Max 5GB."
-                )
-                os.remove(file_path)
-                file_path = None
-                return
-            size_str = (
-                f"{file_size / (1024**2):.1f} MB"
-                if file_size > 1024 * 1024
-                else f"{file_size / 1024:.1f} KB"
-            )
-            await status_msg.edit_text(
-                f"✅ İndirildi: `{file_name}` ({size_str})\n📤 Drive'a yükleniyor...",
-                parse_mode="Markdown",
-            )
-            gfile = await asyncio.to_thread(upload_file, file_path, file_name)
-            file_id = gfile["id"]
-            drive_link = gfile.get(
-                "alternateLink",
-                f"https://drive.google.com/file/d/{file_id}/view",
-            )
-            await status_msg.edit_text(
-                f"🚀 Yükleme başarılı!\n\n"
-                f"📁 `{file_name}`\n"
-                f"📦 {size_str}\n"
-                f"🔗 {drive_link}\n\n"
-                f"⏱ 2 saat sonra otomatik silinecek.",
-                parse_mode="Markdown",
-            )
-            if file_path and os.path.exists(file_path):
-                os.remove(file_path)
-                file_path = None
-            run_date = datetime.now() + timedelta(hours=2)
-            scheduler.add_job(delete_from_drive, "date", run_date=run_date, args=[file_id])
-        except Exception as e:
-            logger.error(f"Processing error: {e}", exc_info=True)
-            try:
-                await status_msg.edit_text(f"❌ Hata: `{e}`", parse_mode="Markdown")
-            except Exception:
-                pass
-        finally:
-            if file_path and os.path.exists(file_path):
-                try:
-                    os.remove(file_path)
-                except OSError:
-                    pass
-# ──────────────────────────────────────────────
-#  MAIN
-# ──────────────────────────────────────────────
-def main():
-    global processing_lock, scheduler, bot_status
-    if not BOT_TOKEN:
-        logger.error("❌ BOT_TOKEN not set!")
-        bot_status = "error: no BOT_TOKEN"
-        while True:
-            time.sleep(3600)
-    try:
-        # Google Drive
-        get_gdrive_client()
-        # Telegram app
-        application = (
-            ApplicationBuilder()
-            .token(BOT_TOKEN)
-            .connect_timeout(30)
-            .read_timeout(30)
-            .write_timeout(30)
-            .build()
-        )
-        application.add_handler(CommandHandler("start", cmd_start))
-        application.add_handler(
-            MessageHandler(filters.TEXT & (~filters.COMMAND), handle_message)
-        )
-        # post_init: event loop hazır, lock ve scheduler başlat
-        async def post_init(app):
-            global processing_lock, scheduler, bot_status
-            processing_lock = asyncio.Lock()
-            scheduler = AsyncIOScheduler()
-            scheduler.start()
-            bot_status = "running"
-            logger.info("✅ Bot fully initialized - scheduler & lock ready")
-        application.post_init = post_init
-        logger.info("🤖 Starting polling...")
-        bot_status = "polling"
-        application.run_polling(
-            allowed_updates=Update.ALL_TYPES,
-            drop_pending_updates=True,
-        )
-    except Exception as e:
-        logger.error(f"❌ Fatal error: {e}", exc_info=True)
-        bot_status = f"fatal_error: {e}"
-        # Health server hala çalışıyor, container ölmesin
-        while True:
-            time.sleep(3600)
-if __name__ == "__main__":
-    main()

 from http.server import HTTPServer, BaseHTTPRequestHandler
+import logging
+logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
+class Handler(BaseHTTPRequestHandler):
     def do_GET(self):
         self.send_response(200)
+        self.send_header("Content-Type", "text/plain")
         self.end_headers()
+        self.wfile.write(b"OK")
+    def log_message(self, *args):
+        pass
+logger.info("Starting server on 7860...")
+server = HTTPServer(("0.0.0.0", 7860), Handler)
+logger.info("Server is running!")
+server.serve_forever()