Spaces:
Running
Running
Update main.py
#1
by osamabyc19866 - opened
main.py
CHANGED
|
@@ -46,7 +46,29 @@ try:
|
|
| 46 |
logging.info("تم تحميل متغيرات البيئة من .env")
|
| 47 |
except ImportError:
|
| 48 |
logging.warning("python-dotenv غير مثبَّت؛ تَخطّي .env")
|
| 49 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 50 |
# ─────────────── ثوابت التهيئة ───────────────
|
| 51 |
CPU_PORT = int(os.getenv("CPU_PORT", "5297"))
|
| 52 |
SHARED_SECRET = os.getenv("SHARED_SECRET", "my_shared_secret_123")
|
|
|
|
| 46 |
logging.info("تم تحميل متغيرات البيئة من .env")
|
| 47 |
except ImportError:
|
| 48 |
logging.warning("python-dotenv غير مثبَّت؛ تَخطّي .env")
|
| 49 |
+
# في بداية main.py بعد imports
|
| 50 |
+
def start_zeroconf_discovery():
|
| 51 |
+
"""تشغيل اكتشاف الأقران عبر ZeroConf"""
|
| 52 |
+
try:
|
| 53 |
+
from peer_registry import register_service, discover_peers
|
| 54 |
+
import threading
|
| 55 |
+
|
| 56 |
+
# تسجيل الخدمة المحلية
|
| 57 |
+
local_ip = get_local_ip()
|
| 58 |
+
register_service(local_ip, CPU_PORT, load=0)
|
| 59 |
+
|
| 60 |
+
# اكتشاف الأقران في خلفية
|
| 61 |
+
def discover_loop():
|
| 62 |
+
while True:
|
| 63 |
+
peers = discover_peers(timeout=3)
|
| 64 |
+
for peer in peers:
|
| 65 |
+
add_peer(peer)
|
| 66 |
+
time.sleep(30)
|
| 67 |
+
|
| 68 |
+
threading.Thread(target=discover_loop, daemon=True).start()
|
| 69 |
+
logging.info("✅ ZeroConf discovery started")
|
| 70 |
+
except ImportError:
|
| 71 |
+
logging.warning("⚠️ zeroconf not installed. Run: pip install zeroconf")
|
| 72 |
# ─────────────── ثوابت التهيئة ───────────────
|
| 73 |
CPU_PORT = int(os.getenv("CPU_PORT", "5297"))
|
| 74 |
SHARED_SECRET = os.getenv("SHARED_SECRET", "my_shared_secret_123")
|