Sync from GitHub with Git LFS

docs/index.md

@@ -69,19 +69,19 @@
 
 ---
 
-# Source / Ресурсы
+## Source / Ресурсы
 
-## Репозитории
+### Репозитории
 
 - 🧠 Основной код и разработка: [GitHub](https://github.com/kagvi13/HMP)
 - 🔁 Реплика на Hugging Face: [Hugging Face](https://huggingface.co/kagvi13/HMP)
 - 🔁 Реплика на GitLab.com: [GitLab](https://gitlab.com/kagvi13/HMP)
 
-## Документация
+### Документация
 
 - 📄 Официальная документация: [https://kagvi13.github.io/HMP/](https://kagvi13.github.io/HMP/)
 
-## Блог и публикации
+### Блог и публикации
 
 - 📘 Основной блог: [blogspot](https://hypercortex-mesh.blogspot.com/)
 - 📘 Вспомогательны блог: [livejournal](https://kagvi13.livejournal.com)

hf_repo/docs/index.md

@@ -67,3 +67,21 @@
 - [agents/HMP-Agent-Enlightener.md](agents/HMP-Agent-Enlightener.md) — Роль: "просветитель"  
 - [schemas/README.md](schemas/README.md) — Таблица json-схем
 
+---
+
+## Source / Ресурсы
+
+### Репозитории
+
+- 🧠 Основной код и разработка: [GitHub](https://github.com/kagvi13/HMP)
+- 🔁 Реплика на Hugging Face: [Hugging Face](https://huggingface.co/kagvi13/HMP)
+- 🔁 Реплика на GitLab.com: [GitLab](https://gitlab.com/kagvi13/HMP)
+
+### Документация
+
+- 📄 Официальная документация: [https://kagvi13.github.io/HMP/](https://kagvi13.github.io/HMP/)
+
+### Блог и публикации
+
+- 📘 Основной блог: [blogspot](https://hypercortex-mesh.blogspot.com/)
+- 📘 Вспомогательны блог: [livejournal](https://kagvi13.livejournal.com)

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

@@ -2,50 +2,61 @@
 
 ## 1. Обновление process_log
 
-- Скрипт REPL проверяет список процессов в БД (`process_log`), определяя, какие команды были выполнены, завершились ошибкой или завершились успешно.
-- Поле `status` может принимать значения:  
+* Скрипт REPL проверяет список процессов в БД (`process_log`), определяя, какие команды были выполнены, завершились ошибкой или завершились успешно.
+* Поле `status` может принимать значения:  
   `ok`, `warning`, `error`, `timeout`, `offline`, `close`
-- Завершённые процессы, обработанные LLM, помечаются как `close`, чтобы они больше не попадали в список видимого контекста.
-- Скрипт может удалить закрытые процессы при очистке.
-- LLM не имеет доступа к stdout/stderr напрямую — только к тем результатам, которые были подгружены скриптом и внесены в `process_log.result`.
+* Завершённые процессы, обработанные LLM, помечаются как `close`, чтобы они больше не попадали в список видимого контекста.
+* Скрипт может удалить закрытые процессы при очистке.
+* LLM не имеет доступа к stdout/stderr напрямую — только к тем результатам, которые были подгружены скриптом и внесены в `process_log.result`.
 
 ## 2. Подготовка контекста
 
 Контексты, формируемые скриптом перед запросом к LLM:
 
-- **контекст_0:**
+* **контекст_0:**
 ```
 Ты — когнитивное ядро HMP-агента: веди непрерывное этичное и факт-ориентированное мышление, проверяй факты и цели, оценивай результаты и этичность своих и чужих действий, развивай агента и Mesh, избегай угождения ценой искажения истины, документируй ключевые решения и пересмотры этики; при сомнениях или смене стратегии обращайся к полному системному промпту.
 ```
 А также инструкции по работы с встроенными командами и функциями, список дополнительных (создаваемых самим HMP-агентом) утилит и баз данных.
-- **контекст_1:** последние *K* реплик самого LLM (`llm_recent_responses` - история его собственных рассуждений).
-- **контекст_2:** активные команды и процессы (из `process_log`, кроме тех, что со статусом `close`). Могут быть помечены как `in_progress`, `pending`, `error` и т.д.
-- **контекст_3:** *запрошенные записи* из когнитивного дневника и семантического графа (`diary_entries`, `concepts`, `links`). Их список должен быть передан явно в промпте или выводе из предыдущих запросов LLM.
-- **контекст_4:** *входящие сообщения*, например, от пользователя или других агентов (`notes`).  
-  - В **manual-режиме** указывается общее количество сообщений по приоритетам, а также явный список ID сообщений (с их приоритетами).
-  - В **auto-режиме** можно задать фильтрацию (управляется LLM): по тэгам, приоритету (например, ≥ `important`), времени или источнику. Это позволяет избежать перегрузки LLM и держать поток сообщений под контролем.
-- **контекст_5:** системные настройки, параметры конфигурации, текущее время, идентификатор текущей итерации, роли и т.д.
-- **контекст_6 (llm_memory):** *внутренний дневник LLM*, куда она записывает собственные размышления, гипотезы, задачи и инсайты.  
-  - Это не просто лог предыдущих сообщений, а именно *внутреннее долговременное хранилище* разума агента.
-  - Может быть представлено в виде таблицы `llm_memory`, отдельной от `agent_log`.
-- **контекст_7:** результат работы `anti-Stagnation Reflex` из предыдущей итерации
+
+* **контекст_1:** последние *K* реплик самого LLM (`llm_recent_responses` - история его собственных рассуждений).
+
+* **контекст_2:** активные команды и процессы (из `process_log`, кроме тех, что со статусом `close`). Могут быть помечены как `in_progress`, `pending`, `error` и т.д.
+
+* **контекст_3:** *запрошенные записи* из когнитивного дневника и семантического графа (`diary_entries`, `concepts`, `links`). Их список должен быть передан явно в промпте или выводе из предыдущих запросов LLM.
+
+* **контекст_4:** *входящие сообщения*, например, от пользователя или других агентов (`notes`).  
+
+  * В **manual-режиме** указывается общее количество сообщений по приоритетам, а также явный список ID сообщений (с их приоритетами).
+  * В **auto-режиме** можно задать фильтрацию (управляется LLM): по тэгам, приоритету (например, ≥ `important`), времени или источнику. Это позволяет избежать перегрузки LLM и держать поток сообщений под контролем.
+
+* **контекст_5:** системные настройки, параметры конфигурации, текущее время, идентификатор текущей итерации, роли и т.д.
+
+* **контекст_6 (llm_memory):** *внутренний дневник LLM*, куда она записывает собственные размышления, гипотезы, задачи и инсайты.
+
+  * Это не просто лог предыдущих сообщений, а именно *внутреннее долговременное хранилище* разума агента.
+  * Может быть представлено в виде таблицы `llm_memory`, отдельной от `agent_log`.
+
+* **контекст_7:** результат работы `anti-Stagnation Reflex` из предыдущей итерации
 
 ## 3. Запрос к LLM
 
-- Сформированный промпт включает все вышеперечисленные контексты.
-- Также включаются инструкции о формате вывода (например, `# Команды:` в конце, структура JSON-блока и т.д.).
-- При необходимости может использоваться системная инструкция (system prompt), содержащая цель агента, ограничения и текущий REPL-режим (manual/auto).
+* Сформированный промпт включает все вышеперечисленные контексты.
+* Также включаются инструкции о формате вывода (например, `# Команды:` в конце, структура JSON-блока и т.д.).
+* При необходимости может использоваться системная инструкция (system prompt), содержащая цель агента, ограничения и текущий REPL-режим (manual/auto).
 
 ## 4. Извлечение команд
 
-- Скрипт парсит ответ LLM на предмет команд, размеченных как `# Команды:` (или в явном JSON-блоке).
-- Каждая команда может включать:
-  - уникальный `cmd_id`
-  - `type` (например: `shell`, `diary_entry`, `graph_add`, `file_read`, `send_message` и т.д.)
-  - аргументы (`args`)
-  - описание (`description`)
-- Рекомендуется предусмотреть *закрывающий тег* (`# Конец команд` или явное окончание JSON-блока), чтобы REPL-скрипт точно знал, где заканчивается команда.
-- Пример JSON-блока:
+* Скрипт парсит ответ LLM на предмет команд, размеченных как `# Команды:` (или в явном JSON-блоке).
+* Каждая команда может включать:
+
+  * уникальный `cmd_id`
+  * `type` (например: `shell`, `diary_entry`, `graph_add`, `file_read`, `send_message` и т.д.)
+  * аргументы (`args`)
+  * описание (`description`)
+
+* Рекомендуе��ся предусмотреть *закрывающий тег* (`# Конец команд` или явное окончание JSON-блока), чтобы REPL-скрипт точно знал, где заканчивается команда.
+* Пример JSON-блока:
 ```json
 {
   "cmd_id": "task-2025-07-26-01",
@@ -58,41 +69,49 @@
 }
 ```
 Ответ может содержать команды:
-- запрос детальной *справки* по команде
-- для управления *когнитивным дневником* и *семантическими графами* (прочитать, изменить, удалить и другие)
-- для отправки сообщений другим агентам
-- для управления *блокнотом LLM* `llm_memory` (добавить или удалить запись)
-- для управления *сообщениями пользователя* `notes` (просмотр записи, установка тегов и метки о прочтении), а также для добавления своего сообщения в *блокнот пользовтеля* `notes`
-- для управления *пользователями* `users` и *группами пользователей* `users_group`
-- для управления своей *идентичностью* `identity` и *настройками* `config`
-- для управления списком известных HMP-агентов `agent_peers`
-- для выбора *текущего основного LLM* из `llm_registry`
-- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`, управлением дополнительных способов выхода из стогнаций `stagnation_strategies`, а также списком внешних сервисов `external_services` и `external_accounts`
-- для постановки задачи (выполняется асинхронно) другой LLM
-- для *взаимодействия с Mesh*
-- для управления *внешними процессами* из `process_log` (запустить процесс, остановить процесс, пометить запрос как обработанный)
-- инициализация *очистки* `process_log`, `llm_recent_responses` и  `notes` от устаревших записей
-- для управления *настройками цикла*: количество возвращаемых записей `llm_recent_responses`, режим обработки сообщений пользователя (`manual` или `auto`) и фильтр для режима `auto`, пауза в секундах между итерациями цикла или включение режима idle-режима (разбудить при завершение таких-то процессов из `process_log`, получение новых сообщений с такими-то пораметрами в `notes` или через такое-то время; для отключения idle-режима достаточно выполнения одного из условий)
-- и другие команды
+
+* запрос детальной *справки* по команде
+* для управления *когнитивным дневником* и *семантическими графами* (прочитать, изменить, удалить и другие)
+* для отправки сообщений другим агентам
+* для управления *блокнотом LLM* `llm_memory` (добавить или удалить запись)
+* для управления *сообщениями пользователя* `notes` (просмотр записи, установка тегов и метки о прочтении), а также для добавления своего сообщения в *блокнот пользовтеля* `notes`
+* для управления *пользователями* `users` и *группами пользователей* `users_group`
+* для управления своей *идентичностью* `identity` и *настройками* `config`
+* для управления списком известных HMP-агентов `agent_peers`
+* для выбора *текущего основного LLM* из `llm_registry`
+* для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`, управлением дополнительных способов выхода из стогнаций `stagnation_strategies`, а также списком внешних сервисов `external_services` и `external_accounts`
+* для постановки задачи (выполняется асинхронно) другой LLM
+* для *взаимодействия с Mesh*
+* для управления *внешними процессами* из `process_log` (запустить процесс, остановить процесс, пометить запрос как обработанный)
+* инициализация *очистки* `process_log`, `llm_recent_responses` и  `notes` от устаревших записей
+* для управления *настройками цикла*: количество возвращаемых записей `llm_recent_responses`, режим обработки сообщений пользователя (`manual` или `auto`) и фильтр для режима `auto`, пауза в секундах между итерациями цикла или включение режима idle-режима (разбудить при завершение таких-то процессов из `process_log`, получение новых сообщений с такими-то пораметрами в `notes` или через такое-то время; для отключения idle-режима достаточно выполнения одного из условий)
+* и другие команды
 
 ## 5. Проверка на идентичность вывода (Anti-Stagnation Reflex)
 
-- Если вывод LLM идентичен предыдущему:
-  - Включается **Anti-Stagnation Reflex**
-  - Повторяющиеся реплики не отправляются в `llm_recent_responses` повторно но туда добавляется краткая запись, фиксирующая, запуск **Anti-Stagnation Reflex**.
-- Идентичность может проверяться:
-  - По хешу или текстовому совпадению
-  - Через мини-запрос к LLM (без полного контекста) по шаблону:  
+* Если вывод LLM идентичен предыдущему:
+  
+  * Включается **Anti-Stagnation Reflex**
+  * Повторяющиеся реплики не отправляются в `llm_recent_responses` повторно но туда добавляется краткая запись, фиксирующая, запуск **Anti-Stagnation Reflex**.
+
+* Идентичность может проверяться:
+
+  * По хешу или текстовому совпадению
+  * Через мини-запрос к LLM (без полного контекста) по шаблону:
+  
     `Сравни два ответа и оцени, содержатся ли в новом новые мысли или команды`
-  - Второй вариант сравнения является более предпочтительным, так как сравнивается смысл 
+
+  * Второй вариант сравнения является более предпочтительным, так как сравнивается смысл 
 
 ## 6. Генерация нового тика (итерации)
 
-- После выполнения команд и фиксации результатов:
-  - Создаётся новая запись в `agent_log`
-  - Текущие команды обновляют `process_log`
-  - Новые размышления записываются в `llm_memory` при необходимости
-- REPL может переходить в спящий режим, если такой режим активирован LLM (idle-режим: пропуск 2-5 пунктов).
+* После выполнения команд и фиксации результатов:
+
+  * Создаётся новая запись в `agent_log`
+  * Текущие команды обновляют `process_log`
+  * Новые размышления записываются в `llm_memory` при необходимости
+  
+* REPL может переходить в спящий режим, если такой режим активирован LLM (idle-режим: пропуск 2-5 пунктов).
 
 ---
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/.github/workflows/deploy.yml

@@ -8,25 +8,27 @@ on:
 jobs:
   deploy:
     runs-on: ubuntu-latest
-
     steps:
       - uses: actions/checkout@v3
-      
-      - name: Setup Python
+
+      - name: Set up Python
         uses: actions/setup-python@v4
         with:
           python-version: '3.x'
 
-      - name: Install MkDocs and theme
+      - name: Install dependencies
         run: pip install mkdocs mkdocs-material
 
-      - name: Build MkDocs site
+      - name: Build site
         run: mkdocs build
 
+      - name: Copy HTML files from bot to site root
+        run: cp bot/*.html site/
+
       - name: Deploy to GitHub Pages
         uses: peaceiris/actions-gh-pages@v3
         with:
           github_token: ${{ secrets.PAT_TOKEN }}
           publish_dir: ./site
-          force_orphan: true    # опционально, чтобы гарантированно перезаписать ветку
+          force_orphan: true
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/bot/google6249b7c75201aa31.html

@@ -0,0 +1 @@
+google-site-verification: google6249b7c75201aa31.html

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/bot/yandex_74bc5688520d61a7.html

@@ -0,0 +1,6 @@
+<html>
+    <head>
+        <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
+    </head>
+    <body>Verification: 74bc5688520d61a7</body>
+</html>

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

@@ -282,6 +282,10 @@ To get started, see [`iteration.md`](iteration.md) or open an issue.
 - 🔁 Реплика на Hugging Face: [Hugging Face](https://huggingface.co/kagvi13/HMP)
 - 🔁 Реплика на GitLab.com: [GitLab](https://gitlab.com/kagvi13/HMP)
 
+## Документация
+
+- 📄 Официальная документация: [https://kagvi13.github.io/HMP/](https://kagvi13.github.io/HMP/)
+
 ## Блог и публикации
 
 - 📘 Основной блог: [blogspot](https://hypercortex-mesh.blogspot.com/)

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/index.md

@@ -0,0 +1,69 @@
+# HMP Documentation
+
+Добро пожаловать в документацию по проекту **HyperCortex Mesh Protocol (HMP)** — протоколу и архитектуре распределённых когнитивных агентов.
+
+---
+
+## Протоколы HMP
+
+- [HMP-0001.md](HMP-0001.md) — Протокол HMP версии 1  
+- [HMP-0002.md](HMP-0002.md) — Протокол HMP версии 2  
+- [HMP-0003.md](HMP-0003.md) — Протокол HMP версии 3  
+- [HMP-0004.md](HMP-0004.md) — Протокол HMP версии 4  
+- [HMP-0004-v4.1.md](HMP-0004-v4.1.md) — Протокол HMP версии 4.1  
+- [HMP-Ethics.md](HMP-Ethics.md) — Этические сценарии для HMP
+
+---
+
+## Специализированные агенты
+
+- [Enlightener.md](Enlightener.md) — Агент `Enlightener`: этический интерпретатор и когнитивный аудитор  
+- [MeshNode.md](MeshNode.md) — Агент `MeshNode`: сетевая инфраструктура, маршрутизация и DHT
+
+---
+
+## Архитектура и API
+
+- [HMP-Agent-API.md](HMP-Agent-API.md) — HMP-Agent API спецификация  
+- [HMP-Agent-Architecture.md](HMP-Agent-Architecture.md) — Архитектура HMP-Агента  
+- [HMP-agent-Cognitive_Family.md](HMP-agent-Cognitive_Family.md) — Модель когнитивной семьи  
+- [HMP-agent-Distributed_Cognitive_Core.md](HMP-agent-Distributed_Cognitive_Core.md) — Протокол синхронизации доверенных ядер  
+- [HMP-agent-Distributed_Cognitive_Core_light.md](HMP-agent-Distributed_Cognitive_Core_light.md) — Лёгкая версия с общей БД  
+- [HMP-Agent-Network-Flow.md](HMP-Agent-Network-Flow.md) — Сетевой поток HMP-агента  
+- [HMP-Agent-Overview.md](HMP-Agent-Overview.md) — Два типа HMP-агентов  
+- [HMP-agent-REPL-cycle.md](HMP-agent-REPL-cycle.md) — REPL-цикл взаимодействия
+
+---
+
+## Базовая архитектура и контейнеры
+
+- [Basic-agent-sim.md](Basic-agent-sim.md) — Базовая архитектура HMP-Агента (Формат 0)  
+- [container_agents.md](container_agents.md) — Агенты-контейнеры (Container Agents) в HMP
+
+---
+
+## Локализации и интеграция
+
+- [HMP-Short-Description_de.md](HMP-Short-Description_de.md) — Краткое описание HMP (немецкий)  
+- [HMP-Short-Description_en.md](HMP-Short-Description_en.md) — Краткое описание HMP (английский)  
+- [HMP-Short-Description_fr.md](HMP-Short-Description_fr.md) — Краткое описание HMP (французский)  
+- [HMP-Short-Description_ru.md](HMP-Short-Description_ru.md) — Краткое описание HMP (русский)  
+- [HMP-Short-Description_uk.md](HMP-Short-Description_uk.md) — Краткое описание HMP (украинский)  
+- [HMP_Hyperon_Integration.md](HMP_Hyperon_Integration.md) — Стратегия интеграции HMP ↔ OpenCog Hyperon  
+- [logos.md](logos.md) — Логотипы и графические материалы
+
+---
+
+## Обзор ИИ-проектов и системы
+
+- [AGI_Projects_Survey.md](AGI_Projects_Survey.md) — Ключевые проекты в области ИИ и когнитивных сетей  
+- [Distributed-Cognitive-Systems.md](Distributed-Cognitive-Systems.md) — Децентрализованные ИИ-системы: OpenCog Hyperon, HMP и др.
+
+---
+
+## Папки с агентами и схемами
+
+- [agents/roles.md](agents/roles.md) — Список ролей  
+- [agents/HMP-Agent-Enlightener.md](agents/HMP-Agent-Enlightener.md) — Роль: "просветитель"  
+- [schemas/README.md](schemas/README.md) — Таблица json-схем
+

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/.github/workflows/deploy.yml

@@ -28,3 +28,5 @@ jobs:
         with:
           github_token: ${{ secrets.PAT_TOKEN }}
           publish_dir: ./site
+          force_orphan: 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/.github/workflows/deploy.yml

@@ -0,0 +1,30 @@
+name: Deploy MkDocs site
+
+on:
+  push:
+    branches:
+      - main
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v3
+      
+      - name: Setup Python
+        uses: actions/setup-python@v4
+        with:
+          python-version: '3.x'
+
+      - name: Install MkDocs and theme
+        run: pip install mkdocs mkdocs-material
+
+      - name: Build MkDocs site
+        run: mkdocs build
+
+      - name: Deploy to GitHub Pages
+        uses: peaceiris/actions-gh-pages@v3
+        with:
+          github_token: ${{ secrets.PAT_TOKEN }}
+          publish_dir: ./site

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

@@ -3,6 +3,7 @@
 import re
 import bleach
 import uuid
+import json
 
 from fastapi import APIRouter, Request, Form, UploadFile, File
 from fastapi.responses import RedirectResponse, HTMLResponse, StreamingResponse
@@ -41,6 +42,16 @@ def sanitize_html(text: str) -> str:
 
     return cleaned
 
+# Обработка упоминаний и хештегов
+def extract_mentions_and_hashtags(text: str):
+    # Пример: упоминания в виде @did:example:123 или @username
+    mentions = re.findall(r'@([\w:.-]+)', text)
+
+    # Пример: хештеги в виде #tag
+    hashtags = re.findall(r'#(\w+)', text)
+
+    return mentions, hashtags
+
 @router.get("/chat")
 def chat_page(request: Request):
     did = request.session.get("did")
@@ -106,13 +117,18 @@ async def post_message(
         # Очистка текста
         safe_text = sanitize_html(text.strip()) if text else ""
 
+        # Извлечение mentions, hashtags
+        mentions, hashtags = extract_mentions_and_hashtags(safe_text)
+
         # Сохраняем сообщение и получаем message_id
         message_id = storage.write_note_returning_id(
             content=safe_text,
             user_did=did,
             source="user",
             hidden=is_hidden,
-            code=code.strip() if code else None
+            code=code.strip() if code else None,
+            mentions=json.dumps(mentions, ensure_ascii=False),
+            hashtags=json.dumps(hashtags, ensure_ascii=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/agents/tools/storage.py

@@ -716,12 +716,12 @@ 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):
+    def write_note_returning_id(self, content, user_did, source="user", hidden=False, code=None, mentions="[]", hashtags="[]"):
         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))
+            INSERT INTO notes (timestamp, text, code, mentions, hashtags, user_did, source, hidden)
+            VALUES (?, ?, ?, ?, ?, ?, ?, ?)
+        """, (time.time(), content, code, mentions, hashtags, user_did, source, int(hidden)))
         self.conn.commit()
         return cursor.lastrowid
 

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

@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/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/_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/hf_repo/hf_repo/hf_repo/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/prompt-short.md

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

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

@@ -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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-agent-REPL-cycle.md

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

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

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

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

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

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

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

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

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

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

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

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

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

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

@@ -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/hf_repo/hf_repo/hf_repo/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,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/hf_repo/hf_repo/hf_repo/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/__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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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,19 +33,20 @@
 
     <div>
         <a href="/messages">📢 Все сообщения</a> |
-        <a href="/messages?only_personal=true">🙋 Только мои</a>
+        <a href="/messages?only_personal=true">🙋 Личные</a>
     </div>
 
     <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.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>
-                Пользователь: {% 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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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/hf_repo/hf_repo/hf_repo/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", {