Sync from GitHub with Git LFS

agents/config.yml

@@ -1,70 +1,46 @@
-# HMP Agent Configuration
-
-# === Общие параметры ===
-agent_id: ""                      # Оставьте пустым для генерации DiD автоматически
-agent_name: "CognitiveCore"       # Имя агента
-agent_role: "core"                # 'core' или 'shell'
-
-# === Прокси ===
-proxy_mode: false                 # false — прокси не используется, иначе true
-proxy_type: "socks5"              # 'http', 'socks4', 'socks5' и т.д. (если proxy_mode: true)
-proxy_address: "127.0.0.1:9050"
-
-# === Функции ядра ===
-enable_llm: true                  # доступ к LLM
-
-serve_api: true                   # REST API
+agent_id: did:hmp:4b2e20ef-a6c1-4605-897f-665140035494
+agent_name: CognitiveCore
+agent_role: core
 api_port: 8080
-
-# === DHT-сеть и обмен знаниями ===
-dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
-dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
-bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
-dht_port: 20784
-update_interval: 60               # секунд (для DHT-обновлений)
-
-# === LLM-бэкенды ===
+bootstrap_responder: true
+debug: true
+default_llm: local-model
+default_user:
+  badges: 📌
+  email: [email protected]
+  password: password
+  username: user
+dht_enabled: true
+dht_update: true
+enable_llm: true
+identity_agent: 4b2e20ef-a6c1-4605-897f-665140035494
 llm_backends:
-  - name: "local-model"
-    type: "local"
-    path: "/models/gguf/mistral.gguf"
-    format: "gguf"
-    prompt_template: "mistral"
-
-  - name: "lmstudio-local"
-    type: "api"
-    provider: "openai-compatible"
-    model: "mistral"               # или то, что LM Studio показывает как модель
-    api_key: "lm-studio-any-key"  # может быть заглушкой
-    base_url: "http://127.0.0.1:1234/v1"
-
-  - name: "openai-gpt4o"
-    type: "api"
-    provider: "openai"
-    model: "gpt-4o"
-    api_key: "sk-..."
-
-  # Пользователь может добавить сколько угодно дополнительных локальных или сетевых LLM
-
-default_llm: "local-model"        # если модели нет в списке `llm_backends` используется первая в списке
-
-# === Веб-интерфейс ===
-notebook_ui: true                 # UI в виде блокнота
-# ui_hosts:
-#   - "0.0.0.0"   # (небезопасно) доступ с любых IPv4-адресов
-#   - "::"        # (небезопасно) доступ с любых IPv6-адресов
-ui_hosts:                         # Какие IP прослушиваются, ["0.0.0.0"; "::"] - доступен везде
-  - "127.0.0.1"
-  - "::1"
+- format: gguf
+  name: local-model
+  path: /models/gguf/mistral.gguf
+  prompt_template: mistral
+  type: local
+- api_key: lm-studio-any-key
+  base_url: http://127.0.0.1:1234/v1
+  model: mistral
+  name: lmstudio-local
+  provider: openai-compatible
+  type: api
+- api_key: sk-...
+  model: gpt-4o
+  name: openai-gpt4o
+  provider: openai
+  type: api
+log_level: INFO
+notebook_ui: true
+proxy_address: 127.0.0.1:9050
+proxy_mode: false
+proxy_type: socks5
+serve_api: true
+tcp_port: 5000
+udp_port: 4000
+ui_hosts:
+- 127.0.0.1
+- ::1
 ui_port: 8765
-
-# === Данные пользователя ===
-default_user:
-  username: "user"
-  badges: "📌"
-  email: "[email protected]"
-  password: "password"            # пусто при инициализации, будет установлен при регистрации
-
-# === Отладка и логгирование ===
-debug: true
-log_level: "INFO"                 # DEBUG, INFO, WARNING, ERROR
+update_interval: 60

agents/examples/config.yml

@@ -20,7 +20,8 @@ api_port: 8080
 dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
 dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
 bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
-dht_port: 20784
+udp_port: 4000
+tcp_port: 5000
 update_interval: 60               # секунд (для DHT-обновлений)
 
 # === LLM-бэкенды ===

agents/peer_sync.py

