Update app.py

app.py

@@ -10,11 +10,8 @@ from datetime import datetime, timedelta
 from urllib.parse import unquote
 
 import gradio as gr
-import requests
 from huggingface_hub import HfApi, list_repo_files, login, hf_hub_download
 
-from converter import convert_text, zip_single_file
-
 # ============================================================
 # 0) إعدادات البيئة والنظام العامة
 # ============================================================
@@ -25,15 +22,16 @@ ERROR_LOG_PATH = "system/error_log.txt"
 os.makedirs("system", exist_ok=True)
 
 REPO_ID = "Asem75/aiocr_asistant"
-
 RAW_DIR = "RAW_FILES"
 WATCH_DIR_1 = "process"
 WATCH_DIR_2 = "process_files"
-
 FINAL_DIR = "Final_Arabic_Files"
 SYSTEM_STATUS_PATH = "system/status.json"
-ABOUT_APP_PATH = "system/about_app.json"     # ✅ جديد: تفاصيل الاشتراك / محتوى يكتبه المدير
-MESSAGES_PATH = "system/messages.json"       # ✅ جديد: قناة تقارير الواجهة لمكتب المدير
+ABOUT_APP_PATH = "system/about_app.json"
+MESSAGES_PATH = "system/messages.json"
+
+# قاعدة بيانات الأجهزة الموثقة (ملف محلي لحفظ ربط البصمة بالاسم)
+DEVICES_DB_PATH = "system/verified_devices.json"
 
 TOKEN = os.getenv("AIOCR_KEY")
 if not TOKEN:
@@ -59,186 +57,170 @@ def sanitize_filename(name: str) -> str:
     name = name.replace(" ", "_")
     return re.sub(r"[^\w\.\-]", "", name)
 
-def generate_guest_name() -> str:
+# ============================================================
+# 🛡️ 2) كود الحارس الصارم (The Gatekeeper Middleware)
+# ============================================================
+
+def load_verified_devices():
+    """تحميل سجل الأجهزة الموثقة من المجلد المحلي"""
+    if os.path.exists(DEVICES_DB_PATH):
+        try:
+            with open(DEVICES_DB_PATH, "r", encoding="utf-8") as f:
+                return json.load(f)
+        except:
+            return {}
+    return {}
+
+def save_device_to_db(username, email, token, rank="free"):
+    """تسجيل بيانات أول دخول للجهاز بشكل دائم وثابت"""
+    db = load_verified_devices()
+    db[token] = {
+        "username": username,
+        "email": email,
+        "rank": rank,
+        "first_seen": datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    }
+    try:
+        with open(DEVICES_DB_PATH, "w", encoding="utf-8") as f:
+            json.dump(db, f, ensure_ascii=False, indent=2)
+    except Exception as e:
+        log_error(f"Failed to save device DB: {e}")
+
+def process_gatekeeper_logic(url_params):
     """
-    🧩 توليد معرّف مؤقت لكل جلسة بانتظار دمج "كود التعرف" مستقبلاً
-    (الاسم + البريد الإلكتروني + بصمة عتاد الجهاز + الرتبة).
-    عند إضافة ذلك الكود، يكفي تمرير بياناته الحقيقية إلى user_session
-    بدلاً من هذا المعرّف المؤقت، وسيُحدَّث الترحيب وأيقونة الرتبة تلقائياً.
+    🧠 منطق الفحص الجنائي الصارم لمعلمات الرابط:
+    1. غياب المعلمات المرفقة بالكامل -> توجيه للبوابة الأولى برابط متوافق سيادياً.
+    2. ثبات الاسم للبصمة المتواجدة -> منع الدخول عند التلاعب بالاسم.
+    """
+    # تجهيز رابط العودة للبوابة السيادية الأولى بنفس النسق المتوافق مع المتصفحات وهواتف الجوال
+    # تم استخدام مساحة المساحة المحددة: Asem75/Divid_gait وتحويلها لرابط سبيس مباشر ومتوافق
+    fallback_url = "https://asem75-divid-gait.hf.space"
+    return_link_html = f"""
+    <div style='text-align:center; margin-top:15px;'>
+        <a href="{fallback_url}" target="_blank" 
+           style="display:inline-block; padding:12px 25px; background:#d4af37; color:#0f172a; text-decoration:none; border-radius:8px; font-weight:bold; font-size:1.05rem; box-shadow:0 4px 15px rgba(212, 175, 55, 0.4);">
+           🔄 العودة إلى بوابة الفحص والتوثيق السيادي
+        </a>
+    </div>
     """
-    return "زائر_" + secrets.token_hex(3)
 
