Spaces:

Opera8
/

tts10

Paused

File size: 107,069 Bytes

import os
import uuid
import requests
import threading
import time
import sqlite3
import tempfile
import ffmpeg
import json
from datetime import datetime
from flask import Flask, request, jsonify, render_template, send_from_directory, send_file, after_this_request, Response, stream_with_context
from deep_translator import GoogleTranslator
import random  # اضافه شد

app = Flask(__name__)

# --- تنظیم کلیدهای Groq ---
GROQ_API_KEYS_RAW = os.environ.get("GROQ_API_KEYS", "")
GROQ_KEYS = [k.strip() for k in GROQ_API_KEYS_RAW.split(",") if k.strip()]

groq_lock = threading.Lock()
groq_index = 0

def get_next_groq_key():
    global groq_index
    if not GROQ_KEYS:
        return None
    with groq_lock:
        key = GROQ_KEYS[groq_index % len(GROQ_KEYS)]
        groq_index += 1
    return key

if GROQ_KEYS:
    print(f"✅ تعداد {len(GROQ_KEYS)} کلید Groq شناسایی شد (توزیع بار به صورت چرخشی فعال است).", flush=True)
else:
    print("⚠️ هیچ کلید Groq در متغیر محیطی GROQ_API_KEYS تعریف نشده است.", flush=True)

# --- مپینگ‌های کمکی برای مانیتورینگ زنده اکشن‌ها ---
RUN_ACCOUNT_MAPPING = {}
LAST_RUN_CHECK = {}

# --- پیکربندی حساب‌های گیت‌هاب (سیستم توزیع بار یا Load Balancer) ---
GITHUB_ACCOUNTS_CONFIG = [
    {"repo": "Hamed744/vid-test", "token_env": "GITHUB_TOKEN1"},
    {"repo": "hajiliker4-cpu/a", "token_env": "GITHUB_TOKEN3"},
    {"repo": "asrasahar744-ops/a", "token_env": "GITHUB_TOKEN4"},
]

GITHUB_ACCOUNTS = []
for config in GITHUB_ACCOUNTS_CONFIG:
    token = os.environ.get(config["token_env"])
    if token:
        GITHUB_ACCOUNTS.append({
            "repo": config["repo"], 
            "token": token,
            "token_env": config["token_env"]
        })

print(f"✅ تعداد {len(GITHUB_ACCOUNTS)} حساب گیت‌هاب با موفقیت شناسایی و به سیستم متصل شد.", flush=True)
for i, acc in enumerate(GITHUB_ACCOUNTS):
    token_masked = acc['token'][:4] + "..." + acc['token'][-4:] if len(acc['token']) > 8 else "***"
    print(f"   🔹 حساب {i+1}: مخزن {acc['repo']} متصل با متغیر {acc['token_env']} ({token_masked})", flush=True)

account_lock = threading.Lock()
account_index = 0

def get_next_account():
    global account_index
    if not GITHUB_ACCOUNTS:
        return None
    with account_lock:
        acc = GITHUB_ACCOUNTS[account_index % len(GITHUB_ACCOUNTS)]
        account_index += 1
    return acc

SPACE_HOST = os.environ.get("SPACE_HOST", "")
SPACE_URL = f"https://{SPACE_HOST}"

# --- کلمات ممنوعه ---
FORBIDDEN_KEYWORDS = {"sex", "sexy", "porn", "nude", "erotic", "سکس", "سکسی", "پورن", "شهوانی", "برهنه", "لخت"}

# --- تنظیمات دیتابیس SQLite ---
DB_DIR = "/data" if os.path.exists("/data") else "."
DB_PATH = os.path.join(DB_DIR, "users.db")
TEMP_DIR = "tmp"
USAGE_LIMIT = 5
ONE_WEEK_SECONDS = 7 * 24 * 60 * 60
ONE_DAY_SECONDS = 24 * 60 * 60  

DB_IMAGE_PATH = os.path.join(DB_DIR, "users_image.db")
IMAGE_USAGE_LIMIT = 5

DB_IMAGE_EDIT_PATH = os.path.join(DB_DIR, "users_image_edit.db")
EDIT_USAGE_LIMIT = 5

DB_CHAT_QUEUE_PATH = os.path.join(DB_DIR, "chat_queue.db")

os.makedirs(TEMP_DIR, exist_ok=True)
os.makedirs("static/images", exist_ok=True)
os.makedirs("yml", exist_ok=True)

# --- سیستم پاکسازی خودکار فایل‌های قدیمی (تنظیم شده روی 3 روز) ---
def cleanup_old_files():
    while True:
        time.sleep(3600)
        now = time.time()
        max_age_seconds = 3 * 24 * 60 * 60  # 3 روز
        
        for folder in ["static/images", "tmp"]:
            if os.path.exists(folder):
                for filename in os.listdir(folder):
                    file_path = os.path.join(folder, filename)
                    if os.path.isfile(file_path):
                        if os.stat(file_path).st_mtime < now - max_age_seconds:
                            try:
                                os.remove(file_path)
                            except Exception:
                                pass

threading.Thread(target=cleanup_old_files, daemon=True).start()

# تابع تولید کارت تصویری خطا
def create_error_image(run_id, message):
    try:
        from PIL import Image, ImageDraw
        img = Image.new('RGB', (800, 500), color='#1e293b')
        draw = ImageDraw.Draw(img)
        
        draw.rectangle([20, 20, 780, 480], outline="#f43f5e", width=4)
        draw.text((50, 60), "⚠️ PROCESS ERROR / خطای اجرای فرآیند", fill="#f43f5e")
        draw.text((50, 110), f"Run ID: {run_id}", fill="#94a3b8")
        
        y_offset = 160
        for line in message.split('\n'):
            draw.text((50, y_offset), line, fill="#f1f5f9")
            y_offset += 40
            
        draw.text((50, y_offset + 30), "برای مشاهده لاگ‌ها، به تب Actions در مخزن گیت هاب خود بروید.", fill="#38bdf8")
        
        img.save(f"static/images/{run_id}.png")
        print(f"🎨 [کارت خطا] کارت تصویری خطا با موفقیت در static/images/{run_id}.png ایجاد شد.", flush=True)
    except Exception as e:
        print(f"Failed to generate error image: {e}", flush=True)

# سیستم مانیتورینگ زنده (تنها برای ثبت لاگ در کنسول ادمین و بدون دخالت در رکوئست‌ها)
def check_github_run_status_and_log(run_id):
    acc = RUN_ACCOUNT_MAPPING.get(run_id)
    if not acc:
        acc = get_next_account()
    if not acc:
        return
        
    headers = {
        "Accept": "application/vnd.github.v3+json", 
        "Authorization": f"token {acc['token']}"
    }
    
    # ۱. بررسی مشخصات مخزن
    try:
        repo_url = f"https://api.github.com/repos/{acc['repo']}"
        repo_r = requests.get(repo_url, headers=headers, timeout=10)
        if repo_r.status_code == 200:
            repo_info = repo_r.json()
            default_branch = repo_info.get("default_branch", "نامشخص")
            is_private = repo_info.get("private", False)
            print(f"   ℹ️ [مشخصات مخزن] شاخه پیش‌فرض گیت‌هاب: {default_branch} | نوع مخزن: {'خصوصی (Private)' if is_private else 'عمومی (Public)'}", flush=True)
    except Exception as e:
        print(f"   ⚠️ [مانیتور مخزن] خطا در ارتباط با گیت‌هاب: {e}", flush=True)

    # ۲. بررسی آخرین وضعیت اجراها (تنها جهت ثبت لاگ در ترمینال ادمین)
    url = f"https://api.github.com/repos/{acc['repo']}/actions/runs?per_page=5"
    try:
        r = requests.get(url, headers=headers, timeout=10)
        if r.status_code == 200:
            runs_data = r.json()
            runs = runs_data.get('workflow_runs', [])
            total_runs = runs_data.get('total_count', 0)
            
            print(f"🔍 [رهگیری زنده اکشنز] بررسی مخزن {acc['repo']} برای شناسه فرآیند {run_id[:8]}... تعداد کل اجراهای یافت شده: {total_runs}", flush=True)
            
            for run in runs:
                created_at_dt = datetime.strptime(run['created_at'], "%Y-%m-%dT%H:%M:%SZ")
                time_diff = (datetime.utcnow() - created_at_dt).total_seconds()
                print(f"   🔸 اکشن شماره {run['id']} | نام: {run['name']} | وضعیت: {run['status']} | نتیجه: {run.get('conclusion')} | زمان ایجاد: {run['created_at']} ({int(time_diff)} ثانیه پیش)", flush=True)
        else:
            print(f"   ⚠️ [مانیتورینگ اکشنز] دریافت وضعیت با خطای API مواجه شد: {r.status_code}", flush=True)
    except Exception as e:
        print(f"   ⚠️ [خطای سیستم مانیتورینگ] خطا در دریافت لیست فرآیندها: {e}", flush=True)

