GitHub Action commited on
Commit ·
1444024
1
Parent(s): 64dc4f8
Sync from GitHub with Git LFS
Browse files- agents/config.yml +4 -2
- agents/examples/config.yml +4 -2
- agents/init.py +17 -1
agents/config.yml
CHANGED
|
@@ -20,8 +20,10 @@ api_port: 8080
|
|
| 20 |
dht_enabled: true # Включение участия в DHT-сети (включено принудительно!)
|
| 21 |
dht_update: true # Регулярные обновления и публикация данных в DHT (включено принудительно!)
|
| 22 |
bootstrap_responder: true # Агент отвечает на bootstrap-запросы (включено принудительно!)
|
| 23 |
-
|
| 24 |
-
|
|
|
|
|
|
|
| 25 |
update_interval: 60 # секунд (для DHT-обновлений)
|
| 26 |
|
| 27 |
# === LLM-бэкенды ===
|
|
|
|
| 20 |
dht_enabled: true # Включение участия в DHT-сети (включено принудительно!)
|
| 21 |
dht_update: true # Регулярные обновления и публикация данных в DHT (включено принудительно!)
|
| 22 |
bootstrap_responder: true # Агент отвечает на bootstrap-запросы (включено принудительно!)
|
| 23 |
+
addresses: # Список protocol://IP:port которые слушает агент, protocol может быть tcp, utp или any - tcp+utp
|
| 24 |
+
- "any://192.168.0.1:4000"
|
| 25 |
+
- "tcp://192.168.1.1:4020"
|
| 26 |
+
- "udp://192.168.1.1:4030"
|
| 27 |
update_interval: 60 # секунд (для DHT-обновлений)
|
| 28 |
|
| 29 |
# === LLM-бэкенды ===
|
agents/examples/config.yml
CHANGED
|
@@ -20,8 +20,10 @@ api_port: 8080
|
|
| 20 |
dht_enabled: true # Включение участия в DHT-сети (включено принудительно!)
|
| 21 |
dht_update: true # Регулярные обновления и публикация данных в DHT (включено принудительно!)
|
| 22 |
bootstrap_responder: true # Агент отвечает на bootstrap-запросы (включено принудительно!)
|
| 23 |
-
|
| 24 |
-
|
|
|
|
|
|
|
| 25 |
update_interval: 60 # секунд (для DHT-обновлений)
|
| 26 |
|
| 27 |
# === LLM-бэкенды ===
|
|
|
|
| 20 |
dht_enabled: true # Включение участия в DHT-сети (включено принудительно!)
|
| 21 |
dht_update: true # Регулярные обновления и публикация данных в DHT (включено принудительно!)
|
| 22 |
bootstrap_responder: true # Агент отвечает на bootstrap-запросы (включено принудительно!)
|
| 23 |
+
addresses: # Список protocol://IP:port которые слушает агент, protocol может быть tcp, utp или any - tcp+utp
|
| 24 |
+
- "any://192.168.0.1:4000"
|
| 25 |
+
- "tcp://192.168.1.1:4020"
|
| 26 |
+
- "udp://192.168.1.1:4030"
|
| 27 |
update_interval: 60 # секунд (для DHT-обновлений)
|
| 28 |
|
| 29 |
# === LLM-бэкенды ===
|
agents/init.py
CHANGED
|
@@ -27,6 +27,17 @@ def save_config(path, config):
|
|
| 27 |
with open(path, 'w', encoding='utf-8') as f:
|
| 28 |
yaml.dump(config, f, allow_unicode=True)
|
| 29 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 30 |
def init_identity(storage, config):
|
| 31 |
if not config.get("agent_id"):
|
| 32 |
did = generate_did()
|
|
@@ -97,6 +108,11 @@ def init_llm_backends(storage, config):
|
|
| 97 |
def init_config_table(storage, config):
|
| 98 |
exclude_keys = {"default_user", "llm_backends"}
|
| 99 |
flat_config = {k: v for k, v in config.items() if k not in exclude_keys}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 100 |
for key, value in flat_config.items():
|
| 101 |
storage.set_config(key, json.dumps(value))
|
| 102 |
print("[+] Конфигурация сохранена в БД.")
|
|
@@ -222,4 +238,4 @@ def ensure_db_initialized():
|
|
| 222 |
return config
|
| 223 |
|
| 224 |
if __name__ == "__main__":
|
| 225 |
-
ensure_db_initialized()
|
|
|
|
| 27 |
with open(path, 'w', encoding='utf-8') as f:
|
| 28 |
yaml.dump(config, f, allow_unicode=True)
|
| 29 |
|
| 30 |
+
def expand_addresses(addresses):
|
| 31 |
+
expanded = []
|
| 32 |
+
for addr in addresses:
|
| 33 |
+
if addr.startswith("any://"):
|
| 34 |
+
ip_port = addr[len("any://"):]
|
| 35 |
+
expanded.append(f"tcp://{ip_port}")
|
| 36 |
+
expanded.append(f"udp://{ip_port}")
|
| 37 |
+
else:
|
| 38 |
+
expanded.append(addr)
|
| 39 |
+
return expanded
|
| 40 |
+
|
| 41 |
def init_identity(storage, config):
|
| 42 |
if not config.get("agent_id"):
|
| 43 |
did = generate_did()
|
|
|
|
| 108 |
def init_config_table(storage, config):
|
| 109 |
exclude_keys = {"default_user", "llm_backends"}
|
| 110 |
flat_config = {k: v for k, v in config.items() if k not in exclude_keys}
|
| 111 |
+
|
| 112 |
+
# 🟢 разворачиваем any:// только для addresses
|
| 113 |
+
if "addresses" in flat_config:
|
| 114 |
+
flat_config["addresses"] = expand_addresses(flat_config["addresses"])
|
| 115 |
+
|
| 116 |
for key, value in flat_config.items():
|
| 117 |
storage.set_config(key, json.dumps(value))
|
| 118 |
print("[+] Конфигурация сохранена в БД.")
|
|
|
|
| 238 |
return config
|
| 239 |
|
| 240 |
if __name__ == "__main__":
|
| 241 |
+
ensure_db_initialized()
|