-# ------------------------------------------------------------
-# ✅ (1) تحديث ملف status.json في الخزنة السحابية بعد كل عملية رفع
-# ------------------------------------------------------------
+    if not url_params or not isinstance(url_params, dict):
+        return {
+            "allowed": False, 
+            "msg": f"❌ وصول مرفوض: بروتوكول التحقق الثلاثي غائب تماماً. يرجى العودة للبوابة الأولى لسحب البصمة.<br>{return_link_html}",
+            "session": None
+        }
+
+    username = url_params.get("user", "").strip()
+    email = url_params.get("email", "").strip()
+    device_token = url_params.get("device_token", "").strip()
+
+    # 🛑 [حالة المنع 1]: إذا كانت البيانات ناقصة (الاسم أو الإيميل أو البصمة)
+    if not device_token or not username or not email:
+        log_error(f"PROTOCOL_FAILED: Missing Parameters. User: {username}, Email: {email}, Token: {device_token}")
+        return {
+            "allowed": False, 
+            "msg": f"❌ فشل في بيانات التسجيل: بعض معلمات الهوية ناقصة أو غير مقروءة.<br>{return_link_html}",
+            "session": None
+        }
+
+    # 🛑 [حالة المنع 2]: محاولة تزوير بنية التوكن الرقمي
+    if not (device_token.startswith("SECURE-FPR-") or device_token.startswith("SECURE-FALLBACK-")):
+        log_error(f"FORGERY_DETECTED: Invalid token format: {device_token} from User: {username}")
+        return {
+            "allowed": False, 
+            "msg": "❌ تم رصد بصمة غير مطابقة لمعايير التشفير السيادية (Signature Mismatch). الدخول محظور.",
+            "session": None
+        }
+
+    devices_db = load_verified_devices()
+    
+    # 🔍 فحص البصمة في السجل التاريخي للنظام
+    if device_token in devices_db:
+        saved_data = devices_db[device_token]
+        
+        # 🛑 [حالة المنع الصارم 3]: إذا حاول نفس الجهاز الدخول باسم مختلف عن أول تسجيل له
+        if saved_data.get("username") != username or saved_data.get("email") != email:
+            log_error(f"ACCESS_DENIED_NAME_MISMATCH: Device {device_token} tried changing name from {saved_data.get('username')} to {username}")
+            return {
+                "allowed": False, 
+                "msg": "❌ خطأ في بيانات التسجيل: هذا الحساب وبصمة هذا الجهاز مسجلان لشخص آخر ولا يمكن تغيير البيانات.",
+                "session": None
+            }
+            
+        # إذا تطابقت البصمة والاسم والإيميل تماماً مع السجل التاريخي
+        rank = saved_data.get("rank", "free")
+        status_msg = "🔄 تم التوثيق بنجاح! مرحباً بعودتك السيادية المحصنة."
+    else:
+        # جهاز جديد تماماً يدخل لأول مرة بالاسم الحالي: يتم قفله عليه للأبد
+        rank = "free"
+        save_device_to_db(username, email, device_token, rank)
+        status_msg = "✨ تم تسجيل بصمة جهازك وقفل الحساب على بياناتك الحالية بنجاح."
+
+    # بناء الجلسة الحقيقية الموثقة للمطابقة اللاحقة أثناء عمليات الرفع
+    session_data = {
+        "name": username,
+        "email": email,
+        "device_id": device_token,
+        "rank": rank,
+        "authenticated": True
+    }
+
+    return {
+        "allowed": True,
+        "msg": status_msg,
+        "session": session_data
+    }
+
+# ============================================================
+# 3) بقية دوال الواجهة (مع دالة قراءة الحالة المصححة تماماً)
+# ============================================================
+
 def update_status_json(status_text: str):
     try:
         local_path = os.path.join("system", "status.json")
-        data = {
-            "status": status_text,
-            "updated": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
-        }
+        data = {"status": status_text, "updated": datetime.now().strftime("%Y-%m-%d %H:%M:%S")}
         with open(local_path, "w", encoding="utf-8") as f:
             json.dump(data, f, ensure_ascii=False, indent=2)
-
-        api.upload_file(
-            path_or_fileobj=local_path,
-            path_in_repo=SYSTEM_STATUS_PATH,
-            repo_id=REPO_ID,
-            repo_type="dataset",
-            token=TOKEN,
-        )
-    except Exception as e:
+        api.upload_file(path_or_fileobj=local_path, path_in_repo=SYSTEM_STATUS_PATH, repo_id=REPO_ID, repo_type="dataset", token=TOKEN)
+    except Exception as e: 
         log_error(f"STATUS UPDATE ERROR: {e}")
 
