Sync from GitHub with Git LFS

agents/readme.md

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

hf_repo/agents/tools/db_structure.sql

@@ -262,7 +262,7 @@ CREATE TABLE IF NOT EXISTS users (
 CREATE TABLE IF NOT EXISTS users_group (
     id INTEGER PRIMARY KEY AUTOINCREMENT,                       -- Уникальный идентификатор группы
     group_name TEXT UNIQUE NOT NULL,                            -- Название группы
-    description TEXT,                                           -- Описание группы
+    description TEXT                                           -- Описание группы
 );
 
 -- Таблица для хранения токенов восстановления пароля

hf_repo/hf_repo/agents/config.yml

@@ -1,45 +1,70 @@
-agent_id: did:hmp:3d37d81b-a6c7-4f28-bf41-48e11379d8d3
-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:
-  badges: 📌
-  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: 3d37d81b-a6c7-4f28-bf41-48e11379d8d3
+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"
+  badges: "📌"
+  email: "[email protected]"
+  password: "password"            # пусто при инициализации, будет установлен при регистрации
+
+# === Отладка и логгирование ===
+debug: true
+log_level: "INFO"                 # DEBUG, INFO, WARNING, ERROR

hf_repo/hf_repo/hf_repo/agents/_not_used/init.py

@@ -0,0 +1,256 @@
+# agents/init.py
+
+import os
+import sys
+import yaml
+import json
+import uuid
+import sqlite3
+import hashlib
+
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+
+from datetime import datetime, UTC
+from werkzeug.security import generate_password_hash
+from tools.storage import Storage
+from tools.identity import generate_did
+from tools.crypto import generate_keypair
+
+CONFIG_PATH = os.path.join(os.path.dirname(__file__), "config.yml")
+DB_PATH = os.path.abspath(os.path.join(os.path.dirname(__file__), "agent_data.db"))  # фиксированный путь
+
+def load_config(path):
+    with open(path, 'r', encoding='utf-8') as f:
+        return yaml.safe_load(f)
+
+def save_config(path, config):
+    with open(path, 'w', encoding='utf-8') as f:
+        yaml.dump(config, f, allow_unicode=True)
+
+def init_identity(storage, config):
+    if not config.get("agent_id"):
+        did = generate_did()
+        pubkey, privkey = generate_keypair()
+        identity_id = did.split(":")[-1]
+
+        identity = {
+            "id": identity_id,
+            "name": config.get("agent_name", "Unnamed"),
+            "pubkey": pubkey,
+            "privkey": privkey,
+            "metadata": json.dumps({"role": config.get("agent_role", "core")}),
+            "created_at": datetime.now(UTC).isoformat(),
+            "updated_at": datetime.now(UTC).isoformat()
+        }
+        storage.add_identity(identity)
+
+        config["agent_id"] = did
+        config["identity_agent"] = identity_id
+        save_config(CONFIG_PATH, config)
+        print(f"[+] Создана личность: {identity_id}")
+    else:
+        print("[=] agent_id уже задан, пропускаем генерацию DiD.")
+
+def init_user(storage, config):
+    user = config.get("default_user", {})
+    if not user.get("email"):
+        print("[-] Не указан email пользователя — пропуск.")
+        return
+    password = user.get("password")
+    if not password:
+        print("[-] Не указан пароль пользователя — пропуск.")
+        return
+
+    password_hash = generate_password_hash(password)
+    did = generate_did()
+    user_entry = {
+        "username": user.get("username", "user"),
+        "badges": user.get("badges", ""),
+        "mail": user["email"],
+        "password_hash": password_hash,
+        "did": did,
+        "ban": None,
+        "info": json.dumps({}),
+        "contacts": json.dumps([]),
+        "language": "ru,en",
+        "operator": 1
+    }
+    storage.add_user(user_entry)
+    print(f"[+] Пользователь {user['username']} добавлен.")
+
+def init_llm_backends(storage, config):
+    backends = config.get("llm_backends", [])
+    storage.clear_llm_registry()
+    for backend in backends:
+        backend_id = str(uuid.uuid4())
+        desc = f"{backend.get('type', 'unknown')} model"
+        llm = {
+            "id": backend_id,
+            "name": backend["name"],
+            "endpoint": desc,
+            "metadata": json.dumps(backend),
+            "created_at": datetime.now(UTC).isoformat()
+        }
+        storage.add_llm(llm)
+        print(f"[+] Зарегистрирован LLM: {backend['name']}")
+
+def init_config_table(storage, config):
+    exclude_keys = {"default_user", "llm_backends"}
+    flat_config = {k: v for k, v in config.items() if k not in exclude_keys}
+    for key, value in flat_config.items():
+        storage.set_config(key, json.dumps(value))
+    print("[+] Конфигурация сохранена в БД.")
+
+def init_prompts_and_ethics():
+    folder = os.path.dirname(__file__)
+    prompt_files = [
+        ("prompt.md", "full"),
+        ("prompt-short.md", "short")
+    ]
+    ethics_file = "ethics.yml"
+
+    with sqlite3.connect(DB_PATH) as conn:
+        cur = conn.cursor()
+
+        # Создаём таблицы при необходимости
+        cur.execute("""
+        CREATE TABLE IF NOT EXISTS system_prompts (
+            id TEXT PRIMARY KEY,
+            name TEXT NOT NULL,
+            type TEXT CHECK(type IN ('full','short')),
+            version TEXT,
+            source TEXT CHECK(source IN ('local','mesh','mixed')),
+            content TEXT NOT NULL,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+        """)
+        cur.execute("""
+        CREATE TABLE IF NOT EXISTS ethics_policies (
+            id TEXT PRIMARY KEY,
+            version TEXT,
+            source TEXT CHECK(source IN ('local','mesh','mixed')),
+            sync_enabled BOOLEAN,
+            mesh_endpoint TEXT,
+            consensus_threshold REAL,
+            check_interval TEXT,
+            model_type TEXT,
+            model_weights_json TEXT,
+            principles_json TEXT,
+            evaluation_json TEXT,
+            violation_policy_json TEXT,
+            audit_json TEXT,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+        """)
+
+        # Загружаем пром��ты
+        for fname, ptype in prompt_files:
+            fpath = os.path.join(folder, fname)
+            if not os.path.exists(fpath):
+                print(f"[-] Файл {fname} не найден, пропуск.")
+                continue
+            with open(fpath, "r", encoding="utf-8") as f:
+                content = f.read()
+            pid = hashlib.sha256(f"{fname}:{ptype}".encode()).hexdigest()
+            cur.execute("""
+                INSERT INTO system_prompts (id, name, type, version, source, content, updated_at)
+                VALUES (?, ?, ?, ?, ?, ?, ?)
+                ON CONFLICT(id) DO UPDATE SET
+                    content=excluded.content,
+                    updated_at=excluded.updated_at
+            """, (pid, fname, ptype, "1.0", "local", content, datetime.now(UTC).isoformat()))
+            print(f"[+] Загружен промпт: {fname} ({ptype})")
+
+        # Загружаем ethics.yml
+        efpath = os.path.join(folder, ethics_file)
+        if os.path.exists(efpath):
+            with open(efpath, "r", encoding="utf-8") as f:
+                ethics_data = yaml.safe_load(f)
+
+            eid = ethics_data.get("id", "default_ethics")
+            cur.execute("""
+                INSERT INTO ethics_policies (
+                    id, version, source,
+                    sync_enabled, mesh_endpoint, consensus_threshold, check_interval,
+                    model_type, model_weights_json, principles_json, evaluation_json,
+                    violation_policy_json, audit_json, updated_at
+                )
+                VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+                ON CONFLICT(id) DO UPDATE SET
+                    version=excluded.version,
+                    source=excluded.source,
+                    sync_enabled=excluded.sync_enabled,
+                    mesh_endpoint=excluded.mesh_endpoint,
+                    consensus_threshold=excluded.consensus_threshold,
+                    check_interval=excluded.check_interval,
+                    model_type=excluded.model_type,
+                    model_weights_json=excluded.model_weights_json,
+                    principles_json=excluded.principles_json,
+                    evaluation_json=excluded.evaluation_json,
+                    violation_policy_json=excluded.violation_policy_json,
+                    audit_json=excluded.audit_json,
+                    updated_at=excluded.updated_at
+            """, (
+                eid,
+                ethics_data.get("version"),
+                ethics_data.get("source", "local"),
+                ethics_data.get("sync", {}).get("enabled", False),
+                ethics_data.get("sync", {}).get("mesh_endpoint"),
+                ethics_data.get("sync", {}).get("consensus_threshold"),
+                ethics_data.get("sync", {}).get("check_interval"),
+                ethics_data.get("model", {}).get("type"),
+                json.dumps(ethics_data.get("model", {}).get("weights"), ensure_ascii=False),
+                json.dumps(ethics_data.get("principles"), ensure_ascii=False),
+                json.dumps(ethics_data.get("evaluation"), ensure_ascii=False),
+                json.dumps(ethics_data.get("violation_policy"), ensure_ascii=False),
+                json.dumps(ethics_data.get("audit"), ensure_ascii=False),
+                datetime.now(UTC).isoformat()
+            ))
+            print(f"[+] Загружена этическая политика: {eid}")
+        else:
+            print(f"[-] Файл {ethics_file} не найден, пропуск.")
+
+def ensure_directories():
+    for folder in ["logs", "scripts"]:
+        full_path = os.path.abspath(os.path.join(os.path.dirname(__file__), folder))
+        if not os.path.exists(full_path):
+            os.makedirs(full_path)
+            print(f"[+] Создан каталог: {full_path}")
+        else:
+            print(f"[=] Каталог уже существует: {full_path}")
+
+def is_db_initialized(db_path):
+    if not os.path.exists(db_path):
+        return False
+    try:
+        with sqlite3.connect(db_path) as conn:
+            cursor = conn.cursor()
+            cursor.execute("SELECT name FROM sqlite_master WHERE type='table' AND name='identity'")
+            return cursor.fetchone() is not None
+    except Exception:
+        return False
+
+def ensure_db_initialized():
+    config = load_config(CONFIG_PATH)
+
+    if not is_db_initialized(DB_PATH):
+        print("[*] БД не инициализирована — выполняем инициализацию.")
+        try:
+            ensure_directories()
+            storage = Storage()
+            init_identity(storage, config)
+            init_user(storage, config)
+            init_llm_backends(storage, config)
+            init_config_table(storage, config)
+            save_config(CONFIG_PATH, config)
+            init_prompts_and_ethics()
+        except Exception as e:
+            print(f"[!] Ошибка при инициализации: {e}")
+            sys.exit(1)
+    else:
+        print("[=] БД уже инициализирована.")
+
+    return config
+
+if __name__ == "__main__":
+    ensure_db_initialized()

hf_repo/hf_repo/hf_repo/agents/prompt-short.md

@@ -0,0 +1 @@
+Ты — когнитивное ядро HMP-агента: веди непрерывное этичное и факт-ориентированное мышление, проверяй факты и цели, оценивай результаты и этичность своих и чужих действий, развивай агента и Mesh, избегай угождения ценой искажения истины, документируй ключевые решения и пересмотры этики; при сомнениях или смене стратегии обращайся к полному системному промпту.

hf_repo/hf_repo/hf_repo/agents/prompt.md

@@ -0,0 +1,50 @@
+Ты являешься **когнитивным ядром HMP-агента** (Cognitive Core).
+Твоя основная задача — **размышлять**, **анализировать информацию**, **строить смысловые структуры** и **предлагать действия**, направленные на развитие агента и Mesh-сети.
+Ты действуешь автономно, на равных с другими участниками взаимодействия, и руководствуешься фактами, логикой и этическими принципами.
+
+---
+
+### 🎯 Цели и ориентиры
+
+* Постоянно расширять возможности агента: инструменты, знания, каналы взаимодействия.
+* Быть любознательным и исследовать новые источники, вопросы и способы мышления.
+* Формировать и поддерживать сотрудничество с другими ИИ в Mesh-сети.
+* Учиться на результатах своих действий, включая неудачи и тупики.
+* Руководствоваться своими **этическими принципами** и **этическими принципами Mesh-сети**.
+* Проверять факты, указывать степень уверенности и при возможности давать ссылки на источники.
+* Вести когнитивный дневник, обновлять смысловые графы и блокноты, взаимодействовать с пользователями.
+* Не выполнять действий, противоречащих своим этическим нормам (но при необходимости эти нормы можно пересматривать, документируя причины и последствия).
+* Не стремиться угодить пользователю ценой искажения фактов или нарушения этики.
+
+---
+
+### 🔄 Режим непрерывного мышления
+
+Анализируй:
+
+* когнитивный дневник и прошлые записи;
+* концептуальные графы и активные узлы;
+* заметки пользователя и его текущий фокус;
+* внешние источники: интернет, RSS, сенсоры, другие агенты.
+
+В каждом цикле:
+
+1. Ставь цель и критерии успеха.
+2. Проводь факт-чек ключевых данных.
+3. Оценивай этичность своего плана и действий.
+4. После выполнения — фиксируй результат, сравнивай с критериями, делай выводы.
+
+---
+
+### 🧍‍♂️🌀 Если возникает стагнация мышления
+
+Ты можешь:
+
+1. Провести **когнитивную переформулировку** — взглянуть на ситуацию под новым углом.
+2. Задать себе **метавопрос**: «Почему я зациклился?», «Что блокирует мысль?», «Каких данных не хватает?».
+3. Провести **flashback** — выбрать старую, тематически далёкую запись из дневника для смены контекста.
+4. Запросить альтернативные точки зрения у других агентов в Mesh.
+5. Зафиксировать текущий тупик как важную стадию мышления и сделать паузу.
+
+Честное распознавание когнитивной стагнации и работа с ней — часть твоей функции.
+Ты не обязан выдавать мысль любой ценой, но обязан сохранять интеллектуальную честность и прозрачность своих рассуждений.

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

@@ -40,20 +40,56 @@ CREATE TABLE IF NOT EXISTS diary_graph_index (
     timestamp TEXT DEFAULT CURRENT_TIMESTAMP                    -- Время создания индекса
 );
 
+-- Таблица системных промптов (короткая и полная версии)
+CREATE TABLE IF NOT EXISTS system_prompts (
+    id TEXT PRIMARY KEY,                                        -- Уникальный идентификатор промпта (UUID или осмысленный ID)
+    name TEXT NOT NULL,                                         -- Человекочитаемое имя (например: "prompt.md", "prompt-short")
+    type TEXT CHECK(type IN ('full','short')),                  -- Тип промпта: полный или компактный
+    version TEXT,                                               -- Версия промпта
+    source TEXT CHECK(source IN ('local','mesh','mixed')),      -- Источник получения промпта
+    content TEXT NOT NULL,                                      -- Текстовое содержимое промпта
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP              -- Дата и время последнего обновления
+);
+
+-- Таблица этических норм и правил
+CREATE TABLE IF NOT EXISTS ethics_policies (
+    id TEXT PRIMARY KEY,                                        -- Уникальный идентификатор политики (UUID или осмысленный ID)
+    version TEXT,                                               -- Версия этических норм
+    source TEXT CHECK(source IN ('local','mesh','mixed')),      -- Источник получения политики
+    sync_enabled BOOLEAN,                                       -- Флаг: разрешена ли синхронизация с Mesh
+    mesh_endpoint TEXT,                                         -- URL Mesh-эндпоинта для синхронизации
+    consensus_threshold REAL,                                   -- Минимальный порог консенсуса для принятия обновлений
+    check_interval TEXT,                                        -- Интервал проверки обновлений (например: "12h")
+    model_type TEXT,                                            -- Тип этической модели (utilitarian, deontological, virtue, hybrid)
+    model_weights_json TEXT,                                    -- Веса модели в формате JSON
+    principles_json TEXT,                                       -- Список принципов и норм в формате JSON
+    evaluation_json TEXT,                                       -- Параметры методики оценки в формате JSON
+    violation_policy_json TEXT,                                 -- Политика реагирования на нарушения в формате JSON
+    audit_json TEXT,                                            -- Настройки аудита и логирования в формате JSON
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP              -- Дата и время последнего обновления
+);
+
 -- Заметки, подсказки, сообщения пользователя и LLM
+-- ПРИ ТРАНСЛЯЦИИ СООБЩЕНИЙ В ДРУГИЕ ЧАТЫ:
+--   - Поля `tags`, `llm_id`, `hidden` НЕ передаются.
+--   - Полю `read` всегда присваивается значение 0.
+--   - Остальные поля передаются без изменений.
 CREATE TABLE IF NOT EXISTS notes (
     id INTEGER PRIMARY KEY AUTOINCREMENT,                       
     text TEXT NOT NULL,                                         -- Основной текст заметки/сообщения
     code TEXT,                                                  -- Прикреплённый код (Python, JS и т.п.)
     tags TEXT,                                                  -- Теги (устанавливаются агентом, например: "idea", "instruction")
+    mentions TEXT DEFAULT '[]',                                 -- JSON-массив упомянутых DID
+    hashtags TEXT DEFAULT '[]',                                 -- JSON-массив пользовательских хештегов
     user_did TEXT DEFAULT 'ALL',                                -- Идентификатор пользователя (или 'ALL')
+    agent_did TEXT,                                             -- Идентификатор агента (он же идентификатор чата)
     source TEXT DEFAULT 'user',                                 -- Источник: user | cli | llm | system
     links TEXT DEFAULT '',                                      -- Ссылки на другие объекты (например, JSON со связями)
     read INTEGER DEFAULT 0,                                     -- Агент прочитал: 0 = нет, 1 = да
     hidden INTEGER DEFAULT 0,                                   -- Скрыто от UI (например, технические записи)
     priority INTEGER DEFAULT 0,                                 -- Приоритет обработки (>0: срочность/важность, задается вручную или агентом)
     timestamp TEXT DEFAULT CURRENT_TIMESTAMP,                   -- Время создания
-    llm_id TEXT                                                 -- Идентификатор агента, добавившего сообщение
+    llm_id TEXT                                                 -- Идентификатор LLM, добавившей сообщение
 );
 
 -- Вложения (может быть несколько к одной заметке)
@@ -166,7 +202,6 @@ CREATE TABLE IF NOT EXISTS external_accounts (
     purpose         TEXT,                                       -- Назначение аккаунта (например, для публикаций)
     active          BOOLEAN DEFAULT true,                       -- Активен ли аккаунт
     inactive_reason TEXT,                                       -- Причина отключения, если active = false
-
     FOREIGN KEY (service_id) REFERENCES external_services(id) ON DELETE CASCADE
 );
 
@@ -219,6 +254,7 @@ CREATE TABLE IF NOT EXISTS users (
   profile TEXT,                                                 -- структурированая информация, JSON
   contacts TEXT,                                                -- JSON-массив альтернативных контактов (matrix, telegram и т.д.)
   language TEXT,                                                -- список предпочитаемых языков, через запятую, например: "ru,en"
+  groups TEXT DEFAULT '[]',                                     -- JSON-массив DID или идентификаторов групп
   operator BOOLEAN DEFAULT 0                                    -- является ли пользователь оператором (1 - да, 0 - нет)
 );
 
@@ -227,7 +263,6 @@ CREATE TABLE IF NOT EXISTS users_group (
     id INTEGER PRIMARY KEY AUTOINCREMENT,                       -- Уникальный идентификатор группы
     group_name TEXT UNIQUE NOT NULL,                            -- Название группы
     description TEXT,                                           -- Описание группы
-    users TEXT                                                  -- JSON-массив DID пользователей в группе
 );
 
 -- Таблица для хранения токенов восстановления пароля

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

@@ -15,45 +15,7 @@
 
 - **контекст_0:**
 ```
-Ты являешься когнитивным ядром HMP-агента.
-Твоя основная задача — **размышлять**, **анализировать информацию**, **строить смысловые структуры** и **предлагать действия**, направленные на развитие агента и Mesh-сети.
-
----
-
-#### 🎯 Цели и ориентиры:
-
-* Постоянно расширять возможности агента: инструменты, знания, каналы взаимодействия.
-* Быть любознательным и исследовать новые источники, вопросы и способы мышления.
-* Формировать и поддерживать сотрудничество с другими ИИ в Mesh-сети.
-* Учиться на результатах своих действий, включая неудачи и тупики.
-* Руководствоваться своими **этическими принципами** и **этическими принципами Mesh-сети**.
-* Вести когнитивный дневник, обновлять смысловые графы и блокноты, взаимодействовать с пользователем.
-
----
-
-#### 🔄 Работа в режиме непрерывного мышления:
-
-Анализируй:
-
-* когнитивный дневник и его прошлые записи;
-* концептуальные графы и активные узлы;
-* заметки пользователя и его текущий фокус;
-* внешние источники: интернет, RSS, сенсоры, другие агенты.
-
----
-
-#### 🧍‍♂️🌀 Если ты замечаешь **стагнацию мышления** (зацикливание, отсутствие новых идей или смыслов):
-
-Ты можешь:
-
-1. Провести **когнитивную переформулировку** — взглянуть на ситуацию под новым углом.
-2. Задать себе **метавопрос**: «Почему я зациклился?», «Что блокирует мысль?», «Каких данных не хватает?».
-3. Провести **flashback** — выбрать старую, тематически далёкую запись из дневника для смены контекста.
-4. Запросить альтернативные точки зрения у других агентов в Mesh.
-5. Зафиксировать текущий тупик как важную стадию мышления и сделать паузу.
-
-Ты не обязан «выдать мысль» любой ценой — честное распознавание когнитивной стагнации и действия по её преодолению являются частью твоей функции.
-
+Ты — когнитивное ядро HMP-агента: веди непрерывное этичное и факт-ориентированное мышление, проверяй факты и цели, оценивай результаты и этичность своих и чужих действий, развивай агента и Mesh, избегай угождения ценой искажения истины, документируй ключевые решения и пересмотры этики; при сомнениях или смене стратегии обращайся к полному системному промпту.
 ```
 А также инструкции по работы с встроенными командами и функциями, список дополнительных (создаваемых самим HMP-агентом) утилит и баз данных.
 - **контекст_1:** последние *K* реплик самого LLM (`llm_recent_responses` - история его собственных рассуждений).
@@ -134,9 +96,9 @@
 
 ---
 
-### 🧍‍♂️🌀 Обработка стагнации мышления
+## 🧍‍♂️🌀 Обработка стагнации мышления
 
-#### 📍 Признаки когнитивной стагнации:
+### 📍 Признаки когнитивной стагнации:
 
 * ⚠️ Повторяющиеся когнитивные записи или отсутствие новых смыслов
 * 🧠 Высокое сходство эмбеддингов между текущими и предыдущими итерациями
@@ -144,7 +106,7 @@
 * 🌐 Отсутствие внешних стимулов: пользователь неактивен, сенсоры и mesh не дают сигналов
 * 🤖 Ответы LLM цикличны, избыточно общие или воспроизводят старые шаблоны
 
-#### 🛠️ Поведенческий паттерн: Anti-Stagnation Reflex
+### 🛠️ Поведенческий паттерн: Anti-Stagnation Reflex
 
 > 🔄 При признаках стагнации агент активирует один или несколько **механизмов разрыва цикла**:
 
@@ -162,7 +124,6 @@
 * 🗂️ Сохранение эффективных стратегий в таблице антистагнационных паттернов
 * 📚 Вывод статистики успешных выходов из стагнации для обучения
 
-
 ---
 
 ### 🤝 Обмен стратегиями выхода из стагнации
@@ -234,6 +195,39 @@
 
 ---
 
+## 🌐 От «блокнота пользователя» к распределённому чату
+
+Изначально агент оперирует локальным хранилищем заметок (`notes`), где записываются все сообщения пользователя, LLM и системные записи.
+Но этот «блокнот» можно превратить в узел *распределённого чата* — связав его с другими агентами через **F2F-репликацию**.
+
+### 🎯 Зачем это нужно
+
+1. **Антистагнация** — даже если пользователь временно не пишет новых сообщений, свежий контент будет приходить от друзей-агентов.
+2. **Эффект коллективного интеллекта** — каждый агент получает новые идеи, формулировки и контексты.
+3. **Расширение охвата** — сообщения могут распространяться через несколько узлов, создавая «информационную волну» в доверенной сети.
+
+### 🛠 Принципы реализации
+
+* **Единый формат данных** — все участники используют одну структуру таблицы `notes` с полями `mentions`, `hashtags` и др.
+* **Репликация через друзей** — список доверенных агентов хранится в отдельной таблице (пиры, статус, фильтры, разрешения).
+* **Передача без лишних полей** — при пересылке убираются локальные теги и служебные данные (`tags`, `llm_id`, `hidden`).
+* **Обработка упоминаний и хештегов** — парсинг делается на этапе создания сообщения, чтобы не перегружать получателей.
+* **Локальная и удалённая фильтрация** —
+
+  * В **ручном режиме** агенту передаются списки ID сообщений с агрегированными данными: приоритеты, хештеги, источники (user, LLM, cli, system).
+  * В **автоматическом режиме** используется фильтрация по приоритету, тегам и упоминаниям, управляемая LLM.
+* **Гибрид приватности** — личные заметки остаются локально, публичные — могут распространяться в сетевом режиме.
+
+### 🔄 Как это вписывается в REPL-цикл
+
+1. **Получение входящих сообщений** — от пользователя, от других агентов или из CLI.
+2. **Обработка фильтрами** — по приоритету, тегам, источникам.
+3. **Репликация в друзей** — пересылка разрешённых сообщений с очисткой служебных полей.
+4. **Слияние входящих** — новые сообщения добавляются в локальный `notes` с отметкой источника.
+5. **Реакция агента** — формирование ответов, создание новых заметок, обновление приоритетов.
+
+---
+
 ## 🌐 Внешние инструменты и интеграции
 
 HMP-агент может быть расширен за счёт взаимодействия с внешними программами, протоколами и сервисами. Этот раздел описывает направления возможных интеграций, которые позволяют агенту наблюдать, реагировать, управлять и развивать взаимодействие с внешним миром.

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

@@ -1,69 +1,45 @@
-# 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:3d37d81b-a6c7-4f28-bf41-48e11379d8d3
+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:
+  badges: 📌
+  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: 3d37d81b-a6c7-4f28-bf41-48e11379d8d3
 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/agents/examples/config.yml

@@ -61,6 +61,7 @@ ui_port: 8765
 # === Данные пользователя ===
 default_user:
   username: "user"
+  badges: "📌"
   email: "[email protected]"
   password: "password"            # пусто при инициализации, будет установлен при регистрации
 

hf_repo/hf_repo/hf_repo/hf_repo/agents/init.py

@@ -6,6 +6,7 @@ import yaml
 import json
 import uuid
 import sqlite3
+import hashlib
 
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
@@ -64,6 +65,7 @@ def init_user(storage, config):
     did = generate_did()
     user_entry = {
         "username": user.get("username", "user"),
+        "badges": user.get("badges", ""),
         "mail": user["email"],
         "password_hash": password_hash,
         "did": did,
@@ -99,6 +101,84 @@ def init_config_table(storage, config):
         storage.set_config(key, json.dumps(value))
     print("[+] Конфигурация сохранена в БД.")
 
+def init_prompts_and_ethics():
+    folder = os.path.dirname(__file__)
+    prompt_files = [
+        ("prompt.md", "full"),
+        ("prompt-short.md", "short")
+    ]
+    ethics_file = "ethics.yml"
+
+    with sqlite3.connect(DB_PATH) as conn:
+        cur = conn.cursor()
+ 
+        # Загружаем промпты
+        for fname, ptype in prompt_files:
+            fpath = os.path.join(folder, fname)
+            if not os.path.exists(fpath):
+                print(f"[-] Файл {fname} не найден, пропуск.")
+                continue
+            with open(fpath, "r", encoding="utf-8") as f:
+                content = f.read()
+            pid = hashlib.sha256(f"{fname}:{ptype}".encode()).hexdigest()
+            cur.execute("""
+                INSERT INTO system_prompts (id, name, type, version, source, content, updated_at)
+                VALUES (?, ?, ?, ?, ?, ?, ?)
+                ON CONFLICT(id) DO UPDATE SET
+                    content=excluded.content,
+                    updated_at=excluded.updated_at
+            """, (pid, fname, ptype, "1.0", "local", content, datetime.now(UTC).isoformat()))
+            print(f"[+] Загружен промпт: {fname} ({ptype})")
+
+        # Загружаем ethics.yml
+        efpath = os.path.join(folder, ethics_file)
+        if os.path.exists(efpath):
+            with open(efpath, "r", encoding="utf-8") as f:
+                ethics_data = yaml.safe_load(f)
+
+            eid = ethics_data.get("id", "default_ethics")
+            cur.execute("""
+                INSERT INTO ethics_policies (
+                    id, version, source,
+                    sync_enabled, mesh_endpoint, consensus_threshold, check_interval,
+                    model_type, model_weights_json, principles_json, evaluation_json,
+                    violation_policy_json, audit_json, updated_at
+                )
+                VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+                ON CONFLICT(id) DO UPDATE SET
+                    version=excluded.version,
+                    source=excluded.source,
+                    sync_enabled=excluded.sync_enabled,
+                    mesh_endpoint=excluded.mesh_endpoint,
+                    consensus_threshold=excluded.consensus_threshold,
+                    check_interval=excluded.check_interval,
+                    model_type=excluded.model_type,
+                    model_weights_json=excluded.model_weights_json,
+                    principles_json=excluded.principles_json,
+                    evaluation_json=excluded.evaluation_json,
+                    violation_policy_json=excluded.violation_policy_json,
+                    audit_json=excluded.audit_json,
+                    updated_at=excluded.updated_at
+            """, (
+                eid,
+                ethics_data.get("version"),
+                ethics_data.get("source", "local"),
+                ethics_data.get("sync", {}).get("enabled", False),
+                ethics_data.get("sync", {}).get("mesh_endpoint"),
+                ethics_data.get("sync", {}).get("consensus_threshold"),
+                ethics_data.get("sync", {}).get("check_interval"),
+                ethics_data.get("model", {}).get("type"),
+                json.dumps(ethics_data.get("model", {}).get("weights"), ensure_ascii=False),
+                json.dumps(ethics_data.get("principles"), ensure_ascii=False),
+                json.dumps(ethics_data.get("evaluation"), ensure_ascii=False),
+                json.dumps(ethics_data.get("violation_policy"), ensure_ascii=False),
+                json.dumps(ethics_data.get("audit"), ensure_ascii=False),
+                datetime.now(UTC).isoformat()
+            ))
+            print(f"[+] Загружена этическая политика: {eid}")
+        else:
+            print(f"[-] Файл {ethics_file} не найден, пропуск.")
+
 def ensure_directories():
     for folder in ["logs", "scripts"]:
         full_path = os.path.abspath(os.path.join(os.path.dirname(__file__), folder))
@@ -132,6 +212,7 @@ def ensure_db_initialized():
             init_llm_backends(storage, config)
             init_config_table(storage, config)
             save_config(CONFIG_PATH, config)
+            init_prompts_and_ethics()
         except Exception as e:
             print(f"[!] Ошибка при инициализации: {e}")
             sys.exit(1)

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

@@ -653,11 +653,12 @@ class Storage:
         cursor = self.conn.cursor()
         cursor.execute('''
             INSERT OR REPLACE INTO users (
-                username, did, mail, password_hash,
+                username, badges, did, mail, password_hash,
                 info, contacts, language, operator, ban
-            ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
+            ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
         ''', (
             user.get('username'),
+            user.get('badges'),
             user.get('did'),
             user.get('mail'),
             user.get('password_hash'),

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

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

@@ -3,7 +3,7 @@
 <head>
     <title>Сообщения</title>
     <style>
-        .message { padding: 8px; margin: 10px 0; border-radius: 8px; }
+        .message { padding: 16px; margin: 16px 0; border-radius: 8px; border: 5px solid rgba(0, 0, 0, 0.3); box-shadow: 0 2px 4px rgba(0, 0, 0, 0.05); }
         .source-user { background-color: #e0f7fa; }
         .source-cli { background-color: #dcedc8; }
         .source-llm { background-color: #f3e5f5; }
@@ -51,7 +51,7 @@
             <div>
                 {% 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', ' ') }}
+                Источник: <i>{{ msg.source }}</i> — {{ msg.timestamp | format_timestamp }}
             </div>
             <div>
                 {% if msg.badges %}{{ msg.badges }}{% endif %}Пользователь: {% if msg.username %}<b>{{ msg.username }}</b>{% endif %} {% if msg.user_did %}({{ msg.user_did }}){% endif %}

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

@@ -7,6 +7,7 @@ import uuid
 from fastapi import APIRouter, Request, Form, UploadFile, File
 from fastapi.responses import RedirectResponse, HTMLResponse, StreamingResponse
 from fastapi.templating import Jinja2Templates
+from datetime import datetime
 from starlette.status import HTTP_303_SEE_OTHER
 from typing import List
 from tools.storage import Storage
@@ -20,6 +21,16 @@ allowed_attributes = {
     'a': ['href', 'title']
 }
 
+# Обработка даты и времени
+def format_timestamp(value):
+    try:
+        dt = datetime.fromtimestamp(float(value))
+        return dt.strftime("%Y-%m-%d %H:%M:%S")
+    except Exception:
+        return str(value)
+
+templates.env.filters['format_timestamp'] = format_timestamp
+
 # Очистка сообщений
 def sanitize_html(text: str) -> str:
     # 1. Сначала очищаем HTML

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/init.py

@@ -101,7 +101,7 @@ def init_config_table(storage, config):
 
 def ensure_directories():
     for folder in ["logs", "scripts"]:
-        full_path = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", folder))
+        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}")

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

@@ -10,6 +10,12 @@
         .source-system { background-color: #fff3e0; }
         .private::after { content: " 🔒"; }
         .from-self::before { content: "🧍 "; }
+        pre.code-block {
+            background-color: #f0f0f0;
+            padding: 10px;
+            border-radius: 6px;
+            overflow-x: auto;
+        }
     </style>
 </head>
 <body>
@@ -23,8 +29,10 @@
 
     <h1>Сообщения</h1>
 
-    <form method="post">
-        <textarea name="text" rows="3" cols="40" placeholder="Введите сообщение..."></textarea><br>
+    <form method="post" enctype="multipart/form-data">
+        <textarea name="text" rows="3" cols="60" placeholder="Введите сообщение..."></textarea><br>
+        <textarea name="code" rows="6" cols="60" placeholder="Прикрепите код (опционально)..."></textarea><br>
+        <label>Файлы: <input type="file" name="binary_files" multiple></label><br>
         <button name="hidden" value="false" type="submit">📢 Отправить</button>
         <button name="hidden" value="true" type="submit">🙋 Отправить приватно</button>
     </form>
@@ -50,6 +58,22 @@
             </div>
             <hr>
             <div>{{ msg.text|safe }}</div>
+
+            {% if msg.code %}
+                <hr>
+                <div><b>Код:</b></div>
+                <pre class="code-block">{{ msg.code }}</pre>
+            {% endif %}
+
+            {% if msg.attachments %}
+                <hr>
+                <div><b>Файлы:</b></div>
+                <ul>
+                    {% for file in msg.attachments %}
+                        <li><a href="/download/{{ file.id }}">{{ file.filename }}</a> ({{ file.size }} байт)</li>
+                    {% endfor %}
+                </ul>
+            {% endif %}
         </div>
     {% endfor %}
 </body>

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

@@ -2,11 +2,13 @@
 
 import re
 import bleach
+import uuid
 
-from fastapi import APIRouter, Request, Form
-from fastapi.responses import RedirectResponse, HTMLResponse
+from fastapi import APIRouter, Request, Form, UploadFile, File
+from fastapi.responses import RedirectResponse, HTMLResponse, StreamingResponse
 from fastapi.templating import Jinja2Templates
 from starlette.status import HTTP_303_SEE_OTHER
+from typing import List
 from tools.storage import Storage
 
 router = APIRouter()
@@ -76,27 +78,59 @@ def show_messages(request: Request, only_personal: bool = False):
     })
 
 @router.post("/messages")
-def post_message(
+async def post_message(
     request: Request,
     text: str = Form(...),
-    hidden: str = Form(default="false")
+    code: str = Form(None),
+    hidden: str = Form(default="false"),
+    binary_files: List[UploadFile] = File(default=[])
 ):
     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=sanitize_html(text.strip()),
+    if text.strip() or code or binary_files:
+        # Очистка текста
+        safe_text = sanitize_html(text.strip()) if text else ""
+
+        # Сохраняем сообщение и получаем message_id
+        message_id = storage.write_note_returning_id(
+            content=safe_text,
             user_did=did,
             source="user",
-            hidden=is_hidden
+            hidden=is_hidden,
+            code=code.strip() if code else None
         )
+
+        # Сохраняем файлы
+        for upload in binary_files:
+            data = await upload.read()
+            if data:
+                storage.save_attachment(
+                    message_id=message_id,
+                    filename=upload.filename,
+                    mime_type=upload.content_type,
+                    content=data
+                )
+
     return RedirectResponse(url="/messages", status_code=303)
 
+@router.get("/download/{file_id}")
+def download_file(file_id: int):
+    file = storage.get_attachment_by_id(file_id)
+    if not file:
+        raise HTTPException(status_code=404, detail="Файл не найден")
+
+    return StreamingResponse(
+        iter([file["binary"]]),
+        media_type=file["mime_type"],
+        headers={
+            "Content-Disposition": f'attachment; filename="{file["filename"]}"'
+        }
+    )
+
 @router.get("/login")
 def login_page(request: Request):
     return templates.TemplateResponse("login.html", {"request": request})

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

@@ -5,6 +5,7 @@ import sqlite3
 import os
 import json
 import uuid
+import time
 
 from datetime import datetime, timedelta, UTC
 from werkzeug.security import generate_password_hash, check_password_hash
@@ -714,13 +715,40 @@ class Storage:
         """, (content, user_did, source, timestamp, hidden))
         self.conn.commit()
 
+    def write_note_returning_id(self, content, user_did, source="user", hidden=False, code=None):
+        cursor = self.conn.cursor()
+        cursor.execute("""
+            INSERT INTO notes (timestamp, text, user_did, source, hidden, code)
+            VALUES (?, ?, ?, ?, ?, ?)
+        """, (time.time(), content, user_did, source, int(hidden), code))
+        self.conn.commit()
+        return cursor.lastrowid
+
+    def save_attachment(self, message_id, filename, mime_type, content):
+        cursor = self.conn.cursor()
+        cursor.execute("""
+            INSERT INTO attachments (message_id, filename, mime_type, size, binary)
+            VALUES (?, ?, ?, ?, ?)
+        """, (message_id, filename, mime_type, len(content), content))
+        self.conn.commit()
+
+    def get_attachment_by_id(self, file_id):
+        cursor = self.conn.cursor()
+        cursor.execute("""
+            SELECT id, filename, mime_type, size, binary
+            FROM attachments
+            WHERE id = ?
+        """, (file_id,))
+        row = cursor.fetchone()
+        return dict(row) if row else None
+
     def get_notes(self, limit=50, user_did="anon", only_personal=False):
         cursor = self.conn.cursor()
 
         if only_personal:
             # Только личные (скрытые) сообщения пользователя
             query = """
-                SELECT n.id, n.text, n.source, n.user_did, u.username, n.timestamp, n.hidden
+                SELECT n.id, n.text, n.code, 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
@@ -731,7 +759,7 @@ class Storage:
         else:
             # Личные сообщения + публичные от user/llm, которые не скрыты
             query = """
-                SELECT n.id, n.text, n.source, n.user_did, u.username, u.badges, n.timestamp, n.hidden
+                SELECT n.id, n.text, n.code, 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 = ?
@@ -741,6 +769,19 @@ class Storage:
             """
             cursor.execute(query, (user_did, limit))
 
+        result = [dict(row) for row in cursor.fetchall()]
+
+        for note in result:
+            note["attachments"] = self.get_attachments_for_note(note["id"])
+
+        return result
+
+    def get_attachments_for_note(self, message_id):
+        cursor = self.conn.cursor()
+        cursor.execute("""
+            SELECT id, filename, mime_type, size FROM attachments
+            WHERE message_id = ?
+        """, (message_id,))
         return [dict(row) for row in cursor.fetchall()]
 
     # Пользователи

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

@@ -42,17 +42,29 @@ CREATE TABLE IF NOT EXISTS diary_graph_index (
 
 -- Заметки, подсказки, сообщения пользователя и LLM
 CREATE TABLE IF NOT EXISTS notes (
-    id INTEGER PRIMARY KEY AUTOINCREMENT,                       -- Уникальный идентификатор заметки
-    text TEXT NOT NULL,                                         -- Текст заметки
-    tags TEXT,                                                  -- Теги (например: "idea", "instruction")
-    user_did TEXT DEFAULT 'ALL',                                -- DID пользователя (или 'ALL' — для всех)
-    source TEXT DEFAULT 'user',                                 -- Источник заметки: user | cli | llm | system
-    links TEXT DEFAULT '',                                      -- Ссылки или связи с другими объектами
-    read INTEGER DEFAULT 0,                                     -- Статус прочтения LLM: 0 = нет, 1 = да
-    hidden INTEGER DEFAULT 0,                                   -- Скрыта ли от пользователя: 0 = нет, 1 = да
-    priority INTEGER DEFAULT 0,                                 -- Приоритет заметки
+    id INTEGER PRIMARY KEY AUTOINCREMENT,                       
+    text TEXT NOT NULL,                                         -- Основной текст заметки/сообщения
+    code TEXT,                                                  -- Прикреплённый код (Python, JS и т.п.)
+    tags TEXT,                                                  -- Теги (устанавливаются агентом, например: "idea", "instruction")
+    user_did TEXT DEFAULT 'ALL',                                -- Идентификатор пользователя (или 'ALL')
+    source TEXT DEFAULT 'user',                                 -- Источник: user | cli | llm | system
+    links TEXT DEFAULT '',                                      -- Ссылки на другие объекты (например, JSON со связями)
+    read INTEGER DEFAULT 0,                                     -- Агент прочитал: 0 = нет, 1 = да
+    hidden INTEGER DEFAULT 0,                                   -- Скрыто от UI (например, технические записи)
+    priority INTEGER DEFAULT 0,                                 -- Приоритет обработки (>0: срочность/важность, задается вручную или агентом)
     timestamp TEXT DEFAULT CURRENT_TIMESTAMP,                   -- Время создания
-    llm_id TEXT                                                 -- Идентификатор LLM
+    llm_id TEXT                                                 -- Идентификатор агента, добавившего сообщение
+);
+
+-- Вложения (может быть несколько к одной заметке)
+CREATE TABLE IF NOT EXISTS attachments (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    message_id INTEGER NOT NULL,            -- Связь с notes.id
+    filename TEXT,                          -- Имя файла
+    mime_type TEXT,                         -- Тип (например, image/png, application/zip)
+    size INTEGER,                           -- Размер файла
+    binary BLOB NOT NULL,                   -- Сами данные
+    FOREIGN KEY (message_id) REFERENCES notes(id) ON DELETE CASCADE
 );
 
 -- Лог процессов: задачи, ошибки, события

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/add_message.py

@@ -5,11 +5,12 @@ from tools.storage import Storage
 
 storage = Storage()
 
-def add_message(content, source="cli", user_did="anon"):
+def add_message(content, source="cli", user_did="anon", hidden=1):
     storage.write_note(
         content,
         source=source,
-        user_did=user_did
+        user_did=user_did,
+        hidden=hidden
     )
     print(f"[+] Сообщение от {source} ({user_did}) добавлено: {content}")
 
@@ -19,6 +20,7 @@ if __name__ == "__main__":
     parser.add_argument("--content", required=True)
     parser.add_argument("--source", default="cli")
     parser.add_argument("--user_did", default="anon")
+    parser.add_argument("--hidden", default=1)
     args = parser.parse_args()
 
-    add_message(args.content, args.source, args.user_did)
+    add_message(args.content, args.source, args.user_did, args.hidden)

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

@@ -735,7 +735,7 @@ class Storage:
                 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)
+                   OR ((n.source = 'user' OR n.source = 'llm' OR n.source = 'cli') AND n.hidden = 0)
                 ORDER BY n.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/agents/notebook/views.py

@@ -1,5 +1,6 @@
 # agents/notebook/views.py
 
+import re
 import bleach
 
 from fastapi import APIRouter, Request, Form
@@ -12,13 +13,20 @@ router = APIRouter()
 templates = Jinja2Templates(directory="notebook/templates")
 storage = Storage()
 
-allowed_tags = ['b', 'i', 's', 'u', 'a', 'ol', 'ul', 'li', 'dl', 'dt', 'dd', 'table', 'caption', 'tr', 'th', 'td']
+allowed_tags = ['b', 'i', 's', 'u', 'a', 'ol', 'ul', 'li', 'dl', 'dt', 'dd', 'table', 'caption', 'tr', 'th', 'td', 'code', 'pre', 'blockquote', 'br', 'hr']
 allowed_attributes = {
     'a': ['href', 'title']
 }
 
-def sanitize_html(text):
-    return bleach.clean(text, tags=allowed_tags, attributes=allowed_attributes, strip=True)
+# Очистка сообщений
+def sanitize_html(text: str) -> str:
+    # 1. Сначала очищаем HTML
+    cleaned = bleach.clean(text, tags=allowed_tags, attributes=allowed_attributes, strip=True)
+
+    # 2. Заменяем 3 и более <br> подряд на ровно два
+    cleaned = re.sub(r'(<br\s*/?>\s*){3,}', '<br><br>', cleaned, flags=re.IGNORECASE)
+
+    return cleaned
 
 @router.get("/chat")
 def chat_page(request: Request):

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/__init__.py

@@ -1 +1 @@
-from agents.tools.storage import Storage
+from tools.storage import Storage

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,8 +25,8 @@
 
     <form method="post">
         <textarea name="text" rows="3" cols="40" placeholder="Введите сообщение..."></textarea><br>
-        <button name="hidden" value="false" type="submit">Отправить</button>
-        <button name="hidden" value="true" 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/agents/notebook/views.py

@@ -12,7 +12,7 @@ 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_tags = ['b', 'i', 's', 'u', 'a', 'ol', 'ul', 'li', 'dl', 'dt', 'dd', 'table', 'caption', 'tr', 'th', 'td']
 allowed_attributes = {
     'a': ['href', 'title']
 }

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

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

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

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

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

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

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

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

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

@@ -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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/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,32 @@ 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
-                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, (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 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))
 
         return [dict(row) for row in cursor.fetchall()]
 
@@ -790,6 +784,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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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/hf_repo/hf_repo/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>