Sync from GitHub with Git LFS

agents/notebook/views.py

@@ -12,7 +12,7 @@ router = APIRouter()
 templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
 
-allowed_tags = ['b', 'i', 'a']
+allowed_tags = ['b', 'i', 'a', 'ol', 'ul', 'li', 'dl', 'dt', 'dd', 'table', 'caption', 'tr', 'th', 'td']
 allowed_attributes = {
     'a': ['href', 'title']
 }

hf_repo/agents/notebook/views.py

@@ -1,5 +1,7 @@
 # agents/notebook/views.py
 
+import bleach
+
 from fastapi import APIRouter, Request, Form
 from fastapi.responses import RedirectResponse, HTMLResponse
 from fastapi.templating import Jinja2Templates
@@ -10,6 +12,14 @@ router = APIRouter()
 templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
 
+allowed_tags = ['b', 'i', 'a', 'ol', 'ul', 'li', 'dl', 'dt', 'dd', 'table', 'caption', 'tr', 'th', 'td']
+allowed_attributes = {
+    'a': ['href', 'title']
+}
+
+def sanitize_html(text):
+    return bleach.clean(text, tags=allowed_tags, attributes=allowed_attributes, strip=True)
+
 @router.get("/chat")
 def chat_page(request: Request):
     did = request.session.get("did")
@@ -72,7 +82,7 @@ def post_message(
 
     if text.strip():
         storage.write_note(
-            content=text.strip(),
+            content=sanitize_html(text.strip()),
             user_did=did,
             source="user",
             hidden=is_hidden

hf_repo/agents/requirements.txt

@@ -12,4 +12,5 @@ jinja2
 python-multipart
 passlib[bcrypt]
 werkzeug
-itsdangerous
+itsdangerous
+bleach

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

@@ -46,10 +46,10 @@
                 Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp[:19].replace('T', ' ') }}
             </div>
             <div>
-                {{ msg.badges }}Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did !="" %}({{ msg.user_did }}){% endif %}
+                {% if msg.badges %}{{ msg.badges }}{% endif %}Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did %}({{ msg.user_did }}){% endif %}
             </div>
             <hr>
-            <div>{{ msg.text }}</div>
+            <div>{{ msg.text|safe }}</div>
         </div>
     {% endfor %}
 </body>

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

