Update app.py

app.py

@@ -3,6 +3,135 @@ import os
 from flask import Flask, request, jsonify
 
 app = Flask(__name__)
+# ──────────────────────────────────────────────────────────────────────────────
+# محرك اتصال خارجي: Direct أولاً، ثم Relay (WebSocket) كخطة B
+# ألصقه بعد الاستيرادات وقبل بدء خدامك (RPC/Flask)
+# ──────────────────────────────────────────────────────────────────────────────
+import os, time, threading, socket, random, requests, importlib
+MODE = None                 # "direct" أو "relay"
+CURRENT_SERVER = None
+PORT = None                 # منفذك المحلي لخدمة /run أو RPC
+CONNECTED = threading.Event()
+RELAY_SIO = None
+
+# ← جِب المرشحين من peer_discovery في كل دورة (حتى لو بيولدهم ديناميكياً)
+def _load_candidates():
+    import peer_discovery as pd
+    importlib.reload(pd)
+    servers = list(getattr(pd, "CENTRAL_REGISTRY_SERVERS", []))
+    # منفذك الذي ستشغل عليه الـ RPC محليًا (وليس منفذ السيرفر العام)
+    # يفضل أن يكون ما يولده peer_discovery؛ وإن لم يوجد استخدم 7860/8000/5000 احتياط
+    ports = list(getattr(pd, "rport", [])) or ["7860", "8000", "5000"]
+    get_ip = getattr(pd, "get_local_ip", lambda: "127.0.0.1")
+    random.shuffle(servers); random.shuffle(ports)
+    return servers, [int(p) for p in ports], get_ip
+
+def _is_port_free(p, 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(p)))
+            return True
+        except OSError:
+            return False
+
+def _try_direct_register(server, port, get_ip):
+    """
+    يحاول التسجيل المباشر عند السيرفر: POST /register
+    إذا نجح، نستخدم هذا المنفذ لتشغيل خادمنا المحلي لاحقًا.
+    """
+    info = {
+        "node_id": os.getenv("NODE_ID", socket.gethostname()),
+        "ip": get_ip(),
+        "port": int(port),
+    }
+    r = requests.post(f"{server}/register", json=info, timeout=6)
+    r.raise_for_status()  # يرمي استثناء لو فشل
+    return True
+
+def _start_relay_client(server):
+    """
+    وضع Relay: قناة Socket.IO دائمة مع السيرفر (على 443 غالبًا).
+    لا تحتاج أي منفذ inbound. إذا السيرفر يدعم relay، يُعتبر اتصال خارجي ناجح.
+    """
+    global RELAY_SIO
+    import socketio  # python-socketio client
+    sio = socketio.Client(reconnection=True, reconnection_attempts=0)
+
+    node_id = os.getenv("NODE_ID", socket.gethostname())
+
+    @sio.event
+    def connect():
+        print(f"🔌 Relay connected to {server}")
+        sio.emit("register_node", {"node_id": node_id})
+        # اعتبر الاتصال ناجح خارجيًا
+        # نُبقي PORT لاستخدام LAN/RPC محلي (لو احتجته). تستطيع ضبطه لاحقًا.
+    
+    @sio.event
+    def disconnect():
+        print("⚠️ Relay disconnected; will auto-reconnect…")
+
+    # أمثلة أحداث (عدّل على مزاجك):
+    @sio.on("ping_node")
+    def _on_ping(msg):
+        sio.emit("pong_node", {"node_id": node_id, "t": time.time()})
+
+    try:
+        # Socket.IO URL ← عادة نفس الدومين على /socket.io
+        sio.connect(server, transports=["websocket", "polling"], wait_timeout=10)
+        RELAY_SIO = sio
+        return True
+    except Exception as e:
+        print(f"❌ Relay connect failed: {e}")
+        return False
+
+def _connect_until_success():
+    global MODE, CURRENT_SERVER, PORT
+    backoff = 1
+    while True:
+        servers, ports, get_ip = _load_candidates()
+
+        # 1) جرّب DIRECT على كل السيرفرات مع مجموعة منافذك
+        for s in servers:
+            for p in ports:
+                # تأكد أن المنفذ متاح محليًا لتشغيل خادمك لاحقًا
+                if not _is_port_free(p):
+                    continue
+                try:
+                    _try_direct_register(s, p, get_ip)
+                    MODE, CURRENT_SERVER, PORT = "direct", s, int(p)
+                    print(f"✅ DIRECT connected: {s} (node port {PORT})")
+                    CONNECTED.set()
+                    return
+                except Exception as e:
+                    print(f"⚠️ DIRECT failed on {s} / {p}: {e}")
+
+        # 2) إذا فشلت المباشرة على الكل → جرّب RELAY لكل سيرفر بالترتيب
+        for s in servers:
+            ok = _start_relay_client(s)
+            if ok:
+                MODE, CURRENT_SERVER = "relay", s
+                # PORT اختياري هنا (لـ LAN فقط). لو عندك RPC محلّي شغّله على أي منفذ متاح.
+                if ports:
+                    # اختر أول منفذ متاح محليًا للتشغيل الداخلي
+                    for p in ports:
+                        if _is_port_free(p):
+                            PORT = int(p)
+                            break
+                print(f"✅ RELAY connected via {s} (no inbound port needed)")
+                CONNECTED.set()
+                return
+
+        # لا نجاح بعد التجربتين → انتظر وزِد المهلة وأعد المحاولة
+        time.sleep(backoff)
+        backoff = min(backoff * 2, 30)
+
+def start_connect_loop():
+    threading.Thread(target=_connect_until_success, daemon=True).start()
+
+# شغّل حلقة الاتصال مبكرًا:
+start_connect_loop()
+# ──────────────────────────────────────────────────────────────────────────────
 
 # مسار اختبار سريع
 @app.get("/")