# ایجاد خودکار اسکریپت‌های مورد نیاز
def write_default_scripts():
    scripts = {
        "ghibli.py": """
import os, sys, requests, base64
from gradio_client import Client, handle_file

raw_prompt = os.environ.get('PROMPT', '')
run_id = os.environ.get('RUN_ID', '')
space_url = os.environ.get('SPACE_URL', '')
github_run_id = os.environ.get('GITHUB_RUN_ID', '')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "ghibli",
                "client_payload": {
                    "prompt": raw_prompt,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Decoding packed configurations from safe payload...')
if not raw_prompt.startswith("GHIBLICONFIG_"):
    err_str = "Error: Invalid ghibli configuration payload signature."
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

config_str = raw_prompt[len("GHIBLICONFIG_"):]
parts = config_str.split("_")
config = {}
i = 0
while i < len(parts) - 1:
    key = parts[i]
    val = parts[i+1]
    config[key] = val
    i += 2

user_run_id = config.get("userRunId", run_id)
img_ext = config.get("imgExt", "png")

try:
    b64_style = config.get("style", "")
    style = base64.b64decode(b64_style).decode('utf-8')
except Exception as e:
    style = "Studio Ghibli"

img_url = f"{space_url}/static/images/{user_run_id}_ghibli_img.{img_ext}"
local_img = f"input_img.{img_ext}"

print('2. Downloading reference image from your Space...')
try:
    req_img = requests.get(img_url, timeout=45)
    if req_img.status_code != 200:
        raise Exception(f"Image download failed. Status code: {req_img.status_code}")
    with open(local_img, 'wb') as f:
        f.write(req_img.content)
except Exception as download_err:
    err_str = f"Error downloading source files: {download_err}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

print('3. Connecting to Yuanshi/OminiControl_Art Space...')
try:
    client = Client("Yuanshi/OminiControl_Art")
    result = client.predict(
        style,
        handle_file(local_img),
        "High Quality",
        1.5,
        "Auto",
        True,
        42,
        20,
        fn_index=7
    )

    image_path = None
    if isinstance(result, list) and len(result) > 0:
        image_path = result[0].get('image') or result[0].get('path') if isinstance(result[0], dict) else result[0]
    elif isinstance(result, tuple) and len(result) > 0:
        image_path = result[0]
    elif isinstance(result, dict):
        image_path = result.get('image') or result.get('path')
    else:
        image_path = result

    if not image_path or not os.path.exists(str(image_path)):
        raise Exception("Generated output image file not found or invalid.")

    with open(image_path, 'rb') as f:
        res_upload = requests.post(
            f'{space_url}/api/webhook/upload', 
            data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': 'webp'}, 
            files={'file': f}
        )
    if res_upload.status_code == 200:
        print('SUCCESS!')
    else:
        sys.exit(1)
except Exception as e:
    err_str = str(e)
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-flux.py": """
import os, sys, random, requests
from gradio_client import Client

def get_env_int(name, default=0):
    val = os.environ.get(name, '')
    try:
        return int(val) if val.strip() else default
    except ValueError:
        return default

prompt = os.environ.get('PROMPT', '')
width = get_env_int('WIDTH', 1024)
height = get_env_int('HEIGHT', 1024)
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-flux",
                "client_payload": {
                    "prompt": prompt,
                    "width": width,
                    "height": height,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Connecting to Flux...')
try:
    client = Client('black-forest-labs/FLUX.1-dev')
    seed = random.randint(1, 2147483647)
    
    result = client.predict(prompt, seed, True, width, height, 3.5, 28, api_name='/infer')
    image_path = result[0] if isinstance(result, (tuple, list)) else result
    
    print(f'2. Uploading back to Docker Space...')
    with open(image_path, 'rb') as f:
        res = requests.post(f'{space_url}/api/webhook/upload', data={'run_id': run_id, 'github_run_id': github_run_id}, files={'file': f})
    
    if res.status_code == 200:
        print('3. SUCCESS!')
    else:
        sys.exit(1)
        
except Exception as e:
    err_str = str(e)
    print(f'ERROR: {err_str}')
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-flux2.py": """
import os, sys, random, requests, json
from gradio_client import Client, handle_file

def get_env_int(name, default=0):
    val = os.environ.get(name, '')
    try:
        return int(val) if val.strip() else default
    except ValueError:
        return default

def get_env_float(name, default=0.0):
    val = os.environ.get(name, '')
    try:
        return float(val) if val.strip() else default
    except ValueError:
        return default

prompt = os.environ.get('PROMPT', '')
image_urls_raw = os.environ.get('IMAGE_URLS', '[]')
width = get_env_int('WIDTH', 1024)
height = get_env_int('HEIGHT', 1024)
steps = get_env_int('STEPS', 30)
guidance = get_env_float('GUIDANCE', 4.0)
seed = get_env_int('SEED', 0)
randomize_seed = os.environ.get('RANDOMIZE_SEED', 'true').lower() == 'true'
prompt_upsampling = os.environ.get('PROMPT_UPSAMPLING', 'true').lower() == 'true'
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')
hf_token = os.environ.get('HF_TOKEN', '')

print(f'Starting direct Flux 2 generation for run_id: {run_id}')

print('1. Parsing and downloading images...')
image_urls = []
if image_urls_raw:
    try:
        cleaned_json = image_urls_raw.replace('null', '').strip()
        if cleaned_json and cleaned_json != '[]':
            image_urls = json.loads(cleaned_json)
    except Exception as e:
        print(f'JSON parsing error: {e}')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-flux2",
                "client_payload": {
                    "data": {
                        "prompt": prompt,
                        "image_urls": image_urls,
                        "width": width,
                        "height": height,
                        "steps": steps,
                        "guidance": guidance,
                        "seed": seed,
                        "randomize_seed": randomize_seed,
                        "prompt_upsampling": prompt_upsampling,
                        "run_id": run_id,
                        "space_url": space_url,
                        "hf_token": hf_token
                    }
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

files_to_send = []
for idx, url in enumerate(image_urls):
    if url:
        print(f'Downloading input image {idx}: {url}')
        ext = url.split('.')[-1] if '.' in url else 'png'
        local_filename = f'input_{idx}.{ext}'
        try:
            req = requests.get(url, timeout=30)
            with open(local_filename, 'wb') as f:
                f.write(req.content)
            files_to_send.append({'image': handle_file(local_filename), 'caption': None})
        except Exception as e:
            print(f'Failed to download {url}: {e}')

print('2. Connecting to FLUX.2-dev Space...')
try:
    if hf_token:
        client = Client('black-forest-labs/FLUX.2-dev', token=hf_token)
    else:
        client = Client('black-forest-labs/FLUX.2-dev')
    
    if randomize_seed:
        seed = random.randint(1, 2147483647)
    
    print(f'Predicting with seed={seed}, width={width}, height={height}, steps={steps}, guidance={guidance}, upsampling={prompt_upsampling}...')
    result = client.predict(
        prompt,
        files_to_send,
        seed,
        randomize_seed,
        width,
        height,
        steps,
        guidance,
        prompt_upsampling,
        api_name='/infer'
    )
    
    image_path = result[0] if isinstance(result, (tuple, list)) else result
    seed_used = result[1] if (isinstance(result, (tuple, list)) and len(result) > 1) else seed
    
    print('3. Uploading metadata seed back...')
    with open('seed.txt', 'w') as sf:
        sf.write(str(seed_used))
    requests.post(
        f'{space_url}/api/webhook/upload',
        data={'run_id': f'{run_id}_seed', 'github_run_id': github_run_id, 'ext': 'txt'},
        files={'file': open('seed.txt', 'rb')}
    )
    
    print('4. Uploading generated image back...')
    with open(image_path, 'rb') as f:
        upload_res = requests.post(
            f'{space_url}/api/webhook/upload', 
            data={'run_id': run_id, 'github_run_id': github_run_id}, 
            files={'file': f}
        )
    
    if upload_res.status_code == 200:
        print('SUCCESS!')
    else:
        print(f'Upload failed with status {upload_res.status_code}: {upload_res.text}')
        sys.exit(1)
        
except Exception as e:
    err_str = str(e)
    print(f'Generation error: {err_str}')
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-cartoon.py": """
import os, sys, random, requests
from gradio_client import Client

def get_env_int(name, default=0):
    val = os.environ.get(name, '')
    try:
        return int(val) if val.strip() else default
    except ValueError:
        return default

prompt = os.environ.get('PROMPT', '')
width = get_env_int('WIDTH', 1024)
height = get_env_int('HEIGHT', 1024)
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-cartoon",
                "client_payload": {
                    "prompt": prompt,
                    "width": width,
                    "height": height,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Connecting to LoRA DLC Space...')
try:
    client = Client('prithivMLmods/FLUX-LoRA-DLC')
    print('2. Loading Cartoon Model (Long Toons)...')
    client.predict('prithivMLmods/Flux-Long-Toon-LoRA', api_name='/add_custom_lora')
    
    print('3. Generating Cartoon Image...')
    result = client.predict(
        prompt=f'Long toons {prompt}',
        image_input=None,
        cfg_scale=3.5,
        steps=28,
        randomize_seed=True,
        seed=random.randint(1, 2147483647),
        width=width,
        height=height,
        lora_scale=0.8,
        api_name='/run_lora'
    )
    image_path = result[0] if isinstance(result, (tuple, list)) else result
    
    print('4. Uploading back to Docker Space...')
    with open(image_path, 'rb') as f:
        res = requests.post(f'{space_url}/api/webhook/upload', 
                         data={'run_id': run_id, 'github_run_id': github_run_id}, 
                         files={'file': f})
    if res.status_code == 200:
        print('5. SUCCESS!')
    else:
        sys.exit(1)
except Exception as e:
    err_str = str(e)
    print(f'CRITICAL ERROR: {err_str}')
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-midjourney.py": """
import os, sys, random, requests
from gradio_client import Client

def get_env_int(name, default=0):
    val = os.environ.get(name, '')
    try:
        return int(val) if val.strip() else default
    except ValueError:
        return default

raw_prompt = os.environ.get('PROMPT', '')
final_prompt = f'MJ v6 {raw_prompt}'
width = get_env_int('WIDTH', 1024)
height = get_env_int('HEIGHT', 1024)
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-midjourney",
                "client_payload": {
                    "prompt": raw_prompt,
                    "width": width,
                    "height": height,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Connecting to LoRA DLC Space...')
try:
    client = Client('prithivMLmods/FLUX-LoRA-DLC')
    print('2. Loading Midjourney Model...')
    client.predict('strangerzonehf/Flux-Midjourney-Mix2-LoRA', api_name='/add_custom_lora')
    
    print(f'3. Generating Image... Prompt: {final_prompt[:50]}...')
    result = client.predict(
        prompt=final_prompt,
        image_input=None,
        cfg_scale=3.5,
        steps=28,
        randomize_seed=True,
        seed=random.randint(1, 2147483647),
        width=width,
        height=height,
        lora_scale=0.8,
        api_name='/run_lora'
    )
    image_path = result[0] if isinstance(result, (tuple, list)) else result
    
    print('4. Uploading back to Docker Space...')
    with open(image_path, 'rb') as f:
        res = requests.post(f'{space_url}/api/webhook/upload', 
                         data={'run_id': run_id, 'github_run_id': github_run_id}, 
                         files={'file': f})
    if res.status_code == 200:
        print('5. SUCCESS!')
    else:
        sys.exit(1)
except Exception as e:
    err_str = str(e)
    print(f'CRITICAL ERROR: {err_str}')
    report_failure(err_str)
    sys.exit(1)
        """,
        "chat-gemma.py": """
import os, sys, requests
from gradio_client import Client, handle_file

prompt = os.environ.get('PROMPT', '')
file_url = os.environ.get('FILE_URL', '')
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
gh_run_id = os.environ.get('GITHUB_RUN_ID')

files_to_send = []
if file_url:
    print(f'Downloading attachment: {file_url}')
    ext = file_url.split('.')[-1] if '.' in file_url else 'bin'
    local_filename = f'attachment.{ext}'
    try:
        req = requests.get(file_url, timeout=30)
        with open(local_filename, 'wb') as f:
            f.write(req.content)
        files_to_send.append(handle_file(local_filename))
    except Exception as e:
        print(f'Failed to download file: {e}')

print('Connecting to Gemma-4 Space...')
bot_reply = ''
try:
    client = Client('huggingface-projects/gemma-4-e4b-it')
    message_payload = {'text': prompt, 'files': files_to_send}
    result = client.predict(
        message=message_payload,
        thinking=False,
        max_new_tokens=4000,
        max_soft_tokens=1120,
        system_prompt='شما یک دستیار هوش مصنوعی بسیار باهوش، مفید و مودب به زبان فارسی هستید.',
        api_name='/generate'
    )
    bot_reply = result[0] if isinstance(result, (list, tuple)) else result
    if isinstance(bot_reply, dict):
        bot_reply = bot_reply.get('text', str(bot_reply))
except Exception as e:
    err_str = str(e)
    print(f'Generation Error: {err_str}')
    if 'ZeroGPU quota' in err_str or 'quota' in err_str.lower():
        bot_reply = '⚠️ **پردازش متوقف شد:**\\nدرخواست شما طولانی و پرحجم است (پردازش فایل‌های صوتی یا حجیم نیازمند منابع بالایی است و سهمیه سرور موقتاً پر شده است).\\n\\nلطفاً چند ساعت دیگر امتحان کنید یا درخواست و فایل سبک‌تری ارسال نمایید.'
    else:
        bot_reply = f'⚠️ خطای سرور پردازش: {err_str}'

print('Uploading response back to Docker Space...')
try:
    with open('response.txt', 'w', encoding='utf-8') as f:
        f.write(bot_reply)
    with open('response.txt', 'rb') as f:
        res = requests.post(f'{space_url}/api/webhook/upload',
                         data={'run_id': run_id, 'github_run_id': gh_run_id, 'ext': 'txt'},
                         files={'file': f})
    if res.status_code == 200:
        print('SUCCESS!')
    else:
        sys.exit(1)
except Exception as e:
    sys.exit(1)
        """,
        "generate-editor.py": """
import os, sys, random, requests, json, time, base64
import httpx
from PIL import Image

# =========================================================
# رفع قطعی مشکل Time Out رانر گیت‌هاب با تنظیم زمان انتظار به ۵ دقیقه
original_client_init = httpx.Client.__init__
def patched_client_init(self, *args, **kwargs):
    kwargs['timeout'] = httpx.Timeout(300.0)
    original_client_init(self, *args, **kwargs)
httpx.Client.__init__ = patched_client_init

original_async_init = httpx.AsyncClient.__init__
def patched_async_init(self, *args, **kwargs):
    kwargs['timeout'] = httpx.Timeout(300.0)
    original_async_init(self, *args, **kwargs)
httpx.AsyncClient.__init__ = patched_async_init
# =========================================================

from gradio_client import Client

prompt = os.environ.get('PROMPT', '')
image_url = os.environ.get('IMAGE_URL', '')
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

# دریافت متغیرهای عددی با مقادیر پیش‌فرض هماهنگ با فرانت‌اند جدید
try:
    steps = int(os.environ.get('STEPS', '15'))
except:
    steps = 15

try:
    guidance_scale = float(os.environ.get('GUIDANCE', '1.0'))
except:
    guidance_scale = 1.0

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-editor",
                "client_payload": {
                    "prompt": prompt,
                    "image_url": image_url,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Downloading input image from Docker Space...')
local_input_path = 'input_to_edit.png'
try:
    req = requests.get(image_url, timeout=30)
    with open(local_input_path, 'wb') as f:
        f.write(req.content)
    print('   -> Input image ready.')
except Exception as e:
    err_str = f"Download failed: {e}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

print('2. Extracting exact original dimensions and preparing Base64 Data URI...')
try:
    # استخراج ابعاد دقیق پیکسلی کاربر برای بازنشانی نهایی
    img = Image.open(local_input_path)
    orig_width, orig_height = img.size
    print(f'   -> Target Exact Size required by User: {orig_width}x{orig_height}')
    
    # تبدیل تصویر دانلود شده به فرمت کد دیتا (Base64 Data URI) همانطور که اسپیس جدید نیاز دارد
    with open(local_input_path, "rb") as img_file:
        encoded_string = base64.b64encode(img_file.read()).decode('utf-8')
    
    base64_data_uri = f"data:image/png;base64,{encoded_string}"
    
    # ساخت ساختار آرایه رشته‌ای جی‌سون (JSON String of Images Array)
    images_json_payload = json.dumps([base64_data_uri])
    print('   -> Base64 payload generated successfully.')

except Exception as e:
    err_str = f"Failed to prepare image data payload: {e}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

print('3. Connecting to Qwen Image Edit Space (Fast LoRA)...')
success = False
raw_result = None

for attempt in range(3):
    try:
        print(f'   -> Attempt {attempt + 1} of 3...')
        
        # اتصال به آدرس اسپیس جدید معرفی شده در فرانت‌اند شما
        client = Client("https://prithivmlmods-qwen-image-edit-2511-loras-fast.hf.space/")
        
        seed = random.randint(1, 2147483647)
        lora_adapter = "Anything2Real" # استایل پیش‌فرض برای تبدیل به عکس طبیعی و واقعی
        randomize_seed = True
        
        # ارسال پارامترها دقیقاً منطبق با Predict شماره 2 اسپیس مقصد
        result = client.predict(
            images_json_payload,     # پارامتر اول: رشته جی‌سون تصاویر
            prompt,                  # پارامتر دوم: دستور متنی
            lora_adapter,            # پارامتر سوم: نام آداپتور لورا
            seed,                    # پارامتر چهارم: سید عددی
            randomize_seed,          # پارامتر پنجم: رندوم کردن سید
            guidance_scale,          # پارامتر ششم: مقدار Guidance Scale
            steps,                   # پارامتر هفتم: تعداد مراحل پردازش
            fn_index=2               # مشخص کردن اجرای ایندکس شماره ۲ API
        )
        
        if result:
            raw_result = result
            success = True
            break
    except Exception as client_err:
        print(f'   -> Attempt {attempt + 1} failed: {client_err}')
        time.sleep(5)

if not success or not raw_result:
    err_str = "Qwen-Image-Edit Space failed to process the image after 3 attempts."
    print(f'CRITICAL ERROR: {err_str}')
    report_failure(err_str)
    sys.exit(1)

print('4. Resolving and downloading generated output image...')
local_output_path = 'output_raw.png'
try:
    # استخراج مسیر فایل یا لینک دانلود از پاسخ Gradio Client
    if isinstance(raw_result, (tuple, list)):
        res_data = raw_result[0]
    elif isinstance(raw_result, dict):
        res_data = raw_result.get('data', [None])[0] or raw_result
    else:
        res_data = raw_result

    if isinstance(res_data, dict):
        output_url_or_path = res_data.get('url') or res_data.get('path')
    else:
        output_url_or_path = str(res_data)

    # اگر خروجی یک لینک وب بود آن را دانلود کن، در غیر این صورت فایل محلی را بخوان
    if output_url_or_path.startswith('http'):
        img_req = requests.get(output_url_or_path, timeout=60)
        with open(local_output_path, 'wb') as f:
            f.write(img_req.content)
    else:
        if os.path.exists(output_url_or_path):
            import shutil
            shutil.copy(output_url_or_path, local_output_path)
        else:
            raise FileNotFoundError(f"Result file path not found: {output_url_or_path}")
            
    print('   -> Output downloaded and ready for post-processing.')
except Exception as extract_err:
    err_str = f"Failed to resolve processed image output: {extract_err}. Raw response was: {raw_result}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

print('5. Post-Processing: Precisely resizing back to match user original size...')
try:
    # باز کردن تصویر تولید شده جهت اعمال تغییر ابعاد نهایی
    generated_img = Image.open(local_output_path)
    
    # تغییر سایز با بالاترین کیفیت ممکن (فیلتر Lanczos) به ابعاد دقیق پیکسل اولیه کاربر
    final_resized_img = generated_img.resize((orig_width, orig_height), Image.Resampling.LANCZOS)
    
    # ذخیره نهایی بر روی دیسک
    final_resized_img.save(local_input_path) 
    print(f'   -> Done! Output image matches perfectly with original size: {orig_width}x{orig_height} px.')
except Exception as resize_err:
    print(f'   -> Warning: High precision resizing failed ({resize_err}). Using raw output.')
    import shutil
    shutil.copy(local_output_path, local_input_path)

print('6. Preparing image file extension metadata...')
ext = 'png'
try:
    with Image.open(local_input_path) as verify_img:
        content_type = verify_img.format
        if content_type == 'WEBP': ext = 'webp'
        elif content_type in ['JPEG', 'JPG']: ext = 'jpg'
except:
    ext = 'png'

print(f'7. Uploading processed natural photo back to Docker Space: {space_url}')
try:
    with open(local_input_path, 'rb') as f:
        res = requests.post(
            f'{space_url}/api/webhook/upload', 
            data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': ext}, 
            files={'file': f},
            timeout=60
        )
    
    if res.status_code == 200:
        print('8. SUCCESS! Qwen-Image-Edit workflow finished perfectly.')
    else:
        err_str = f"Upload to Docker webhook failed: {res.status_code} - {res.text}"
        print(err_str)
        report_failure(err_str)
        sys.exit(1)
except Exception as up_err:
    err_str = f"Failed to upload result to webhook: {up_err}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-video.py": """
import os, sys, random, requests, time
from gradio_client import Client, handle_file
from PIL import Image, ImageOps

prompt = os.environ.get('PROMPT', '').strip()
if not prompt: 
    prompt = 'make this image come alive, cinematic motion, smooth animation'
else:
    prompt = f'{prompt}, cinematic motion, smooth animation, high quality'

negative_prompt = '色调艳丽, 过曝, 静态, 细节模糊不清, 字幕, 风格, 作品, 画作, 画面, 静止, 整体发灰, 最差质量, 低质量, JPEG压缩残留, 丑陋의, 残缺의, 多余的手指, 画得不好的手部, 画得不好的脸部, 畸形の, 毁容의, 形态畸形の肢体, 手指融合, 静止不动的画面, 杂乱의 背景, 三条腿, 背景人很多, 倒着走'

image_url = os.environ.get('IMAGE_URL', '')
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

try:
    duration = float(os.environ.get('DURATION', 5.0))
except Exception:
    duration = 5.0

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-video",
                "client_payload": {
                    "prompt": prompt,
                    "duration": duration,
                    "image_url": image_url,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

print('1. Downloading input image from Docker Space...')
try:
    req = requests.get(image_url, timeout=30)
    with open('input_raw.png', 'wb') as f:
        f.write(req.content)
except Exception as e:
    print(f'Download failed: {e}')
    sys.exit(1)

print('2. Analyzing image dimensions to prevent stretching...')
img = Image.open('input_raw.png').convert('RGB')
orig_w, orig_h = img.size
ratio = orig_w / orig_h

if ratio > 1.2:
    target_w, target_h = 832, 480  
    print('   -> Format: Landscape (16:9)')
elif ratio < 0.8:
    target_w, target_h = 480, 832  
    print('   -> Format: Portrait (9:16)')
else:
    target_w, target_h = 480, 480  
    print('   -> Format: Square (1:1)')

img_resized = ImageOps.fit(img, (target_w, target_h), Image.Resampling.LANCZOS)
img_resized.save('input.png')
print(f'   -> Image resized to {target_w}x{target_h}')

print('3. Connecting to AI Video Space...')
video_path = None

space_id = 'zerogpu-aoti/wan2-2-fp8da-aoti-faster'
print(f'   -> Loading Space: {space_id}')
try:
    client = Client(space_id)
except Exception as e:
    print(f'CRITICAL ERROR: Could not load space. {e}')
    sys.exit(1)

max_attempts = 4
for attempt in range(max_attempts):
    seed = random.randint(1, 2147483647)
    print(f'   -> Attempt {attempt + 1} of {max_attempts} with seed {seed} and duration {duration}s...')
    
    try:
        result = client.predict(
            handle_file('input.png'), 
            prompt,                    
            6,                         
            negative_prompt,           
            duration,                  
            1,                         
            1,                         
            seed,                      
            True,                      
            fn_index=0
        )
        
        if isinstance(result, list) and len(result) > 0:
            video_path = result[0].get('video') or result[0].get('path') if isinstance(result[0], dict) else result[0]
        elif isinstance(result, tuple) and len(result) > 0:
            video_path = result[0]
        elif isinstance(result, dict):
            video_path = result.get('video') or result.get('path')
        else:
            video_path = result
            
        if video_path and os.path.exists(str(video_path)):
            print('   -> Success! Video generated.')
            break
            
    except Exception as e:
        err_msg = str(e)
        print(f'   -> Failed on attempt {attempt + 1}: {err_msg}')
        time.sleep(5)

if not video_path or not os.path.exists(str(video_path)):
    err_str = "Video generation failed on all attempts"
    report_failure(err_str)
    sys.exit(1)

print('4. Uploading back to your Docker Space...')
try:
    with open(video_path, 'rb') as f:
        res = requests.post(f'{space_url}/api/webhook/upload', 
                         data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': 'mp4'}, 
                         files={'file': f})
    if res.status_code == 200:
        print('5. SUCCESS!')
    else:
        sys.exit(1)
except Exception as e:
    err_str = str(e)
    report_failure(err_str)
    sys.exit(1)
        """,
        "generate-audio.py": """
import os, sys, requests, time
from gradio_client import Client, handle_file

AUDIO_TYPE = '___AUDIO_TYPE___'
NEGATIVE_PROMPT = '''___NEGATIVE_PROMPT___'''

prompt = os.environ.get('PROMPT', '')
try: seed = int(os.environ.get('SEED', '-1'))
except: seed = -1
try: duration = float(os.environ.get('DURATION', '8'))
except: duration = 8.0

file_url = os.environ.get('FILE_URL', '')
run_id = os.environ.get('RUN_ID')
space_url = os.environ.get('SPACE_URL')
github_run_id = os.environ.get('GITHUB_RUN_ID')

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "generate-audio",
                "client_payload": {
                    "data": {
                        "prompt": prompt,
                        "duration": duration,
                        "seed": seed,
                        "audio_type": AUDIO_TYPE,
                        "negative_prompt": NEGATIVE_PROMPT,
                        "file_url": file_url,
                        "run_id": run_id,
                        "space_url": space_url
                    }
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

try:
    print('1. Connecting to Audio Space...')
    client = Client("hkchengrex/MMAudio")
    
    if AUDIO_TYPE == 'video':
        print('2. Downloading video for audio generation...')
        req = requests.get(file_url, timeout=30)
        ext = file_url.split('.')[-1] if '.' in file_url else 'mp4'
        local_vid = f'input.{ext}'
        with open(local_vid, 'wb') as f:
            f.write(req.content)
            
        print('3. Processing Video-to-Audio...')
        result = client.predict(
            video=handle_file(local_vid),
            prompt=prompt,
            negative_prompt=NEGATIVE_PROMPT,
            seed=seed,
            num_steps=25,
            cfg_strength=4.5,
            duration=duration,
            api_name="/video_to_audio"
        )
    else:
        print('2. Processing Text-to-Audio...')
        result = client.predict(
            prompt=prompt,
            negative_prompt=NEGATIVE_PROMPT,
            seed=seed,
            num_steps=25,
            cfg_strength=4.5,
            duration=duration,
            api_name="/text_to_audio"
        )
        
    print('4. Preparing File Data...')
    audio_path = None
    if isinstance(result, list) and len(result) > 0:
        audio_path = result[0].get('video') or result[0].get('path') or result[0].get('url') if isinstance(result[0], dict) else result[0]
    elif isinstance(result, tuple) and len(result) > 0:
        audio_path = result[0]
    elif isinstance(result, dict):
        audio_path = result.get('video') or result.get('path') or result.get('url')
    else:
        audio_path = result
        
    ext = 'mp4'
    if str(audio_path).endswith('.wav'): ext = 'wav'
    if str(audio_path).endswith('.mp3'): ext = 'mp3'
    
    print('5. Uploading back to Space...')
    with open(audio_path, 'rb') as f:
        res = requests.post(
            f'{space_url}/api/webhook/upload', 
            data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': ext}, 
            files={'file': f}
        )
        
    if res.status_code == 200:
        print('SUCCESS!')
    else:
        sys.exit(1)
        
except Exception as e:
    err_str = str(e)
    print(f'Generation error: {err_str}')
    report_failure(err_str)
    sys.exit(1)
        """,
        "taqviat-sada.py": """
import os
import sys
import requests
import json
from gradio_client import Client, handle_file

raw_prompt = os.environ.get('PROMPT', '')
run_id = os.environ.get('RUN_ID', '')
space_url = os.environ.get('SPACE_URL', '')
github_run_id = os.environ.get('GITHUB_RUN_ID', '')
BALE_BOT_TOKEN = os.environ.get("BALE_BOT_TOKEN", "").strip()

# رمزگشایی توکن بله ارسال شده از سمت سرور اصلی
if "_baleToken_" in raw_prompt:
    prompt_parts = raw_prompt.split("_baleToken_")
    raw_prompt = prompt_parts[0]
    BALE_BOT_TOKEN = prompt_parts[1].strip()

def report_failure(error_msg):
    try:
        requests.post(
            f"{space_url}/api/webhook/fail",
            json={
                "run_id": run_id,
                "error": error_msg,
                "event_type": "taqviat-sada",
                "client_payload": {
                    "prompt": raw_prompt,
                    "run_id": run_id,
                    "space_url": space_url
                },
                "github_run_id": github_run_id
            },
            timeout=15
        )
    except Exception as e:
        print(f"Failed to report failure: {e}")

def upload_to_bale(file_path):
    if not BALE_BOT_TOKEN:
        return None
    try:
        bale_chat_id = BALE_BOT_TOKEN.split(":")[0]
        bale_url = f"https://tapi.bale.ai/bot{BALE_BOT_TOKEN}/sendDocument"
        for attempt in range(3):
            with open(file_path, 'rb') as f:
                resp = requests.post(bale_url, data={'chat_id': bale_chat_id}, files={'document': (os.path.basename(file_path), f)}, timeout=120)
                if resp.status_code == 200:
                    data = resp.json()
                    if data.get("ok"):
                        file_id = data.get("result", {}).get("document", {}).get("file_id")
                        if not file_id:
                            file_id = data.get("result", {}).get("audio", {}).get("file_id")
                        if file_id:
                            return f"https://tapi.bale.ai/file/bot{BALE_BOT_TOKEN}/{file_id}"
    except Exception as e:
        print(f"Error uploading to Bale: {e}")
    return None

print('1. Decoding configuration from Taqviat payload...')
if not raw_prompt.startswith("VOICECONFIG_TAQVIAT_"):
    err_str = "Error: Invalid Taqviat configuration payload signature."
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

config_str = raw_prompt[len("VOICECONFIG_TAQVIAT_"):]
parts = config_str.split("_")
config = {}
i = 0
while i < len(parts) - 1:
    key = parts[i]
    val = parts[i+1]
    config[key] = val
    i += 2

user_run_id = config.get("userRunId", run_id)
solver = config.get("solver", "Midpoint")
nfe = int(config.get("nfe", "64"))
tau = float(config.get("tau", "0.5"))
denoising = config.get("denoising", "false").lower() == "true"
ext = config.get("ext", "wav")

input_audio_url = f"{space_url}/static/images/{user_run_id}_input.{ext}"
local_input = f"input.{ext}"

print("2. Downloading input audio from host...")
try:
    r_input = requests.get(input_audio_url, timeout=60)
    if r_input.status_code != 200:
        raise Exception(f"Input audio download failed. Status: {r_input.status_code}")
    with open(local_input, 'wb') as f:
        f.write(r_input.content)
except Exception as download_err:
    err_str = f"Error downloading source files: {download_err}"
    print(err_str)
    report_failure(err_str)
    sys.exit(1)

print("3. Connecting to Resemble Enhance Space...")
try:
    client = Client("https://opera8-resemble-enhance.hf.space")
    
    dependencies = client.config.get("dependencies", [])
    predict_index = 0
    for idx, dep in enumerate(dependencies):
        inputs = dep.get("inputs", [])
        outputs = dep.get("outputs", [])
        if len(inputs) == 5 and len(outputs) == 2:
            predict_index = idx
            break

    print(f"4. Processing audio enhancement on endpoint {predict_index}...")
    result = client.predict(
        handle_file(local_input),
        solver,
        nfe,
        tau,
        denoising,
        fn_index=predict_index
    )

    def parse_file_response(f):
        if not f: return None
        if isinstance(f, dict):
            return f.get('path') or f.get('name')
        return str(f)

    if not isinstance(result, (tuple, list)) or len(result) < 2:
        raise Exception("Invalid prediction result format from Resemble Enhance.")

    denoised_path = parse_file_response(result[0])
    enhanced_path = parse_file_response(result[1])

    if not denoised_path or not os.path.exists(str(denoised_path)):
        raise Exception("Output denoised audio file was not found or invalid.")
    if not enhanced_path or not os.path.exists(str(enhanced_path)):
        raise Exception("Output enhanced audio file was not found or invalid.")

    print("5. Uploading output files to Cloud...")
    denoised_url = None
    enhanced_url = None

    if os.path.getsize(denoised_path) < 52428800:
        print("   -> Uploading denoised audio to Bale...")
        denoised_url = upload_to_bale(denoised_path)
        
    if os.path.getsize(enhanced_path) < 52428800:
        print("   -> Uploading enhanced audio to Bale...")
        enhanced_url = upload_to_bale(enhanced_path)

    # Fallback to local upload if Bale fails or file is too large
    if not denoised_url:
        print("   -> Uploading denoised audio to Space (Local fallback)...")
        with open(denoised_path, 'rb') as f_denoised:
            requests.post(f'{space_url}/api/webhook/upload', data={'run_id': f'{run_id}_denoised', 'github_run_id': github_run_id, 'ext': 'wav'}, files={'file': f_denoised})

    if not enhanced_url:
        print("   -> Uploading enhanced audio to Space (Local fallback)...")
        with open(enhanced_path, 'rb') as f_enhanced:
            requests.post(f'{space_url}/api/webhook/upload', data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': 'wav'}, files={'file': f_enhanced})

    print("6. Creating and uploading JSON metadata for fast retrieval...")
    final_denoised = denoised_url if denoised_url else f"/static/images/{run_id}_denoised.wav"
    final_enhanced = enhanced_url if enhanced_url else f"/static/images/{run_id}.wav"
    
    json_data = {
        "denoised_url": final_denoised,
        "enhanced_url": final_enhanced
    }
    with open("result.json", "w", encoding="utf-8") as f:
        json.dump(json_data, f)
        
    with open("result.json", "rb") as f:
        requests.post(f'{space_url}/api/webhook/upload', data={'run_id': run_id, 'github_run_id': github_run_id, 'ext': 'json'}, files={'file': f})

    print('7. SUCCESS! Process complete.')

except Exception as e:
    err_str = str(e)
    print(f"CRITICAL ERROR during processing: {err_str}")
    report_failure(err_str)
    sys.exit(1)
        """
    }
    for name, content in scripts.items():
        path = os.path.join("yml", name)
        
        if os.path.exists(path):
            try:
                with open(path, "r", encoding="utf-8") as f:
                    old_data = f.read()
                if "report_failure" not in old_data:
                    os.remove(path)
            except:
                pass
                
        if not os.path.exists(path):
            with open(path, "w", encoding="utf-8") as f:
                f.write(content.strip())

write_default_scripts()

# پایگاه داده SQLite
def init_db():
    conn = sqlite3.connect(DB_PATH)
    c = conn.cursor()
    c.execute('''CREATE TABLE IF NOT EXISTS users
                 (id TEXT PRIMARY KEY, count INTEGER, week_start REAL)''')
    c.execute('''CREATE TABLE IF NOT EXISTS retries
                 (run_id TEXT PRIMARY KEY, attempt INTEGER, event_type TEXT, client_payload TEXT, last_failed_github_run_id INTEGER)''')
    
    for col, col_type in [("event_type", "TEXT"), ("client_payload", "TEXT"), ("last_failed_github_run_id", "INTEGER")]:
        try:
            c.execute(f"ALTER TABLE retries ADD COLUMN {col} {col_type}")
        except sqlite3.OperationalError:
            pass
            
    conn.commit()
    conn.close()

def init_image_db():
    conn = sqlite3.connect(DB_IMAGE_PATH)
    c = conn.cursor()
    c.execute('''CREATE TABLE IF NOT EXISTS users
                 (id TEXT PRIMARY KEY, count INTEGER, week_start REAL)''')
    conn.commit()
    conn.close()

def init_image_edit_db():
    conn = sqlite3.connect(DB_IMAGE_EDIT_PATH)
    c = conn.cursor()
    c.execute('''CREATE TABLE IF NOT EXISTS users
                 (id TEXT PRIMARY KEY, count INTEGER, week_start REAL)''')
    conn.commit()
    conn.close()

def init_chat_queue_db():
    conn = sqlite3.connect(DB_CHAT_QUEUE_PATH)
    c = conn.cursor()
    c.execute('''CREATE TABLE IF NOT EXISTS queue
                 (run_id TEXT PRIMARY KEY, prompt TEXT, file_url TEXT, file_mime TEXT, status TEXT, timestamp REAL)''')
    conn.commit()
    conn.close()

init_db()
init_image_db()
init_image_edit_db()
init_chat_queue_db()

def get_db_connection():
    conn = sqlite3.connect(DB_PATH)
    conn.row_factory = sqlite3.Row
    return conn

def get_image_db_connection():
    conn = sqlite3.connect(DB_IMAGE_PATH)
    conn.row_factory = sqlite3.Row
    return conn

def get_image_edit_db_connection():
    conn = sqlite3.connect(DB_IMAGE_EDIT_PATH)
    conn.row_factory = sqlite3.Row
    return conn

def get_chat_queue_db_connection():
    conn = sqlite3.connect(DB_CHAT_QUEUE_PATH)
    conn.row_factory = sqlite3.Row
    return conn

# --- توابع کمکی ---
def delete_github_run(gh_run_id):
    time.sleep(300)
    for acc in GITHUB_ACCOUNTS:
        url = f"https://api.github.com/repos/{acc['repo']}/actions/runs/{gh_run_id}"
        headers = {"Accept": "application/vnd.github.v3+json", "Authorization": f"token {acc['token']}"}
        r = requests.delete(url, headers=headers)
        if r.status_code in [204, 200]:
            print(f"🧹 [حذف موفق اکشن] شناسه {gh_run_id} از روی مخزن {acc['repo']} پاک شد.", flush=True)
            break

def get_user_identifier(data):
    fingerprint = data.get('fingerprint')
    if fingerprint: return str(fingerprint)
    if request.headers.getlist("X-Forwarded-For"):
        return request.headers.getlist("X-Forwarded-For")[0].split(',')[0].strip()
    return request.remote_addr

def has_forbidden_words(text):
    text_lower = text.lower()
    return any(keyword in text_lower for keyword in FORBIDDEN_KEYWORDS)

def get_github_runs():
    all_runs = []
    for acc in GITHUB_ACCOUNTS:
        url = f"https://api.github.com/repos/{acc['repo']}/actions/runs"
        headers = {"Accept": "application/vnd.github.v3+json", "Authorization": f"token {acc['token']}"}
        try:
            r = requests.get(f"{url}?per_page=100", headers=headers)
            if r.status_code == 200:
                runs = r.json().get('workflow_runs', [])
                for run in runs:
                    run['_account'] = acc
                all_runs.extend(runs)
        except Exception as e:
            print("Error fetching workflow runs:", e, flush=True)
            
    all_runs.sort(key=lambda x: x.get('created_at', ''), reverse=True)
    return all_runs

def is_today(created_at_str):
    try:
        run_date_str = created_at_str.split('T')[0]
        today_str = datetime.utcnow().strftime('%Y-%m-%d')
        return run_date_str == today_str
    except Exception:
        return False

# سیستم یکپارچه نجات و اجرای مجدد رانرهای موازی با استفاده از دیتابیس
def trigger_retry(run_id, github_run_id, error_msg):
    conn = sqlite3.connect(DB_PATH)
    conn.row_factory = sqlite3.Row
    c = conn.cursor()
    c.execute("SELECT * FROM retries WHERE run_id = ?", (run_id,))
    row = c.fetchone()
    if not row:
        conn.close()
        return "No retry record"

    attempt = row['attempt'] if row['attempt'] is not None else 0
    last_failed = row['last_failed_github_run_id']
    event_type = row['event_type']
    client_payload_raw = row['client_payload']

    # جلوگیری از دوبرابر شدن درخواست به ازای شناسه رانر یکسان در نخ‌های موازی
    if github_run_id and last_failed == int(github_run_id):
        conn.close()
        return "Already processed"

    new_attempt = attempt + 1
    max_retries = 20

    # بروزرسانی تعداد دفعات تلاش و شناسه شکست خورده جاری
    c.execute("UPDATE retries SET attempt = ?, last_failed_github_run_id = ? WHERE run_id = ?",
              (new_attempt, github_run_id, run_id))
    conn.commit()
    conn.close()

    if new_attempt <= max_retries:
        try:
            client_payload = json.loads(client_payload_raw)
        except Exception:
            client_payload = {}

        # بررسی و تعدیل تطبیقی ابعاد برای عبور از فیلترهای محدودیت زمانی سخت‌افزار
        is_duration_error = any(term in error_msg.lower() for term in ["duration", "larger", "max", "quota", "capacity", "limit"])
        if is_duration_error:
            print(f"📉 [تنظیم تطبیقی پارامترها] تعدیل پارامترها برای تلاش شماره {new_attempt}...", flush=True)
            if "data" in client_payload:
                original_steps = int(client_payload["data"].get("steps", 30))
                original_width = int(client_payload["data"].get("width", 1024))
                original_height = int(client_payload["data"].get("height", 1024))
                
                if new_attempt == 1:
                    client_payload["data"]["steps"] = min(20, original_steps)
                    client_payload["data"]["width"] = min(896, original_width)
                    client_payload["data"]["height"] = min(896, original_height)
                elif new_attempt == 2:
                    client_payload["data"]["steps"] = min(15, original_steps)
                    client_payload["data"]["width"] = min(768, original_width)
                    client_payload["data"]["height"] = min(768, original_height)
                else:
                    client_payload["data"]["steps"] = min(12, original_steps)
                    client_payload["data"]["width"] = min(512, original_width)
                    client_payload["data"]["height"] = min(512, original_height)
                    
        print(f"🔄 [ نجات خودکار - تلاش مجدد ] اجرای تلاش {new_attempt}/{max_retries} برای فرآیند {run_id} به دلیل خطا: {error_msg}", flush=True)
        dispatch_github_workflow(event_type, client_payload)
        return "Retrying"
    else:
        print(f"❌ [اتمام سقف تلاش مجدد] فرآیند {run_id} به سقف تلاش رسید ({max_retries}). تولید کارت تصویری خطا...", flush=True)
        create_error_image(run_id, f"Error: {error_msg}")
        return "Max retries reached"

# تابع ارسال رویداد داینامیک به گیت‌هاب با پشتیبانی از سوییچینگ اکانت (جلوگیری از خطای سرور)
def dispatch_github_workflow(event_type, client_payload):
    if not GITHUB_ACCOUNTS:
        print("❌ [خطای دیسپچ] هیچ حساب گیت‌هابی پیکربندی نشده یا فعال نیست!", flush=True)
        dummy_response = requests.models.Response()
        dummy_response.status_code = 500
        dummy_response._content = b'No GitHub accounts configured'
        return dummy_response

    # انتقال ایمن توکن بله به رانر گیت‌هاب جهت جلوگیری از پاک شدن فایل‌ها در ری‌استارت
    if event_type == "taqviat-sada":
        bale_token = os.environ.get("BALE_BOT_TOKEN", "").strip()
        if bale_token:
            if "prompt" in client_payload:
                client_payload["prompt"] = f"{client_payload['prompt']}_baleToken_{bale_token}"
            elif "data" in client_payload and "prompt" in client_payload["data"]:
                client_payload["data"]["prompt"] = f"{client_payload['data']['prompt']}_baleToken_{bale_token}"

    max_attempts = len(GITHUB_ACCOUNTS)
    run_id = client_payload.get("run_id") or client_payload.get("data", {}).get("run_id")

    script_path = os.path.join("yml", f"{event_type}.py")
    script_content = ""
    if os.path.exists(script_path):
        with open(script_path, "r", encoding="utf-8") as f:
            script_content = f.read()

    if event_type == "generate-audio":
        data_dict = client_payload.get("data", client_payload)
        audio_type = data_dict.get('audio_type', 'text')
        negative_prompt = data_dict.get('negative_prompt', 'music')
        script_content = script_content.replace("___AUDIO_TYPE___", str(audio_type))
        script_content = script_content.replace("___NEGATIVE_PROMPT___", str(negative_prompt))
    
    if "data" in client_payload:
        client_payload["data"]["script"] = script_content
    else:
        client_payload["script"] = script_content

    last_response = None

    for attempt in range(max_attempts):
        acc = get_next_account()
        if not acc:
            break

        if run_id:
            RUN_ACCOUNT_MAPPING[run_id] = acc
            
            # ذخیره یا بازیابی فراداده در پایگاه داده نجات
            conn = sqlite3.connect(DB_PATH)
            c = conn.cursor()
            c.execute("INSERT OR IGNORE INTO retries (run_id, attempt, event_type, client_payload) VALUES (?, 0, ?, ?)",
                      (run_id, event_type, json.dumps(client_payload)))
            c.execute("UPDATE retries SET event_type = ?, client_payload = ? WHERE run_id = ?",
                      (event_type, json.dumps(client_payload), run_id))
            conn.commit()
            conn.close()

        url = f"https://api.github.com/repos/{acc['repo']}/dispatches"
        headers = {
            "Accept": "application/vnd.github.v3+json", 
            "Authorization": f"token {acc['token']}"
        }

        print(f"🚀 [ارسال دیسپچ] (تلاش {attempt+1} از {max_attempts}) در حال ارسال به مخزن '{acc['repo']}'...", flush=True)

        try:
            r = requests.post(url, headers=headers, json={
                "event_type": event_type,
                "client_payload": client_payload
            }, timeout=20)
            
            last_response = r
            
            if r.status_code == 204:
                print(f"📩 [پاسخ دیسپچ گیت‌هاب] مخزن: {acc['repo']} | کد وضعیت: {r.status_code} | دیسپچ موفقیت‌آمیز.", flush=True)
                return r
            else:
                print(f"⚠️ [خطای دیسپچ] مخزن: {acc['repo']} پاسخ ناموفق داد (کد {r.status_code}). امتحان مخزن بعدی...", flush=True)
                
        except Exception as e:
            print(f"❌ [خطای ارتباطی با گیت‌هاب] ارسال دیسپچ به {acc['repo']} ناموفق بود: {e}. امتحان مخزن بعدی...", flush=True)
            dummy = requests.models.Response()
            dummy.status_code = 502
            dummy._content = str(e).encode('utf-8')
            last_response = dummy

    print("❌ [خطای دیسپچ نهایی] تمامی حساب‌های گیت‌هاب بررسی شدند اما هیچ‌کدام پاسخ موفقیت‌آمیز ندادند!", flush=True)
    return last_response

# --- مسیرهای صفحات HTML ---
@app.route('/')
def index():
    return render_template('index.html')

@app.route('/<page_name>')
def serve_html(page_name):
    if not page_name.endswith('.html'):
        page_name += '.html'
    try:
        return render_template(page_name)
    except:
        return "Page not found", 404

# --- API مخصوص مدیریت گیت‌هاب اکشنز در داشبورد ---
@app.route('/api/actions/active', methods=['GET'])
def get_active_actions():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    active = [
        {
            "id": run["id"],
            "name": run["name"],
            "status": run["status"],
            "html_url": run["html_url"],
            "created_at": run["created_at"]
        }
        for run in runs if run["status"] in ["queued", "in_progress", "waiting"]
    ]
    return jsonify({"status": "success", "actions": active})

@app.route('/api/actions/inactive-today', methods=['GET'])
def get_inactive_today():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    inactive_today = [
        {
            "id": run["id"],
            "name": run["name"],
            "status": run["status"],
            "conclusion": run.get("conclusion"),
            "html_url": run["html_url"],
            "created_at": run["created_at"]
        }
        for run in runs if run["status"] == "completed" and is_today(run["created_at"])
    ]
    return jsonify({"status": "success", "actions": inactive_today})

@app.route('/api/actions/completed-today-count', methods=['GET'])
def get_completed_today_count():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    completed_today = [
        run for run in runs if run["status"] == "completed" and run.get("conclusion") == "success" and is_today(run["created_at"])
    ]
    return jsonify({"status": "success", "count": len(completed_today)})

@app.route('/api/actions/delete-inactive', methods=['POST'])
def delete_inactive_actions():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    deleted_count = 0
    for run in runs:
        if run["status"] == "completed":
            acc = run['_account']
            headers = {"Accept": "application/vnd.github.v3+json", "Authorization": f"token {acc['token']}"}
            delete_url = f"https://api.github.com/repos/{acc['repo']}/actions/runs/{run['id']}"
            r = requests.delete(delete_url, headers=headers)
            if r.status_code in [204, 200]:
                deleted_count += 1
    return jsonify({"status": "success", "deleted_count": deleted_count})

@app.route('/api/actions/delete-failed-completed', methods=['POST'])
def delete_failed_completed():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    deleted_count = 0
    for run in runs:
        if run["status"] == "completed" and run.get("conclusion") in ["success", "failure", "cancelled"]:
            acc = run['_account']
            headers = {"Accept": "application/vnd.github.v3+json", "Authorization": f"token {acc['token']}"}
            delete_url = f"https://api.github.com/repos/{acc['repo']}/actions/runs/{run['id']}"
            r = requests.delete(delete_url, headers=headers)
            if r.status_code in [204, 200]:
                deleted_count += 1
    return jsonify({"status": "success", "deleted_count": deleted_count})

@app.route('/api/actions/cancel-delete-active', methods=['POST'])
def cancel_delete_active_actions():
    if not GITHUB_ACCOUNTS:
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    runs = get_github_runs()
    cancelled_count = 0
    deleted_count = 0
    for run in runs:
        if run["status"] in ["queued", "in_progress", "waiting"]:
            acc = run['_account']
            headers = {"Accept": "application/vnd.github.v3+json", "Authorization": f"token {acc['token']}"}
            cancel_url = f"https://api.github.com/repos/{acc['repo']}/actions/runs/{run['id']}/cancel"
            requests.post(cancel_url, headers=headers)
            cancelled_count += 1
            
            time.sleep(0.5)
            
            delete_url = f"https://api.github.com/repos/{acc['repo']}/actions/runs/{run['id']}"
            r_del = requests.delete(delete_url, headers=headers)
            if r_del.status_code in [204, 200]:
                deleted_count += 1
                
    return jsonify({
        "status": "success", 
        "cancelled_count": cancelled_count, 
        "deleted_count": deleted_count
    })

# وب‌هوک خطای ورک‌فلوها با یکپارچه‌سازی سیستم نجات
@app.route('/api/webhook/fail', methods=['POST'])
def webhook_fail():
    data = request.get_json()
    if not data:
        print("⚠️ [وب‌هوک خطا] پارامترهای ناقص یا خالی ارسال شده است.", flush=True)
        return "Invalid request", 400
        
    run_id = data.get('run_id')
    error_msg = data.get('error', '')
    gh_run_id = data.get('github_run_id')

    print(f"⚠️ [گزارش شکست فرآیند در اکشنز] شناسه: {run_id} | خطا: {error_msg}", flush=True)
    
    if gh_run_id:
        print(f"🧹 [پاک‌سازی خودکار] ثبت فرآیند حذف اجرای ناموفق {gh_run_id} در پس‌زمینه...", flush=True)
        threading.Thread(target=delete_github_run, args=(gh_run_id,)).start()
        
    if not run_id:
        return "Missing run_id", 400
        
    res = trigger_retry(run_id, gh_run_id, error_msg)
    return res, 200

# استریم چت زنده (SSE) برای تحلیل پاسخ‌های متنی گما
@app.route('/api/stream_chat/<run_id>')
def stream_chat(run_id):
    def generate_stream():
        import json
        file_path = f"static/images/{run_id}.txt"
        waited = 0
        while waited < 120:
            if os.path.exists(file_path):
                try:
                    with open(file_path, "r", encoding="utf-8") as f:
                        content = f.read().strip()
                    yield f"data: {json.dumps({'text': content})}\n\n"
                    yield "data: DONE\n\n"
                    return
                except Exception:
                    pass
            time.sleep(1)
            waited += 1
        yield f"data: {json.dumps({'text': '⚠️ خطای زمان انتظار: سرور در زمان مقرر پاسخ نداد.'})}\n\n"
        yield "data: DONE\n\n"
        
    return Response(generate_stream(), mimetype='text/event-stream')

# --- API برای ساخت عکس و شبیه‌سازی صدا ---
@app.route('/api/generate', methods=['POST'])
def generate():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای امنیتی] درخواست متوقف شد: هیچ توکنی متصل نیست.", flush=True)
        return jsonify({"status": "error", "message": "Secret GITHUB_TOKENs are missing!"}), 500
        
    data = request.json
    persian_prompt = data.get('prompt', '')

    # بررسی جهت شناسایی و تفکیک درخواست‌های شبیه‌ساز صدا و تقویت صدا
    is_voice_config = persian_prompt.startswith("VOICECONFIG_")

    # بررسی کلمات نامناسب تنها برای درخواست‌های عادی (غیر از شبیه‌ساز صدا)
    if not is_voice_config and has_forbidden_words(persian_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت فیلتر شد: {persian_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400
    
    print(f"📝 [ثبت درخواست جدید] پرامپت خام: {persian_prompt[:100]}...", flush=True)
    
    if is_voice_config:
        # کدهای تنظیمات صوتی نباید ترجمه شوند تا ساختار کاراکترها بدون تغییر باقی بماند
        english_prompt = persian_prompt
        print("🎙️ [تنظیمات صوتی] دور زدن مترجم گوگل جهت جلوگیری از تغییر کاراکترهای پیکربندی.", flush=True)
    else:
        try: 
            english_prompt = GoogleTranslator(source='auto', target='en').translate(persian_prompt)
            print(f"🔄 [ترجمه با موفقیت انجام شد] فارسی: {persian_prompt} -> انگلیسی: {english_prompt}", flush=True)
        except Exception as e: 
            print(f"⚠️ [ترجمه ناموفق] مترجم گوگل با خطا مواجه شد: {e}. استفاده از پرامپت خام.", flush=True)
            english_prompt = persian_prompt

    run_id = str(uuid.uuid4())
    
    client_payload = {
        "prompt": english_prompt, 
        "width": data.get('width', 1024), 
        "height": data.get('height', 1024), 
        "run_id": run_id, 
        "space_url": SPACE_URL
    }
    r = dispatch_github_workflow(data.get('action_name', 'generate-flux'), client_payload)
    
    if r.status_code == 204:
        print(f"✅ [درخواست دیسپچ شد] فرآیند با شناسه {run_id} با موفقیت در صف گیت‌هاب قرار گرفت.", flush=True)
        return jsonify({
            "status": "success", 
            "run_id": run_id, 
            "translated_prompt": english_prompt, 
            "translated": english_prompt
        })
    else:
        print(f"❌ [توقف درخواست] گیت‌هاب پاسخ غیرمنتظره داد (کد {r.status_code}): {r.text}", flush=True)
        return jsonify({"status": "error", "message": f"GitHub dispatch error: {r.status_code}"}), 400

# --- API مخصوص ویرایش عکس (AI Photoshop) ---
@app.route('/api/edit', methods=['POST'])
def edit_image():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای ویرایش] توکنی برای ارتباط وجود ندارد.", flush=True)
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    if 'image' not in request.files: 
        print("❌ [خطای ویرایش] فایلی ارسال نشده است.", flush=True)
        return jsonify({"status": "error", "message": "Image required"}), 400
    
    file = request.files['image']
    persian_prompt = request.form.get('prompt', '')

    if has_forbidden_words(persian_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت ویرایش فیلتر شد: {persian_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400
    
    print(f"📝 [درخواست ویرایش عکس] دستور فارسی: {persian_prompt}", flush=True)
    try: 
        english_prompt = GoogleTranslator(source='auto', target='en').translate(persian_prompt)
        print(f"🔄 [ترجمه ویرایش با موفقیت انجام شد] فارسی: {persian_prompt} -> انگلیسی: {english_prompt}", flush=True)
    except Exception as e: 
        print(f"⚠️ [ترجمه ناموفق ویرایش] استفاده از پرامپت خام: {e}", flush=True)
        english_prompt = persian_prompt

    run_id = str(uuid.uuid4())
    for k in ['image', 'image2', 'image3']:
        if k in request.files: request.files[k].save(f"static/images/{run_id}_{k}.png")

    # چسباندن آدرس‌ها با کاما برای انتقال ایمن از طریق تک متغیر گیت‌هاب
    urls = [f"{SPACE_URL}/static/images/{run_id}_image.png"]
    if 'image2' in request.files: urls.append(f"{SPACE_URL}/static/images/{run_id}_image2.png")
    if 'image3' in request.files: urls.append(f"{SPACE_URL}/static/images/{run_id}_image3.png")

    client_payload = {
        "prompt": english_prompt,
        "image_url": ",".join(urls),
        "run_id": run_id,
        "space_url": SPACE_URL
    }
    r = dispatch_github_workflow("generate-editor", client_payload)
    
    if r.status_code == 204:
        print(f"✅ [درخواست ویرایش عکس دیسپچ شد] فرآیند با شناسه {run_id} با موفقیت در صف گیت‌هاب قرار گرفت.", flush=True)
        return jsonify({"status": "success", "run_id": run_id, "translated": english_prompt})
    else:
        print(f"❌ [توقف ویرایش عکس] گیت‌هاب پاسخ خطا داد (کد {r.status_code}): {r.text}", flush=True)
        return jsonify({"status": "error", "message": f"GitHub dispatch error: {r.status_code}"}), 400

# --- API مخصوص تولید تصویر FLUX.2 ---
@app.route('/api/generate-flux2', methods=['POST'])
def generate_flux2():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای FLUX2] حسابی یافت نشد.", flush=True)
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    
    persian_prompt = request.form.get('prompt', '')
    if has_forbidden_words(persian_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت Flux2 فیلتر شد: {persian_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400
    
    print(f"📝 [ثبت درخواست جدید Flux2] پرامپت فارسی: {persian_prompt}", flush=True)
    try:
        english_prompt = GoogleTranslator(source='auto', target='en').translate(persian_prompt)
        print(f"🔄 [ترجمه Flux2 انجام شد] فارسی: {persian_prompt} -> انگلیسی: {english_prompt}", flush=True)
    except Exception as e:
        print(f"⚠️ [ترجمه ناموفق Flux2] استفاده از پرامپت خام: {e}", flush=True)
        english_prompt = persian_prompt

    run_id = str(uuid.uuid4())
    
    image_urls = []
    files = request.files.getlist('images')
    for idx, file in enumerate(files):
        if file and file.filename:
            ext = file.filename.split('.')[-1] if '.' in file.filename else 'png'
            input_filename = f"{run_id}_input_{idx}.{ext}"
            file.save(f"static/images/{input_filename}")
            image_urls.append(f"{SPACE_URL}/static/images/{input_filename}")

    try: width = int(request.form.get('width', 1024))
    except ValueError: width = 1024
        
    try: height = int(request.form.get('height', 1024))
    except ValueError: height = 1024

    try: steps = int(request.form.get('steps', 30))
    except ValueError: steps = 30

    try: guidance = float(request.form.get('guidance', 4.0))
    except ValueError: guidance = 4.0

    try:
        seed_raw = request.form.get('seed', '0')
        seed = int(seed_raw) if seed_raw.strip() else 0
    except ValueError:
        seed = 0

    client_payload = {
        "data": {
            "prompt": english_prompt,
            "image_urls": image_urls,
            "width": width,
            "height": height,
            "steps": steps,
            "guidance": guidance,
            "seed": seed,
            "randomize_seed": request.form.get('randomizeSeed') == 'true',
            "prompt_upsampling": request.form.get('promptUpsampling') == 'true',
            "run_id": run_id,
            "space_url": SPACE_URL,
            "hf_token": request.form.get('hfToken', '')
        }
    }
    r = dispatch_github_workflow("generate-flux2", client_payload)
    
    if r.status_code == 204:
        print(f"✅ [درخواست Flux2 دیسپچ شد] فرآیند با شناسه {run_id} با موفقیت در صف گیت‌هاب قرار گرفت.", flush=True)
        return jsonify({"status": "success", "run_id": run_id, "translated": english_prompt})
    else:
        print(f"❌ [توقف درخواست Flux2] خطا در ارسال درخواست دیسپچ: {r.status_code}", flush=True)
        return jsonify({"status": "error", "message": f"GitHub dispatch error: {r.status_code}"}), 400

# --- API مخصوص تبدیل عکس به ویدیو ---
@app.route('/api/generate-video', methods=['POST'])
def generate_video():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای ویدیو] حسابی جهت دیسپچ متصل نیست.", flush=True)
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    if 'image' not in request.files: 
        print("❌ [خطای ویدیو] تصویری به سرور ارسال نشده است.", flush=True)
        return jsonify({"status": "error", "message": "Image required"}), 400
    
    file = request.files['image']
    user_prompt = request.form.get('prompt', '').strip()
    duration = request.form.get('duration', 5.0)

    if has_forbidden_words(user_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت ویدیو فیلتر شد: {user_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400
    
    run_id = str(uuid.uuid4())
    
    input_filename = f"{run_id}_video_input.png"
    local_image_path = os.path.join("static/images", input_filename)
    file.save(local_image_path)
    image_public_url = f"{SPACE_URL}/static/images/{input_filename}"

    master_prompt = """You are an expert AI Animation Planner. Your absolute highest priority is to faithfully and creatively execute the user's specific request based on the provided image.

    1. If the user prompt is empty or generic (like "animate this"), add subtle, high-quality, believable cinematic motion (e.g., slow zoom, water flowing, wind in hair).
    2. If the user gives specific directions, focus ENTIRELY on executing that command perfectly. If the action is not visible in-frame, use cinematic camera movements to reveal it.
    3. You must output ONLY a highly detailed, descriptive animation prompt in ENGLISH. Do not translate literally; ENHANCE the prompt for a text-to-video AI model.
    4. MUST Include keywords at the end: cinematic, photorealistic, high detail, smooth motion, 8k.

    CRITICAL RULE: DO NOT say "Here is the prompt" or give any conversational explanations. DO NOT output JSON. Output ONLY the raw English animation prompt text and NOTHING ELSE."""

    english_prompt = ""
    groq_success = False
    
    prompt_for_groq = user_prompt if user_prompt else "لطفاً این تصویر را به یک ویدیوی سینمایی بسیار جذاب و واقع‌گرایانه متحرک کن."
    combined_prompt = f"{master_prompt}\n\nUser request: {prompt_for_groq}"

    print(f"🎬 [متحرک‌سازی تصویر] آغاز هماهنگی سناریو با پلانر تصویری Groq (Llama 4 Scout)...", flush=True)
    
    if GROQ_KEYS:
        # انتخاب کلید به صورت چرخشی و با امنیت بالا در پردازش‌های همزمان
        selected_key = get_next_groq_key()
        try:
            import base64
            # تبدیل تصویر به فرمت استاندارد Base64
            with open(local_image_path, "rb") as img_file:
                image_base64 = base64.b64encode(img_file.read()).decode('utf-8')
                
            headers = {
                "Authorization": f"Bearer {selected_key}",
                "Content-Type": "application/json"
            }
            payload = {
                "model": "meta-llama/llama-4-scout-17b-16e-instruct",
                "messages": [
                    {
                        "role": "user",
                        "content": [
                            {
                                "type": "text",
                                "text": combined_prompt
                            },
                            {
                                "type": "image_url",
                                "image_url": {
                                    "url": f"data:image/png;base64,{image_base64}"
                                }
                            }
                        ]
                    }
                ],
                "temperature": 0.7,
                "max_completion_tokens": 1024,
                "top_p": 1,
                "stream": False
            }
            
            response = requests.post("https://api.groq.com/openai/v1/chat/completions", headers=headers, json=payload, timeout=20)
            if response.status_code == 200:
                res_json = response.json()
                english_prompt = res_json['choices'][0]['message']['content'].strip()
                
                # پاکسازی تگ‌های مارک‌داون احتمالی از پاسخ متنی
                if "```" in english_prompt:
                    english_prompt = english_prompt.replace("```text", "").replace("```", "").replace("```json", "").strip()
                
                groq_success = True
                print("✅ بهینه‌سازی پرامپت با موفقیت توسط Groq انجام شد.", flush=True)
            else:
                print(f"⚠️ خطای API از سمت Groq (کد {response.status_code}): {response.text}", flush=True)
        except Exception as e:
            print(f"⚠️ خطا در ارتباط با Groq API: {e}", flush=True)

    if not groq_success:
        print("🔄 [پلانر تصویر با خطا مواجه شد یا کلیدی در دسترس نبود] بازگشت به مترجم ساده...", flush=True)
        try: 
            if user_prompt:
                english_prompt = GoogleTranslator(source='auto', target='en').translate(user_prompt)
                english_prompt += ", cinematic motion, photorealistic, high detail, smooth animation, 8k"
            else:
                english_prompt = "cinematic motion, photorealistic, high detail, smooth animation, 8k"
        except Exception as trans_err: 
            print(f"⚠️ خطا در ترجمه گوگل: {trans_err}", flush=True)
            english_prompt = "cinematic motion, photorealistic, high detail, smooth animation, 8k"

    print(f"🎥 [پرامپت ساخت نهایی ویدیو] {english_prompt}", flush=True)

    client_payload_video = {
        "prompt": english_prompt,
        "duration": duration,
        "image_url": image_public_url,
        "run_id": run_id,
        "space_url": SPACE_URL
    }
    r_vid = dispatch_github_workflow("generate-video", client_payload_video)
    
    if r_vid.status_code == 204:
        print(f"✅ [درخواست ساخت ویدیو دیسپچ شد] فرآیند با شناسه {run_id} با موفقیت در صف گیت‌هاب قرار گرفت.", flush=True)
        return jsonify({"status": "success", "run_id": run_id, "translated": english_prompt})
    else:
        print(f"❌ [توقف متحرک‌سازی عکس] دیسپچ با کد {r_vid.status_code} رد شد.", flush=True)
        return jsonify({"status": "error", "message": f"GitHub dispatch error: {r_vid.status_code}"}), 400

# ==========================================
# API اختصاصی جهت پردازش فایل صوتی در گیت هاب
# ==========================================
@app.route('/api/generate-audio', methods=['POST'])
def generate_audio():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای صوتی] توکن‌های گیت‌هاب یافت نشدند.", flush=True)
        return jsonify({"status": "error", "message": "Tokens missing"}), 500
    
    audio_type = request.form.get('type', 'text')
    persian_prompt = request.form.get('prompt', '')
    persian_negative = request.form.get('negative_prompt', 'music')
    duration = request.form.get('duration', '8')
    seed = request.form.get('seed', '-1')
    
    if has_forbidden_words(persian_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت صوتی فیلتر شد: {persian_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400
        
    print(f"📝 [ثبت درخواست صوتی جدید] نوع: {audio_type} | پرامپت فارسی: {persian_prompt}", flush=True)
    try: 
        english_prompt = GoogleTranslator(source='auto', target='en').translate(persian_prompt) if persian_prompt else ""
        english_negative = GoogleTranslator(source='auto', target='en').translate(persian_negative) if persian_negative else "music"
        print(f"🔄 [ترجمه با موفقیت انجام شد] فارسی: {persian_prompt} -> انگلیسی: {english_prompt}", flush=True)
    except Exception as e: 
        print(f"⚠️ [ترجمه ناموفق صوتی] استفاده از پرامپت صوتی خام: {e}", flush=True)
        english_prompt = persian_prompt
        english_negative = persian_negative

    run_id = str(uuid.uuid4())
    file_url = ""
    
    if audio_type == 'video':
        file = request.files.get('file')
        if not file: 
            print("❌ [خطای صوتی] فایل ویدیویی دریافت نشد.", flush=True)
            return jsonify({"status": "error", "message": "Video file required"}), 400
        ext = file.filename.split('.')[-1] if '.' in file.filename else 'mp4'
        filename = f"{run_id}_input.{ext}"
        file.save(f"static/images/{filename}")
        file_url = f"{SPACE_URL}/static/images/{filename}"

    client_payload = {
        "data": {
            "prompt": english_prompt,
            "negative_prompt": english_negative,
            "duration": duration,
            "seed": seed,
            "audio_type": audio_type,
            "file_url": file_url,
            "run_id": run_id,
            "space_url": SPACE_URL
        }
    }
    
    r = dispatch_github_workflow("generate-audio", client_payload)
    if r.status_code == 204:
        print(f"✅ [درخواست صوتی دیسپچ شد] فرآیند با شناسه {run_id} با موفقیت در صف گیت‌هاب قرار گرفت.", flush=True)
        return jsonify({"status": "success", "run_id": run_id, "translated": english_prompt})
    else:
        print(f"❌ [توقف درخواست صوتی] دیسپچ با خطا مواجه شد: {r.status_code}", flush=True)
        return jsonify({"status": "error", "message": f"GitHub dispatch error: {r.status_code}"}), 400

# ==========================================
# سیستم جدید چت بات (ارسال مستقیم و بدون تاخیر به گیت‌هاب)
# ==========================================
@app.route('/api/chat', methods=['POST'])
def chat_api():
    if not GITHUB_ACCOUNTS: 
        print("❌ [خطای چت] توکن گیت‌هاب جهت چت یافت نشد.", flush=True)
        return jsonify({"status": "error", "message": "Tokens missing"}), 500

    text_prompt = request.form.get('prompt', '')
    if has_forbidden_words(text_prompt):
        print(f"⚠️ [محتوای غیرمجاز] پرامپت چت فیلتر شد: {text_prompt}", flush=True)
        return jsonify({"status": "error", "message": "متن ورودی شامل کلمات نامناسب است."}), 400

    file_obj = request.files.get('file')
    run_id = str(uuid.uuid4())
    file_url = ""
    mime_type = ""

    print(f"💬 [ثبت چت] پرامپت کاربر: {text_prompt[:100]}...", flush=True)
    if file_obj:
        ext = file_obj.filename.split('.')[-1] if '.' in file_obj.filename else 'bin'
        mime_type = file_obj.mimetype
        filename = f"{run_id}_chat_attach.{ext}"
        file_obj.save(f"static/images/{filename}")
        file_url = f"{SPACE_URL}/static/images/{filename}"
        print(f"   📎 پیوست چت ثبت شد در: {file_url}", flush=True)

    client_payload = {
        "prompt": text_prompt,
        "file_url": file_url,
        "file_mime": mime_type,
        "run_id": run_id,
        "space_url": SPACE_URL
    }
    r = dispatch_github_workflow("chat-gemma", client_payload)
    if r.status_code == 204:
         print(f"✅ [درخواست چت دیسپچ شد] چت با شناسه {run_id} ارسال شد.", flush=True)
         return jsonify({"status": "success", "run_id": run_id})
    else:
         print(f"❌ [توقف چت] گیت‌هاب به دیسپچ چت پاسخ خطا داد: {r.status_code}", flush=True)
         return jsonify({"status": "error", "message": f"GitHub dispatch error: {r.status_code}"}), 400

@app.route('/api/worker/poll', methods=['POST'])
def worker_poll():
    return jsonify({"status": "empty"})

# --- API میکس ویدیوها سمت سرور ---
@app.route('/api/merge-videos', methods=['POST'])
def merge_videos():
    if 'base_video' not in request.files or 'new_clip' not in request.files:
        return jsonify({"error": "هر دو فایل ویدیویی برای میکس لازم هستند."}), 400

    base_video_file = request.files['base_video']
    new_clip_file = request.files['new_clip']
    
    temp_files_to_clean = []

    try:
        base_video_path = os.path.join(TEMP_DIR, f"{uuid.uuid4().hex}.mp4")
        new_clip_path = os.path.join(TEMP_DIR, f"{uuid.uuid4().hex}.mp4")
        output_path = os.path.join(TEMP_DIR, f"{uuid.uuid4().hex}.mp4")

        temp_files_to_clean.extend([base_video_path, new_clip_path, output_path])

        base_video_file.save(base_video_path)
        new_clip_file.save(new_clip_path)

        probe = ffmpeg.probe(base_video_path)
        video_stream = next((stream for stream in probe['streams'] if stream['codec_type'] == 'video'), None)
        width = int(video_stream['width'])
        height = int(video_stream['height'])

        input1 = ffmpeg.input(base_video_path)
        input2 = ffmpeg.input(new_clip_path).filter('scale', width, height).filter('setsar', '1')

        merged_video = ffmpeg.concat(input1, input2, v=1, a=0).output(
            output_path,
            crf=18,
            preset='veryfast',
            pix_fmt='yuv420p'
        )
        
        merged_video.run(overwrite_output=True, quiet=True)
        
        @after_this_request
        def cleanup(response):
            try:
                for f_path in temp_files_to_clean:
                    if os.path.exists(f_path):
                        os.remove(f_path)
            except:
                pass
            return response

        return send_file(output_path, mimetype='video/mp4', as_attachment=True, download_name='merged_video.mp4')

    except ffmpeg.Error as e:
        for f_path in temp_files_to_clean:
            if os.path.exists(f_path):
                os.remove(f_path)
        return jsonify({"error": "خطا در پردازش و میکس ویدیو در سرور."}), 500
    except Exception as e:
        for f_path in temp_files_to_clean:
            if os.path.exists(f_path):
                os.remove(f_path)
        return jsonify({"error": "خطای پیش‌بینی نشده در سرور."}), 500

# --- مدیریت اعتبارها ---
@app.route('/api/check-credit', methods=['POST'])
def check_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    credits_remaining = USAGE_LIMIT
    limit_reached = False
    reset_timestamp = 0
    
    if user_record:
        if user_record['week_start'] < (now - ONE_WEEK_SECONDS):
            c.execute("UPDATE users SET count = 0, week_start = ? WHERE id = ?", (now, user_id))
            conn.commit()
            credits_remaining = USAGE_LIMIT
        else:
            credits_remaining = max(0, USAGE_LIMIT - user_record['count'])
            if credits_remaining == 0:
                limit_reached = True
                reset_timestamp = user_record['week_start'] + ONE_WEEK_SECONDS
                
    conn.close()
    return jsonify({
        "credits_remaining": credits_remaining, 
        "limit_reached": limit_reached, 
        "reset_timestamp": reset_timestamp
    })

@app.route('/api/use-credit', methods=['POST'])
def use_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    if user_record:
        if user_record['week_start'] < (now - ONE_WEEK_SECONDS):
            c.execute("UPDATE users SET count = 1, week_start = ? WHERE id = ?", (now, user_id))
        else:
            if user_record['count'] >= USAGE_LIMIT:
                conn.close()
                reset_timestamp = user_record['week_start'] + ONE_WEEK_SECONDS
                return jsonify({"status": "limit_reached", "credits_remaining": 0, "reset_timestamp": reset_timestamp}), 429
            c.execute("UPDATE users SET count = count + 1 WHERE id = ?", (user_id,))
    else:
        c.execute("INSERT INTO users (id, count, week_start) VALUES (?, 1, ?)", (user_id, now))
        
    conn.commit()
    c.execute("SELECT count FROM users WHERE id = ?", (user_id,))
    new_count = c.fetchone()['count']
    credits_remaining = USAGE_LIMIT - new_count
    
    conn.close()
    return jsonify({"status": "success", "credits_remaining": credits_remaining})

@app.route('/api/check-image-credit', methods=['POST'])
def check_image_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_image_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    credits_remaining = IMAGE_USAGE_LIMIT
    limit_reached = False
    reset_timestamp = 0
    
    if user_record:
        if user_record['week_start'] < (now - ONE_DAY_SECONDS):
            c.execute("UPDATE users SET count = 0, week_start = ? WHERE id = ?", (now, user_id))
            conn.commit()
            credits_remaining = IMAGE_USAGE_LIMIT
        else:
            credits_remaining = max(0, IMAGE_USAGE_LIMIT - user_record['count'])
            if credits_remaining == 0:
                limit_reached = True
                reset_timestamp = user_record['week_start'] + ONE_DAY_SECONDS
                
    conn.close()
    return jsonify({
        "credits_remaining": credits_remaining, 
        "limit_reached": limit_reached, 
        "reset_timestamp": reset_timestamp
    })

@app.route('/api/use-image-credit', methods=['POST'])
def use_image_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_image_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    if user_record:
        if user_record['week_start'] < (now - ONE_DAY_SECONDS):
            c.execute("UPDATE users SET count = 1, week_start = ? WHERE id = ?", (now, user_id))
        else:
            if user_record['count'] >= IMAGE_USAGE_LIMIT:
                conn.close()
                reset_timestamp = user_record['week_start'] + ONE_DAY_SECONDS
                return jsonify({"status": "limit_reached", "credits_remaining": 0, "reset_timestamp": reset_timestamp}), 429
            c.execute("UPDATE users SET count = count + 1 WHERE id = ?", (user_id,))
    else:
        c.execute("INSERT INTO users (id, count, week_start) VALUES (?, 1, ?)", (user_id, now))
        
    conn.commit()
    c.execute("SELECT count FROM users WHERE id = ?", (user_id,))
    new_count = c.fetchone()['count']
    credits_remaining = IMAGE_USAGE_LIMIT - new_count
    
    conn.close()
    return jsonify({"status": "success", "credits_remaining": credits_remaining})

@app.route('/api/check-edit-credit', methods=['POST'])
def check_edit_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_image_edit_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    credits_remaining = EDIT_USAGE_LIMIT
    limit_reached = False
    reset_timestamp = 0
    
    if user_record:
        if user_record['week_start'] < (now - ONE_WEEK_SECONDS):
            c.execute("UPDATE users SET count = 0, week_start = ? WHERE id = ?", (now, user_id))
            conn.commit()
            credits_remaining = EDIT_USAGE_LIMIT
        else:
            credits_remaining = max(0, EDIT_USAGE_LIMIT - user_record['count'])
            if credits_remaining == 0:
                limit_reached = True
                reset_timestamp = ONE_WEEK_SECONDS + user_record['week_start']
                
    conn.close()
    return jsonify({
        "credits_remaining": credits_remaining, 
        "limit_reached": limit_reached, 
        "reset_timestamp": reset_timestamp
    })

@app.route('/api/use-edit-credit', methods=['POST'])
def use_edit_credit():
    data = request.get_json()
    if not data: return jsonify({"error": "Invalid request"}), 400
    user_id = get_user_identifier(data)
    
    conn = get_image_edit_db_connection()
    c = conn.cursor()
    c.execute("SELECT * FROM users WHERE id = ?", (user_id,))
    user_record = c.fetchone()
    
    now = time.time()
    if user_record:
        if user_record['week_start'] < (now - ONE_WEEK_SECONDS):
            c.execute("UPDATE users SET count = 1, week_start = ? WHERE id = ?", (now, user_id))
        else:
            if user_record['count'] >= EDIT_USAGE_LIMIT:
                conn.close()
                reset_timestamp = user_record['week_start'] + ONE_WEEK_SECONDS
                return jsonify({"status": "limit_reached", "credits_remaining": 0, "reset_timestamp": reset_timestamp}), 429
            c.execute("UPDATE users SET count = count + 1 WHERE id = ?", (user_id,))
    else:
        c.execute("INSERT INTO users (id, count, week_start) VALUES (?, 1, ?)", (user_id, now))
        
    conn.commit()
    c.execute("SELECT count FROM users WHERE id = ?", (user_id,))
    new_count = c.fetchone()['count']
    credits_remaining = EDIT_USAGE_LIMIT - new_count
    
    conn.close()
    return jsonify({"status": "success", "credits_remaining": credits_remaining})


# --- دریافت و ارسال فایل ---
@app.route('/api/webhook/upload', methods=['POST'])
def webhook_upload():
    run_id = request.form.get('run_id')
    gh_run_id = request.form.get('github_run_id')
    ext = request.form.get('ext', 'webp')
    
    if 'file' not in request.files or not run_id:
        print("⚠️ [وب‌هوک آپلود] آپلود ناموفق به دلیل کسری پارامتر.", flush=True)
        return "Invalid request", 400
        
    file = request.files['file']
    file_path = f"static/images/{run_id}.{ext}"
    file.save(file_path)
    print(f"📥 [فایل دریافت شد] ذخیره‌سازی موفق خروجی در مسیر: {file_path}", flush=True)
    
    if gh_run_id: 
        print(f"🧹 [پاک‌سازی خودکار] ثبت فرآیند حذف اجرای {gh_run_id} در پس‌زمینه...", flush=True)
        threading.Thread(target=delete_github_run, args=(gh_run_id,)).start()
    return "OK", 200

# پراکسی ایمن جهت دور زدن محدودیت‌های CORS برای پخش لینک‌های بله در مرورگر
@app.route('/api/proxy_bale')
def proxy_bale():
    file_id = request.args.get('file_id')
    bot_token = os.environ.get("BALE_BOT_TOKEN", "").strip()
    if not file_id or not bot_token:
        return "Missing parameters", 400
    
    bale_url = f"https://tapi.bale.ai/file/bot{bot_token}/{file_id}"
    try:
        req = requests.get(bale_url, stream=True)
        
        # استخراج و اعمال هدرهای حیاتی فایل جهت محاسبه صحیح زمان و امکان جلو/عقب بردن آهنگ در پلیر
        headers = {
            'Content-Type': req.headers.get('content-type', 'audio/wav'),
            'Content-Length': req.headers.get('content-length', ''),
            'Accept-Ranges': 'bytes',
            'Access-Control-Allow-Origin': '*'
        }
        # حذف هدرهای خالی احتمالی برای پیشگیری از بروز خطا در پاسخ فلاسک
        headers = {k: v for k, v in headers.items() if v}
        
        return Response(stream_with_context(req.iter_content(chunk_size=8192)),
                        headers=headers,
                        status=req.status_code)
    except Exception as e:
        return str(e), 500

@app.route('/api/status/<run_id>')
def check_status(run_id):
    # بررسی وجود فایل گزارش خطای نهایی
    error_path = f"static/images/{run_id}.txt"
    if os.path.exists(error_path):
        try:
            with open(error_path, "r", encoding="utf-8") as ef:
                error_msg = ef.read().strip()
            return jsonify({"status": "failed", "message": error_msg})
        except Exception:
            pass

    # بررسی فایل json (ایجاد شده توسط اسکریپت تقویت صدا برای لینک‌های بله)
    json_path = f"static/images/{run_id}.json"
    if os.path.exists(json_path):
        try:
            with open(json_path, "r", encoding="utf-8") as jf:
                data = json.load(jf)
            
            denoised = data.get("denoised_url", "")
            enhanced = data.get("enhanced_url", "")
            
            # تبدیل لینک مستقیم بله به لینک پراکسی سرور برای عبور از تحریم‌ها و CORS مرورگر
            if "tapi.bale.ai/file/bot" in denoised:
                file_id = denoised.split("/")[-1]
                denoised = f"/api/proxy_bale?file_id={file_id}"
            
            if "tapi.bale.ai/file/bot" in enhanced:
                file_id = enhanced.split("/")[-1]
                enhanced = f"/api/proxy_bale?file_id={file_id}"
                
            return jsonify({
                "status": "ready",
                "url": enhanced,
                "denoised_url": denoised,
                "enhanced_url": enhanced
            })
        except Exception:
            pass

    valid_extensions = [
        'png', 'jpg', 'jpeg', 'webp', 'gif',  
        'mp4', 'webm', 'mov', 'mkv', 'avi',   
        'mp3', 'wav', 'ogg', 'm4a', 'flac'
    ]
    
    for ext in valid_extensions:
        file_path = f"static/images/{run_id}.{ext}"
        if os.path.exists(file_path):
            seed_val = None
            seed_path = f"static/images/{run_id}_seed.txt"
            if os.path.exists(seed_path):
                try:
                    with open(seed_path, 'r') as sf:
                        seed_val = sf.read().strip()
                except Exception:
                    pass
            
            resp = {"status": "ready", "url": f"/static/images/{run_id}.{ext}"}
            if seed_val:
                resp["seed"] = seed_val
            return jsonify(resp)

    # نظارت بر وضعیت جاری در گیت‌هاب در صورت نبود خروجی
    now = time.time()
    last_check = LAST_RUN_CHECK.get(run_id, 0)
    if now - last_check > 12:  
        LAST_RUN_CHECK[run_id] = now
        threading.Thread(target=check_github_run_status_and_log, args=(run_id,)).start()
            
    return jsonify({"status": "processing"})

@app.route('/static/images/<filename>')
def serve_file(filename):
    return send_from_directory('static/images', filename)

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=7860)