Spaces:
Running
Running
Update main.py
Browse files
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")
|