@@ -731,7 +731,7 @@ class Storage:
         else:
             # Личные сообщения + публичные от user/llm, которые не скрыты
             query = """
-                SELECT n.id, n.text, n.source, n.user_did, u.username, n.timestamp, n.hidden
+                SELECT n.id, n.text, n.source, n.user_did, u.username, u.badges, n.timestamp, n.hidden
                 FROM notes n
                 LEFT JOIN users u ON n.user_did = u.did
                 WHERE n.user_did = ?

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

@@ -46,7 +46,7 @@
                 Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp[:19].replace('T', ' ') }}
             </div>
             <div>
-                Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did !="" %}({{ msg.user_did }}){% endif %}
+                {{ msg.badges }}Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did !="" %}({{ msg.user_did }}){% endif %}
             </div>
             <hr>
             <div>{{ msg.text }}</div>

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

@@ -199,9 +199,10 @@ CREATE TABLE IF NOT EXISTS users (
   user_id INTEGER PRIMARY KEY AUTOINCREMENT,
   ban DATETIME DEFAULT NULL,                                    -- если стоит дата/время, то пользователь забанен до этого момента
   username TEXT,                                                -- имя пользователя (необязательно уникальное)
-  did TEXT UNIQUE,                                              -- децентрализованный идентификатор
-  mail TEXT UNIQUE,                                             -- электронная почта
-  password_hash TEXT,                                           -- хэш пароля
+  badges TEXT,                                                  -- значки, присвоенные агентом (например, "🎓💬")
+  did TEXT  UNIQUE NOT NULL,                                    -- децентрализованный идентификатор
+  mail TEXT UNIQUE NOT NULL,                                    -- электронная почта
+  password_hash TEXT NOT NULL,                                  -- хэш пароля
   info TEXT,                                                    -- произвольная информация, JSON
   profile TEXT,                                                 -- структурированая информация, JSON
   contacts TEXT,                                                -- JSON-массив альтернативных контактов (matrix, telegram и т.д.)

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

@@ -1,7 +1,7 @@
 # agents/notebook/views.py
 
 from fastapi import APIRouter, Request, Form
-from fastapi.responses import RedirectResponse
+from fastapi.responses import RedirectResponse, HTMLResponse
 from fastapi.templating import Jinja2Templates
 from starlette.status import HTTP_303_SEE_OTHER
 from tools.storage import Storage
@@ -66,6 +66,10 @@ def post_message(
     did = request.session.get("did", "anon")
     is_hidden = 1 if hidden.lower() == "true" else 0
 
+    # Проверка на бан
+    if storage.is_banned(did):
+        return HTMLResponse(content="Вы забанены и не можете отправлять сообщения.", status_code=403)
+
     if text.strip():
         storage.write_note(
             content=text.strip(),

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

@@ -769,6 +769,18 @@ class Storage:
             return check_password_hash(result["password_hash"], password)
         return False
 
+    def is_banned(self, user_did):
+        result = self.conn.execute("""
+            SELECT ban
+            FROM users
+            WHERE did = ?
+        """, (user_did,)).fetchone()
+
+        if result and result["ban"]:
+            return datetime.fromisoformat(result["ban"]) > datetime.now(UTC)
+
+        return False
+
     def get_user_info(self, mail: str) -> dict | None:
         mail = mail.lower()
         cursor = self.conn.cursor()

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

@@ -33,7 +33,7 @@
 
     <div>
         <a href="/messages">📢 Все сообщения</a> |
-        <a href="/messages?only_personal=true">🙋 Только мои</a>
+        <a href="/messages?only_personal=true">🙋 Личные</a>
     </div>
 
     <hr>
@@ -41,8 +41,8 @@
     {% for msg in messages %}
         <div class="message source-{{ msg.source }}">
             <div>
-                {% if msg.user_did == request.session['did'] %}<span class="from-self"></span>{% endif %}
-                {% if msg.hidden %}<span class="private"></span>{% endif %}
+                {% if msg.user_did == request.session['did'] %}<span class="from-self" title="это ваше сообщение"></span>{% endif %}
+                {% if msg.hidden %}<span class="private" title="личное сообщение"></span>{% endif %}
                 Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp[:19].replace('T', ' ') }}
             </div>
             <div>

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

@@ -39,13 +39,14 @@
     <hr>
 
     {% for msg in messages %}
-        <div class="message source-{{ msg.source }} {% if msg.user_did == request.session['did'] %}from-self{% endif %}">
+        <div class="message source-{{ msg.source }}">
             <div>
-                Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp }}
+                {% if msg.user_did == request.session['did'] %}<span class="from-self"></span>{% endif %}
                 {% if msg.hidden %}<span class="private"></span>{% endif %}
+                Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp[:19].replace('T', ' ') }}
             </div>
             <div>
-                Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} ({{ msg.user_did }})
+                Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did !="" %}({{ msg.user_did }}){% endif %}
             </div>
             <hr>
             <div>{{ msg.text }}</div>

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

@@ -41,11 +41,11 @@
     {% for msg in messages %}
         <div class="message source-{{ msg.source }} {% if msg.user_did == request.session['did'] %}from-self{% endif %}">
             <div>
-                <strong>{{ msg.source }}</strong> — {{ msg.timestamp }}
+                Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp }}
                 {% if msg.hidden %}<span class="private"></span>{% endif %}
             </div>
             <div>
-                участник: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} ({{ msg.user_did[:10] }})...
+                Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} ({{ msg.user_did }})
             </div>
             <hr>
             <div>{{ msg.text }}</div>

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

@@ -45,9 +45,9 @@
                 {% if msg.hidden %}<span class="private"></span>{% endif %}
             </div>
             <div>
-                участник: {{ msg.user_did[:10] }}...
-                {% if msg.username %}({{ msg.username }}){% endif %}
+                участник: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} ({{ msg.user_did[:10] }})...
             </div>
+            <hr>
             <div>{{ msg.text }}</div>
         </div>
     {% endfor %}

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

@@ -45,7 +45,7 @@
                 {% if msg.hidden %}<span class="private"></span>{% endif %}
             </div>
             <div>
-                от {{ msg.user_did[:10] }}...
+                участник: {{ msg.user_did[:10] }}...
                 {% if msg.username %}({{ msg.username }}){% endif %}
             </div>
             <div>{{ msg.text }}</div>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -718,23 +718,25 @@ class Storage:
         cursor = self.conn.cursor()
 
         if only_personal:
-            # Только личные сообщения пользователя
+            # Только личные (скрытые) сообщения пользователя
             query = """
