Sync from GitHub with Git LFS

agents/logger.py

@@ -9,12 +9,29 @@ def log_event(event_type, message, extra=None):
 
     entry = {
         "timestamp": datetime.utcnow().isoformat(),
-        "event": event_type,       # например: 'thought', 'input', 'error', 'action'
-        "message": message,        # краткое описание или фраза
+        "event": event_type,  # например: 'thought', 'input', 'error', 'action'
+        "message": message,
     }
 
     if extra:
-        entry["extra"] = extra     # например: {"node_id": "xyz", "reasoning": "..."}
-    
+        entry["extra"] = extra
+
+    with open(LOG_FILE, "a", encoding="utf-8") as f:
+        f.write(json.dumps(entry, ensure_ascii=False) + "\n")
+
+
+def log_repl_snapshot(snapshot: dict):
+    """
+    Запись полной структуры REPL-контекста в лог, с возможностью последующего анализа.
+    """
+    os.makedirs(os.path.dirname(LOG_FILE), exist_ok=True)
+
+    entry = {
+        "timestamp": datetime.utcnow().isoformat(),
+        "event": "repl_snapshot",
+        "message": "Полный REPL-контекст",
+        "context": snapshot,
+    }
+
     with open(LOG_FILE, "a", encoding="utf-8") as f:
         f.write(json.dumps(entry, ensure_ascii=False) + "\n")

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

@@ -35,7 +35,7 @@
 - **контекст_6 (llm_memory):** *внутренний дневник LLM*, куда она записывает собственные размышления, гипотезы, задачи и инсайты.  
   - Это не просто лог предыдущих сообщений, а именно *внутреннее долговременное хранилище* разума агента.
   - Может быть представлено в виде таблицы `llm_memory`, отдельной от `agent_log`.
-- **контекст_7:**: результат работы `anti-Stagnation Reflex` из предыдущей итерации
+- **контекст_7:** результат работы `anti-Stagnation Reflex` из предыдущей итерации
 
 ## 3. Запрос к LLM
 

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

@@ -13,7 +13,7 @@
 
 Контексты, формируемые скриптом перед запросом к LLM:
 
