Sync from GitHub with Git LFS

agents/notebook/templates/login.html

@@ -1,3 +1,7 @@
+{% if error %}
+  <p style="color:red">{{ error }}</p>
+{% endif %}
+
 <table>
  <caption>Вход</caption>
  <form method="post">

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>
-        <button type="submit">Отправить</button>
+        <button name="hidden" value="false" type="submit">Отправить</button>
+        <button name="hidden" value="true" type="submit">Отправить приватно</button>
     </form>
 
     <hr>

agents/notebook/templates/register.html

@@ -1,3 +1,7 @@
+{% if error %}
+  <p style="color:red">{{ error }}</p>
+{% endif %}
+
 <table>
  <caption>Регистрация</caption>
  <form method="post">

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

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/agents/notebook/templates/login.html

@@ -1,6 +1,10 @@
-<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>
+<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/agents/notebook/templates/messages.html

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

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

@@ -1,7 +1,11 @@
-<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>
+<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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/agents/init.py

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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