-                SELECT id, text, source, user_did, timestamp, hidden
-                FROM notes
-                WHERE user_did = ?
-                ORDER BY timestamp DESC
+                SELECT n.id, n.text, n.source, n.user_did, u.username, n.timestamp, n.hidden
+                FROM notes n
+                LEFT JOIN users u ON n.user_did = u.did
+                WHERE n.user_did = ? AND n.hidden = 1
+                ORDER BY n.timestamp DESC
                 LIMIT ?
             """
             cursor.execute(query, (user_did, limit))
         else:
             # Личные сообщения + публичные от user/llm, которые не скрыты
             query = """
-                SELECT id, text, source, user_did, timestamp, hidden
-                FROM notes
-                WHERE user_did = ?
-                   OR ((source = 'user' OR source = 'llm') AND hidden = 0)
-                ORDER BY timestamp DESC
+                SELECT n.id, n.text, n.source, n.user_did, u.username, n.timestamp, n.hidden
+                FROM notes n
+                LEFT JOIN users u ON n.user_did = u.did
+                WHERE n.user_did = ?
+                   OR ((n.source = 'user' OR n.source = 'llm') AND n.hidden = 0)
+                ORDER BY n.timestamp DESC
                 LIMIT ?
             """
             cursor.execute(query, (user_did, limit))

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

@@ -45,14 +45,9 @@ def show_messages(request: Request, only_personal: bool = False):
     if not did:
         return RedirectResponse("/login", status_code=303)
 
-    # Получаем инфу о пользователе, чтобы понять, оператор ли он
-    user_info = storage.get_user_info_by_did(did)
-    is_operator = bool(user_info and user_info.get("operator"))
-
     messages = storage.get_notes(
         limit=50,
         user_did=did,
-        is_operator=is_operator,
         only_personal=only_personal
     )
     return templates.TemplateResponse("messages.html", {

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

@@ -714,38 +714,30 @@ class Storage:
         """, (content, user_did, source, timestamp, hidden))
         self.conn.commit()
 
-    def get_notes(self, limit=50, user_did="anon", is_operator=False, only_personal=False):
+    def get_notes(self, limit=50, user_did="anon", only_personal=False):
         cursor = self.conn.cursor()
 
-        if is_operator:
+        if only_personal:
+            # Только личные сообщения пользователя
             query = """
                 SELECT id, text, source, user_did, timestamp, hidden
                 FROM notes
+                WHERE user_did = ?
                 ORDER BY timestamp DESC
                 LIMIT ?
             """
-            cursor.execute(query, (limit,))
+            cursor.execute(query, (user_did, 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))
+            # Личные сообщения + публичные от user/llm, которые не скрыты
+            query = """
+                SELECT id, text, source, user_did, timestamp, hidden
+                FROM notes
+                WHERE user_did = ?
+                   OR ((source = 'user' OR source = 'llm') AND hidden = 0)
+                ORDER BY timestamp DESC
+                LIMIT ?
+            """
+            cursor.execute(query, (user_did, limit))
 
         return [dict(row) for row in cursor.fetchall()]
 
@@ -790,6 +782,21 @@ class Storage:
             }
         return None
 
+    def get_user_info_by_did(self, did: str) -> dict | None:
+        cursor = self.conn.cursor()
+        cursor.execute(
+            "SELECT username, mail, operator FROM users WHERE did = ?",
+            (did,)
+        )
+        result = cursor.fetchone()
+        if result:
+            return {
+                "username": result["username"],
+                "mail": result["mail"],
+                "operator": result["operator"]
+            }
+        return None
+
     # Утилиты
 
     def close(self):

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

