Update app.py

app.py

@@ -1,34 +1,26 @@
 #!/usr/bin/env python3
 import os
+import threading
+import time
+import socket
+import requests
+import importlib
+import random
 from flask import Flask, request, jsonify
-from connection_engine import start_connect_loop, CONNECTED, PORT  # ← إذا وضعت الكود في ملف منفصل
-start_connect_loop()
-
-app = Flask(__name__)# ─────────────────────────────────────────────────────────────────────
-# محرك اتصال: سيرفر عشوائي من peer_discovery + منافذ 0001..9999 بالتسلسل
-# يتوقف فقط عند أول تسجيل ناجح
-# ─────────────────────────────────────────────────────────────────────
-import os, time, threading, socket, requests, importlib, random, sys
 
+# ───────── إعدادات عامة ──────────
 CURRENT_SERVER = None
 PORT = None
 CONNECTED = threading.Event()
-print("⏳ بستنّى أول اتصال ناجح…")
-CONNECTED.wait()
-
-# مثال: تشغيل خادم Flask أو RPC باستخدام PORT المكتشف
-from rpc_server import rpc_app
-rpc_app.run(host="0.0.0.0", port=PORT)
+app = Flask(__name__)
 
+# ───────── دوال محرك الاتصال ──────────
 def _load_peer_discovery():
     import peer_discovery as pd
     importlib.reload(pd)
     return pd
 
 def _pick_random_server(pd):
-    # إن كان لديك pd.random_server() استخدمه، وإلا اختر عشوائياً من القائمة
-    if hasattr(pd, "random_server"):
-        return pd.random_server()
     servers = list(getattr(pd, "CENTRAL_REGISTRY_SERVERS", []))
     if not servers:
         raise RuntimeError("لا توجد سيرفرات في peer_discovery.CENTRAL_REGISTRY_SERVERS")
@@ -38,7 +30,6 @@ def _pick_random_server(pd):
 def _get_local_ip(pd):
     if hasattr(pd, "get_local_ip"):
         return pd.get_local_ip()
-    # احتياط
     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
     try:
         s.connect(("8.8.8.8", 80))
@@ -52,13 +43,12 @@ def _lan_port(pd):
     return int(getattr(pd, "LAN_PORT", os.getenv("LAN_PORT", 7520)))
 
 def _can_bind_low_ports():
-    # على لينكس: تحتاج root للمنافذ <1024
     if os.name != "nt":
         try:
-            return os.geteuid() == 0  # type: ignore[attr-defined]
+            return os.geteuid() == 0
         except Exception:
             return False
-    return True  # ويندوز عادة يسمح
+    return True
 
 def _is_port_free(port, host="0.0.0.0"):
     with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
@@ -75,7 +65,6 @@ def _try_register(server, port, node_id, ip):
     r.raise_for_status()
 
 def _sequential_ports(pd):
-    """يولّد 0001..9999 مع مراعاة الـ LAN_PORT وتخطي <1024 إذا غير مسموح."""
     lan_p = _lan_port(pd)
     start = 1 if _can_bind_low_ports() else 1025
     for p in range(start, 10000):
@@ -105,39 +94,42 @@ def _connect_until_success():
                 print(f"✅ Connected to {server} with port {PORT:04d}")
                 return
             except Exception as e:
-                # اطبع على فترات لتجنب الضوضاء
                 if p % 1000 == 0:
                     print(f"…still scanning (last error on {server}:{p:04d}) -> {e}")
-
-        # لم ينجح أي منفذ مع هذا السيرفر → جرّب سيرفر جديد
         if not any_attempt:
             print("⚠️ لم تُجرَ محاولات منافذ (تحقق من صلاحيات المنافذ المنخفضة).")
-
         print(f"↻ No success on {server}. Picking a new server…")
         time.sleep(backoff)
-        backoff = min(backoff * 2, 10)  # backoff بسيط لتخفيف الضغط
+        backoff = min(backoff * 2, 10)
 
 def start_connect_loop():
+    print("🌀 Launching connection thread")
     threading.Thread(target=_connect_until_success, daemon=True).start()
 
-    print("🌀 Launching connection thread")  # ← أضف هنا أيضًا
-    threading.Thread(target=_connect_until_success, daemon=True).start()
+# ───────── تشغيل الاتصال الخارجي ──────────
+start_connect_loop()
+
+# ───────── (اختياري) تشغيل خادم خارجي بعد الاتصال ──────────
+def run_rpc_server_after_connected():
+    CONNECTED.wait()
+    print(f"🚀 RPC Server ready on PORT={PORT}")
+    from rpc_server import rpc_app
+    rpc_app.run(host="0.0.0.0", port=PORT)
+
+threading.Thread(target=run_rpc_server_after_connected, daemon=True).start()
 
-# مسار اختبار سريع
+# ───────── مسارات Flask الأساسية ──────────
 @app.get("/")
 def hello():
-    return "✅ ��لحمد لله… التطبيق يعمل على Hugging Face Spaces!"
+    return f"✅ الحمد لله… التطبيق يعمل على Hugging Face Spaces! [سيرفر: {CURRENT_SERVER}, بورت: {PORT}]"
 
-# مثال لمسار POST يمكن ربطه بواجهتك
 @app.post("/generate")
 def generate():
     data = request.json or {}
     text = data.get("text", "")
-    # --- ضَع هنا منطقك الحقيقي (نموذج ذكاء اصطناعي، إلخ) ---
-    return jsonify({"echo": text[::-1]})  # يعكس النص كمثال فقط
-from peer_discovery import PORT, PORT
+    return jsonify({"echo": text[::-1]})
 
+# ───────── تشغيل تطبيق Flask الأساسي ──────────
 if __name__ == "__main__":
-    # Spaces يحقن متغيّر PORT تلقائياً (افتراضي 7860) :contentReference[oaicite:0]{index=0}
-    port = int(os.environ.get("PORT", 7860))
-    app.run(host="0.0.0.0", port=port, debug=False)
+    hf_port = int(os.environ.get("PORT", 7860))  # Port المخصص من Hugging Face
+    app.run(host="0.0.0.0", port=hf_port, debug=False)