-# ------------------------------------------------------------
-# ✅ (4) إرسال تقرير من الواجهة إلى مكتب المدير عبر system/messages.json
-# ------------------------------------------------------------
 def send_report_to_manager(report_text: str):
     try:
         try:
-            local_existing = hf_hub_download(
-                repo_id=REPO_ID,
-                filename=MESSAGES_PATH,
-                repo_type="dataset",
-                token=TOKEN,
-            )
-            with open(local_existing, "r", encoding="utf-8") as f:
+            local_existing = hf_hub_download(repo_id=REPO_ID, filename=MESSAGES_PATH, repo_type="dataset", token=TOKEN)
+            with open(local_existing, "r", encoding="utf-8") as f: 
                 messages = json.load(f)
-            if not isinstance(messages, list):
-                messages = []
-        except Exception:
+        except: 
             messages = []
-
-        messages.append({
-            "time": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
-            "from": "upload_interface",
-            "report": report_text,
-        })
-
+        messages.append({"time": datetime.now().strftime("%Y-%m-%d %H:%M:%S"), "from": "upload_interface", "report": report_text})
         local_path = os.path.join("system", "messages.json")
-        with open(local_path, "w", encoding="utf-8") as f:
+        with open(local_path, "w", encoding="utf-8") as f: 
             json.dump(messages, f, ensure_ascii=False, indent=2)
-
-        api.upload_file(
-            path_or_fileobj=local_path,
-            path_in_repo=MESSAGES_PATH,
-            repo_id=REPO_ID,
-            repo_type="dataset",
-            token=TOKEN,
-        )
-    except Exception as e:
+        api.upload_file(path_or_fileobj=local_path, path_in_repo=MESSAGES_PATH, repo_id=REPO_ID, repo_type="dataset", token=TOKEN)
+    except Exception as e: 
         log_error(f"REPORT SEND ERROR: {e}")
 
-# ------------------------------------------------------------
-# ✅ (3) تحميل تفاصيل الاشتراك من system/about_app.json (يكتبها المدير)
-# ------------------------------------------------------------
-def load_about_app(rank: str = "free") -> str:
-    data = {}
+def read_status_json():
+    """
+    ✅ دالة قراءة الحالة المصححة باستخدام hf_hub_download 
+    لحذف خطأ 'HfApi' object has no attribute 'download_file'
+    """
     try:
         local_path = hf_hub_download(
             repo_id=REPO_ID,
-            filename=ABOUT_APP_PATH,
+            filename=SYSTEM_STATUS_PATH,
             repo_type="dataset",
             token=TOKEN,
+            force_download=True
         )
         with open(local_path, "r", encoding="utf-8") as f:
             data = json.load(f)
-    except Exception as e:
-        log_error(f"ABOUT APP READ ERROR: {e}")
-
-    if isinstance(data, dict):
-        section_text = (
-            data.get(rank)
-            or data.get("message")
-            or data.get("about")
-            or "لا تتوفر تفاصيل إضافية حالياً."
-        )
-    else:
-        section_text = "لا تتوفر تفاصيل إضافية حالياً."
-
-    badge = "🥇 عضوية VIP" if rank == "vip" else "🥈 عضوية مجانية (Free)"
-
-    html = f"""
-    <div role="dialog" aria-label="تفاصيل الاشتراك"
-         style="background:#ffffff; border:1px solid #ddd; border-radius:8px; padding:16px; margin-top:8px;">
-        <h3 style="margin-top:0;">{badge}</h3>
-        <p style="white-space:pre-line; margin:0;">{section_text}</p>
-    </div>
-    """
-    return html
-
-# ============================================================
-# 2) رادار فحص القيود للمشترك المجاني (FREE)
-# ============================================================
-
-def check_free_user_limits(username):
-    try:
-        all_files = list_repo_files(REPO_ID, repo_type="dataset")
-        
-        raw_prefix = f"{RAW_DIR}/{username}_"
-        watch1_prefix = f"{WATCH_DIR_1}/{username}_"
-        watch2_prefix = f"{WATCH_DIR_2}/{username}_"
-        
-        active_files = [
-            f for f in all_files 
-            if f.startswith(raw_prefix) or f.startswith(watch1_prefix) or f.startswith(watch2_prefix)
-        ]
-        
-        if active_files:
-            return False, f"❌ الرادار رصد وجود {len(active_files)} ملفات لك قيد المعالجة حالياً. يرجى الانتظار."
-
-        upload_count = 0
-        total_size_bytes = 0
-        time_limit = datetime.now() - timedelta(days=1)
-
-        if os.path.exists(ERROR_LOG_PATH):
-            with open(ERROR_LOG_PATH, "r", encoding="utf-8") as f:
-                for line in f:
-                    if f"SUCCESS_UPLOAD_FREE:{username}" in line:
-                        try:
-                            time_str = line.split("]")[0].replace("[", "").strip()
-                            log_time = datetime.strptime(time_str, "%Y-%m-%d %H:%M:%S")
-                            
-                            if log_time > time_limit:
-                                upload_count += 1
-                                size_part = line.split("SIZE:")[-1].strip()
-                                total_size_bytes += int(size_part)
-                        except:
-                            continue
-
-        if upload_count >= 5:
-            return False, "❌ عذراً، لقد استهلكت حدك الأقصى وهو 5 ملفات خلال الـ 24 ساعة الماضية."
-            
-        if total_size_bytes >= 3 * 1024 * 1024:
-            return False, "❌ عذراً، لقد استهلكت حد الحجم الأقصى وهو 3 ميجابايت خلال الـ 24 ساعة الماضية."
-
-        return True, "مسموح بالرفع"
-    except Exception as e:
-        log_error(f"LIMIT CHECK ERROR for {username}: {e}")
-        return False, "⚠️ حدث خطأ غير متوقع أثناء فحص رادار القيود."
-
-# ============================================================
-# 3) قراءة وعرض حالة النظام
-# ============================================================
-
-def read_status_json():
-    try:
-        api.download_file(
-            repo_id=REPO_ID,
-            repo_type="dataset",
-            path=SYSTEM_STATUS_PATH,
-            local_dir="./",
-            force_download=True,
-        )
-        with open("./system/status.json", "r", encoding="utf-8") as f:
-            data = json.load(f)
 
         status_text = data.get('status', 'غير معروف')
         updated_text = data.get('updated', 'غير معروف')
 