@@ -1,3 +1,5 @@
+# agents/notebook/views.py
+
 from fastapi import APIRouter, Request, Form
 from fastapi.responses import RedirectResponse
 from fastapi.templating import Jinja2Templates
@@ -43,7 +45,10 @@ def show_messages(request: Request, only_personal: bool = False):
     if not did:
         return RedirectResponse("/login", status_code=303)
 
-    is_operator = False  # Пока не реализовано
+    # Получаем инфу о пользователе, чтобы понять, оператор ли он
+    user_info = storage.get_user_info_by_did(did)
+    is_operator = bool(user_info and user_info.get("operator"))
+
     messages = storage.get_notes(
         limit=50,
         user_did=did,
@@ -61,17 +66,18 @@ def show_messages(request: Request, only_personal: bool = False):
 def post_message(
     request: Request,
     text: str = Form(...),
-    hidden: str = Form(default=None)
+    hidden: str = Form(default="false")
 ):
     did = request.session.get("did", "anon")
-    is_hidden = 1 if hidden else 0
+    is_hidden = 1 if hidden.lower() == "true" else 0
 
-    storage.write_note(
-        content=text,
-        user_did=did,
-        source="user",
-        hidden=is_hidden
-    )
+    if text.strip():
+        storage.write_note(
+            content=text.strip(),
+            user_did=did,
+            source="user",
+            hidden=is_hidden
+        )
     return RedirectResponse(url="/messages", status_code=303)
 
 @router.get("/login")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -12,7 +12,6 @@ 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 starlette.middleware.sessions import SessionMiddleware
 from agents.notebook.views import router as notebook_router
 from tools.storage import Storage
@@ -25,7 +24,6 @@ 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"))
 
-#app.include_router(auth_router)
 app.include_router(notebook_router)
 
 @app.on_event("startup")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/login.html

@@ -1,6 +1,14 @@
-<form method="post">
-  <label>Email: <input type="email" name="mail" required></label><br>
-  <label>Пароль: <input type="password" name="password" required></label><br>
-  <button type="submit">Войти</button>
-</form>
-Нет учетки: <a href="/register">зарегистрироваться</a>
+{% if error %}
+  <p style="color:red">{{ error }}</p>
+{% endif %}
+
+<table>
+ <caption>Вход</caption>
+ <form method="post">
+   <tr><th><label>Email:</th><td><input type="email" name="mail" required></label></td></tr>
+   <tr><th><label>Пароль:</th><td><input type="password" name="password" required></label></td></tr>
+   <tr><th colspan="2"><button type="submit">Войти</button></th></tr>
+ </form>
+</table>
+
+<hr>Нет учетки: <a href="/register">Зарегистрироваться</a>

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

@@ -25,10 +25,8 @@
 
     <form method="post">
         <textarea name="text" rows="3" cols="40" placeholder="Введите сообщение..."></textarea><br>
-        <label>
-            <input type="checkbox" name="hidden"> Скрыто
-        </label><br>
-        <button type="submit">Отправить</button>
+        <button name="hidden" value="false" type="submit">Отправить</button>
+        <button name="hidden" value="true" type="submit">Отправить приватно</button>
     </form>
 
     <hr>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/register.html

@@ -1,7 +1,15 @@
-<form method="post">
-  <label>Имя пользователя: <input type="text" name="username" required></label><br>
-  <label>Email: <input type="email" name="mail" required></label><br>
-  <label>Пароль: <input type="password" name="password" required></label><br>
-  <button type="submit">Зарегистрироваться</button>
-</form>
-Есть учетка: <a href="/login">войти</a>
+{% if error %}
+  <p style="color:red">{{ error }}</p>
+{% endif %}
+
+<table>
+ <caption>Регистрация</caption>
+ <form method="post">
+   <tr><th><label>Имя:</th><td><input type="text" name="username" required></label></td></tr>
+   <tr><th><label>Email:</th><td><input type="email" name="mail" required></label></td></tr>
+   <tr><th><label>Пароль:</th><td><input type="password" name="password" required></label></td></tr>
+   <tr><th colspan="2"><button type="submit">Зарегистрироваться</button></th></tr>
+ </form>
+</table>
+
+<hr>Есть учетка: <a href="/login">Войти</a>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -7,6 +7,9 @@ import json
 import uuid
 
 from datetime import datetime, timedelta, UTC
+from werkzeug.security import generate_password_hash, check_password_hash
+from tools.identity import generate_did
+from tools.crypto import generate_keypair
 
 SCRIPTS_BASE_PATH = "scripts"
 
@@ -747,21 +750,18 @@ class Storage:
         return [dict(row) for row in cursor.fetchall()]
 
     # Пользователи
-    def _hash_password(self, password: str) -> str:
-        return hashlib.sha256(password.encode()).hexdigest()
-
     def register_user(self, username: str, mail: str, password: str) -> bool:
         mail = mail.lower()
-        did = f"did:example:{uuid.uuid4()}"
+        did = generate_did()
         try:
             self.conn.execute(
                 "INSERT INTO users (username, mail, password_hash, did) VALUES (?, ?, ?, ?)",
-                (username, mail, self._hash_password(password), did)
+                (username, mail, generate_password_hash(password), did)
             )
             self.conn.commit()
             return True
         except sqlite3.IntegrityError:
-            return False  # уже существует (уникальность mail или did)
+            return False
 
     def authenticate_user(self, mail: str, password: str) -> bool:
         mail = mail.lower()
@@ -772,7 +772,7 @@ class Storage:
         )
         result = cursor.fetchone()
         if result:
