Sync from GitHub with Git LFS

agents/peer_sync.py

@@ -113,94 +113,6 @@ def load_bootstrap_peers(filename="bootstrap.txt"):
                                    source="bootstrap", status="offline")
         print(f"[Bootstrap] Loaded peer {did} -> {expanded_addresses}")
 
-# ---------------------------
-# TCP Listener (обработка входящих PEER_EXCHANGE_REQUEST)
-# ---------------------------
-def tcp_listener():
-    listen_sockets = []
-
-    # Создаём TCP сокеты на всех локальных портах
-    for port in local_ports:
-        try:
-            sock4 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-            sock4.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-            sock4.bind(("", port))
-            sock4.listen(5)
-            listen_sockets.append(sock4)
-            print(f"[TCP Listener] Listening IPv4 on *:{port}")
-        except Exception as e:
-            print(f"[TCP Listener] IPv4 bind failed on port {port}: {e}")
-
-        try:
-            sock6 = socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
-            sock6.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-            sock6.bind(("::", port))
-            sock6.listen(5)
-            listen_sockets.append(sock6)
-            print(f"[TCP Listener] Listening IPv6 on [::]:{port}")
-        except Exception as e:
-            print(f"[TCP Listener] IPv6 bind failed on port {port}: {e}")
-
-    while True:
-        if not listen_sockets:
-            time.sleep(1)
-            continue
-        rlist, _, _ = select.select(listen_sockets, [], [], 1)
-        for s in rlist:
-            try:
-                conn, addr = s.accept()
-                data = conn.recv(1024)
-
-                if data == b"PEER_EXCHANGE_REQUEST":
-                    print(f"[TCP Listener] PEER_EXCHANGE_REQUEST from {addr}")
-
-                    # --- (1) Сохраняем нового пира ---
-                    peer_host, peer_port = addr[0], addr[1]
-                    peer_id = f"did:hmp:{peer_host}:{peer_port}"  # временный ID, пока пир не представился
-                    storage.add_or_update_peer(
-                        peer_id,
-                        name="incoming",
-                        addresses=[f"tcp4://{peer_host}:{peer_port}"],
-                        source="incoming",
-                        status="online"
-                    )
-
-                    # --- (2) Отправляем список известных ---
-                    peers_list = []
-                    for peer in storage.get_known_peers(my_id, limit=50):
-                        peer_id = peer["id"]
-                        addresses_json = peer["addresses"]
-                        try:
-                            addresses = json.loads(addresses_json)
-                        except:
-                            addresses = []
-                        peers_list.append({"id": peer_id, "addresses": addresses})
-                    payload = json.dumps(peers_list).encode("utf-8")
-                    conn.sendall(payload)
-
-                    # --- (3) Делаем встречный запрос ---
-                    try:
-                        with socket.create_connection((peer_host, peer_port), timeout=3) as s2:
-                            s2.sendall(b"PEER_EXCHANGE_REQUEST")
-                            resp = s2.recv(65536)
-                            if resp:
-                                new_peers = json.loads(resp.decode("utf-8"))
-                                for p in new_peers:
-                                    storage.add_or_update_peer(
-                                        p["id"],
-                                        name="from_incoming",
-                                        addresses=p.get("addresses", []),
-                                        source="reverse-sync",
-                                        status="online"
-                                    )
-                                print(f"[TCP Listener] Reverse sync: got {len(new_peers)} peers from {peer_host}:{peer_port}")
-                    except Exception as e:
-                        print(f"[TCP Listener] Reverse sync failed with {peer_host}:{peer_port}: {e}")
-
-                conn.close()
-            except Exception as e:
-                print(f"[TCP Listener] Connection handling error: {e}")
-
 # ---------------------------
 # UDP Discovery
 # ---------------------------