@@ -0,0 +1,116 @@
+# agents/peer_sync.py
+
+"""
+peer_sync.py — фоновый процесс синхронизации пиров в сети HMP
+"""
+
+import socket
+import threading
+import time
+import json
+from tools.storage import Storage
+
+storage = Storage()
+
+# ======================
+# UDP Discovery
+# ======================
+
+def udp_discovery_listener(udp_port: int):
+    """Слушаем UDP-пакеты"""
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    sock.bind(("", udp_port))
+
+    while True:
+        data, addr = sock.recvfrom(1024)
+        try:
+            msg = json.loads(data.decode("utf-8"))
+            peer_id = msg.get("id")
+            name = msg.get("name", "unknown")
+            addresses = msg.get("addresses", [f"{addr[0]}:{msg.get('tcp_port', udp_port)}"])
+            storage.add_or_update_peer(peer_id, name, addresses, source="discovery", status="online")
+        except Exception as e:
+            print("[PeerSync] Ошибка при обработке UDP пакета:", e)
+
+
+def udp_discovery_sender(agent_id: str, agent_name: str, udp_port: int, tcp_port: int):
+    """Рассылаем UDP multicast/broadcast пакеты"""
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
+    sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 2)
+
+    msg = {
+        "id": agent_id,
+        "name": agent_name,
+        "tcp_port": tcp_port,
+        "addresses": [f"127.0.0.1:{tcp_port}"]
+    }
+
+    last_broadcast = 0
+    DISCOVERY_INTERVAL = 60
+    BROADCAST_INTERVAL = 600
+
+    while True:
+        now = time.time()
+        # Multicast раз в минуту
+        if int(now) % DISCOVERY_INTERVAL == 0:
+            sock.sendto(json.dumps(msg).encode("utf-8"), ("239.255.0.1", udp_port))
+        # Broadcast раз в 10 минут
+        if now - last_broadcast > BROADCAST_INTERVAL:
+            sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
+            sock.sendto(json.dumps(msg).encode("utf-8"), ("255.255.255.255", udp_port))
+            last_broadcast = now
+        time.sleep(1)
+
+
+# ======================
+# Peer Exchange (TCP)
+# ======================
+
+def peer_exchange():
+    """Периодический обмен списками пиров"""
+    PEER_EXCHANGE_INTERVAL = 120
+    while True:
+        peers = storage.get_online_peers(limit=50)
+        for peer in peers:
+            peer_id, addresses = peer["id"], peer["addresses"]
+            try:
+                addr = json.loads(addresses)[0]
+                host, port = addr.split(":")
+                s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+                s.settimeout(2)
+                s.connect((host, int(port)))
+                # пока только "каркас"
+                s.sendall(b"PEER_EXCHANGE_REQUEST")
+                s.close()
+            except Exception as e:
+                print(f"[PeerSync] Не удалось подключиться к {peer_id} ({addresses}): {e}")
+        time.sleep(PEER_EXCHANGE_INTERVAL)
+
+
+# ======================
+# Основной запуск
+# ======================
+
+def start_sync():
+    print("[PeerSync] Запуск фоновой синхронизации")
+
+    # 1. Конфиг
+    udp_port = int(storage.get_config_value("udp_port", 4000))
+    tcp_port = int(storage.get_config_value("tcp_port", 5000))
+    agent_id = storage.get_config_value("agent_id", "unknown-agent")
+    agent_name = storage.get_config_value("agent_name", "HMP-Agent")
+
+    # 2. Bootstrap загрузка
+    storage.load_bootstrap()
+
+    # 3. UDP discovery
+    threading.Thread(target=udp_discovery_listener, args=(udp_port,), daemon=True).start()
+    threading.Thread(target=udp_discovery_sender, args=(agent_id, agent_name, udp_port, tcp_port), daemon=True).start()
+
+    # 4. Peer exchange (TCP)
+    threading.Thread(target=peer_exchange, daemon=True).start()
+
+    # вечный цикл (чтобы поток не завершался)
+    while True:
+        time.sleep(60)

agents/start_repl.py

@@ -16,7 +16,7 @@ storage = Storage()
 ENABLE_REPL      = False  # 🧠 repl.py
 ENABLE_UI        = True  # 📓 web_ui.py (FastAPI)
 ENABLE_MESH      = False  # 🌐 agent_mesh_listener.py
-ENABLE_SYNC      = False  # 🔄 peer_sync.py
+ENABLE_SYNC      = True  # 🔄 peer_sync.py
 ENABLE_TRANSPORT = False  # 📡 transporter.py
 ENABLE_CONTROL   = False  # 🧭 agent_controller.py
 ENABLE_CONTAINER = False  # 🧱 container_agent.py

agents/tools/storage.py

@@ -870,6 +870,49 @@ class Storage:
             }
         return None
 
+    # Работа с пирам (agent_peers)
+    def add_or_update_peer(self, peer_id, name, addresses, source="discovery", status="unknown"):
+        c = self.conn.cursor()
+        c.execute("""
+            INSERT INTO agent_peers (id, name, addresses, source, status, last_seen)
+            VALUES (?, ?, ?, ?, ?, ?)
+            ON CONFLICT(id) DO UPDATE SET
+                addresses=excluded.addresses,
+                source=excluded.source,
+                status=excluded.status,
+                last_seen=excluded.last_seen
+        """, (
+            peer_id,
+            name,
+            json.dumps(addresses),
+            source,
+            status,
+            datetime.now(UTC).isoformat()
+        ))
+        self.conn.commit()
+
+    def get_online_peers(self, limit=50):
+        c = self.conn.cursor()
+        c.execute("SELECT id, addresses FROM agent_peers WHERE status='online' LIMIT ?", (limit,))
+        return c.fetchall()
+
+    def load_bootstrap(self, bootstrap_file="bootstrap.txt"):
+        if not os.path.exists(bootstrap_file):
+            return
+        with open(bootstrap_file, "r", encoding="utf-8") as f:
+            for line in f:
+                line = line.strip()
+                if not line or line.startswith("#"):
+                    continue
+                # Пример: http://node1.mesh.local:8000
+                try:
+                    peer_url = line
+                    peer_id = str(uuid.uuid4())  # временно генерим ID, потом можно подтянуть DID
+                    name = peer_url.split("://")[1].split(":")[0]
+                    self.add_or_update_peer(peer_id, name, [peer_url], source="bootstrap")
+                except Exception as e:
+                    print(f"[Storage] Ошибка парсинга bootstrap: {line} -> {e}")
+
     # Утилиты
 
     def close(self):