-            return result["password_hash"] == self._hash_password(password)
+            return check_password_hash(result["password_hash"], password)
         return False
 
     def get_user_info(self, mail: str) -> dict | None:

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/config.yml

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/login.html

@@ -3,3 +3,4 @@
   <label>Пароль: <input type="password" name="password" required></label><br>
   <button type="submit">Войти</button>
 </form>
+Нет учетки: <a href="/register">зарегистрироваться</a>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/register.html

@@ -4,3 +4,4 @@
   <label>Пароль: <input type="password" name="password" required></label><br>
   <button type="submit">Зарегистрироваться</button>
 </form>
+Есть учетка: <a href="/login">войти</a>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/config.yml

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/login.html

@@ -1,14 +1,5 @@
-<!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>
+<form method="post">
+  <label>Email: <input type="email" name="mail" required></label><br>
+  <label>Пароль: <input type="password" name="password" required></label><br>
+  <button type="submit">Войти</button>
+</form>

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

@@ -20,11 +20,14 @@
             <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="{{ username }}">
+        <label>
+            <input type="checkbox" name="hidden"> Скрыто
+        </label><br>
         <button type="submit">Отправить</button>
     </form>
 
@@ -38,11 +41,15 @@
     <hr>
 
     {% for msg in messages %}
-        <div class="message source-{{ msg.source }} {% if msg.user_did == 'did:example:local-user' %}from-self{% endif %}">
+        <div class="message source-{{ msg.source }} {% if msg.user_did == request.session['did'] %}from-self{% endif %}">
             <div>
                 <strong>{{ msg.source }}</strong> — {{ msg.timestamp }}
                 {% if msg.hidden %}<span class="private"></span>{% endif %}
             </div>
+            <div>
+                от {{ msg.user_did[:10] }}...
+                {% if msg.username %}({{ msg.username }}){% endif %}
+            </div>
             <div>{{ msg.text }}</div>
         </div>
     {% endfor %}

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/register.html

@@ -1,14 +1,6 @@
-<!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>
+<form method="post">
+  <label>Имя пользователя: <input type="text" name="username" required></label><br>
+  <label>Email: <input type="email" name="mail" required></label><br>
+  <label>Пароль: <input type="password" name="password" required></label><br>
+  <button type="submit">Зарегистрироваться</button>
+</form>

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

@@ -1,14 +1,8 @@
-# agents/notebook/views.py
-
-from fastapi import APIRouter, Request, Form, Depends
+from fastapi import APIRouter, Request, Form
 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")
@@ -16,13 +10,14 @@ storage = Storage()
 
 @router.get("/chat")
 def chat_page(request: Request):
