Update app.py

app.py

@@ -1,135 +1,28 @@
 #!/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 peer_discovery import PORT, CURRENT_SERVER, PEERS
 
-# ───────── إعدادات عامة ──────────
-CURRENT_SERVER = None
-PORT = None
-CONNECTED = threading.Event()
 app = Flask(__name__)
 
-# ───────── دوال محرك الاتصال ──────────
-def _load_peer_discovery():
-    import peer_discovery as pd
-    importlib.reload(pd)
-    return pd
-
-def _pick_random_server(pd):
-    servers = list(getattr(pd, "CENTRAL_REGISTRY_SERVERS", []))
-    if not servers:
-        raise RuntimeError("لا توجد سيرفرات في peer_discovery.CENTRAL_REGISTRY_SERVERS")
-    random.shuffle(servers)
-    return servers[0]
-
-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))
-        return s.getsockname()[0]
-    except Exception:
-        return "127.0.0.1"
-    finally:
-        s.close()
-
-def _lan_port(pd):
-    return int(getattr(pd, "LAN_PORT", os.getenv("LAN_PORT", 7520)))
-
-def _can_bind_low_ports():
-    if os.name != "nt":
-        try:
-            return os.geteuid() == 0
-        except Exception:
-            return False
-    return True
-
-def _is_port_free(port, host="0.0.0.0"):
-    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
-        s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-        try:
-            s.bind((host, int(port)))
-            return True
-        except OSError:
-            return False
-
-def _try_register(server, port, node_id, ip):
-    payload = {"node_id": node_id, "ip": ip, "port": int(port)}
-    r = requests.post(f"{server}/register", json=payload, timeout=6)
-    r.raise_for_status()
-
-def _sequential_ports(pd):
-    lan_p = _lan_port(pd)
-    start = 1 if _can_bind_low_ports() else 1025
-    for p in range(start, 10000):
-        if p == lan_p:
-            continue
-        yield p
-
-def _connect_until_success():
-    global CURRENT_SERVER, PORT
-    backoff = 1
-    while True:
-        pd = _load_peer_discovery()
-        server = _pick_random_server(pd)
-        node_id = os.getenv("NODE_ID", socket.gethostname())
-        ip = _get_local_ip(pd)
-        print(f"🔎 Trying server: {server}")
-        print("🚀 Started connection attempt loop")
-        any_attempt = False
-        for p in _sequential_ports(pd):
-            any_attempt = True
-            if not _is_port_free(p):
-                continue
-            try:
-                _try_register(server, p, node_id, ip)
-                CURRENT_SERVER, PORT = server, int(p)
-                CONNECTED.set()
-                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)
-
-def start_connect_loop():
-    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 f"✅ الحمد لله… التطبيق يعمل على Hugging Face Spaces! [سيرفر: {CURRENT_SERVER}, بورت: {PORT}]"
+def home():
+    return f"""
+    <h2>✅ Hugging Face App يعمل</h2>
+    <p><b>🌐 السيرفر المركزي:</b> {CURRENT_SERVER}</p>
+    <p><b>🧠 المنفذ الذي تعمل عليه:</b> {PORT}</p>
+    <p><b>🤝 عدد الأقران (Peers):</b> {len(PEERS)}</p>
+    """
 
 @app.post("/generate")
 def generate():
     data = request.json or {}
     text = data.get("text", "")
-    return jsonify({"echo": text[::-1]})
+    response = text[::-1]  # عكس النص كمثال
+    return jsonify({"result": response})
 
-# ───────── تشغيل تطبيق Flask الأساسي ──────────
+# نقطة التشغيل الرئيسية
 if __name__ == "__main__":
-    print("🚀 Starting Flask server on port 7860...")
-    app.run(host="0.0.0.0", port=PORT, debug=True)
+    port = int(os.environ.get("PORT", 7860))  # Hugging Face يمرر هذا المتغير تلقائيًا
+    print(f"🚀 Flask app is starting on port {port}...")
+    app.run(host="0.0.0.0", port=port)