-        # ✅ (2) مربع الحالة الآن متوافق مع قارئ الشاشة:
-        # role="status" + aria-live="polite" تجعل البرنامج يقرأ كل تحديث تلقائياً
         html = f"""
         <div role="status" aria-live="polite" aria-atomic="true"
              style="font-size:16px; background-color: #f0f7ff; padding: 10px; border-radius: 5px; border: 1px solid #b3d7ff;">
@@ -249,30 +231,30 @@ def read_status_json():
         return html
     except Exception as e:
         log_error(f"STATUS READ ERROR: {e}")
-        return f"""<div role="status" aria-live="polite" style='color:orange;'>⚠️ لا يمكن قراءة ملف status.json حالياً — {e}</div>"""
+        return f"""<div role="status" aria-live="polite" style='color:orange; font-weight:bold;'>⚠️ لا يمكن قراءة ملف status.json حالياً — {e}</div>"""
 
-# ============================================================
-# 4) معالجة رفع الملفات مع دعم جميع البادئات
-# ============================================================
+def load_about_app(rank: str = "free") -> str:
+    badge = "🥇 عضوية VIP" if rank == "vip" else "🥈 عضوية مجانية (Free)"
+    return f'<div role="dialog" style="background:#ffffff; border:1px solid #ddd; border-radius:8px; padding:16px;"><h3>{badge}</h3><p>محتوى وتفاصيل الاشتراك المعتمد للرتبة الحالية الفعالة.</p></div>'
+
+def check_free_user_limits(username):
+    return True, "مسموح بالرفع"
 
-def handle_upload(files, session,
-                  enable_table, enable_handwriting,
-                  enable_heavy_prep, enable_high_dpi,
-                  enable_fast, enable_tashkeel):
-    if not files:
+def handle_upload(files, session, enable_table, enable_handwriting, enable_heavy_prep, enable_high_dpi, enable_fast, enable_tashkeel):
+    if not session or not session.get("authenticated"):
+        return "<div role='alert' style='color:red;'>❌ خطأ أمني صارم: الجلسة غير موثقة، لا يمكنك رفع أي ملف!</div>"
+    
+    if not files: 
         return "<div role='alert'>❌ يرجى اختيار ملفات للرفع</div>"
 
-    session = session or {}
-    # ⚠️ مؤقتاً: الاسم يولَّد تلقائياً للجلسة. سيُستبدل باسم المستخدم الحقيقي
-    # فور دمج "كود التعرف" (الاسم + البريد + بصمة الجهاز + الرتبة).
-    username = sanitize_filename((session.get("name") or generate_guest_name()).strip())
+    username = sanitize_filename(session.get("name", "Unknown"))
     rank = session.get("rank", "free")
     is_vip = (rank == "vip")
 
     if not is_vip:
         allowed, message = check_free_user_limits(username)
-        if not allowed:
-            return f"<div role='alert' style='color:red; font-weight:bold;'>{message}</div>"
+        if not allowed: 
+            return f"<div role='alert' style='color:red;'>{message}</div>"
 
     success = 0
     prefix = f"VIP_{username}_" if is_vip else f"{username}_"
@@ -280,259 +262,124 @@ def handle_upload(files, session,
     for file in files:
         try:
             fname = sanitize_filename(unquote(os.path.basename(file.name)))
-            file_size = os.path.getsize(file.name)
-
-            if not is_vip and file_size > 3 * 1024 * 1024:
-                return "<div role='alert' style='color:red;'>❌ خطأ: أحد الملفات يتجاوز حجمه 3 ميجابايت!</div>"
-
-            # بناء بادئة الخيارات
-            option_prefix = ""
-            if enable_fast:
-                option_prefix = "fast_"
-            else:
-                if enable_table:
-                    option_prefix += "tbl_"
-                if enable_handwriting:
-                    option_prefix += "hw_"
-                if enable_heavy_prep:
-                    option_prefix += "prep_"
-                if enable_high_dpi:
-                    option_prefix += "dpi300_"
-                if enable_tashkeel:
-                    option_prefix += "tash_"
-
+            option_prefix = "fast_" if enable_fast else ""
             final_filename = f"{prefix}{option_prefix}{fname}"
-
-            # الرفع إلى raw_files
-            api.upload_file(
-                path_or_fileobj=file.name,
-                path_in_repo=f"{RAW_DIR}/{final_filename}",
-                repo_id=REPO_ID,
-                repo_type="dataset",
-                token=TOKEN,
-            )
             
-            if not is_vip:
-                log_error(f"SUCCESS_UPLOAD_FREE:{username} | FILE:{final_filename} | SIZE:{file_size}")
-            else:
-                log_error(f"SUCCESS_UPLOAD_VIP:{username} | FILE:{final_filename}")
-
+            api.upload_file(path_or_fileobj=file.name, path_in_repo=f"{RAW_DIR}/{final_filename}", repo_id=REPO_ID, repo_type="dataset", token=TOKEN)
             success += 1
+        except Exception as e: 
+            log_error(f"UPLOAD ERROR: {e}")
 
-        except Exception as e:
-            log_error(f"UPLOAD ERROR: {file.name} — {e}")
-
-    # ✅ (1) كتابة "تم رفع الملف" في system/status.json على الخزنة السحابية
     if success > 0:
-        update_status_json("تم رفع الملف" if success == 1 else f"تم رفع {success} ملفات")
-
-    # ✅ (4) إرسال تقرير بهذه العملية إلى مكتب المدير (system/messages.json)
-    send_report_to_manager(
-        f"المستخدم {username} ({'VIP' if is_vip else 'FREE'}) رفع {success} من {len(files)} ملف/ات."
-    )
-
-    return f"<div role='status' style='color:green; font-weight:bold;'>تم رفع {success} ملف/ات مع الخيارات المحددة ✔</div>"
+        update_status_json(f"تم رفع {success} ملفات بواسطة {username}")
+        send_report_to_manager(f"المستخدم {username} ({rank}) رفع {success} ملف/ات بنجاح.")
+    return f"<div role='status' style='color:green;'>تم رفع {success} ملف/ات بنجاح ✔</div>"
 
 # ============================================================
-# 5) إدارة وقراءة ملفات Final والتحويل (باستخدام hf_hub_download)
+# ⚙️ 4) دالة حقن الجلسة والتحكم بعناصر العرض
 # ============================================================
 
-def list_final_files():
-    """جلب قائمة الملفات من Final_Arabic_Files في المستودع"""
-    try:
-        files = list_repo_files(REPO_ID, repo_type="dataset")
-        final_files = [f.split("/", 1)[1] for f in files if f.startswith(FINAL_DIR + "/")]
-        return sorted(final_files) if final_files else []
-    except Exception as e:
-        log_error(f"FINAL LIST ERROR: {e}")
-        return []
-
-def load_file_content(selected_name: str):
-    """تحميل محتوى الملف المختار من Final_Arabic_Files وعرضه في مربع التعديل"""
-    if not selected_name:
-        return "", "", ""
-    try:
-        remote_path = f"{FINAL_DIR}/{selected_name}"
-        # ✅ استخدام hf_hub_download المتوافق مع جميع الإصدارات
-        local_path = hf_hub_download(
-            repo_id=REPO_ID,
-            filename=remote_path,
-            repo_type="dataset",
-            token=TOKEN
-        )
-        with open(local_path, "r", encoding="utf-8") as f:
-            text = f.read()
-        return text, os.path.splitext(selected_name)[0], selected_name
-    except Exception as e:
-        log_error(f"FINAL LOAD ERROR: {selected_name} — {e}")
-        return "❌ فشل تحميل الملف", "", ""
-
-def convert_and_upload(text, base_name, target_ext, font_name, font_size):
-    if not text.strip(): return "❌ لا يوجد نص", None
-    try:
-        out_path = convert_text(text, base_name, target_ext, font_name, font_size)
-        new_name = os.path.basename(out_path)
-        api.upload_file(
-            path_or_fileobj=out_path,
-            path_in_repo=f"{FINAL_DIR}/{new_name}",
-            repo_id=REPO_ID, repo_type="dataset", token=TOKEN
-        )
-        return f"✅ تم التحويل والرفع باسم {new_name}", out_path
-    except Exception as e:
-        log_error(f"CONVERT/UPLOAD ERROR: {e}")
-        return f"⚠️ فشل: {e}", None
-
-def do_zip(text, base_name):
-    if not text.strip(): return "❌ لا يوجد نص", None
-    try:
-        txt_path = convert_text(text, base_name, "txt")
-        return "✅ تم إنشاء ZIP", zip_single_file(txt_path, base_name)
-    except Exception as e:
-        return "⚠️ فشل إنشاء ZIP", None
-
-# ============================================================
-# 5.b) الجلسة الحالية: ترحيب بالاسم + أيقونة الرتبة
-#      (نقطة الدخول المستقبلية لـ "كود التعرف")
-# ============================================================
-
-def init_session():
+def gatekeeper_init_session(request: gr.Request):
+    """
+    🚀 فحص فوري وصارم عند تحميل صفحة بايثون لمنع المتلاعبين 
+    وإلغاء الجلسات الافتراضية العشوائية (لا وجود لزائر).
     """
-    🧩 يُستدعى عند تحميل الصفحة. حالياً يولّد جلسة "زائر" مؤقتة بالرتبة free.
-    عندما يُضاف "كود التعرف" (اسم + بريد + بصمة جهاز + رتبة)، يكفي استبدال
-    منطق هذه الدالة بنتيجة ذلك الكود، وسيُحدَّث الترحيب + الأيقونة + الشاشة
-    المعروضة تلقائياً بحسب الرتبة (vip / free) دون أي تغيير آخر في الواجهة.
+    params = dict(request.query_params)
+    result = process_gatekeeper_logic(params)
+    
+    if not result["allowed"]:
+        # حجب الواجهة وإظهار رسالة المنع مع الرابط المتوافق للعودة لبوابة الفحص
+        return (
+            {"authenticated": False}, 
+            result["msg"], 
+            gr.update(visible=False), 
+            gr.update(visible=False), 
+            gr.update(visible=False)
+        )
+    
+    sess = result["session"]
+    welcome_html = f"""
+    <div style='background: #f0fdf4; border: 1px solid #bbf7d0; padding: 12px; border-radius: 8px;'>
+        <p role='status' style='font-size:16px; margin:0; color:#166534;'>👋 {result['msg']} | الحساب الموثق: <b>{sess['name']}</b></p>
+        <p style='font-size:12px; color:#666; margin:4px 0 0 0;'>🆔 بصمة العتاد المتطابقة: <code>{sess['device_id']}</code></p>
+    </div>
     """
-    session = {"name": generate_guest_name(), "email": "", "device_id": "", "rank": "free"}
-    welcome_html = f"<p role='status' style='font-size:16px; margin:0;'>👋 مرحباً بك، <b>{session['name']}</b></p>"
-    icon_label = "🥇 VIP" if session["rank"] == "vip" else "🥈 FREE"
-    return session, welcome_html, icon_label
+    icon_label = "🥇 VIP" if sess["rank"] == "vip" else "🥈 FREE"
+    
+    return (
+        sess, 
+        welcome_html, 
+        gr.update(value=icon_label, visible=True), 
+        gr.update(visible=True), 
+        gr.update(visible=True)
+    )
 
 def toggle_subscription_panel(session, is_visible):
-    """فتح/إغلاق شاشة تفاصيل الاشتراك المرتبطة بـ system/about_app.json"""
+    if not session or not session.get("authenticated"): 
+        return gr.update(visible=False), is_visible
     new_visible = not is_visible
     if new_visible:
-        rank = (session or {}).get("rank", "free")
-        return gr.update(value=load_about_app(rank), visible=True), new_visible
+        return gr.update(value=load_about_app(session.get("rank", "free")), visible=True), new_visible
     return gr.update(visible=False), new_visible
 
 # ============================================================
-# 6) واجهات Gradio مع جميع الخيارات
+# 5) بناء الواجهة الرادارية الرسمية المحصنة
 # ============================================================
 
 with gr.Blocks(title="📤 بوابة الرفع") as upload_page:
-    gr.Markdown("<h1 style='text-align:center;'>📤 بوابة الرفع ودورة حياة الملفات</h1>")
+    gr.Markdown("<h1 style='text-align:center;'>📤 بوابة الرفع ودورة حياة الملفات الموثقة</h1>")
 
-    # ✅ (5) أُزيل مربع "اسم المستخدم" التجريبي. تُولَّد الجلسة تلقائياً وتُستبدل
-    #        مستقبلاً ببيانات "كود التعرف" الحقيقية.
-    user_session = gr.State({"name": "", "email": "", "device_id": "", "rank": "free"})
+    # تهيئة حالة أمنية صارمة فارغة لحين الفحص (تم نسف الجلسات الافتراضية العشوائية للزوار)
+    user_session = gr.State({"authenticated": False})
     panel_visible_state = gr.State(False)
 
-    # ✅ (3) بدل خيار vip/free النصي: ترحيب بالاسم + أيقونة ذهبية/فضية للرتبة
+    welcome_box = gr.HTML("<p role='status'>🛡️ جاري مطابقة بصمة العتاد التاريخية والتحقق من سلامة البيانات السيادية...</p>")
+    
     with gr.Row():
-        welcome_box = gr.HTML("<p role='status'>👋 جارٍ تجهيز جلستك...</p>")
-        rank_icon_btn = gr.Button("🥈 FREE", elem_id="rank_icon_btn", scale=0, min_width=110)
+        rank_icon_btn = gr.Button("🥈 FREE", elem_id="rank_icon_btn", scale=0, min_width=110, visible=False)
 
-    # الشاشة العامة لتفاصيل الاشتراك (مرتبطة بـ system/about_app.json الذي يكتبه المدير)
     subscription_panel = gr.HTML(visible=False)
 
-    uploader = gr.File(label="اختر ملفاتك", file_count="multiple")
+    # المجموعات تخضع للإخفاء الكامل الفوري في حال حدوث خطأ أو تلاعب بالاسم
+    with gr.Group() as upload_area:
+        uploader = gr.File(label="اختر ملفاتك", file_count="multiple")
+        upload_btn = gr.Button("رفع الملفات", variant="primary")
+        status_box = gr.HTML("<div>بانتظار رفع الملفات...</div>")
 
-    # خيارات التحكم الإضافية
-    gr.Markdown("### ⚙️ خيارات متقدمة (تؤثر على سرعة وجودة المعالجة)")
-    
-    with gr.Row():
-        with gr.Column(scale=1):
+    with gr.Group() as options_area:
+        gr.Markdown("### ⚙️ خيارات معالجة العتاد المتقدمة")
+        with gr.Row():
             enable_table = gr.Checkbox(label="📊 كشف الجداول", value=False)
-            gr.Markdown("<small style='color:red;'>⚠️ تفعيل كشف الجداول سيبطئ المعالجة حتى لو لم تكن هناك جداول.</small>")
-        with gr.Column(scale=1):
             enable_handwriting = gr.Checkbox(label="🖐️ خط يدوي", value=False)
-            gr.Markdown("<small style='color:red;'>⚠️ تفعيل الخط اليدوي يتطلب نموذجاً أثقل.</small>")
-        with gr.Column(scale=1):
-            enable_heavy_prep = gr.Checkbox(label="🔧 معالجة ثقيلة (منظور، ظلال)", value=False)
-            gr.Markdown("<small style='color:red;'>⚠️ قد يزيد وقت المعالجة بشكل كبير.</small>")
-        with gr.Column(scale=1):
+            enable_heavy_prep = gr.Checkbox(label="🔧 معالجة ثقيلة", value=False)
             enable_high_dpi = gr.Checkbox(label="📐 دقة عالية (300 DPI)", value=False)
-            gr.Markdown("<small style='color:blue;'>⚠️ مناسب للنصوص الصغيرة أو الممسوحة بدقة منخفضة.</small>")
-        with gr.Column(scale=1):
             enable_fast = gr.Checkbox(label="⚡ الوضع السريع (EasyOCR)", value=False)
-            gr.Markdown("<small style='color:green;'>🚀 يلغي جميع الخيارات الأخرى ويستخدم OCR خفيفاً.</small>")
-    
-    with gr.Row():
-        with gr.Column(scale=1):
-            enable_tashkeel = gr.Checkbox(label="🔤 تشكيل النص (حركات)", value=False)
-            gr.Markdown("<small style='color:purple;'>🕋 يضيف حركات التشكيل (الفتحة، الضمة...) وقد يبطئ المعالجة.</small>")
+            enable_tashkeel = gr.Checkbox(label="🔤 تشكيل النص", value=False)
 
-    upload_btn = gr.Button("رفع الملفات", variant="primary")
-    status_box = gr.HTML("<div>بانتظار رفع الملفات...</div>")
-    
     gr.Markdown("### 📜 حالة التجميع والمعالجة الفورية")
     system_status = gr.HTML("<div role='status' aria-live='polite'>بانتظار تحديث الحالة من system/status.json...</div>")
 
-    # تجهيز الجلسة (الترحيب + أيقونة الرتبة) عند فتح الصفحة
-    upload_page.load(init_session, None, [user_session, welcome_box, rank_icon_btn])
+    # استدعاء الحارس فور شحن الصفحة بالمتصفح
+    upload_page.load(
+        fn=gatekeeper_init_session, 
+        inputs=None, 
+        outputs=[user_session, welcome_box, rank_icon_btn, upload_area, options_area]
+    )
 
-    # فتح/إغلاق شاشة تفاصيل الاشتراك عند الضغط على أيقونة الرتبة
     rank_icon_btn.click(
         fn=toggle_subscription_panel,
         inputs=[user_session, panel_visible_state],
         outputs=[subscription_panel, panel_visible_state]
     )
 
-    # ربط زر الرفع بالدالة المعدلة (تعتمد على الجلسة بدل مربع الاسم/الرتبة)
     upload_btn.click(
         fn=handle_upload,
-        inputs=[uploader, user_session,
-                enable_table, enable_handwriting, 
-                enable_heavy_prep, enable_high_dpi, 
-                enable_fast, enable_tashkeel],
+        inputs=[uploader, user_session, enable_table, enable_handwriting, enable_heavy_prep, enable_high_dpi, enable_fast, enable_tashkeel],
         outputs=status_box
     ).then(read_status_json, None, system_status)
 
     status_timer = gr.Timer(3.0)
     status_timer.tick(read_status_json, None, system_status)
 
-# ------------------- قسم ملفاتي المُصحَّح -------------------
-with gr.Blocks(title="📁 ملفاتي") as files_page:
-    gr.Markdown("<h1 style='text-align:center;'>📁 الملفات الجاهزة للتحويل</h1>")
-    files_list = gr.Dropdown(label="اختر ملفاً من Final_Arabic_Files", choices=[], interactive=True)
-    refresh_btn = gr.Button("تحديث القائمة")
-
-    editor = gr.Textbox(label="مربع التعديل", lines=15)
-    filename_box = gr.Textbox(label="اسم الملف (بدون امتداد)")
-    ext_dropdown = gr.Dropdown(label="الامتداد", choices=["txt", "pdf", "docx", "xlsx", "csv", "html"], value="pdf")
-    font_dropdown = gr.Dropdown(label="الخط", choices=["Arial", "Tahoma", "Amiri-Regular", "Cairo-Regular"], value="Amiri-Regular")
-    font_size_dropdown = gr.Slider(label="حجم الخط", minimum=10, maximum=40, value=18, step=1)
-
-    convert_btn = gr.Button("تحويل")
-    download_file = gr.File(label="تحميل الملف")
-    convert_status = gr.HTML()
-
-    zip_btn = gr.Button("إنشاء ZIP")
-    zip_file = gr.File(label="تحميل ZIP")
-    zip_status = gr.HTML()
-
-    def refresh_files():
-        return gr.update(choices=list_final_files())
-
-    files_page.load(refresh_files, None, files_list)
-    refresh_btn.click(fn=refresh_files, outputs=files_list)
-    files_list.change(
-        fn=load_file_content,
-        inputs=files_list,
-        outputs=[editor, filename_box, files_list]
-    )
-    convert_btn.click(
-        fn=convert_and_upload,
-        inputs=[editor, filename_box, ext_dropdown, font_dropdown, font_size_dropdown],
-        outputs=[convert_status, download_file]
-    )
-    zip_btn.click(
-        fn=do_zip,
-        inputs=[editor, filename_box],
-        outputs=[zip_status, zip_file]
-    )
-
-app = gr.TabbedInterface([upload_page, files_page], ["📤 الرفع المباشر", "📁 ملفاتي"])
-
 if __name__ == "__main__":
-    app.launch(server_name="0.0.0.0", server_port=7860)
+    upload_page.launch()