GitHub Action commited on Aug 6

Commit

5782aa4

1 Parent(s): fa98d7a

Sync from GitHub with Git LFS

Browse files

This view is limited to 50 files because it contains too many changes. See raw diff

Files changed (50) hide show

agents/notebook/templates/login.html +14 -0
agents/notebook/templates/messages.html +40 -8
agents/notebook/templates/register.html +14 -0
agents/notebook/views.py +72 -11
agents/requirements.txt +2 -1
agents/tools/storage.py +76 -11
agents/web_ui.py +3 -0
hf_repo/hf_repo/agents/add_message.py +5 -9
hf_repo/hf_repo/agents/notebook/views.py +3 -5
hf_repo/hf_repo/agents/tools/db_structure.sql +1 -1
hf_repo/hf_repo/agents/tools/storage.py +5 -5
hf_repo/hf_repo/hf_repo/agents/readme.md +1 -1
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md +1 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/config.yml +65 -40
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.py +19 -5
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/config.yml +40 -71
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/examples/config.yml +1 -7
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/init.py +17 -26
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/logger.py +3 -3
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/mcp_server.py +2 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/repl.py +2 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/context_builder.py +2 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/identity.py +3 -3
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/memory_utils.py +3 -3
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py +11 -10
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py +1 -2
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 +4 -0
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py +7 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py +5 -3
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/check_agents.bat +12 -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/agents/check_agents.sh +11 -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/agents/tools/check_agents.bat +12 -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/agents/check_agents.py +29 -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/agents/readme.md +6 -3
hf_repo/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/start_repl.py +56 -32
hf_repo/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/storage.py +13 -1
hf_repo/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/web_ui.py +2 -1
hf_repo/hf_repo/hf_repo/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/__init__.py +0 -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/agents/repl.py +1 -1
hf_repo/hf_repo/hf_repo/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 +3 -3
hf_repo/hf_repo/hf_repo/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/web_ui.py +45 -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/agents/start_repl.py +34 -13
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 -1
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +3 -3
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +10 -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/README.md +15 -9
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +109 -22
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +71 -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/agents/readme.md +3 -2
hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +12 -6

agents/notebook/templates/login.html ADDED Viewed

	@@ -0,0 +1,14 @@

+<!DOCTYPE html>
+<html>
+<head><title>Вход</title></head>
+<body>
+  <h2>Вход</h2>
+  {% if error %}<p style="color: red">{{ error }}</p>{% endif %}
+  <form method="post">
+    <input name="username" placeholder="Имя пользователя">
+    <input name="password" type="password" placeholder="Пароль">
+    <button type="submit">Войти</button>
+  </form>
+  <p>Нет аккаунта? <a href="/register">Регистрация</a></p>
+</body>
+</html>

agents/notebook/templates/messages.html CHANGED Viewed

@@ -1,18 +1,50 @@
-<!-- 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>

 <!DOCTYPE html>
 <html>
 <head>
