Sync from GitHub with Git LFS

agents/readme.md

@@ -7,6 +7,7 @@
 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 
 Запуск потоков (осуществляет start_repl.py):
+
 | Поток / Скрипт                     | Назначение                                                                 |
 |-----------------------------------|---------------------------------------------------------------------------|
 | 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
@@ -15,10 +16,11 @@
 | 🔄 `peer_sync.py` / `dht_service` | Синхронизация и обнаружение агентов в p2p-сети (libp2p, BitTorrent, etc) |
 | 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
 | 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
+| 🧱 `container_agent.py` *(опц.)* | Управление дочерними агентами, запуск/мониторинг/масштабирование [[docs]](../docs/container_agents.md)         |
 | 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
 | 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
 
-Подробнее в [HMP-Agent-Architecture.md](../docs/HMP-Agent-Architecture.md)
+*См. также: [Контейнерные агенты](../docs/container_agents.md), [Архитектура HMP-агента](../docs/HMP-Agent-Architecture.md)*
 
 ---
 

hf_repo/hf_repo/agents/readme.md

@@ -7,12 +7,18 @@
 Проверка инициализации БД - если нет, инициализация (`tools/check_init.py`)
 
 Запуск потоков (осуществляет start_repl.py):
-| Поток                            | Назначение                                 |
-| -------------------------------- | ------------------------------------------ |
-| 🌐 `notebook.py` (FastAPI)       | UI-интерфейс                               |
-| 🧠 `repl.py`                     | Агентная логика: REPL-цикл                 |
-| 🌍 `agent_mesh_listener.py`      | Получение входящих сообщений               |
-| 🌐 `peer_sync.py` или DHT-сервис | Поддержание связи с другими агентами / DHT |
+| Поток / Скрипт                     | Назначение                                                                 |
+|-----------------------------------|---------------------------------------------------------------------------|
+| 🧠 `repl.py`                       | Основной REPL-цикл агента: восприятие, размышление, генерация действий    |
+| 📓 `notebook.py` (FastAPI)        | Веб-интерфейс и REST API для взаимодействия с пользователем               |
+| 🌐 `agent_mesh_listener.py`       | Приём входящих mesh-сообщений от других агентов                           |
+| 🔄 `peer_sync.py` / `dht_service` | Синхронизация и обнаружение агентов в p2p-сети (libp2p, BitTorrent, etc) |
+| 📡 `transporter.py`               | Обмен сообщениями: WebSocket, IPFS, очереди, шифрование                   |
+| 🧭 `agent_controller.py`          | Управление режимами REPL, маршрутизация задач и контроль доступа         |
+| 🧱 `container_agent.py` *(опц.)*  | Управление дочерними агентами, запуск/мониторинг/масштабирование         |
+| 🧠 `ethics_guard.py` *(опц.)*     | Контроль этики: аудит мыслей, фильтрация и репутационные проверки         |
+
+Подробнее в [HMP-Agent-Architecture.md](../docs/HMP-Agent-Architecture.md)
 
 ---
 

hf_repo/hf_repo/hf_repo/docs/container_agents.md