-    username = request.session.get("user")
-    if not username:
+    did = request.session.get("did")
+    username = request.session.get("username")
+    if not did:
         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,)
+        (did,)
     )
     return templates.TemplateResponse("chat.html", {
         "request": request,
@@ -32,24 +27,26 @@ def chat_page(request: Request):
 
 @router.post("/chat")
 def submit_note(request: Request, message: str = Form(...)):
-    username = request.session.get("user", "anon")  # Можно вернуть anon, если не залогинен
+    did = request.session.get("did", "anon")
     if message.strip():
-        storage.execute(
-            "INSERT INTO notes (text, source, user_did) VALUES (?, ?, ?)",
-            (message.strip(), "user", username)
+        storage.write_note(
+            content=message.strip(),
+            user_did=did,
+            source="user"
         )
     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:
+    did = request.session.get("did")
+    username = request.session.get("username")
+    if not did:
         return RedirectResponse("/login", status_code=303)
 
     is_operator = False  # Пока не реализовано
     messages = storage.get_notes(
         limit=50,
-        user_did=username,
+        user_did=did,
         is_operator=is_operator,
         only_personal=only_personal
     )
@@ -57,21 +54,21 @@ def show_messages(request: Request, only_personal: bool = False):
         "request": request,
         "messages": messages,
         "only_personal": only_personal,
-        "username": username  # 👈 вот это
+        "username": username
     })
 
 @router.post("/messages")
 def post_message(
     request: Request,
     text: str = Form(...),
-    user_did: str = Form(default="anon"),
     hidden: str = Form(default=None)
 ):
+    did = request.session.get("did", "anon")
     is_hidden = 1 if hidden else 0
 
     storage.write_note(
         content=text,
-        user_did=user_did,
+        user_did=did,
         source="user",
         hidden=is_hidden
     )
@@ -82,13 +79,15 @@ 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)
+def login_user(request: Request, mail: str = Form(...), password: str = Form(...)):
+    if storage.authenticate_user(mail, password):
+        user_info = storage.get_user_info(mail)
+        request.session["username"] = user_info["username"]
+        request.session["did"] = user_info["did"]
+        return RedirectResponse("/messages", status_code=HTTP_303_SEE_OTHER)
     return templates.TemplateResponse("login.html", {
         "request": request,
-        "error": "Неверный логин или пароль"
+        "error": "Неверный email или пароль"
     })
 
 @router.get("/register")
@@ -96,13 +95,20 @@ 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)
+def register_user(
+    request: Request,
+    username: str = Form(...),
+    mail: str = Form(...),
+    password: str = Form(...)
+):
+    if storage.register_user(username, mail, password):
+        user_info = storage.get_user_info(mail)
+        request.session["username"] = user_info["username"]
+        request.session["did"] = user_info["did"]
+        return RedirectResponse("/messages", status_code=HTTP_303_SEE_OTHER)
     return templates.TemplateResponse("register.html", {
         "request": request,
-        "error": "Пользователь уже существует"
+        "error": "Пользователь с таким email уже существует"
     })
 
 @router.get("/logout")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -4,6 +4,7 @@ import hashlib
 import sqlite3
 import os
 import json
+import uuid
 
 from datetime import datetime, timedelta, UTC
 
@@ -17,7 +18,6 @@ class Storage:
         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
@@ -750,39 +750,46 @@ class Storage:
     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()
+    def register_user(self, username: str, mail: str, password: str) -> bool:
+        mail = mail.lower()
+        did = f"did:example:{uuid.uuid4()}"
         try:
             self.conn.execute(
-                "INSERT INTO users (username, password_hash) VALUES (?, ?)",
-                (username, self._hash_password(password))
+                "INSERT INTO users (username, mail, password_hash, did) VALUES (?, ?, ?, ?)",
+                (username, mail, self._hash_password(password), did)
             )
             self.conn.commit()
             return True
         except sqlite3.IntegrityError:
-            return False  # пользователь уже существует
+            return False  # уже существует (уникальность mail или did)
 