+    <title>Сообщения</title>
+    <style>
+        .message { padding: 8px; margin: 10px 0; border-radius: 8px; }
+        .source-user { background-color: #e0f7fa; }
+        .source-cli { background-color: #dcedc8; }
+        .source-llm { background-color: #f3e5f5; }
+        .source-system { background-color: #fff3e0; }
+        .private::after { content: " 🔒"; }
+        .from-self::before { content: "🧍 "; }
+    </style>
 </head>
 <body>
+    <div style="margin-bottom: 10px;">
+        {% if username %}
+            Привет, {{ username }} | <a href="/logout">Выход</a>
+        {% else %}
+            <a href="/login">Войти</a> | <a href="/register">Регистрация</a>
+        {% endif %}
+    </div>
+    <h1>Сообщения</h1>
+    <form method="post">
+        <textarea name="text" rows="3" cols="40" placeholder="Введите сообщение..."></textarea><br>
+        <input type="text" name="user_did" placeholder="User DID" readonly value="{ user_did }">
         <button type="submit">Отправить</button>
     </form>
+    <hr>
+    <div>
+        <a href="/messages">📢 Все сообщения</a> |
+        <a href="/messages?only_personal=true">🙋 Только мои</a>
+    </div>
+    <hr>
+    {% for msg in messages %}
+        <div class="message source-{{ msg.source }} {% if msg.user_did == 'did:example:local-user' %}from-self{% endif %}">
+            <div>
+                <strong>{{ msg.source }}</strong> — {{ msg.timestamp }}
+                {% if msg.hidden %}<span class="private"></span>{% endif %}
+            </div>
+            <div>{{ msg.text }}</div>
+        </div>
+    {% endfor %}
 </body>
 </html>

agents/notebook/templates/register.html ADDED Viewed

	@@ -0,0 +1,14 @@

+<!DOCTYPE html>
+<html>
+<head><title>Регистрация</title></head>
+<body>
+  <h2>Регистрация</h2>
+  {% if error %}<p style="color: red">{{ error }}</p>{% endif %}
+  <form method="post">
+    <input name="username" placeholder="Имя пользователя">
+    <input name="password" type="password" placeholder="Пароль">
+    <button type="submit">Зарегистрироваться</button>
+  </form>
+  <p>Уже есть аккаунт? <a href="/login">Войти</a></p>
+</body>
+</html>

agents/notebook/views.py CHANGED Viewed

@@ -1,50 +1,111 @@
 # agents/notebook/views.py
-from fastapi import APIRouter, Request, Form
 from fastapi.responses import RedirectResponse
 from fastapi.templating import Jinja2Templates
 from tools.storage import Storage
 router = APIRouter()
 templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
-DID = "did:example:local-user"  # временно
 @router.get("/chat")
 def chat_page(request: Request):
     notes = storage.fetchall(
         "SELECT text, timestamp, source FROM notes WHERE hidden=0 AND user_did=? ORDER BY timestamp DESC LIMIT 20",
-        (DID,)
     )
-    return templates.TemplateResponse("chat.html", {"request": request, "notes": notes})
 @router.post("/chat")
 def submit_note(request: Request, message: str = Form(...)):
     if message.strip():
         storage.execute(
             "INSERT INTO notes (text, source, user_did) VALUES (?, ?, ?)",
-            (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)
     return templates.TemplateResponse("messages.html", {
         "request": request,
-        "messages": messages
     })
 @router.post("/messages")
 def post_message(
     request: Request,
     text: str = Form(...),
-    user_did: str = Form(default="anon")
 ):
     storage.write_note(
         content=text,
         user_did=user_did,
-        source="user"
     )
     return RedirectResponse(url="/messages", status_code=303)

 # agents/notebook/views.py
+from fastapi import APIRouter, Request, Form, Depends
 from fastapi.responses import RedirectResponse
 from fastapi.templating import Jinja2Templates
+from fastapi.exceptions import HTTPException
+from starlette.middleware.sessions import SessionMiddleware
+from starlette.status import HTTP_303_SEE_OTHER
 from tools.storage import Storage
+from passlib.hash import bcrypt
+from fastapi import FastAPI
 router = APIRouter()
 templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
 @router.get("/chat")
 def chat_page(request: Request):
+    username = request.session.get("user")
+    if not username:
+        return RedirectResponse("/login", status_code=303)
     notes = storage.fetchall(
         "SELECT text, timestamp, source FROM notes WHERE hidden=0 AND user_did=? ORDER BY timestamp DESC LIMIT 20",
+        (username,)
     )
+    return templates.TemplateResponse("chat.html", {
+        "request": request,
+        "notes": notes,
+        "username": username
+    })
 @router.post("/chat")
 def submit_note(request: Request, message: str = Form(...)):
+    username = request.session.get("user", "anon")  # Можно вернуть anon, если не залогинен
     if message.strip():
         storage.execute(
             "INSERT INTO notes (text, source, user_did) VALUES (?, ?, ?)",
+            (message.strip(), "user", username)
         )
     return RedirectResponse(url="/chat", status_code=303)
 @router.get("/messages")
+def show_messages(request: Request, only_personal: bool = False):
+    username = request.session.get("user")
+    if not username:
+        return RedirectResponse("/login", status_code=303)
+    is_operator = False  # Пока не реализовано
+    messages = storage.get_notes(
+        limit=50,
+        user_did=username,
+        is_operator=is_operator,
+        only_personal=only_personal
+    )
     return templates.TemplateResponse("messages.html", {
         "request": request,
+        "messages": messages,
+        "only_personal": only_personal,
+        "username": username  # 👈 вот это
     })
 @router.post("/messages")
 def post_message(
     request: Request,
     text: str = Form(...),
+    user_did: str = Form(default="anon"),
+    hidden: str = Form(default=None)
 ):
+    is_hidden = 1 if hidden else 0
     storage.write_note(
         content=text,
         user_did=user_did,
+        source="user",
+        hidden=is_hidden
     )
     return RedirectResponse(url="/messages", status_code=303)
+@router.get("/login")
+def login_page(request: Request):
+    return templates.TemplateResponse("login.html", {"request": request})
+@router.post("/login")
+def login_user(request: Request, username: str = Form(...), password: str = Form(...)):
+    if storage.authenticate_user(username, password):
+        request.session["user"] = username
+        return RedirectResponse("/chat", status_code=HTTP_303_SEE_OTHER)
+    return templates.TemplateResponse("login.html", {
+        "request": request,
+        "error": "Неверный логин или пароль"
+    })
+@router.get("/register")
+def register_page(request: Request):
+    return templates.TemplateResponse("register.html", {"request": request})
+@router.post("/register")
+def register_user(request: Request, username: str = Form(...), password: str = Form(...)):
+    if storage.register_user(username, password):
+        request.session["user"] = username
+        return RedirectResponse("/chat", status_code=HTTP_303_SEE_OTHER)
+    return templates.TemplateResponse("register.html", {
+        "request": request,
+        "error": "Пользователь уже существует"
+    })
+@router.get("/logout")
+def logout(request: Request):
+    request.session.clear()
+    return RedirectResponse("/login", status_code=HTTP_303_SEE_OTHER)

agents/requirements.txt CHANGED Viewed

@@ -11,4 +11,5 @@ uvicorn
 jinja2
 python-multipart
 passlib[bcrypt]
-werkzeug

 jinja2
 python-multipart
 passlib[bcrypt]
+werkzeug
+itsdangerous

agents/tools/storage.py CHANGED Viewed

@@ -1,5 +1,6 @@
 # agents/tools/storage.py
 import sqlite3
 import os
 import json
@@ -14,7 +15,9 @@ class Storage:
         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()
     def _init_db(self):
         # Загружаем и выполняем весь SQL из файла db_structure.sql
@@ -700,24 +703,86 @@ class Storage:
         return row[0] if row else default
     # Web-интерфейс и API
-    def write_note(self, content, user_did="anon", source="user"):
         timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
-            INSERT INTO notes (text, user_did, source, timestamp)
-            VALUES (?, ?, ?, ?)
-        """, (content, user_did, source, timestamp))
         self.conn.commit()
-    def get_notes(self, limit=50):
         cursor = self.conn.cursor()
-        cursor.execute("""
-            SELECT text, source, user_did, timestamp FROM notes
-            WHERE hidden = 0
-            ORDER BY timestamp DESC
-            LIMIT ?
-        """, (limit,))
         return [dict(row) for row in cursor.fetchall()]
     # Утилиты
     def close(self):

 # agents/tools/storage.py
+import hashlib
 import sqlite3
 import os
 import json
         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.conn.row_factory = sqlite3.Row
         self._init_db()
+        self._init_user_table()
     def _init_db(self):
         # Загружаем и выполняем весь SQL из файла db_structure.sql
         return row[0] if row else default
     # Web-интерфейс и API
+    def write_note(self, content, user_did="anon", source="user", hidden=0):
         timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
+            INSERT INTO notes (text, user_did, source, timestamp, hidden)
+            VALUES (?, ?, ?, ?, ?)
+        """, (content, user_did, source, timestamp, hidden))
         self.conn.commit()
+    def get_notes(self, limit=50, user_did="anon", is_operator=False, only_personal=False):
         cursor = self.conn.cursor()
+        if is_operator:
+            query = """
+                SELECT id, text, source, user_did, timestamp, hidden
+                FROM notes
+                ORDER BY timestamp DESC
+                LIMIT ?
+            """
+            cursor.execute(query, (limit,))
+        else:
+            if only_personal:
+                # Только личные сообщения
+                query = """
+                    SELECT id, text, source, user_did, timestamp, hidden
+                    FROM notes
+                    WHERE user_did = ? AND hidden = 0
+                    ORDER BY timestamp DESC
+                    LIMIT ?
+                """
+                cursor.execute(query, (user_did, limit))
+            else:
+                # Публичные и личные
+                query = """
+                    SELECT id, text, source, user_did, timestamp, hidden
+                    FROM notes
+                    WHERE (user_did = ? OR user_did = 'ALL') AND hidden = 0
+                    ORDER BY timestamp DESC
+                    LIMIT ?
+                """
+                cursor.execute(query, (user_did, limit))
         return [dict(row) for row in cursor.fetchall()]
+    # Пользователи
+    def _hash_password(self, password: str) -> str:
+        return hashlib.sha256(password.encode()).hexdigest()
+    def _init_user_table(self):
+        self.conn.execute('''
+            CREATE TABLE IF NOT EXISTS users (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                username TEXT UNIQUE NOT NULL,
+                password_hash TEXT NOT NULL
+            )
+        ''')
+        self.conn.commit()
+    def register_user(self, username: str, password: str) -> bool:
+        self._init_user_table()
+        try:
+            self.conn.execute(
+                "INSERT INTO users (username, password_hash) VALUES (?, ?)",
+                (username, self._hash_password(password))
+            )
+            self.conn.commit()
+            return True
+        except sqlite3.IntegrityError:
+            return False  # пользователь уже существует
+    def authenticate_user(self, username: str, password: str) -> bool:
+        cursor = self.conn.cursor()
+        cursor.execute(
+            "SELECT password_hash FROM users WHERE username = ?",
+            (username,)
+        )
+        result = cursor.fetchone()
+        if result:
+            return result["password_hash"] == self._hash_password(password)
+        return False
     # Утилиты
     def close(self):

agents/web_ui.py CHANGED Viewed

@@ -13,11 +13,14 @@ 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
 storage = 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"))

 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
 #from agents.notebook.auth import router as auth_router
+from starlette.middleware.sessions import SessionMiddleware
 from agents.notebook.views import router as notebook_router
 from tools.storage import Storage
 storage = Storage()
 app = FastAPI()
+app.add_middleware(SessionMiddleware, secret_key="очень_секретный_ключ")
 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"))

hf_repo/hf_repo/agents/add_message.py CHANGED Viewed

@@ -1,28 +1,24 @@
 # agents/add_message.py
 import argparse
-from datetime import datetime
 from tools.storage import Storage
 storage = Storage()
-def add_message(role, content, source="cli", user_did=None):
     storage.write_note(
         content,
-        role=role,
         source=source,
-        user_did=user_did,
-        tags=[]
     )
-    print(f"[+] Сообщение от {role} ({source}) добавлено: {content}")
 # --- CLI interface ---
 if __name__ == "__main__":
     parser = argparse.ArgumentParser()
-    parser.add_argument("--role", required=True)
     parser.add_argument("--content", required=True)
     parser.add_argument("--source", default="cli")
-    parser.add_argument("--user_did")
     args = parser.parse_args()
-    add_message(args.role, args.content, args.source, args.user_did)

 # agents/add_message.py
 import argparse
 from tools.storage import Storage
 storage = Storage()
+def add_message(content, source="cli", user_did="anon"):
     storage.write_note(
         content,
         source=source,
+        user_did=user_did
     )
+    print(f"[+] Сообщение от {source} ({user_did}) добавлено: {content}")
 # --- CLI interface ---
 if __name__ == "__main__":
     parser = argparse.ArgumentParser()
     parser.add_argument("--content", required=True)
     parser.add_argument("--source", default="cli")
+    parser.add_argument("--user_did", default="anon")
     args = parser.parse_args()
+    add_message(args.content, args.source, args.user_did)

hf_repo/hf_repo/agents/notebook/views.py CHANGED Viewed

@@ -6,7 +6,7 @@ from fastapi.templating import Jinja2Templates
 from tools.storage import Storage
 router = APIRouter()
-templates = Jinja2Templates(directory="agents/notebook/templates")
 storage = Storage()
 DID = "did:example:local-user"  # временно
@@ -30,7 +30,7 @@ def submit_note(request: Request, message: str = Form(...)):
 @router.get("/messages")
 def show_messages(request: Request):
-    messages = storage.get_notes(limit=50)  # должна быть в Storage
     return templates.TemplateResponse("messages.html", {
         "request": request,
         "messages": messages
@@ -40,13 +40,11 @@ def show_messages(request: Request):
 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)

 from tools.storage import Storage
 router = APIRouter()
+templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
 DID = "did:example:local-user"  # временно
 @router.get("/messages")
 def show_messages(request: Request):
+    messages = storage.get_notes(limit=50)
     return templates.TemplateResponse("messages.html", {
         "request": request,
         "messages": messages
 def post_message(
     request: Request,
     text: str = Form(...),
     user_did: str = Form(default="anon")
 ):
     storage.write_note(
         content=text,
         user_did=user_did,
+        source="user"
     )
     return RedirectResponse(url="/messages", status_code=303)

hf_repo/hf_repo/agents/tools/db_structure.sql CHANGED Viewed

@@ -46,7 +46,7 @@ CREATE TABLE IF NOT EXISTS notes (
     text TEXT NOT NULL,                                         -- Текст заметки
     tags TEXT,                                                  -- Теги (например: "idea", "instruction")
     user_did TEXT DEFAULT 'ALL',                                -- DID пользователя (или 'ALL' — для всех)
-    source TEXT DEFAULT 'user',                                 -- Источник заметки: user | llm | system
     links TEXT DEFAULT '',                                      -- Ссылки или связи с другими объектами
     read INTEGER DEFAULT 0,                                     -- Статус прочтения LLM: 0 = нет, 1 = да
     hidden INTEGER DEFAULT 0,                                   -- Скрыта ли от пользователя: 0 = нет, 1 = да

     text TEXT NOT NULL,                                         -- Текст заметки
     tags TEXT,                                                  -- Теги (например: "idea", "instruction")
     user_did TEXT DEFAULT 'ALL',                                -- DID пользователя (или 'ALL' — для всех)
+    source TEXT DEFAULT 'user',                                 -- Источник заметки: user | cli | llm | system
     links TEXT DEFAULT '',                                      -- Ссылки или связи с другими объектами
     read INTEGER DEFAULT 0,                                     -- Статус прочтения LLM: 0 = нет, 1 = да
     hidden INTEGER DEFAULT 0,                                   -- Скрыта ли от пользователя: 0 = нет, 1 = да

hf_repo/hf_repo/agents/tools/storage.py CHANGED Viewed

@@ -700,18 +700,18 @@ class Storage:
         return row[0] if row else default
     # Web-интерфейс и API
-    def write_note(self, content, role="user", user_did="anon", source="web"):
         timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
-            INSERT INTO notes (text, role, user_did, source, timestamp)
-            VALUES (?, ?, ?, ?, ?)
-        """, (content, role, user_did, source, timestamp))
         self.conn.commit()
     def get_notes(self, limit=50):
         cursor = self.conn.cursor()
         cursor.execute("""
-            SELECT text, role, source, user_did, timestamp FROM notes
             WHERE hidden = 0
             ORDER BY timestamp DESC
             LIMIT ?

         return row[0] if row else default
     # Web-интерфейс и API
+    def write_note(self, content, user_did="anon", source="user"):
         timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
+            INSERT INTO notes (text, user_did, source, timestamp)
+            VALUES (?, ?, ?, ?)
+        """, (content, user_did, source, timestamp))
         self.conn.commit()
     def get_notes(self, limit=50):
         cursor = self.conn.cursor()
         cursor.execute("""
+            SELECT text, source, user_did, timestamp FROM notes
             WHERE hidden = 0
             ORDER BY timestamp DESC
             LIMIT ?

hf_repo/hf_repo/hf_repo/agents/readme.md CHANGED Viewed

@@ -79,4 +79,4 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей
 ├── [`config.yml`](config.yml) ← Конфигурация агента (имя, порты, роли и т.п.)
 ├── [`bootstrap.txt`](bootstrap.txt) ← Локальная этическая модель
-└── [`ethics.yml`](ethics.yml) ← Список начальных узлов  '

 │       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей
 ├── [`config.yml`](config.yml) ← Конфигурация агента (имя, порты, роли и т.п.)
 ├── [`bootstrap.txt`](bootstrap.txt) ← Локальная этическая модель
+└── [`ethics.yml`](ethics.yml) ← Список начальных узлов

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md CHANGED Viewed

@@ -4,7 +4,7 @@
 Конфигурационные файлы: `config.yml`, `bootstrap.txt`
 Локальная этическая модель: `ethics.yml`
-Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 Запуск потоков (осуществляет start_repl.py):
@@ -17,7 +17,6 @@
 | 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
 | 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
 | 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
-| 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 *См. также: [Контейнерные агенты](../docs/container_agents.md), [Архитектура HMP-агента](../docs/HMP-Agent-Architecture.md)*

 Конфигурационные файлы: `config.yml`, `bootstrap.txt`
 Локальная этическая модель: `ethics.yml`
+Проверка инициализации БД - если нет, инициализация (`init.py`)
 Запуск потоков (осуществляет start_repl.py):
 | 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
 | 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
 | 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 *См. также: [Контейнерные агенты](../docs/container_agents.md), [Архитектура HMP-агента](../docs/HMP-Agent-Architecture.md)*

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/config.yml CHANGED Viewed

@@ -1,44 +1,69 @@
-agent_id: did:hmp:6afb62eb-8384-4042-948a-c4b7adee3e59
-agent_name: CognitiveCore
-agent_role: core
 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_port: 20784
-dht_update: true
-enable_llm: true
-identity_agent: 6afb62eb-8384-4042-948a-c4b7adee3e59
 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
 ui_port: 8765
-update_interval: 60

+# 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
+# === DHT-сеть и обмен знаниями ===
+dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
+dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
+bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
 dht_port: 20784
+update_interval: 60               # секунд (для DHT-обновлений)
+# === LLM-бэкенды ===
 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"
 ui_port: 8765
+# === Данные пользователя ===
+default_user:
+  username: "user"
+  email: "[email protected]"
+  password: "password"            # пусто при инициализации, будет установлен при регистрации
+# === Отладка и логгирование ===
+debug: true
+log_level: "INFO"                 # DEBUG, INFO, WARNING, ERROR

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.py CHANGED Viewed

@@ -1,21 +1,35 @@
 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)
@@ -26,4 +40,4 @@ def check_all_processes():
             print(f" • {name:20} — ⚠️ Ошибка: {e}")
 if __name__ == "__main__":
-    check_all_processes()

+# agents/check_agents.py
 import os
 import sys
+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.now(UTC)
     for name, heartbeat in processes:
         try:
             hb_time = datetime.fromisoformat(heartbeat)
             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/config.yml CHANGED Viewed

@@ -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
 api_port: 8080
-# === DHT-сеть и обмен знаниями ===
-dht_enabled: true                 # Включение участия в DHT-сети (включено принудительно!)
-dht_update: true                  # Регулярные обновления и публикация данных в DHT (включено принудительно!)
-bootstrap_responder: true         # Агент отвечает на bootstrap-запросы (включено принудительно!)
 dht_port: 20784
-update_interval: 60               # секунд (для DHT-обновлений)
-# === LLM-бэкенды ===
 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"
 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

+agent_id: did:hmp:6afb62eb-8384-4042-948a-c4b7adee3e59
+agent_name: CognitiveCore
+agent_role: core
 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_port: 20784
+dht_update: true
+enable_llm: true
+identity_agent: 6afb62eb-8384-4042-948a-c4b7adee3e59
 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
 ui_port: 8765
+update_interval: 60

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/examples/config.yml CHANGED Viewed

@@ -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"
 # === Отладка и логгирование ===
 debug: true

 default_user:
   username: "user"
   email: "[email protected]"
+  password: "password"            # пусто при инициализации, будет установлен при регистрации
 # === Отладка и логгирование ===
 debug: true

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/init.py CHANGED Viewed

@@ -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 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")
 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()
         }
         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)
     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()
         }
         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}")
         else:
-            print(f"[=] Каталог уже существует: {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):
         print("[*] БД не инициализирована — выполняем инициализацию.")
         try:
-            ensure_directories(config)
-            storage = Storage(config)
             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()

 import sys
 import yaml
 import json
 import uuid
 import sqlite3
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+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
 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:
             "pubkey": pubkey,
             "privkey": privkey,
             "metadata": json.dumps({"role": config.get("agent_role", "core")}),
+            "created_at": datetime.now(UTC).isoformat(),
+            "updated_at": datetime.now(UTC).isoformat()
         }
         storage.add_identity(identity)
         config["agent_id"] = did
         config["identity_agent"] = identity_id
         save_config(CONFIG_PATH, config)
     if not password:
         print("[-] Не указан пароль пользователя — пропуск.")
         return
+    password_hash = generate_password_hash(password)
     did = generate_did()
     user_entry = {
         "username": user.get("username", "user"),
         "operator": 1
     }
     storage.add_user(user_entry)
     print(f"[+] Пользователь {user['username']} добавлен.")
 def init_llm_backends(storage, config):
             "name": backend["name"],
             "endpoint": desc,
             "metadata": json.dumps(backend),
+            "created_at": datetime.now(UTC).isoformat()
         }
         storage.add_llm(llm)
         print(f"[+] Зарегистрирован LLM: {backend['name']}")
         storage.set_config(key, json.dumps(value))
     print("[+] Конфигурация сохранена в БД.")
+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"[=] Каталог уже существует: {full_path}")
 def is_db_initialized(db_path):
     if not os.path.exists(db_path):
 def ensure_db_initialized():
     config = load_config(CONFIG_PATH)
+    if not is_db_initialized(DB_PATH):
         print("[*] БД не инициализирована — выполняем инициализацию.")
         try:
+            ensure_directories()
+            storage = Storage()
             init_identity(storage, config)
             init_user(storage, config)
             init_llm_backends(storage, config)
     return config
 if __name__ == "__main__":
+    ensure_db_initialized()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/logger.py CHANGED Viewed

@@ -2,7 +2,7 @@
 import json
 import os
-from datetime import datetime
 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(),
         "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(),
         "event": "repl_snapshot",
         "message": "Полный REPL-контекст",
         "context": snapshot,

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/mcp_server.py CHANGED Viewed

@@ -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 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()}
 @app.post("/diary/write", response_model=dict)
 def write_diary(entry: DiaryInput):

 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 from typing import List, Optional
