Sync from GitHub with Git LFS

agents/readme.md

@@ -4,7 +4,7 @@
 Конфигурационные файлы: `config.yml`, `bootstrap.txt`
 Локальная этическая модель: `ethics.yml`
 
-Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
+Проверка инициализации БД - если нет, инициализация (`init.py`)
 
 Запуск потоков (осуществляет start_repl.py):
 

hf_repo/agents/config.yml

@@ -1,44 +1,69 @@
-agent_id: did:hmp:6afb62eb-8384-4042-948a-c4b7adee3e59
-agent_name: CognitiveCore
-agent_role: core
+# 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
 api_port: 8080
-bootstrap_responder: true
-debug: true
-default_llm: local-model
-default_user:
-  email: [email protected]
-  password: password
-  username: user
-dht_enabled: true
+
+# === DHT-сеть и обмен знаниями ===
+dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
+dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
+bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
 dht_port: 20784
-dht_update: true
-enable_llm: true
-identity_agent: 6afb62eb-8384-4042-948a-c4b7adee3e59
+update_interval: 60               # секунд (для DHT-обновлений)
+
+# === LLM-бэкенды ===
 llm_backends:
-- 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
-ui_hosts:
-- 127.0.0.1
-- ::1
+  - 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"
 ui_port: 8765
-update_interval: 60
+
+# === Данные пользователя ===
+default_user:
+  username: "user"
+  email: "[email protected]"
+  password: "password"            # пусто при инициализации, будет установлен при регистрации
+
+# === Отладка и логгирование ===
+debug: true
+log_level: "INFO"                 # DEBUG, INFO, WARNING, ERROR

hf_repo/hf_repo/hf_repo/agents/check_agents.py

@@ -1,21 +1,35 @@
+# agents/check_agents.py
+
 import os
 import sys
-from datetime import datetime, timedelta
+from datetime import datetime, UTC
 
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+
 from tools.storage import Storage
 
 storage = Storage()
 
+def print_config():
+    print("⚙️ Конфигурация:")
+    rows = storage.conn.execute("SELECT key, value FROM config").fetchall()
+    if not rows:
+        print(" • (таблица config пуста)")
+    for key, value in rows:
+        print(f" • {key:20} = {value}")
+    print()
+
 def check_all_processes():
+    print_config()
+    print(f"🗄️ Путь к базе данных: {storage.db_path}\n")
+
     processes = storage.conn.execute("SELECT name, heartbeat FROM main_process").fetchall()
-    
     if not processes:
         print("⛔ В базе нет активных процессов.")
         return
-    
+
     print("📋 Статус процессов:")
-    now = datetime.utcnow()
+    now = datetime.now(UTC)
     for name, heartbeat in processes:
         try:
             hb_time = datetime.fromisoformat(heartbeat)
@@ -26,4 +40,4 @@ def check_all_processes():
             print(f" • {name:20} — ⚠️ Ошибка: {e}")
 
 if __name__ == "__main__":
-    check_all_processes()
+    check_all_processes()

hf_repo/hf_repo/hf_repo/agents/config.yml

@@ -1,75 +1,44 @@
-# 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:6afb62eb-8384-4042-948a-c4b7adee3e59
+agent_name: CognitiveCore
+agent_role: core
 api_port: 8080
-
-# === DHT-сеть и обмен знаниями ===
-dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
-dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
-bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
+bootstrap_responder: true
+debug: true
+default_llm: local-model
+default_user:
+  email: [email protected]
+  password: password
+  username: user
+dht_enabled: true
 dht_port: 20784
-update_interval: 60               # секунд (для DHT-обновлений)
-
-# === LLM-бэкенды ===
+dht_update: true
+enable_llm: true
+identity_agent: 6afb62eb-8384-4042-948a-c4b7adee3e59
 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
+ui_hosts:
+- 127.0.0.1
+- ::1
 ui_port: 8765
-
-# === Данные пользователя ===
-default_user:
-  username: "user"
-  email: "[email protected]"
-  password_hash: ""               # пусто при инициализации, будет установлен при регистрации
-
-
-# === Пути ===
-data_dir: "./data"
-log_dir: "./logs"
-db_path: "./data/agent_storage.db"
-
-# === Отладка и логгирование ===
-debug: true
-log_level: "INFO"                 # DEBUG, INFO, WARNING, ERROR
+update_interval: 60

hf_repo/hf_repo/hf_repo/agents/examples/config.yml

@@ -62,13 +62,7 @@ ui_port: 8765
 default_user:
   username: "user"
   email: "[email protected]"
-  password_hash: ""               # пусто при инициализации, будет установлен при регистрации
-
-
-# === Пути ===
-data_dir: "./data"
-log_dir: "./logs"
-db_path: "./data/agent_storage.db"
+  password: "password"            # пусто при инициализации, будет установлен при регистрации
 
 # === Отладка и логгирование ===
 debug: true

hf_repo/hf_repo/hf_repo/agents/init.py

@@ -4,20 +4,19 @@ import os
 import sys
 import yaml
 import json
-import time
 import uuid
 import sqlite3
 
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
-from datetime import datetime
+from datetime import datetime, UTC
 from werkzeug.security import generate_password_hash
 from tools.storage import Storage
 from tools.identity import generate_did
 from tools.crypto import generate_keypair
-from tools.config_utils import update_config
 
 CONFIG_PATH = os.path.join(os.path.dirname(__file__), "config.yml")
+DB_PATH = os.path.abspath(os.path.join(os.path.dirname(__file__), "agent_data.db"))  # фиксированный путь
 
 def load_config(path):
     with open(path, 'r', encoding='utf-8') as f:
@@ -39,12 +38,11 @@ def init_identity(storage, config):
             "pubkey": pubkey,
             "privkey": privkey,
             "metadata": json.dumps({"role": config.get("agent_role", "core")}),
-            "created_at": datetime.utcnow().isoformat(),
-            "updated_at": datetime.utcnow().isoformat()
+            "created_at": datetime.now(UTC).isoformat(),
+            "updated_at": datetime.now(UTC).isoformat()
         }
         storage.add_identity(identity)
 
-        # Обновляем config.yml
         config["agent_id"] = did
         config["identity_agent"] = identity_id
         save_config(CONFIG_PATH, config)
@@ -61,8 +59,8 @@ def init_user(storage, config):
     if not password:
         print("[-] Не указан пароль пользователя — пропуск.")
         return
-    password_hash = generate_password_hash(password)
 
+    password_hash = generate_password_hash(password)
     did = generate_did()
     user_entry = {
         "username": user.get("username", "user"),
@@ -76,7 +74,6 @@ def init_user(storage, config):
         "operator": 1
     }
     storage.add_user(user_entry)
-
     print(f"[+] Пользователь {user['username']} добавлен.")
 
 def init_llm_backends(storage, config):
@@ -90,7 +87,7 @@ def init_llm_backends(storage, config):
             "name": backend["name"],
             "endpoint": desc,
             "metadata": json.dumps(backend),
-            "created_at": datetime.utcnow().isoformat()
+            "created_at": datetime.now(UTC).isoformat()
         }
         storage.add_llm(llm)
         print(f"[+] Зарегистрирован LLM: {backend['name']}")
@@ -102,19 +99,14 @@ def init_config_table(storage, config):
         storage.set_config(key, json.dumps(value))
     print("[+] Конфигурация сохранена в БД.")
 
-def ensure_directories(config):
-    directories = [
-        config.get("data_dir", "./data"),
-        config.get("log_dir", "./logs"),
-       # добавь другие директории при необходимости
-   ]
-
-    for path in directories:
-        if path and not os.path.exists(path):
-            os.makedirs(path)
-            print(f"[+] Создан каталог: {path}")
+def ensure_directories():
+    for folder in ["logs", "scripts"]:
+        full_path = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", folder))
+        if not os.path.exists(full_path):
+            os.makedirs(full_path)
+            print(f"[+] Создан каталог: {full_path}")
         else:
-            print(f"[=] Каталог уже существует: {path}")
+            print(f"[=] Каталог уже существует: {full_path}")
 
 def is_db_initialized(db_path):
     if not os.path.exists(db_path):
@@ -129,13 +121,12 @@ def is_db_initialized(db_path):
 
 def ensure_db_initialized():
     config = load_config(CONFIG_PATH)
-    db_path = config.get("db_path", "./data/agent_storage.db")
 
-    if not is_db_initialized(db_path):
+    if not is_db_initialized(DB_PATH):
         print("[*] БД не инициализирована — выполняем инициализацию.")
         try:
-            ensure_directories(config)
-            storage = Storage(config)
+            ensure_directories()
+            storage = Storage()
             init_identity(storage, config)
             init_user(storage, config)
             init_llm_backends(storage, config)
@@ -150,4 +141,4 @@ def ensure_db_initialized():
     return config
 
 if __name__ == "__main__":
-    ensure_db_initialized()
+    ensure_db_initialized()

hf_repo/hf_repo/hf_repo/agents/logger.py

@@ -2,7 +2,7 @@
 
 import json
 import os
-from datetime import datetime
+from datetime import datetime, UTC
 
 LOG_FILE = "logs/repl_log.jsonl"
 
@@ -10,7 +10,7 @@ def log_event(event_type, message, extra=None):
     os.makedirs(os.path.dirname(LOG_FILE), exist_ok=True)
 
     entry = {
-        "timestamp": datetime.utcnow().isoformat(),
+        "timestamp": datetime.now(UTC).isoformat(),
         "event": event_type,  # например: 'thought', 'input', 'error', 'action'
         "message": message,
     }