-    def authenticate_user(self, username: str, password: str) -> bool:
+    def authenticate_user(self, mail: str, password: str) -> bool:
+        mail = mail.lower()
         cursor = self.conn.cursor()
         cursor.execute(
-            "SELECT password_hash FROM users WHERE username = ?",
-            (username,)
+            "SELECT password_hash FROM users WHERE mail = ?",
+            (mail,)
         )
         result = cursor.fetchone()
         if result:
             return result["password_hash"] == self._hash_password(password)
         return False
 
+    def get_user_info(self, mail: str) -> dict | None:
+        mail = mail.lower()
+        cursor = self.conn.cursor()
+        cursor.execute(
+            "SELECT username, did FROM users WHERE mail = ?",
+            (mail,)
+        )
+        result = cursor.fetchone()
+        if result:
+            return {
+                "username": result["username"],
+                "did": result["did"]
+            }
+        return None
+
     # Утилиты
 
     def close(self):

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/login.html

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

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

@@ -1,18 +1,50 @@
-<!-- templates/messages.html -->
 <!DOCTYPE html>
 <html>
 <head>
-    <title>Отправка сообщения агенту</title>
+    <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>
-    <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>
+    <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="{{ username }}">
         <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>

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/register.html

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

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

@@ -1,50 +1,111 @@
 # agents/notebook/views.py
 
-from fastapi import APIRouter, Request, Form
+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()
 
-DID = "did:example:local-user"  # временно
-
 @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",
-        (DID,)
+        (username,)
     )
-    return templates.TemplateResponse("chat.html", {"request": request, "notes": notes})
+    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", DID)
+            (message.strip(), "user", username)
         )
     return RedirectResponse(url="/chat", status_code=303)
 
 @router.get("/messages")
-def show_messages(request: Request):
-    messages = storage.get_notes(limit=50)
+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
+        "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")
+    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"
+        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)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/requirements.txt

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -1,5 +1,6 @@
 # agents/tools/storage.py
 
+import hashlib
 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.conn.row_factory = sqlite3.Row
         self._init_db()
+        self._init_user_table()
 
     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"):
+    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)
-            VALUES (?, ?, ?, ?)
-        """, (content, user_did, source, timestamp))
+            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):
+    def get_notes(self, limit=50, user_did="anon", is_operator=False, only_personal=False):
         cursor = self.conn.cursor()
-        cursor.execute("""
-            SELECT text, source, user_did, timestamp FROM notes
-            WHERE hidden = 0
-            ORDER BY timestamp DESC
-            LIMIT ?
-        """, (limit,))
+
+        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):

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -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 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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/add_message.py

@@ -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):
+def add_message(content, source="cli", user_did="anon"):
     storage.write_note(
         content,
-        role=role,
         source=source,
-        user_did=user_did,
-        tags=[]
+        user_did=user_did
     )
-    print(f"[+] Сообщение от {role} ({source}) добавлено: {content}")
+    print(f"[+] Сообщение от {source} ({user_did}) добавлено: {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")
+    parser.add_argument("--user_did", default="anon")
     args = parser.parse_args()
 
-    add_message(args.role, args.content, args.source, args.user_did)
+    add_message(args.content, args.source, args.user_did)

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

@@ -6,7 +6,7 @@ from fastapi.templating import Jinja2Templates
 from tools.storage import Storage
 
 router = APIRouter()
-templates = Jinja2Templates(directory="agents/notebook/templates")
+templates = Jinja2Templates(directory="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
+    messages = storage.get_notes(limit=50)
     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"
+        source="user"
     )
     return RedirectResponse(url="/messages", status_code=303)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -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
+    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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -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"):
+    def write_note(self, content, user_did="anon", source="user"):
         timestamp = datetime.now(UTC).isoformat()
         self.conn.execute("""
-            INSERT INTO notes (text, role, user_did, source, timestamp)
-            VALUES (?, ?, ?, ?, ?)
-        """, (content, role, user_did, source, timestamp))
+            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, role, source, user_did, timestamp FROM notes
+            SELECT text, source, user_did, timestamp FROM notes
             WHERE hidden = 0
             ORDER BY timestamp DESC
             LIMIT ?

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/config.yml

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/config.yml

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/examples/config.yml

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

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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/init.py

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