+from datetime import datetime, UTC
 from tools.storage import Storage
 app = FastAPI(title="HMP MCP-Agent API", version="0.2")
 @app.get("/status")
 def status():
+    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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/repl.py CHANGED Viewed

@@ -8,7 +8,7 @@ import sqlite3
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
-from datetime import datetime
 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()
             print(f"\n=== [🌀 Новый тик REPL] {tick_start} ===")
             # 0. Обновление информации о пирах

 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+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
     try:
         while True:
+            tick_start = datetime.now(UTC).isoformat()
             print(f"\n=== [🌀 Новый тик REPL] {tick_start} ===")
             # 0. Обновление информации о пирах

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/context_builder.py CHANGED Viewed

@@ -1,6 +1,6 @@
 # agents/tools/context_builder.py
-from datetime import datetime
 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(),
         "agent_name": config.get("agent_name", "Unnamed-Agent"),
         "mode": config.get("mode", "auto"),
         "idle_mode": config.get("idle_mode", False),

 # agents/tools/context_builder.py
+from datetime import datetime, UTC
 def build_contexts(db, config):
     """
 def get_system_info(config):
     return {
+        "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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/identity.py CHANGED Viewed

@@ -3,7 +3,7 @@
 import uuid
 import json
 import base64
-from datetime import datetime
 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(),
     }
     return identity

 import uuid
 import json
 import base64
+from datetime import datetime, UTC
 from cryptography.hazmat.primitives.asymmetric import rsa, ed25519
 from cryptography.hazmat.primitives import serialization
         "pubkey": serialize_public_key(pub_key),
         "privkey": serialize_private_key(priv_key, password),
         "metadata": json.dumps(metadata or {}),
+        "created_at": datetime.now(UTC).isoformat(),
+        "updated_at": datetime.now(UTC).isoformat(),
     }
     return identity

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/memory_utils.py CHANGED Viewed

@@ -1,6 +1,6 @@
 # agents/tools/memory_utils.py
-from datetime import datetime, timedelta
 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()
     })

 # agents/tools/memory_utils.py
+from datetime import datetime, timedelta, UTC
 from difflib import SequenceMatcher
 from typing import Optional, List, Dict
         "title": title,
         "content": content,
         "tags": tags,
+        "created_at": datetime.now(UTC).isoformat(),
+        "updated_at": datetime.now(UTC).isoformat()
     })

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py CHANGED Viewed

@@ -3,15 +3,16 @@
 import sqlite3
 import os
 import json
-from datetime import datetime, timedelta
-DEFAULT_DB_PATH = "agent_data.db"
 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)
         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()
         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()
         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()
         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.extend([name, version])
         query = f"""
