Update app.py

app.py

@@ -6,7 +6,6 @@ from telethon.errors import SessionPasswordNeededError, PhoneCodeInvalidError, A
 from huggingface_hub import upload_file
 from dotenv import load_dotenv
 from flask import Flask, request, render_template, jsonify
-import threading
 
 # === Load secrets from .env ===
 load_dotenv()
@@ -16,7 +15,7 @@ API_HASH = os.getenv("API_HASH")
 HF_TOKEN = os.getenv("HF_TOKEN")
 CHANNEL = os.getenv("CHANNEL_USERNAME")
 REPO_ID = os.getenv("DATASET_REPO")
-DATA_PATH = "AEffects"
+DATA_PATH = "telegram_uploads"
 
 # === Logging setup ===
 logging.basicConfig(
@@ -73,17 +72,12 @@ async def process_filenames(name_input):
             await client.connect()
         
         if not await client.is_user_authorized():
-            # Attempt to re-authorize if not authorized
-            # This part needs user interaction, which is not possible in this setup.
-            # For a web app, you'd redirect to a login page.
-            # For now, we'll just return an error.
             return "❌ Error: Telegram client not authorized. Please ensure your session is valid and authenticated."
         
         filenames = [name.strip().lower() for name in name_input.replace(",", "\n").splitlines() if name.strip()]
         results = []
         found = set()
 
-        # Use a more conservative approach to message iteration
         try:
             messages = []
             async for msg in client.iter_messages(CHANNEL, limit=30000):
@@ -133,10 +127,6 @@ async def process_filenames(name_input):
         logging.error(f"Error in process_filenames: {e}")
         return f"❌ Error: {str(e)}"
 
-# === Global event loop for the Telegram client ===
-# This ensures the client uses a single, persistent event loop.
-loop = asyncio.get_event_loop()
-
 # === Flask App with explicit template and static folder paths ===
 # Get the directory where this script is located
 basedir = os.path.abspath(os.path.dirname(__file__))
@@ -150,18 +140,17 @@ def index():
     return render_template('index.html')
 
 @app.route('/upload', methods=['POST'])
-def upload():
+async def upload(): # Mark the route as async
     try:
         filenames_input = request.form.get('filenames', '').strip()
         if not filenames_input:
             return "❌ Error: No filenames provided", 400
         
-        # Check if credentials are configured
         if not client:
             return "❌ Error: Application not configured. Please set up your environment variables with API credentials.", 500
         
-        # Run the async function on the global event loop
-        results = loop.run_until_complete(process_filenames(filenames_input))
+        # Await the async function directly
+        results = await process_filenames(filenames_input)
         return results
     
     except Exception as e:
@@ -226,7 +215,6 @@ def session_info():
         return jsonify({"error": "Client not initialized"})
     
     try:
-        # This is a synchronous check
         session_status = {
             "session_file_exists": os.path.exists('my_session.session'),
             "client_initialized": bool(client),