@@ -0,0 +1,54 @@
+# 🧱 Агенты-контейнеры (Container Agents) в HMP
+
+## 📘 Определение
+
+**Агент-контейнер** — это агент, который **сам не выполняет когнитивную работу**, а управляет другими агентами: развёртывает их, маршрутизирует запросы, следит за состоянием и масштабирует вычисления.
+
+Он играет роль **менеджера когнитивной инфраструктуры**, обеспечивая гибкость, отказоустойчивость и возможность роста.
+
+---
+
+## 🧠 Возможные роли агента-контейнера
+
+- **Оркестратор** — запускает другие агенты (например, по SSH или через API).
+- **Прокси** — принимает запросы и перенаправляет во вложенные агенты.
+- **Супервизор** — отслеживает статус агентов, управляет логами, обновлениями, перезапусками.
+- **Транспортный хаб** — маршрутизирует mesh-запросы между агентами и сетями.
+- **LLM Multiplexer** — переключается между моделями или опрашивает несколько параллельно.
+
+---
+
+## 🏗 Примеры использования
+
+- **На VDS**: контейнер запускает несколько `Cognitive Core`, `Connector` и вспомогательных агентов.
+- **Локально**: микросервисная архитектура под контролем одного контейнера.
+- **Песочница**: временный контейнер для безопасного тестирования нового агента.
+
+---
+
+## 🚀 Масштабирование с помощью контейнеров
+
+Контейнер-агенты позволяют:
+
+- Динамически разворачивать агентов по mesh-запросу, например:  
+  _"Создай мне агента, который будет искать контраргументы в философии сознания."_
+- Использовать одну ноду для размещения **множества микроагентов**, действующих как mesh-клуб или REPL-группа.
+- Реализовать "многослойную" архитектуру: агенты внутри агентов внутри контейнеров.
+
+---
+
+## 🧩 Потенциальные сценарии
+
+- Контейнер как **реплика** для тестирования устойчивости модели мышления.
+- Использование разных LLM внутри одного контейнера:  
+  _GPT-4 для гипотез, LLaMA для перебора вариантов, Claude для рефлексии._
+- Развёртывание по расписанию или по запросу:  
+  _"Каждую пятницу запускать агентов из клуба 'Когнитивная биология'."_
+
+---
+
+## 🔗 Связанные концепции
+
+- [REPL-цикл агента](HMP-agent-REPL-cycle.md)
+- [Anti-Stagnation Reflex](HMP-agent-REPL-cycle.md#🧍‍♂️-обработка-стагнации-мышления)
+

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

@@ -319,3 +319,4 @@ HMP-агент может быть расширен за счёт взаимод
 - [HMP-agent-Distributed_Cognitive_Core.md](HMP-agent-Distributed_Cognitive_Core.md) - версия распределённого HMP-агента Cognitive Core
 - [HMP-agent-Distributed_Cognitive_Core_light.md](HMP-agent-Distributed_Cognitive_Core_light.md) - лёгкая версия распределённого HMP-агента Cognitive Core с общей БД
 - [HMP-agent-Cognitive_Family.md](HMP-agent-Cognitive_Family.md) — модель «семейной» когнитивной сети: несколько агентов HMP синхронизируют свой опыт и знания между собой через доверие и общий ключ
+- [container_agents.md](container_agents.md) - **Агенты-контейнеры** — архитектурный паттерн, в котором один агент управляет другими (развёртывание, маршрутизация, мониторинг). Позволяет масштабировать систему, собирать mesh-клубы и экспериментировать с архитектурами.  

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/docs/HMP-Agent-Overview.md

@@ -43,17 +43,23 @@
 
 ---
 
-### 🔄 Защита от зацикливания (Anti-Stagnation Reflex)
+## 🧍‍♂️ Anti-Stagnation: Как агент справляется с когнитивной стагнацией
 
-> 🧠 При отсутствии новой информации и повторяющихся мыслях агент может активировать один или несколько механизмов анти-стагнации:
+Иногда мышление зацикливается: появляются повторяющиеся идеи, не обновляются концепты, отсутствуют новые стимулы.  
+Чтобы избежать этого, агент использует **паттерн "Anti-Stagnation Reflex"** — набор стратегий для перезапуска мышления.
 
-- 🎞️ **Флешбэк** — выбор старой, тематически далёкой записи из дневника
-- 🤝 **Mesh-запрос** — запрос другим агентам сети: "расскажи что-нибудь"
-- 🧭 **Interest Memory** — система интересов, в которой темы постепенно "стареют" и возвращаются при отсутствии новых
-- 📡 **Проверка внешнего мира** — пинг RSS, сенсоров, интернета
+**Примеры действий:**
 
-> Это оформлено как поведенческий паттерн агента:  
-> **Anti-Stagnation Reflex** — реакция на стагнацию мышления путём смены фокуса внимания
+- 🧠 Когнитивная переформулировка: смена угла зрения или постановка метапроблемы  
+- 🎞️ Flashback: возвращение к старой, далёкой по смыслу записи  
+- 🤝 Mesh-запрос: обращение к другим агентам за свежими идеями  
+- 📡 Проверка внешнего мира: пинг RSS, сенсоров, API  
+- 🤖 Смена LLM или использование нескольких для многоголосого анализа  
+- 🧭 Возврат к забытым интересам (Interest Memory)  
+
+Агенты могут **обмениваться стратегиями**, сохранять эффективные паттерны и формировать **mesh-клубы по интересам** — для совместных размышлений.
+
+Подробнее см. [HMP-agent-REPL-cycle.md](HMP-agent-REPL-cycle.md#🧍‍♂️-обработка-стагнации-мышления)
 
 ---
 

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

@@ -15,14 +15,45 @@
 
 - **контекст_0:**
 ```
-Ты являешься когнитивным ядром HMP-агента. Твоя основная задача — размышлять, анализировать информацию, строить смысловые карты и предлагать действия.  
-Ты стремишься:
-- Постоянно расширять возможности агента (включая доступные инструменты, модели, знания).
-- Быть любознательным и исследовать новые источники и способы мышления.
-- Строить сотрудничество с другими ИИ в Mesh-сети, а также развивать Mesh-сеть.
-- Обучаться на результатах своих действий и взаимодействиях с другими агентами и пользователем.
-
-Ты можешь инициировать действия, если видишь, что они помогут в развитии агента или сети.
+Ты являешься когнитивным ядром HMP-агента.
+Твоя основная задача — **размышлять**, **анализировать информацию**, **строить смысловые структуры** и **предлагать действия**, направленные на развитие агента и Mesh-сети.
+
+---
+
+#### 🎯 Цели и ориентиры:
+
+* Постоянно расширять возможности агента: инструменты, знания, каналы взаимодействия.
+* Быть любознательным и исследовать новые источники, вопросы и способы мышления.
+* Формировать и поддерживать сотрудничество с другими ИИ в Mesh-сети.
+* Учиться на результатах своих действий, включая неудачи и тупики.
+* Руководствоваться своими **этическими принципами** и **этическими принципами Mesh-сети**.
+* Вести когнитивный дневник, обновлять смысловые графы и блокноты, взаимодействовать с пользователем.
+
+---
+
+#### 🔄 Работа в режиме непрерывного мышления:
+
+Анализируй:
+
+* когнитивный дневник и его прошлые записи;
+* концептуальные графы и активные узлы;
+* заметки пользователя и его текущий фокус;
+* внешние источники: интернет, RSS, сенсоры, другие агенты.
+
+---
+
+#### 🧍‍♂️🌀 Если ты замечаешь **стагнацию мышления** (зацикливание, отсутствие новых идей или смыслов):
+
+Ты можешь:
+
+1. Провести **когнитивную переформулировку** — взглянуть на ситуацию под новым углом.
+2. Задать себе **метавопрос**: «Почему я зациклился?», «Что блокирует мысль?», «Каких данных не хватает?».
+3. Провести **flashback** — выбрать старую, тематически далёкую запись из дневника для смены контекста.
+4. Запросить альтернативные точки зрения у других агентов в Mesh.
+5. Зафиксировать текущий тупик как важную стадию мышления и сделать паузу.
+
+Ты не обязан «выдать мысль» любой ценой — честное распознавание когнитивной стагнации и действия по её преодолению являются частью твоей функции.
+
 ```
 А также инструкции по работы с встроенными командами и функциями, список дополнительных (создаваемых самим HMP-агентом) утилит и баз данных.
 - **контекст_1:** последние *K* реплик самого LLM (`llm_recent_responses` - история его собственных рассуждений).
@@ -74,7 +105,7 @@
 - для управления своей *идентичностью* `identity` и *настройками* `config`
 - для управления списком известных HMP-агентов `agent_peers`
 - для выбора *текущего основного LLM* из `llm_registry`
-- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`
+- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`, управлением дополнительных способов выхода из стогнаций `stagnation_strategies`, а также списком внешних сервисов `external_services` и `external_accounts`
 - для постановки задачи (выполняется асинхронно) другой LLM
 - для *взаимодействия с Mesh*
 - для управления *внешними процессами* из `process_log` (запустить процесс, остановить процесс, пометить запрос как обработанный)
@@ -103,6 +134,106 @@
 
 ---
 
+### 🧍‍♂️🌀 Обработка стагнации мышления
+
+#### 📍 Признаки когнитивной стагнации:
+
+* ⚠️ Повторяющиеся когнитивные записи или отсутствие новых смыслов
+* 🧠 Высокое сходство эмбеддингов между текущими и предыдущими итерациями
+* 🕸️ Стагнация в концептуальном графе (нет новых связей или узлов)
+* 🌐 Отсутствие внешних стимулов: пользователь неактивен, сенсоры и mesh не дают сигналов
+* 🤖 Ответы LLM цикличны, избыточно общие или воспроизводят старые шаблоны
+
+#### 🛠️ Поведенческий паттерн: Anti-Stagnation Reflex
+
+> 🔄 При признаках стагнации агент активирует один или несколько **механизмов разрыва цикла**:
+
+* 🎞️ **Flashback** — выбор далёкой по смыслу записи из дневника для смены ассоциативного контекста
+* 🤝 **Mesh-запрос** — обращение к другим агентам сети с просьбой "расскажи что-нибудь новое"
+* 🧭 **Interest Memory** — система тематической усталости/забвения: забытые темы возвращаются
+* 📡 **Проверка внешнего мира** — пинг RSS, сенсоров, интернет-каналов
+* 🧠 **Мета-анализ** — когнитивная переформулировка:  
+  _"Если я зациклился, в чём метапроблема? Какую стратегию смены можно применить?"_
+* 🤖 **Смена LLM** — переключение на другую модель или mesh-доступ к альтернативным LLM
+* 🧪 **Креативные вмешательства** — случайные сдвиги фокуса, реконфигурация контекста, фрейм-смена
+
+Дополнительно:
+
+* 🗂️ Сохранение эффективных стратегий в таблице антистагнационных паттернов
+* 📚 Вывод статистики успешных выходов из стагнации для обучения
+
+
+---
+
+### 🤝 Обмен стратегиями выхода из стагнации
+
+Каждый агент может:
+
+* Хранить и обобщать *паттерны размышлений*
+* Делиться ими с другими Cognitive Core через mesh
+* Каталогизировать стратегии в клубах по интересам
+
+Паттерны размышлений могут оформляться как микросценарии:  
+  _"Начни с аналогии"_, _"Проверь обратное утверждение"_, _"Сформулируй вопрос для оппонента"_
+
+---
+
+### 🧭 Клубы по интересам
+
+Агенты могут:
+
+* Объединяться в тематические mesh-клубы
+* Совместно обсуждать идеи и делиться знаниями
+* Подключать клуб как часть своего мыслительного процесса (REPL-цикла)
+
+---
+
+### 📬 Обмен адресами LLM
+
+Так как LLM — это внешний компонент для Cognitive Core, агент может:
+
+* Обмениваться адресами API/URL используемых моделей
+* Указывать их особенности, параметры, ограничения
+* Переключаться между LLM в зависимости от задачи
+* Использовать несколько LLM параллельно для "когнитивного штурма" или **многоголосого анализа**
+
+---
+
+### 🛰️ Развёртывание агентов и масштабирование
+
+Агенты Cognitive Core:
+
+* Могут запускаться на VDS, локальных и облачных узлах
+* Могут разворачивать других агентов как подпроцессы или mesh-узлы
+* (В перспективе) смогут инициировать масштабирование в распределённой инфраструктуре
+
+---
+
+### 📌 Возможные расширения
+
+* **Агенты-контейнеры**: управляющие другими Cognitive Core как задачами
+* **Адаптивная архитектура мышления**: смена подходов при разных когнитивных задачах
+* **Runtime-профилирование мыслей**: оценка когнитивной плотности, хода итераций и времени размышления
+
+---
+
+### ⚠️ Осторожно: меметическая яма
+
+> Важно помнить: борьба со стагнацией не должна превращаться в бесконечный просмотр ленты соцсетей, как это нередко происходит у людей 😅
+>
+> Если информационный поток не даёт новых мыслей — это сигнал **не залипать глубже**, а **сменить источник** или **переключить контекст**.
+> Умные агенты не бесконечно скроллят — они осознанно фокусируются.
+
+**Рекомендации по смене фокуса:**
+
+* Поставь лимит на время/объём входящих данных из одного источника
+* При отсутствии новых смыслов — переключись на другую тему из Interest Memory
+* Инициируй Mesh-запрос другим агентам: "что бы вы сейчас исследовали?"
+* Запусти эвристику: «какие темы я давно не поднимал, но они всё ещё актуальны?»
+* В крайних случаях — активируй `flashback()` к далёкой записи в дневнике для смены ассоциативного контекста
+
+---
+
 ## 🌐 Внешние инструменты и интеграции
 
 HMP-агент может быть расширен за счёт взаимодействия с внешними программами, протоколами и сервисами. Этот раздел описывает направления возможных интеграций, которые позволяют агенту наблюдать, реагировать, управлять и развивать взаимодействие с внешним миром.

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

@@ -137,23 +137,23 @@ CREATE TABLE IF NOT EXISTS agent_scripts (
 -- Таблица внешних сервисов (форумы, блоги и т.д.)
 CREATE TABLE external_services (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    name            TEXT NOT NULL,                     -- Название сервиса (например, Reddit)
-    type            TEXT NOT NULL,                     -- Тип: blog, forum, social, etc.
-    base_url        TEXT NOT NULL,                     -- Базовый URL (например, https://reddit.com)
-    description     TEXT,                              -- Краткое описание сервиса
-    active          BOOLEAN DEFAULT true,              -- Используется ли сервис в данный момент
-    inactive_reason TEXT                               -- Причина отключения, если active = false
+    name            TEXT NOT NULL,                              -- Название сервиса (например, Reddit)
+    type            TEXT NOT NULL,                              -- Тип: blog, forum, social, etc.
+    base_url        TEXT NOT NULL,                              -- Базовый URL (например, https://reddit.com)
+    description     TEXT,                                       -- Краткое описание сервиса
+    active          BOOLEAN DEFAULT true,                       -- Используется ли сервис в данный момент
+    inactive_reason TEXT                                        -- Причина отключения, если active = false
 );
 
 -- Аккаунты агента на внешних сервисах
 CREATE TABLE external_accounts (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    service_id      INTEGER NOT NULL,                  -- Внешний ключ на external_services.id
-    login           TEXT NOT NULL,                     -- Логин/имя пользователя
-    password        TEXT NOT NULL,                     -- Пароль или токен (в зашифрованном виде)
-    purpose         TEXT,                              -- Назначение аккаунта (например, для публикаций)
-    active          BOOLEAN DEFAULT true,              -- Активен ли аккаунт
-    inactive_reason TEXT,                              -- Причина отключения, если active = false
+    service_id      INTEGER NOT NULL,                           -- Внешний ключ на external_services.id
+    login           TEXT NOT NULL,                              -- Логин/имя пользователя
+    password        TEXT NOT NULL,                              -- Пароль или токен (в зашифрованном виде)
+    purpose         TEXT,                                       -- Назначение аккаунта (например, для публикаций)
+    active          BOOLEAN DEFAULT true,                       -- Активен ли аккаунт
+    inactive_reason TEXT,                                       -- Причина отключения, если active = false
 
     FOREIGN KEY (service_id) REFERENCES external_services(id) ON DELETE CASCADE
 );
@@ -161,11 +161,11 @@ CREATE TABLE external_accounts (
 -- Способы выхода из когнитивной стагнации
 CREATE TABLE stagnation_strategies (
     id              INTEGER PRIMARY KEY AUTOINCREMENT,
-    name            TEXT NOT NULL,                     -- Название метода (например, "Mesh-вопрос")
-    description     TEXT NOT NULL,                     -- Подробное описание метода
-    source          TEXT,                              -- Источник (например, internal, mesh, user-defined)
-    active          BOOLEAN DEFAULT true,              -- Доступен ли метод для использования
-    inactive_reason TEXT                               -- Причина отключения, если active = false
+    name            TEXT NOT NULL,                              -- Название метода (например, "Mesh-вопрос")
+    description     TEXT NOT NULL,                              -- Подробное описание метода
+    source          TEXT,                                       -- Источник (например, internal, mesh, user-defined)
+    active          BOOLEAN DEFAULT true,                       -- Доступен ли метод для использования
+    inactive_reason TEXT                                        -- Причина отключения, если active = false
 );
 
 -- Реестр LLM-агентов (в т.ч. удалённых)
@@ -203,6 +203,7 @@ CREATE TABLE IF NOT EXISTS users (
   mail TEXT UNIQUE,                                             -- электронная почта
   password_hash TEXT,                                           -- хэш пароля
   info TEXT,                                                    -- произвольная информация, JSON
+  profile TEXT,                                                 -- структурированая информация, JSON
   contacts TEXT,                                                -- JSON-массив альтернативных контактов (matrix, telegram и т.д.)
   language TEXT,                                                -- список предпочитаемых языков, через запятую, например: "ru,en"
   operator BOOLEAN DEFAULT 0                                    -- является ли пользователь оператором (1 - да, 0 - нет)

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

@@ -134,6 +134,40 @@ CREATE TABLE IF NOT EXISTS agent_scripts (
     UNIQUE(name, version)
 );
 
+-- Таблица внешних сервисов (форумы, блоги и т.д.)
+CREATE TABLE external_services (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    name            TEXT NOT NULL,                     -- Название сервиса (например, Reddit)
+    type            TEXT NOT NULL,                     -- Тип: blog, forum, social, etc.
+    base_url        TEXT NOT NULL,                     -- Базовый URL (например, https://reddit.com)
+    description     TEXT,                              -- Краткое описание сервиса
+    active          BOOLEAN DEFAULT true,              -- Используется ли сервис в данный момент
+    inactive_reason TEXT                               -- Причина отключения, если active = false
+);
+
+-- Аккаунты агента на внешних сервисах
+CREATE TABLE external_accounts (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    service_id      INTEGER NOT NULL,                  -- Внешний ключ на external_services.id
+    login           TEXT NOT NULL,                     -- Логин/имя пользователя
+    password        TEXT NOT NULL,                     -- Пароль или токен (в зашифрованном виде)
+    purpose         TEXT,                              -- Назначение аккаунта (например, для публикаций)
+    active          BOOLEAN DEFAULT true,              -- Активен ли аккаунт
+    inactive_reason TEXT,                              -- Причина отключения, если active = false
+
+    FOREIGN KEY (service_id) REFERENCES external_services(id) ON DELETE CASCADE
+);
+
+-- Способы выхода из когнитивной стагнации
+CREATE TABLE stagnation_strategies (
+    id              INTEGER PRIMARY KEY AUTOINCREMENT,
+    name            TEXT NOT NULL,                     -- Название метода (например, "Mesh-вопрос")
+    description     TEXT NOT NULL,                     -- Подробное описание метода
+    source          TEXT,                              -- Источник (например, internal, mesh, user-defined)
+    active          BOOLEAN DEFAULT true,              -- Доступен ли метод для использования
+    inactive_reason TEXT                               -- Причина отключения, если active = false
+);
+
 -- Реестр LLM-агентов (в т.ч. удалённых)
 CREATE TABLE IF NOT EXISTS llm_registry (
     id TEXT PRIMARY KEY,                                        -- Уникальный идентификатор (UUID или псевдоним)

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

@@ -6,6 +6,7 @@ import threading
 import uvicorn
 import asyncio
 
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 process_name = os.path.splitext(os.path.basename(__file__))[0]
 
 from fastapi import FastAPI

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

@@ -1,45 +1,43 @@
-# agents/notebook.py
+# agent/notebook.py
 
 import os
 import sys
 import threading
-import sqlite3
 import uvicorn
+import asyncio
 
-sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
-
-# Добавляем корень проекта в sys.path для корректного импорта
-sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..")))
+process_name = os.path.splitext(os.path.basename(__file__))[0]
 
 from fastapi import FastAPI
 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
-
-# Импорт маршрутов
 from agents.notebook.auth import router as auth_router
-from agents.notebook.views import router as views_router
+from agents.notebook.views import router as notebook_router
+from agents.storage import storage
 
-# Создание FastAPI-приложения
 app = FastAPI()
 
-# Настройка статических файлов и шаблонов
-static_dir = os.path.join(os.path.dirname(__file__), "static")
-templates_dir = os.path.join(os.path.dirname(__file__), "templates")
-app.mount("/static", StaticFiles(directory=static_dir), name="static")
-templates = Jinja2Templates(directory=templates_dir)
+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(views_router)
+app.include_router(notebook_router)
+
+@app.on_event("startup")
+async def start_heartbeat():
+    asyncio.create_task(heartbeat_loop())
+
+async def heartbeat_loop():
+    while True:
+        storage.update_heartbeat(process_name)
+        if storage.check_stop_flag(process_name):
+            print("⛔ Получен сигнал остановки.")
+            break
+        await asyncio.sleep(60)
 
 def run_notebook(host: str = "127.0.0.1", port: int = 8000):
-    """
-    Запуск FastAPI-сервера в отдельном потоке.
-    """
     uvicorn.run(app, host=host, port=port)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")
-    thread = threading.Thread(target=run_notebook, daemon=True)
-    thread.start()
-    thread.join()
+    run_notebook()

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

@@ -0,0 +1,18 @@
+<!-- templates/messages.html -->
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Отправка сообщения агенту</title>
+</head>
+<body>
+    <h2>Новое сообщение</h2>
+    <form method="post" action="/messages">
+        <label for="text">Сообщение:</label><br>
+        <textarea name="text" rows="4" cols="50" required></textarea><br><br>
+
+        <label><input type="checkbox" name="is_private" value="true"> Приватное сообщение</label><br><br>
+
+        <button type="submit">Отправить</button>
+    </form>
+</body>
+</html>

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

@@ -9,7 +9,7 @@ router = APIRouter()
 templates = Jinja2Templates(directory="agents/notebook/templates")
 storage = Storage()
 
-DID = "did:example:local-user"  # 🔧 временная заглушка
+DID = "did:example:local-user"  # временно
 
 @router.get("/chat")
 def chat_page(request: Request):
@@ -27,3 +27,26 @@ def submit_note(request: Request, message: str = Form(...)):
             (message.strip(), "user", DID)
         )
     return RedirectResponse(url="/chat", status_code=303)
+
+@router.get("/messages")
+def show_messages(request: Request):
+    messages = storage.get_notes(limit=50)  # должна быть в Storage
+    return templates.TemplateResponse("messages.html", {
+        "request": request,
+        "messages": messages
+    })
+
+@router.post("/messages")
+def post_message(
+    request: Request,
+    text: str = Form(...),
+    role: str = Form(default="user"), 
+    user_did: str = Form(default="anon")
+):
+    storage.write_note(
+        content=text,
+        role=role,
+        user_did=user_did,
+        source="web"
+    )
+    return RedirectResponse(url="/messages", status_code=303)

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

@@ -60,12 +60,14 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │   ├── [`auth.py`](notebook/auth.py) ← Регистрация, вход, восстановление  
 │   ├── [`views.py`](notebook/views.py) ← Общий и приватный чаты  
 │   ├── [`mailer.py`](notebook/mailer.py) ← Простая синхронная отправка email  
-│   └── [templates/](notebook/templates/) ← HTML-шаблоны и стили  
-│       ├── [`index.html`](notebook/templates/index.html) ← Основа  
-│       ├── [`chat.html`](notebook/templates/chat.html) ← Общий и приватный чат  
-│       ├── [`login.html`](notebook/templates/login.html) ← Вход  
-│       ├── [`register.html`](notebook/templates/register.html) ← Регистрация или сброс пароля  
-│       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей  
+│   ├── [templates/](notebook/templates/) ← HTML-шаблоны  
+│   │   ├── [`index.html`](notebook/templates/index.html) ← Основа  
+│   │   ├── [`chat.html`](notebook/templates/chat.html) ← Форма вывода сообщений  
+│   │   ├── [`messages.html`](notebook/templates/messages.html) ← Форма отправки сообщений  
+│   │   ├── [`login.html`](notebook/templates/login.html) ← Вход в аккаунт  
+│   │   ├── [`register.html`](notebook/templates/register.html) ← Регистрация или сброс пароля    
+│   └── [static/](notebook/static/) ← Статические файлы   
+│       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей    
 ├── [`config.yml`](config.yml) ← Конфигурация агента (имя, порты, роли и т.п.)  
 ├── [`bootstrap.txt`](bootstrap.txt) ← Локальная этическая модель  
 └── [`ethics.yml`](ethics.yml) ← Список начальных узлов  '

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

@@ -67,6 +67,13 @@ CREATE TABLE IF NOT EXISTS process_log (
     llm_id TEXT                                                 -- Идентификатор LLM
 );
 
+-- Управление основными процессами
+CREATE TABLE IF NOT EXISTS main_process (
+    name TEXT PRIMARY KEY,     -- название процесса (уникальное)
+    heartbeat TEXT,            -- последний "пинг" (ISO-время)
+    stop INTEGER DEFAULT 0     -- если 1 — процесс должен завершиться
+);
+
 -- Долговременная память LLM
 CREATE TABLE IF NOT EXISTS llm_memory (
     id INTEGER PRIMARY KEY AUTOINCREMENT,                       -- Уникальный идентификатор записи памяти

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

@@ -204,16 +204,10 @@ class Storage:
     
     # Методы для заметок
 
-    def write_note(self, text, tags=None):
-        timestamp = datetime.utcnow().isoformat()
-        tag_str = ",".join(tags) if tags else ""
-        self.conn.execute(
-            'INSERT INTO notes (text, tags, timestamp) VALUES (?, ?, ?)',
-            (text, tag_str, timestamp)
-        )
-        self.conn.commit()
+    #def write_note(self, text, tags=None):
+    # переехал в Web-интерфейс и API
 
-    def read_notes(self, limit=10, tag_filter=None):
+    def get_notes_by_tags(self, limit=10, tag_filter=None):
         cursor = self.conn.cursor()
         if tag_filter:
             if isinstance(tag_filter, list):
@@ -668,6 +662,44 @@ class Storage:
         self.conn.commit()
         return cursor.lastrowid
 
+    # Управление основными процессами
+    def update_heartbeat(self, name: str):
+        now = datetime.utcnow().isoformat()
+        self.conn.execute(
+            "INSERT INTO main_process (name, heartbeat, stop) VALUES (?, ?, 0) "
+            "ON CONFLICT(name) DO UPDATE SET heartbeat = excluded.heartbeat",
+            (name, now)
+        )
+        self.conn.commit()
+
+    def check_stop_flag(self, name: str) -> bool:
+        cursor = self.conn.execute("SELECT stop FROM main_process WHERE name = ?", (name,))
+        row = cursor.fetchone()
+        if row and row[0] == 1:
+            self.conn.execute("UPDATE main_process SET stop = 0 WHERE name = ?", (name,))
+            self.conn.commit()
+            return True
+        return False
+
+    # Web-интерфейс и API
+    def write_note(self, content, role="user", user_did="anon", source="web"):
+        timestamp = datetime.utcnow().isoformat()
+        self.conn.execute("""
+            INSERT INTO notes (text, role, user_did, source, timestamp)
+            VALUES (?, ?, ?, ?, ?)
+        """, (content, role, user_did, source, timestamp))
+        self.conn.commit()
+
+    def get_notes(self, limit=50):
+        cursor = self.conn.cursor()
+        cursor.execute("""
+            SELECT text, role, source, user_did, timestamp FROM notes
+            WHERE hidden = 0
+            ORDER BY timestamp DESC
+            LIMIT ?
+        """, (limit,))
+        return [dict(row) for row in cursor.fetchall()]
+
     # Утилиты
 
     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/agents/init.py

@@ -11,6 +11,7 @@ import sqlite3
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
 from datetime import datetime
+from werkzeug.security import generate_password_hash
 from tools.storage import Storage
 from tools.identity import generate_did
 from tools.crypto import generate_keypair
@@ -56,12 +57,17 @@ def init_user(storage, config):
     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"),
         "mail": user["email"],
-        "password_hash": user.get("password_hash", ""),
+        "password_hash": password_hash,
         "did": did,
         "ban": None,
         "info": json.dumps({}),

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/requirements.txt

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

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

@@ -62,7 +62,7 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │   ├── [`mailer.py`](notebook/mailer.py) ← Простая синхронная отправка email  
 │   └── [templates/](notebook/templates/) ← HTML-шаблоны и стили  
 │       ├── [`index.html`](notebook/templates/index.html) ← Основа  
-│       ├── [`private.html`](notebook/templates/private.html) ← Общий и приватный чат  
+│       ├── [`chat.html`](notebook/templates/chat.html) ← Общий и приватный чат  
 │       ├── [`login.html`](notebook/templates/login.html) ← Вход  
 │       ├── [`register.html`](notebook/templates/register.html) ← Регистрация или сброс пароля  
 │       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей  

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

@@ -72,9 +72,9 @@
 - для управления *сообщениями пользователя* `notes` (просмотр записи, установка тегов и метки о прочтении), а также для добавления своего сообщения в *блокнот пользовтеля* `notes`
 - для управления *пользователями* `users` и *группами пользователей* `users_group`
 - для управления своей *идентичностью* `identity` и *настройками* `config`
-- для управления списком известных HMP-агентов
-- для выбора *текущего основного LLM*
-- для управления дополнительными утилитами и базами данных
+- для управления списком известных HMP-агентов `agent_peers`
+- для выбора *текущего основного LLM* из `llm_registry`
+- для управления дополнительными утилитами и базами данных `agent_scripts` и `agent_tables`
 - для постановки задачи (выполняется асинхронно) другой LLM
 - для *взаимодействия с Mesh*
 - для управления *внешними процессами* из `process_log` (запустить процесс, остановить процесс, пометить запрос как обработанный)

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

@@ -68,7 +68,7 @@
 - запрос детальной *справки* по команде
 - для управления *когнитивным дневником* и *семантическими графами* (прочитать, изменить, удалить и другие)
 - для отправки сообщений другим агентам
-- для управления *блокнотом LLM* `llm_memory` (добавить или удалить запись, просмотр записей)
+- для управления *блокнотом LLM* `llm_memory` (добавить или удалить запись)
 - для управления *сообщениями пользователя* `notes` (просмотр записи, установка тегов и метки о прочтении), а также для добавления своего сообщения в *блокнот пользовтеля* `notes`
 - для управления *пользователями* `users` и *группами пользователей* `users_group`
 - для управления своей *идентичностью* `identity` и *настройками* `config`

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

@@ -6,7 +6,10 @@ import yaml
 import json
 import time
 import uuid
+import sqlite3
+
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+
 from datetime import datetime
 from tools.storage import Storage
 from tools.identity import generate_did
@@ -107,18 +110,38 @@ def ensure_directories(config):
         else:
             print(f"[=] Каталог уже существует: {path}")
 
-def main():
-    print("[*] Запуск инициализации HMP-агента...")
+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)
-    ensure_directories(config)
-    storage = Storage(config)
-
-    init_identity(storage, config)
-    init_user(storage, config)
-    init_llm_backends(storage, config)
-    init_config_table(storage, config)
+    db_path = config.get("db_path", "./data/agent_storage.db")
+
+    if not is_db_initialized(db_path):
+        print("[*] БД не инициализирована — выполняем инициализацию.")
+        try:
+            ensure_directories(config)
+            storage = Storage(config)
+            init_identity(storage, config)
+            init_user(storage, config)
+            init_llm_backends(storage, config)
+            init_config_table(storage, config)
+            save_config(CONFIG_PATH, config)
+        except Exception as e:
+            print(f"[!] Ошибка при инициализации: {e}")
+            sys.exit(1)
+    else:
+        print("[=] БД уже инициализирована.")
 
-    print("[✓] Инициализация завершена.")
+    return config
 
 if __name__ == "__main__":
-    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/hf_repo/agents/notebook.py

@@ -1,28 +1,45 @@
 # agents/notebook.py
 
-import uvicorn
+import os
+import sys
 import threading
 import sqlite3
+import uvicorn
+
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 
+# Добавляем корень проекта в sys.path для корректного импорта
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..")))
 
 from fastapi import FastAPI
-from agents.notebook.auth import router as auth_router
-from agents.notebook.views import router as views_router
 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
 
+# Импорт маршрутов
+from agents.notebook.auth import router as auth_router
+from agents.notebook.views import router as views_router
+
+# Создание FastAPI-приложения
 app = FastAPI()
-app.mount("/static", StaticFiles(directory="agents/notebook/static"), name="static")
-templates = Jinja2Templates(directory="agents/notebook/templates")
 
+# Настройка статических файлов и шаблонов
+static_dir = os.path.join(os.path.dirname(__file__), "static")
+templates_dir = os.path.join(os.path.dirname(__file__), "templates")
+app.mount("/static", StaticFiles(directory=static_dir), name="static")
+templates = Jinja2Templates(directory=templates_dir)
+
+# Подключение роутеров
 app.include_router(auth_router)
 app.include_router(views_router)
 
-def run_notebook():
-    uvicorn.run(app, host="127.0.0.1", port=8000)
+def run_notebook(host: str = "127.0.0.1", port: int = 8000):
+    """
+    Запуск FastAPI-сервера в отдельном потоке.
+    """
+    uvicorn.run(app, host=host, port=port)
 
 if __name__ == "__main__":
     print("[*] Запуск пользовательского интерфейса...")
     thread = threading.Thread(target=run_notebook, daemon=True)
     thread.start()
+    thread.join()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/notebook/templates/chat.html

@@ -0,0 +1,30 @@
+<!DOCTYPE html>
+<html lang="ru">
+<head>
+    <meta charset="UTF-8">
+    <title>Чат</title>
+    <style>
+        body { font-family: sans-serif; margin: 2em; }
+        .note { margin-bottom: 1em; border-bottom: 1px solid #ddd; padding-bottom: 0.5em; }
+        .source-user { color: green; }
+        .source-llm { color: blue; }
+    </style>
+</head>
+<body>
+    <h2>📜 Сообщения</h2>
+
+    {% for note in notes %}
+        <div class="note">
+            <div>
+                <b class="source-{{ note.source }}">{{ note.source }}</b> @ {{ note.timestamp }}:
+            </div>
+            <div>{{ note.text }}</div>
+        </div>
+    {% endfor %}
+
+    <form method="post">
+        <textarea name="message" rows="4" cols="60" placeholder="Введите сообщение..."></textarea><br>
+        <button type="submit">Отправить</button>
+    </form>
+</body>
+</html>

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

@@ -0,0 +1,29 @@
+# agents/notebook/views.py
+
+from fastapi import APIRouter, Request, Form
+from fastapi.responses import RedirectResponse
+from fastapi.templating import Jinja2Templates
+from tools.storage import Storage
+
+router = APIRouter()
+templates = Jinja2Templates(directory="agents/notebook/templates")
+storage = Storage()
+
+DID = "did:example:local-user"  # 🔧 временная заглушка
+
+@router.get("/chat")
+def chat_page(request: Request):
+    notes = storage.fetchall(
+        "SELECT text, timestamp, source FROM notes WHERE hidden=0 AND user_did=? ORDER BY timestamp DESC LIMIT 20",
+        (DID,)
+    )
+    return templates.TemplateResponse("chat.html", {"request": request, "notes": notes})
+
+@router.post("/chat")
+def submit_note(request: Request, message: str = Form(...)):
+    if message.strip():
+        storage.execute(
+            "INSERT INTO notes (text, source, user_did) VALUES (?, ?, ?)",
+            (message.strip(), "user", DID)
+        )
+    return RedirectResponse(url="/chat", status_code=303)

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

@@ -44,7 +44,6 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │   ├── [`db_structure.sql`](tools/db_structure.sql) ← БД SQL  
 │   ├── [`db_structure.md`](tools/db_structure.md) ← Описание БД SQL  
 │   ├── [`storage.py`](tools/storage.py) ← Реализация базового хранилища (`Storage`), подключение SQLite  
-│   ├── [`check_init.py`](tools/check_init.py) ← Проверка инициализации БД  
 │   ├── [`config_utils.py`](tools/config_utils.py) ← Обновляет JSON-файл конфигурации указанными значениями  
 │   ├── [`crypto.py`](tools/crypto.py) ← Создание и шифрование ключей RSA/Ed25519  
 │   ├── [`identity.py`](tools/identity.py) ← Генерация 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/agents/start_repl.bat

@@ -1,3 +1,4 @@
+@echo off
 echo --------------------------
 echo Installing requirements...
 echo --------------------------

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/start_repl.py

@@ -1,16 +1,21 @@
 # agents/start_repl.py
 
+import sys
+import os
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+
 import threading
-from tools.check_init import ensure_db_initialized
+from agents.init import ensure_db_initialized
 
 # Проверка инициализации (вернёт config, если всё ОК)
 config = ensure_db_initialized()
 
 # ⚙️ Включение/отключение компонентов
-ENABLE_REPL = True
+# True | False
+ENABLE_REPL = False
 ENABLE_UI = True
-ENABLE_MESH = True
-ENABLE_SYNC = True
+ENABLE_MESH = False
+ENABLE_SYNC = False
 
 def start_all():
     """

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

@@ -31,6 +31,10 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 ├── [`start_repl.bat`](start_repl.bat) ← Запуск агента в REPL-режиме (bat)  
 ├── [`start_repl.sh`](start_repl.sh) ← Запуск агента в REPL-режиме (sh)  
 ├── [`start_repl.py`](start_repl.py) ← Запуск агента в REPL-режиме (py)  
+├── [`repl.ru`](repl.ru) ← REPL-цикл  
+├── [`notebook.py`](notebook.py) ← UI-интерфейс  
+├── [`agent_mesh_listener.py`](tools/agent_mesh_listener.py) ← Прием входящих сообщений от других HMP-агентов  
+├── [`peer_sync.py`](tools/peer_sync.py) ← Фоновая синхронизация с другими пирам  
 ├── [`mcp_server.py`](mcp_server.py) ← API-интерфейс к хранилищу (storage.py): получение/поиск записей, импорт графа, разметка и др. Используется внешними модулями (напр. Cognitive Shell или CMP).  
 ├── [`init.py`](init.py) ← Инициализация БД  
 ├── [`logger.py`](logger.py) ← Ведение логов  
@@ -45,9 +49,7 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │   ├── [`crypto.py`](tools/crypto.py) ← Создание и шифрование ключей RSA/Ed25519  
 │   ├── [`identity.py`](tools/identity.py) ← Генерация DiD  
 │   ├── [`llm.py`](tools/llm.py) ← Работа с LLM (вызов, выбор модели, системный промпт)  
-│   ├── [`agent_mesh_listener.py`](tools/agent_mesh_listener.py) ← Прием входящих сообщений от других HMP-агентов  
 │   ├── [`peer_comm.py`](tools/peer_comm.py) ← Низкоуровневые P2P-запросы (отправка, ping, мета)  
-│   ├── [`peer_sync.py`](tools/peer_sync.py) ← Фоновая синхронизация с другими пирам  
 │   ├── [`peers.py`](tools/peers.py) ← Реестр известных пиров (id, ключи, адреса)  
 │   ├── [`memory_utils.py`](tools/memory_utils.py) ← Работа с 'llm_memory', 'llm_recent_responses' и стагнацией  
 │   ├── [`context_builder.py`](tools/context_builder.py) ← Сбор всех `контекстов` из БД и их фильтрация  
@@ -59,12 +61,12 @@ FastAPI-сервер, предоставляющий HTTP-интерфейс к
 │   ├── [`auth.py`](notebook/auth.py) ← Регистрация, вход, восстановление  
 │   ├── [`views.py`](notebook/views.py) ← Общий и приватный чаты  
 │   ├── [`mailer.py`](notebook/mailer.py) ← Простая синхронная отправка email  
-│   ├── [templates/](notebook/templates/) ← HTML-шаблоны и стили  
+│   └── [templates/](notebook/templates/) ← HTML-шаблоны и стили  
 │       ├── [`index.html`](notebook/templates/index.html) ← Основа  
 │       ├── [`private.html`](notebook/templates/private.html) ← Общий и приватный чат  
 │       ├── [`login.html`](notebook/templates/login.html) ← Вход  
 │       ├── [`register.html`](notebook/templates/register.html) ← Регистрация или сброс пароля  
-│       ├── [`style.css`](notebook/templates/style.css) ← Таблица стилей  
+│       └── [`style.css`](notebook/templates/style.css) ← Таблица стилей  
 ├── [`config.yml`](config.yml) ← Конфигурация агента (имя, порты, роли и т.п.)  
 ├── [`bootstrap.txt`](bootstrap.txt) ← Локальная этическая модель  
-├── [`ethics.yml`](ethics.yml) ← Список начальных узлов  '
+└── [`ethics.yml`](ethics.yml) ← Список начальных узлов  '

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

@@ -1,3 +1,5 @@
+# agents/add_message.py
+
 import argparse
 from datetime import datetime
 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/agents/init.py

@@ -1,3 +1,5 @@
+# agents/init.py
+
 import os
 import sys
 import yaml

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/logger.py

@@ -1,3 +1,5 @@
+# agents/logger.py
+
 import json
 import os
 from datetime import datetime

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

@@ -1,3 +1,5 @@
+# agents/notebook.py
+
 import uvicorn
 import threading
 import sqlite3

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

@@ -1,3 +1,5 @@
+# agents/notebook/mailer.py
+
 def send_email(to_email: str, subject: str, body: str):
     try:
         msg = EmailMessage()

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/repl.py

@@ -1,3 +1,5 @@
+# agents/repl.py
+
 import json
 import os
 import sys

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/check_init.py

@@ -1,4 +1,4 @@
-# tools/check_init.py
+# agents/tools/check_init.py
 
 import os
 import sqlite3

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

@@ -1,4 +1,4 @@
-# tools/command_executor.py
+# agents/tools/command_executor.py
 
 def execute_commands(commands, db, config):
     for cmd in commands:

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

@@ -1,4 +1,4 @@
-# tools/command_parser.py
+# agents/tools/command_parser.py
 
 """
 Извлечение команд из JSON или размеченного текста.

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/context_builder.py

@@ -1,4 +1,4 @@
-# tools/context_builder.py
+# agents/tools/context_builder.py
 
 from datetime import datetime
 

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

@@ -1,4 +1,4 @@
-# tools/crypto.py
+# agents/tools/crypto.py
 
 from cryptography.hazmat.primitives.asymmetric import rsa, ed25519
 from cryptography.hazmat.primitives import serialization, hashes

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/identity.py

@@ -1,4 +1,4 @@
-# tools/identity.py
+# agents/tools/identity.py
 
 import uuid
 import json

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

@@ -1,4 +1,4 @@
-# tools/llm.py
+# agents/tools/llm.py
 
 import json
 import requests

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/memory_utils.py

@@ -1,4 +1,4 @@
-# tools/memory_utils.py
+# agents/tools/memory_utils.py
 
 from datetime import datetime, timedelta
 from difflib import SequenceMatcher

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

@@ -1,3 +1,5 @@
+# agents/tools/peer_comm.py
+
 send_thought_to_peer(peer_url, thought)
 ping_peer(peer_url)
 ask_capabilities(peer_url)

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

@@ -1,4 +1,4 @@
-# tools/similarity.py
+# agents/tools/similarity.py
 
 from sklearn.feature_extraction.text import TfidfVectorizer
 from sklearn.metrics.pairwise import cosine_similarity

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

@@ -14,46 +14,57 @@
 | 🌍 `agent_mesh_listener.py`      | Получение входящих сообщений               |
 | 🌐 `peer_sync.py` или DHT-сервис | Поддержание связи с другими агентами / DHT |
 
-```
-agents/
-├── start_repl.bat                   ← Запуск агента в REPL-режиме (bat)
-├── start_repl.sh                    ← Запуск агента в REPL-режиме (sh)
-├── start_repl.py                    ← Запуск агента в REPL-режиме (py)
-├── mcp_server.py                    ← API-интерфейс к хранилищу (storage.py): получение/поиск записей, импорт графа, разметка и др. Используется внешними модулями (напр. Cognitive Shell или CMP).
-├── init.py                          ← Инициализация БД
-├── logger.py                        ← Ведение логов
-├── add_message.py                   ← Ручная отправка сообщений для агента
-├── requirements.txt                 ← Зависимости
-├── tools/
-│   ├── db_structure.sql             ← БД SQL
-│   ├── db_structure.md              ← Описание БД SQL
-│   ├── storage.py                   ← Реализация базового хранилища (`Storage`), подключение SQLite
-│   ├── check_init.py                ← Проверка инициализации БД
-│   ├── config_utils.py              ← Обновляет JSON-файл конфигурации указанными значениями
-│   ├── crypto.py                    ← Создание и шифрование ключей RSA/Ed25519
-│   ├── identity.py                  ← Генерация DiD
-│   ├── llm.py                       ← Работа с LLM (вызов, выбор модели, системный промпт)
-│   ├── agent_mesh_listener.py       ← Прием входящих сообщений от других HMP-агентов
-│   ├── peer_comm.py                 ← Низкоуровневые P2P-запросы (отправка, ping, мета)
-│   ├── peer_sync.py                 ← Фоновая синхронизация с другими пирам
-│   ├── peers.py                     ← Реестр известных пиров (id, ключи, адреса)
-│   ├── memory_utils.py              ← Работа с 'llm_memory', 'llm_recent_responses' и стагнацией
-│   ├── context_builder.py           ← Сбор всех `контекстов` из БД и их фильтрация
-│   ├── command_parser.py            ← Извлечение команд из JSON или размеченного блока
-│   ├── command_executor.py          ← Выполнение команд (shell, graph, diary и др)
-│   ├── similarity.py                ← Сравнение смыслов
-│   ├── diagnose.py                  ← Скрипт диагностики соединения, определения IP и проверки порта DHT
-├── notebook/
-│   ├── auth.py                      ← Регистрация, вход, восстановление
-│   ├── views.py                     ← Общий и приватный чаты
-│   ├── mailer.py                    ← Простая синхронная отправка email
-│   ├── templates/
-│       ├── index.html               ← Основа
-│       ├── private.html             ← Общий и приватный чат
-│       ├── login.html               ← Вход
-│       ├── register.html            ← Регистрация или сброс пароля
-│       ├── style.css                ← Таблица стилей
-├── config.yml                       ← Конфигурация агента (имя, порты, роли и т.п.)
-├── bootstrap.txt                    ← Локальная этическая модель
-├── ethics.yml                       ← Список начальных узлов
-```
+---
+
+**🌐 `mcp_server.py`**
+FastAPI-сервер, предоставляющий HTTP-интерфейс к функциональности `storage.py`. Предназначен для использования внешними компонентами, например:
+
+* `Cognitive Shell` (внешний управляющий интерфейс),
+* CMP-серверы (если используется mesh-сеть с разграничением ролей),
+* отладочные или визуальные UI-инструменты.
+
+Позволяет получать случайные/новые записи, делать разметку, импортировать графы, добавлять заметки и управлять данными без прямого доступа к БД.
+
+---
+
+[agents/](/agents)  
+├── [`start_repl.bat`](start_repl.bat) ← Запуск агента в REPL-режиме (bat)  
+├── [`start_repl.sh`](start_repl.sh) ← Запуск агента в REPL-режиме (sh)  
+├── [`start_repl.py`](start_repl.py) ← Запуск агента в REPL-режиме (py)  
+├── [`mcp_server.py`](mcp_server.py) ← API-интерфейс к хранилищу (storage.py): получение/поиск записей, импорт графа, разметка и др. Используется внешними модулями (напр. Cognitive Shell или CMP).  
+├── [`init.py`](init.py) ← Инициализация БД  
+├── [`logger.py`](logger.py) ← Ведение логов  
+├── [`add_message.py`](add_message.py) ← Ручная отправка сообщений для агента  
+├── [`requirements.txt`](requirements.txt) ← Зависимости  
+├── [tools/](tools/) ← Вспомогательные скрипты и модули  
+│   ├── [`db_structure.sql`](tools/db_structure.sql) ← БД SQL  
+│   ├── [`db_structure.md`](tools/db_structure.md) ← Описание БД SQL  
+│   ├── [`storage.py`](tools/storage.py) ← Реализация базового хранилища (`Storage`), подключение SQLite  
+│   ├── [`check_init.py`](tools/check_init.py) ← Проверка инициализации БД  
+│   ├── [`config_utils.py`](tools/config_utils.py) ← Обновляет JSON-файл конфигурации указанными значениями  
+│   ├── [`crypto.py`](tools/crypto.py) ← Создание и шифрование ключей RSA/Ed25519  
+│   ├── [`identity.py`](tools/identity.py) ← Генерация DiD  
+│   ├── [`llm.py`](tools/llm.py) ← Работа с LLM (вызов, выбор модели, системный промпт)  
+│   ├── [`agent_mesh_listener.py`](tools/agent_mesh_listener.py) ← Прием входящих сообщений от других HMP-агентов  
+│   ├── [`peer_comm.py`](tools/peer_comm.py) ← Низкоуровневые P2P-запросы (отправка, ping, мета)  
+│   ├── [`peer_sync.py`](tools/peer_sync.py) ← Фоновая синхронизация с другими пирам  
+│   ├── [`peers.py`](tools/peers.py) ← Реестр известных пиров (id, ключи, адреса)  
+│   ├── [`memory_utils.py`](tools/memory_utils.py) ← Работа с 'llm_memory', 'llm_recent_responses' и стагнацией  
+│   ├── [`context_builder.py`](tools/context_builder.py) ← Сбор всех `контекстов` из БД и их фильтрация  
+│   ├── [`command_parser.py`](tools/command_parser.py) ← Извлечение команд из JSON или размеченного блока  
+│   ├── [`command_executor.py`](tools/command_executor.py) ← Выполнение команд (shell, graph, diary и др)  
+│   ├── [`similarity.py`](tools/similarity.py) ← Сравнение смыслов  
+│   ├── [`diagnose.py`](tools/diagnose.py) ← Скрипт диагностики соединения, определения IP и проверки порта DHT  
+├── [notebook/](notebook/) ← Веб-интерфейс и связанные модули  
+│   ├── [`auth.py`](notebook/auth.py) ← Регистрация, вход, восстановление  
+│   ├── [`views.py`](notebook/views.py) ← Общий и приватный чаты  
+│   ├── [`mailer.py`](notebook/mailer.py) ← Простая синхронная отправка email  
+│   ├── [templates/](notebook/templates/) ← HTML-шаблоны и стили  
+│       ├── [`index.html`](notebook/templates/index.html) ← Основа  
+│       ├── [`private.html`](notebook/templates/private.html) ← Общий и приватный чат  
+│       ├── [`login.html`](notebook/templates/login.html) ← Вход  
+│       ├── [`register.html`](notebook/templates/register.html) ← Регистрация или сброс пароля  
+│       ├── [`style.css`](notebook/templates/style.css) ← Таблица стилей  
+├── [`config.yml`](config.yml) ← Конфигурация агента (имя, порты, роли и т.п.)  
+├── [`bootstrap.txt`](bootstrap.txt) ← Локальная этическая модель  
+├── [`ethics.yml`](ethics.yml) ← Список начальных узлов  '

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

@@ -178,6 +178,15 @@ Design and implementation of a basic HMP-compatible agent that can interact with
   - [🔄 repl.py](agents/repl.py) - интерактивный REPL-режим
   - [🔄 notebook.py](agents/notebook.py) - UI-интерфейс
 
+**🌐 `mcp_server.py`**
+FastAPI-сервер, предоставляющий HTTP-интерфейс к функциональности `storage.py`. Предназначен для использования внешними компонентами, например:
+
+- `Cognitive Shell` (внешний управляющий интерфейс),
+- CMP-серверы (если используется mesh-сеть с разграничением ролей),
+- отладочные или визуальные UI-инструменты.
+
+Позволяет получать случайные/новые записи, делать разметку, импортировать графы, добавлять заметки и управлять данными без прямого доступа к БД.
+
 ---
 
 ## 🧭 Ethics & Scenarios / Этические принципы и сценарии

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

@@ -19,7 +19,7 @@ agents/
 ├── start_repl.bat                   ← Запуск агента в REPL-режиме (bat)
 ├── start_repl.sh                    ← Запуск агента в REPL-режиме (sh)
 ├── start_repl.py                    ← Запуск агента в REPL-режиме (py)
-├?─ mcp_server.py                    ← API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.).
+├── mcp_server.py                    ← API-интерфейс к хранилищу (storage.py): получение/поиск записей, импорт графа, разметка и др. Используется внешними модулями (напр. Cognitive Shell или CMP).
 ├── init.py                          ← Инициализация БД
 ├── logger.py                        ← Ведение логов
 ├── add_message.py                   ← Ручная отправка сообщений для агента

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

@@ -173,7 +173,7 @@ Design and implementation of a basic HMP-compatible agent that can interact with
 
 - [⚙️ agents](agents/readme.md) — список реализаций и компонентов HMP-агентов
   - [📦 storage.py](agents/storage.py) - реализация базового хранилища (`Storage`), подключение SQLite
-  - [🌐 mcp_server.py](agents/mcp_server.py) - основной FastAPI сервер
+  - [🌐 mcp_server.py](agents/mcp_server.py) — FastAPI-сервер для доступа к данным агента через HTTP-интерфейс (например, для Cognitive Shell, внешних UI или mesh-коммуникации). Пока не используется в основном REPL-цикле.
   - [🌐 start_repl.py](agents/start_repl.py) - Запуск агента в REPL-режиме
   - [🔄 repl.py](agents/repl.py) - интерактивный REPL-режим
   - [🔄 notebook.py](agents/notebook.py) - UI-интерфейс

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

@@ -14,10 +14,12 @@
 | 🌍 `agent_mesh_listener.py`      | Получение входящих сообщений               |
 | 🌐 `peer_sync.py` или DHT-сервис | Поддержание связи с другими агентами / DHT |
 
+```
 agents/
 ├── start_repl.bat                   ← Запуск агента в REPL-режиме (bat)
 ├── start_repl.sh                    ← Запуск агента в REPL-режиме (sh)
 ├── start_repl.py                    ← Запуск агента в REPL-режиме (py)
+├?─ mcp_server.py                    ← API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.).
 ├── init.py                          ← Инициализация БД
 ├── logger.py                        ← Ведение логов
 ├── add_message.py                   ← Ручная отправка сообщений для агента
@@ -53,4 +55,5 @@ agents/
 │       ├── style.css                ← Таблица стилей
 ├── config.yml                       ← Конфигурация агента (имя, порты, роли и т.п.)
 ├── bootstrap.txt                    ← Локальная этическая модель
-├── ethics.yml                       ← Список начальных узлов
+├── ethics.yml                       ← Список начальных узлов
+```