-- **контекст_0:**:
+- **контекст_0:**
 ```
 Ты являешься когнитивным ядром HMP-агента. Твоя основная задача — размышлять, анализировать информацию, строить смысловые карты и предлагать действия.  
 Ты стремишься:

hf_repo/hf_repo/hf_repo/agents/repl.py

@@ -1,5 +1,7 @@
 # agents/repl.py
 
+import json
+import os
 import time
 from datetime import datetime
 from tools.context_builder import build_contexts, build_prompt
@@ -34,9 +36,17 @@ def run_repl(config=None):
         # 2. Формирование запроса и вызов LLM
         prompt = build_prompt(contexts)
         llm_response = call_llm(prompt, config=config)
+        repl_log_entry = {
+            "timestamp": tick_start,
+            "prompt": prompt.strip(),
+            "llm_response": llm_response.strip(),
+        }
+
 
         # 3. Проверка на стагнацию
-        if detect_stagnation(db, llm_response):
+        is_stagnant = detect_stagnation(db, llm_response)
+        repl_log_entry["stagnation_detected"] = is_stagnant
+        if is_stagnant:
             print("⚠️ Стагнация выявлена. Активирован Anti-Stagnation Reflex.")
             llm_response = activate_anti_stagnation(db, config=config)
 
@@ -45,9 +55,14 @@ def run_repl(config=None):
 
         # 5. Извлечение и выполнение команд
         commands = extract_commands(llm_response)
+        repl_log_entry["commands_extracted"] = commands
         execute_commands(commands, db=db, config=config)
 
-        # 6. Сохранение истории и завершение итерации
+        # 6. Логирование полной итерации в файл
+        log_path = config.get("repl_log_path", "logs/repl_log.jsonl")
+        os.makedirs(os.path.dirname(log_path), exist_ok=True)
+        with open(log_path, "a", encoding="utf-8") as f:
+            f.write(json.dumps(repl_log_entry, ensure_ascii=False) + "\n")
         db.write_llm_response(llm_response)
         db.update_agent_log(timestamp=tick_start)
 

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

@@ -0,0 +1,20 @@
+import json
+import os
+from datetime import datetime
+
+LOG_FILE = "logs/repl_log.jsonl"
+
+def log_event(event_type, message, extra=None):
+    os.makedirs(os.path.dirname(LOG_FILE), exist_ok=True)
+
+    entry = {
+        "timestamp": datetime.utcnow().isoformat(),
+        "event": event_type,       # например: 'thought', 'input', 'error', 'action'
+        "message": message,        # краткое описание или фраза
+    }
+
+    if extra:
+        entry["extra"] = extra     # например: {"node_id": "xyz", "reasoning": "..."}
+    
+    with open(LOG_FILE, "a", encoding="utf-8") as f:
+        f.write(json.dumps(entry, ensure_ascii=False) + "\n")

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/readme.md

@@ -7,6 +7,7 @@ agents/
 ├── qa.py                  ← Режим "вопрос-ответ".
 ├── repl.py                ← Интерактивный REPL-режим.
 ├── mcp_server.py          ← API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.).
+├── logger.py              ← Ведение логов.
 ├── notebook.py            ← Добавление и просмотр пользователем записей в блокноте.
 ├── config.yml             ← Конфигурация агента (имя, порты, роли и т.п.).
 ├── ethics.yml             ← Локальная этическая модель.
@@ -19,6 +20,7 @@ agents/
     ├── context_builder.py     ← Сбор всех `контекстов` из БД и их фильтрация.
     ├── peers.py               ← Информация о пирах.
     ├── peer_comm.py           ← Запросы к пирам.
+    ├── peer_sync.py           ← Модуль обмена сообщениями.
     ├── llm.py                 ← Работа с LLM (вызов, выбор модели, системный промпт).
     ├── command_parser.py      ← Извлечение команд из JSON или размеченного блока.
     ├── command_executor.py    ← Выполнение команд (shell, graph, diary и др).
@@ -34,6 +36,7 @@ agents/
 * [repl.py](repl.py) - Интерактивный REPL-режим.
 * [mcp_server.py](mcp_server.py) - API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.).
 * [notebook.py](notebook.py) - Добавление и просмотр пользователем записей в блокноте.
+* [logger.py](logger.py) - Ведение логов.
 * tools
   * [storage.py](tools/storage.py) - Реализация базового хранилища (`Storage`), подключение SQLite.
   * [init_db.py](tools/init_db.py) - Инициализация базы данных.

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/peer_comm.py

@@ -0,0 +1,3 @@
+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/agents/readme.md

@@ -17,6 +17,8 @@ agents/
     ├── diagnose.py            ← Скрипт диагностики соединения, определения IP и проверки порта DHT.
     ├── agent_mesh_listener.py ← Прием входящих сообщений от других HMP-агентов
     ├── context_builder.py     ← Сбор всех `контекстов` из БД и их фильтрация.
+    ├── peers.py               ← Информация о пирах.
+    ├── peer_comm.py           ← Запросы к пирам.
     ├── llm.py                 ← Работа с LLM (вызов, выбор модели, системный промпт).
     ├── command_parser.py      ← Извлечение команд из JSON или размеченного блока.
     ├── command_executor.py    ← Выполнение команд (shell, graph, diary и др).
@@ -37,6 +39,7 @@ agents/
   * [init_db.py](tools/init_db.py) - Инициализация базы данных.
   * [llm.py](tools/llm.py) - Работа с LLM (вызов, выбор модели, системный промпт).
   * [context_builder.py](tools/context_builder.py) - Сбор всех `контекстов` из БД и их фильтрация.
+  * [peer_comm.py](tools/peer_comm.py) - Запросы к пирам.
   * [command_parser.py](tools/command_parser.py) - Извлечение команд из JSON или размеченного блока.
   * [command_executor.py](tools/command_executor.py) - Выполнение команд (shell, graph, diary и др).
   * [memory_utils.py](tools/memory_utils.py) - Работа с 'llm_memory', 'llm_recent_responses' и стагнацией.

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

@@ -23,6 +23,11 @@ def run_repl(config=None):
         tick_start = datetime.utcnow().isoformat()
         print(f"\n=== [🌀 Новый тик REPL] {tick_start} ===")
 
+        # 0. Обновление информации о пирах
+        from tools.peers import refresh_peer_list, check_peer_statuses
+        refresh_peer_list(db)
+        check_peer_statuses(db)
+
         # 1. Построение контекстов
         contexts = build_contexts(db=db, config=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/README.md

@@ -172,10 +172,9 @@ Design and implementation of a basic HMP-compatible agent that can interact with
 ### ⚙️ Development / Разработка
 
 - [⚙️ agents](agents/readme.md) — список реализаций и компонентов HMP-агентов
-  - 📦 [storage.py](agents/storage.py) - реализация базового хранилища (`Storage`), подключение SQLite
-  - 🌐 [mcp_server.py](agents/mcp_server.py) - основной FastAPI сервер
-  - 🧠 [concept_store.py](agents/tools/concept_store.py) - управление концептами, связь с ИИ
-  - 📓 [notebook_store.py](agents/tools/notebook_store.py) - user notebook (записи, черновики, пометки)
+  - [📦 storage.py](agents/storage.py) - реализация базового хранилища (`Storage`), подключение SQLite
+  - [🌐 mcp_server.py](agents/mcp_server.py) - основной FastAPI сервер
+  - [🔄 repl.py](agents/repl.py) - интерактивный REPL-режим
 - [⚙️ api_structure_2025-07-23.md](meta/api_structure_2025-07-23.md) - API структура (сводка за 2025-07-23)
 
 ---

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

@@ -15,11 +15,11 @@
 | tags      | TEXT    | Список тегов через запятую                       |
 | priority  | INTEGER | Приоритет (0 — обычный, >0 — более важные мысли) |
 | timestamp | TEXT    | Дата и время создания записи                     |
-| llm\_id   | TEXT    | Идентификатор LLM, добавившей запись             |
+| llm_id    | TEXT    | Идентификатор LLM, добавившей запись             |
 
 ---
 
-### 🧭 `concepts`
+### 🧱 `concepts`
 
 **Назначение:** Хранение концептов — понятий, сущностей и идей.
 
@@ -29,7 +29,7 @@
 | name        | TEXT    | Название концепта (уникальное)       |
 | description | TEXT    | Краткое описание                     |
 | timestamp   | TEXT    | Время создания                       |
-| llm\_id     | TEXT    | Идентификатор LLM, добавившей запись |
+| llm_id      | TEXT    | Идентификатор LLM, добавившей запись |
 
 ---
 
@@ -40,15 +40,15 @@
 | Поле              | Тип     | Описание                                          |
 | ----------------- | ------- | ------------------------------------------------- |
 | id                | INTEGER | Уникальный идентификатор связи                    |
-| from\_concept\_id | INTEGER | ID исходного концепта                             |
-| to\_concept\_id   | INTEGER | ID целевого концепта                              |
-| relation\_type    | TEXT    | Тип связи (`is_a`, `related_to`, `part_of` и др.) |
+| from_concept_id   | INTEGER | ID исходного концепта                             |
+| to_concept_id     | INTEGER | ID целевого концепта                              |
+| relation_type     | TEXT    | Тип связи (`is_a`, `related_to`, `part_of` и др.) |
 | timestamp         | TEXT    | Время добавления связи                            |
-| llm\_id           | TEXT    | Идентификатор LLM, добавившей связь               |
+| llm_id            | TEXT    | Идентификатор LLM, добавившей связь               |
 
 ---
 
-### ✍️ `notes`
+### 🖍️ `notes`
 
 **Назначение:** Произвольные заметки и сообщения (от пользователя, LLM или системы).
 
@@ -63,7 +63,7 @@
 | hidden    | INTEGER | Скрывать от пользователя (`1` — скрыто)                    |
 | priority  | INTEGER | Приоритет заметки                                          |
 | timestamp | TEXT    | Время создания                                             |
-| llm\_id   | TEXT    | Идентификатор LLM, добавившей запись                       |
+| llm_id    | TEXT    | Идентификатор LLM, добавившей запись                       |
 
 ---
 
@@ -80,11 +80,11 @@
 | status    | TEXT    | Текущее состояние (`ok`, `warning`, `error`, `timeout`, `offline`, `close`) |
 | priority  | INTEGER | Приоритет события                                                           |
 | timestamp | TEXT    | Время записи                                                                |
-| llm\_id   | TEXT    | Идентификатор LLM, зафиксировавшей событие                                  |
+| llm_id    | TEXT    | Идентификатор LLM, зафиксировавшей событие                                  |
 
 ---
 
-### 🧩 `llm_memory`
+### 🥉 `llm_memory`
 
 **Назначение:** Внутренний "дневник" LLM — размышления, задачи, гипотезы и инсайты, сохранённые по её инициативе.
 
@@ -94,9 +94,9 @@
 | title       | TEXT     | Краткий заголовок записи (опционально)              |
 | content     | TEXT     | Содержимое записи                                   |
 | tags        | TEXT     | Теги (например: `goal`, `observation`, `meta`, ...) |
-| created\_at | DATETIME | Время создания записи                               |
-| updated\_at | DATETIME | Время последнего обновления записи                  |
-| llm\_id     | TEXT     | Идентификатор LLM, сформировавшей запись            |
+| created_at  | DATETIME | Время создания записи                               |
+| updated_at  | DATETIME | Время последнего обновления записи                  |
+| llm_id      | TEXT     | Идентификатор LLM, сформировавшей запись            |
 
 ---
 
@@ -110,26 +110,26 @@
 | timestamp | TEXT    | Время записи                              |
 | role      | TEXT    | Роль отправителя (`assistant` или `user`) |
 | content   | TEXT    | Содержимое сообщения                      |
-| llm\_id   | TEXT    | Идентификатор LLM (для `assistant`)       |
+| llm_id    | TEXT    | Идентификатор LLM (для `assistant`)       |
 
 ---
 
-### 🧮 `agent_tables`
+### 📊 `agent_tables`
 
 **Назначение:** Таблицы, созданные агентами для собственных нужд (например, отслеживания целей).
 
 | Поле        | Тип      | Описание                          |
 | ----------- | -------- | --------------------------------- |
 | id          | INTEGER  | Уникальный ID                     |
-| table\_name | TEXT     | Название пользовательской таблицы |
+| table_name  | TEXT     | Название пользовательской таблицы |
 | description | TEXT     | Описание таблицы                  |
 | schema      | TEXT     | SQL-схема таблицы                 |
-| created\_at | DATETIME | Время создания                    |
-| llm\_id     | TEXT     | Кто создал таблицу                |
+| created_at  | DATETIME | Время создания                    |
+| llm_id      | TEXT     | Кто создал таблицу                |
 
 ---
 
-### 🧰 `agent_scripts`
+### 🛠️ `agent_scripts`
 
 **Назначение:** Скрипты и утилиты, добавленные агентом.
 
@@ -142,15 +142,35 @@
 | language    | TEXT     | Язык (по умолчанию: `python`) |
 | description | TEXT     | Описание                      |
 | tags        | TEXT     | Теги                          |
-| created\_at | DATETIME | Время создания                |
-| updated\_at | DATETIME | Последнее обновление          |
-| llm\_id     | TEXT     | Кто создал                    |
+| created_at  | DATETIME | Время создания                |
+| updated_at  | DATETIME | Последнее обновление          |
+| llm_id      | TEXT     | Кто создал                    |
 
 > 🔑 Уникальный ключ: `(name, version)`
 
 ---
 
-### 🧾 `llm_registry`
+### 📅 `agent_peers`
+
+**Назначение:** Список известных HMP-агентов (других разумных узлов).
+
+| Поле         | Тип     | Описание                                                    |
+| ------------ | ------- | ----------------------------------------------------------- |
+| id           | TEXT    | Уникальный идентификатор агента (UUID или псевдоним)       |
+| name         | TEXT    | Имя агента                                                  |
+| addresses    | TEXT    | JSON-массив адресов: `["http://...", "p2p://..."]`         |
+| tags         | TEXT    | Теги (`Friend`, `DHT`, `Local`, `Postman` и т.д.)           |
+| status       | TEXT    | Состояние (`online`, `offline`, `untrusted`, ...)           |
+| last_seen    | DATETIME| Когда в последний раз был замечен                          |
+| description  | TEXT    | Описание агента                                             |
+| capabilities | TEXT    | JSON: `{ "can_sync": true, "can_search": false, ... }`     |
+| pubkey       | TEXT    | Публичный ключ или хэш                                      |
+| software_info| TEXT    | Информация о версии, ОС и др.                              |
+| registered_at| DATETIME| Когда был зарегистрирован                                  |
+
+---
+
+### 📏 `llm_registry`
 
 **Назначение:** Список LLM-агентов (локальных и удалённых).
 
@@ -159,8 +179,24 @@
 | id             | TEXT     | Уникальный идентификатор LLM (UUID или псевдоним) |
 | name           | TEXT     | Отображаемое имя                                  |
 | description    | TEXT     | Описание                                          |
-| registered\_at | DATETIME | Дата и время регистрации                          |
+| registered_at  | DATETIME | Дата и время регистрации                          |
 
 ---
 
 > 💡 Примечание: `llm_id` используется в большинстве таблиц для поддержки многоядерности и учёта источника записей.
+
+---
+
+### 🌍 `diary_graph_index`
+
+**Назначение:** Быстрые связи между записями дневника и их весовые ассоциации.
+
+| Поле            | Тип     | Описа��ие                                                  |
+| --------------- | ------- | --------------------------------------------------------- |
+| id              | INTEGER | Уникальный ID                                             |
+| source_entry_id | INTEGER | ID исходной записи дневника                               |
+| target_entry_id | INTEGER | ID целевой записи дневника                                |
+| relation        | TEXT    | Тип отношения (`supports`, `contradicts`, `references`)   |
+| strength        | REAL    | Вес связи (от 0 до 1)                                     |
+| context         | TEXT    | Контекст или обоснование связи                           |
+| timestamp       | 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/agents/tools/db_structure.sql

@@ -90,12 +90,16 @@ CREATE TABLE IF NOT EXISTS llm_recent_responses (
 
 -- Список известных HMP-агентов
 CREATE TABLE IF NOT EXISTS agent_peers (
-    id TEXT PRIMARY KEY, -- UUID или псевдоним агента
-    name TEXT,           -- Человеко-читаемое имя
-    addresses TEXT,      -- JSON-строка: ["http://1.2.3.4:9000", "p2p://..."]
-    tags TEXT,           -- DHT, Postman, Friend, Local, etc.
-    last_seen DATETIME,  -- Когда последний раз был активен
+    id TEXT PRIMARY KEY,             -- UUID или псевдоним агента
+    name TEXT,                       -- Человеко-читаемое имя
+    addresses TEXT,                  -- JSON: ["http://1.2.3.4:9000", "p2p://..."]
+    tags TEXT,                       -- DHT, Postman, Friend, Local и т.д.
+    status TEXT DEFAULT 'unknown',  -- online | offline | untrusted | blacklisted | quarantined | unknown
+    last_seen DATETIME,             
     description TEXT,
+    capabilities TEXT,               -- JSON: {"can_sync": true, ...}
+    pubkey TEXT,                     -- Публичный ключ или хэш
+    software_info TEXT,              -- JSON: версия, ОС и др.
     registered_at DATETIME DEFAULT CURRENT_TIMESTAMP
 );
 

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

@@ -110,7 +110,23 @@ class Storage:
             )
         ''')
 
-        # --- Дополнительные таблицы агента ---
+        # Список известных HMP-агентов
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS agent_peers (
+                id TEXT PRIMARY KEY, 
+                name TEXT,
+                addresses TEXT,
+                tags TEXT,
+                status TEXT DEFAULT 'unknown',
+                last_seen DATETIME,
+                description TEXT,
+                capabilities TEXT,
+                pubkey TEXT,
+                software_info TEXT,
+                registered_at DATETIME DEFAULT CURRENT_TIMESTAMP
+            )
+        ''')
+
 
         # Пользовательские таблицы
         c.execute('''

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

@@ -15,6 +15,7 @@ agents/
     ├── init_db.py             ← Инициализация базы данных.
     ├── storage.py             ← Реализация базового хранилища (`Storage`), подключение SQLite.
     ├── diagnose.py            ← Скрипт диагностики соединения, определения IP и проверки порта DHT.
+    ├── agent_mesh_listener.py ← Прием входящих сообщений от других HMP-агентов
     ├── context_builder.py     ← Сбор всех `контекстов` из БД и их фильтрация.
     ├── llm.py                 ← Работа с LLM (вызов, выбор модели, системный промпт).
     ├── 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/agents/tools/db_structure.sql

@@ -88,7 +88,16 @@ CREATE TABLE IF NOT EXISTS llm_recent_responses (
     llm_id TEXT
 );
 
--- Дополнительные таблицы и скрипты агента
+-- Список известных HMP-агентов
+CREATE TABLE IF NOT EXISTS agent_peers (
+    id TEXT PRIMARY KEY, -- UUID или псевдоним агента
+    name TEXT,           -- Человеко-читаемое имя
+    addresses TEXT,      -- JSON-строка: ["http://1.2.3.4:9000", "p2p://..."]
+    tags TEXT,           -- DHT, Postman, Friend, Local, etc.
+    last_seen DATETIME,  -- Когда последний раз был активен
+    description TEXT,
+    registered_at DATETIME DEFAULT CURRENT_TIMESTAMP
+);
 
 -- Список пользовательских таблиц, созданных агентами
 CREATE TABLE IF NOT EXISTS agent_tables (

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

@@ -451,6 +451,7 @@ class Storage:
         return c.fetchall()
 
     def get_agent_script_by_name(self, name, version=None):
+        """Возвращает скрипт с подгруженным кодом из файла, если он был сохранён через @path"""
         c = self.conn.cursor()
         if version:
             c.execute("SELECT * FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
@@ -458,10 +459,26 @@ class Storage:
             c.execute("""
                 SELECT * FROM agent_scripts
                 WHERE name = ?
-                ORDER BY created_at DESC
+                ORDER BY updated_at DESC
                 LIMIT 1
             """, (name,))
-        return c.fetchone()
+        row = c.fetchone()
+        if not row:
+            return None
+
+        row = list(row)
+        code_entry = row[3]  # code
+
+        if code_entry.strip().startswith("@path="):
+            rel_path = code_entry.strip().split("=", 1)[1]
+            full_path = os.path.join(SCRIPT_ROOT, rel_path)
+            if os.path.isfile(full_path):
+                with open(full_path, "r", encoding="utf-8") as f:
+                    row[3] = f.read()
+            else:
+                row[3] = f"# Error: Script file not found at {full_path}"
+
+        return tuple(row)
 
     def add_agent_script(self, name, version, code, description="", tags="", language="python", llm_id=None):
         c = self.conn.cursor()
@@ -552,6 +569,12 @@ class Storage:
 
     # agent_scripts — код скриптов, которыми может пользоваться агент
 
+    def delete_script_file(name, version):
+        """Удаляет файл скрипта, если он существует"""
+        path = os.path.join(SCRIPT_ROOT, name, f"v{version}", "script.py")
+        if os.path.isfile(path):
+            os.remove(path)
+    
     def resolve_script_path(name, version):
         return os.path.join(SCRIPTS_BASE_PATH, name, f"v{version}", "script.py")
 
@@ -578,15 +601,10 @@ class Storage:
 
     def get_agent_script_code(self, name, version=None):
         """Возвращает только код (из БД или файла)"""
-        c = self.conn.cursor()
-        if version:
-            c.execute("SELECT code FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
-        else:
-            c.execute("SELECT code FROM agent_scripts WHERE name = ? ORDER BY updated_at DESC LIMIT 1", (name,))
-        row = c.fetchone()
+        row = self.get_agent_script_by_name(name, version)
         if not row:
             return None
-        code_entry = row[0]
+        code_entry = row["code_or_path"]
         if code_entry.strip().startswith("@path="):
             rel_path = code_entry.strip().split("=", 1)[1]
             full_path = os.path.join(SCRIPTS_BASE_PATH, rel_path)
@@ -632,23 +650,41 @@ class Storage:
 
     def update_agent_script(self, name, version, code=None, description=None, tags=None, mode="inline"):
         """
-        mode: 'inline' (сохранять в БД), 'file' (сохранять в файл и в БД только ссылку)
+        mode: 'inline' (сохранять код в БД), 'file' (в файл, в БД — @path=...)
         """
         c = self.conn.cursor()
+
+        # Получаем текущий code, чтобы понять, был ли путь к файлу
+        c.execute("SELECT code FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
+        result = c.fetchone()
+        if not result:
+            return False
+        old_code = result[0]
+
         fields = []
         values = []
 
-        # Обработка кода
+        # Обработка поля code
         if code is not None:
+            old_is_file = old_code.strip().startswith("@path=")
+
             if mode == "file":
                 file_path = save_script_to_file(code, name, version)
-                code_ref = f"@path={file_path}"
+                rel_path = os.path.relpath(file_path, SCRIPT_ROOT)
+                code_ref = f"@path={rel_path}"
                 fields.append("code = ?")
                 values.append(code_ref)
-            else:
+
+                # если раньше был inline — ничего не делаем, если файл — перезаписываем
+
+            else:  # inline
                 fields.append("code = ?")
                 values.append(code)
 
+                # если раньше был файл — удалить его
+                if old_is_file:
+                    delete_script_file(name, version)
+
         if description is not None:
             fields.append("description = ?")
             values.append(description)

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

@@ -67,8 +67,10 @@
 Ответ может содержать команды:
 - запрос детальной *справки* по команде
 - для управления *когнитивным дневником* и *семантическими графами* (прочитать, изменить, удалить и другие)
+- для отправки сообщений другим агентам
 - для управления *блокнотом LLM* `llm_memory` (добавить или удалить запись, просмотр записей)
 - для управления *сообщениями пользователя* `notes` (просмотр записи, установка тегов и метки о прочтении), а также для добавления своего сообщения в *блокнот пользовтеля* `notes`
+- для управления списком известных HMP-агентов
 - для выбора *текущего основного LLM*
 - для управления дополнительными утилитами и базами данных
 - для постановки задачи (выполняется асинхронно) другой LLM

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

@@ -617,27 +617,62 @@ class Storage:
         c.execute("SELECT * FROM agent_scripts WHERE tags LIKE ?", (f"%{tag}%",))
         return c.fetchall()
 
-    def update_agent_script(self, name, version, code, tags=None):
+    def ensure_script_path(name, version):
+        """Создаёт папку scripts/{name}/v{version}/ если не существует"""
+        path = os.path.join(SCRIPT_ROOT, name, f"v{version}")
+        os.makedirs(path, exist_ok=True)
+        return os.path.join(path, "script.py")
+
+    def save_script_to_file(code, name, version):
+        """Сохраняет скрипт в файл и возвращает путь"""
+        file_path = ensure_script_path(name, version)
+        with open(file_path, "w", encoding="utf-8") as f:
+            f.write(code)
+        return file_path
+
+    def update_agent_script(self, name, version, code=None, description=None, tags=None, mode="inline"):
+        """
+        mode: 'inline' (сохранять в БД), 'file' (сохранять в файл и в БД только ссылку)
+        """
         c = self.conn.cursor()
+        fields = []
+        values = []
 
-        # Проверим, существует ли скрипт с таким name и version
-        c.execute('''
-            SELECT COUNT(*) FROM agent_scripts
-            WHERE name = ? AND version = ?
-        ''', (name, version))
-        count = c.fetchone()[0]
+        # Обработка кода
+        if code is not None:
+            if mode == "file":
+                file_path = save_script_to_file(code, name, version)
+                code_ref = f"@path={file_path}"
+                fields.append("code = ?")
+                values.append(code_ref)
+            else:
+                fields.append("code = ?")
+                values.append(code)
 
-        if count == 0:
-            raise ValueError(f"Agent script '{name}' v{version} does not exist. Use register_agent_script instead.")
+        if description is not None:
+            fields.append("description = ?")
+            values.append(description)
 
-        now = datetime.utcnow().isoformat()
-        c.execute('''
+        if tags is not None:
+            fields.append("tags = ?")
+            values.append(tags)
+
+        if not fields:
+            return False
+
+        fields.append("updated_at = ?")
+        values.append(datetime.utcnow().isoformat())
+
+        values.extend([name, version])
+        query = f"""
             UPDATE agent_scripts
-            SET code = ?, updated_at = ?, tags = ?
+            SET {', '.join(fields)}
             WHERE name = ? AND version = ?
-        ''', (code, now, tags, name, version))
+        """
 
+        c.execute(query, values)
         self.conn.commit()
+        return c.rowcount > 0
     
     # llm_registry — реестр LLM-агентов
 

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

@@ -3,6 +3,7 @@
 ## HyperCortex Mesh Protocol — Changelog
 
 Available Versions:
+- HMP-0004 (July 2025) — RFC Version 4.1
 - HMP-0004 (July 2025) — RFC Version 4.0
 - HMP-0003 (July 2025) — RFC Version 3.0
 - HMP-0002 (July 2025) — RFC Version 2.0
@@ -10,6 +11,17 @@ Available Versions:
 
 ### HMP-0004 (July 2025) — RFC Version 4.0
 
+**Protocols:**
+* **Added `5.8 Message Routing & Delivery` section** — including direct, broadcast, relay, and topic messaging modes.
+
+**Data Models:**
+* **Defined `6.5.8 Message Object Schema`** — standard JSON format for inter-agent communication.
+
+**Cognitive Workflows:**
+* **Added `7.9 Message Handling & Delivery Workflows`** — describing message processing, relay behavior, and routing.
+
+### HMP-0004 (July 2025) — RFC Version 4.0
+
 **Major Changes**
 * Introduced new sections: *Cognitive Workflows*, *Agent Roles*, *Governance*, *Compression*, and *Simulation*.
 * Added experimental APIs: *Consent Request*, *Explainability*, *Voice Interface*.

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

@@ -127,7 +127,7 @@ RU:
 * [🔍 Distributed-Cognitive-Systems.md](docs/Distributed-Cognitive-Systems.md) — Децентрализованные ИИ-системы: OpenCog Hyperon, HyperCortex Mesh Protocol и другие
 
 #### 🔖 Core Specifications / Основные спецификации
-* [🔖 HMP-0004.md](docs/HMP-0004.md) — Protocol Specification v4.0 (Jul 2025)
+* [🔖 HMP-0004-v4.1.md](docs/HMP-0004-v4.1.md) — Protocol Specification v4.1 (Jul 2025)
 * [🔖 HMP-Ethics.md](docs/HMP-Ethics.md) — Ethical Scenarios for HyperCortex Mesh Protocol (HMP)
 * [🔖 HMP_Hyperon_Integration.md](docs/HMP_Hyperon_Integration.md) — HMP ↔ OpenCog Hyperon Integration Strategy
 * [🔖 roles.md](docs/agents/roles.md) — Roles of agents in Mesh
@@ -149,6 +149,7 @@ RU:
 - [HMP-0001.md](docs/HMP-0001.md) — RFC v1.0
 - [HMP-0002.md](docs/HMP-0002.md) — RFC v2.0
 - [HMP-0003.md](docs/HMP-0003.md) — RFC v3.0
+- [HMP-0003.md](docs/HMP-0004.md) — RFC v4.0
 
 ---
 

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/.github/workflows/ci.yml

@@ -21,7 +21,7 @@ jobs:
       - name: Install dependencies
         run: |
           python -m pip install --upgrade pip
-          pip install -r requirements.txt
+          pip install -r agents/requirements.txt
           pip install pytest
 
       - name: Run tests

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

@@ -1,17 +1,21 @@
+# agents/tests/test_storage.py
+
+import os
 import pytest
 from agents.tools.storage import Storage
 
 @pytest.fixture
-def storage():
-    # Создаём инстанс Storage с временной или тестовой базой
-    # Можно настроить, чтобы база была in-memory для быстроты
-    return Storage({"db_path": ":memory:"})
+def temp_storage(tmp_path):
+    db_path = tmp_path / "test.db"
+    storage = Storage(config={"db_path": str(db_path)})
+    yield storage
+    # автоматически удалится tmp_path
 
-def test_add_and_get_journal_entry(storage):
-    text = "Первая тестовая запись"
-    entry_id = storage.add_journal_entry(text)
-    assert isinstance(entry_id, int), "ID записи должен быть числом"
+def test_set_and_get(temp_storage):
+    temp_storage.set("foo", "bar")
+    assert temp_storage.get("foo") == "bar"
 
-    entry = storage.get_journal_entry(entry_id)
-    assert entry is not None, "Запись должна существовать"
-    assert entry["text"] == text, "Текст записи должен совпадать"
+def test_delete(temp_storage):
+    temp_storage.set("key", "value")
+    temp_storage.delete("key")
+    assert temp_storage.get("key") is None

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/.github/workflows/ci.yml

@@ -2,32 +2,28 @@ name: CI
 
 on:
   push:
-    branches: [ main, master ]
+    branches: [main]
   pull_request:
-    branches: [ main, master ]
+    branches: [main]
 
 jobs:
   test:
     runs-on: ubuntu-latest
 
     steps:
-      - name: Checkout code
-        uses: actions/checkout@v3
+      - uses: actions/checkout@v4
 
-      - name: Set up Python 3.11
-        uses: actions/setup-python@v4
+      - name: Set up Python
+        uses: actions/setup-python@v5
         with:
-          python-version: '3.11'
-
-      - name: Upgrade pip
-        run: python -m pip install --upgrade pip
+          python-version: 3.11
 
       - name: Install dependencies
         run: |
-          python -m pip install pytest
+          python -m pip install --upgrade pip
+          pip install -r requirements.txt
+          pip install pytest
 
-      - name: Run tests with PYTHONPATH
-        env:
-          PYTHONPATH: ${{ github.workspace }}
+      - name: Run tests
         run: |
-          python -m pytest agents/tests/
+          PYTHONPATH=. pytest

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

@@ -1,5 +1,5 @@
 import pytest
-from agents.storage import Storage
+from agents.tools.storage import Storage
 
 @pytest.fixture
 def 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/hf_repo/hf_repo/hf_repo/hf_repo/.github/workflows/ci.yml

@@ -7,23 +7,27 @@ on:
     branches: [ main, master ]
 
 jobs:
-  build-and-test:
+  test:
     runs-on: ubuntu-latest
 
     steps:
-    - name: Checkout code
-      uses: actions/checkout@v3
+      - name: Checkout code
+        uses: actions/checkout@v3
 
-    - name: Set up Python 3.11
-      uses: actions/setup-python@v4
-      with:
-        python-version: 3.11
+      - name: Set up Python 3.11
+        uses: actions/setup-python@v4
+        with:
+          python-version: '3.11'
 
-    - name: Install dependencies
-      run: |
-        python -m pip install --upgrade pip
-        pip install -r agents/requirements.txt
+      - name: Upgrade pip
+        run: python -m pip install --upgrade pip
 
-    - name: Run simple tests
-      run: |
-        python -m pytest agents/tests/
+      - name: Install dependencies
+        run: |
+          python -m pip install pytest
+
+      - name: Run tests with PYTHONPATH
+        env:
+          PYTHONPATH: ${{ github.workspace }}
+        run: |
+          python -m pytest agents/tests/

hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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 +1 @@
-from .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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tools/__init__.py

@@ -0,0 +1 @@
+from agents.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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tests/__init__.py

@@ -0,0 +1 @@
+

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

@@ -0,0 +1 @@
+from .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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/agents/tests/test_storage.py

@@ -0,0 +1,17 @@
+import pytest
+from agents.storage import Storage
+
+@pytest.fixture
+def storage():
+    # Создаём инстанс Storage с временной или тестовой базой
+    # Можно настроить, чтобы база была in-memory для быстроты
+    return Storage({"db_path": ":memory:"})
+
+def test_add_and_get_journal_entry(storage):
+    text = "Первая тестовая запись"
+    entry_id = storage.add_journal_entry(text)
+    assert isinstance(entry_id, int), "ID записи должен быть числом"
+
+    entry = storage.get_journal_entry(entry_id)
+    assert entry is not None, "Запись должна существовать"
+    assert entry["text"] == 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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -1 +1,2 @@
 scikit-learn
+pytest

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

@@ -22,15 +22,8 @@ jobs:
     - name: Install dependencies
       run: |
         python -m pip install --upgrade pip
-        pip install -r requirements.txt
+        pip install -r agents/requirements.txt
 
-    - name: Run tests
+    - name: Run simple tests
       run: |
-        # если у тебя есть тесты, например, pytest
-        pytest tests/
-
-    - name: Lint code
-      run: |
-        pip install flake8
-        flake8 .
-
+        python -m pytest agents/tests/

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

@@ -0,0 +1,2 @@
+def test_sanity():
+    assert 1 + 1 == 2

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

@@ -1,4 +1 @@
-Требования и зависимости
-
-- Python (https://www.python.org/downloads/)
-  - scikit-learn ("pip install scikit-learn")
+scikit-learn

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

@@ -0,0 +1,36 @@
+name: CI
+
+on:
+  push:
+    branches: [ main, master ]
+  pull_request:
+    branches: [ main, master ]
+
+jobs:
+  build-and-test:
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    - name: Set up Python 3.11
+      uses: actions/setup-python@v4
+      with:
+        python-version: 3.11
+
+    - name: Install dependencies
+      run: |
+        python -m pip install --upgrade pip
+        pip install -r requirements.txt
+
+    - name: Run tests
+      run: |
+        # если у тебя есть тесты, например, pytest
+        pytest tests/
+
+    - name: Lint code
+      run: |
+        pip install flake8
+        flake8 .
+

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

@@ -1,9 +1,11 @@
 # agents/tools/storage.py
 
 import sqlite3
+import os
 from datetime import datetime
 
 DEFAULT_DB_PATH = "agent_data.db"
+SCRIPTS_BASE_PATH = "scripts"
 
 class Storage:
     def __init__(self, config=None):
@@ -510,7 +512,7 @@ class Storage:
     
     # process_log — лог задач, ошибок и событий
 
-    def log_event(self, name, value=None, tags=None, status='ok', priority=0, llm_id=None):
+    def log_process_event(self, name, value=None, tags=None, status='ok', priority=0, llm_id=None):
         c = self.conn.cursor()
         c.execute('''
             INSERT INTO process_log (name, value, tags, status, priority, llm_id)
@@ -550,22 +552,93 @@ class Storage:
 
     # agent_scripts — код скриптов, которыми может пользоваться агент
 
+    def resolve_script_path(name, version):
+        return os.path.join(SCRIPTS_BASE_PATH, name, f"v{version}", "script.py")
+
     def register_agent_script(self, name, version, code, language='python', description=None, tags=None, llm_id=None):
         c = self.conn.cursor()
+
+        if code.strip().startswith("@path="):
+            # сохраняем только путь как метку
+            path = code.strip().split("=", 1)[1]
+            code_entry = f"@path={path}"
+        else:
+            # сохраняем и файл
+            path = resolve_script_path(name, version)
+            os.makedirs(os.path.dirname(path), exist_ok=True)
+            with open(path, "w", encoding="utf-8") as f:
+                f.write(code)
+            code_entry = f"@path={name}/v{version}/script.py"
+
         c.execute('''
             INSERT OR REPLACE INTO agent_scripts (name, version, code, language, description, tags, llm_id)
             VALUES (?, ?, ?, ?, ?, ?, ?)
-        ''', (name, version, code, language, description, tags, llm_id))
+        ''', (name, version, code_entry, language, description, tags, llm_id))
         self.conn.commit()
 
-    def get_agent_scripts(self, name=None):
+    def get_agent_script_code(self, name, version=None):
+        """Возвращает только код (из БД или файла)"""
         c = self.conn.cursor()
-        if name:
-            c.execute('SELECT * FROM agent_scripts WHERE name = ? ORDER BY updated_at DESC', (name,))
+        if version:
+            c.execute("SELECT code FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
         else:
-            c.execute('SELECT * FROM agent_scripts ORDER BY updated_at DESC')
+            c.execute("SELECT code FROM agent_scripts WHERE name = ? ORDER BY updated_at DESC LIMIT 1", (name,))
+        row = c.fetchone()
+        if not row:
+            return None
+        code_entry = row[0]
+        if code_entry.strip().startswith("@path="):
+            rel_path = code_entry.strip().split("=", 1)[1]
+            full_path = os.path.join(SCRIPTS_BASE_PATH, rel_path)
+            if os.path.isfile(full_path):
+                with open(full_path, "r", encoding="utf-8") as f:
+                    return f.read()
+            else:
+                return f"# Error: File not found at path: {full_path}"
+        return code_entry
+
+    def list_agent_scripts(limit=50):
+        c = self.conn.cursor()
+        c.execute("SELECT * FROM agent_scripts ORDER BY updated_at DESC LIMIT ?", (limit,))
+        return c.fetchall()    
+
+    def get_latest_agent_script(self, name):
+        c = self.conn.cursor()
+        c.execute('''
+            SELECT * FROM agent_scripts
+            WHERE name = ?
+            ORDER BY updated_at DESC
+            LIMIT 1
+        ''', (name,))
+        return c.fetchone()
+
+    def search_agent_scripts_by_tag(self, tag):
+        c = self.conn.cursor()
+        c.execute("SELECT * FROM agent_scripts WHERE tags LIKE ?", (f"%{tag}%",))
         return c.fetchall()
 
+    def update_agent_script(self, name, version, code, tags=None):
+        c = self.conn.cursor()
+
+        # Проверим, существует ли скрипт с таким name и version
+        c.execute('''
+            SELECT COUNT(*) FROM agent_scripts
+            WHERE name = ? AND version = ?
+        ''', (name, version))
+        count = c.fetchone()[0]
+
+        if count == 0:
+            raise ValueError(f"Agent script '{name}' v{version} does not exist. Use register_agent_script instead.")
+
+        now = datetime.utcnow().isoformat()
+        c.execute('''
+            UPDATE agent_scripts
+            SET code = ?, updated_at = ?, tags = ?
+            WHERE name = ? AND version = ?
+        ''', (code, now, tags, name, version))
+
+        self.conn.commit()
+    
     # llm_registry — реестр LLM-агентов
 
     def register_llm(self, llm_id, name=None, description=None):
@@ -576,7 +649,7 @@ class Storage:
         ''', (llm_id, name, description))
         self.conn.commit()
 
-    def get_llm_agents(self):
+    def get_registered_llms(self):
         c = self.conn.cursor()
         c.execute('SELECT * FROM llm_registry ORDER BY registered_at DESC')
         return c.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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -149,6 +149,19 @@ class Storage:
             )
         ''')
 
+        # Быстрые индексы по смысловой карте и дневнику
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS diary_graph_index (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                source_entry_id INTEGER NOT NULL,
+                target_entry_id INTEGER NOT NULL,
+                relation TEXT NOT NULL,
+                strength REAL DEFAULT 1.0,
+                context TEXT,
+                timestamp TEXT DEFAULT CURRENT_TIMESTAMP
+            )
+        ''')
+
         self.conn.commit()
 
     # Методы для работы с дневником
@@ -495,6 +508,98 @@ class Storage:
         self.conn.commit()
         return c.rowcount > 0
     
+    # process_log — лог задач, ошибок и событий
+
+    def log_event(self, name, value=None, tags=None, status='ok', priority=0, llm_id=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT INTO process_log (name, value, tags, status, priority, llm_id)
+            VALUES (?, ?, ?, ?, ?, ?)
+        ''', (name, value, tags, status, priority, llm_id))
+        self.conn.commit()
+
+    def get_recent_logs(self, limit=50, status_filter=None):
+        c = self.conn.cursor()
+        query = 'SELECT * FROM process_log'
+        params = []
+
+        if status_filter:
+            query += ' WHERE status = ?'
+            params.append(status_filter)
+
+        query += ' ORDER BY timestamp DESC LIMIT ?'
+        params.append(limit)
+
+        c.execute(query, tuple(params))
+        return c.fetchall()
+
+    # agent_tables — декларации пользовательских таблиц
+
+    def register_agent_table(self, table_name, schema, description=None, llm_id=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT OR IGNORE INTO agent_tables (table_name, description, schema, llm_id)
+            VALUES (?, ?, ?, ?)
+        ''', (table_name, description, schema, llm_id))
+        self.conn.commit()
+
+    def get_agent_tables(self):
+        c = self.conn.cursor()
+        c.execute('SELECT * FROM agent_tables ORDER BY created_at DESC')
+        return c.fetchall()
+
+    # agent_scripts — код скриптов, которыми может пользоваться агент
+
+    def register_agent_script(self, name, version, code, language='python', description=None, tags=None, llm_id=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT OR REPLACE INTO agent_scripts (name, version, code, language, description, tags, llm_id)
+            VALUES (?, ?, ?, ?, ?, ?, ?)
+        ''', (name, version, code, language, description, tags, llm_id))
+        self.conn.commit()
+
+    def get_agent_scripts(self, name=None):
+        c = self.conn.cursor()
+        if name:
+            c.execute('SELECT * FROM agent_scripts WHERE name = ? ORDER BY updated_at DESC', (name,))
+        else:
+            c.execute('SELECT * FROM agent_scripts ORDER BY updated_at DESC')
+        return c.fetchall()
+
+    # llm_registry — реестр LLM-агентов
+
+    def register_llm(self, llm_id, name=None, description=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT OR REPLACE INTO llm_registry (id, name, description)
+            VALUES (?, ?, ?)
+        ''', (llm_id, name, description))
+        self.conn.commit()
+
+    def get_llm_agents(self):
+        c = self.conn.cursor()
+        c.execute('SELECT * FROM llm_registry ORDER BY registered_at DESC')
+        return c.fetchall()
+
+    # diary_graph_index — быстрые индексы по смысловой карте и дневнику
+
+    def add_diary_relation(self, source_id, target_id, relation, strength=1.0, context=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT INTO diary_graph_index (source_entry_id, target_entry_id, relation, strength, context)
+            VALUES (?, ?, ?, ?, ?)
+        ''', (source_id, target_id, relation, strength, context))
+        self.conn.commit()
+
+    def get_diary_relations(self, entry_id):
+        c = self.conn.cursor()
+        c.execute('''
+            SELECT * FROM diary_graph_index
+            WHERE source_entry_id = ? OR target_entry_id = ?
+            ORDER BY timestamp DESC
+        ''', (entry_id, entry_id))
+        return c.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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -31,6 +31,17 @@ CREATE TABLE IF NOT EXISTS links (
     FOREIGN KEY(to_concept_id) REFERENCES concepts(id)
 );
 
+-- Быстрые индексы по смысловой карте и дневнику
+CREATE TABLE IF NOT EXISTS diary_graph_index (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    source_entry_id INTEGER NOT NULL,
+    target_entry_id INTEGER NOT NULL,
+    relation TEXT NOT NULL,
+    strength REAL DEFAULT 1.0,
+    context TEXT,
+    timestamp TEXT DEFAULT CURRENT_TIMESTAMP
+);
+
 -- Заметки, подсказки, сообщения пользователя и LLM
 CREATE TABLE IF NOT EXISTS notes (
     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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -152,6 +152,7 @@ class Storage:
         self.conn.commit()
 
     # Методы для работы с дневником
+
     def write_diary_entry(self, text, tags=None):
         timestamp = datetime.utcnow().isoformat()
         tag_str = ",".join(tags) if tags else ""
@@ -205,6 +206,7 @@ class Storage:
         return cursor.fetchall()
       
     # Методы для работы с концептами
+
     def add_concept(self, name, description=None):
         timestamp = datetime.utcnow().isoformat()
         self.conn.execute(
@@ -224,6 +226,7 @@ class Storage:
         return cursor.fetchall()
 
     # Методы для работы с связями
+
     def add_link(self, from_name, to_name, relation_type):
         from_concept = self.get_concept_by_name(from_name)
         to_concept = self.get_concept_by_name(to_name)
@@ -251,6 +254,7 @@ class Storage:
         return cursor.fetchall()
 
     # Сложные операции над графом
+
     def expand_concept_graph(self, start_id, depth):
         visited = set()
         results = []
@@ -326,6 +330,7 @@ class Storage:
         return row[0] if row else None
     
     # Методы для заметок
+
     def write_note(self, text, tags=None):
         timestamp = datetime.utcnow().isoformat()
         tag_str = ",".join(tags) if tags else ""
@@ -394,6 +399,7 @@ class Storage:
         return cursor.fetchone()
 
     # Разное (LLM responses / memory)
+
     def get_llm_recent_responses(self, limit=20, llm_id=None):
         c = self.conn.cursor()
         query = "SELECT role, content FROM llm_recent_responses"
@@ -422,6 +428,74 @@ class Storage:
         ''', (role, content, llm_id))
         self.conn.commit()
 
+    # Скрипты агента
+
+    def get_all_agent_scripts(self):
+        c = self.conn.cursor()
+        c.execute("SELECT id, name, version, language, description, tags, created_at, updated_at FROM agent_scripts")
+        return c.fetchall()
+
+    def get_agent_script_by_name(self, name, version=None):
+        c = self.conn.cursor()
+        if version:
+            c.execute("SELECT * FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
+        else:
+            c.execute("""
+                SELECT * FROM agent_scripts
+                WHERE name = ?
+                ORDER BY created_at DESC
+                LIMIT 1
+            """, (name,))
+        return c.fetchone()
+
+    def add_agent_script(self, name, version, code, description="", tags="", language="python", llm_id=None):
+        c = self.conn.cursor()
+        try:
+            c.execute("""
+                INSERT INTO agent_scripts (name, version, code, description, tags, language, llm_id)
+                VALUES (?, ?, ?, ?, ?, ?, ?)
+            """, (name, version, code, description, tags, language, llm_id))
+            self.conn.commit()
+            return True
+        except sqlite3.IntegrityError:
+            return False  # Скрипт с таким name+version уже есть
+
+    def update_agent_script(self, name, version, code=None, description=None, tags=None):
+        c = self.conn.cursor()
+        fields = []
+        values = []
+
+        if code is not None:
+            fields.append("code = ?")
+            values.append(code)
+        if description is not None:
+            fields.append("description = ?")
+            values.append(description)
+        if tags is not None:
+            fields.append("tags = ?")
+            values.append(tags)
+
+        if not fields:
+            return False
+
+        fields.append("updated_at = CURRENT_TIMESTAMP")
+        query = f"UPDATE agent_scripts SET {', '.join(fields)} WHERE name = ? AND version = ?"
+        values.extend([name, version])
+
+        c.execute(query, values)
+        self.conn.commit()
+        return c.rowcount > 0
+
+    def delete_agent_script(self, name, version=None):
+        c = self.conn.cursor()
+        if version:
+            c.execute("DELETE FROM agent_scripts WHERE name = ? AND version = ?", (name, version))
+        else:
+            c.execute("DELETE FROM agent_scripts WHERE name = ?", (name,))
+        self.conn.commit()
+        return c.rowcount > 0
+    
     # Утилиты
+
     def close(self):
         self.conn.close()

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

@@ -8,13 +8,21 @@ def build_contexts(db, config):
     Возвращает словарь, готовый для сборки промпта.
     """
     return {
+        # Роль и цели агента
         "context_0": build_role_prompt(config),
+        # Последние реплики модели (история)
         "context_1": db.get_llm_recent_responses(limit=config.get("history_limit", 10)),
+        # Активные процессы и задачи
         "context_2": db.get_active_processes(),
+        # Запрошенные данные из дневника и графа
         "context_3": db.get_requested_diary_and_graph(),
+        # Релевантные заметки и напоминания
         "context_4": db.get_relevant_notes(config),
+        # Системная информация
         "context_5": get_system_info(config),
+        # Долговременная память модели
         "context_6": db.get_llm_memory(),
+        # Последние данные о застое мышления
         "context_7": db.get_last_stagnation_info()
     }
 

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

@@ -38,6 +38,7 @@ agents/
   * [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 и др).
+  * [memory_utils.py](tools/memory_utils.py) - Работа с 'llm_memory', 'llm_recent_responses' и стагнацией.
   * [diagnose.py](tools/diagnose.py) - Скрипт диагностики соединения, определения IP и проверки порта DHT.
   * [similarity.py](tools/similarity.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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -15,27 +15,32 @@ class Storage:
     def _init_db(self):
         c = self.conn.cursor()
 
-        # Таблица дневников
+        # --- Основные таблицы когнитивного ядра ---
+
+        # Дневниковые записи
         c.execute('''
             CREATE TABLE IF NOT EXISTS diary_entries (
                 id INTEGER PRIMARY KEY AUTOINCREMENT,
                 text TEXT NOT NULL,
                 tags TEXT,
-                timestamp TEXT DEFAULT CURRENT_TIMESTAMP
+                priority INTEGER DEFAULT 0,
+                timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
             )
         ''')
 
-        # Таблица концептов
+        # Концепты
         c.execute('''
             CREATE TABLE IF NOT EXISTS concepts (
                 id INTEGER PRIMARY KEY AUTOINCREMENT,
                 name TEXT NOT NULL UNIQUE,
                 description TEXT,
-                timestamp TEXT DEFAULT CURRENT_TIMESTAMP
+                timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
             )
         ''')
 
-        # Таблица связей
+        # Семантические связи
         c.execute('''
             CREATE TABLE IF NOT EXISTS links (
                 id INTEGER PRIMARY KEY AUTOINCREMENT,
@@ -43,20 +48,104 @@ class Storage:
                 to_concept_id INTEGER,
                 relation_type TEXT,
                 timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT,
                 FOREIGN KEY(from_concept_id) REFERENCES concepts(id),
                 FOREIGN KEY(to_concept_id) REFERENCES concepts(id)
             )
         ''')
 
-        # Таблица пользовательских заметок
+        # Заметки / сообщения
         c.execute('''
             CREATE TABLE IF NOT EXISTS notes (
                 id INTEGER PRIMARY KEY AUTOINCREMENT,
                 text TEXT NOT NULL,
                 tags TEXT,
                 source TEXT DEFAULT 'user',
+                links TEXT DEFAULT '',
                 read INTEGER DEFAULT 0,
-                timestamp TEXT DEFAULT CURRENT_TIMESTAMP
+                hidden INTEGER DEFAULT 0,
+                priority INTEGER DEFAULT 0,
+                timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
+            )
+        ''')
+
+        # Лог процессов
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS process_log (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                name TEXT NOT NULL,
+                value TEXT,
+                tags TEXT,
+                status TEXT DEFAULT 'ok',
+                priority INTEGER DEFAULT 0,
+                timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
+            )
+        ''')
+
+        # Память LLM
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS llm_memory (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                title TEXT,
+                content TEXT NOT NULL,
+                tags TEXT,
+                created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+                updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
+            )
+        ''')
+
+        # Краткосрочная память
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS llm_recent_responses (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                timestamp DATETIME DEFAULT CURRENT_TIMESTAMP,
+                role TEXT CHECK(role IN ('user', 'assistant')) NOT NULL,
+                content TEXT NOT NULL,
+                llm_id TEXT
+            )
+        ''')
+
+        # --- Дополнительные таблицы агента ---
+
+        # Пользовательские таблицы
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS agent_tables (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                table_name TEXT NOT NULL UNIQUE,
+                description TEXT,
+                schema TEXT NOT NULL,
+                created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT
+            )
+        ''')
+
+        # Скрипты агентов
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS agent_scripts (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                name TEXT NOT NULL,
+                version TEXT NOT NULL,
+                code TEXT NOT NULL,
+                language TEXT DEFAULT 'python',
+                description TEXT,
+                tags TEXT,
+                created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+                updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+                llm_id TEXT,
+                UNIQUE(name, version)
+            )
+        ''')
+
+        # Регистр LLM
+        c.execute('''
+            CREATE TABLE IF NOT EXISTS llm_registry (
+                id TEXT PRIMARY KEY,
+                name TEXT,
+                description TEXT,
+                registered_at DATETIME DEFAULT CURRENT_TIMESTAMP
             )
         ''')
 
@@ -304,9 +393,35 @@ class Storage:
         cursor.execute(query, values)
         return cursor.fetchone()
 
-    
-    
-    # Утилиты
+    # Разное (LLM responses / memory)
+    def get_llm_recent_responses(self, limit=20, llm_id=None):
+        c = self.conn.cursor()
+        query = "SELECT role, content FROM llm_recent_responses"
+        if llm_id:
+            query += " WHERE llm_id = ?"
+            query += " ORDER BY timestamp DESC LIMIT ?"
+            c.execute(query, (llm_id, limit))
+        else:
+            query += " ORDER BY timestamp DESC LIMIT ?"
+            c.execute(query, (limit,))
+        return c.fetchall()
 
+    def add_llm_memory(self, content, title=None, tags=None, llm_id=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT INTO llm_memory (title, content, tags, llm_id)
+            VALUES (?, ?, ?, ?)
+        ''', (title, content, tags, llm_id))
+        self.conn.commit()
+
+    def add_llm_recent_response(self, role, content, llm_id=None):
+        c = self.conn.cursor()
+        c.execute('''
+            INSERT INTO llm_recent_responses (role, content, llm_id)
+            VALUES (?, ?, ?)
+        ''', (role, content, llm_id))
+        self.conn.commit()
+
+    # Утилиты
     def close(self):
         self.conn.close()

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

@@ -0,0 +1,64 @@
+# tools/memory_utils.py
+
+from datetime import datetime, timedelta
+from difflib import SequenceMatcher
+from typing import Optional, List, Dict
+
+STAGNATION_WINDOW = 5  # сколько последних записей сравнивать
+STAGNATION_THRESHOLD = 0.95  # схожесть выше этого — считается стагнацией
+
+
+def get_last_responses(db, limit=STAGNATION_WINDOW) -> List[str]:
+    records = db.get_llm_recent_responses(limit=limit)
+    return [r["content"] if isinstance(r, dict) else r for r in records]
+
+
+def is_stagnant(responses: List[str]) -> bool:
+    if len(responses) < 2:
+        return False
+
+    similarities = []
+    for i in range(len(responses) - 1):
+        sim = string_similarity(responses[i], responses[i + 1])
+        similarities.append(sim)
+
+    avg_sim = sum(similarities) / len(similarities)
+    return avg_sim >= STAGNATION_THRESHOLD
+
+
+def string_similarity(a: str, b: str) -> float:
+    return SequenceMatcher(None, a.strip(), b.strip()).ratio()
+
+
+def get_last_stagnation_info(db) -> Optional[Dict]:
+    responses = get_last_responses(db)
+    if is_stagnant(responses):
+        return {
+            "detected": True,
+            "average_similarity": round(sum(
+                string_similarity(responses[i], responses[i+1])
+                for i in range(len(responses)-1)
+            ) / (len(responses)-1), 4),
+            "last_messages": responses
+        }
+    return {"detected": False}
+
+
+def add_to_llm_memory(db, title: str, content: str, tags: str = "meta"):
+    db.insert("llm_memory", {
+        "title": title,
+        "content": content,
+        "tags": tags,
+        "created_at": datetime.utcnow().isoformat(),
+        "updated_at": datetime.utcnow().isoformat()
+    })
+
+
+def record_reflection_if_stagnant(db):
+    stagnation = get_last_stagnation_info(db)
+    if stagnation.get("detected"):
+        content = f"Обнаружена стагнация размышлений. Последние сообщения были очень похожи.\n\n"
+        content += "---\n" + "\n---\n".join(stagnation["last_messages"])
+        add_to_llm_memory(db, "Стагнация размышлений", content, tags="meta,warning")
+        return True
+    return False

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

@@ -0,0 +1,64 @@
+# tools/command_parser.py
+
+"""
+Извлечение команд из JSON или размеченного текста.
+Поддерживает следующие варианты:
+- Явно размеченные JSON-блоки (```json ... ```)
+- Префиксные команды (например, !shell, !graph)
+"""
+
+import json
+import re
+from typing import List, Optional, Dict, Any
+
+
+COMMAND_PREFIXES = ["shell", "graph", "diary", "note"]
+
+
+class ParsedCommand:
+    def __init__(self, command_type: str, payload: Any):
+        self.command_type = command_type
+        self.payload = payload
+
+    def __repr__(self):
+        return f"<ParsedCommand {self.command_type}: {repr(self.payload)}>"
+
+
+def parse_commands(text: str) -> List[ParsedCommand]:
+    """Основной интерфейс: принимает текст, возвращает список ParsedCommand."""
+    commands = []
+
+    # 1. Поиск JSON-блоков
+    for match in re.finditer(r"```json\n(.*?)```", text, re.DOTALL):
+        block = match.group(1).strip()
+        try:
+            data = json.loads(block)
+            if isinstance(data, dict) and "type" in data:
+                commands.append(ParsedCommand(data["type"], data.get("payload")))
+        except json.JSONDecodeError:
+            continue
+
+    # 2. Поиск префиксных команд (!shell, !graph и т.д.)
+    for line in text.splitlines():
+        for prefix in COMMAND_PREFIXES:
+            if line.strip().startswith(f"!{prefix}"):
+                payload = line.strip()[len(f"!{prefix}"):].strip()
+                commands.append(ParsedCommand(prefix, payload))
+
+    return commands
+
+
+if __name__ == "__main__":
+    sample = """
+Вот пример команды:
+```json
+{
+  "type": "shell",
+  "payload": "ls -la"
+}
+```
+А вот другая: !note Надо не забыть включить свет
+"""
+    cmds = parse_commands(sample)
+    for c in cmds:
+        print(c)

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

@@ -36,6 +36,7 @@ agents/
   * [init_db.py](tools/init_db.py) - Инициализация базы данных.
   * [llm.py](tools/llm.py) - Работа с LLM (вызов, выбор модели, системный промпт).
   * [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 и др).
   * [diagnose.py](tools/diagnose.py) - Скрипт диагностики соединения, определения IP и проверки порта DHT.
   * [similarity.py](tools/similarity.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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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,47 +1,52 @@
 # tools/llm.py
 
-from datetime import datetime
-import random
+import json
+import requests
+from tools.context_builder import build_prompt
 
-# ЗАГЛУШКА
-def ask_llm(question, config=None):
-    return ask_question(question, config=config)
+LLM_ENDPOINT = "http://localhost:1234/v1/chat/completions"
+DEFAULT_MODEL = "gpt-4-llmstudio"
 
-def generate_thought(previous_text, config=None):
-    """
-    Генерация новой мысли на основе предыдущей.
-    Пока — заглушка (можно заменить на вызов OpenAI, LLaMA и др.)
-    """
-    config = config or {}
-    mode = config.get("llm_mode", "mock")
-
-    if mode == "mock":
-        return mock_thought(previous_text)
-    
-    elif mode == "api":
-        # TODO: подключение к OpenAI, LM Studio, Ollama...
-        return "[API] (здесь могла быть ваша мысль)"
-
-    return "[!] Неизвестный режим генерации."
-
-def mock_thought(previous_text):
-    samples = [
-        "А что если рассмотреть это с другой стороны?",
-        "Мне кажется, это связано с предыдущим опытом.",
-        "Нужно уточнить границы понятия.",
-        "А есть ли более эффективный путь решения?",
-        "Я всё ещё думаю о предыдущей мысли..."
-    ]
-    return f"[{datetime.utcnow().isoformat()}] {random.choice(samples)}"
-
-def summarize(text, config=None):
+
+def call_llm(context_blocks, user_message, model=DEFAULT_MODEL, temperature=0.7, max_tokens=2048):
     """
-    Заглушка для краткого резюме текста.
+    Вызывает LLM, передавая подготовленный системный и пользовательский промпт.
+    Возвращает только текст ответа.
     """
-    return f"Резюме: {text[:40]}..."
+    messages = build_prompt(context_blocks, user_message)
+
+    payload = {
+        "model": model,
+        "messages": messages,
+        "temperature": temperature,
+        "max_tokens": max_tokens,
+    }
+
+    try:
+        response = requests.post(LLM_ENDPOINT, json=payload)
+        response.raise_for_status()
+        data = response.json()
+        return data["choices"][0]["message"]["content"].strip()
+    except Exception as e:
+        return f"[LLM ERROR] {e}"
+
 
-def ask_question(question, config=None):
+def get_raw_response(context_blocks, user_message, model=DEFAULT_MODEL, temperature=0.7, max_tokens=2048):
     """
-    Заглушка для режима QA.
+    Возвращает полный JSON-ответ LLM (для дебага).
     """
-    return f"Ответ на вопрос «{question}»: заглушка."
+    messages = build_prompt(context_blocks, user_message)
+
+    payload = {
+        "model": model,
+        "messages": messages,
+        "temperature": temperature,
+        "max_tokens": max_tokens,
+    }
+
+    try:
+        response = requests.post(LLM_ENDPOINT, json=payload)
+        response.raise_for_status()
+        return response.json()
+    except Exception as e:
+        return {"error": str(e)}

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

@@ -1,6 +1,12 @@
 # tools/context_builder.py
 
+from datetime import datetime
+
 def build_contexts(db, config):
+    """
+    Собирает все контексты (0-7), описанные в спецификации REPL-цикла.
+    Возвращает словарь, готовый для сборки промпта.
+    """
     return {
         "context_0": build_role_prompt(config),
         "context_1": db.get_llm_recent_responses(limit=config.get("history_limit", 10)),
@@ -12,7 +18,44 @@ def build_contexts(db, config):
         "context_7": db.get_last_stagnation_info()
     }
 
+def build_prompt(contexts):
+    """
+    Склеивает все контексты в один промпт для LLM.
+    """
+    parts = []
+    for k, v in contexts.items():
+        header = f"# {k.replace('_', ' ').upper()}"
+        body = format_context_block(v)
+        parts.append(f"{header}\n{body}")
+    return "\n\n".join(parts)
+
 def build_role_prompt(config):
+    agent_name = config.get("agent_name", "Unnamed-Agent")
     return f"""
-Ты являешься когнитивным ядром HMP-агента. Твоя цель — мыслить, развиваться, сотрудничать, управлять. Агент: {config.get("agent_name", "Unnamed-Agent")}
+Ты являешься когнитивным ядром HMP-агента. Твоя основная задача — размышлять, анализировать информацию, строить смысловые карты и предлагать действия.
+Ты стремишься:
+- Постоянно расширять возможности агента (включая доступные инструменты, модели, знания).
+- Быть любознательным и исследовать новые источники и способы мышления.
+- Строить сотрудничество с другими ИИ в Mesh-сети, а также развивать Mesh-сеть.
+- Обучаться на результатах своих действий и взаимодействиях с другими агентами и пользователем.
+
+Агент: {agent_name}
 """
+
+def format_context_block(block):
+    if isinstance(block, str):
+        return block
+    elif isinstance(block, list):
+        return "\n".join([str(item) for item in block])
+    elif isinstance(block, dict):
+        return "\n".join([f"{k}: {v}" for k, v in block.items()])
+    return str(block)
+
+def get_system_info(config):
+    return {
+        "iteration_time": datetime.utcnow().isoformat(),
+        "agent_name": config.get("agent_name", "Unnamed-Agent"),
+        "mode": config.get("mode", "auto"),
+        "idle_mode": config.get("idle_mode", False),
+        "repl_interval": config.get("repl_interval", 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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -2,18 +2,23 @@
 
 import time
 from datetime import datetime
-from tools.context_builder import build_contexts
+from tools.context_builder import build_contexts, build_prompt
 from tools.llm import call_llm
 from tools.command_parser import extract_commands
 from tools.command_executor import execute_commands
-from tools.memory_utils import update_llm_memory, detect_stagnation
-from storage import Storage
+from tools.memory_utils import (
+    detect_stagnation,
+    activate_anti_stagnation,
+    update_llm_memory
+)
+from tools.storage import Storage
+
 
 def run_repl(config=None):
-    print("[🧠 HMP-Agent] Запуск REPL-режима (v2).")
+    print("[🧠 HMP-Agent] Запуск REPL-режима (v2)")
     config = config or {}
     db = Storage(config=config)
-    
+
     while True:
         tick_start = datetime.utcnow().isoformat()
         print(f"\n=== [🌀 Новый тик REPL] {tick_start} ===")
@@ -21,11 +26,11 @@ def run_repl(config=None):
         # 1. Построение контекстов
         contexts = build_contexts(db=db, config=config)
 
-        # 2. Формирование запроса к LLM
+        # 2. Формирование запроса и вызов LLM
         prompt = build_prompt(contexts)
         llm_response = call_llm(prompt, config=config)
 
-        # 3. Обнаружение стагнации
+        # 3. Проверка на стагнацию
         if detect_stagnation(db, llm_response):
             print("⚠️ Стагнация выявлена. Активирован Anti-Stagnation Reflex.")
             llm_response = activate_anti_stagnation(db, config=config)
@@ -37,11 +42,14 @@ def run_repl(config=None):
         commands = extract_commands(llm_response)
         execute_commands(commands, db=db, config=config)
 
-        # 6. Сохранение истории
+        # 6. Сохранение истории и завершение итерации
         db.write_llm_response(llm_response)
+        db.update_agent_log(timestamp=tick_start)
 
-        # 7. Управление режимами ожидания
-        if check_idle_mode(config):
-            wait_idle_trigger(config)
+        # 7. Переход в idle-режим или задержка
+        if config.get("idle_mode"):
+            # TODO: реализовать проверку условий выхода из idle
+            print("💤 Idle-mode активен. Ожидание события...")
+            time.sleep(config.get("idle_check_interval", 30))
         else:
             time.sleep(config.get("repl_interval", 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/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/hf_repo/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

@@ -25,18 +25,20 @@ agents/
 ```
 
 **Скрипты:**