@@ -664,7 +665,7 @@ class Storage:
     # Управление основными процессами
     def update_heartbeat(self, name: str):
-        now = datetime.utcnow().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
             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()
         self.conn.execute("""
             INSERT INTO notes (text, role, user_did, source, timestamp)
             VALUES (?, ?, ?, ?, ?)

 import sqlite3
 import os
 import json
+from datetime import datetime, timedelta, UTC
 SCRIPTS_BASE_PATH = "scripts"
 class Storage:
     def __init__(self, config=None):
         self.config = config or {}
+        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()
     # Методы для работы с дневником
     def write_diary_entry(self, text, tags=None):
+        timestamp = datetime.now(UTC).isoformat()
         tag_str = ",".join(tags) if tags else ""
         self.conn.execute(
             'INSERT INTO diary_entries (text, tags, timestamp) VALUES (?, ?, ?)',
     # Методы для работы с концептами
     def add_concept(self, name, description=None):
+        timestamp = datetime.now(UTC).isoformat()
         self.conn.execute(
             'INSERT INTO concepts (name, description, timestamp) VALUES (?, ?, ?)',
             (name, description, timestamp)
             raise ValueError("Один или оба концепта не найдены")
         from_id = from_concept[0]
         to_id = to_concept[0]
+        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)
             return False
         fields.append("updated_at = ?")
+        values.append(datetime.now(UTC).isoformat())
         values.extend([name, version])
         query = f"""
     # Управление основными процессами
     def update_heartbeat(self, name: str):
+        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",
         if row:
             try:
                 last_beat = datetime.fromisoformat(row[0])
+                return (datetime.now(UTC) - 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.now(UTC).isoformat()
         self.conn.execute("""
             INSERT INTO notes (text, role, user_did, source, timestamp)
             VALUES (?, ?, ?, ?, ?)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py CHANGED Viewed

@@ -1,4 +1,4 @@
-# agent/notebook.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("[*] Запуск пользовательского интерфейса...")

+# agent/web_ui.py
 import os
 import sys
     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)
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

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 CHANGED Viewed

@@ -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
 # Проверка инициализации (вернёт config, если всё ОК)
 config = ensure_db_initialized()

 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/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py CHANGED Viewed

@@ -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._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
     # Web-интерфейс и API
     def write_note(self, content, role="user", user_did="anon", source="web"):
         timestamp = datetime.utcnow().isoformat()

     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, check_same_thread=False)
         self._init_db()
     def _init_db(self):
             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()
                 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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py CHANGED Viewed

@@ -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)
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

             break
         await asyncio.sleep(60)
+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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.bat ADDED Viewed

	@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.sh ADDED Viewed

	@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/check_agents.bat ADDED Viewed

	@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/check_agents.py ADDED Viewed

	@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md CHANGED Viewed

@@ -10,13 +10,13 @@
 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
-| 🧠 `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` *(опц.)* | Управление дочерними агентами, запуск/мониторинг/масштабирование [[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-цикл
 ├── [`notebook.py`](notebook.py) ← UI-интерфейс
 ├── [`agent_mesh_listener.py`](tools/agent_mesh_listener.py) ← Прием входящих сообщений от других HMP-агентов
 ├── [`peer_sync.py`](tools/peer_sync.py) ← Фоновая синхронизация с другими пирам

 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
+| 🧠 `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` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 ├── [`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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py CHANGED Viewed

@@ -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 ENABLE_UI:
-        def ui():
-            from agents.web_ui import start_notebook
-            start_notebook()
-        threads.append(threading.Thread(target=ui, name="NotebookUI"))
     if ENABLE_MESH:
-        def mesh():
-            from agents.agent_mesh_listener import start_listener
-            start_listener()
-        threads.append(threading.Thread(target=mesh, name="MeshListener"))
     if ENABLE_SYNC:
-        def sync():
-            from agents.peer_sync import start_sync
-            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:

     threads = []
     if ENABLE_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:
+        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:
+        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:
+        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:
+        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:
+        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:
+        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:
+        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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/storage.py CHANGED Viewed

@@ -3,7 +3,7 @@
 import sqlite3
 import os
 import json
-from datetime import datetime
 DEFAULT_DB_PATH = "agent_data.db"
 SCRIPTS_BASE_PATH = "scripts"
@@ -681,6 +681,18 @@ class Storage:
             return True
         return False
     # Web-интерфейс и API
     def write_note(self, content, role="user", user_did="anon", source="web"):
         timestamp = datetime.utcnow().isoformat()

 import sqlite3
 import os
 import json
+from datetime import datetime, timedelta
 DEFAULT_DB_PATH = "agent_data.db"
 SCRIPTS_BASE_PATH = "scripts"
             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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py CHANGED Viewed

@@ -16,6 +16,7 @@ from fastapi.templating import Jinja2Templates
 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")
@@ -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)
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

 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")
 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)
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")

hf_repo/hf_repo/hf_repo/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/__init__.py ADDED Viewed

File without changes

hf_repo/hf_repo/hf_repo/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/repl.py CHANGED Viewed

@@ -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):
     print("[🧠 HMP-Agent] Запуск REPL-режима (v2)")
     config = config or {}
     db = Storage(config=config)

 from tools.storage import Storage
 from tools.peers import refresh_peer_list, check_peer_statuses
+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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/db_structure.sql CHANGED Viewed

@@ -135,7 +135,7 @@ 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.
@@ -146,7 +146,7 @@ CREATE TABLE external_services (
 );
 -- Аккаунты агента на внешних сервисах
-CREATE TABLE 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 (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
     name            TEXT NOT NULL,                              -- Название метода (например, "Mesh-вопрос")
     description     TEXT NOT NULL,                              -- Подробное описание метода

 );
 -- Таблица внешних сервисов (форумы, блоги и т.д.)
+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.
 );
 -- Аккаунты агента на внешних сервисах
+CREATE TABLE IF NOT EXISTS external_accounts (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
     service_id      INTEGER NOT NULL,                           -- Внешний ключ на external_services.id
     login           TEXT NOT NULL,                              -- Логин/имя пользователя
 );
 -- Способы выхода из когнитивной стагнации
+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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/web_ui.py ADDED Viewed

	@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py CHANGED Viewed

@@ -1,26 +1,24 @@
-# agents/start_repl.py
 import sys
 import os
 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
 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
             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"))
     # Запуск потоков
     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()

 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
 # Проверка инициализации (вернёт config, если всё ОК)
 config = ensure_db_initialized()
 # ⚙️ Включение/отключение компонентов
+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:
     if ENABLE_UI:
         def ui():
+            from agents.web_ui import start_notebook
             start_notebook()
         threads.append(threading.Thread(target=ui, name="NotebookUI"))
             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:
         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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook.py CHANGED Viewed

@@ -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
 app = FastAPI()

 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()

@@ -127,11 +127,11 @@ RU:
 В этом разделе собраны основные статьи, черновики и переводы, связанные с проектом 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 и другие

 В этом разделе собраны основные статьи, черновики и переводы, связанные с проектом HMP.
+* **[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)** — текущий редакторский перевод (в процессе доработки).
 #### 🔍 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/hf_repo/hf_repo/hf_repo/README.md CHANGED Viewed

@@ -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)
 #### 🔍 Overviews / Обзоры
 * [🔍 Distributed-Cognitive-Systems.md](docs/Distributed-Cognitive-Systems.md) — Децентрализованные ИИ-системы: OpenCog Hyperon, HyperCortex Mesh Protocol и другие

 * [🔍 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 и другие

@@ -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>Экспериментальная когнитивная архитектура агента (проект на ранней стадии).                                          |
 ### 📘 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.

 > 🧠🔥 **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>Экспериментальная когнитивная архитектура агента (проект на ранней стадии).                                                |
+| 💾 [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.

@@ -25,7 +25,7 @@
 * **Key Features:**
   * Decentralized agent communication and transaction system.
-  * AI-DSL: A 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:**
 * **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**
 ##### 🤖 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   |
 ---
 ### 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   |

 * **Key Features:**
   * Decentralized agent communication and transaction system.
+  * 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.
 * **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.
 * **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**
 * **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. **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
 * **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)
 * **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
 * **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
 ### 🧩 Suggested Additions to Summary Table
+| 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       |
+| 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  |

@@ -1620,3 +1620,74 @@ P.S. Репозиторий на GitHub выглядит перспективн
 HMP v4.0 — это не просто эволюция, а качественный скачок. Это смелая и глубокая попытка заложить основы для будущего, в котором ИИ-агенты смогут сотрудничать не только эффективно, но и этично. У вас в руках есть все шансы создать не просто очередной протокол, а фундаментальный стандарт для нового поколения децентрализованных когнитивных систем.
 Спасибо за возможность ознакомиться с вашей работой! 😉

 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-протоколу не только соединяться с уже существующими технологиями семантических графов и когнитивных систем, но и легко эволюционировать вместе с ними.

@@ -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` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
-Подробнее в [HMP-Agent-Architecture.md](../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

 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 Запуск потоков (осуществляет start_repl.py):
 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
 | 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
 | 🔄 `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` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
+*См. также: [Контейнерные агенты](../docs/container_agents.md), [Архитектура HMP-агента](../docs/HMP-Agent-Architecture.md)*
 ---
 ├── [`requirements.txt`](requirements.txt) ← Зависимости
 ├── [tools/](tools/) ← Вспомогательные скрипты и модули
 │   ├── [`db_structure.sql`](tools/db_structure.sql) ← БД SQL
 │   ├── [`storage.py`](tools/storage.py) ← Реализация базового хранилища (`Storage`), подключение SQLite
 │   ├── [`config_utils.py`](tools/config_utils.py) ← Обновляет JSON-файл конфигурации указанными значениями
 │   ├── [`crypto.py`](tools/crypto.py) ← Создание и шифрование ключей RSA/Ed25519

@@ -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 |
 ---

 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 Запуск потоков (осуществляет start_repl.py):
+| Поток / Скрипт                     | Назначение                                                                 |
+|-----------------------------------|---------------------------------------------------------------------------|
+| 🧠 `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)
 ---