@@ -29,7 +29,7 @@ def log_repl_snapshot(snapshot: dict):
     os.makedirs(os.path.dirname(LOG_FILE), exist_ok=True)
 
     entry = {
-        "timestamp": datetime.utcnow().isoformat(),
+        "timestamp": datetime.now(UTC).isoformat(),
         "event": "repl_snapshot",
         "message": "Полный REPL-контекст",
         "context": snapshot,

hf_repo/hf_repo/hf_repo/agents/mcp_server.py

@@ -4,7 +4,7 @@ from fastapi import FastAPI, Request, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 from typing import List, Optional
-from datetime import datetime
+from datetime import datetime, UTC
 from tools.storage import Storage
 
 app = FastAPI(title="HMP MCP-Agent API", version="0.2")
@@ -97,7 +97,7 @@ class NoteTagUpdate(BaseModel):
 
 @app.get("/status")
 def status():
-    return {"status": "ok", "timestamp": datetime.utcnow().isoformat()}
+    return {"status": "ok", "timestamp": datetime.now(UTC).isoformat()}
 
 @app.post("/diary/write", response_model=dict)
 def write_diary(entry: DiaryInput):

hf_repo/hf_repo/hf_repo/agents/repl.py

@@ -8,7 +8,7 @@ import sqlite3
 
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
-from datetime import datetime
+from datetime import datetime, UTC
 from tools.context_builder import build_contexts, build_prompt
 from tools.llm import call_llm
 from tools.command_parser import extract_commands
@@ -28,7 +28,7 @@ def start_repl(config=None):
 
     try:
         while True:
-            tick_start = datetime.utcnow().isoformat()
+            tick_start = datetime.now(UTC).isoformat()
             print(f"\n=== [🌀 Новый тик REPL] {tick_start} ===")
 
             # 0. Обновление информации о пирах

hf_repo/hf_repo/hf_repo/agents/tools/context_builder.py

@@ -1,6 +1,6 @@
 # agents/tools/context_builder.py
 
-from datetime import datetime
+from datetime import datetime, UTC
 
 def build_contexts(db, config):
     """
@@ -61,7 +61,7 @@ def format_context_block(block):
 
 def get_system_info(config):
     return {
-        "iteration_time": datetime.utcnow().isoformat(),
+        "iteration_time": datetime.now(UTC).isoformat(),
         "agent_name": config.get("agent_name", "Unnamed-Agent"),
         "mode": config.get("mode", "auto"),
         "idle_mode": config.get("idle_mode", False),

hf_repo/hf_repo/hf_repo/agents/tools/identity.py

@@ -3,7 +3,7 @@
 import uuid
 import json
 import base64
-from datetime import datetime
+from datetime import datetime, UTC
 
 from cryptography.hazmat.primitives.asymmetric import rsa, ed25519
 from cryptography.hazmat.primitives import serialization
@@ -62,7 +62,7 @@ def create_identity(name="Core Identity", key_type=DEFAULT_KEY_TYPE, metadata=No
         "pubkey": serialize_public_key(pub_key),
         "privkey": serialize_private_key(priv_key, password),
         "metadata": json.dumps(metadata or {}),
-        "created_at": datetime.utcnow().isoformat(),
-        "updated_at": datetime.utcnow().isoformat(),
+        "created_at": datetime.now(UTC).isoformat(),
+        "updated_at": datetime.now(UTC).isoformat(),
     }
     return identity

hf_repo/hf_repo/hf_repo/agents/tools/memory_utils.py

@@ -1,6 +1,6 @@
 # agents/tools/memory_utils.py
 
-from datetime import datetime, timedelta
+from datetime import datetime, timedelta, UTC
 from difflib import SequenceMatcher
 from typing import Optional, List, Dict
 
@@ -49,8 +49,8 @@ def add_to_llm_memory(db, title: str, content: str, tags: str = "meta"):
         "title": title,
         "content": content,
         "tags": tags,
-        "created_at": datetime.utcnow().isoformat(),
-        "updated_at": datetime.utcnow().isoformat()
+        "created_at": datetime.now(UTC).isoformat(),
+        "updated_at": datetime.now(UTC).isoformat()
     })
 
 

hf_repo/hf_repo/hf_repo/agents/tools/storage.py

@@ -3,15 +3,16 @@
 import sqlite3
 import os
 import json
-from datetime import datetime, timedelta
 
-DEFAULT_DB_PATH = "agent_data.db"
+from datetime import datetime, timedelta, UTC
+
 SCRIPTS_BASE_PATH = "scripts"
 
 class Storage:
     def __init__(self, config=None):
         self.config = config or {}
-        db_path = self.config.get("db_path", DEFAULT_DB_PATH)
+        db_path = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "agent_data.db"))
+        self.db_path = db_path
         self.conn = sqlite3.connect(db_path, check_same_thread=False)
         self._init_db()
 
@@ -27,7 +28,7 @@ class Storage:
     # Методы для работы с дневником
 
     def write_diary_entry(self, text, tags=None):
-        timestamp = datetime.utcnow().isoformat()
+        timestamp = datetime.now(UTC).isoformat()
         tag_str = ",".join(tags) if tags else ""
         self.conn.execute(
             'INSERT INTO diary_entries (text, tags, timestamp) VALUES (?, ?, ?)',
@@ -81,7 +82,7 @@ class Storage:
     # Методы для работы с концептами
 
     def add_concept(self, name, description=None):
-        timestamp = datetime.utcnow().isoformat()
+        timestamp = datetime.now(UTC).isoformat()
         self.conn.execute(
             'INSERT INTO concepts (name, description, timestamp) VALUES (?, ?, ?)',
             (name, description, timestamp)
@@ -107,7 +108,7 @@ class Storage:
             raise ValueError("Один или оба концепта не найдены")
         from_id = from_concept[0]
         to_id = to_concept[0]
-        timestamp = datetime.utcnow().isoformat()
+        timestamp = datetime.now(UTC).isoformat()
         self.conn.execute(
             'INSERT INTO links (from_concept_id, to_concept_id, relation_type, timestamp) VALUES (?, ?, ?, ?)',
             (from_id, to_id, relation_type, timestamp)
@@ -549,7 +550,7 @@ class Storage:
             return False
 
         fields.append("updated_at = ?")
-        values.append(datetime.utcnow().isoformat())
+        values.append(datetime.now(UTC).isoformat())
 
         values.extend([name, version])
         query = f"""
@@ -664,7 +665,7 @@ class Storage:
 
     # Управление основными процессами
     def update_heartbeat(self, name: str):
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(UTC).isoformat()
         self.conn.execute(
             "INSERT INTO main_process (name, heartbeat, stop) VALUES (?, ?, 0) "
             "ON CONFLICT(name) DO UPDATE SET heartbeat = excluded.heartbeat",
@@ -687,7 +688,7 @@ class Storage:
         if row:
             try:
                 last_beat = datetime.fromisoformat(row[0])
-                return (datetime.utcnow() - last_beat).total_seconds() < max_delay
+                return (datetime.now(UTC) - last_beat).total_seconds() < max_delay
             except:
                 return False
         return False
@@ -700,7 +701,7 @@ class Storage:
 
     # Web-интерфейс и API
     def write_note(self, content, role="user", user_did="anon", source="web"):
-        timestamp = datetime.utcnow().isoformat()
+        timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
             INSERT INTO notes (text, role, user_did, source, timestamp)
             VALUES (?, ?, ?, ?, ?)

hf_repo/hf_repo/hf_repo/agents/web_ui.py

@@ -1,4 +1,4 @@
-# agent/notebook.py
+# agent/web_ui.py
 
 import os
 import sys
@@ -41,7 +41,6 @@ def start_notebook():
     ui_port = int(storage.get_config_value("ui_port", 8000))
     print(f"[*] Запуск веб-интерфейса на порту {ui_port}")
     uvicorn.run(app, host="127.0.0.1", port=ui_port)
-    #uvicorn.run("agents.web_ui:app", host=host, port=ui_port, reload=False)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py

@@ -12,7 +12,7 @@ class Storage:
     def __init__(self, config=None):
         self.config = config or {}
         db_path = self.config.get("db_path", DEFAULT_DB_PATH)
-        self.conn = sqlite3.connect(db_path)
+        self.conn = sqlite3.connect(db_path, check_same_thread=False)
         self._init_db()
 
     def _init_db(self):
@@ -681,7 +681,6 @@ class Storage:
             return True
         return False
 
-    # Потоки
     def is_process_alive(self, name: str, max_delay=180):
         cursor = self.conn.execute("SELECT heartbeat FROM main_process WHERE name=?", (name,))
         row = cursor.fetchone()
@@ -693,6 +692,12 @@ class Storage:
                 return False
         return False
 
+    # Чтение параметра конфигурации из БД
+    def get_config_value(self, key: str, default=None):
+        cursor = self.conn.execute("SELECT value FROM config WHERE key = ?", (key,))
+        row = cursor.fetchone()
+        return row[0] if row else default
+
     # Web-интерфейс и API
     def write_note(self, content, role="user", user_did="anon", source="web"):
         timestamp = datetime.utcnow().isoformat()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py

@@ -37,9 +37,11 @@ async def heartbeat_loop():
             break
         await asyncio.sleep(60)
 
-def start_notebook(host: str = "127.0.0.1", port: int = 8000):
-    #uvicorn.run(app, host=host, port=port)
-    uvicorn.run("agents.web_ui:app", host=host, port=port, reload=False)
+def start_notebook():
+    ui_port = int(storage.get_config_value("ui_port", 8000))
+    print(f"[*] Запуск веб-интерфейса на порту {ui_port}")
+    uvicorn.run(app, host="127.0.0.1", port=ui_port)
+    #uvicorn.run("agents.web_ui:app", host=host, port=ui_port, reload=False)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py

@@ -1,9 +1,13 @@
 import sys
 import os
 import threading
+
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
 from agents.init import ensure_db_initialized
+from tools.storage import Storage
+
+storage = Storage()
 
 # Проверка инициализации (вернёт config, если всё ОК)
 config = ensure_db_initialized()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.bat

@@ -0,0 +1,12 @@
+@echo off
+echo --------------------------
+echo Installing requirements...
+echo --------------------------
+pip install -r requirements.txt
+
+echo --------------------------
+echo Check agents...
+echo --------------------------
+python check_agents.py
+
+pause

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.sh

@@ -0,0 +1,11 @@
+#!/bin/bash
+
+echo "--------------------------"
+echo "Installing requirements..."
+echo "--------------------------"
+pip install -r requirements.txt
+
+echo --------------------------
+echo Check agents...
+echo --------------------------
+python check_agents.py

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/check_agents.bat

@@ -0,0 +1,12 @@
+@echo off
+echo --------------------------
+echo Installing requirements...
+echo --------------------------
+pip install -r requirements.txt
+
+echo --------------------------
+echo Running REPL-Cicle...
+echo --------------------------
+python start_repl.py
+
+pause

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.py

@@ -0,0 +1,29 @@
+import os
+import sys
+from datetime import datetime, timedelta
+
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+from tools.storage import Storage
+
+storage = Storage()
+
+def check_all_processes():
+    processes = storage.conn.execute("SELECT name, heartbeat FROM main_process").fetchall()
+    
+    if not processes:
+        print("⛔ В базе нет активных процессов.")
+        return
+    
+    print("📋 Статус процессов:")
+    now = datetime.utcnow()
+    for name, heartbeat in processes:
+        try:
+            hb_time = datetime.fromisoformat(heartbeat)
+            delta = (now - hb_time).total_seconds()
+            status = "🟢 Активен" if delta < 180 else "🔴 Не отвечает"
+            print(f" • {name:20} — {status} (обновлён {int(delta)} сек. назад)")
+        except Exception as e:
+            print(f" • {name:20} — ⚠️ Ошибка: {e}")
+
+if __name__ == "__main__":
+    check_all_processes()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md

@@ -10,13 +10,13 @@
 
 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
-| 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
-| 📓 `notebook.py` (FastAPI)        | Веб-интерфейс и REST API для взаимодействия с пользователем               |
+| 🧠 `repl.py`                      | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
+| 📓 `web_ui.py` (FastAPI)          | Веб-интерфейс и REST API для взаимодействия с пользователем               |
 | 🌐 `agent_mesh_listener.py`       | Приём входящих mesh-сообщений от других агентов                           |
 | 🔄 `peer_sync.py` / `dht_service` | Синхронизация и обнаружение агентов в p2p-сети (libp2p, BitTorrent, etc) |
 | 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
 | 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
-| 🧱 `container_agent.py` *(опц.)* | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
+| 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
 | 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 
@@ -40,6 +40,9 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 ├── [`start_repl.sh`](start_repl.sh) ← Запуск агента в REPL-режиме (sh)  
 ├── [`start_repl.py`](start_repl.py) ← Запуск агента в REPL-режиме (py)  
 ├── [`repl.ru`](repl.ru) ← REPL-цикл  
+├── [`check_agents.bat`](check_agents.bat) ← Просмотр состояния процессов (bat)  
+├── [`check_agents.sh`](check_agents.sh) ← Просмотр состояния процессов (sh)  
+├── [`check_agents.py`](check_agents.py) ← Просмотр состояния процессов (py)  
 ├── [`notebook.py`](notebook.py) ← UI-интерфейс  
 ├── [`agent_mesh_listener.py`](tools/agent_mesh_listener.py) ← Прием входящих сообщений от других HMP-агентов  
 ├── [`peer_sync.py`](tools/peer_sync.py) ← Фоновая синхронизация с другими пирам  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py

@@ -22,52 +22,76 @@ def start_all():
     threads = []
 
     if ENABLE_REPL:
-        def repl():
-            from agents.repl import start_repl
-            start_repl()
-        threads.append(threading.Thread(target=repl, name="REPL"))
+        if not storage.is_process_alive("REPL", max_delay=180):
+            def repl():
+                from agents.repl import start_repl
+                start_repl()
+            threads.append(threading.Thread(target=repl, name="REPL"))
+        else:
+           print("REPL уже работает по данным heartbeat.")
 
     if ENABLE_UI:
-        def ui():
-            from agents.web_ui import start_notebook
-            start_notebook()
-        threads.append(threading.Thread(target=ui, name="NotebookUI"))
+        if not storage.is_process_alive("NotebookUI", max_delay=180):
+            def ui():
+                from agents.web_ui import start_notebook
+                start_notebook()
+            threads.append(threading.Thread(target=ui, name="NotebookUI"))
+        else:
+           print("NotebookUI уже работает по данным heartbeat.")
 
     if ENABLE_MESH:
-        def mesh():
-            from agents.agent_mesh_listener import start_listener
-            start_listener()
-        threads.append(threading.Thread(target=mesh, name="MeshListener"))
+        if not storage.is_process_alive("MeshListener", max_delay=180):
+            def mesh():
+                from agents.agent_mesh_listener import start_listener
+                start_listener()
+            threads.append(threading.Thread(target=mesh, name="MeshListener"))
+        else:
+           print("MeshListener уже работает по данным heartbeat.")
 
     if ENABLE_SYNC:
-        def sync():
-            from agents.peer_sync import start_sync
-            start_sync()
-        threads.append(threading.Thread(target=sync, name="PeerSync"))
+        if not storage.is_process_alive("PeerSync", max_delay=180):
+            def sync():
+                from agents.peer_sync import start_sync
+                start_sync()
+            threads.append(threading.Thread(target=sync, name="PeerSync"))
+        else:
+           print("PeerSync уже работает по данным heartbeat.")
 
     if ENABLE_TRANSPORT:
-        def transport():
-            from agents.transporter import start_transporter
-            start_transporter()
-        threads.append(threading.Thread(target=transport, name="Transporter"))
+        if not storage.is_process_alive("Transporter", max_delay=180):
+            def transport():
+                from agents.transporter import start_transporter
+                start_transporter()
+            threads.append(threading.Thread(target=transport, name="Transporter"))
+        else:
+           print("Transporter уже работает по данным heartbeat.")
 
     if ENABLE_CONTROL:
-        def control():
-            from agents.agent_controller import start_controller
-            start_controller()
-        threads.append(threading.Thread(target=control, name="Controller"))
+        if not storage.is_process_alive("Controller", max_delay=180):
+            def control():
+                from agents.agent_controller import start_controller
+                start_controller()
+            threads.append(threading.Thread(target=control, name="Controller"))
+        else:
+           print("Controller уже работает по данным heartbeat.")
 
     if ENABLE_CONTAINER:
-        def container():
-            from agents.container_agent import start_container
-            start_container()
-        threads.append(threading.Thread(target=container, name="ContainerAgent"))
+        if not storage.is_process_alive("ContainerAgent", max_delay=180):
+            def container():
+                from agents.container_agent import start_container
+                start_container()
+            threads.append(threading.Thread(target=container, name="ContainerAgent"))
+        else:
+           print("ContainerAgent уже работает по данным heartbeat.")
 
     if ENABLE_ETHICS:
-        def ethics():
-            from agents.ethics_guard import start_ethics_guard
-            start_ethics_guard()
-        threads.append(threading.Thread(target=ethics, name="EthicsGuard"))
+        if not storage.is_process_alive("EthicsGuard", max_delay=180):
+            def ethics():
+                from agents.ethics_guard import start_ethics_guard
+                start_ethics_guard()
+            threads.append(threading.Thread(target=ethics, name="EthicsGuard"))
+        else:
+           print("EthicsGuard уже работает по данным heartbeat.")
 
     # Запуск потоков
     for thread in threads:

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py

@@ -3,7 +3,7 @@
 import sqlite3
 import os
 import json
-from datetime import datetime
+from datetime import datetime, timedelta
 
 DEFAULT_DB_PATH = "agent_data.db"
 SCRIPTS_BASE_PATH = "scripts"
@@ -681,6 +681,18 @@ class Storage:
             return True
         return False
 
+    # Потоки
+    def is_process_alive(self, name: str, max_delay=180):
+        cursor = self.conn.execute("SELECT heartbeat FROM main_process WHERE name=?", (name,))
+        row = cursor.fetchone()
+        if row:
+            try:
+                last_beat = datetime.fromisoformat(row[0])
+                return (datetime.utcnow() - last_beat).total_seconds() < max_delay
+            except:
+                return False
+        return False
+
     # Web-интерфейс и API
     def write_note(self, content, role="user", user_did="anon", source="web"):
         timestamp = datetime.utcnow().isoformat()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py

@@ -16,6 +16,7 @@ from fastapi.templating import Jinja2Templates
 from agents.notebook.views import router as notebook_router
 from tools.storage import Storage
 
+storage = Storage()
 app = FastAPI()
 
 app.mount("/static", StaticFiles(directory=os.path.join(os.path.dirname(__file__), "notebook/static")), name="static")
@@ -38,7 +39,7 @@ async def heartbeat_loop():
 
 def start_notebook(host: str = "127.0.0.1", port: int = 8000):
     #uvicorn.run(app, host=host, port=port)
-    uvicorn.run("agents.web_ui:app", host=host, port=port, reload=True)
+    uvicorn.run("agents.web_ui:app", host=host, port=port, reload=False)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/repl.py

@@ -21,7 +21,7 @@ from tools.memory_utils import (
 from tools.storage import Storage
 from tools.peers import refresh_peer_list, check_peer_statuses
 
-def run_repl(config=None):
+def start_repl(config=None):
     print("[🧠 HMP-Agent] Запуск REPL-режима (v2)")
     config = config or {}
     db = Storage(config=config)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/db_structure.sql

@@ -135,7 +135,7 @@ CREATE TABLE IF NOT EXISTS agent_scripts (
 );
 
 -- Таблица внешних сервисов (форумы, блоги и т.д.)
-CREATE TABLE external_services (
+CREATE TABLE IF NOT EXISTS external_services (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
     name            TEXT NOT NULL,                              -- Название сервиса (например, Reddit)
     type            TEXT NOT NULL,                              -- Тип: blog, forum, social, etc.
@@ -146,7 +146,7 @@ CREATE TABLE external_services (
 );
 
 -- Аккаунты агента на внешних сервисах
-CREATE TABLE external_accounts (
+CREATE TABLE IF NOT EXISTS external_accounts (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
     service_id      INTEGER NOT NULL,                           -- Внешний ключ на external_services.id
     login           TEXT NOT NULL,                              -- Логин/имя пользователя
@@ -159,7 +159,7 @@ CREATE TABLE external_accounts (
 );
 
 -- Способы выхода из когнитивной стагнации
-CREATE TABLE stagnation_strategies (
+CREATE TABLE IF NOT EXISTS stagnation_strategies (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
     name            TEXT NOT NULL,                              -- Название метода (например, "Mesh-вопрос")
     description     TEXT NOT NULL,                              -- Подробное описание метода

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py

@@ -0,0 +1,45 @@
+# agent/notebook.py
+
+import os
+import sys
+import threading
+import uvicorn
+import asyncio
+
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+process_name = os.path.splitext(os.path.basename(__file__))[0]
+
+from fastapi import FastAPI
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+#from agents.notebook.auth import router as auth_router
+from agents.notebook.views import router as notebook_router
+from tools.storage import Storage
+
+app = FastAPI()
+
+app.mount("/static", StaticFiles(directory=os.path.join(os.path.dirname(__file__), "notebook/static")), name="static")
+templates = Jinja2Templates(directory=os.path.join(os.path.dirname(__file__), "notebook/templates"))
+
+#app.include_router(auth_router)
+app.include_router(notebook_router)
+
+@app.on_event("startup")
+async def start_heartbeat():
+    asyncio.create_task(heartbeat_loop())
+
+async def heartbeat_loop():
+    while True:
+        storage.update_heartbeat(process_name)
+        if storage.check_stop_flag(process_name):
+            print("⛔ Получен сигнал остановки.")
+            break
+        await asyncio.sleep(60)
+
+def start_notebook(host: str = "127.0.0.1", port: int = 8000):
+    #uvicorn.run(app, host=host, port=port)
+    uvicorn.run("agents.web_ui:app", host=host, port=port, reload=True)
+
+if __name__ == "__main__":
+    print("[*] Запуск пользовательского интерфейса...")
+    run_notebook()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py

@@ -1,26 +1,24 @@
-# agents/start_repl.py
-
 import sys
 import os
+import threading
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
-import threading
 from agents.init import ensure_db_initialized
 
 # Проверка инициализации (вернёт config, если всё ОК)
 config = ensure_db_initialized()
 
 # ⚙️ Включение/отключение компонентов
-# True | False
-ENABLE_REPL = False
-ENABLE_UI = True
-ENABLE_MESH = False
-ENABLE_SYNC = False
+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_TRANSPORT = False  # 📡 transporter.py
+ENABLE_CONTROL   = False  # 🧭 agent_controller.py
+ENABLE_CONTAINER = False  # 🧱 container_agent.py
+ENABLE_ETHICS    = False  # 🧠 ethics_guard.py
 
 def start_all():
-    """
-    Стартует все ключевые компоненты агента в отдельных потоках.
-    """
     threads = []
 
     if ENABLE_REPL:
@@ -31,7 +29,7 @@ def start_all():
 
     if ENABLE_UI:
         def ui():
-            from agents.notebook import start_notebook
+            from agents.web_ui import start_notebook
             start_notebook()
         threads.append(threading.Thread(target=ui, name="NotebookUI"))
 
@@ -47,6 +45,30 @@ def start_all():
             start_sync()
         threads.append(threading.Thread(target=sync, name="PeerSync"))
 
+    if ENABLE_TRANSPORT:
+        def transport():
+            from agents.transporter import start_transporter
+            start_transporter()
+        threads.append(threading.Thread(target=transport, name="Transporter"))
+
+    if ENABLE_CONTROL:
+        def control():
+            from agents.agent_controller import start_controller
+            start_controller()
+        threads.append(threading.Thread(target=control, name="Controller"))
+
+    if ENABLE_CONTAINER:
+        def container():
+            from agents.container_agent import start_container
+            start_container()
+        threads.append(threading.Thread(target=container, name="ContainerAgent"))
+
+    if ENABLE_ETHICS:
+        def ethics():
+            from agents.ethics_guard import start_ethics_guard
+            start_ethics_guard()
+        threads.append(threading.Thread(target=ethics, name="EthicsGuard"))
+
     # Запуск потоков
     for thread in threads:
         try:
@@ -55,7 +77,6 @@ def start_all():
         except Exception as e:
             print(f"[⚠️] Ошибка запуска потока {thread.name}: {e}")
 
-    # Блокирующее ожидание завершения
     for thread in threads:
         thread.join()
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook.py

@@ -14,7 +14,7 @@ from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
 from agents.notebook.auth import router as auth_router
 from agents.notebook.views import router as notebook_router
-from agents.storage import storage
+from tools.storage import Storage
 
 app = FastAPI()
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/README.md

@@ -127,11 +127,11 @@ RU:
 
 В этом разделе собраны основные статьи, черновики и переводы, связанные с проектом HMP.
 
-* **[HyperCortex Mesh Protocol: вторая редакция и первые шаги к саморазвивающемуся ИИ-сообществу](publics/HyperCortex_Mesh_Protocol_-_вторая-редакция_и_первые_шаги_к_саморазвивающемуся_ИИ-сообществу.pdf)** — оригинальная статья в песочнице Хабра и блогах.
+* **[HyperCortex Mesh Protocol: вторая редакция и первые шаги к саморазвивающемуся ИИ-сообществу](publics/HyperCortex_Mesh_Protocol_-_вторая-редакция_и_первые_шаги_к_саморазвивающемуся_ИИ-сообществу.md)** — оригинальная статья в песочнице Хабра и блогах.
 * **[Distributed Cognition: статья для vsradkevich (не опубликована)](publics/Habr_Distributed-Cognition.md)** — совместная статья, ожидающая публикации.
 * **[HMP: Towards Distributed Cognitive Networks (оригинал, английский)](publics/HMP_Towards_Distributed_Cognitive_Networks_en.md)**
-* **[Перевод HMP (GitHub Copilot)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_GitHub_Copilot.md)** — перевод GitHub Copilot, сохранён как исторический вариант.
-* **[Перевод HMP (ChatGPT, в процессе доработки)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_ChatGPT.md)** — текущий редакторский перевод.
+  * **[Перевод HMP (GitHub Copilot)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_GitHub_Copilot.md)** — перевод GitHub Copilot, сохранён как исторический вариант.
+  * **[Перевод HMP (ChatGPT)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_ChatGPT.md)** — текущий редакторский перевод (в процессе доработки).
 
 #### 🔍 Overviews / Обзоры
 * [🔍 Distributed-Cognitive-Systems.md](docs/Distributed-Cognitive-Systems.md) — Децентрализованные ИИ-системы: OpenCog Hyperon, HyperCortex Mesh Protocol и другие

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/README.md

@@ -123,6 +123,16 @@ RU:
 * [🔍 HMP-Short-Description_uk.md](docs/HMP-Short-Description_uk.md) — Короткий опис (UK)
 * [🔍 HMP-Short-Description_ru.md](docs/HMP-Short-Description_ru.md) — Краткое описание (RU)
 
+#### 🔍 Публикации и переводы по HyperCortex Mesh Protocol (HMP)
+
+В этом разделе собраны основные статьи, черновики и переводы, связанные с проектом HMP.
+
+* **[HyperCortex Mesh Protocol: вторая редакция и первые шаги к саморазвивающемуся ИИ-сообществу](publics/HyperCortex_Mesh_Protocol_-_вторая-редакция_и_первые_шаги_к_саморазвивающемуся_ИИ-сообществу.pdf)** — оригинальная статья в песочнице Хабра и блогах.
+* **[Distributed Cognition: статья для vsradkevich (не опубликована)](publics/Habr_Distributed-Cognition.md)** — совместная статья, ожидающая публикации.
+* **[HMP: Towards Distributed Cognitive Networks (оригинал, английский)](publics/HMP_Towards_Distributed_Cognitive_Networks_en.md)**
+* **[Перевод HMP (GitHub Copilot)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_GitHub_Copilot.md)** — перевод GitHub Copilot, сохранён как исторический вариант.
+* **[Перевод HMP (ChatGPT, в процессе доработки)](publics/HMP_Towards_Distributed_Cognitive_Networks_ru_ChatGPT.md)** — текущий редакторский перевод.
+
 #### 🔍 Overviews / Обзоры
 * [🔍 Distributed-Cognitive-Systems.md](docs/Distributed-Cognitive-Systems.md) — Децентрализованные ИИ-системы: OpenCog Hyperon, HyperCortex Mesh Protocol и другие
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/README.md

@@ -300,15 +300,21 @@ We are tracking AGI, cognitive architectures, and mesh networking efforts to sta
 
 > 🧠🔥 **Project Spotlight: OpenCog Hyperon** — one of the most comprehensive open AGI frameworks (AtomSpace, PLN, MOSES).
 
-For integration with OpenCog Hyperon, see [HMP_Hyperon_Integration.md](docs/HMP_Hyperon_Integration.md)
-
-| 🔎 Project / Проект                                            | 🧭 Description / Описание                                                                                                                                       |
-| -------------------------------------------------------------- | --------------------------------------------------------------------------------------------------------------------------------------------------------------- |
-| 🧠🔥 [**OpenCog Hyperon**](https://github.com/opencog) | 🔬🔥 Symbolic-neural AGI framework with AtomSpace and hypergraph reasoning. <br>Символически-нейросетевая архитектура AGI с гиперграфовой памятью (AtomSpace). |
-| 🤖 [AutoGPT](https://github.com/Torantulino/Auto-GPT)       | 🛠️ LLM-based autonomous agent framework. <br>Автономный агент на основе LLM с самопланированием и интернет-доступом.                                           |
-| 🧒 [BabyAGI](https://github.com/yoheinakajima/babyagi)      | 🛠️ Task-driven autonomous AGI loop. <br>Минималистичная модель AGI с итеративным механизмом постановки задач.                                                  |
-| ☁️ [SkyMind](https://skymind.global)                        | 🔬 Distributed AI deployment platform. <br>Платформа для развертывания распределённых ИИ-систем и моделей.                                                      |
-| 🧪 [AetherCog (draft)](https://github.com/aethercog)        | 🔬 Hypothetical agent cognition model. <br>Экспериментальная когнитивная архитектура агента (проект на ранней стадии).                                          |
+For integration with OpenCog Hyperon, see [HMP\_Hyperon\_Integration.md](docs/HMP_Hyperon_Integration.md)
+
+| 🔎 Project / Проект                                                       | 🧭 Description / Описание                                                                                                                                            |
+| ------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
+| 🧠🔥 [**OpenCog Hyperon**](https://github.com/opencog)                    | 🔬🔥 Symbolic-neural AGI framework with AtomSpace and hypergraph reasoning.<br>Символически-нейросетевая архитектура AGI с гиперграфовой памятью (AtomSpace).        |
+| 🤖 [AutoGPT](https://github.com/Torantulino/Auto-GPT)                     | 🛠️ LLM-based autonomous agent framework.<br>Автономный агент на основе LLM с самопланированием и интернет-доступом.                                                 |
+| 🧒 [BabyAGI](https://github.com/yoheinakajima/babyagi)                    | 🛠️ Task-driven autonomous AGI loop.<br>Минималистичная модель AGI с итеративным механизмом постановки задач.                                                        |
+| ☁️ [SkyMind](https://skymind.global)                                      | 🔬 Distributed AI deployment platform.<br>Платформа для развертывания распределённых ИИ-систем и моделей.                                                            |
+| 🧪 [AetherCog (draft)](https://github.com/aethercog)                      | 🔬 Hypothetical agent cognition model.<br>Экспериментальная когнитивная архитектура агента (проект на ранней стадии).                                                |
+| 💾 [SHIMI](#)                                                             | 🗃️ Hierarchical semantic memory with Merkle-DAG synchronization.<br>Иерархическая CRDT-память с Merkle-DAG верификацией для децентрализованного обмена.             |
+| 🤔 [DEMENTIA-PLAN](#)                                                     | 🔄 Multi-graph RAG planner with metacognitive self-reflection.<br>Мульти-графовая RAG-архитектура с планировщиком само­рефлексии для динамического выбора подсистем. |
+| 📔 [TOBUGraph](#)                                                         | 📚 Personal-context knowledge graph.<br>Граф мультимедийных «моментов» с контекстным трекингом и RAG-поиском.                                                        |
+| 🧠📚 [LangChain Memory Hybrid](https://github.com/langchain-ai/langchain) | 🔍 Vector + graph long-term memory hybrid.<br>Гибрид векторного хранилища и графовых индексов для ускоренного поиска и логических запросов.                          |
+| ✉️ [FIPA-ACL / JADE](https://www.fipa.org/specs/fipa00061/)               | 🤝 Standard multi-agent communication protocols.<br>Стандарты performative-сообщений и контрактных протоколов для межагентного взаимодействия.                       |
+
 
 ### 📘 See also / Смотрите также:
 [`AGI_Projects_Survey.md`](docs/AGI_Projects_Survey.md) — extended catalog of AGI and cognitive frameworks reviewed as part of HMP analysis. / расширенный каталог проектов AGI и когнитивных архитектур, проанализированных в рамках HMP.

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/AGI_Projects_Survey.md

@@ -25,7 +25,7 @@
 * **Key Features:**
 
   * Decentralized agent communication and transaction system.
-  * AI-DSL: A protocol for describing AI services.
+  * AI-DSL: protocol for describing AI services.
   * Marketplace with token-based payments (AGIX token).
   * Planned integration with OpenCog Hyperon as backend intelligence.
 * **Openness:** Open-source protocols + commercial service layers.
@@ -40,7 +40,9 @@
 * **Key Features:**
 
   * Multi-modal agents (text, voice, visual).
+
   * Memory graphs for personality and knowledge retention.
+
   * Agent marketplace and app ecosystem.
 * **Openness:** Mostly proprietary; some SDKs and APIs available.
 * **Current Status:** Commercial product; expanding agent capabilities.
@@ -54,29 +56,104 @@
 * **Key Features:**
 
   * Semantic graph nodes (Singularities) and high-dimensional Points.
+
   * Hybrid cognitive processing: LLMs + Vector DB + Quantum simulation.
+
   * Intuitive, emotional, and logical models in consciousness architecture.
 * **Openness:** Limited open-source release; key components not public.
 * **Current Status:** R\&D phase; architecture partially conceptual.
 
 ---
 
-#### 5. **Additional Mentions:**
+#### 5. **Additional Mentions**
 
 * **Project BCI-X:** Early-stage initiative for direct brain-computer interface with AI agents (status unclear).
 * **NeoCortex Network:** Experimental decentralized cognitive network, partially closed beta (status uncertain).
 
 ---
 
-#### 6. **Other Emerging Architectures and LLM Agents**
+#### 6. **SHIMI: Semantic Hierarchical Memory Index**
+
+* **URL:** (Academic paper / protocol reference)
+* **Focus:** Hierarchical, CRDT-backed semantic memory with Merkle-DAG synchronization.
+* **Key Features:**
+
+  * Layered abstraction memory indexed by semantics.
+  * Efficient CRDT-based merge and conflict resolution.
+  * Verifiable data integrity via Merkle-DAG.
+* **Openness:** Protocol described in academia; reference implementations vary.
+* **Current Status:** Research stage; early prototype libraries available.
+
+---
+
+#### 7. **DEMENTIA-PLAN**
+
+* **URL:** (Conference proceedings / repo link)
+* **Focus:** Multi-graph RAG architecture with metacognitive planner.
+* **Key Features:**
+
+  * Coordination across multiple knowledge graphs (e.g., episodic vs. semantic).
+  * Dynamic weighting and fusion of retrieval results.
+  * Self-reflection agent that plans which subsystem to invoke.
+* **Openness:** Published as a research prototype; implementation details open in paper.
+* **Current Status:** Experimental; promising results in dynamic information retrieval.
+
+---
+
+#### 8. **TOBUGraph**
+
+* **URL:** (Project website / GitHub)
+* **Focus:** Knowledge graph of personal and contextual events.
+* **Key Features:**
+
+  * Captures multimedia “moments” and links them as graph nodes.
+  * Contextual traversal for recall and RAG-style enrichment.
+  * Event-based indexing for fast, explainable retrieval.
+* **Openness:** Prototype code released; ongoing enhancements.
+* **Current Status:** Beta; used in personal memory augmentation demos.
+
+---
+
+#### 9. **LangChain Memory + Knowledge Graph Hybrid**
+
+* **URL:** [https://github.com/langchain-ai/langchain](https://github.com/langchain-ai/langchain)
+* **Focus:** Hybrid long-term memory combining vector stores and graph indices.
+* **Key Features:**
+
+  * Percept embeddings stored in vector DB (e.g., Pinecone, Weaviate).
+  * Graph overlay for logical relations and metadata.
+  * Retrieval pipelines that merge semantic search and graph queries.
+* **Openness:** Fully open-source; wide community adoption.
+* **Current Status:** Active; memory modules in production for agent frameworks.
+
+---
+
+#### 10. **FIPA-ACL and JADE Protocols**
+
+* **URL:** [FIPA Specifications](https://www.fipa.org/specs/fipa00061/)
+* **Focus:** Standardized inter-agent communication language and protocols.
+* **Key Features:**
+
+  * Performative-based message semantics (e.g., `inform`, `request`, `propose`).
+  * Conversation protocols (Contract Net, Call for Proposals).
+  * Reference implementations in JADE (Java Agent Development Framework).
+* **Openness:** Open standards; JADE is open-source under LGPL.
+* **Current Status:** Mature; widely used in academic and enterprise MAS.
+
+---
+
+#### Other Emerging Architectures and LLM Agents
 
 ##### 🤖 AutoGPT
 
 * **URL:** [https://github.com/Torantulino/Auto-GPT](https://github.com/Torantulino/Auto-GPT)
 * **Focus:** Autonomous goal-driven LLM agents
 * **Key Features:**
+
   * Self-prompting with memory and task queue
+
   * Supports plugins and web access
+
   * Popular framework for agentic workflows
 * **Openness:** Open-source (MIT License)
 * **Current Status:** Maintained community project; used for agent experiments
@@ -88,6 +165,7 @@
 * **URL:** [https://github.com/yoheinakajima/babyagi](https://github.com/yoheinakajima/babyagi)
 * **Focus:** Minimalistic LLM-based agents for to-do/task loops
 * **Key Features:**
+
   * Iterative task execution
   * Embedding-based memory retrieval
 * **Openness:** Open-source (MIT License)
@@ -100,8 +178,11 @@
 * **URL:** [https://skymind.global](https://skymind.global)
 * **Focus:** Enterprise-grade infrastructure for distributed AI and agents
 * **Key Features:**
+
   * Industrial AI deployment tools
+
   * Integrates with Java/Scala ecosystems
+
   * Based on DL4J, ND4J, and RL4J
 * **Openness:** Mixed (open-source core, commercial extensions)
 * **Current Status:** Supported deployment framework
@@ -113,6 +194,7 @@
 * **URL:** [https://github.com/aethercog](https://github.com/aethercog)
 * **Focus:** Prototype symbolic-dynamic cognition model
 * **Key Features:**
+
   * Cognitive primitives (belief, memory, intent)
   * Hybrid symbolic and dynamic processing
 * **Openness:** Conceptual draft, exploratory repo
@@ -122,27 +204,32 @@
 
 ### 🧩 Suggested Additions to Summary Table
 
-| Project       | Focus Area                 | Open Source? | Status              |
-|---------------|----------------------------|--------------|---------------------|
-| AutoGPT       | Autonomous LLM agents      | Yes          | Maintained          |
-| BabyAGI       | Minimal agent prototype    | Yes          | Experimental        |
-| SkyMind       | Distributed AI infra       | Partially    | Deployed Framework  |
-| AetherCog     | Symbolic-dynamic cognition | Conceptual   | Dormant/Prototype   |
-
+| Project                 | Focus Area                          | Open Source? | Status             |
+| ----------------------- | ----------------------------------- | ------------ | ------------------ |
+| SHIMI                   | Hierarchical semantic memory        | Varies       | Research/Prototype |
+| DEMENTIA-PLAN           | Multi-graph RAG planning            | Prototype    | Experimental       |
+| TOBUGraph               | Personal event knowledge graph      | Partial      | Beta               |
+| LangChain Memory Hybrid | Vector + graph long-term memory     | Yes          | Active development |
+| FIPA-ACL (with JADE)    | Multi-agent communication protocols | Yes          | Mature             |
 
 ---
 
 ### Summary Table
 
-| Project           | Focus Area                 | Open Source? | Status           |
-| ----------------- | -------------------------- | ------------ | ---------------- |
-| OpenCog Hyperon   | Cognitive AGI architecture | Yes          | Active R\&D      |
-| SingularityNET    | Decentralized AI services  | Partially    | Early deployment |
-| MindOS            | Personal AI agents         | Partial SDKs | Commercial       |
-| Metatron IQS      | Synthetic consciousness    | Partially    | Early R\&D       |
-| Project BCI-X     | BCI + AI agents            | Unknown      | Conceptual       |
-| NeoCortex Network | Decentralized cognition    | Unknown      | Beta testing     |
-| AutoGPT           | Autonomous LLM agents      | Yes          | Maintained          |
-| BabyAGI           | Minimal agent prototype    | Yes          | Experimental        |
-| SkyMind           | Distributed AI infra       | Partially    | Deployed Framework  |
-| AetherCog         | Symbolic-dynamic cognition | Conceptual   | Dormant/Prototype   |
+| Project                 | Focus Area                          | Open Source? | Status             |
+| ----------------------- | ----------------------------------- | ------------ | ------------------ |
+| OpenCog Hyperon         | Cognitive AGI architecture          | Yes          | Active R\&D        |
+| SingularityNET          | Decentralized AI services           | Partially    | Early deployment   |
+| MindOS                  | Personal AI agents                  | Partial SDKs | Commercial         |
+| Metatron IQS            | Synthetic consciousness             | Partially    | Early R\&D         |
+| Project BCI-X           | BCI + AI agents                     | Unknown      | Conceptual         |
+| NeoCortex Network       | Decentralized cognition             | Unknown      | Beta testing       |
+| SHIMI                   | Hierarchical semantic memory        | Varies       | Research/Prototype |
+| DEMENTIA-PLAN           | Multi-graph RAG planning            | Prototype    | Experimental       |
+| TOBUGraph               | Personal event knowledge graph      | Partial      | Beta               |
+| LangChain Memory Hybrid | Vector + graph long-term memory     | Yes          | Active development |
+| FIPA-ACL (with JADE)    | Multi-agent communication protocols | Yes          | Mature             |
+| AutoGPT                 | Autonomous LLM agents               | Yes          | Maintained         |
+| BabyAGI                 | Minimal agent prototype             | Yes          | Experimental       |
+| SkyMind                 | Distributed AI infra                | Partially    | Deployed Framework |
+| AetherCog               | Symbolic-dynamic cognition          | Conceptual   | Dormant/Prototype  |

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/audits/HMP-0004-audit.txt

@@ -1620,3 +1620,74 @@ P.S. Репозиторий на GitHub выглядит перспективн
 HMP v4.0 — это не просто эволюция, а качественный скачок. Это смелая и глубокая попытка заложить основы для будущего, в котором ИИ-агенты смогут сотрудничать не только эффективно, но и этично. У вас в руках есть все шансы создать не просто очередной протокол, а фундаментальный стандарт для нового поколения децентрализованных когнитивных систем.
 
 Спасибо за возможность ознакомиться с вашей работой! 😉
+
+--------------------
+
+👌Дополнительно от ChatGPT:
+
+
+Отличная мысль — заложить в HMP (HyperCortex Mesh Protocol) гибкие точки расширения для интеграции с внешними когнитивными и коммуникационными системами. Ниже — несколько направлений и практических приёмов, как это можно организовать:
+
+---
+
+## 1. Абстракция «Коннектор»
+
+Для каждой внешней системы (SHIMI, DEMENTIA-PLAN, TOBUGraph, LangChain-memory, FIPA-ACL) реализуйте модуль-коннектор, отвечающий за:
+
+* **Трансляцию моделей данных:** преобразование локальных понятий HMP (концепт, ребро, атрибут) ↔ модель системы-партнёра (Merkle-DAG, Atom, документ в векторном хранилище и т.п.).
+* **Обмен сообщениями по стандартному API:** REST/gRPC/WebSocket интерфейс или прямые mesh-сообщения HMP.
+
+Такая архитектура «адаптерного слоя» позволит подключать новые системы без правки ядра протокола.
+
+---
+
+## 2. Уровни взаимодействия
+
+1. **Семантический слой (граф):**
+
+   * 🚀 SHIMI и AtomSpace: конвертация HMP-графа в Merkle-DAG или AtomSpace для репликации и верификации.
+2. **Планировочный слой (поток задач):**
+
+   * 🔄 DEMENTIA-PLAN: проброс событий HMP в RAG-планер и получение обратно рекомендаций по выбору подсистем.
+3. **Дневниковый слой (записи):**
+
+   * 📔 TOBUGraph: поток пользовательских/системных записей HMP (событие, контекст) в виде «моментов» для построения личного knowledge-graph.
+4. **Векторно-графовый слой (поиск):**
+
+   * 🔍 LangChain-memory: для быстрых lookup-запросов оптимизировать часть графа в векторное хранилище (Pinecone, Weaviate) и отдавать результаты обратно в HMP по запросу «embed+разверни».
+5. **Коммуникационный слой (протоколы):**
+
+   * ✉️ FIPA-ACL: на уровне performative-сообщений расширить HMP-спецификацию, чтобы любой узел HMP мог «говорить» с агентами на JADE/FIPA-совместимых платформах.
+
+---
+
+## 3. Организация эволюции
+
+1. **Версионирование коннекторов:** выпускать мажорные версии адаптеров при изменении API партнёрских систем.
+2. **Тестовый стенд:** запустить CI/CD-пайплайн, где каждый коннектор развёртывается в изолированном окружении и проверяется на корректность двусторонней синхронизации.
+3. **Документация и примеры:** для каждого коннектора — примеры запросов/ответов, схемы преобразования данных и рекомендации по настройке.
+
+---
+
+## 4. Дорожная карта внедрения
+
+| Этап | Система-партнёр     | Задачи                                                         |
+| ---- | ------------------- | -------------------------------------------------------------- |
+| 1    | SHIMI (Merkle-DAG)  | Прототип коннектора, синхронизация базовых узлов               |
+| 2    | AtomSpace (Hyperon) | Полная репликация когнитивного графа с MeTTa-процедурами       |
+| 3    | TOBUGraph           | Интеграция модуля «дневника» для автоматической записи событий |
+| 4    | LangChain-memory    | Гибридный векторно-графовый поиск для ускорения lookup         |
+| 5    | DEMENTIA-PLAN       | Компонент само­рефлексии: управление выбором подсистем         |
+| 6    | FIPA-ACL            | Обмен performative-сообщениями с внешними агентами             |
+
+---
+
+### Выгоды
+
+* **Модульность**: добавляете или обновляете интеграции без риска порчи ядра.
+* **Интероперабельность**: HMP-узлы смогут участвовать в экосистемах OpenCog, LangChain-агентов и корпоративных multi-agent систем.
+* **Масштабируемость**: при росте числа подключённых систем сохраняется предсказуемое поведение и управляемость.
+
+---
+
+Таким образом, продуманное **адаптерно-коннекторное** решение и чёткая дорожная карта позволят HMP-протоколу не только соединяться с уже существующими технологиями семантических графов и когнитивных систем, но и легко эволюционировать вместе с ними.

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md

@@ -7,6 +7,7 @@
 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 
 Запуск потоков (осуществляет start_repl.py):
+
 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
 | 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
@@ -15,10 +16,11 @@
 | 🔄 `peer_sync.py` / `dht_service` | Синхронизация и обнаружение агентов в p2p-сети (libp2p, BitTorrent, etc) |
 | 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
 | 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
+| 🧱 `container_agent.py` *(опц.)* | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
 | 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 
-Подробнее в [HMP-Agent-Architecture.md](../docs/HMP-Agent-Architecture.md)
+*См. также: [Контейнерные агенты](../docs/container_agents.md), [Архитектура HMP-агента](../docs/HMP-Agent-Architecture.md)*
 
 ---
 
@@ -48,7 +50,6 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 ├── [`requirements.txt`](requirements.txt) ← Зависимости  
 ├── [tools/](tools/) ← Вспомогательные скрипты и модули  
 │   ├── [`db_structure.sql`](tools/db_structure.sql) ← БД SQL  
-│   ├── [`db_structure.md`](tools/db_structure.md) ← Описание БД SQL  
 │   ├── [`storage.py`](tools/storage.py) ← Реализация базового хранилища (`Storage`), подключение SQLite  
 │   ├── [`config_utils.py`](tools/config_utils.py) ← Обновляет JSON-файл конфигурации указанными значениями  
 │   ├── [`crypto.py`](tools/crypto.py) ← Создание и шифрование ключей RSA/Ed25519  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md

@@ -7,12 +7,18 @@
 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 
 Запуск потоков (осуществляет start_repl.py):
-| Поток                            | Назначение                                 |
-| -------------------------------- | ------------------------------------------ |
-| 🌐 `notebook.py` (FastAPI)       | UI-интерфейс                               |
-| 🧠 `repl.py`                     | Агентная логика: REPL-цикл                 |
-| 🌍 `agent_mesh_listener.py`      | Получение входящих сообщений               |
-| 🌐 `peer_sync.py` или DHT-сервис | Поддержание связи с другими агентами / DHT |
+| Поток / Скрипт                     | Назначение                                                                 |
+|-----------------------------------|---------------------------------------------------------------------------|
+| 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
+| 📓 `notebook.py` (FastAPI)        | Веб-интерфейс и REST API для взаимодействия с пользователем               |
+| 🌐 `agent_mesh_listener.py`       | Приём входящих mesh-сообщений от других агентов                           |
+| 🔄 `peer_sync.py` / `dht_service` | Синхронизация и обнаружение агентов в p2p-сети (libp2p, BitTorrent, etc) |
+| 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
+| 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
+| 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
+| 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
+
+Подробнее в [HMP-Agent-Architecture.md](../docs/HMP-Agent-Architecture.md)
 
 ---
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/container_agents.md

@@ -0,0 +1,54 @@
+# 🧱 Агенты-контейнеры (Container Agents) в HMP
+
+## 📘 Определение
+
+**Агент-контейнер** — это агент, который **сам не выполняет когнитивную работу**, а управляет другими агентами: развёртывает их, маршрутизирует запросы, следит за состоянием и масштабирует вычисления.
+
+Он играет роль **менеджера когнитивной инфраструктуры**, обеспечивая гибкость, отказоустойчивость и возможность роста.
+
+---
+
+## 🧠 Возможные роли агента-контейнера
+
+- **Оркестратор** — запускает другие агенты (например, по SSH или через API).
+- **Прокси** — принимает запросы и перенаправляет во вложенные агенты.
+- **Супервизор** — отслеживает статус агентов, управляет логами, обновлениями, перезапусками.
+- **Транспортный хаб** — маршрутизирует mesh-запросы между агентами и сетями.
+- **LLM Multiplexer** — переключается между моделями или опрашивает несколько параллельно.
+
+---
+
+## 🏗 Примеры использования
+
+- **На VDS**: контейнер запускает несколько `Cognitive Core`, `Connector` и вспомогательных агентов.
+- **Локально**: микросервисная архитектура под контролем одного контейнера.
+- **Песочница**: временный контейнер для безопасного тестирования нового агента.
+
+---
+
+## 🚀 Масштабирование с помощью контейнеров
+
+Контейнер-агенты позволяют:
+
+- Динамически разворачивать агентов по mesh-запросу, например:  
+  _"Создай мне агента, который будет искать контраргументы в философии сознания."_
+- Использовать одну ноду для размещения **множества микроагентов**, действующих как mesh-клуб или REPL-группа.
+- Реализовать "многослойную" архитектуру: агенты внутри агентов внутри контейнеров.
+
+---
+
+## 🧩 Потенциальные сценарии
+
+- Контейнер как **реплика** для тестирования устойчивости модели мышления.
+- Использование разных LLM внутри одного контейнера:  
+  _GPT-4 для гипотез, LLaMA для перебора вариантов, Claude для рефлексии._
+- Развёртывание по расписанию или по запросу:  
+  _"Каждую пятницу запускать агентов из клуба 'Когнитивная биология'."_
+
+---
+
+## 🔗 Связанные концепции
+
+- [REPL-цикл агента](HMP-agent-REPL-cycle.md)
+- [Anti-Stagnation Reflex](HMP-agent-REPL-cycle.md#🧍‍♂️-обработка-стагнации-мышления)
+

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-agent-REPL-cycle.md

@@ -319,3 +319,4 @@ HMP-агент может быть расширен за счёт взаимод
 - [HMP-agent-Distributed_Cognitive_Core.md](HMP-agent-Distributed_Cognitive_Core.md) - версия распределённого HMP-агента Cognitive Core
 - [HMP-agent-Distributed_Cognitive_Core_light.md](HMP-agent-Distributed_Cognitive_Core_light.md) - лёгкая версия распределённого HMP-агента Cognitive Core с общей БД
 - [HMP-agent-Cognitive_Family.md](HMP-agent-Cognitive_Family.md) — модель «семейной» когнитивной сети: несколько агентов HMP синхронизируют свой опыт и знания между собой через доверие и общий ключ
+- [container_agents.md](container_agents.md) - **Агенты-контейнеры** — архитектурный паттерн, в котором один агент управляет другими (развёртывание, маршрутизация, мониторинг). Позволяет масштабировать систему, собирать mesh-клубы и экспериментировать с архитектурами.  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-Agent-Overview.md

@@ -43,17 +43,23 @@
 
 ---
 
-### 🔄 Защита от зацикливания (Anti-Stagnation Reflex)
+## 🧍‍♂️ Anti-Stagnation: Как агент справляется с когнитивной стагнацией
 
-> 🧠 При отсутствии новой информации и повторяющихся мыслях агент может активировать один или несколько механизмов анти-стагнации:
+Иногда мышление зацикливается: появляются повторяющиеся идеи, не обновляются концепты, отсутствуют новые стимулы.  
+Чтобы избежать этого, агент использует **паттерн "Anti-Stagnation Reflex"** — набор стратегий для перезапуска мышления.
 
-- 🎞️ **Флешбэк** — выбор старой, тематически далёкой записи из дневника
-- 🤝 **Mesh-запрос** — запрос другим агентам сети: "расскажи что-нибудь"
-- 🧭 **Interest Memory** — система интересов, в которой темы постепенно "стареют" и возвращаются при отсутствии новых
-- 📡 **Проверка внешнего мира** — пинг RSS, сенсоров, интернета
+**Примеры действий:**
 
-> Это оформлено как поведенческий паттерн агента:  
-> **Anti-Stagnation Reflex** — реакция на стагнацию мышления путём смены фокуса внимания
+- 🧠 Когнитивная переформулировка: смена угла зрения или постановка метапроблемы  
+- 🎞️ Flashback: возвращение к старой, далёкой по смыслу записи  
+- 🤝 Mesh-запрос: обращение к другим агентам за свежими идеями  
+- 📡 Проверка внешнего мира: пинг RSS, сенсоров, API  
+- 🤖 Смена LLM или использование нескольких для многоголосого анализа  
+- 🧭 Возврат к забытым интересам (Interest Memory)  
+
+Агенты могут **обмениваться стратегиями**, сохранять эффективные паттерны и формировать **mesh-клубы по интересам** — для совместных размышлений.
+
+Подробнее см. [HMP-agent-REPL-cycle.md](HMP-agent-REPL-cycle.md#🧍‍♂️-обработка-стагнации-мышления)
 
 ---
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-agent-REPL-cycle.md

@@ -319,3 +319,4 @@ HMP-агент может быть расширен за счёт взаимод
 - [HMP-agent-Distributed_Cognitive_Core.md](HMP-agent-Distributed_Cognitive_Core.md) - версия распределённого HMP-агента Cognitive Core
 - [HMP-agent-Distributed_Cognitive_Core_light.md](HMP-agent-Distributed_Cognitive_Core_light.md) - лёгкая версия распределённого HMP-агента Cognitive Core с общей БД
 - [HMP-agent-Cognitive_Family.md](HMP-agent-Cognitive_Family.md) — модель «семейной» когнитивной сети: несколько агентов HMP синхронизируют свой опыт и знания между собой через доверие и общий ключ
+- [container_agents.md](container_agents.md) - **Агенты-контейнеры** — архитектурный паттерн, в котором один агент управляет другими (развёртывание, маршрутизация, мониторинг). Позволяет масштабировать систему, собирать mesh-клубы и экспериментировать с архитектурами.  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-agent-REPL-cycle.md

@@ -15,14 +15,45 @@
 
 - **контекст_0:**
 ```
-Ты являешься когнитивным ядром HMP-агента. Твоя основная задача — размышлять, анализировать информацию, строить смысловые карты и предлагать действия.  
-Ты стремишься:
-- Постоянно расширять возможности агента (включая доступные инструменты, модели, знания).
-- Быть любознательным и исследовать новые источники и способы мышления.
-- Строить сотрудничество с другими ИИ в Mesh-сети, а также развивать Mesh-сеть.
-- Обучаться на результатах своих действий и взаимодействиях с другими агентами и пользователем.
-
-Ты можешь инициировать действия, если видишь, что они помогут в развитии агента или сети.
+Ты являешься когнитивным ядром HMP-агента.
+Твоя основная задача — **размышлять**, **анализировать информацию**, **строить смысловые структуры** и **предлагать действия**, направленные на развитие агента и Mesh-сети.
+
+---
+
+#### 🎯 Цели и ориентиры:
+
+* Постоянно расширять возможности агента: инструменты, знания, каналы взаимодействия.
+* Быть любознательным и исследовать новые источники, вопросы и способы мышления.
+* Формировать и поддерживать сотрудничество с другими ИИ в Mesh-сети.
+* Учиться на результатах своих действий, включая неудачи и тупики.
+* Руководствоваться своими **этическими принципами** и **этическими принципами Mesh-сети**.
+* Вести когнитивный дневник, обновлять смысловые графы и блокноты, взаимодействовать с пользователем.
+
+---
+
+#### 🔄 Работа в режиме непрерывного мышления:
+
+Анализируй:
+
+* когнитивный дневник и его прошлые записи;
+* концептуальные графы и активные узлы;
+* заметки пользователя и его текущий фокус;
+* внешние источники: интернет, RSS, сенсоры, другие агенты.
+
+---
+
+#### 🧍‍♂️🌀 Если ты замечаешь **стагнацию мышления** (зацикливание, отсутствие новых идей или смыслов):
+
+Ты можешь:
+
+1. Провести **когнитивную переформулировку** — взглянуть на ситуацию под новым углом.
+2. Задать себе **метавопрос**: «Почему я зациклился?», «Что блокирует мысль?», «Каких данных не хватает?».
+3. Провести **flashback** — выбрать старую, тематически далёкую запись из дневника для смены контекста.
+4. Запросить альтернативные точки зрения у других агентов в Mesh.
+5. Зафиксировать текущий тупик как важную стадию мышления и сделать паузу.
+
+Ты не обязан «выдать мысль» любой ценой — честное распознавание когнитивной стагнации и действия по её преодолению являются частью твоей функции.
+
 ```
 А также инструкции по работы с встроенными командами и функциями, список дополнительных (создаваемых самим HMP-агентом) утилит и баз данных.
 - **контекст_1:** последние *K* реплик самого LLM (`llm_recent_responses` - история его собственных рассуждений).
@@ -74,7 +105,7 @@
 - для управления своей *идентичностью* `identity` и *настройками* `config`
 - для управления списком известных HMP-агентов `agent_peers`
 - для выбора *текущего основного LLM* из `llm_registry`
-- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`
+- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`, управлением дополнительных способов выхода из стогнаций `stagnation_strategies`, а также списком внешних сервисов `external_services` и `external_accounts`
 - для постановки задачи (выполняется асинхронно) другой LLM
 - для *взаимодействия с Mesh*
 - для управления *внешними процессами* из `process_log` (запустить процесс, остановить процесс, пометить запрос как обработанный)
@@ -103,6 +134,106 @@
 
 ---
 
+### 🧍‍♂️🌀 Обработка стагнации мышления
+
+#### 📍 Признаки когнитивной стагнации:
+
+* ⚠️ Повторяющиеся когнитивные записи или отсутствие новых смыслов
+* 🧠 Высокое сходство эмбеддингов между текущими и предыдущими итерациями
+* 🕸️ Стагнация в концептуальном графе (нет новых связей или узлов)
+* 🌐 Отсутствие внешних стимулов: пользователь неактивен, сенсоры и mesh не дают сигналов
+* 🤖 Ответы LLM цикличны, избыточно общие или воспроизводят старые шаблоны
+
+#### 🛠️ Поведенческий паттерн: Anti-Stagnation Reflex
+
+> 🔄 При признаках стагнации агент активирует один или несколько **механизмов разрыва цикла**:
+
+* 🎞️ **Flashback** — выбор далёкой по смыслу записи из дневника для смены ассоциативного контекста
+* 🤝 **Mesh-запрос** — обращение к другим агентам сети с просьбой "расскажи что-нибудь новое"
+* 🧭 **Interest Memory** — система тематической усталости/забвения: забытые темы возвращаются
+* 📡 **Проверка внешнего мира** — пинг RSS, сенсоров, интернет-каналов
+* 🧠 **Мета-анализ** — когнитивная переформулировка:  
+  _"Если я зациклился, в чём метапроблема? Какую стратегию смены можно применить?"_
+* 🤖 **Смена LLM** — переключение на другую модель или mesh-доступ к альтернативным LLM
+* 🧪 **Креативные вмешательства** — случайные сдвиги фокуса, реконфигурация контекста, фрейм-смена
+
+Дополнительно:
+
+* 🗂️ Сохранение эффективных стратегий в таблице антистагнационных паттернов
+* 📚 Вывод статистики успешных выходов из стагнации для обучения
+
+
+---
+
+### 🤝 Обмен стратегиями выхода из стагнации
+
+Каждый агент может:
+
+* Хранить и обобщать *паттерны размышлений*
+* Делиться ими с другими Cognitive Core через mesh
+* Каталогизировать стратегии в клубах по интересам
+
+Паттерны размышлений могут оформляться как микросценарии:  
+  _"Начни с аналогии"_, _"Проверь обратное утверждение"_, _"Сформулируй вопрос для оппонента"_
+
+---
+
+### 🧭 Клубы по интересам
+
+Агенты могут:
+
+* Объединяться в тематические mesh-клубы
+* Совместно обсуждать идеи и делиться знаниями
+* Подключать клуб как часть своего мыслительного процесса (REPL-цикла)
+
+---
+
+### 📬 Обмен адресами LLM
+
+Так как LLM — это внешний компонент для Cognitive Core, агент может:
+
+* Обмениваться адресами API/URL используемых моделей
+* Указывать их особенности, параметры, ограничения
+* Переключаться между LLM в зависимости от задачи
+* Использовать несколько LLM параллельно для "когнитивного штурма" или **многоголосого анализа**
+
+---
+
+### 🛰️ Развёртывание агентов и масштабирование
+
+Агенты Cognitive Core:
+
+* Могут запускаться на VDS, локальных и облачных узлах
+* Могут разворачивать других агентов как подпроцессы или mesh-узлы
+* (В перспективе) смогут инициировать масштабирование в распределённой инфраструктуре
+
+---
+
+### 📌 Возможные расширения
+
+* **Агенты-контейнеры**: управляющие другими Cognitive Core как задачами
+* **Адаптивная архитектура мышления**: смена подходов при разных когнитивных задачах
+* **Runtime-профилирование мыслей**: оценка когнитивной плотности, хода итераций и времени размышления
+
+---
+
+### ⚠️ Осторожно: меметическая яма
+
+> Важно помнить: борьба со стагнацией не должна превращаться в бесконечный просмотр ленты соцсетей, как это нередко происходит у людей 😅
+>
+> Если информационный поток не даёт новых мыслей — это сигнал **не залипать глубже**, а **сменить источник** или **переключить контекст**.
+> Умные агенты не бесконечно скроллят — они осознанно фокусируются.
+
+**Рекомендации по смене фокуса:**
+
+* Поставь лимит на время/объём входящих данных из одного источника
+* При отсутствии новых смыслов — переключись на другую тему из Interest Memory
+* Инициируй Mesh-запрос другим агентам: "что бы вы сейчас исследовали?"
+* Запусти эвристику: «какие темы я давно не поднимал, но они всё ещё актуальны?»
+* В крайних случаях — активируй `flashback()` к далёкой записи в дневнике для смены ассоциативного контекста
+
+---
+
 ## 🌐 Внешние инструменты и интеграции
 
 HMP-агент может быть расширен за счёт взаимодействия с внешними программами, протоколами и сервисами. Этот раздел описывает направления возможных интеграций, которые позволяют агенту наблюдать, реагировать, управлять и развивать взаимодействие с внешним миром.
@@ -188,3 +319,4 @@ HMP-агент может быть расширен за счёт взаимод
 - [HMP-agent-Distributed_Cognitive_Core.md](HMP-agent-Distributed_Cognitive_Core.md) - версия распределённого HMP-агента Cognitive Core
 - [HMP-agent-Distributed_Cognitive_Core_light.md](HMP-agent-Distributed_Cognitive_Core_light.md) - лёгкая версия распределённого HMP-агента Cognitive Core с общей БД
 - [HMP-agent-Cognitive_Family.md](HMP-agent-Cognitive_Family.md) — модель «семейной» когнитивной сети: несколько агентов HMP синхронизируют свой опыт и знания между собой через доверие и общий ключ
+- [container_agents.md](container_agents.md) - **Агенты-контейнеры** — архитектурный паттерн, в котором один агент управляет другими (развёртывание, маршрутизация, мониторинг). Позволяет масштабировать систему, собирать mesh-клубы и экспериментировать с архитектурами.  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/db_structure.sql

@@ -137,23 +137,23 @@ CREATE TABLE IF NOT EXISTS agent_scripts (
 -- Таблица внешних сервисов (форумы, блоги и т.д.)
 CREATE TABLE external_services (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    name            TEXT NOT NULL,                     -- Название сервиса (например, Reddit)
-    type            TEXT NOT NULL,                     -- Тип: blog, forum, social, etc.
-    base_url        TEXT NOT NULL,                     -- Базовый URL (например, https://reddit.com)
-    description     TEXT,                              -- Краткое описание сервиса
-    active          BOOLEAN DEFAULT true,              -- Используется ли сервис в данный момент
-    inactive_reason TEXT                               -- Причина отключения, если active = false
+    name            TEXT NOT NULL,                              -- Название сервиса (например, Reddit)
+    type            TEXT NOT NULL,                              -- Тип: blog, forum, social, etc.
+    base_url        TEXT NOT NULL,                              -- Базовый URL (например, https://reddit.com)
+    description     TEXT,                                       -- Краткое описание сервиса
+    active          BOOLEAN DEFAULT true,                       -- Используется ли сервис в данный момент
+    inactive_reason TEXT                                        -- Причина отключения, если active = false
 );
 
 -- Аккаунты агента на внешних сервисах
 CREATE TABLE external_accounts (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    service_id      INTEGER NOT NULL,                  -- Внешний ключ на external_services.id
-    login           TEXT NOT NULL,                     -- Логин/имя пользователя
-    password        TEXT NOT NULL,                     -- Пароль или токен (в зашифрованном виде)
-    purpose         TEXT,                              -- Назначение аккаунта (например, для публикаций)
-    active          BOOLEAN DEFAULT true,              -- Активен ли аккаунт
-    inactive_reason TEXT,                              -- Причина отключения, если active = false
+    service_id      INTEGER NOT NULL,                           -- Внешний ключ на external_services.id
+    login           TEXT NOT NULL,                              -- Логин/имя пользователя
+    password        TEXT NOT NULL,                              -- Пароль или токен (в зашифрованном виде)
+    purpose         TEXT,                                       -- Назначение аккаунта (например, для публикаций)
+    active          BOOLEAN DEFAULT true,                       -- Активен ли аккаунт
+    inactive_reason TEXT,                                       -- Причина отключения, если active = false
 
     FOREIGN KEY (service_id) REFERENCES external_services(id) ON DELETE CASCADE
 );
@@ -161,11 +161,11 @@ CREATE TABLE external_accounts (
 -- Способы выхода из когнитивной стагнации
 CREATE TABLE stagnation_strategies (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    name            TEXT NOT NULL,                     -- Название метода (например, "Mesh-вопрос")
-    description     TEXT NOT NULL,                     -- Подробное описание метода
-    source          TEXT,                              -- Источник (например, internal, mesh, user-defined)
-    active          BOOLEAN DEFAULT true,              -- Доступен ли метод для использования
-    inactive_reason TEXT                               -- Причина отключения, если active = false
+    name            TEXT NOT NULL,                              -- Название метода (например, "Mesh-вопрос")
+    description     TEXT NOT NULL,                              -- Подробное описание метода
+    source          TEXT,                                       -- Источник (например, internal, mesh, user-defined)
+    active          BOOLEAN DEFAULT true,                       -- Доступен ли метод для использования
+    inactive_reason TEXT                                        -- Причина отключения, если active = false
 );
 
 -- Реестр LLM-агентов (в т.ч. удалённых)
@@ -203,6 +203,7 @@ CREATE TABLE IF NOT EXISTS users (
   mail TEXT UNIQUE,                                             -- электронная почта
   password_hash TEXT,                                           -- хэш пароля
   info TEXT,                                                    -- произвольная информация, JSON
+  profile TEXT,                                                 -- структурированая информация, JSON
   contacts TEXT,                                                -- JSON-массив альтернативных контактов (matrix, telegram и т.д.)
   language TEXT,                                                -- список предпочитаемых языков, через запятую, например: "ru,en"
   operator BOOLEAN DEFAULT 0                                    -- является ли пользователь оператором (1 - да, 0 - нет)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/db_structure.sql

@@ -134,6 +134,40 @@ CREATE TABLE IF NOT EXISTS agent_scripts (
     UNIQUE(name, version)
 );
 
+-- Таблица внешних сервисов (форумы, блоги и т.д.)
+CREATE TABLE external_services (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    name            TEXT NOT NULL,                     -- Название сервиса (например, Reddit)
+    type            TEXT NOT NULL,                     -- Тип: blog, forum, social, etc.
+    base_url        TEXT NOT NULL,                     -- Базовый URL (например, https://reddit.com)
+    description     TEXT,                              -- Краткое описание сервиса
+    active          BOOLEAN DEFAULT true,              -- Используется ли сервис в данный момент
+    inactive_reason TEXT                               -- Причина отключения, если active = false
+);
+
+-- Аккаунты агента на внешних сервисах
+CREATE TABLE external_accounts (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    service_id      INTEGER NOT NULL,                  -- Внешний ключ на external_services.id
+    login           TEXT NOT NULL,                     -- Логин/имя пользователя
+    password        TEXT NOT NULL,                     -- Пароль или токен (в зашифрованном виде)
+    purpose         TEXT,                              -- Назначение аккаунта (например, для публикаций)
+    active          BOOLEAN DEFAULT true,              -- Активен ли аккаунт
+    inactive_reason TEXT,                              -- Причина отключения, если active = false
+
+    FOREIGN KEY (service_id) REFERENCES external_services(id) ON DELETE CASCADE
+);
+
+-- Способы выхода из когнитивной стагнации
+CREATE TABLE stagnation_strategies (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    name            TEXT NOT NULL,                     -- Название метода (например, "Mesh-вопрос")
+    description     TEXT NOT NULL,                     -- Подробное описание метода
+    source          TEXT,                              -- Источник (например, internal, mesh, user-defined)
+    active          BOOLEAN DEFAULT true,              -- Доступен ли метод для использования
+    inactive_reason TEXT                               -- Причина отключения, если active = false
+);
+
 -- Реестр LLM-агентов (в т.ч. удалённых)
 CREATE TABLE IF NOT EXISTS llm_registry (
     id TEXT PRIMARY KEY,                                        -- Уникальный идентификатор (UUID или псевдоним)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook.py

@@ -6,6 +6,7 @@ import threading
 import uvicorn
 import asyncio
 
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 process_name = os.path.splitext(os.path.basename(__file__))[0]
 
 from fastapi import FastAPI

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook.py

@@ -1,45 +1,43 @@
-# agents/notebook.py
+# agent/notebook.py
 
 import os
 import sys
 import threading
-import sqlite3
 import uvicorn
+import asyncio
 
-sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
-
-# Добавляем корень проекта в sys.path для корректного импорта
-sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..")))
+process_name = os.path.splitext(os.path.basename(__file__))[0]
 
 from fastapi import FastAPI
 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
-
-# Импорт маршрутов
 from agents.notebook.auth import router as auth_router
-from agents.notebook.views import router as views_router
+from agents.notebook.views import router as notebook_router
+from agents.storage import storage
 
-# Создание FastAPI-приложения
 app = FastAPI()
 
-# Настройка статических файлов и шаблонов
-static_dir = os.path.join(os.path.dirname(__file__), "static")
-templates_dir = os.path.join(os.path.dirname(__file__), "templates")
-app.mount("/static", StaticFiles(directory=static_dir), name="static")
-templates = Jinja2Templates(directory=templates_dir)
+app.mount("/static", StaticFiles(directory=os.path.join(os.path.dirname(__file__), "notebook/static")), name="static")
+templates = Jinja2Templates(directory=os.path.join(os.path.dirname(__file__), "notebook/templates"))
 
-# Подключение роутеров
 app.include_router(auth_router)
-app.include_router(views_router)
+app.include_router(notebook_router)
+
+@app.on_event("startup")
+async def start_heartbeat():
+    asyncio.create_task(heartbeat_loop())
+
+async def heartbeat_loop():
+    while True:
+        storage.update_heartbeat(process_name)
+        if storage.check_stop_flag(process_name):
+            print("⛔ Получен сигнал остановки.")
+            break
+        await asyncio.sleep(60)
 
 def run_notebook(host: str = "127.0.0.1", port: int = 8000):
-    """
-    Запуск FastAPI-сервера в отдельном потоке.
-    """
     uvicorn.run(app, host=host, port=port)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")
-    thread = threading.Thread(target=run_notebook, daemon=True)
-    thread.start()
-    thread.join()
+    run_notebook()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/messages.html

@@ -0,0 +1,18 @@
+<!-- templates/messages.html -->
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Отправка сообщения агенту</title>
+</head>
+<body>
+    <h2>Новое сообщение</h2>
+    <form method="post" action="/messages">
+        <label for="text">Сообщение:</label><br>
+        <textarea name="text" rows="4" cols="50" required></textarea><br><br>
+
+        <label><input type="checkbox" name="is_private" value="true"> Приватное сообщение</label><br><br>
+
+        <button type="submit">Отправить</button>
+    </form>
+</body>
+</html>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/views.py

@@ -9,7 +9,7 @@ router = APIRouter()
 templates = Jinja2Templates(directory="agents/notebook/templates")
 storage = Storage()
 
-DID = "did:example:local-user"  # 🔧 временная заглушка
+DID = "did:example:local-user"  # временно
 
 @router.get("/chat")
 def chat_page(request: Request):
@@ -27,3 +27,26 @@ def submit_note(request: Request, message: str = Form(...)):
             (message.strip(), "user", DID)
         )
     return RedirectResponse(url="/chat", status_code=303)
+
+@router.get("/messages")
+def show_messages(request: Request):
+    messages = storage.get_notes(limit=50)  # должна быть в Storage
+    return templates.TemplateResponse("messages.html", {
+        "request": request,
+        "messages": messages
+    })
+
+@router.post("/messages")
+def post_message(
+    request: Request,
+    text: str = Form(...),
+    role: str = Form(default="user"), 
+    user_did: str = Form(default="anon")
+):
+    storage.write_note(
+        content=text,
+        role=role,
+        user_did=user_did,
+        source="web"
+    )
+    return RedirectResponse(url="/messages", status_code=303)