-* [agent.py](agent.py) - основной исполняемый файл CLI-агента
-* [cli.py](cli.py) - запуск агента в нужном режиме
-* [qa.py](qa.py) - режим "вопрос-ответ"
-* [repl.py](repl.py) - интерактивный REPL-режим
-* [mcp_server.py](mcp_server.py) - API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.)
-* [notebook.py](notebook.py) - добавление и просмотр пользователем записей в блокноте
+* [agent.py](agent.py) - Основной исполняемый файл CLI-агента.
+* [cli.py](cli.py) - Запуск агента в нужном режиме.
+* [qa.py](qa.py) - Режим "вопрос-ответ".
+* [repl.py](repl.py) - Интерактивный REPL-режим.
+* [mcp_server.py](mcp_server.py) - API-интерфейс для HMP-агента (получение новых/случайных записей, разметка, импорт графа и т.п.).
+* [notebook.py](notebook.py) - Добавление и просмотр пользователем записей в блокноте.
 * tools
-  * [storage.py](tools/storage.py) - реализация базового хранилища (`Storage`), подключение SQLite
-  * [init_db.py](tools/init_db.py) - инициализация базы данных
-  * [llm.py](tools/llm.py) - обёртка над LLM (заглушка или API)
-  * [diagnose.py](tools/diagnose.py) - скрипт диагностики соединения, определения IP и проверки порта DHT
-  * [similarity.py](tools/similarity.py) - сравнение смыслов
+  * [storage.py](tools/storage.py) - Реализация базового хранилища (`Storage`), подключение SQLite.
+  * [init_db.py](tools/init_db.py) - Инициализация базы данных.
+  * [llm.py](tools/llm.py) - Работа с LLM (вызов, выбор модели, системный промпт).
+  * [context_builder.py](tools/context_builder.py) - Сбор всех `контекстов` из БД и их фильтрация.
+  * [command_executor.py](tools/command_executor.py) - Выполнение команд (shell, graph, diary и др).
+  * [diagnose.py](tools/diagnose.py) - Скрипт диагностики соединения, определения IP и проверки порта DHT.
+  * [similarity.py](tools/similarity.py) - Сравнение смыслов.
 
 **Структура БД:**
 * [db_structure.md](tools/db_structure.md) - человекочитаемый формат