fix(client): make ReconnectingOutbox KMP-native-safe (@Volatile→AtomicReference, Math.pow→kotlin.math.pow)

CI red on tag 10 release #1983: client:compileCommonMainKotlinMetadata
and :compileKotlinLinuxArm64 both failed with:
  e: ReconnectingOutbox.kt:154 Unresolved reference 'Volatile'
  e: ReconnectingOutbox.kt:227 Unresolved reference 'Math'

@Volatile is JVM-only annotation; java.lang.Math is JVM-only API. On
linuxArm64/macosArm64 they don't resolve.

Fix:
- @Volatile private var lastSeen: Instant? → AtomicReference<Instant?>
  (kotlin.concurrent.atomics, same module as the AtomicBoolean already
  used for ). .load() / .store() / @OptIn(ExperimentalAtomicApi::class).
- Math.pow(m, e) → m.pow(e) via kotlin.math.pow import.

commonMain stays KMP-clean; jvmTest green (95 tasks); linuxX64 / linuxArm64
/ mingwX64 / macosX64 / macosArm64 compile green.

.gitea/workflows/ci.yml

@@ -5,6 +5,9 @@
 # Зависимости (text-embedding-kmp) подтягиваются из caffeine Nexus.
 # Все env secrets доступны через vars/secrets репозитория — см. начало
 # release.yml для требуемых переменных.
+#
+# :agentik-cli / :agentik-tui исключены из сборки (settings.gradle.kts
+# 2026-09-17/21) — соответствующие шаги shadowJar тут НЕ запускаются.
 name: ci
 
 on:
@@ -17,6 +20,14 @@ concurrency:
   group: ${{ github.workflow }}-${{ github.ref }}
   cancel-in-progress: true
 
+# UTF-8 обязателен: в именах тестов есть типографские символы (—), а Kotlin-компилятор
+# создаёт .class-файлы с именем теста. При LANG=C sun.jnu.encoding = ASCII, и компилятор
+# падает с "InvalidPathException: Malformed input or input contains unmappable characters"
+# (проверено локально: LANG=C → BUILD FAILED, LANG=C.UTF-8 → BUILD SUCCESSFUL).
+env:
+  LANG: C.UTF-8
+  LC_ALL: C.UTF-8
+
 jobs:
   build-jvm:
     name: JVM build + tests
@@ -59,31 +70,13 @@ jobs:
           test -f standalone/build/libs/standalone-*-all.jar \
             && echo "shadowJar OK: $(du -h standalone/build/libs/standalone-*-all.jar)"
 
-      - name: Build :agentik-cli shadowJar
-        shell: bash
-        run: |
-          ./gradlew :agentik-cli:shadowJar \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-          test -f agentik-cli/build/libs/agentik-cli-all.jar \
-            && echo "shadowJar OK: $(du -h agentik-cli/build/libs/agentik-cli-all.jar)"
-
-      - name: Build :agentik-tui shadowJar
-        shell: bash
-        run: |
-          ./gradlew :agentik-tui:shadowJar \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-          test -f agentik-tui/build/libs/agentik-tui-all.jar \
-            && echo "shadowJar OK: $(du -h agentik-tui/build/libs/agentik-tui-all.jar)"
-
-      - name: Upload shadowJars
-        uses: actions/upload-artifact@v4
-        with:
-          name: agentik-jars
-          path: |
-            standalone/build/libs/standalone-all.jar
-            agentik-cli/build/libs/agentik-cli-all.jar
-            agentik-tui/build/libs/agentik-tui-all.jar
-          if-no-files-found: error
-          retention-days: 7
+# Шага "Build :agentik-cli shadowJar" здесь нет: :agentik-cli исключён из
+# settings.gradle.kts (2026-09-21). :agentik-tui — тоже исключён (2026-09-17).
+# Когда/если оба вернутся, добавим отдельные шаги по аналогии с :standalone.
+#
+# Шага "Upload shadowJars" здесь нет сознательно: upload-artifact@v4 требует
+# @actions/artifact v2, который на GHES/Gitea-раннере падает с
+# "GHESNotSupportedError: @actions/artifact v2.0.0+ ... not supported on GHES"
+# и валит весь джоб уже ПОСЛЕ успешной сборки и зелёных тестов.
+# У соседних репо (asr-kmp, litert-kmp) артефакты наружу тоже не выгружаются —
+# проверка сборки ограничивается test -f на jar (шаги выше).

.gitea/workflows/release.yml

@@ -1,14 +1,20 @@
 # Триггерится при публикации релиза в Gitea. Публикует все KMP-библиотеки
-# (jvm + native таргеты) в домашний Nexus-репозиторий "caffeine", а также
-# собирает fatjar'ы запускаемых модулей и прикрепляет их к релизу как
-# бинарные ассеты.
+# (jvm + native таргеты) в домашний Nexus-репозиторий "caffeine".
 #
-# Требуемые Gitea Action Variables:
-#   BINOM_REPO_URL — например http://192.168.76.117/repository/caffeine/
-# Требуемые Gitea Action Secrets:
-#   BINOM_REPO_USER, BINOM_REPO_PASSWORD — креды Nexus с правами на публикацию.
-#   RELEASE_TOKEN — Gitea API-токен с правами на запись в релиз (используется
-#     forgejo-release action для прикрепления fatjar'ов к release).
+# Fatjar-ы запускаемых модулей (:standalone, :agentik-cli).
+# :agentik-tui был исключён из сборки 2026-09-17 (см. settings.gradle.kts).
+# НЕ собираются и НЕ крепятся к релизу здесь. Сборка артефактов
+# выполняется локально из исходников (или руками через `./gradlew
+# :<module>:shadowJar`) и загружается в релиз через Gitea UI / API
+# отдельно от этого workflow.
+#
+# Версия публикации = имя тега релиза (без префикса 'v'). Релиз с именем "3"
+# публикует pw.binom.agentik:*:3 в Nexus. Ничего хардкодить не нужно —
+# версия берётся из тега каждый раз.
+#
+# Публикация выполняется общим composite-action'ом subochev/devops/publish@main
+# (тот же, что у asr-kmp / litert-kmp / embedder-kmp / a2a-protocol) — credentials
+# BINOM_REPO_* берутся им из Gitea Action Variables (owner_id=0, глобальные).
 name: release
 
 on:
@@ -19,6 +25,15 @@ concurrency:
   group: release-${{ github.ref }}
   cancel-in-progress: false
 
+# UTF-8 обязателен: генерация POM/Kotlin-метаданных и имена тестовых классов
+# содержат не-ASCII символы; при LANG=C sun.jnu.encoding = ASCII и сборка
+# падает с "InvalidPathException: Malformed input or input contains unmappable
+# characters" (проверено локально 19.09.2026: LANG=C → BUILD FAILED,
+# LANG=C.UTF-8 → BUILD SUCCESSFUL).
+env:
+  LANG: C.UTF-8
+  LC_ALL: C.UTF-8
+
 jobs:
   publish-libraries:
     name: Publish KMP libraries → caffeine Nexus
@@ -28,108 +43,7 @@ jobs:
       - name: Checkout
         uses: actions/checkout@v4
 
-      - name: Setup JDK 21
-        uses: actions/setup-java@v4
+      - name: Publish libraries (all KMP targets, all modules) to Nexus
+        uses: https://git.binom.pw/subochev/devops/publish@main
         with:
-          java-version: '21'
-          distribution: 'adopt'
-
-      - name: Gradle cache
-        uses: actions/cache@v4
-        with:
-          path: |
-            ~/.gradle/caches
-            ~/.gradle/wrapper
-            .gradle
-          key: ${{ runner.os }}-gradle-agentik-${{ hashFiles('**/*.gradle.kts', '**/gradle/libs.versions.toml', 'gradle/wrapper/gradle-wrapper.properties') }}
-          restore-keys: |
-            ${{ runner.os }}-gradle-agentik-
-
-      - name: Publish libraries (all KMP targets, all modules)
-        shell: bash
-        env:
-          BINOM_REPO_USER: ${{ secrets.BINOM_REPO_USER }}
-          BINOM_REPO_PASSWORD: ${{ secrets.BINOM_REPO_PASSWORD }}
-          BINOM_REPO_URL: ${{ vars.BINOM_REPO_URL }}
-        run: |
-          ./gradlew \
-            "-Pversion=${GITEA_REF_NAME}" \
-            "-Pbinom.repo.url=${BINOM_REPO_URL}" \
-            "-Pbinom.repo.user=${BINOM_REPO_USER}" \
-            "-Pbinom.repo.password=${BINOM_REPO_PASSWORD}" \
-            publish \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-
-  build-fatjars:
-    name: Build runnable fatjars
-    runs-on: ubuntu-latest
-    timeout-minutes: 30
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v4
-
-      - name: Setup JDK 21
-        uses: actions/setup-java@v4
-        with:
-          java-version: '21'
-          distribution: 'adopt'
-
-      - name: Gradle cache
-        uses: actions/cache@v4
-        with:
-          path: |
-            ~/.gradle/caches
-            ~/.gradle/wrapper
-            .gradle
-          key: ${{ runner.os }}-gradle-agentik-${{ hashFiles('**/*.gradle.kts', '**/gradle/libs.versions.toml', 'gradle/wrapper/gradle-wrapper.properties') }}
-          restore-keys: |
-            ${{ runner.os }}-gradle-agentik-
-
-      - name: Build :standalone shadowJar
-        shell: bash
-        run: |
-          ./gradlew :standalone:shadowJar \
-            -Pdisable-javadoc=true \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-
-      - name: Build :agentik-cli shadowJar
-        shell: bash
-        run: |
-          ./gradlew :agentik-cli:shadowJar \
-            -Pdisable-javadoc=true \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-
-      - name: Build :agentik-tui shadowJar
-        shell: bash
-        run: |
-          ./gradlew :agentik-tui:shadowJar \
-            -Pdisable-javadoc=true \
-            -Dorg.gradle.jvmargs=-Xmx4096M \
-            --no-daemon --no-watch-fs --stacktrace
-
-      - name: Upload fatjars as release assets
-        uses: actions/upload-artifact@v4
-        with:
-          name: agentik-fatjars
-          path: |
-            standalone/build/libs/standalone-*-all.jar
-            agentik-cli/build/libs/agentik-cli-*-all.jar
-            agentik-tui/build/libs/agentik-tui-*-all.jar
-          if-no-files-found: error
-          retention-days: 90
-
-      - name: Attach to release
-        uses: https://git.binom.pw/actions/forgejo-release@v1
-        if: startsWith(github.ref, 'refs/tags/')
-        with:
-          url: ${{ github.server_url }}
-          repo: ${{ github.repository }}
-          token: ${{ secrets.RELEASE_TOKEN }}
-          tag: ${{ github.ref_name }}
-          files: |
-            standalone/build/libs/standalone-*-all.jar
-            agentik-cli/build/libs/agentik-cli-*-all.jar
-            agentik-tui/build/libs/agentik-tui-*-all.jar
+          version: ${{ gitea.ref_name }}

.gitignore

@@ -18,8 +18,13 @@ out/
 
 # Local tooling (Magic Context, IDE plugins, MCP configs)
 .cortexkit/
+# opencode CLI local config (per-machine, не коммитим)
+config.json
 .veai/
 
+# Internal review scratch dir (review/validation .md файлы, .tasks структура)
+.tasks/
+
 # Runtime / test artifacts
 agentik.db
 agentik.db-shm

README.md

@@ -21,8 +21,8 @@ agentik/
 ├── storage-inmemory/  in-memory реализация для тестов и Android
 ├── storage-sqlite/    SQLite реализация для production
 ├── agent-toolsets/    ядро tool-calls с cooperative cancel + concurrency budget
-├── agentik-cli/       JVM REPL-клиент (JLine) к /agentik
-├── agentik-tui/       Compose-for-Mosaic TUI-клиент (desktop) к /agentik
+├── agentik-cli/       JVM one-shot CLI-клиент (kotlinx.cli) к /agentik
+├── ~~agentik-tui/~~  ~~Compose-for-Mosaic TUI-клиент (desktop)~~ — исключён 2026-09-17
 └── standalone/        single-jar HTTP-сервер со всеми transport'ами и движками
 ```
 
@@ -70,10 +70,7 @@ java --enable-native-access=ALL-UNNAMED -jar agentik-0.1.0-all.jar
 
 ```bash
 # CLI
-java --enable-native-access=ALL-UNNAMED -jar agentik-cli-0.1.0-all.jar
-
-# TUI
-java --enable-native-access=ALL-UNNAMED -jar agentik-tui-0.1.0-all.jar
+java --enable-native-access=ALL-UNNAMED -jar agentik-cli-0.1.0-SNAPSHOT-all.jar --help
 
 # curl
 curl http://localhost:8080/health
@@ -83,8 +80,7 @@ curl http://localhost:8080/health
 
 - Запускаемые:
   - [`:standalone`](standalone/README.md) — single-jar HTTP-сервер.
-  - [`:agentik-cli`](agentik-cli/README.md) — REPL-клиент (JLine).
-  - [`:agentik-tui`](agentik-tui/README.md) — Compose-for-Mosaic TUI.
+  - [`:agentik-cli`](agentik-cli/README.md) — one-shot CLI-клиент (kotlinx.cli), JVM + 4 native.
 - Библиотеки (контракты и реализации):
   - [`:proto`](proto/README.md) — stateful KMP-протокол.
   - [`:server`](server/README.md) — HTTP/SSE фасад `:proto`.

STATUS.txt

@@ -0,0 +1,37 @@
+Status of message-log-api migration:
+
+DONE:
+1. Created :message-log-api module with build.gradle.kts (KMP, jvm + linuxX64 + mingwX64, kotlinx-serialization plugin).
+2. Created 5 files in message-log-api/src/commonMain/kotlin/pw/binom/agentik/messageLog/:
+   - Content.kt (sealed: Text, Image)
+   - MessageRecord.kt (sealed: UserMessage, AssistantMessage, ToolCall, ToolResult, Error; plus TurnTokens)
+   - MessageStore.kt (interface, TokenStats, MessageEvent)
+   - MessageContext.kt (MessageOrigin enum + MessageContext data class)
+   - Payload.kt (bodyJson, MessageBodyPayload, encode/decodeBodyPayload, BodyDecoded)
+3. Added include(":message-log-api") in settings.gradle.kts (right after message-store-api).
+4. Added api(project(":message-log-api")) to working-memory-api/build.gradle.kts.
+5. Wrote /tmp/rename_imports.py with 12 FQN renames (MessageRecord, MessageStore, Content, MessageContext, MessageOrigin, TurnTokens, TokenStats, MessageEvent, MessageBodyPayload, BodyDecoded, encodeBodyPayload, decodeBodyPayload).
+6. Wrote /tmp/run_rename.sh that runs the python script.
+
+PENDING:
+- Run /tmp/run_rename.sh to apply the renames across all consumer files.
+- Delete the 5 originals from message-store-api/src/commonMain/kotlin/pw/binom/agentik/messageStore/.
+- Add api(project(":message-log-api")) to storage-inmemory/sqlite/ksqlite gradle files.
+- Verify build compiles (run standalone tests).
+
+Files that need import updates (per search):
+- storage-inmemory/src/commonMain/.../InMemoryMessageStore.kt
+- storage-inmemory/src/commonTest/.../InMemoryMessageStoreTest.kt
+- storage-sqlite/src/jvmMain/.../SqliteMessageStore.kt
+- storage-ksqlite/src/commonMain/.../KsqliteMessageStore.kt
+- storage-ksqlite/src/commonMain/.../MessageCodecs.kt
+- storage-ksqlite/src/commonTest/.../KsqliteMessageStoreTest.kt
+- standalone/src/jvmMain/.../ToolDispatcher.kt
+- standalone/src/jvmMain/.../ConversationLoop.kt
+- standalone/src/jvmTest/.../ChatAgentTest.kt
+- standalone/src/jvmTest/.../persistence/PersistenceTest.kt
+- standalone/src/jvmTest/.../persistence/SqliteStoresMigrationTest.kt
+- standalone/src/jvmTest/.../persistence/TokenStatsTest.kt
+
+Tool issue: run_command keeps failing JSON validation (safe_to_run field required).
+Workaround needed before continuing the migration.

agent-toolsets/README.md

@@ -77,7 +77,7 @@ budget exhaustion, registry filter, parallel dispatch.
 ## Чего здесь НЕТ
 
 - Никакого конкретного LLM. Dispatcher вызывает tools, не LLM.
-- Никакого persistent storage. Опирается на контракт `WorkingMemoryStore`
+- Никакого persistent storage. Опирается на контракт `ContextStore`
   (см. `:storage-core`).
 
 ## Текущий статус

agent-toolsets/build.gradle.kts

@@ -21,8 +21,9 @@ kotlin {
 
     sourceSets {
         commonMain.dependencies {
-            // :storage-core — для StorageBundle в ToolsetContext (commit 5+)
-            api(project(":storage-core"))
+            api(project(":journal-api"))
+            api(project(":reflection-api"))
+            api(project(":context-api"))
 
             // litert-kmp: LiteTool интерфейс (sync describe/invoke)
             api(libs.litert.api)

agent-toolsets/src/commonMain/kotlin/pw/binom/agentik/toolsets/NamedTool.kt

@@ -1,4 +1,4 @@
-package pw.binom.agentik.standalone.agent
+package pw.binom.agentik.toolsets
 
 import pw.binom.litert.LiteTool
 
@@ -8,5 +8,8 @@ import pw.binom.litert.LiteTool
  * Имя используется как ключ для матчинга `LiteToolCall.name` (приходящего от LLM)
  * с конкретной реализацией тула. Для MCP-адаптеров имя имеет формат `server__tool`,
  * чтобы избежать коллизий между разными MCP-серверами.
+ *
+ * Перенесён из `:standalone/agent/NamedTool.kt` — это generic data-класс,
+ * должен жить рядом с другими тулами в `:agent-toolsets`.
  */
 data class NamedTool(val name: String, val tool: LiteTool)

agent-toolsets/src/commonMain/kotlin/pw/binom/agentik/toolsets/ToolsetContext.kt

@@ -4,7 +4,7 @@ package pw.binom.agentik.toolsets
  * Контекст, который тулсеты получают при активации.
  *
  * В commit 4 — минимальный: логгер. Позже (commit 5+, если понадобится) сюда
- * добавятся `StorageBundle`, `SkillStore` и пр., чтобы тулы внутри тулсета
+ * добавятся `SkillStore` и пр., чтобы тулы внутри тулсета
  * могли читать/писать сообщения и память.
  *
  * Если конкретному тулсету нужно больше, чем [Logger], он может объявить свой

agentik-cli/README.md

@@ -1,83 +1,176 @@
-# `:agentik-cli` — JVM CLI клиент к `/agentik`
+# `:agentik-cli` — one-shot CLI клиент к `/agentik`
 
 ## Что это
 
-JVM-only REPL-клиент к серверу `:standalone` через `:client`
-над HTTP+SSE:
+**One-shot subcommand CLI** (Kotlin Multiplatform) к серверу
+`:standalone` через `:client` по HTTP+SSE. Один вызов — одна команда:
+стрим ответа `send` идёт в stdout построчно, никакого embedded-REPL.
 
-- Нативный REPL с JLine (стрелки влево/вправо/вверх, история,
-  Ctrl-D/E).
-- Подписка на live-стрим событий агента.
-- Slash-команды: `/new /list /switch /rename /rm /interrupt /history
-  /pwd /help /exit /quit`.
-- Persistent session id в `~/.agentik/cli-state.json`.
+Решает: быстрый способ дёрнуть агента из shell-скрипта или руками,
+не поднимая отдельную TUI-сессии.
 
-Решает: быстрый способ проверить агента руками из терминала.
-Используется в CI-смоук-тестах и для daily-driver.
+## Платформы
+
+| Платформа | Артефакт | Размер | Статус |
+|---|---|---|---|
+| `jvm` (JRE 21) | `*-all.jar` | ~7 МБ | ✓ собирается и работает |
+| `linuxX64` | `.kexe` | ~5 МБ | ✓ собирается и работает на этом хосте |
+| `macosX64` | `.kexe` | — | собирается на macOS-раннере |
+| `macosArm64` | `.kexe` | — | собирается на macOS-arm64-раннере |
+| `mingwX64` | `.exe` | ~6 МБ | ✓ собирается (cross-compile с Linux) |
+| `linuxArm64` | — | — | **нет** — kotlinx-cli 0.3.6 не публикует klib для linuxArm64 |
+| `iOS` | — | — | нет смысла на iOS |
+
+## Подкоманды
+
+```
+agentik-cli <command> [args...]
+
+Команды верхнего уровня:
+    conv <subcommand>      операции над диалогами (см. ниже)
+    msgs <id> [--limit N]  показать сообщения
+    send <id> <text...>    отправить ход, стримит response-события в stdout
+    interrupt <id>         прервать текущий ход
+    info                   показать конфиг (server URL + agent id)
+
+Подкоманды `conv`:
+    conv ls                список диалогов
+    conv new [--temp]      создать диалог, печатает id
+    conv show <id>         метаданные диалога
+    conv delete <id>       удалить диалог
+    conv rename <id> <title> переименовать
+```
+
+`--server URL` и `--id ID` (env: `AGENTIK_SERVER`, `AGENTIK_AGENT_ID`)
+задаются **после** имени subcommand'а — kotlinx.cli не шарит опции
+родителя в subcommand. Примеры:
+
+```bash
+agentik-cli conv ls --server http://192.168.76.166:8080/agentik
+agentik-cli conv new --server http://localhost:8080/agentik
+agentik-cli send --server http://localhost:8080/agentik conv-abc "привет"
+agentik-cli info   # через AGENTIK_SERVER env-переменную
+```
 
 ## Как запустить
 
-### Требования
-
-- JVM 21+ (на машине должна быть JAVA_HOME или `java` в PATH).
-- Запущенный `:standalone` (по умолчанию `http://localhost:8080/agentik`).
-
-### Запуск из готового fatjar
+### JVM (fatjar)
 
 ```bash
-java --enable-native-access=ALL-UNNAMED -jar agentik-cli-0.1.0-all.jar \
-     --server http://192.168.76.166:8080/agentik
+./gradlew :agentik-cli:shadowJar
+java --enable-native-access=ALL-UNNAMED \
+     -jar agentik-cli/build/libs/agentik-cli-0.1.0-SNAPSHOT-all.jar conv --help
 ```
 
-### Запуск через Gradle (dev)
+### Native linuxX64
 
 ```bash
-./gradlew :agentik-cli:run --args="--server http://localhost:8080/agentik"
+./gradlew :agentik-cli:linkReleaseExecutableLinuxX64
+./agentik-cli/build/bin/linuxX64/releaseExecutable/agentik-cli.kexe conv --help
 ```
 
-## Параметры CLI
+### Native macOS / Windows
 
-| Флаг | ENV | Что делает |
-|---|---|---|
-| `--server URL` | `AGENTIK_SERVER` | URL `/agentik` (default `http://localhost:8080/agentik`) |
-| `--id ID` | `USER`/`USERNAME` | Имя агента (default — текущий пользователь) |
-| `--no-history` | — | Не восстанавливать последнюю диалог после запуска |
-| `--help` | — | Показывает help и выходит |
+На Linux-хосте `macosX64`/`macosArm64` линкуются пустыми (нужен
+macOS-раннер, Apple Mach-O формат). `mingwX64` собирается через
+кросс-компиляцию.
 
-## Slash-команды (внутри REPL)
+CI-ноут: запускать `./gradlew :agentik-cli:linkReleaseExecutableMacosX64
+:agentik-cli:linkReleaseExecutableMacosArm64` на `macos-latest`
+раннере Gitea Actions.
 
-| Команда | Синонимы | Что делает |
-|---|---|---|
-| `/help` | | Показывает help |
-| `/new [title]` | | Создать диалог |
-| `/list` | `/ls` | Список диалогов |
-| `/switch <id>` | `/sw`, `/cd` | Переключиться на диалог |
-| `/rename <title>` | | Переименовать текущий диалог |
-| `/rm [id]` | `/delete` | Удалить (текущий или по id) |
-| `/interrupt` | `/stop`, `/cancel` | Прервать текущий ход |
-| `/history` | `/h`, `/hist` | Показывает историю текущего диалога |
-| `/pwd` | | Путь к state-file |
-| `/exit`, `/quit` | | Выйти |
+## Примеры
 
-## Переменные среды (пробрасываются серверу через `--server`)
+```bash
+# Список диалогов (таблица)
+agentik-cli conv ls --server http://localhost:8080/agentik
 
-См. [`../standalone/README.md`](../standalone/README.md). На стороне
-клиента они **не** интерпретируются — это лишь настройки запуска
-агента. CLI только знает, по какому URL стучаться.
+# Создать диалог
+ID=$(agentik-cli conv new --server http://localhost:8080/agentik)
+echo "new conv: $ID"
 
-## Известное ограничение
+# Переименовать
+agentik-cli conv rename --server http://localhost:8080/agentik "$ID" "мой чат"
 
-SSE event-stream в не-TTY ssh-сессии (без `-tt`) закрывается на
-default-таймауте Ktor. Используйте либо `ssh -tt`, либо нативный
-terminal. Это upstream-особенность Ktor SSE.
+# Отправить ход и стримить ответ
+agentik-cli send --server http://localhost:8080/agentik "$ID" "2+2"
+
+# Показать последние N сообщений
+agentik-cli msgs --server http://localhost:8080/agentik "$ID" --limit 10
+
+# Прервать активный ход
+agentik-cli interrupt --server http://localhost:8080/agentik "$ID"
+
+# Удалить
+agentik-cli conv delete --server http://localhost:8080/agentik "$ID"
+
+# Через env-переменную
+AGENTIK_SERVER=http://localhost:8080/agentik agentik-cli info
+```
+
+## Формат вывода `send`
+
+Каждое SSE-событие печатается отдельной строкой `event <Type> ...` —
+пригодно для парсинга через `awk`/`jq`-обёртки:
+
+```
+event StartReasoning
+event StartResponse TEXT
+event AppendText \n\n
+event AppendText Привет!
+event End
+```
+
+Терминальные события (`End`, `Interrupted`, `Error`) тоже
+печатаются; CLI выходит сразу после `End`.
+
+## Почему kotlinx.cli (а не clikt)
+
+- **kotlinx.cli 0.3.6** (JetBrains, KMP) — единственный зрелый
+  arg-parser, который стабильно линкуется под `linux_x64` +
+  `macos_x64`/`macos_arm64` + `mingw_x64`. Минус: нет `linux_arm64`.
+- **clikt-multiplatform 5.x** (ajalt) — имеет linuxArm64, но
+  ломается на native linker: `duplicate symbol selfAndAncestors`
+  между `clikt` и `clikt-mordant` commonMain (issue
+  [ajalt/clikt#598](https://github.com/ajalt/clikt/issues/598)).
+  Workaround `kotlin.native.cacheKind.linuxX64=none` замедляет
+  сборку на порядки и не решает проблему до конца. Поэтому clikt
+  отвергнут.
+
+## Платформенные детали
+
+- **entryPoint на K/N** — это FQN функции **без** суффикса `Kt`
+  (т.е. `pw.binom.agentik.cli.main`, а не `MainKt.main`). JVM
+  convention `MainKt.main` тут не работает — K/N линкер ищет
+  функцию по `package.main`.
+- **`platformEnv(key)`** для чтения env-переменных:
+  - JVM: `System.getenv(key)` через `jvmMain` actual.
+  - Native: `getenv(key)` из `platform.posix` через
+    `kotlinx.cinterop.toKString()` (`nativeMain` actual,
+    требует `@OptIn(ExperimentalForeignApi::class)`).
+- **Stdout / exit code** — работают на K/N через корутины.
+
+## Готчасы kotlinx.cli
+
+- **Вложенные subcommands + parent.execute().** В kotlinx.cli 0.3.6
+  `parent.execute()` вызывается ПОСЛЕ `leaf.execute()` всегда,
+  когда leaf был достигнут через parent. Поэтому `ConvCommand.execute()`
+  сделан no-op (`override fun execute() = Unit`), иначе вывод
+  дочерней команды дублируется выводом родителя. Дочерние команды
+  смотрятся через `agentik-cli conv --help`.
+- **strictSubcommandOptionsOrder.** Без этого флага `conv new --server ...`
+  парсится как `conv [--server ...]` + позиционный аргумент `new`
+  на уровне родителя — и дочерняя команда не запускается.
+  В `ArgParser` сразу включается `strictSubcommandOptionsOrder = true`.
 
 ## Тесты
 
-```
-./gradlew :agentik-cli:jvmTest
-```
+Тесты для подкоманд пока не написаны (TODO). Базовый smoke
+покрывается руками против живого сервера.
 
-23 теста: парсер slash-команд, event-рендер, state-repository.
+```bash
+./gradlew :agentik-cli:jvmTest   # 0/0 — пока пусто
+```
 
 ## Версии
 

agentik-cli/build.gradle.kts

@@ -1,7 +1,6 @@
 import org.jetbrains.kotlin.gradle.ExperimentalKotlinGradlePluginApi
 
 import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
-import org.gradle.api.artifacts.ConfigurationContainer
 
 plugins {
     alias(libs.plugins.kotlin.multiplatform)
@@ -12,67 +11,68 @@ plugins {
 kotlin {
     jvmToolchain(21)
 
-    // Suppress Beta-предупреждения от expect/actual объектов — фича стабильна с Kotlin 1.9,
-    // но компилятор всё ещё требует -Xexpect-actual-classes, чтобы не ныть.
-    compilerOptions {
-        freeCompilerArgs.add("-Xexpect-actual-classes")
-    }
-
-    // "Все возможные цели сборки": jvm + весь натив. Зеркалит набор :server/:proto.
-    // commonMain зависит только от :proto (KMP). jvmMain подключает :client (JVM-only)
-    // и JLine — там же и `:client`'s AgentClient. nativeMain пока получает stub actual,
-    // расширять будем через ktor-client-* {curl,darwin,winhttp} когда дойдёт очередь.
+    // Native-таргеты, которые покрывает kotlinx.cli 0.3.6 (см. его .module
+    // в Maven Central): linux_x64, macos_x64, macos_arm64, mingw_x64.
+    // linuxArm64 не входит — kotlinx.cli 0.3.6 для него не публикуется
+    // (последний релиз 2023-09, KMP-targets зафиксированы). clikt-multiplatform
+    // 5.x имеет linuxArm64, но ломается на duplicate symbol `selfAndAncestors`
+    // между clikt и clikt-mordant при линковке native (issue ajalt/clikt#598),
+    // поэтому clikt отвергнут.
+    //
+    // iOS не входит: :agentik-cli бессмыслен на iOS, а :client (единственный
+    // его потребитель) тоже без iOS.
     jvm()
-    macosX64()
-    macosArm64()
-    iosX64()
-    iosArm64()
-    iosSimulatorArm64()
-    linuxX64()
-    linuxArm64()
-    mingwX64()
+    listOf(
+        linuxX64(),
+        macosX64(),
+        macosArm64(),
+        mingwX64(),
+    )
 
     sourceSets {
         commonMain.dependencies {
             implementation(project(":proto"))
+            implementation(project(":client"))
+
+            // kotlinx.cli 0.3.6 — KMP subcommand-парсер от JetBrains.
+            // clikt 5.x имеет upstream-баг: `duplicate symbol selfAndAncestors`
+            // между `clikt` и `clikt-mordant` при линковке native. kotlinx.cli
+            // таких проблем нет.
+            implementation(libs.kotlinx.cli)
 
             implementation(libs.kotlinx.coroutines.core)
-            implementation(libs.kotlinx.serialization.core)
-            implementation(libs.kotlinx.serialization.json)
-        }
-        jvmMain.dependencies {
-            // :client JVM-only (ktor-cio). Подключаем только в jvmMain.
-            implementation(project(":client"))
-            // JLine для readline с историей и completion.
-            implementation(libs.jline)
-        }
-        commonTest.dependencies {
-            implementation(kotlin("test"))
-            implementation(libs.kotlinx.coroutines.core)
-            // runTest { } — suspend test runner для commonTest.
-            implementation("org.jetbrains.kotlinx:kotlinx-coroutines-test:1.11.0")
-        }
-        jvmTest.dependencies {
-            // JUnit нужен в jvmTest — kotlin-test на JVM = JUnit4.
-            implementation("junit:junit:4.13.2")
+            implementation(libs.ktor.client.cio)
         }
+        // :agentik-cli — commonMain-only (нет jvmMain/nativeMain разделения):
+        // весь код, включая platformEnv, лежит в commonMain.
     }
 
     @OptIn(ExperimentalKotlinGradlePluginApi::class)
     jvm {
         binaries {
             executable {
-                mainClass.set("pw.binom.agentik.cli.MainKt")
+                mainClass.set("pw.binom.agentik.cli.AgentikCliKt")
             }
         }
     }
+
+    // entryPoint на K/N — это FQN функции БЕЗ суффикса `Kt`
+    // (Java/Kotlin convention `MainKt.main` тут не работает, линкер K/N ищет
+    // функцию как `package.main`). На JVM суффикс `Kt` сохраняется через
+    // mainClass.set(...) выше.
+    listOf(
+        linuxX64(),
+        macosX64(),
+        macosArm64(),
+        mingwX64(),
+    ).forEach {
+        it.binaries.executable {
+            entryPoint = "pw.binom.agentik.cli.main"
+        }
+    }
 }
 
-// --- Fatjar (uberjar) ---
-//
-// По аналогии с :standalone: shadowJar берёт `jvmJar` + `jvmRuntimeClasspath`.
-// Shadow 8.x не авторегистрирует shadowJar в KMP-проектах — нужно явно register.
-
+// Fatjar — аналог :standalone.
 val shadowJarTask = tasks.register<ShadowJar>("shadowJar") {
     archiveBaseName.set("agentik-cli")
     archiveClassifier.set("all")
@@ -80,20 +80,13 @@ val shadowJarTask = tasks.register<ShadowJar>("shadowJar") {
     group = "build"
 
     from(tasks.named("jvmJar"))
-    val cc = try {
-        @Suppress("UNCHECKED_CAST")
-        configurations as org.gradle.api.artifacts.ConfigurationContainer
-    } catch (_: ClassCastException) {
-        @Suppress("UNCHECKED_CAST")
-        (project as org.gradle.api.Project).configurations as org.gradle.api.artifacts.ConfigurationContainer
-    }
-    from(cc.getByName("jvmRuntimeClasspath"))
+    from(project.configurations.getByName("jvmRuntimeClasspath"))
 
     mergeServiceFiles()
     duplicatesStrategy = DuplicatesStrategy.EXCLUDE
 
     manifest {
-        attributes["Main-Class"] = "pw.binom.agentik.cli.MainKt"
+        attributes["Main-Class"] = "pw.binom.agentik.cli.AgentikCliKt"
         attributes["Implementation-Title"] = "agentik-cli"
         attributes["Implementation-Version"] = project.version.toString()
     }

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/AgentikCli.kt

@@ -1,323 +1,87 @@
 package pw.binom.agentik.cli
 
-import kotlinx.coroutines.CompletableDeferred
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.cancel
-import kotlinx.coroutines.flow.first
-import kotlinx.coroutines.isActive
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.runBlocking
-import pw.binom.agentik.proto.Agent
-import pw.binom.agentik.proto.Content
-import pw.binom.agentik.proto.Conversation
-import pw.binom.agentik.proto.Event
-import pw.binom.agentik.proto.Message
-import kotlin.time.Instant
+import kotlinx.cli.ArgParser
+import kotlinx.cli.ArgType
+import kotlinx.cli.ExperimentalCli
+import kotlinx.cli.Subcommand
+import kotlinx.cli.default
+import pw.binom.agentik.cli.commands.ConvCommand
+import pw.binom.agentik.cli.commands.InfoSubcommand
+import pw.binom.agentik.cli.commands.InterruptSubcommand
+import pw.binom.agentik.cli.commands.MsgsSubcommand
+import pw.binom.agentik.cli.commands.SendSubcommand
 
 /**
- * Главный класс REPL.
+ * Default `server` URL: env `AGENTIK_SERVER` или `http://localhost:8080/agentik`.
+ * Default `agent id`: env `AGENTIK_AGENT_ID` или `cli`.
  *
- * Управляет:
- *   - текущим диалогом ([currentConv]) + позицией в его event-stream ([lastEventAt]);
- *   - фоновым job'ом, слушающим events и рендерящим их через [EventRenderer].
- *   - персистентностью сессии (восстановление последнего диалога при перезапуске CLI).
- *
- * Один ход = один заход в REPL: пока идёт turn, REPL ждёт его завершения.
- * `/interrupt` стучится в [Conversation.interrupt] — фоновый подписчик событий
- * увидит [Event.Interrupted] и сам завершится.
+ * Используется в `runAgentikCli` и в каждом subcommand'е для своего
+ * `--server`/`--id` (иначе subcommand не видит значения родителя).
  */
-class AgentikCli internal constructor(private val config: CliConfig) {
+internal fun defaultServerUrl(): String = platformEnv("AGENTIK_SERVER") ?: "http://localhost:8080/agentik"
+internal fun defaultAgentId(): String = platformEnv("AGENTIK_AGENT_ID") ?: "cli"
 
-    private val agent: Agent = CliPlatform.openAgent(baseUrl = config.server, id = config.id)
-    private val terminal: CliTerminal = CliPlatform.openTerminal(
-        historyFile = if (config.historyEnabled) stateFilePath() else null,
-        prompt = "agentik> ",
-    )
-    private val sessionRepo = SessionRepository(
-        filePath = if (config.historyEnabled) stateFilePath() else null,
-        io = CliPlatform.sessionIo(),
+/**
+ * Корневой [ArgParser] `agentik-cli`. Один вызов — одна команда.
+ *
+ * ```
+ * agentik-cli <command> [args...]
+ *
+ * Commands:
+ *   conv ls|new|show|delete|rename     операции над диалогами
+ *   msgs <id> [--limit N]              показать сообщения
+ *   send <id> <text...>                отправить ход, стримит response-события в stdout
+ *   interrupt <id>                     прервать текущий ход
+ *   info                               показать конфиг
+ *
+ * `--server` и `--id` задаются ПОСЛЕ имени subcommand'а (т.е.
+ * `agentik-cli conv ls --server http://...`), не до — kotlinx.cli не
+ * шарит опции родителя в subcommand.
+ *
+ * Вложенные subcommands (`conv ls`, `conv new`, ...) реализованы
+ * через [Subcommand.subcommands]: `conv` сам — subcommand, и его
+ * дочерние команды (`ls`, `new`, `show`, `delete`, `rename`)
+ * регистрируются у него.
+ */
+@OptIn(ExperimentalCli::class)
+fun runAgentikCli(args: Array<String>) {
+    val parser = ArgParser(
+        programName = "agentik-cli",
+        // Все аргументы после имени subcommand должны передаваться
+        // В subcommand-парсер, а не парситься на уровне родителя.
+        // Без этого `conv new --server ...` парсится как `conv [--server ...]`
+        // + аргумент "new" → execute родителя, без вложенной команды.
+        strictSubcommandOptionsOrder = true,
     )
 
-    private var currentConv: Conversation? = null
-    private var currentTitle: String? = null
-    private var lastEventAt: Instant = Instant.DISTANT_PAST
+    val conv = ConvCommand()
+    parser.subcommands(
+        conv,
+        MsgsSubcommand(),
+        SendSubcommand(),
+        InterruptSubcommand(),
+        InfoSubcommand(),
+    )
 
-    private val scope = CoroutineScope(Dispatchers.Default)
-
-    suspend fun run() {
-        try {
-            // Восстановление сессии.
-            val saved = sessionRepo.load()
-            if (saved != null) {
-                val conv = runCatching { agent.getConversation(saved.conversationId) }
-                    .getOrNull()
-                if (conv != null) {
-                    currentConv = conv
-                    currentTitle = conv.title
-                    lastEventAt = saved.lastEventAt
-                    terminal.printSystem(
-                        "восстановлен диалог ${shorten(conv.id)}" +
-                            " (${conv.title ?: "без названия"})",
-                    )
-                } else {
-                    terminal.printSystem(
-                        "прошлый диалог ${shorten(saved.conversationId)} больше не существует",
-                    )
-                }
-            }
-
-            printBanner()
-
-            // Главный цикл.
-            while (scope.isActive) {
-                terminal.print(prompt())
-                val line = terminal.readLine() ?: break  // EOF → выходим
-                val trimmed = line.trim()
-                if (trimmed.isEmpty()) continue
-
-                if (trimmed.startsWith("/")) {
-                    when (val r = parseSlash(trimmed.substring(1))) {
-                        is ParseResult.Success -> {
-                            if (handleCommand(r.command) == CommandResult.Exit) break
-                        }
-                        is ParseResult.Failure -> terminal.printSystem(r.message)
-                    }
-                } else {
-                    handleUserMessage(trimmed)
-                }
-            }
-        } finally {
-            terminal.printSystem("до свидания.")
-            currentConv?.close()
-            terminal.close()
-            sessionRepo.close()
-            scope.cancel()
-        }
-    }
-
-    // ============================================================ banner / prompt
-
-    private suspend fun printBanner() {
-        terminal.println()
-        terminal.println("agentik-cli — id=${config.id} — type /help")
-        terminal.println("server: ${config.server}")
-        when (val c = currentConv) {
-            null -> terminal.println("диалог: не выбран — начните с /new или /switch <id>")
-            else -> terminal.println("диалог: ${shorten(c.id)} (${c.title ?: "без названия"})")
-        }
-        terminal.println()
-    }
-
-    private fun prompt(): String = "agentik${if (currentConv != null) "" else " (-)"}> "
-
-    private suspend fun printHelp() {
-        terminal.println(
-            """
-            |Slash-команды:
-            |  /help                  эта справка
-            |  /new [title]           создать новый диалог
-            |  /list, /ls             список диалогов (новые сверху)
-            |  /switch <id>, /sw      переключиться на диалог по id
-            |  /rename <title>        переименовать текущий диалог
-            |  /delete [<id>], /rm    удалить диалог (по id или текущий)
-            |  /history, /h           последние сообщения текущего диалога
-            |  /interrupt, /stop      прервать текущий ход
-            |  /pwd                   показать текущий диалог
-            |  /exit, /quit           выйти (Ctrl-D тоже)
-            |
-            |Любой ввод без ведущего `/` отправляется агенту в текущий диалог.
-            """.trimMargin(),
-        )
-    }
-
-    // ============================================================ command dispatch
-
-    private suspend fun handleCommand(cmd: SlashCommand): CommandResult = when (cmd) {
-        SlashCommand.Help -> { printHelp(); CommandResult.Continue }
-        SlashCommand.Exit, SlashCommand.Quit -> CommandResult.Exit
-        is SlashCommand.New -> { handleNew(cmd.title); CommandResult.Continue }
-        SlashCommand.List -> { handleList(); CommandResult.Continue }
-        is SlashCommand.Switch -> { handleSwitch(cmd.id); CommandResult.Continue }
-        is SlashCommand.Rename -> { handleRename(cmd.title); CommandResult.Continue }
-        is SlashCommand.Delete -> { handleDelete(cmd.id); CommandResult.Continue }
-        SlashCommand.Interrupt -> { handleInterrupt(); CommandResult.Continue }
-        SlashCommand.History -> { handleHistory(); CommandResult.Continue }
-        SlashCommand.Pwd -> { handlePwd(); CommandResult.Continue }
-    }
-
-    private suspend fun handleNew(title: String?) {
-        val conv = agent.createConversation(temp = false)
-        if (title != null) conv.rename(title)
-        currentConv = conv
-        currentTitle = title ?: conv.title
-        lastEventAt = Instant.DISTANT_PAST
-        terminal.printSystem("создан диалог ${shorten(conv.id)}" + if (title != null) " — «$title»" else "")
-        sessionRepo.save(conv.id, lastEventAt)
-    }
-
-    private suspend fun handleList() {
-        terminal.println("диалоги (новые сверху):")
-        agent.getConversations(offset = 0).collect { conv ->
-            val marker = if (conv.id == currentConv?.id) "*" else " "
-            val title = conv.title ?: "(без названия)"
-            terminal.println("  $marker ${shorten(conv.id)}  $title  [${conv.updatedAt}]")
-        }
-    }
-
-    private suspend fun handleSwitch(id: String) {
-        val conv = agent.getConversation(id)
-        if (conv == null) {
-            terminal.printSystem("диалог $id не найден")
-            return
-        }
-        currentConv?.close()
-        currentConv = conv
-        currentTitle = conv.title
-        lastEventAt = Instant.DISTANT_PAST
-        sessionRepo.save(conv.id, lastEventAt)
-        terminal.printSystem("переключились на ${shorten(conv.id)} (${conv.title ?: "без названия"})")
-    }
-
-    private suspend fun handleRename(title: String) {
-        val c = currentConv ?: run {
-            terminal.printSystem("нет активного диалога — /new")
-            return
-        }
-        c.rename(title)
-        currentTitle = title
-        terminal.printSystem("заголовок: $title")
-    }
-
-    private suspend fun handleDelete(id: String?) {
-        val target = id ?: currentConv?.id
-        if (target == null) {
-            terminal.printSystem("нет диалога для удаления")
-            return
-        }
-        val ok = agent.deleteConversation(target)
-        if (ok) {
-            terminal.printSystem("удалён ${shorten(target)}")
-            if (target == currentConv?.id) {
-                currentConv?.close()
-                currentConv = null
-                currentTitle = null
-                sessionRepo.clear()
-            }
-        } else {
-            terminal.printSystem("диалог ${shorten(target)} не найден")
-        }
-    }
-
-    private suspend fun handleInterrupt() {
-        val c = currentConv ?: run {
-            terminal.printSystem("нет активного диалога")
-            return
-        }
-        c.interrupt()
-        terminal.printSystem("прерывание отправлено")
-    }
-
-    private suspend fun handlePwd() {
-        val c = currentConv ?: run {
-            terminal.printSystem("диалог: не выбран")
-            return
-        }
-        terminal.printSystem("id:        ${c.id}")
-        terminal.printSystem("title:     ${c.title ?: "—"}")
-        terminal.printSystem("updatedAt: ${c.updatedAt}")
-        terminal.printSystem("temporal:  ${c.isTemporal}")
-    }
-
-    private suspend fun handleHistory() {
-        val c = currentConv ?: run {
-            terminal.printSystem("нет активного диалога")
-            return
-        }
-        terminal.println("история:")
-        c.getMessages(after = Instant.DISTANT_PAST).collect { msg -> renderHistoryMessage(msg) }
-    }
-
-    private suspend fun renderHistoryMessage(msg: Message) {
-        val prefix = "  [${msg.date}] "
-        when (msg) {
-            is Message.UserMessage ->
-                terminal.println(prefix + "user     | " + msg.content.text())
-            is Message.AssistantMessage ->
-                terminal.println(prefix + "agent    | " + msg.content.text())
-            is Message.ToolCall ->
-                terminal.println(prefix + "tool>${msg.toolName} | ${msg.toolArgs.take(160)}")
-            is Message.ToolResult ->
-                terminal.println(prefix + "tool<    | " + (msg.result?.take(160) ?: "null"))
-            is Message.Error ->
-                terminal.println(prefix + "<error${msg.code?.let { "/$it" } ?: ""}> ${msg.message}")
-        }
-    }
-
-    private fun List<Content>.text(): String =
-        joinToString(separator = "") { c ->
-            when (c) {
-                is Content.Text -> c.body
-                is Content.Image -> "[image:${c.mime}:${c.data.size}B]"
-            }
-        }
-
-    // ============================================================ user-message
-
-    private suspend fun handleUserMessage(text: String) {
-        val conv = currentConv ?: run {
-            terminal.printSystem("нет активного диалога — /new")
-            return
-        }
-
-        terminal.println()  // пустая строка для визуального отделения блока
-
-        val renderer = EventRenderer(terminal)
-        val turnFinished = CompletableDeferred<Unit>()
-
-        // Подписчик events: принимает события и обновляет lastEventAt,
-        // по терминальному событию закрывает Deferred.
-        val eventsJob = scope.launch {
-            try {
-                conv.events(after = lastEventAt).collect { ev ->
-                    renderer.render(ev)
-                    if (ev.date > lastEventAt) {
-                        lastEventAt = ev.date
-                        sessionRepo.save(conv.id, lastEventAt)
-                    }
-                    if (ev is Event.End || ev is Event.Interrupted || ev is Event.Error) {
-                        if (!turnFinished.isCompleted) turnFinished.complete(Unit)
-                    }
-                }
-            } catch (t: Throwable) {
-                if (!turnFinished.isCompleted) turnFinished.complete(Unit)
-                if (t !is kotlinx.coroutines.CancellationException) {
-                    terminal.printSystem("[events stream error] ${t.message}")
-                }
-            }
-        }
-
-        try {
-            conv.send(listOf(Content.Text(text)))
-            turnFinished.await()
-        } catch (t: Throwable) {
-            terminal.printSystem("[send error] ${t.message}")
-        } finally {
-            eventsJob.cancel()
-            renderer.close()
-            terminal.println()
-        }
-    }
-
-    // ============================================================ utils
-
-    private fun shorten(id: String): String = id.take(8)
-
-    private fun stateFilePath(): String? {
-        val home = CliPlatform.homeDir() ?: return null
-        val dir = "$home/.agentik"
-        return "$dir/cli-state.json"
-    }
+    parser.parse(args)
 }
 
-private enum class CommandResult { Continue, Exit }
+/**
+ * Базовый класс subcommand'а: каждый subcommand владеет своим `--server`/`--id`,
+ * чтобы значения родительских флагов были ему доступны (kotlinx.cli не шарит
+ * свойства родителя в subcommand).
+ */
+abstract class AgentikSubcommand(name: String, description: String) : Subcommand(name, description) {
+    val serverUrl: String by option(
+        ArgType.String, fullName = "server", shortName = "s",
+        description = "Base URL агента (env AGENTIK_SERVER)",
+    ).default(defaultServerUrl())
+    val agentId: String by option(
+        ArgType.String, fullName = "id", shortName = "i",
+        description = "Идентификатор агента (env AGENTIK_AGENT_ID)",
+    ).default(defaultAgentId())
+}
+
+fun main(args: Array<String>) {
+    runAgentikCli(args)
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/AgentikHttpClient.kt

@@ -0,0 +1,24 @@
+package pw.binom.agentik.cli
+
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import pw.binom.agentik.client.applyAgentikDefaults
+
+/**
+ * HTTP-клиент CLI: движок CIO + конфигурация agentik.
+ *
+ * Движок выбирается здесь, а не в `:client`: библиотека не выбирает транспорт за
+ * потребителя. Таргеты `:agentik-cli` (jvm + linuxX64/macosX64/macosArm64/mingwX64)
+ * покрываются CIO.
+ *
+ * `requestTimeout = 0` — отключение встроенного request-таймаута CIO;
+ * defense-in-depth против обрыва долгих SSE-idle (основная защита —
+ * `noSseReadTimeout` в `:client`).
+ *
+ * [token] = `null` — авторизация выключена.
+ */
+internal fun defaultCliHttpClient(token: String? = null): HttpClient =
+    HttpClient(CIO) {
+        applyAgentikDefaults(token)
+        engine { requestTimeout = 0 }
+    }

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/CliPlatform.kt

@@ -1,52 +0,0 @@
-package pw.binom.agentik.cli
-
-import pw.binom.agentik.proto.Agent
-
-/**
- * Платформенные зависимости CLI. Все вещи, требующие JVM-stdlib или
- * нативных API (терминал, env, файловое IO для state-файла, HTTP-клиент),
- * предоставляются здесь как `expect/actual`.
- *
- * Текущий статус: jvmMain полностью реализован (JLine + `java.io` + `:client`),
- * nativeMain — заглушки (подключение native ktor-движков и termios — отдельная задача).
- */
-expect object CliPlatform {
-    fun openAgent(baseUrl: String, id: String): Agent
-
-    fun openTerminal(
-        historyFile: String?,
-        prompt: String,
-    ): CliTerminal
-
-    /** HOME/USERPROFILE для пути пути state-файла; null если недоступна. */
-    fun homeDir(): String?
-
-    /** Переменная среды (native API). Для jvmMain — `System.getenv`. */
-    fun env(key: String): String?
-
-    /** Файловое IO для session-state; nativeMain возвращает no-op. */
-    fun sessionIo(): SessionIo
-}
-
-/**
- * Абстракция терминала, нужная для REPL. suspend-методы, чтобы не блокировать
- * event-loop агентного цикла во время ожидания ввода.
- */
-interface CliTerminal {
-    val prompt: String
-
-    /** Следующая строка пользователя (без prompt). null = EOF (Ctrl-D/Ctrl-Z). */
-    suspend fun readLine(): String?
-
-    /** Печатает строку + перевод строки. */
-    suspend fun println(text: String = "")
-
-    /** Печатает строку без перевода (для streamed chunks). */
-    suspend fun print(text: String)
-
-    /** Подсветить prompt (символы-разделители сообщений, системные баннеры и т.п.). */
-    suspend fun printSystem(text: String)
-
-    /** Закрыть терминал: restore raw mode, flush history file, ... */
-    fun close()
-}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/EventRenderer.kt

@@ -1,82 +0,0 @@
-package pw.binom.agentik.cli
-
-import pw.binom.agentik.proto.Event
-
-/**
- * Печатает [Event] в человеко-читаемом виде через [CliTerminal].
- *
- * Дизайн:
- *   - [Event.StartReasoning] — просто системный маркер; текст мысли НЕ выводим
- *     отдельным форматом (см. proto: reasonig текст идёт через [Event.AppendText]).
- *   - [Event.StartResponse] с `responseType=TEXT` — начало печати ответа; закрытие
- *     происходит при [Event.End] или [Event.Interrupted].
- *   - [Event.AppendText] — кусок текста, печатается БЕЗ перевода строки (чанки).
- *   - [Event.AppendImage] — выводим как `[image: <mime>, <bytes> bytes]` placeholder.
- *     Реальный рендеринг сделаем позже через iTerm/Kitty протоколы.
- *   - [Event.End] / [Event.Interrupted] — закрывают текущий блок.
- *   - [Event.Error] — отдельный системный блок `[error: …]`.
- */
-class EventRenderer(private val terminal: CliTerminal) {
-
-    /** Трекает открыт ли сейчас «блок ответа» (после [Event.StartResponse], до [Event.End]). */
-    private var responseOpen = false
-
-    suspend fun render(event: Event) {
-        when (event) {
-            is Event.StartReasoning -> {
-                terminal.printSystem("…thinking…")
-                if (responseOpen) {
-                    terminal.println()
-                    responseOpen = false
-                }
-            }
-
-            is Event.StartResponse -> {
-                if (responseOpen) terminal.println()
-                responseOpen = true
-                // Без префикса — текст будет стримиться дальше через AppendText.
-            }
-
-            is Event.AppendText -> {
-                terminal.print(event.body)
-            }
-
-            is Event.AppendImage -> {
-                terminal.print("[image:${event.mime}:${event.body.size} bytes]")
-            }
-
-            is Event.Interrupted -> {
-                if (responseOpen) {
-                    terminal.println()
-                    terminal.printSystem("[interrupted]")
-                    responseOpen = false
-                } else {
-                    terminal.printSystem("[interrupted]")
-                }
-            }
-
-            is Event.End -> {
-                if (responseOpen) {
-                    terminal.println()
-                    responseOpen = false
-                }
-            }
-
-            is Event.Error -> {
-                terminal.println()
-                terminal.printSystem("[error${event.code?.let { "/$it" } ?: ""}] ${event.message}")
-                if (responseOpen) responseOpen = false
-            }
-
-            else -> {
-                // ToolCall/ToolResult — это «структура» диалога, в текстовом стриме
-                // не показываем; в веб-UI будет по-другому.
-                terminal.printSystem("[event:${event::class.simpleName}]")
-            }
-        }
-    }
-
-    fun close() {
-        responseOpen = false
-    }
-}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/Main.kt

@@ -1,105 +0,0 @@
-package pw.binom.agentik.cli
-
-import kotlinx.coroutines.runBlocking
-
-/**
- * Точка входа CLI. Поддерживает аргументы командной строки:
- *
- * ```
- * agentik-cli [--server URL] [--id ID] [--no-history] [--help]
- *
- *   --server URL   базовый URL сервера agentik (default $AGENTIK_SERVER или
- *                  http://localhost:8080/agentik)
- *   --id ID        идентификатор этого клиента (default "cli:$USER")
- *   --no-history   не сохранять состояние в ~/.agentik/cli-state.json
- *   --help, -h     распечатать usage и выйти
- * ```
- *
- * Без аргументов — стартует REPL.
- */
-fun main(args: Array<String>) = runBlocking {
-    val cfg = parseCliArgs(args)
-    if (cfg == null) {
-        printUsage()
-        return@runBlocking
-    }
-    AgentikCli(cfg).run()
-}
-
-/**
- * Конфигурация CLI, вычисленная из аргументов + переменных среды.
- * Доступна из других файлов commonMain (видна как `internal` внутри модуля).
- */
-internal data class CliConfig(
-    val server: String,
-    val id: String,
-    val historyEnabled: Boolean,
-)
-
-private fun parseCliArgs(args: Array<String>): CliConfig? {
-    var server: String? = null
-    var id: String? = null
-    var historyEnabled = true
-
-    var i = 0
-    while (i < args.size) {
-        when (val a = args[i]) {
-            "--help", "-h", "help" -> return null
-            "--server", "-s" -> {
-                require(i + 1 < args.size) { "$a требует URL" }
-                server = args[i + 1]; i += 2
-            }
-            "--id" -> {
-                require(i + 1 < args.size) { "$a требует значение" }
-                id = args[i + 1]; i += 2
-            }
-            "--no-history" -> { historyEnabled = false; i++ }
-            "--" -> i++  // разделитель; остальное игнорируем
-            else -> error("неизвестный аргумент: $a (введите --help)")
-        }
-    }
-
-    val resolvedServer = server
-        ?: CliPlatform.env("AGENTIK_SERVER")
-        ?: "http://localhost:8080/agentik"
-    val resolvedId = id ?: "cli:${CliPlatform.env("USER") ?: CliPlatform.env("USERNAME") ?: "anon"}"
-
-    return CliConfig(
-        server = resolvedServer,
-        id = resolvedId,
-        historyEnabled = historyEnabled,
-    )
-}
-
-private fun printUsage() {
-    val defaultServer = CliPlatform.env("AGENTIK_SERVER") ?: "http://localhost:8080/agentik"
-    val defaultUser = CliPlatform.env("USER") ?: CliPlatform.env("USERNAME") ?: "anon"
-    println("""
-        agentik-cli — REPL поверх протокола agentik
-
-        Использование:
-          agentik-cli [--server URL] [--id ID] [--no-history]
-
-        Аргументы:
-          --server, -s URL   базовый URL (default: $defaultServer)
-          --id ID            идентификатор клиента (default: cli:${defaultUser})
-          --no-history       не сохранять состояние в ~/.agentik/cli-state.json
-          --help, -h         эта справка
-
-        Переменные среды:
-          AGENTIK_SERVER     базовый URL агента (используется если --server не задан)
-          HOME               для пути ~/.agentik/cli-state.json
-
-        В REPL:
-          /help                 список slash-команд
-          /new [title]          создать диалог (title опционально)
-          /list, /ls            список диалогов
-          /switch <id>, /sw <id>  переключиться на диалог
-          /rename <title>       переименовать текущий диалог
-          /delete [<id>], /rm   удалить (по id или текущий)
-          /history, /h          последние сообщения текущего диалога
-          /interrupt, /stop     прервать текущий ход
-          /pwd                  показать текущий диалог
-          /exit, /quit          выйти (Ctrl-D тоже работает)
-    """.trimIndent())
-}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/PlatformEnv.kt

@@ -0,0 +1,3 @@
+package pw.binom.agentik.cli
+
+internal expect fun platformEnv(key: String): String?

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/SessionRepository.kt

@@ -1,81 +0,0 @@
-package pw.binom.agentik.cli
-
-import kotlinx.serialization.Serializable
-import kotlinx.serialization.json.Json
-import kotlin.time.Instant
-
-/**
- * Состояние CLI между запусками: последний выбранный диалог и момент последнего
- * увиденного [Event.date] в его потоке (для корректного `events(after)` после рестарта).
- *
- * Доступ к диску инкапсулирован в платформенный [CliPlatform] — commonMain ничего
- * не знает про `java.io.File`/`NSFileManager`, чтобы KMP-сборка собиралась
- * под все цели. Файл: `$HOME/.agentik/cli-state.json`.
- */
-internal class SessionRepository internal constructor(
-    private val filePath: String?,
-    private val io: SessionIo,
-) {
-
-    @Serializable
-    private data class State(
-        val conversationId: String,
-        val lastEventAt: String,
-    )
-
-    private val json = Json { prettyPrint = true; ignoreUnknownKeys = true }
-
-    /** Открывается ленивым чтением. [save] ещё не было — файл может отсутствовать. */
-    private var cached: State? = null
-
-    fun load(): SavedSession? {
-        val path = filePath ?: return null
-        val raw = io.readAll(path) ?: return null
-        return runCatching {
-            val state = json.decodeFromString(State.serializer(), raw)
-            cached = state
-            SavedSession(
-                conversationId = state.conversationId,
-                lastEventAt = Instant.parse(state.lastEventAt),
-            )
-        }.getOrNull()
-    }
-
-    fun save(conversationId: String, lastEventAt: Instant) {
-        val path = filePath ?: return
-        val state = State(
-            conversationId = conversationId,
-            lastEventAt = lastEventAt.toString(),
-        )
-        cached = state
-        val body = json.encodeToString(State.serializer(), state)
-        io.writeAtomic(path, body)
-    }
-
-    fun clear() {
-        val path = filePath ?: return
-        io.delete(path)
-        cached = null
-    }
-
-    fun close() {
-        // для совместимости с будущим in-memory state; пока no-op
-    }
-}
-
-internal data class SavedSession(
-    val conversationId: String,
-    val lastEventAt: Instant,
-)
-
-/**
- * Минимальный платформо-зависимый IO-интерфейс для одного файла. Реализации
- * в jvmMain (`java.io.File` + atomic `tmp → rename`) и в nativeMain (пока no-op-stub).
- *
- * public, потому что его возвращает public [CliPlatform.sessionIo].
- */
-interface SessionIo {
-    fun readAll(path: String): String?
-    fun writeAtomic(path: String, body: String)
-    fun delete(path: String)
-}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/SlashCommand.kt

@@ -1,90 +0,0 @@
-package pw.binom.agentik.cli
-
-/**
- * Slash-команды REPL'а. Первая буква `/` не хранится — парсер уже её отрезал.
- *
- * Свободный ввод (без `/` в начале) — это сообщение пользователя агенту в
- * текущий диалог и НЕ разбирается в [parse].
- */
-sealed interface SlashCommand {
-    data object Help : SlashCommand
-    data object Exit : SlashCommand
-    data object Quit : SlashCommand  // синоним Exit
-
-    /** Создать новый диалог; опционально — заголовок. */
-    data class New(val title: String?) : SlashCommand
-
-    /** Список диалогов (cold flow — печатаем по мере прихода страниц). */
-    data object List : SlashCommand
-
-    /** Подключиться к существующему диалогу по id. */
-    data class Switch(val id: String) : SlashCommand
-
-    /** Переименовать текущий диалог. */
-    data class Rename(val title: String) : SlashCommand
-
-    /** Удалить диалог (по id или текущий). */
-    data class Delete(val id: String?) : SlashCommand
-
-    /** Прервать текущий ход. no-op если хода нет. */
-    data object Interrupt : SlashCommand
-
-    /** Показать последние сообщения текущего диалога (cold flow). */
-    data object History : SlashCommand
-
-    /** Показать информацию о текущем диалоге. */
-    data object Pwd : SlashCommand
-}
-
-/**
- * Парсит строку (без ведущего `/`) в [SlashCommand] либо возвращает [Result.Failure]
- * с сообщением об ошибке.
- *
- * Команды нечувствительны к регистру (команда `/LIST` == `/list`).
- */
-fun parseSlash(input: String): ParseResult {
-    val s = input.trim()
-    if (s.isEmpty()) return ParseResult.Failure("пустая команда (введите /help)")
-
-    // Разбиваем на команду и её аргументы. Поддерживаем склейку: /new foo bar → new "foo bar"
-    val firstSpace = s.indexOfAny(charArrayOf(' ', '\t'))
-    val cmd = if (firstSpace < 0) s else s.substring(0, firstSpace)
-    val rest = if (firstSpace < 0) "" else s.substring(firstSpace + 1).trim()
-    val args = if (rest.isEmpty()) emptyList() else rest.split(' ').filter { it.isNotEmpty() }
-
-    val command: SlashCommand? = when (cmd.lowercase()) {
-        "help", "?" -> SlashCommand.Help
-        "exit" -> SlashCommand.Exit
-        "quit", "q" -> SlashCommand.Quit
-        "new" -> SlashCommand.New(rest.takeIf { it.isNotEmpty() })
-        "list", "ls" -> SlashCommand.List
-        "switch", "sw", "cd" -> args.firstOrNull()?.let { SlashCommand.Switch(it) }
-        "rename", "mv", "title" -> rest.takeIf { it.isNotEmpty() }?.let { SlashCommand.Rename(it) }
-        "delete", "rm" -> SlashCommand.Delete(args.firstOrNull())
-        "interrupt", "stop", "cancel" -> SlashCommand.Interrupt
-        "history", "hist", "h" -> SlashCommand.History
-        "pwd", "where" -> SlashCommand.Pwd
-        else -> null
-    }
-    if (command != null) return ParseResult.Success(command)
-
-    // Не нашли команду: либо неизвестная, либо не хватает аргумента.
-    val cmdLower = cmd.lowercase()
-    return when (cmdLower) {
-        "switch", "sw", "cd" -> ParseResult.Failure("укажите id диалога: /switch <id>")
-        "rename", "mv", "title" -> ParseResult.Failure("укажите заголовок: /rename <title>")
-        else -> ParseResult.Failure("неизвестная команда: /$cmd (введите /help)")
-    }
-}
-
-sealed interface ParseResult {
-    data class Success(val command: SlashCommand) : ParseResult
-    data class Failure(val message: String) : ParseResult
-}
-
-/** Удобный helper для тестов и общего кода. */
-fun parseSlashOrNull(input: String): SlashCommand? =
-    when (val r = parseSlash(input)) {
-        is ParseResult.Success -> r.command
-        is ParseResult.Failure -> null
-    }

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvCommand.kt

@@ -0,0 +1,32 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ExperimentalCli
+import kotlinx.cli.Subcommand
+import pw.binom.agentik.cli.AgentikSubcommand
+
+/**
+ * Родительская группа `conv`: операции над диалогами.
+ *
+ * Сама команда `agentik-cli conv` (без подкоманды) — no-op:
+ * в kotlinx.cli parent.execute() вызывается ПОСЛЕ leaf.execute(),
+ * поэтому любая работа в execute() дублирует вывод дочерней команды.
+ * Для просмотра дочерних команд есть `agentik-cli conv --help`.
+ *
+ * Дочерние команды регистрируются через [subcommands] в конструкторе.
+ */
+@OptIn(ExperimentalCli::class)
+class ConvCommand : Subcommand("conv", "Операции над диалогами") {
+    init {
+        subcommands(
+            ConvLsSubcommand(),
+            ConvNewSubcommand(),
+            ConvShowSubcommand(),
+            ConvDeleteSubcommand(),
+            ConvRenameSubcommand(),
+        )
+    }
+
+    override fun execute() = Unit
+}
+
+abstract class ConvSubcommand(name: String, description: String) : AgentikSubcommand(name, description)

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvDeleteSubcommand.kt

@@ -0,0 +1,16 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+
+class ConvDeleteSubcommand : ConvSubcommand("delete", "Удалить диалог") {
+    val id by argument(ArgType.String, description = "ID диалога")
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val ok = agent.deleteConversation(id)
+        if (ok) println("deleted: $id") else println("conversation not found: $id")
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvLsSubcommand.kt

@@ -0,0 +1,33 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import kotlinx.cli.default
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+import pw.binom.agentik.proto.Agent
+
+class ConvLsSubcommand : ConvSubcommand("ls", "Список диалогов агента") {
+    val limit by option(ArgType.Int, fullName = "limit", description = "Максимум диалогов").default(Agent.PAGE_SIZE)
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val convs = agent.getConversations(offset = 0, limit = limit.coerceAtMost(Agent.PAGE_SIZE))
+        if (convs.isEmpty()) {
+            println("(no conversations)")
+            return@runBlocking
+        }
+        println("ID                                     UPDATED-AT              TITLE                            FLAGS")
+        convs.forEach { c ->
+            val flags = buildString {
+                if (c.isTemporal) append('T')
+                if (c.isSupportImageInput) append('I')
+                if (c.isSupportImageOutput) append('O')
+                if (isEmpty()) append('-')
+            }
+            val title = c.title ?: "(untitled)"
+            println("${c.id.padEnd(38)}  ${c.updatedAt.toString().padEnd(22)}  ${title.take(30).padEnd(31)}  $flags")
+        }
+        println("--- ${convs.size} conversation(s)")
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvNewSubcommand.kt

@@ -0,0 +1,17 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import kotlinx.cli.default
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+
+class ConvNewSubcommand : ConvSubcommand("new", "Создать диалог; печатает id") {
+    val temp by option(ArgType.Boolean, fullName = "temp", description = "Временный диалог").default(false)
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.createConversation(temp = temp)
+        println(conv.id)
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvRenameSubcommand.kt

@@ -0,0 +1,25 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+
+class ConvRenameSubcommand : ConvSubcommand("rename", "Переименовать диалог") {
+    val id by argument(ArgType.String, description = "ID диалога")
+    val title by argument(ArgType.String, description = "Новое название")
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.getConversation(id) ?: run {
+            println("conversation not found: $id")
+            return@runBlocking
+        }
+        try {
+            conv.rename(title)
+        } finally {
+            conv.close()
+        }
+        println("renamed: $id -> $title")
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/ConvShowSubcommand.kt

@@ -0,0 +1,28 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+
+class ConvShowSubcommand : ConvSubcommand("show", "Метаданные диалога") {
+    val id by argument(ArgType.String, description = "ID диалога")
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.getConversation(id) ?: run {
+            println("conversation not found: $id")
+            return@runBlocking
+        }
+        try {
+            println("id:           ${conv.id}")
+            println("title:        ${conv.title ?: "(untitled)"}")
+            println("updatedAt:    ${conv.updatedAt}")
+            println("isTemporal:   ${conv.isTemporal}")
+            println("isSupportImageInput:  ${conv.isSupportImageInput}")
+            println("isSupportImageOutput: ${conv.isSupportImageOutput}")
+        } finally {
+            conv.close()
+        }
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/InfoSubcommand.kt

@@ -0,0 +1,10 @@
+package pw.binom.agentik.cli.commands
+
+import pw.binom.agentik.cli.AgentikSubcommand
+
+class InfoSubcommand : AgentikSubcommand("info", "Показать server URL и agent id") {
+    override fun execute() {
+        println("server: $serverUrl")
+        println("id:     $agentId")
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/InterruptSubcommand.kt

@@ -0,0 +1,24 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+
+class InterruptSubcommand : AgentikSubcommand("interrupt", "Прервать текущий ход диалога") {
+    val id by argument(ArgType.String, description = "ID диалога")
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.getConversation(id) ?: run {
+            println("conversation not found: $id")
+            return@runBlocking
+        }
+        try {
+            conv.interrupt()
+            println("interrupted: $id")
+        } finally {
+            conv.close()
+        }
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/MsgsSubcommand.kt

@@ -0,0 +1,55 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import kotlinx.cli.default
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Message
+import kotlin.time.Instant
+
+class MsgsSubcommand : AgentikSubcommand("msgs", "Показать сообщения диалога") {
+    val id by argument(ArgType.String, description = "ID диалога")
+    val limit by option(ArgType.Int, fullName = "limit", description = "Максимум сообщений").default(100)
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.getConversation(id) ?: run {
+            println("conversation not found: $id")
+            return@runBlocking
+        }
+        try {
+            val msgs = conv.getMessages(Instant.DISTANT_PAST, offset = 0, limit = limit)
+                .sortedBy { it.date }
+            msgs.forEach { m -> println(formatMessage(m)) }
+            println("--- ${msgs.size} message(s)")
+        } finally {
+            conv.close()
+        }
+    }
+
+    private fun formatMessage(m: Message): String =
+        "[${m.date}] ${m.role().padEnd(11)} ${m.bodyOneLine()}"
+
+    private fun Message.role(): String = when (this) {
+        is Message.UserMessage -> "[user]"
+        is Message.AssistantMessage -> "[assistant]"
+        is Message.ToolCall -> "[tool_call]"
+        is Message.ToolResult -> "[tool_result]"
+        is Message.Error -> "[error]"
+    }
+
+    private fun Message.bodyOneLine(): String = when (this) {
+        is Message.UserMessage -> content.joinToString(" ") { c -> c.toOneLine() }
+        is Message.AssistantMessage -> content.joinToString(" ") { c -> c.toOneLine() }
+        is Message.ToolCall -> "tool=$toolName args=$toolArgs"
+        is Message.ToolResult -> "id=$id result=${result ?: "<null>"}"
+        is Message.Error -> "code=${code ?: "?"} message=$message"
+    }
+
+    private fun Content.toOneLine(): String = when (this) {
+        is Content.Text -> body.replace('\n', ' ').take(200)
+        is Content.Image -> "<image ${data.size}B $mime>"
+    }
+}

agentik-cli/src/commonMain/kotlin/pw/binom/agentik/cli/commands/SendSubcommand.kt

@@ -0,0 +1,65 @@
+package pw.binom.agentik.cli.commands
+
+import kotlinx.cli.ArgType
+import kotlinx.cli.vararg
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.onEach
+import kotlinx.coroutines.flow.takeWhile
+import kotlinx.coroutines.launch
+import pw.binom.agentik.cli.AgentikSubcommand
+import pw.binom.agentik.cli.defaultCliHttpClient
+import pw.binom.agentik.client.AgentikAgent
+import pw.binom.agentik.outbox.Event
+import pw.binom.agentik.proto.Content
+import kotlin.time.Instant
+
+class SendSubcommand : AgentikSubcommand("send", "Отправить user-ход и стримить ответ") {
+    val id by argument(ArgType.String, description = "ID диалога")
+    val text by argument(ArgType.String, description = "Текст хода (все позиционные после <id> склеиваются пробелом)").vararg()
+
+    override fun execute() = kotlinx.coroutines.runBlocking {
+        val agent = AgentikAgent(id = agentId, baseUrl = serverUrl, httpClient = defaultCliHttpClient())
+        val conv = agent.getConversation(id) ?: run {
+            println("conversation not found: $id")
+            return@runBlocking
+        }
+        try {
+            // Подписываемся на поток событий ДО send: события, отправленные
+            // до подписки, не реплеятся (shared-flow без replay).
+            val eventsJob = launch {
+                agent.outbox.conversationEvents(Instant.DISTANT_PAST, conv.id)
+                    // onEach печатает и терминальный event, takeWhile лишь
+                    // завершает сбор после него.
+                    .map { it.event }
+                    .onEach { ev -> emit(ev) }
+                    .takeWhile { ev -> !isTerminal(ev) }
+                    .collect { }
+            }
+            // Даём SSE-подписке установиться, затем шлём ход.
+            delay(200)
+            conv.send(listOf(Content.Text(text.joinToString(" "))))
+            eventsJob.join()
+        } finally {
+            conv.close()
+        }
+    }
+
+    private fun isTerminal(ev: Event): Boolean =
+        ev is Event.End || ev is Event.Interrupted || ev is Event.Error
+
+    private fun emit(ev: Event) {
+        when (ev) {
+            is Event.StartReasoning -> println("event StartReasoning")
+            is Event.StartResponse -> println("event StartResponse ${ev.responseType}")
+            is Event.AppendText -> println("event AppendText ${escape(ev.body)}")
+            is Event.AppendImage -> println("event AppendImage <${ev.body.size}B ${ev.mime}>")
+            is Event.ToolCall -> println("event ToolCall ${ev.id} ${ev.toolName} ${escape(ev.toolArgs)}")
+            is Event.ToolResult -> println("event ToolResult ${ev.toolCallId} ${escape(ev.result ?: "")}")
+            is Event.End -> println("event End")
+            is Event.Interrupted -> println("event Interrupted")
+            is Event.Error -> println("event Error ${ev.code ?: ""} ${escape(ev.message)}")
+        }
+    }
+
+    private fun escape(s: String): String = s.replace("\n", "\\n").replace("\r", "\\r")
+}

agentik-cli/src/commonTest/kotlin/pw/binom/agentik/cli/EventRendererTest.kt

@@ -1,81 +0,0 @@
-package pw.binom.agentik.cli
-
-import kotlinx.coroutines.test.runTest
-import pw.binom.agentik.proto.Event
-import kotlin.test.Test
-import kotlin.test.assertEquals
-import kotlin.test.assertTrue
-import kotlin.time.Instant
-
-/**
- * Подменяем [CliTerminal] простой in-memory реализацией и проверяем,
- * что события рендерятся в правильном формате.
- */
-class EventRendererTest {
-
-    private class FakeTerminal : CliTerminal {
-        override val prompt: String = ">"
-        val out = StringBuilder()
-        override suspend fun readLine(): String? = null
-        override suspend fun println(text: String) { out.appendLine(text) }
-        override suspend fun print(text: String) { out.append(text) }
-        override suspend fun printSystem(text: String) { out.appendLine("· $text") }
-        override fun close() {}
-        fun text() = out.toString()
-    }
-
-    @Test
-    fun `simple response stream`() = runTest {
-        val t = FakeTerminal()
-        val r = EventRenderer(t)
-        r.render(Event.StartResponse(Instant.DISTANT_PAST, Event.ResponseType.TEXT))
-        r.render(Event.AppendText(Instant.DISTANT_PAST, "Привет"))
-        r.render(Event.AppendText(Instant.DISTANT_PAST, ", мир!"))
-        r.render(Event.End(Instant.DISTANT_PAST))
-
-        // StartResponse открывает блок, AppendText без \n, End закрывает \n
-        val text = t.text()
-        assertTrue(text.contains("Привет, мир!"), "got: $text")
-        // после End должен быть перевод строки
-        assertTrue(text.endsWith("\n"))
-    }
-
-    @Test
-    fun `interrupted closes block`() = runTest {
-        val t = FakeTerminal()
-        val r = EventRenderer(t)
-        r.render(Event.StartResponse(Instant.DISTANT_PAST, Event.ResponseType.TEXT))
-        r.render(Event.AppendText(Instant.DISTANT_PAST, "Частично"))
-        r.render(Event.Interrupted(Instant.DISTANT_PAST))
-        val text = t.text()
-        assertTrue(text.contains("Частично"))
-        assertTrue(text.contains("· [interrupted]"))
-    }
-
-    @Test
-    fun `error before response`() = runTest {
-        val t = FakeTerminal()
-        val r = EventRenderer(t)
-        r.render(Event.Error(Instant.DISTANT_PAST, message = "что-то сломалось", code = "500"))
-        val text = t.text()
-        assertTrue(text.contains("· [error/500] что-то сломалось"))
-    }
-
-    @Test
-    fun `start_reasoning is printed as system line`() = runTest {
-        val t = FakeTerminal()
-        val r = EventRenderer(t)
-        r.render(Event.StartReasoning(Instant.DISTANT_PAST))
-        assertTrue(t.text().contains("· …thinking…"))
-    }
-
-    @Test
-    fun `image append renders placeholder`() = runTest {
-        val t = FakeTerminal()
-        val r = EventRenderer(t)
-        r.render(Event.StartResponse(Instant.DISTANT_PAST, Event.ResponseType.IMAGE))
-        r.render(Event.AppendImage(Instant.DISTANT_PAST, body = ByteArray(64), mime = "image/png"))
-        r.render(Event.End(Instant.DISTANT_PAST))
-        assertTrue(t.text().contains("[image:image/png:64 bytes]"))
-    }
-}

agentik-cli/src/commonTest/kotlin/pw/binom/agentik/cli/SlashCommandTest.kt

@@ -1,101 +0,0 @@
-package pw.binom.agentik.cli
-
-import kotlin.test.Test
-import kotlin.test.assertEquals
-import kotlin.test.assertIs
-import kotlin.test.assertTrue
-
-class SlashCommandTest {
-
-    @Test
-    fun `help is parsed`() {
-        assertIs<SlashCommand.Help>(parseSlashOrNull("help"))
-        assertIs<SlashCommand.Help>(parseSlashOrNull("?"))
-        assertIs<SlashCommand.Help>(parseSlashOrNull("HELP"))
-    }
-
-    @Test
-    fun `exit and quit alias`() {
-        assertIs<SlashCommand.Exit>(parseSlashOrNull("exit"))
-        assertIs<SlashCommand.Quit>(parseSlashOrNull("q"))
-        assertIs<SlashCommand.Quit>(parseSlashOrNull("Quit"))
-    }
-
-    @Test
-    fun `new without title`() {
-        assertIs<SlashCommand.New>(parseSlashOrNull("new")).let {
-            assertEquals(null, it.title)
-        }
-    }
-
-    @Test
-    fun `new with multi-word title`() {
-        val cmd = parseSlashOrNull("new  my cool chat")
-        assertIs<SlashCommand.New>(cmd)
-        assertEquals("my cool chat", cmd.title)
-    }
-
-    @Test
-    fun `switch requires id`() {
-        val r = parseSlash("sw")
-        assertIs<ParseResult.Failure>(r)
-    }
-
-    @Test
-    fun `switch with id`() {
-        val cmd = parseSlashOrNull("switch abc123")
-        assertIs<SlashCommand.Switch>(cmd)
-        assertEquals("abc123", cmd.id)
-    }
-
-    @Test
-    fun `rename requires title`() {
-        val r = parseSlash("rename")
-        assertIs<ParseResult.Failure>(r)
-        // А "rename " (с пробелом, но без слов после) — это уже успех с пустым title?
-        // У нас: rest = "" → takeIf { it.isNotEmpty() } → null → Failure. ОК.
-    }
-
-    @Test
-    fun `rename with title`() {
-        val cmd = parseSlashOrNull("rename  my new title ")
-        assertIs<SlashCommand.Rename>(cmd)
-        assertEquals("my new title", cmd.title)  // trim() делает своё
-    }
-
-    @Test
-    fun `delete may have id or not`() {
-        assertIs<SlashCommand.Delete>(parseSlashOrNull("rm")).let {
-            assertEquals(null, it.id)
-        }
-        assertIs<SlashCommand.Delete>(parseSlashOrNull("delete abc")).let {
-            assertEquals("abc", it.id)
-        }
-    }
-
-    @Test
-    fun `unknown command fails`() {
-        val r = parseSlash("foobar")
-        assertIs<ParseResult.Failure>(r)
-    }
-
-    @Test
-    fun `empty command fails`() {
-        val r = parseSlash("")
-        assertIs<ParseResult.Failure>(r)
-    }
-
-    @Test
-    fun `command is case insensitive`() {
-        assertIs<SlashCommand.List>(parseSlashOrNull("LIST"))
-        assertIs<SlashCommand.Interrupt>(parseSlashOrNull("STOP"))
-        assertIs<SlashCommand.Pwd>(parseSlashOrNull("PWD"))
-    }
-
-    @Test
-    fun `interrupt synonyms`() {
-        assertIs<SlashCommand.Interrupt>(parseSlashOrNull("interrupt"))
-        assertIs<SlashCommand.Interrupt>(parseSlashOrNull("stop"))
-        assertIs<SlashCommand.Interrupt>(parseSlashOrNull("cancel"))
-    }
-}

agentik-cli/src/jvmMain/kotlin/pw/binom/agentik/cli/Platform.jvm.kt

@@ -1,151 +0,0 @@
-package pw.binom.agentik.cli
-
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.withContext
-import org.jline.reader.EndOfFileException
-import org.jline.reader.LineReader
-import org.jline.reader.LineReaderBuilder
-import org.jline.reader.UserInterruptException
-import org.jline.terminal.TerminalBuilder
-import pw.binom.agentik.client.AgentikAgent
-import pw.binom.agentik.proto.Agent
-import java.io.File
-import java.nio.file.Files
-import java.nio.file.StandardCopyOption
-
-actual object CliPlatform {
-    actual fun openAgent(baseUrl: String, id: String): Agent =
-        AgentikAgent(id = id, baseUrl = baseUrl)
-
-    actual fun openTerminal(historyFile: String?, prompt: String): CliTerminal =
-        JLineTerminal(historyFile = historyFile, prompt = prompt)
-
-    actual fun homeDir(): String? =
-        System.getenv("HOME") ?: System.getenv("USERPROFILE")
-
-    actual fun env(key: String): String? = System.getenv(key)
-
-    actual fun sessionIo(): SessionIo = JvmSessionIo
-}
-
-/**
- * Реализация [SessionIo] поверх `java.io.File` + atomic `tmp → rename`.
- * tmp-файл пишется в той же директории, что и целевой, чтобы rename
- * был атомарным в рамках одного раздела (POSIX rename(2) и Windows
- * MoveFileEx — атомарны внутри одного тома).
- */
-private object JvmSessionIo : SessionIo {
-    override fun readAll(path: String): String? {
-        val f = File(path)
-        if (!f.exists()) return null
-        return runCatching { f.readText() }.getOrNull()
-    }
-
-    override fun writeAtomic(path: String, body: String) {
-        val target = File(path)
-        target.parentFile?.mkdirs()
-        val tmp = File(path + ".tmp")
-        tmp.writeText(body)
-        if (!tmp.renameTo(target)) {
-            // fallback: Windows-специфика — renameTo может не перезаписать существующий.
-            runCatching { Files.move(tmp.toPath(), target.toPath(), StandardCopyOption.REPLACE_EXISTING, StandardCopyOption.ATOMIC_MOVE) }
-                .getOrElse { target.writeText(tmp.readText()); tmp.delete() }
-        }
-    }    override fun delete(path: String) {
-        runCatching { File(path).delete() }
-    }
-}
-
-/**
- * Реализация [CliTerminal] поверх JLine ([LineReader]).
- *
- * JLine-3 API:
- *   - [TerminalBuilder.builder().system(true).build()] — открыть системный TTY.
- *   - [LineReader] поверх Terminal — readline-редактор (стрелки, history, Ctrl-A/E).
- *   - [LineReader.readLine(prompt)] — suspend-free, блокирующий IO; мы оборачиваем
- *     в [withContext] [Dispatchers.IO], чтобы не держать event-loop.
- *   - [DefaultHistory] (org.jline.reader.history.DefaultHistory) + история из файла.
- */
-private class JLineTerminal(
-    historyFile: String?,
-    override val prompt: String,
-) : CliTerminal {
-
-    private val terminal = TerminalBuilder.builder()
-        .system(true)
-        .jna(true)
-        .build()
-
-    private val historyImpl: org.jline.reader.History? = run {
-        if (historyFile == null) null else try {
-            val history = org.jline.reader.impl.history.DefaultHistory()
-            val histFile = File(historyFile)
-            histFile.parentFile?.mkdirs()
-            history.load()
-            if (histFile.exists()) {
-                history.append(histFile.toPath(), true)
-            }
-            history
-        } catch (t: Throwable) {
-            null
-        }
-    }
-
-    private val reader: LineReader = LineReaderBuilder.builder()
-        .terminal(terminal)
-        .apply { if (historyImpl != null) history(historyImpl) }
-        .build()
-
-    private val historyFilePath: java.nio.file.Path? =
-        historyFile?.let { File(it).toPath() }
-
-    override suspend fun readLine(): String? = withContext(Dispatchers.IO) {
-        try {
-            val line = reader.readLine(prompt)
-            // Сохраняем history при каждой строке — дешево, и при Ctrl-D / Ctrl-C
-            // ничего не теряется.
-            flushHistory()
-            line
-        } catch (_: UserInterruptException) {
-            // Ctrl-C: трактуем как «всё, выходим», как и EOF.
-            flushHistory()
-            null
-        } catch (_: EndOfFileException) {
-            // Ctrl-D на пустой строке.
-            flushHistory()
-            null
-        }
-    }
-
-    override suspend fun println(text: String): Unit = withContext(Dispatchers.IO) {
-        terminal.writer().println(text)
-        terminal.writer().flush()
-    }
-
-    override suspend fun print(text: String): Unit = withContext(Dispatchers.IO) {
-        terminal.writer().print(text)
-        terminal.writer().flush()
-    }
-
-    override suspend fun printSystem(text: String): Unit = withContext(Dispatchers.IO) {
-        terminal.writer().println("· $text")
-        terminal.writer().flush()
-    }
-
-    private fun flushHistory() {
-        val hf = historyFilePath ?: return
-        val h = historyImpl ?: return
-        runCatching {
-            h.save()
-            if (!h.isEmpty) {
-                // читаем из .tmp и дописываем
-                h.append(hf, true)
-            }
-        }
-    }
-
-    override fun close() {
-        runCatching { flushHistory() }
-        runCatching { terminal.close() }
-    }
-}

agentik-cli/src/jvmMain/kotlin/pw/binom/agentik/cli/PlatformEnv.kt

@@ -0,0 +1,3 @@
+package pw.binom.agentik.cli
+
+internal actual fun platformEnv(key: String): String? = System.getenv(key)

agentik-cli/src/jvmTest/kotlin/pw/binom/agentik/cli/SessionRepositoryTest.kt

@@ -1,108 +0,0 @@
-package pw.binom.agentik.cli
-
-import org.junit.After
-import org.junit.Before
-import java.io.File
-import kotlin.test.Test
-import kotlin.test.assertEquals
-import kotlin.test.assertNotNull
-import kotlin.test.assertNull
-import kotlin.test.assertTrue
-import kotlin.time.Instant
-
-/**
- * Интеграционный тест на реальном временном файле. Только JVM: использует
- * [java.io.File] для IO-интерфейса. На native-таргетах тест не собирается —
- * TODO: переписать на kotlinx-io Files и перенести в commonTest.
- */
-class SessionRepositoryTest {
-
-    private lateinit var tmp: File
-
-    @Before
-    fun setUp() {
-        tmp = File.createTempFile("agentik-cli-state", ".json")
-        tmp.delete()
-    }
-
-    @After
-    fun tearDown() {
-        if (tmp.exists()) tmp.delete()
-        File(tmp.path + ".tmp").delete()
-    }
-
-    @Test
-    fun `load returns null when file missing`() {
-        val repo = SessionRepository(tmp.path, JvmIo)
-        assertNull(repo.load())
-    }
-
-    @Test
-    fun `save then load roundtrip`() {
-        val repo = SessionRepository(tmp.path, JvmIo)
-        val savedAt = Instant.parse("2026-09-16T10:00:00Z")
-        repo.save(conversationId = "abcd-1234", lastEventAt = savedAt)
-        repo.close()
-
-        val repo2 = SessionRepository(tmp.path, JvmIo)
-        val restored = repo2.load()
-        assertNotNull(restored)
-        assertEquals("abcd-1234", restored.conversationId)
-        assertEquals(savedAt, restored.lastEventAt)
-    }
-
-    @Test
-    fun `save overwrites previous state`() {
-        val repo = SessionRepository(tmp.path, JvmIo)
-        repo.save("conv-1", Instant.parse("2026-09-16T10:00:00Z"))
-        repo.save("conv-2", Instant.parse("2026-09-16T11:00:00Z"))
-        repo.close()
-
-        val restored = SessionRepository(tmp.path, JvmIo).load()
-        assertNotNull(restored)
-        assertEquals("conv-2", restored.conversationId)
-    }
-
-    @Test
-    fun `null filepath means no-op`() {
-        val repo = SessionRepository(null, JvmIo)
-        repo.save("conv-X", Instant.parse("2026-09-16T10:00:00Z"))
-        // Не должно ни читать, ни писать.
-        assertNull(repo.load())
-    }
-
-    @Test
-    fun `clear deletes file`() {
-        val repo = SessionRepository(tmp.path, JvmIo)
-        repo.save("conv-Z", Instant.parse("2026-09-16T10:00:00Z"))
-        repo.close()
-        assertTrue(tmp.exists())
-
-        val repo2 = SessionRepository(tmp.path, JvmIo)
-        repo2.clear()
-        assertTrue(!tmp.exists())
-    }
-
-    @Test
-    fun `corrupt json is ignored (does not throw)`() {
-        File(tmp.path).writeText("this is not json")
-        val repo = SessionRepository(tmp.path, JvmIo)
-        assertNull(repo.load())
-    }
-}
-
-// JVM-only helper: реализация [SessionIo] поверх `java.io.File` для теста.
-// В продакшен-коде на jvmMain ровно такая же логика.
-private object JvmIo : SessionIo {
-    override fun readAll(path: String): String? {
-        val f = File(path); if (!f.exists()) return null
-        return runCatching { f.readText() }.getOrNull()
-    }
-    override fun writeAtomic(path: String, body: String) {
-        val target = File(path); target.parentFile?.mkdirs()
-        val tmp = File(path + ".tmp")
-        tmp.writeText(body)
-        if (!tmp.renameTo(target)) target.writeText(tmp.readText()).also { tmp.delete() }
-    }
-    override fun delete(path: String) { File(path).delete() }
-}

agentik-cli/src/nativeMain/kotlin/pw/binom/agentik/cli/Platform.native.kt

@@ -1,36 +0,0 @@
-package pw.binom.agentik.cli
-
-import pw.binom.agentik.proto.Agent
-
-/**
- * Платформо-зависимая реализация для native-целей.
- *
- * Текущий статус: stub. native HTTP требует подключения ktor-client-core +
- * платформенных engine'ов (ktor-client-darwin для Apple, ktor-client-curl для
- * linux/mingw, ktor-client-okhttp для Android в перспективе) и переиспользования
- * уже существующего `:client` SSE-парсера. Native readline требует termios
- * через `kotlinx.cinterop` — добавим, когда дойдут руки.
- *
- * Пока запустить агента из native-бинаря CLI нельзя, но проект компилируется
- * под все 8 KMP-целей — структурная готовность соблюдена.
- */
-actual object CliPlatform {
-    actual fun openAgent(baseUrl: String, id: String): Agent =
-        error("agentik-cli native target is not implemented yet (baseUrl=$baseUrl)")
-
-    actual fun openTerminal(historyFile: String?, prompt: String): CliTerminal =
-        error("agentik-cli native target is not implemented yet (prompt=$prompt)")
-
-    actual fun homeDir(): String? = null
-
-    actual fun env(key: String): String? = null
-
-    actual fun sessionIo(): SessionIo = NoopSessionIo
-}
-
-/** Минимальный no-op-IO для native-целей пока не подключён реальный движок. */
-private object NoopSessionIo : SessionIo {
-    override fun readAll(path: String): String? = null
-    override fun writeAtomic(path: String, body: String) {}
-    override fun delete(path: String) {}
-}

agentik-cli/src/nativeMain/kotlin/pw/binom/agentik/cli/PlatformEnv.kt

@@ -0,0 +1,8 @@
+package pw.binom.agentik.cli
+
+import kotlinx.cinterop.ExperimentalForeignApi
+import kotlinx.cinterop.toKString
+import platform.posix.getenv
+
+@OptIn(ExperimentalForeignApi::class)
+internal actual fun platformEnv(key: String): String? = getenv(key)?.toKString()

agentik-tui/build.gradle.kts

@@ -24,6 +24,23 @@ kotlin {
     linuxArm64()
     mingwX64()
 
+    // Native executables. По умолчанию Kotlin/Native для каждого target'а
+    // собирает только .klib (библиотеку) — для запускаемого .kexe надо
+    // явно попросить binaries.executable(). entryPoint нужно задать явно:
+    // KMP-линкер ищет функцию по FQN (без `Kt`-суффикса), а Kotlin/Native
+    // добавляет суффикс только для файлов с именем `Main.kt`, поэтому
+    // указываем точку входа как `pw.binom.agentik.tui.main` (без суффикса).
+    //
+    // Применяем к каждому из linuxX64/macosX64/macosArm64/linuxArm64/mingwX64
+    // явно (а не через targets.withType), потому что targets DSL в KMP не
+    // поддерживает реифицированный withType<KotlinNativeTarget>().
+    @OptIn(ExperimentalKotlinGradlePluginApi::class)
+    listOf(linuxX64(), linuxArm64(), macosX64(), macosArm64(), mingwX64()).forEach {
+        it.binaries.executable {
+            entryPoint = "pw.binom.agentik.tui.main"
+        }
+    }
+
     sourceSets {
         commonMain.dependencies {
             implementation(project(":proto"))
@@ -34,6 +51,11 @@ kotlin {
             // JetBrains Compose runtime — тащит Mosaic как обёртку.
             implementation(libs.mosaic.runtime)
             implementation(libs.mosaic.tty.terminal)
+
+            // Health-check в Main.kt: Ktor CIO на JVM, на native не собирается —
+            // там работает stub actual через expect/actual.
+            implementation(libs.ktor.client.core)
+            implementation(libs.ktor.client.cio)
         }
         jvmMain.dependencies {
             implementation(project(":client"))
@@ -41,6 +63,7 @@ kotlin {
         commonTest.dependencies {
             implementation(kotlin("test"))
             implementation(libs.kotlinx.coroutines.core)
+            implementation(libs.kotlinx.coroutines.test)
         }
     }
 

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/App.kt

@@ -3,18 +3,19 @@ package pw.binom.agentik.tui
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.collectAsState
 import androidx.compose.runtime.getValue
-import com.jakewharton.mosaic.layout.KeyEvent
-import com.jakewharton.mosaic.layout.drawBehind
 import com.jakewharton.mosaic.layout.onPreviewKeyEvent
 import com.jakewharton.mosaic.modifier.Modifier
-import com.jakewharton.mosaic.ui.Box
 import com.jakewharton.mosaic.ui.Column
 import com.jakewharton.mosaic.ui.Row
-import com.jakewharton.mosaic.ui.Text
-import com.jakewharton.mosaic.ui.TextStyle
+import pw.binom.agentik.tui.ui.Footer
+import pw.binom.agentik.tui.ui.Header
+import pw.binom.agentik.tui.ui.HelpOverlay
+import pw.binom.agentik.tui.ui.HistoryPanel
+import pw.binom.agentik.tui.ui.InputLine
 
 /**
- * Корневая Compose-композиция TUI.
+ * Корневая Compose-композиция TUI. Содержит только каркас + глобальный key-handler;
+ * каждый регион (header/history/input/footer/help) — отдельный компонент в `ui/`.
  *
  * Layout (минимальный):
  * ```
@@ -28,6 +29,9 @@ import com.jakewharton.mosaic.ui.TextStyle
  * │ FOOTER: ↑↓ scroll  Tab focus  Enter send  F1 help …     │
  * └─────────────────────────────────────────────────────────┘
  * ```
+ *
+ * Глобальные клавиши (Tab/Shift-Tab/F1/Esc) обрабатываются здесь.
+ * Клавиши внутри строки ввода — в [InputLine] (через свой `onPreviewKeyEvent`).
  */
 @Composable
 internal fun App(state: AppState) {
@@ -50,105 +54,8 @@ internal fun App(state: AppState) {
             Header(state, focusIndex)
             HistoryPanel(state)
             InputLine(state)
-            Footer(state, showHelp)
+            Footer(showHelp)
         }
     }
     if (showHelp) HelpOverlay()
 }
-
-@Composable
-private fun Header(state: AppState, focusIndex: Int) {
-    val title by state.currentTitle.collectAsState()
-    val convId by state.currentConversationId.collectAsState()
-    val focusLabel = when (focusIndex) { 0 -> "input"; 1 -> "history"; 2 -> "sidebar"; else -> "?" }
-    val convStr = convId?.let { " · ${it.take(8)}…" } ?: ""
-    val titleStr = title ?: "(нет диалога)"
-    Text(
-        value = " agentik · ${state.config.id}$convStr · $titleStr · focus=$focusLabel ",
-        textStyle = TextStyle.Bold + TextStyle.Invert,
-    )
-}
-
-@Composable
-private fun HistoryPanel(state: AppState) {
-    val messages by state.messages.collectAsState()
-    val scroll by state.historyScroll.collectAsState()
-    val rendered = if (messages.isEmpty()) {
-        "  (пока пусто)\n  Tab — переключить фокус, F1 — подсказки.\n"
-    } else {
-        messages.joinToString("") { renderMessage(it) }
-    }
-    Text(value = rendered)
-}
-
-private fun renderMessage(m: TuiMessage): String = when (m) {
-    is TuiMessage.System -> "  ── ${m.text}\n"
-    is TuiMessage.User -> "  > ${m.text}\n"
-    is TuiMessage.Assistant -> "  ╰ ${m.text}\n"
-    is TuiMessage.AssistantStreaming -> "  ╰ ${m.text} ▍\n"
-    is TuiMessage.ToolCall -> "  ⚙ ${m.toolName}${if (!m.title.isNullOrEmpty()) ": ${m.title}" else ""}\n"
-    is TuiMessage.ToolResult -> "    ↳ ${m.result.take(200)}${if (m.result.length > 200) "…" else ""}\n"
-}
-
-@Composable
-private fun InputLine(state: AppState) {
-    val text by state.input.collectAsState()
-    val cursor by state.cursor.collectAsState()
-    val streaming by state.streaming.collectAsState()
-    val cursorPos = cursor.coerceIn(0, text.length)
-    val before = text.substring(0, cursorPos)
-    val cursorChar = if (cursorPos < text.length) text[cursorPos].toString() else " "
-    val afterStart = if (cursorPos < text.length) cursorPos + 1 else cursorPos
-    val after = text.substring(afterStart.coerceAtMost(text.length))
-    val prompt = if (streaming) " ⋯" else " >"
-
-    Text(
-        value = "$prompt $before|$cursorChar|${after}",
-        modifier = Modifier
-            .onPreviewKeyEvent { ev -> handleInputKey(state, ev) }
-            .drawBehind {
-                // Snapshot-read state в drawBehind чтобы changes триггерили redraw.
-                state.input.let { /* touch */ }
-            },
-    )
-}
-
-private fun handleInputKey(state: AppState, ev: KeyEvent): Boolean {
-    if (ev.alt || ev.ctrl) return false
-    return when (ev.key) {
-        "Enter" -> state.submitInput() != null
-        "Backspace" -> { state.inputBackspace(); true }
-        "Delete" -> { state.inputDelete(); true }
-        "Left", "ArrowLeft" -> { state.inputMoveCursor(-1); true }
-        "Right", "ArrowRight" -> { state.inputMoveCursor(+1); true }
-        "Home" -> { state.inputCursorHome(); true }
-        "End" -> { state.inputCursorEnd(); true }
-        else -> {
-            val s = ev.key
-            if (s.length == 1) { state.inputInsert(s); true }
-            else false
-        }
-    }
-}
-
-@Composable
-private fun Footer(state: AppState, showHelp: Boolean) {
-    val hint = if (showHelp) " ↑ наверху help-оверлей ↑ "
-    else " Tab focus  ↑↓ scroll  Enter send  Esc clear  F1 help  Ctrl-D exit "
-    Text(value = hint, textStyle = TextStyle.Italic)
-}
-
-@Composable
-private fun HelpOverlay() {
-    Column(modifier = Modifier) {
-        Text(value = " --- HELP ---", textStyle = TextStyle.Bold + TextStyle.Invert)
-        Text(value = " Tab / Shift-Tab   переключить фокус (history / input / sidebar)")
-        Text(value = " ↑ / ↓             скролл истории / курсор в input")
-        Text(value = " ← / →             курсор в input")
-        Text(value = " Enter             отправить сообщение")
-        Text(value = " Backspace / Del   удалить символ")
-        Text(value = " Esc               очистить input")
-        Text(value = " Ctrl-D / Ctrl-C   выход")
-        Text(value = " F1                toggle help", textStyle = TextStyle.Italic)
-    }
-}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/AppState.kt

@@ -15,6 +15,10 @@ import kotlin.time.Instant
  * (см. samples/snake в репо Mosaic).
  */
 internal class AppState(val config: TuiConfig) {
+    /** Бэкенд, прикреплённый из TuiApp — маршрутизирует submitInput → send. */
+    private var backend: TuiBackend? = null
+    fun attachBackend(b: TuiBackend) { backend = b }
+
     /** Зона фокуса: 0 = input, 1 = history, 2 = sidebar. */
     private val _focusIndex = MutableStateFlow(0)
     val focusIndex: StateFlow<Int> = _focusIndex.asStateFlow()
@@ -101,9 +105,28 @@ internal class AppState(val config: TuiConfig) {
         _messages.value = _messages.value + TuiMessage.User(text = text, ts = nowInstant())
         inputClear()
         _streaming.value = true
+        backend?.onUserMessage(text)
         return text
     }
 
+    fun setStreaming(v: Boolean) { _streaming.value = v }
+
+    fun setConversation(id: String, title: String?) {
+        _currentConversationId.value = id
+        _currentTitle.value = title
+        _messages.value = emptyList()
+        _historyScroll.value = 0
+        _streaming.value = false
+    }
+
+    fun postToolCall(toolName: String, title: String?, args: String) {
+        _messages.value = _messages.value + TuiMessage.ToolCall(toolName = toolName, title = title, args = args, ts = nowInstant())
+    }
+
+    fun postToolResult(toolName: String, result: String) {
+        _messages.value = _messages.value + TuiMessage.ToolResult(toolName = toolName, result = result, ts = nowInstant())
+    }
+
     fun appendAssistant(chunk: String) {
         val list = _messages.value.toMutableList()
         val last = list.lastOrNull()

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/Main.kt

@@ -1,6 +1,12 @@
 package pw.binom.agentik.tui
 
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.plugins.HttpTimeout
+import io.ktor.client.request.get
+import io.ktor.client.statement.bodyAsText
 import kotlinx.coroutines.runBlocking
+import pw.binom.agentik.proto.Agent
 
 /**
  * Точка входа TUI-клиента agentik.
@@ -9,14 +15,62 @@ import kotlinx.coroutines.runBlocking
  * agentik-tui [--server URL] [--id ID] [--no-history] [--help]
  * ```
  *
- * Без аргументов — стартует Compose-Mosaic UI.
+ * Перед запуском UI — обязательный health-check: `GET {server}/health`.
+ * Если сервер недоступен — печатаем понятную ошибку и выходим с кодом 1.
+ * Если OK — создаём [Agent] через платформенную actual и запускаем
+ * [TuiApp].
  */
 fun main(args: Array<String>) = runBlocking {
     val cfg = parseCliArgs(args) ?: run {
         printUsage()
         return@runBlocking
     }
-    TuiApp(cfg).run()
+    checkServer(cfg.server)
+    val agent = platformCreateAgent(cfg.server, cfg.id)
+    TuiApp(cfg, agent).run()
+}
+
+/**
+ * Делает синхронный GET `{baseUrl}/health`. Внутри [route(path)] на сервере
+ * `/health` зарегистрирован под тем же path-prefix'ом, что и сам API
+ * (например, baseUrl = `http://localhost:8080/agentik` → health = …/agentik/health).
+ *
+ * При любой ошибке (connect refused, timeout, не-200 ответ, не `"ok"`) —
+ * бросает [IllegalStateException] с понятным сообщением. [runBlocking]-обёртка
+ * в [main] разворачивает её в stack-trace и `exit 1`.
+ */
+private suspend fun checkServer(baseUrl: String) {
+    val healthUrl = "${baseUrl.trimEnd('/')}/health"
+    val client = HttpClient(CIO) {
+        install(HttpTimeout) {
+            requestTimeoutMillis = 5_000
+            connectTimeoutMillis = 3_000
+        }
+        expectSuccess = false
+    }
+    try {
+        val response = client.get(healthUrl)
+        if (response.status.value !in 200..299) {
+            throw IllegalStateException("сервер ответил HTTP ${response.status.value} на GET $healthUrl")
+        }
+        val body = response.bodyAsText().trim()
+        if (body != "ok") {
+            throw IllegalStateException("сервер ответил неожиданным телом на GET $healthUrl: '$body'")
+        }
+    } catch (e: IllegalStateException) {
+        throw e
+    } catch (e: Exception) {
+        // На JVM сюда упадут java.net.ConnectException, UnknownHostException,
+        // io.ktor.client.network.sockets.ConnectTimeoutException и т.п.
+        // На нативе native stub падает раньше в platformCreateAgent, так что
+        // сюда мы попадём только под JVM-actual.
+        throw IllegalStateException(
+            "ошибка health-check $healthUrl: ${e::class.simpleName} — ${e.message ?: "(нет сообщения)"}",
+            e,
+        )
+    } finally {
+        client.close()
+    }
 }
 
 /**
@@ -70,6 +124,12 @@ private fun parseCliArgs(args: Array<String>): TuiConfig? {
  */
 internal expect fun platformEnv(key: String): String?
 
+/**
+ * Создаёт платформенную реализацию [Agent]. JVM actual подключает `:client`
+ * и ходит в HTTP-фасад; native actual пока возвращает stub (см. Platform.native.kt).
+ */
+internal expect fun platformCreateAgent(baseUrl: String, id: String): Agent
+
 private fun printUsage() {
     val defaultServer = platformEnv("AGENTIK_SERVER") ?: "http://localhost:8080/agentik"
     val defaultUser = platformEnv("USER") ?: platformEnv("USERNAME") ?: "anon"
@@ -86,11 +146,15 @@ private fun printUsage() {
           --no-history       не сохранять состояние
           --help, -h         эта справка
 
+        Переменные среды:
+          AGENTIK_SERVER     базовый URL (эквивалент --server)
+          USER / USERNAME    используется в id клиента по умолчанию
+
         В UI:
           Tab / Shift-Tab     переключить фокус между историей и вводом
           ↑ / ↓               скроллить историю / двигать курсор в инпуте
           ← / →               двинуть курсор в инпуте
-          Enter               отправить сообщение
+          Enter               отправить сообщение (создаст новый диалог, если их нет)
           Ctrl-C / Ctrl-D     выйти
           F1                  показать подсказки по горячим клавишам
     """.trimIndent())

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/TuiApp.kt

@@ -1,27 +1,31 @@
 package pw.binom.agentik.tui
 
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.LaunchedEffect
 import androidx.compose.runtime.remember
 import com.jakewharton.mosaic.runMosaicBlocking
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Job
-import kotlinx.coroutines.SupervisorJob
-import kotlinx.coroutines.cancel
+import kotlinx.coroutines.launch
 import pw.binom.agentik.proto.Agent
-import kotlin.coroutines.CoroutineContext
 
 /**
- * Корневая точка запуска UI. Стартует Mosaic-рантайм и ждёт завершения приложения.
+ * Корневая точка запуска UI. Стартует Mosaic-рантайм, монтирует [TuiBackend] в
+ * его coroutine-scope и ждёт завершения приложения.
  *
- * По дизайну — singleton: все остальные модули (UI, бэкенд-корутины) живут внутри
- * одной Compose-композиции и пользуются её [CoroutineScope].
- *
- * Реальный бэкенд (TuiBackend) подключается в следующем коммите: сейчас
- * стартует на пустом [Agent]-заглушке для smoke-теста.
+ * Бэкенд — единый singleton на процесс: UI-композиция, сетевые подписки и
+ * coroutine job'ы делят scope [runMosaicBlocking] (через [LaunchedEffect]).
  */
-internal class TuiApp(private val config: TuiConfig) {
+internal class TuiApp(
+    private val config: TuiConfig,
+    private val agent: Agent,
+) {
     fun run() {
         runMosaicBlocking {
             val state = remember { AppState(config) }
+            val backend = remember { TuiBackend(state = state, agent = agent) }
+            LaunchedEffect(backend) {
+                backend.start(this)
+            }
+            state.attachBackend(backend)
             App(state = state)
         }
     }

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/TuiBackend.kt

@@ -0,0 +1,142 @@
+package pw.binom.agentik.tui
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.launch
+import pw.binom.agentik.proto.Agent
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Conversation
+import pw.binom.agentik.outbox.Event
+import kotlin.coroutines.CoroutineContext
+import kotlin.time.Instant
+
+/**
+ * Backend-логика TUI: мост между [Agent] и [AppState].
+ *
+ * Жизненный цикл:
+ *  1. На старте [start] — health-check сделан в [Main] ДО Mosaic; здесь только
+ *     пост-сообщение "connected to …".
+ *  2. Подписка на [Agent.events] — обновление списка диалогов в sidebar.
+ *  3. При [onUserMessage] — если текущего диалога нет, создаём
+ *     [createConversation] (temp=false, чтобы он персистился на сервере), затем
+ *     [send]. Подписка на [Conversation.events] идёт сразу при создании/открытии.
+ *
+ * Дизайн: один backend-объект на процесс, живёт в [runMosaicBlocking]-scope.
+ */
+internal class TuiBackend(
+    private val state: AppState,
+    private val agent: Agent,
+) {
+    /** Текущий открытый диалог, либо `null`, если ещё не выбран. */
+    private var current: Conversation? = null
+
+    /** Активная джоба подписки на [Conversation.events]. */
+    private var eventsJob: Job? = null
+
+    /** Последний виденный момент событий — для переподписки при reconnect. */
+    private var lastSeenAt: Instant = Instant.DISTANT_PAST
+
+    /**
+     * Запускает фоновые подписки в scope [scope] (передаётся из Mosaic
+     * LaunchedEffect'а — это scope recomposer'а, живёт до закрытия UI).
+     */
+    fun start(scope: CoroutineScope) {
+        this.scope = scope
+        state.postSystem("подключено к ${state.config.server}")
+        scope.launch {
+            try {
+                // agent.outbox.agentEvents(after) возвращает Flow<CommonEvent.Agent>;
+                // распаковываем .event для получения AgentEvent (раньше был
+                // отдельный метод agent.events(), теперь упразднён — события
+                // живут в outbox-сущности).
+                agent.outbox.agentEvents(Instant.DISTANT_PAST).collect { /* sidebar refresh */ }
+            } catch (_: kotlinx.coroutines.CancellationException) {
+                // штатная отмена при закрытии UI
+            } catch (e: Exception) {
+                state.postSystem("ошибка live-events: ${e.message ?: e::class.simpleName}")
+            }
+        }
+    }
+
+    private lateinit var scope: CoroutineScope
+
+    /**
+     * Обработка пользовательского сообщения, отправленного из input.
+     *
+     * Если текущего диалога нет — создаём его; затем `send`. Подписка на
+     * события конкретного диалога стартует в [ensureConversation].
+     */
+    fun onUserMessage(text: String) {
+        scope.launch {
+            try {
+                val conv = ensureConversation()
+                conv.send(listOf(Content.Text(text)))
+            } catch (e: Exception) {
+                state.postSystem("ошибка отправки: ${e.message ?: e::class.simpleName}")
+                state.setStreaming(false)
+            }
+        }
+    }
+
+    /**
+     * Создаёт [Conversation], если ещё не было; открывает подписку на её события.
+     */
+    private suspend fun ensureConversation(): Conversation {
+        current?.let { return it }
+        val conv = agent.createConversation(temp = false)
+        state.setConversation(id = conv.id, title = conv.title)
+        subscribeEvents(conv, Instant.DISTANT_PAST)
+        current = conv
+        return conv
+    }
+
+    /**
+     * Подписывается на `outbox.conversationEvents(after, conv.id)` и перенаправляет их в [state].
+     */
+    private fun subscribeEvents(conv: Conversation, from: Instant) {
+        eventsJob?.cancel()
+        eventsJob = scope.launch {
+            agent.outbox.conversationEvents(from, conv.id).collect { ce -> dispatch(ce.event) }
+        }
+    }
+
+    /**
+     * Маппинг [Event] → [AppState] (что показать в TUI).
+     *
+     * - AppendText → дописывает в последний ассистентский чанк
+     * - StartReasoning / StartResponse → новый streaming-чанк
+     * - End → закрывает streaming
+     * - Interrupted → закрывает streaming + системное сообщение
+     * - ToolCall / ToolResult → сообщения в историю
+     * - Error → системное сообщение
+     */
+    private fun dispatch(ev: Event) {
+        lastSeenAt = ev.date
+        when (ev) {
+            is Event.AppendText -> state.appendAssistant(ev.body)
+            is Event.StartReasoning -> {
+                state.postSystem("… думаю")
+            }
+            is Event.StartResponse -> state.setStreaming(true)
+            is Event.End -> state.finishAssistant()
+            is Event.Interrupted -> {
+                state.finishAssistant()
+                state.postSystem("прервано")
+            }
+            is Event.AppendImage -> {
+                state.postSystem("[картинка: ${ev.mime}, ${ev.body.size} байт]")
+            }
+            is Event.ToolCall -> {
+                state.postToolCall(toolName = ev.toolName, title = null, args = ev.toolArgs)
+            }
+            is Event.ToolResult -> {
+                state.postToolResult(toolName = "", result = ev.result ?: "")
+            }
+            is Event.Error -> {
+                state.setStreaming(false)
+                state.postSystem("ошибка: ${ev.message}")
+            }
+        }
+    }
+}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/ui/Footer.kt

@@ -0,0 +1,17 @@
+package pw.binom.agentik.tui.ui
+
+import androidx.compose.runtime.Composable
+import com.jakewharton.mosaic.ui.Text
+import com.jakewharton.mosaic.ui.TextStyle
+
+/**
+ * Нижняя подсказка с текущим набором горячих клавиш.
+ *
+ * При открытом help-оверлее показывает заглушку с указателем «наверху».
+ */
+@Composable
+internal fun Footer(showHelp: Boolean) {
+    val hint = if (showHelp) " ↑ наверху help-оверлей ↑ "
+    else " Tab focus  ↑↓ scroll  Enter send  Esc clear  F1 help  Ctrl-D exit "
+    Text(value = hint, textStyle = TextStyle.Italic)
+}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/ui/Header.kt

@@ -0,0 +1,26 @@
+package pw.binom.agentik.tui.ui
+
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.collectAsState
+import androidx.compose.runtime.getValue
+import com.jakewharton.mosaic.ui.Text
+import com.jakewharton.mosaic.ui.TextStyle
+import pw.binom.agentik.tui.AppState
+
+/**
+ * Верхняя инвертированная полоса с идентификатором и текущим фокусом.
+ *
+ * Пример: ` agentik · cli-tui:root · a1b2c3d4… · мой чат · focus=input `
+ */
+@Composable
+internal fun Header(state: AppState, focusIndex: Int) {
+    val title by state.currentTitle.collectAsState()
+    val convId by state.currentConversationId.collectAsState()
+    val focusLabel = when (focusIndex) { 0 -> "input"; 1 -> "history"; 2 -> "sidebar"; else -> "?" }
+    val convStr = convId?.let { " · ${it.take(8)}…" } ?: ""
+    val titleStr = title ?: "(нет диалога)"
+    Text(
+        value = " agentik · ${state.config.id}$convStr · $titleStr · focus=$focusLabel ",
+        textStyle = TextStyle.Bold + TextStyle.Invert,
+    )
+}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/ui/HelpOverlay.kt

@@ -0,0 +1,26 @@
+package pw.binom.agentik.tui.ui
+
+import androidx.compose.runtime.Composable
+import com.jakewharton.mosaic.modifier.Modifier
+import com.jakewharton.mosaic.ui.Column
+import com.jakewharton.mosaic.ui.Text
+import com.jakewharton.mosaic.ui.TextStyle
+
+/**
+ * Полноэкранный оверлей со списком горячих клавиш.
+ * Включается/выключается по F1 (см. [pw.binom.agentik.tui.App]).
+ */
+@Composable
+internal fun HelpOverlay() {
+    Column(modifier = Modifier) {
+        Text(value = " --- HELP ---", textStyle = TextStyle.Bold + TextStyle.Invert)
+        Text(value = " Tab / Shift-Tab   переключить фокус (history / input / sidebar)")
+        Text(value = " ↑ / ↓             скролл истории / курсор в input")
+        Text(value = " ← / →             курсор в input")
+        Text(value = " Enter             отправить сообщение")
+        Text(value = " Backspace / Del   удалить символ")
+        Text(value = " Esc               очистить input")
+        Text(value = " Ctrl-D / Ctrl-C   выход")
+        Text(value = " F1                toggle help", textStyle = TextStyle.Italic)
+    }
+}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/ui/HistoryPanel.kt

@@ -0,0 +1,34 @@
+package pw.binom.agentik.tui.ui
+
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.collectAsState
+import androidx.compose.runtime.getValue
+import com.jakewharton.mosaic.ui.Text
+import pw.binom.agentik.tui.AppState
+import pw.binom.agentik.tui.TuiMessage
+
+/**
+ * Прокручиваемый (через клавиатуру) лог диалога.
+ * Каждое сообщение рендерится отдельной строкой с префиксом (см. [renderMessage]).
+ * При пустом списке показывается подсказка.
+ */
+@Composable
+internal fun HistoryPanel(state: AppState) {
+    val messages by state.messages.collectAsState()
+    val rendered = if (messages.isEmpty()) {
+        "  (пока пусто)\n  Tab — переключить фокус, F1 — подсказки.\n"
+    } else {
+        messages.joinToString("") { renderMessage(it) }
+    }
+    Text(value = rendered)
+}
+
+/** Превращает [TuiMessage] в одну строку с префиксом. Потоковые чанки получают курсор `▍`. */
+internal fun renderMessage(m: TuiMessage): String = when (m) {
+    is TuiMessage.System -> "  ── ${m.text}\n"
+    is TuiMessage.User -> "  > ${m.text}\n"
+    is TuiMessage.Assistant -> "  ╰ ${m.text}\n"
+    is TuiMessage.AssistantStreaming -> "  ╰ ${m.text} ▍\n"
+    is TuiMessage.ToolCall -> "  ⚙ ${m.toolName}${if (!m.title.isNullOrEmpty()) ": ${m.title}" else ""}\n"
+    is TuiMessage.ToolResult -> "    ↳ ${m.result.take(200)}${if (m.result.length > 200) "…" else ""}\n"
+}

agentik-tui/src/commonMain/kotlin/pw/binom/agentik/tui/ui/InputLine.kt

@@ -0,0 +1,67 @@
+package pw.binom.agentik.tui.ui
+
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.collectAsState
+import androidx.compose.runtime.getValue
+import com.jakewharton.mosaic.layout.KeyEvent
+import com.jakewharton.mosaic.layout.drawBehind
+import com.jakewharton.mosaic.layout.onPreviewKeyEvent
+import com.jakewharton.mosaic.modifier.Modifier
+import com.jakewharton.mosaic.ui.Text
+import pw.binom.agentik.tui.AppState
+
+/**
+ * Нижняя строка ввода с курсором.
+ * При активном стриме ассистента показывает ` ⋯`, иначе ` >`.
+ *
+ * Содержимое строки: `<prompt> <before>|<cursorChar>|<after>` —
+ * `cursorChar` — это символ, на котором стоит курсор (или пробел в конце).
+ *
+ * Клавиши обрабатываются через [handleInputKey] внутри `onPreviewKeyEvent`.
+ */
+@Composable
+internal fun InputLine(state: AppState) {
+    val text by state.input.collectAsState()
+    val cursor by state.cursor.collectAsState()
+    val streaming by state.streaming.collectAsState()
+    val cursorPos = cursor.coerceIn(0, text.length)
+    val before = text.substring(0, cursorPos)
+    val cursorChar = if (cursorPos < text.length) text[cursorPos].toString() else " "
+    val afterStart = if (cursorPos < text.length) cursorPos + 1 else cursorPos
+    val after = text.substring(afterStart.coerceAtMost(text.length))
+    val prompt = if (streaming) " ⋯" else " >"
+
+    Text(
+        value = "$prompt $before|$cursorChar|${after}",
+        modifier = Modifier
+            .onPreviewKeyEvent { ev -> handleInputKey(state, ev) }
+            .drawBehind {
+                // Snapshot-read state в drawBehind чтобы changes триггерили redraw.
+                state.input.let { /* touch */ }
+            },
+    )
+}
+
+/**
+ * Обработка клавиш в [InputLine]. `true` = событие поглощено.
+ *
+ * Не перехватывает клавиши с `alt`/`ctrl` — они идут дальше
+ * на корневой обработчик ([pw.binom.agentik.tui.App]).
+ */
+internal fun handleInputKey(state: AppState, ev: KeyEvent): Boolean {
+    if (ev.alt || ev.ctrl) return false
+    return when (ev.key) {
+        "Enter" -> state.submitInput() != null
+        "Backspace" -> { state.inputBackspace(); true }
+        "Delete" -> { state.inputDelete(); true }
+        "Left", "ArrowLeft" -> { state.inputMoveCursor(-1); true }
+        "Right", "ArrowRight" -> { state.inputMoveCursor(+1); true }
+        "Home" -> { state.inputCursorHome(); true }
+        "End" -> { state.inputCursorEnd(); true }
+        else -> {
+            val s = ev.key
+            if (s.length == 1) { state.inputInsert(s); true }
+            else false
+        }
+    }
+}

agentik-tui/src/commonTest/kotlin/pw/binom/agentik/tui/FakeAgent.kt

@@ -0,0 +1,94 @@
+package pw.binom.agentik.tui
+
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.emptyFlow
+import pw.binom.agentik.journal.JournalStore
+import pw.binom.agentik.outbox.OutboxStore
+import pw.binom.agentik.proto.Agent
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Conversation
+import pw.binom.agentik.outbox.Event
+import pw.binom.agentik.proto.Message
+import pw.binom.agentik.proto.MessageContext
+import kotlin.time.Instant
+
+/**
+ * Минимальный fake [Agent] для тестов [TuiBackend]: считает, сколько раз
+ * вызвали [createConversation], и отдаёт заранее сконструированные
+ * [FakeConversation].
+ */
+internal class FakeAgent(
+    private val conversationFactory: () -> FakeConversation = { FakeConversation() },
+) : Agent {
+    override val id: String = "fake"
+    var createCount: Int = 0
+        private set
+    val conversations = mutableListOf<FakeConversation>()
+
+    // Storage handles не используются тестами TuiBackend — тесты проверяют
+    // маршрутизацию Conversation.events в UI state. Outbox stub-ы возвращают
+    // emptyFlow, journal — error-on-access (никто не должен его трогать).
+    override val journal: JournalStore = error("journal not used in TuiBackend tests")
+    override val outbox: OutboxStore = object : OutboxStore {
+        override fun events(after: Instant?) = emptyFlow<pw.binom.agentik.outbox.CommonEvent>()
+        override suspend fun earliestEventDate(): Instant = Instant.DISTANT_PAST
+        override fun close() {}
+    }
+
+    override fun createConversation(temp: Boolean): Conversation {
+        createCount++
+        val c = conversationFactory()
+        conversations += c
+        return c
+    }
+
+    override suspend fun getConversation(id: String): Conversation? =
+        conversations.firstOrNull { it.id == id }
+
+    override suspend fun deleteConversation(id: String): Boolean =
+        conversations.removeAll { it.id == id }
+
+    override suspend fun getConversations(offset: Int, limit: Int): List<Conversation> =
+        conversations.toList()
+}
+
+/**
+ * [Conversation], запоминающий все вызовы [send] и эмитящий управляемые
+ * [Event] через общий [MutableSharedFlow]. Используется в тестах
+ * [TuiBackend] для проверки маршрутизации событий в UI.
+ */
+internal class FakeConversation(
+    override val id: String = "fake-conv",
+    override val title: String? = null,
+) : Conversation {
+    override val isSupportImageInput: Boolean = false
+    override val isSupportImageOutput: Boolean = false
+    override val isTemporal: Boolean = false
+    override val updatedAt: Instant = Instant.DISTANT_PAST
+
+    val sent = mutableListOf<List<Content>>()
+    val sentContexts = mutableListOf<MessageContext?>()
+    var closed: Boolean = false
+        private set
+    var interrupted: Boolean = false
+        private set
+
+    private val eventsFlow = MutableSharedFlow<Event>(extraBufferCapacity = 64)
+    fun emit(e: Event) { eventsFlow.tryEmit(e) }
+
+    override suspend fun rename(title: String) = Unit
+
+    override suspend fun send(content: List<Content>, context: MessageContext?) {
+        sent += content
+        sentContexts += context
+    }
+
+    override suspend fun interrupt() { interrupted = true }
+
+    override fun events(after: Instant): Flow<Event> = eventsFlow
+
+    override suspend fun getMessages(after: Instant, offset: Int, limit: Int): List<Message> = emptyList()
+
+    override fun close() { closed = true }
+}

agentik-tui/src/commonTest/kotlin/pw/binom/agentik/tui/TuiBackendTest.kt

@@ -0,0 +1,249 @@
+package pw.binom.agentik.tui
+
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.test.runCurrent
+import kotlinx.coroutines.test.runTest
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.outbox.Event
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertFalse
+import kotlin.test.assertTrue
+
+/**
+ * Тесты [TuiBackend]. Используем [runTest.backgroundScope] (а не TestScope)
+ * для передачи в `start` — фоновые подписки должны жить параллельно с
+ * телом теста и автоматически отменяться по его завершении. Иначе
+ * бесконечный collect на `agent.events()` завешивает runTest на 60s
+ * `UncompletedCoroutinesError`.
+ *
+ * [runCurrent] нужен после каждого `onUserMessage` и каждого `emit`,
+ * потому что `backgroundScope` использует свой диспетчер, который не
+ * продвигается через `advanceUntilIdle` — `runCurrent` прогоняет ровно
+ * те задачи, что готовы к запуску сейчас.
+ */
+@OptIn(ExperimentalCoroutinesApi::class)
+class TuiBackendTest {
+
+    private fun fixtureConfig(server: String = "http://localhost:8080/agentik") =
+        TuiConfig(server = server, id = "cli-tui:tester", historyEnabled = true)
+
+    @Test
+    fun `start posts connected system message`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val agent = FakeAgent()
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        val sysMsgs = state.messages.value.filterIsInstance<TuiMessage.System>()
+        assertTrue(
+            sysMsgs.any { it.text.contains(cfg.server) },
+            "ожидалось системное 'подключено к ${cfg.server}', было: ${sysMsgs.map { it.text }}",
+        )
+    }
+
+    @Test
+    fun `first onUserMessage auto-creates conversation with temp=false`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val agent = FakeAgent()
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("привет")
+        runCurrent()
+
+        assertEquals(1, agent.createCount, "должен быть один createConversation")
+        assertEquals(listOf("привет"), agent.conversations.first().sent.flattenText())
+        // temp=false — обычный (не временный) диалог: персистится на сервере
+        assertFalse(agent.conversations.first().isTemporal, "диалог не должен быть временным")
+        // state знает id и title нового диалога
+        assertEquals("fake-conv", state.currentConversationId.value)
+    }
+
+    @Test
+    fun `second onUserMessage reuses same conversation`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val agent = FakeAgent()
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("раз")
+        runCurrent()
+        backend.onUserMessage("два")
+        runCurrent()
+
+        assertEquals(1, agent.createCount, "новый диалог создавать не должны — переиспользуем старый")
+        assertEquals(2, agent.conversations.first().sent.size)
+    }
+
+    @Test
+    fun `AppendText appends to current assistant streaming chunk`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.StartResponse(now, Event.ResponseType.TEXT))
+        conv.emit(Event.AppendText(now, "Привет"))
+        conv.emit(Event.AppendText(now, ", мир"))
+        runCurrent()
+
+        val assistantMsgs = state.messages.value.filterIsInstance<TuiMessage.AssistantStreaming>()
+        assertEquals(1, assistantMsgs.size, "должен быть один streaming-чанк, не два")
+        assertEquals("Привет, мир", assistantMsgs.single().text)
+        assertTrue(state.streaming.value)
+    }
+
+    @Test
+    fun `End event finalizes assistant and stops streaming`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.StartResponse(now, Event.ResponseType.TEXT))
+        conv.emit(Event.AppendText(now, "ответ"))
+        conv.emit(Event.End(now))
+        runCurrent()
+
+        val last = state.messages.value.last()
+        assertTrue(last is TuiMessage.Assistant, "после End последнее сообщение должно стать финальным Assistant, было: ${last::class.simpleName}")
+        assertEquals("ответ", (last as TuiMessage.Assistant).text)
+        assertFalse(state.streaming.value)
+    }
+
+    @Test
+    fun `Interrupted event clears streaming and posts system message`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.StartResponse(now, Event.ResponseType.TEXT))
+        conv.emit(Event.AppendText(now, "часть ответа"))
+        conv.emit(Event.Interrupted(now))
+        runCurrent()
+
+        assertFalse(state.streaming.value)
+        val sysMsgs = state.messages.value.filterIsInstance<TuiMessage.System>()
+        assertTrue(
+            sysMsgs.any { it.text.contains("прервано") },
+            "ожидалось 'прервано' в системных сообщениях, было: ${sysMsgs.map { it.text }}",
+        )
+    }
+
+    @Test
+    fun `ToolCall and ToolResult events become visible tool messages`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.ToolCall(date = now, id = "1", title = null, toolName = "echo", toolArgs = """{"x":1}"""))
+        conv.emit(Event.ToolResult(date = now, toolCallId = "1", result = "ok"))
+        runCurrent()
+
+        val toolMsgs = state.messages.value.filterIsInstance<TuiMessage.ToolCall>()
+        val resultMsgs = state.messages.value.filterIsInstance<TuiMessage.ToolResult>()
+        assertEquals(1, toolMsgs.size)
+        assertEquals("echo", toolMsgs.single().toolName)
+        assertEquals("""{"x":1}""", toolMsgs.single().args)
+        assertEquals(1, resultMsgs.size)
+        assertEquals("ok", resultMsgs.single().result)
+    }
+
+    @Test
+    fun `Error event posts system message and clears streaming`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.StartResponse(now, Event.ResponseType.TEXT))
+        conv.emit(Event.Error(date = now, message = "boom"))
+        runCurrent()
+
+        val sysMsgs = state.messages.value.filterIsInstance<TuiMessage.System>()
+        assertTrue(sysMsgs.any { it.text.contains("boom") }, "должно быть 'ошибка: boom'")
+        assertFalse(state.streaming.value)
+    }
+
+    @Test
+    fun `onUserMessage does not swallow exceptions - state stays consistent`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val agent = FakeAgent(conversationFactory = { error("server kaboom") })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+
+        val sysMsgs = state.messages.value.filterIsInstance<TuiMessage.System>()
+        assertTrue(
+            sysMsgs.any { it.text.contains("ошибка отправки") || it.text.contains("server kaboom") },
+            "должна быть системная ошибка, было: ${sysMsgs.map { it.text }}",
+        )
+        assertFalse(state.streaming.value, "стриминг должен быть выключен в catch-ветке")
+    }
+
+    @Test
+    fun `StartReasoning posts thinking system message`() = runTest {
+        val cfg = fixtureConfig()
+        val state = AppState(cfg)
+        val conv = FakeConversation()
+        val agent = FakeAgent(conversationFactory = { conv })
+        val backend = TuiBackend(state = state, agent = agent)
+        backend.start(backgroundScope)
+        runCurrent()
+
+        backend.onUserMessage("hi")
+        runCurrent()
+        val now = kotlin.time.Clock.System.now()
+        conv.emit(Event.StartReasoning(now))
+        runCurrent()
+
+        val sysMsgs = state.messages.value.filterIsInstance<TuiMessage.System>()
+        assertTrue(sysMsgs.any { it.text.contains("думаю") })
+    }
+}
+
+private fun List<List<Content>>.flattenText(): List<String> =
+    map { cs -> cs.filterIsInstance<Content.Text>().joinToString("") { it.body } }

agentik-tui/src/jvmMain/kotlin/pw/binom/agentik/tui/Platform.jvm.kt

@@ -4,11 +4,9 @@ import pw.binom.agentik.client.AgentikAgent
 import pw.binom.agentik.proto.Agent
 
 /**
- * Платформенная фабрика [Agent]. JVM-only пока: native не подключали ktor-движки.
+ * Платформенные actual'ы для JVM. Используется `:client` поверх Ktor CIO.
  */
 internal actual fun platformEnv(key: String): String? = System.getenv(key)
 
-/**
- * Реализация [TuiApp.createAgent] для JVM — обычный ktor-cio через `:client`.
- */
-internal fun jvmCreateAgent(baseUrl: String, id: String): Agent = AgentikAgent(id = id, baseUrl = baseUrl)
+internal actual fun platformCreateAgent(baseUrl: String, id: String): Agent =
+    AgentikAgent(id = id, baseUrl = baseUrl)

agentik-tui/src/nativeMain/kotlin/pw/binom/agentik/tui/Platform.native.kt

@@ -9,5 +9,5 @@ import pw.binom.agentik.proto.Agent
  */
 internal actual fun platformEnv(key: String): String? = null
 
-internal fun nativeCreateAgent(baseUrl: String, id: String): Agent =
+internal actual fun platformCreateAgent(baseUrl: String, id: String): Agent =
     error("agentik-tui native target is not implemented yet (baseUrl=$baseUrl)")

build.gradle.kts

@@ -11,14 +11,16 @@ group = "pw.binom.agentik"
 // прочитать через rootProject.extra["projectVersion"].
 
 // Publication version: -Pversion=<tag> (CICD publishes by release tag) с
-// fallback в gradle.properties ("version=0.1.0"). Без версии maven-publish падает
-// с "Invalid publication 'kotlinMultiplatform': version cannot be empty" —
+// fallback в gradle.properties (ключ `agentik.version.default`, не `version`
+// — иначе Gradle-мерж gradle.properties и -Pversion= отдаёт приоритет
+// gradle.properties). Без версии maven-publish падает с
+// "Invalid publication 'kotlinMultiplatform': version cannot be empty" —
 // это известный gotcha: subprojects читают rootProject.version ДО того, как
 // if-блок ниже успевает его установить. Фикс: provider+orElse вычисляется
 // eagerly, и subprojects получают готовую строку.
 val projectVersion: String = providers.gradleProperty("version")
     .map { it.trimStart('v', 'V') }  // strip optional "v" prefix from tag
-    .getOrElse("0.1.0")
+    .getOrElse(providers.gradleProperty("agentik.version.default").orElse("0.1.0-SNAPSHOT").get())
 version = projectVersion
 extra["projectVersion"] = projectVersion
 
@@ -49,7 +51,7 @@ val moduleDescriptions: Map<String, String> = mapOf(
     "storage-sqlite" to "agentik :storage-sqlite — SQLDelight реализация всех сторов на SQLite (прод-бэкенд).",
     "agent-toolsets" to "agentik :agent-toolsets — реестр инструментов + диспетчер тулов (enable_toolset/disable_toolset); переиспользуемое ядро.",
     "agentik-cli" to "agentik :agentik-cli — JVM CLI-клиент (JLine) к /agentik: REPL + slash-команды + стрим SSE.",
-    "agentik-tui" to "agentik :agentik-tui — Compose-for-Mosaic TUI-клиент (desktop, без iOS) с клавиатурной навигацией без ':'-префиксов.",
+    // "agentik-tui" to "agentik :agentik-tui — Compose-for-Mosaic TUI-клиент (отключён 2026-09-17)."
 "standalone" to "agentik :standalone — single-jar HTTP-сервер со всеми транспортами (AG-UI/A2A/:proto), SQLite, памятью, скилами и SOUL.",
     )
     rootProject.extra.set("moduleDescriptions", moduleDescriptions)

client/README.md

@@ -1,101 +1,402 @@
-# `:client` — Ktor-клиент к `:server`/`:proto` (KMP, jvm + native)
+# `:client` — Ktor-клиент к `:server` (KMP, jvm + native)
 
-## Что это
+Тонкий HTTP-клиент к `:server`-фасаду + локальные примитивы, чтобы
+собирать свои клиенты (UI, CLI, parent-агенты, A2A-bridge) без бойлерплейта
+про HTTP, JSON, SSE и lifecycle `Conversation`.
 
-Ktor client (`io.ktor.client.HttpClient` + `ContentNegotiation(json) +
-Sse`), превращающий HTTP/SSE-фасад `:server` в `Agent`/`Conversation`
-интерфейсы `:proto`:
+## Что есть
 
-- `AgentikAgent(id, baseUrl)` — entry-point фабрики.
-- `AgentClient` — список и lifecycle диалогов.
-- `ConversationClient` — `send()`, `events()`, `interrupt()`,
-  `getMessages()`, `rename()`, `close()`.
-- Внутренний парсер SSE → `Flow<Event>`.
+- `AgentikAgent(id, baseUrl, engineFactory, token?)` — entry-point. Возвращает
+  `Agent` (тот же интерфейс, что в `:proto`). HttpClient создаётся внутри
+  из переданной `engineFactory` (`CIO`, `OkHttp`, `Darwin`).
+- `Agent`: `createConversation` / `getConversation` / `getConversations` /
+  `deleteConversation` / `journal` / `outbox` / `close`.
+- `Conversation`: `send(content, context?)` / `events(after)` (SSE `Flow<Event>`)
+  / `getMessages(after, offset, limit)` / `rename` / `interrupt` / `close`.
+- `HttpJournalStore` — `list(convId, after, offset, limit)` → `List<MessageRecord>`
+  со всеми типами записей (User/Assistant/ToolCall/ToolResult/Error + tokens).
+- `HttpEventStore` — `events` / `agentEvents` / `conversationEvents` (SSE).
+- `ReconnectingOutbox(outbox, scope, policy)` — обёртка над `OutboxStore` с
+  авто-reconnect при обрыве стрима (exponential backoff). Два независимых
+  потока: `events()` (те же `CommonEvent`) и `connectionStatus()`
+  (`Connecting`/`Connected`/`Disconnected`/`Failed`) — статус НЕ мешается
+  с основным потоком событий. См. ниже.
 
-Решает: пишем нативный Kotlin-клиент, без curl/JS/Python boilerplate,
-с теми же типами, что и сервер. Один и тот же клиент работает на
-JVM, iOS, macOS, Linux, Windows.
+`Agent` — `AutoCloseable`; `agent.close()` закрывает HttpClient. Не нужно
+вручную создавать `HttpClient` и накатывать на него JSON/Bearer-плагины.
 
-## Где используется
-
-- `:agentik-cli` — REPL.
-- `:agentik-tui` — Compose-for-Mosaic клиент.
-- Любой внешний KMP-проект, который хочет встроить агента в свой UI.
-
-## Как подключить
+## Подключение
 
 ```kotlin
 // build.gradle.kts
-kotlin {
-    sourceSets.commonMain.dependencies {
-        api("pw.binom.agentik:client:0.1.0")
-    }
-}
-
-// ваш код:
-val agent = AgentikAgent(id = "agentik", baseUrl = "http://192.168.76.166:8080/agentik")
-val conv = agent.createConversation(title = "test")
-conv.send(listOf(Content.Text("hello"))).collect { event ->
-    when (event) {
-        is Event.AppendText -> print(event.body)
-        is Event.End -> println("\n--- end ---")
-        is Event.Error -> error("agent error: ${event.message}")
-        else -> Unit
-    }
+dependencies {
+    api("pw.binom.agentik:client:0.1.0")
+    // Движок — на твой выбор (один из):
+    implementation("io.ktor:ktor-client-cio:3.x")   // JVM/Native
+    implementation("io.ktor:ktor-client-okhttp:3.x") // JVM
+    implementation("io.ktor:ktor-client-darwin:3.x") // iOS/macOS
+    // Опционально — только если будешь использовать `InMemoryJournalStore`
+    // как клиентский кэш. Свой `MutableJournalStore` — не нужен.
+    api("pw.binom.agentik:journal-inmemory:0.1.0")
 }
 ```
 
-## Версии
+## Что клиент хранит локально (persistence)
 
-`gradle/libs.versions.toml` → `[versions] agentik-client`.
+Либа **не** имеет `SettingsRepository` / `Config` — это намеренно: UI-фреймворки хранят настройки по-разному (JSON-файл, Keychain, Android DataStore, NSUserDefaults, ...). Либа не навязывает формат, но клиент должен сериализовать у себя минимум:
 
-Поддерживает все KMP-таргеты, что и `:proto`.
+| Поле | Что это | Где взять |
+|---|---|---|
+| `clientId` (параметр `id` в `AgentikAgent`) | Идентичность клиента в логах сервера (X-Client-Id header). Не user-id в агенте, не device-id — это **произвольная строка клиента**, обычно `<app-name>-<installation-uuid>`. Сервер использует для log multiplexing и не интерпретирует. | Генерируется один раз при первом запуске (`UUID.randomUUID().toString()`) и сохраняется. Никогда не меняется. |
+| `baseUrl` | URL сервера (`http://host:8080/agentik`). Должен включать path-prefix фасада, не только хост. | Из настроек пользователя / дефолт |
+| `token` | Bearer-токен. `null` = анонимный доступ (если сервер разрешает). | Из настроек пользователя / secure-storage |
 
-## Примеры API
+Опционально (для UX): `engineFactory` — обычно compile-time выбор по платформе (`CIO` JVM/Native, `OkHttp` JVM, `Darwin` iOS/macOS).
+
+Минимальный JSON для UI, который хранит в файле:
+
+```json
+{
+  "clientId": "my-android-app-550e8400-e29b-41d4-a716-446655440000",
+  "baseUrl": "https://agent.example.com/agentik",
+  "token": "s3cret"
+}
+```
+
+⚠️ `clientId` **генерируется один раз** при установке и больше не меняется — иначе сломается log multiplexing на сервере.
+
+## Быстрый старт: свой клиент за 5 минут
+
+Один self-contained пример: создаём агента, открываем диалог,
+отправляем сообщение, печатаем streaming-ответ.
 
 ```kotlin
-// список диалогов
-agent.getConversations().collect { println(it.id to it.title) }
+import pw.binom.agentik.client.AgentikAgent
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Event
+import io.ktor.client.engine.cio.CIO
+import kotlinx.coroutines.runBlocking
+import kotlin.time.Clock
 
-// live-подписка на события отдельного диалога
-val sub = conversation.events(after = Instant.parse("2026-09-01T00:00:00Z")).collect { }
+fun main() = runBlocking {
+    // 1. Agent — обёртка над :server фасадом. HttpClient создаётся внутри.
+    val agent = AgentikAgent(
+        id = "my-client",
+        baseUrl = "http://localhost:8080/agentik",
+        engineFactory = CIO,
+        token = "s3cret",  // или null, если не нужен
+    )
 
-// прерывание текущего хода
-conversation.interrupt()
+    // 2. Открыть диалог, отправить сообщение.
+    val conv = agent.createConversation(temp = false)
+    conv.send(listOf(Content.Text("Привет")))
 
-// история
-conversation.getMessages(offset = 0).collect { msg ->
-    when (msg) {
-        is Message.UserMessage -> println("user: ${msg.content}")
-        is Message.AssistantMessage -> println("assistant: ${msg.content}")
-        else -> Unit
+    // 3. Собирать streaming-ответ.
+    conv.events(after = Clock.System.now()).collect { ev ->
+        when (ev) {
+            is Event.StartResponse -> println("[start]")
+            is Event.AppendText    -> print(ev.body)
+            is Event.End           -> println("[end]")
+            is Event.Error         -> println("[error: ${ev.message}]")
+            else                   -> Unit
+        }
+    }
+
+    // 4. Чистый shutdown.
+    conv.close()
+    agent.close()
+}
+```
+
+**Это весь клиент.** `:server` сам хранит историю, контекст, события.
+Ты только получаешь типизированный `Flow<Event>` и рендеришь как хочешь.
+
+`HttpClient`, `applyAgentikDefaults`, выбор engine'а — всё скрыто
+внутри `AgentikAgent`. Один вызов — один готовый `Agent`.
+
+### Добавить локальный кэш истории (ещё 4 строки)
+
+```kotlin
+import pw.binom.agentik.journal.inmemory.InMemoryJournalStore
+import kotlin.time.Instant
+
+// Свой кэш. Хочешь SQLite/JSON/etc. — реализуй MutableJournalStore сам.
+val cache = InMemoryJournalStore()
+
+// Backfill + live-refresh в одном фоне:
+launch {
+    agent.journal.listFlow(conv.id, Instant.DISTANT_PAST)
+        .collect { cache.append(it) }
+}
+
+// История — теперь из кэша, без HTTP:
+val history = cache.list(conv.id, Instant.DISTANT_PAST, 0, Int.MAX_VALUE)
+history.forEach { rec ->
+    when (rec) {
+        is pw.binom.agentik.journal.MessageRecord.UserMessage      -> print("user> ${rec.content.text()}")
+        is pw.binom.agentik.journal.MessageRecord.AssistantMessage -> print("agent> ${rec.content.text()}")
+        is pw.binom.agentik.journal.MessageRecord.ToolCall         -> print("[tool: ${rec.toolName}]")
+        is pw.binom.agentik.journal.MessageRecord.ToolResult       -> print("[result]")
+        is pw.binom.agentik.journal.MessageRecord.Error            -> print("[error: ${rec.message}]")
     }
 }
 ```
 
+Шаблон "remote.listFlow → local.append" работает с любым
+`MutableJournalStore` (см. `:journal-api`). Это и есть кэширование
+"без геморроя".
+
+### Что вообще не нужно писать самому
+
+- HTTP-сериализация `Event`/`Message` — `agentikHttpClient` регистрирует
+  `agentikJson` и `InstantSerializer`.
+- SSE-парсер — `readSse()` внутри `:client`.
+- Cursor-менеджмент для `listFlow` — дефолтная имплементация в
+  `JournalStore.listFlow` сама пагинирует.
+- Lifecycle подписок на `events()` — `Conversation.close()` отменяет SSE-job.
+- HTTP-клиент и Bearer — `AgentikAgent` создаёт `HttpClient(engineFactory)`
+  с Bearer'ом из `token=` под капотом; `agent.close()` его закрывает.
+- Движковые настройки (requestTimeout и пр.) — `HttpClient(engineFactory) { ... }`
+  создаётся здесь; для нестандартных движковых настроек используй
+  `agentikHttpClient(engineFactory, token)` напрямую (он экспортирован).
+
+### Что нужно написать самому
+
+- UI-рендеринг `Event`'ов — это твоё (Compose/HTML/CLI).
+- Диалог с пользователем — ввод текста, отображение кнопок и т.п.
+- Persist кэша между запусками (если нужно) — замени `InMemoryJournalStore`
+  на свой `MutableJournalStore` (см. `:journal-ksqlite` как пример).
+
+
+## Базовый пример: send + collect events
+
+```kotlin
+import pw.binom.agentik.client.AgentikAgent
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Event
+import io.ktor.client.engine.cio.CIO
+
+val agent = AgentikAgent(
+    id = "agentik",
+    baseUrl = "http://localhost:8080/agentik",
+    engineFactory = CIO,
+)
+
+val conv = agent.createConversation(temp = false)
+conv.send(listOf(Content.Text("Привет, расскажи про себя")))
+
+conv.events(after = kotlin.time.Clock.System.now()).collect { ev ->
+    when (ev) {
+        is Event.AppendText -> print(ev.body)             // streaming чанки
+        is Event.End        -> println("\n--- end ---")
+        is Event.Error      -> error("agent error: ${ev.message}")
+        else                -> Unit
+    }
+}
+```
+
+## История с локальным кэшем
+
+Главный паттерн: **клиент держит свой `MutableJournalStore` и периодически
+(или разово) синхронизирует с удалённым через `listFlow`**. Дальше всё
+чтение истории — из локального кэша.
+
+`InMemoryJournalStore` — это `MutableJournalStore`, ты можешь реализовать
+свой (например с персистентностью в SQLite/JSON/whatever) — главное чтобы
+реализовывал интерфейс.
+
+```kotlin
+import pw.binom.agentik.journal.inmemory.InMemoryJournalStore
+import pw.binom.agentik.proto.Content
+import pw.binom.agentik.proto.Event
+import kotlin.time.Instant
+
+class ChatSession(
+    private val agent: pw.binom.agentik.proto.Agent,
+    val conversationId: String,
+) : AutoCloseable {
+
+    // Локальный кэш. Замените InMemoryJournalStore на свой, если нужна
+    // персистентность (SQLite/JSON/etc.) — контракт `MutableJournalStore`
+    // (модуль `:journal-api`).
+    val cache = InMemoryJournalStore()
+
+    // Подписка на live-события этого диалога — будем обновлять кэш на `End`.
+    private val scope = kotlinx.coroutines.CoroutineScope(
+        kotlinx.coroutines.SupervisorJob() +
+        kotlinx.coroutines.Dispatchers.Default,
+    )
+
+    init {
+        // 1. Backfill: забираем всю историю разговора с сервера.
+        scope.launch {
+            agent.journal.listFlow(
+                conversationId = conversationId,
+                after = Instant.DISTANT_PAST,
+            ).collect { cache.append(it) }
+        }
+        // 2. Live: на каждом `End` хода просим у сервера новые записи.
+        scope.launch {
+            agent.getConversation(conversationId)!!.events(Instant.DISTANT_PAST).collect { ev ->
+                if (ev is Event.End) {
+                    val newest = cache.let {
+                        // last-seen курсор — последний createdAt в кэше
+                        it.list(conversationId, Instant.DISTANT_PAST, 0, 1).lastOrNull()?.createdAt
+                            ?: Instant.DISTANT_PAST
+                    }
+                    agent.journal.list(conversationId, newest, offset = 0, limit = 100)
+                        .forEach { cache.append(it) }
+                }
+            }
+        }
+    }
+
+    fun history() = kotlinx.coroutines.runBlocking {
+        cache.list(conversationId, Instant.DISTANT_PAST, 0, Int.MAX_VALUE)
+    }
+
+    override fun close() {
+        scope.cancel()
+    }
+}
+
+// Использование:
+val session = ChatSession(agent, conv.id)
+
+// История — из кэша:
+session.history().forEach { rec ->
+    when (rec) {
+        is MessageRecord.UserMessage      -> println("user: ${rec.content.text()}")
+        is MessageRecord.AssistantMessage -> println("assistant: ${rec.content.text()}")
+        is MessageRecord.ToolCall         -> println("tool-call: ${rec.toolName}")
+        is MessageRecord.ToolResult       -> println("tool-result: ${rec.result}")
+        is MessageRecord.Error            -> println("error: ${rec.message}")
+    }
+}
+
+// Отправить новое сообщение:
+session.scope.launch {
+    agent.getConversation(conversationId)!!.send(listOf(Content.Text("Привет ещё раз")))
+}
+```
+
+`InMemoryJournalStore` отдаёт `MessageRecord` со всем payload'ом
+(текст + tool-call/tool-result + tokens). UI сам решает что показать —
+`rec is MessageRecord.UserMessage` для реплик пользователя,
+`rec is MessageRecord.ToolCall` для отрисовки tool-call баббла, и т.п.
+
+## Стриминг live-ответа
+
+Для streaming-рендера текущего хода подписывайся на `events()` и
+собирай `Event.AppendText`-чанки в свой буфер. Это **не идёт в кэш** —
+только для UI-feedback во время хода. После `End` хода запись уже
+появится в кэше через refresh-блок выше.
+
+```kotlin
+import pw.binom.agentik.proto.Event
+
+agent.getConversation(convId)!!.events(Instant.DISTANT_PAST).collect { ev ->
+    when (ev) {
+        is Event.StartResponse -> println("[start]")
+        is Event.AppendText    -> print(ev.body)
+        is Event.AppendImage   -> showImage(ev.body)
+        is Event.ToolCall      -> println("[tool: ${ev.toolName}]")
+        is Event.ToolResult    -> println("[result]")
+        is Event.End           -> println("[end]")
+        is Event.Error         -> println("[error: ${ev.message}]")
+        else                    -> Unit
+    }
+}
+```
+
+## Прерывание хода
+
+```kotlin
+agent.getConversation(convId)!!.interrupt()
+```
+
+## Multi-conversation
+
+Один `Agent`, много `ChatSession`:
+
+```kotlin
+val sessions = mutableMapOf<String, ChatSession>()
+
+fun open(convId: String): ChatSession =
+    sessions.getOrPut(convId) { ChatSession(agent, convId) }
+
+fun close(convId: String) {
+    sessions.remove(convId)?.close()
+}
+```
+
+Подписка на lifecycle диалогов (`agent.outbox.agentEvents(...)`) +
+UI-обновление списка — отдельная задача, решается `Flow<CommonEvent.Agent>`.
+
+## Где `:client` НЕ помогает
+
+- **UI-рендеринг** — это твоя зона (Compose/HTML/etc.), `:client` только
+  отдаёт типы и потоки.
+- **Персистентность кэша** — `InMemoryJournalStore` хранит в RAM. Для
+  диска пиши свой `MutableJournalStore` (см. `KsqliteJournalStore` в
+  `:journal-ksqlite` как образец).
+- **Нестандартные движковые настройки** — для `requestTimeout`,
+  прокси и т.п. используй `agentikHttpClient(engineFactory, token)`
+  напрямую.
+
 ## Тесты
 
 ```
 ./gradlew :client:jvmTest
 ```
 
-Покрывают: JSON-парсинг Event'ов, SSE-стрим, recovery после разрыва,
-401/404.
+Покрывают: JSON-парсинг `Event`-ов, SSE-стрим, recovery после разрыва,
+401/404, reconnect-cycle `ReconnectingOutbox` (4 кейса: успех / обрыв +
+reconnect / exhausted attempts → Failed / close → cancel).
 
-## Чего здесь НЕТ
+## Auto-reconnect для живого outbox
 
-- Никакого LLM-кода. Это просто клиент.
-- Никакого persistent state. История хранится у сервера, клиент её
-  запрашивает через `getMessages` или подписывается через `events`.
+Базовый `OutboxStore.events(after)` — cold SSE-стрим, при обрыве (мобильная
+сеть, рестарт сервера) клиент сам должен реконнектиться с `after = lastEventDate`.
+Это повторяется в каждом клиенте. `ReconnectingOutbox` берёт это на себя:
 
-## Текущий статус
+```kotlin
+val recon = ReconnectingOutbox(
+    outbox = agent.outbox,           // или HttpEventStore
+    scope = myScreenScope,
+    policy = BackoffPolicy.Default,  // 1s → 2s → ... → 30s, ±20% jitter
+)
 
-Используется продакшеном. Бэкендом служит `:server` поверх `:standalone`,
-но клиент совместим с любым сервером, который держит wire-контракт
-`:server`.
+scope.launch { recon.events(Instant.DISTANT_PAST).collect { handle(it) } }
+scope.launch {
+    recon.connectionStatus().collect { status ->
+        when (status) {
+            is Connecting   -> ui.showBanner("connecting...")
+            is Connected    -> ui.hideBanner()
+            is Disconnected -> ui.showBanner("reconnecting in ${status.willRetryIn}…")
+            is Failed       -> ui.showError(status.cause)
+        }
+    }
+}
+
+// На выходе (например, navigation back):
+recon.close()  // отменяет background-loop, потоки терминируются
+```
+
+Два потока **независимы** — `events()` содержит только `CommonEvent`,
+`connectionStatus()` содержит только `ConnectionStatus`. Никакого
+"мешающего" `Connecting`/`Disconnected` в потоке событий.
+
+Параметры backoff (см. `BackoffPolicy`):
+- `initial` / `max` — границы задержки
+- `multiplier` — множитель на каждом шаге
+- `jitter` — рандом-разброс (по умолчанию 20%)
+- `maxAttempts` — лимит попыток; после — `Failed` + закрытие потока
+
+Если нужен фиксированный delay для тестов — `BackoffPolicy.Fixed(10.milliseconds, attempts = 3)`.
 
 ## Известное ограничение
 
 SSE event-stream в не-TTY ssh-сессии (без `-tt`) закрывается на
-default-таймауте Ktor. Используйте либо ssh -tt, либо нативный
+default-таймауте Ktor. Используйте либо `ssh -tt`, либо нативный
 terminal (TTY). Это upstream-особенность Ktor SSE.

client/build.gradle.kts

@@ -1,25 +1,52 @@
-import org.jetbrains.kotlin.gradle.dsl.JvmTarget
-
 plugins {
-    alias(libs.plugins.kotlin.jvm)
+    alias(libs.plugins.kotlin.multiplatform)
     alias(libs.plugins.kotlin.serialization)
 }
 
 kotlin {
-    compilerOptions {
-        jvmTarget.set(JvmTarget.JVM_21)
+    jvmToolchain(21)
+
+    // Только то, что нам реально нужно: JVM + 5 desktop-native. iOS не входит —
+    // :client не имеет смысла на iOS, а :agentik-cli использует :client и тоже
+    // без iOS. См. agentik-cli/build.gradle.kts.
+    jvm()
+    listOf(
+        macosX64(),
+        macosArm64(),
+        linuxX64(),
+        linuxArm64(),
+        mingwX64(),
+    )
+
+    sourceSets {
+        commonMain.dependencies {
+            api(project(":proto"))
+            api(project(":outbox-api"))
+            api(project(":journal-api"))
+
+            api(libs.ktor.client.core)
+            implementation(libs.ktor.client.content.negotiation)
+            implementation(libs.ktor.serialization.kotlinx.json)
+
+            implementation(libs.kotlinx.coroutines.core)
+            implementation(libs.kotlinx.serialization.core)
+            implementation(libs.kotlinx.serialization.json)
+        }
+        commonTest.dependencies {
+            implementation(libs.kotlin.test)
+            implementation(libs.kotlinx.coroutines.test)
+            implementation(libs.ktor.server.core)
+            implementation(libs.ktor.server.test.host)
+            implementation(libs.ktor.client.content.negotiation)
+            implementation(libs.ktor.client.cio)
+            implementation(libs.ktor.server.cio)
+            implementation(libs.ktor.server.sse)
+        }
+        jvmTest.dependencies {
+            implementation("junit:junit:4.13.2")
+        }
     }
-}
-
-dependencies {
-    implementation(project(":proto"))
-
-    implementation(libs.ktor.client.core)
-    implementation(libs.ktor.client.cio)
-    implementation(libs.ktor.client.content.negotiation)
-    implementation(libs.ktor.serialization.kotlinx.json)
-
-    implementation(libs.kotlinx.coroutines.core)
-    implementation(libs.kotlinx.serialization.core)
-    implementation(libs.kotlinx.serialization.json)
+
+    // :client — это библиотека, не executable. Native-бинари объявляются
+    // в :agentik-cli (он зависит от :client и реально предоставляет main).
 }

client/src/commonMain/kotlin/pw/binom/agentik/client/AgentClient.kt

@@ -7,35 +7,35 @@ import io.ktor.client.request.get
 import io.ktor.client.request.parameter
 import io.ktor.client.request.post
 import io.ktor.client.request.setBody
-import io.ktor.client.statement.bodyAsChannel
+import io.ktor.client.statement.HttpResponse
 import io.ktor.http.ContentType
 import io.ktor.http.HttpStatusCode
 import io.ktor.http.contentType
-import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.runBlocking
+import pw.binom.agentik.journal.JournalStore
+import pw.binom.agentik.outbox.OutboxStore
 import pw.binom.agentik.proto.Agent
-import pw.binom.agentik.proto.AgentEvent
 import pw.binom.agentik.proto.Conversation
-import kotlin.time.Instant
 
 /**
  * HTTP-реализация [Agent]. Ходит в `:server`-фасад, см. `agentikAgent(...)`.
  *
- * Замечание по [createConversation]: интерфейс [Agent] объявлен не-suspend
- * (in-process кейс этого не требует), но HTTP-вариант обязан ждать ответа
- * POST `/conversations`. Используем `runBlocking` — это одноразовая
- * операция (открытие чата), не горячий путь. В UI-контексте вызывающий сам
- * решает, что делать.
+ * HttpClient создаётся внутри из переданного engine и закрывается в [close].
+ *
+ * **Storage handles** ([journal], [outbox]) — read-only views на серверные
+ * хранилища.
  */
 internal class AgentClient(
-    private val httpClient: HttpClient,
-    private val baseUrl: String,
     override val id: String,
+    private val baseUrl: String,
+    private val httpClient: HttpClient,
 ) : Agent {
 
     private val agentUrl: String = baseUrl.trimEnd('/')
 
+    override val outbox: OutboxStore = HttpEventStore(httpClient = httpClient, baseUrl = agentUrl)
+    override val journal: JournalStore = HttpJournalStore(httpClient = httpClient, baseUrl = agentUrl)
+
     override fun createConversation(temp: Boolean): Conversation =
         runBlocking {
             val snapshot: ConversationSnapshot = httpClient.post("$agentUrl/conversations") {
@@ -53,7 +53,7 @@ internal class AgentClient(
     }
 
     override suspend fun deleteConversation(id: String): Boolean {
-        val response = httpClient.delete("$agentUrl/conversations/$id")
+        val response: HttpResponse = httpClient.delete("$agentUrl/conversations/$id")
         return response.status == HttpStatusCode.NoContent
     }
 
@@ -65,14 +65,7 @@ internal class AgentClient(
         return snapshots.map { ConversationClient(httpClient, agentUrl, it) }
     }
 
-    override fun events(after: Instant): Flow<AgentEvent> = flow {
-        val response = httpClient.get("$agentUrl/events?after=$after")
-        check(response.status == HttpStatusCode.OK) {
-            "events: server returned ${response.status}"
-        }
-        readSse(response.bodyAsChannel())
-            .collect { payload ->
-                emit(agentikJson.decodeFromString(AgentEvent.serializer(), payload))
-            }
+    override fun close() {
+        httpClient.close()
     }
 }

client/src/commonMain/kotlin/pw/binom/agentik/client/AgentikAgent.kt

@@ -0,0 +1,74 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.engine.HttpClientEngineFactory
+import pw.binom.agentik.proto.Agent
+
+/**
+ * Создаёт [Agent], который ходит в HTTP-фасад `agentikAgent` (модуль `:server`).
+ *
+ * Принимает [engineFactory] — `HttpClientEngineFactory<*>` (`CIO`, `OkHttp`,
+ * `Darwin`, ...). Внутри сам создаёт `HttpClient`, накатывает JSON-конфиг
+ * [agentikJson] и опциональный Bearer [token]. Никакого `applyAgentikDefaults`
+ * снаружи — всё под капотом.
+ *
+ * ```
+ * val agent = AgentikAgent(
+ *     id = "my-client",
+ *     baseUrl = "http://localhost:8080/agentik",
+ *     engineFactory = CIO,
+ *     token = "s3cret",
+ * )
+ * val conv = agent.createConversation(temp = false)
+ * conv.send(listOf(Content.Text("hi")))
+ * agent.outbox.conversationEvents(Instant.DISTANT_PAST, conv.id)
+ *     .map { it.event }
+ *     .collect { ... }
+ * agent.close()  // закрывает HttpClient
+ * ```
+ *
+ * ## Что клиент должен хранить локально (persistence)
+ *
+ * Либа **не** имеет `SettingsRepository` / `Config` — это намеренно:
+ * UI-фреймворки хранят настройки по-разному (JSON-файл, Keychain,
+ * `SharedPreferences`, Android DataStore, NSUserDefaults, ...). Либа
+ * не навязывает формат, но вот минимальный набор, который клиент должен
+ * сериализовать у себя, чтобы пережить перезапуск:
+ *
+ * | Поле | Что это | Где взять |
+ * |---|---|---|
+ * | `id` | Идентичность клиента в логах сервера (X-Client-Id header). Не user-id в агенте, не device-id, а произвольная строка клиента — обычно `<app-name>-<installation-uuid>`. Сервер использует для log multiplexing и не интерпретирует. | Генерируется клиентом при первом запуске, сохраняется локально |
+ * | `baseUrl` | URL сервера (`http://host:8080/agentik`). Должен включать path-prefix фасада, не только хост. | Из настроек пользователя / дефолт |
+ * | `token` | Bearer-токен. `null` = анонимный доступ (если сервер разрешает). | Из настроек пользователя / secure-storage |
+ *
+ * Опционально (для UX):
+ * | Поле | Зачем |
+ * |---|---|
+ * | `engineFactory` | Зависит от платформы (`CIO` JVM/Native, `OkHttp` JVM, `Darwin` iOS/macOS). Выбор — обычно compile-time. |
+ *
+ * Пример минимального persistence-файла (для UI, который хранит JSON):
+ *
+ * ```json
+ * {
+ *   "clientId": "my-android-app-550e8400-e29b-41d4-a716-446655440000",
+ *   "baseUrl": "https://agent.example.com/agentik",
+ *   "token": "s3cret"
+ * }
+ * ```
+ *
+ * `clientId` генерируется один раз при первой установке (`UUID.randomUUID().toString()`)
+ * и больше не меняется — иначе сломается log multiplexing на сервере.
+ *
+ * **Lifecycle**: [Agent] — `AutoCloseable`. `agent.close()` закрывает
+ * HttpClient (идемпотентно). После этого `createConversation` /
+ * `getConversation` etc. не определены.
+ */
+fun AgentikAgent(
+    id: String,
+    baseUrl: String,
+    engineFactory: HttpClientEngineFactory<*>,
+    token: String? = null,
+): Agent = AgentClient(
+    id = id,
+    baseUrl = baseUrl,
+    httpClient = agentikHttpClient(engineFactory = engineFactory, token = token),
+)

client/src/commonMain/kotlin/pw/binom/agentik/client/ConversationClient.kt

@@ -7,16 +7,11 @@ import io.ktor.client.request.parameter
 import io.ktor.client.request.patch
 import io.ktor.client.request.post
 import io.ktor.client.request.setBody
-import io.ktor.client.statement.bodyAsChannel
 import io.ktor.http.ContentType
-import io.ktor.http.HttpStatusCode
 import io.ktor.http.contentType
-import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flow
 import kotlinx.serialization.Serializable
 import pw.binom.agentik.proto.Content
 import pw.binom.agentik.proto.Conversation
-import pw.binom.agentik.proto.Event
 import pw.binom.agentik.proto.Message
 import pw.binom.agentik.proto.MessageContext
 import kotlin.time.Instant
@@ -71,17 +66,6 @@ internal class ConversationClient(
         httpClient.post("$convUrl/interrupt")
     }
 
-    override fun events(after: Instant): Flow<Event> = flow {
-        val response = httpClient.get("$convUrl/events?after=$after")
-        check(response.status == HttpStatusCode.OK) {
-            "events: server returned ${response.status}"
-        }
-        readSse(response.bodyAsChannel())
-            .collect { payload ->
-                emit(agentikJson.decodeFromString(Event.serializer(), payload))
-            }
-    }
-
     override suspend fun getMessages(after: Instant, offset: Int, limit: Int): List<Message> =
         httpClient.get("$convUrl/messages") {
             parameter("after", after.toString())

client/src/commonMain/kotlin/pw/binom/agentik/client/HttpClientFactory.kt

@@ -0,0 +1,32 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.HttpClientEngineFactory
+import io.ktor.client.plugins.DefaultRequest
+import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
+import io.ktor.client.request.header
+import io.ktor.http.HttpHeaders
+import io.ktor.serialization.kotlinx.json.json
+
+/**
+ * Создаёт [HttpClient] поверх [engineFactory] с конфигурацией agentik.
+ *
+ * Внутренний helper для [AgentikAgent]. Потребителю `:client` обычно
+ * не нужен — он передаёт engine в [AgentikAgent] и получает готовый
+ * [pw.binom.agentik.proto.Agent] с уже закрытым HttpClient'ом
+ * на [pw.binom.agentik.proto.Agent.close].
+ *
+ * Экспортируется для случаев, когда нужен прямой доступ к `HttpClient`
+ * (например, дополнительные нестандартные запросы в обход `Agent` API).
+ */
+fun agentikHttpClient(
+    engineFactory: HttpClientEngineFactory<*>,
+    token: String? = null,
+): HttpClient = HttpClient(engineFactory) {
+    install(ContentNegotiation) { json(agentikJson) }
+    if (token != null) {
+        install(DefaultRequest) {
+            header(HttpHeaders.Authorization, "Bearer $token")
+        }
+    }
+}

client/src/commonMain/kotlin/pw/binom/agentik/client/HttpEventStore.kt

@@ -0,0 +1,132 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.HttpClient
+import io.ktor.client.request.prepareGet
+import io.ktor.client.statement.bodyAsChannel
+import io.ktor.http.HttpStatusCode
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+import pw.binom.agentik.outbox.OutboxStore
+import pw.binom.agentik.outbox.AgentEvent
+import pw.binom.agentik.outbox.CommonEvent
+import pw.binom.agentik.outbox.Event
+import kotlin.time.Clock
+import kotlin.time.Instant
+
+/**
+ * HTTP-реализация [OutboxStore] (= [pw.binom.agentik.outbox.OutboxStore]),
+ * ходящая в `:server`-фасад.
+ *
+ * **Endpoint-раскладка** (новый дизайн — storage handles на [Agent]):
+ *  - [events] → `GET {baseUrl}/outbox/events?after=` (полный поток
+ *    [CommonEvent], bounded-tail + live SSE, см. [pw.binom.agentik.server.outboxRoutes])
+ *  - [agentEvents] → `GET {baseUrl}/events?after=` (legacy proto-роут:
+ *    сервер пробрасывает [pw.binom.agentik.outbox.agentEvents] и распаковывает
+ *    `.event` для обратной совместимости с форматом AgentEvent)
+ *  - [conversationEvents] с `conversationId != null` → `GET /conversations/{id}/events`
+ *
+ * Для [conversationEvents] с `conversationId == null` (события всех диалогов)
+ * fallback на default [OutboxStore.conversationEvents] — общий поток
+ * `/outbox/events` + filter. Это редкий кейс (admin-дашборды), и
+ * оптимизировать его отдельно нерационально.
+ *
+ * [earliestEventDate] не имеет своего endpoint'а; возвращает `Clock.System.now()`
+ * (см. KDoc [OutboxStore.earliestEventDate] — для пустого буфера это и есть
+ * контрактное значение). Клиент, который полагался на gap detection через
+ * message store, продолжит работать — просто fallback никогда не сработает.
+ *
+ * **Импорты [CommonEvent]/[AgentEvent]/[Event] идут напрямую из
+ * `pw.binom.agentik.outbox`** — typealias'ы в `:proto.CommonEvent` и т.п.
+ * НЕ поддерживают nested-class access (`CommonEvent.Agent` через alias
+ * даёт "Unresolved qualified name"), поэтому приходится использовать
+ * конкретный пакет. Типы идентичны, alias только для удобства внешнего API.
+ */
+internal class HttpEventStore(
+    private val httpClient: HttpClient,
+    private val baseUrl: String,
+) : OutboxStore {
+
+    private val agentUrl: String = baseUrl.trimEnd('/')
+
+    override fun events(after: Instant?): Flow<CommonEvent> = flow {
+        val url = buildString {
+            append("$agentUrl/outbox/events")
+            if (after != null) append("?after=$after")
+        }
+        httpClient.prepareGet(url) { noSseReadTimeout() }
+            .execute { response ->
+                check(response.status == HttpStatusCode.OK) {
+                    "events: server returned ${response.status}"
+                }
+                readSse(response.bodyAsChannel())
+                    .collect { payload ->
+                        emit(agentikJson.decodeFromString(CommonEvent.serializer(), payload))
+                    }
+            }
+    }
+
+    /**
+     * Override: идём в `/events` напрямую — сервер фильтрует только lifecycle-события.
+     * Default из [EventStore.agentEvents] читал бы `/events/all` + `filterIsInstance`.
+     */
+    override fun agentEvents(after: Instant?): Flow<CommonEvent.Agent> = flow {
+        val url = buildString {
+            append("$agentUrl/events")
+            if (after != null) append("?after=$after")
+        }
+        httpClient.prepareGet(url) { noSseReadTimeout() }
+            .execute { response ->
+                check(response.status == HttpStatusCode.OK) {
+                    "agentEvents: server returned ${response.status}"
+                }
+                readSse(response.bodyAsChannel())
+                    .collect { payload ->
+                        val event = agentikJson.decodeFromString(AgentEvent.serializer(), payload)
+                        emit(CommonEvent.Agent(date = event.date, event = event))
+                    }
+            }
+    }
+
+    /**
+     * Override с `conversationId != null` — идём в `/conversations/{id}/events`.
+     * С `null` (события всех диалогов) — fallback на default impl из [EventStore]:
+     * общий `/events/all` + filter.
+     */
+    override fun conversationEvents(
+        after: Instant?,
+        conversationId: String?,
+    ): Flow<CommonEvent.Conversation> {
+        if (conversationId == null) {
+            return super.conversationEvents(after, null)
+        }
+        return flow {
+            val url = buildString {
+                append("$agentUrl/conversations/$conversationId/events")
+                if (after != null) append("?after=$after")
+            }
+            httpClient.prepareGet(url) { noSseReadTimeout() }
+                .execute { response ->
+                    check(response.status == HttpStatusCode.OK) {
+                        "conversationEvents: server returned ${response.status}"
+                    }
+                    readSse(response.bodyAsChannel())
+                        .collect { payload ->
+                            val event = agentikJson.decodeFromString(Event.serializer(), payload)
+                            emit(CommonEvent.Conversation(date = event.date, conversationId = conversationId, event = event))
+                        }
+                }
+        }
+    }
+
+    /**
+     * У HTTP-варианта нет своего endpoint'а для earliest-event-date.
+     * Контракт [EventStore.earliestEventDate] для пустого буфера говорит
+     * "сейчас" — для HTTP-клиента буфер на нашей стороне всегда "пуст"
+     * (мы не держим своё состояние), поэтому возвращаем `Clock.System.now()`.
+     */
+    override suspend fun earliestEventDate(): Instant = Clock.System.now()
+
+    override fun close() {
+        // HttpClient закрывает владелец (AgentClient / AgentikAgent).
+    }
+}

client/src/commonMain/kotlin/pw/binom/agentik/client/HttpJournalStore.kt

@@ -0,0 +1,60 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.HttpClient
+import io.ktor.client.call.body
+import io.ktor.client.request.get
+import io.ktor.client.request.parameter
+import io.ktor.http.HttpStatusCode
+import pw.binom.agentik.journal.JournalStore
+import pw.binom.agentik.journal.MessageRecord
+import kotlin.time.Instant
+
+/**
+ * HTTP-реализация [JournalStore] (append-only audit log сообщений диалога),
+ * ходящая в `:server`-фасад.
+ *
+ * **Endpoint**: `GET {baseUrl}/journal/conversations/{id}/messages?after=&offset=&limit=`
+ * (см. [pw.binom.agentik.server.journalRoutes]).
+ *
+ * Возвращает raw [MessageRecord] (все типы: UserMessage / AssistantMessage /
+ * ToolCall / ToolResult / Error). В отличие от `GET /conversations/{id}/messages`
+ * в `:server`'s proto-роутах (который отдаёт project'нутые
+ * [pw.binom.agentik.proto.Message]), здесь клиент получает полный transcript
+ * с tool-call/tool-result/error payload'ами, turn-tokens и context'ом.
+ *
+ * **listFlow** — default cold-flow paging через [list] (N+1 round-trip,
+ * дефолтная реализация из [JournalStore]). Для remote/SQL-backed store'а
+ * это OK: server-side paging + client-side flow compose'ится естественно.
+ *
+ * **Read-only**: [JournalStore] не имеет `append` — запись только через
+ * writer-референс, который ChatAgent держит внутри (тип
+ * `MutableJournalStore`, не выставлен наружу через [pw.binom.agentik.proto.Agent]).
+ */
+internal class HttpJournalStore(
+    private val httpClient: HttpClient,
+    private val baseUrl: String,
+) : JournalStore {
+
+    private val agentUrl: String = baseUrl.trimEnd('/')
+
+    override suspend fun list(
+        conversationId: String,
+        after: Instant,
+        offset: Int,
+        limit: Int,
+    ): List<MessageRecord> {
+        val response = httpClient.get("$agentUrl/journal/conversations/$conversationId/messages") {
+            parameter("after", after.toString())
+            parameter("offset", offset)
+            parameter("limit", limit)
+        }
+        check(response.status == HttpStatusCode.OK) {
+            "journal.list: server returned ${response.status}"
+        }
+        return response.body<List<MessageRecord>>()
+    }
+
+    override fun close() {
+        // HttpClient закрывает владелец (AgentClient / AgentikAgent).
+    }
+}

client/src/commonMain/kotlin/pw/binom/agentik/client/ReconnectingOutbox.kt

@@ -0,0 +1,242 @@
+package pw.binom.agentik.client
+
+import kotlinx.coroutines.CancellationException
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.currentCoroutineContext
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
+import pw.binom.agentik.outbox.CommonEvent
+import pw.binom.agentik.outbox.OutboxStore
+import kotlin.concurrent.atomics.AtomicBoolean
+import kotlin.concurrent.atomics.AtomicReference
+import kotlin.concurrent.atomics.ExperimentalAtomicApi
+import kotlin.math.min
+import kotlin.math.pow
+import kotlin.random.Random
+import kotlin.time.Duration
+import kotlin.time.Duration.Companion.seconds
+import kotlin.time.Instant
+
+/**
+ * Состояние подключения к удалённому [OutboxStore]. Эмитится через
+ * [ReconnectingOutbox.connectionStatus] — отдельным потоком, **не**
+ * смешивается с [ReconnectingOutbox.events].
+ *
+ * Типичный цикл:
+ * ```
+ * Connecting(1) → Connected → ... → Disconnected(reason, retryIn) →
+ *   Connecting(2) → Connected → ...
+ * ```
+ * При полном исчерпании попыток ([BackoffPolicy.maxAttempts]) —
+ * финальный [Failed].
+ */
+sealed interface ConnectionStatus {
+
+    /** Начата попытка подключения (включая первую — `attempt == 1`). */
+    data class Connecting(val attempt: Int) : ConnectionStatus
+
+    /** Получен первый event с сервера после [Connecting] / [Disconnected]. */
+    data class Connected(val since: Instant) : ConnectionStatus
+
+    /**
+     * Стрим оборвался (network error, server close, таймаут). [reason] —
+     * причина, `null` если штатное завершение. [willRetryIn] — через сколько
+     * будет следующая попытка (`null` если [Failed]).
+     */
+    data class Disconnected(
+        val reason: Throwable?,
+        val willRetryIn: Duration?,
+    ) : ConnectionStatus
+
+    /**
+     * Все попытки исчерпаны ([BackoffPolicy.maxAttempts]). Поток [events]
+     * закрывается после этого. Создатель [ReconnectingOutbox] должен
+     * решить, что делать — показать ошибку пользователю, пересоздать
+     * outbox и т.п.
+     */
+    data class Failed(val cause: Throwable) : ConnectionStatus
+}
+
+/**
+ * Политика backoff для [ReconnectingOutbox]. Параметры:
+ *
+ * - [initial] — задержка перед первой retry-попыткой.
+ * - [max] — потолок задержки (после серии умножений).
+ * - [multiplier] — множитель на каждом шаге (например, `2.0` → 1s, 2s, 4s, 8s, ...).
+ * - [jitter] — доля случайного разброса `[0, jitter]` от текущей задержки
+ *   (например, `0.2` = ±20%). Снижает thundering-herd при массовом reconnect.
+ * - [maxAttempts] — лимит попыток. `Int.MAX_VALUE` = бесконечно.
+ */
+data class BackoffPolicy(
+    val initial: Duration = 1.seconds,
+    val max: Duration = 30.seconds,
+    val multiplier: Double = 2.0,
+    val maxAttempts: Int = Int.MAX_VALUE,
+    val jitter: Double = 0.2,
+) {
+    init {
+        require(initial > Duration.ZERO) { "initial must be positive" }
+        require(max >= initial) { "max must be >= initial" }
+        require(multiplier >= 1.0) { "multiplier must be >= 1.0" }
+        require(maxAttempts >= 1) { "maxAttempts must be >= 1" }
+        require(jitter in 0.0..1.0) { "jitter must be in [0, 1]" }
+    }
+
+    companion object {
+        /** 1s → 2s → 4s → ... → 30s, jitter ±20%, бесконечные попытки. */
+        val Default: BackoffPolicy = BackoffPolicy()
+
+        /** Только для тестов: фиксированные задержки без разброса. */
+        fun Fixed(delay: Duration, attempts: Int = 3): BackoffPolicy =
+            BackoffPolicy(
+                initial = delay,
+                max = delay,
+                multiplier = 1.0,
+                maxAttempts = attempts,
+                jitter = 0.0,
+            )
+    }
+}
+
+/**
+ * Обёртка над [OutboxStore] с автоматическим reconnect при обрыве стрима.
+ *
+ * **Два независимых потока**:
+ * - [events] — `Flow<CommonEvent>`, тот же контракт что [OutboxStore.events],
+ *   но с автоматическим переподключением через [BackoffPolicy]. Cursor
+ *   (`lastSeen`) сохраняется между попытками — клиент не теряет события.
+ * - [connectionStatus] — `Flow<ConnectionStatus>`, **параллельный** поток
+ *   lifecycle подключения. Не смешивается с [events].
+ *
+ * ```
+ * val outbox = ReconnectingOutbox(httpEventStore, scope)
+ *
+ * scope.launch {
+ *     outbox.events(after = Instant.DISTANT_PAST).collect { e -> handle(e) }
+ * }
+ * scope.launch {
+ *     outbox.connectionStatus().collect { s -> ui.showStatus(s) }
+ * }
+ *
+ * // На выходе:
+ * outbox.close()  // отменяет background-loop, эмитит Cancelled-как-Disconnected
+ * ```
+ *
+ * Создатель передаёт свой [scope] — жизненный цикл reconnect-цикла
+ * привязан к нему. Закрытие scope (или явный [close]) отменяет
+ * background-loop. После [close] оба flow терминируются.
+ */
+class ReconnectingOutbox(
+    private val outbox: OutboxStore,
+    private val scope: CoroutineScope,
+    private val policy: BackoffPolicy = BackoffPolicy.Default,
+    private val random: Random = Random.Default,
+) : AutoCloseable {
+
+    private val _events = MutableSharedFlow<CommonEvent>(
+        replay = 0,
+        extraBufferCapacity = 64,
+        onBufferOverflow = BufferOverflow.DROP_OLDEST,
+    )
+    private val _status = MutableSharedFlow<ConnectionStatus>(
+        replay = 0,
+        extraBufferCapacity = 64,
+        onBufferOverflow = BufferOverflow.DROP_OLDEST,
+    )
+
+    @OptIn(ExperimentalAtomicApi::class)
+    private val started = AtomicBoolean(false)
+    private var job: Job? = null
+
+    @OptIn(ExperimentalAtomicApi::class)
+    private val lastSeen: AtomicReference<Instant?> = AtomicReference(null)
+
+    /**
+     * Live-события из [outbox] с авто-reconnect. [after] — начальный курсор;
+     * учитывается только при первом вызове (любом из [events] /
+     * [connectionStatus]). После reconnect курсор берётся из `date`
+     * последнего виденного события.
+     *
+     * Коллекторы независимы — каждый получает свою копию потока (shared).
+     * Медленный коллектор может пропускать события при переполнении буфера
+     * (`DROP_OLDEST`).
+     */
+    fun events(after: Instant? = null): Flow<CommonEvent> {
+        ensureStarted(after)
+        return _events
+    }
+
+    /**
+     * Lifecycle подключения: [ConnectionStatus.Connecting] /
+     * [ConnectionStatus.Connected] / [ConnectionStatus.Disconnected] /
+     * [ConnectionStatus.Failed]. **Не смешивается** с [events] — это
+     * отдельный поток для UI-индикации статуса сети.
+     */
+    fun connectionStatus(): Flow<ConnectionStatus> {
+        ensureStarted(null)
+        return _status
+    }
+
+    @OptIn(ExperimentalAtomicApi::class)
+    private fun ensureStarted(initialCursor: Instant?) {
+        if (!started.compareAndSet(false, true)) return
+        lastSeen.store(initialCursor)
+        job = scope.launch { runLoop() }
+    }
+
+    @OptIn(ExperimentalAtomicApi::class)
+    private suspend fun runLoop() {
+        var attempt = 0
+        var connected = false
+        while (currentCoroutineContext().isActive) {
+            attempt++
+            _status.emit(ConnectionStatus.Connecting(attempt))
+            val error: Throwable? = try {
+                outbox.events(after = lastSeen.load()).collect { event ->
+                    lastSeen.store(event.date)
+                    _events.emit(event)
+                    if (!connected) {
+                        connected = true
+                        _status.emit(ConnectionStatus.Connected(event.date))
+                    }
+                }
+                null
+            } catch (t: CancellationException) {
+                throw t
+            } catch (t: Throwable) {
+                t
+            }
+            connected = false
+            if (attempt >= policy.maxAttempts) {
+                _status.emit(
+                    ConnectionStatus.Failed(error ?: RuntimeException("outbox flow ended normally"))
+                )
+                return
+            }
+            val backoff = computeBackoff(attempt)
+            _status.emit(ConnectionStatus.Disconnected(error, backoff))
+            delay(backoff)
+        }
+    }
+
+    private fun computeBackoff(attempt: Int): Duration {
+        // attempt 1 → initial, 2 → initial * m, 3 → initial * m^2, ...
+        val base = (policy.initial.inWholeMilliseconds.toDouble() *
+                policy.multiplier.pow((attempt - 1).toDouble()))
+            .toLong()
+        val capped = min(base, policy.max.inWholeMilliseconds)
+        val jitterMs = (capped * policy.jitter * random.nextDouble()).toLong()
+        val finalMs = (capped + jitterMs).coerceAtLeast(1L)
+        return Duration.parse("${finalMs}ms")
+    }
+
+    override fun close() {
+        job?.cancel()
+        job = null
+    }
+}

client/src/commonMain/kotlin/pw/binom/agentik/client/SseTimeout.kt

@@ -0,0 +1,31 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.plugins.HttpTimeoutConfig
+import io.ktor.client.plugins.HttpTimeoutCapability
+import io.ktor.client.request.HttpRequestBuilder
+
+/**
+ * Отключает request/connect/socket-таймауты для конкретного запроса через
+ * [HttpTimeoutCapability] со всеми таймаутами = [HttpTimeoutConfig.INFINITE_TIMEOUT_MS].
+ *
+ * Зачем: наш SSE-ридер ([readSse]) читает `bodyAsChannel()` руками и не
+ * использует плагин `SSE`, поэтому движок не считает запрос SSE-шным
+ * (`HttpRequestBuilder.supportsRequestTimeout` проверяет
+ * `body is SSEClientContent`, а у нас тело — обычный GET без тела).
+ * Без capability встроенный `HttpTimeoutPlugin.requestTimeoutMillis` (по умолчанию
+ * **15000 мс**) молча убивает долгий idle-стрим через 15 секунд.
+ *
+ * Конфиг создаётся заново на каждый вызов — плагин `HttpTimeout` при
+ * установленном capability мутирует его поля через `?:`, так что шаренный
+ * инстанс мог бы утечь между запросами.
+ */
+internal fun HttpRequestBuilder.noSseReadTimeout() {
+    setCapability(
+        HttpTimeoutCapability,
+        HttpTimeoutConfig(
+            requestTimeoutMillis = HttpTimeoutConfig.INFINITE_TIMEOUT_MS,
+            connectTimeoutMillis = HttpTimeoutConfig.INFINITE_TIMEOUT_MS,
+            socketTimeoutMillis = HttpTimeoutConfig.INFINITE_TIMEOUT_MS,
+        ),
+    )
+}

client/src/commonTest/kotlin/pw/binom/agentik/client/BearerHeaderTest.kt

@@ -0,0 +1,106 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.request.get
+import io.ktor.client.statement.bodyAsText
+import io.ktor.http.ContentType
+import io.ktor.http.HttpHeaders
+import io.ktor.http.HttpStatusCode
+import io.ktor.server.application.call
+import io.ktor.server.application.createRouteScopedPlugin
+import io.ktor.server.cio.CIO as ServerCIO
+import io.ktor.server.engine.EmbeddedServer
+import io.ktor.server.engine.embeddedServer
+import io.ktor.server.response.respondText
+import io.ktor.server.routing.get
+import io.ktor.server.routing.route
+import io.ktor.server.routing.routing
+import kotlinx.coroutines.runBlocking
+import kotlin.test.Test
+import kotlin.test.assertEquals
+
+/**
+ * Тесты клиентской части: [agentikHttpClient] с заданным `token` прикладывает
+ * `Authorization: Bearer <token>` ко всем запросам через плагин `DefaultRequest`,
+ * без токена — заголовок не отправляется.
+ *
+ * Сервер в тесте — локальный ktor-CIO с inline route-scoped Bearer-плагином (один в один
+ * как боевой [pw.binom.agentik.server.BearerTokenPlugin]). Тестовый `:server` не зависит
+ * от `:client`, поэтому боевой плагин тут переиспользовать нельзя — пересоздаём его
+ * минимально, контракт тот же.
+ */
+class BearerHeaderTest {
+
+    private val TestBearer = createRouteScopedPlugin(
+        name = "TestBearer",
+        createConfiguration = ::BearerCfg,
+    ) {
+        val expected = pluginConfig.token
+        onCall { call ->
+            if (expected == null) return@onCall
+            if (call.request.headers[HttpHeaders.Authorization] != "Bearer $expected") {
+                call.respondText("Unauthorized", ContentType.Text.Plain, HttpStatusCode.Unauthorized)
+            }
+        }
+    }
+
+    private class BearerCfg {
+        var token: String? = null
+    }
+
+    private fun clientWith(token: String?): HttpClient =
+        agentikHttpClient(engineFactory = CIO, token = token)
+
+    private suspend fun startServer(): Pair<EmbeddedServer<*, *>, Int> {
+        val server = embeddedServer(ServerCIO, port = 0) {
+            routing {
+                route("/agentik") {
+                    install(TestBearer) { token = "secret" }
+                    get("/conversations") {
+                        call.respondText("[]")
+                    }
+                }
+            }
+        }.start(wait = false)
+        val port = server.engine.resolvedConnectors().first().port
+        return server to port
+    }
+
+    @Test
+    fun clientWithTokenAttachesBearerHeader() = runBlocking {
+        val (server, port) = startServer()
+        try {
+            val client = clientWith("secret")
+            val resp = client.get("http://127.0.0.1:$port/agentik/conversations")
+            assertEquals(HttpStatusCode.OK, resp.status)
+            assertEquals("[]", resp.bodyAsText())
+        } finally {
+            server.stop(100, 200)
+        }
+    }
+
+    @Test
+    fun clientWithoutTokenGets401(): Unit = runBlocking {
+        val (server, port) = startServer()
+        try {
+            val client = clientWith(null)
+            val resp = client.get("http://127.0.0.1:$port/agentik/conversations")
+            assertEquals(HttpStatusCode.Unauthorized, resp.status)
+        } finally {
+            server.stop(100, 200)
+        }
+    }
+
+    @Test
+    fun clientWithWrongTokenGets401(): Unit = runBlocking {
+        val (server, port) = startServer()
+        try {
+            val client = clientWith("wrong")
+            val resp = client.get("http://127.0.0.1:$port/agentik/conversations")
+            assertEquals(HttpStatusCode.Unauthorized, resp.status)
+        } finally {
+            server.stop(100, 200)
+        }
+    }
+}

client/src/commonTest/kotlin/pw/binom/agentik/client/ReconnectingOutboxTest.kt

@@ -0,0 +1,211 @@
+package pw.binom.agentik.client
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.emptyFlow
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.test.advanceTimeBy
+import kotlinx.coroutines.test.runCurrent
+import kotlinx.coroutines.test.runTest
+import pw.binom.agentik.outbox.AgentEvent
+import pw.binom.agentik.outbox.CommonEvent
+import pw.binom.agentik.outbox.OutboxStore
+import pw.binom.agentik.outbox.Event
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertNotNull
+import kotlin.test.assertTrue
+import kotlin.time.Duration
+import kotlin.time.Instant
+
+/**
+ * In-memory [OutboxStore] для unit-тестов [ReconnectingOutbox].
+ *
+ * Управление:
+ * - [push] — кладёт [CommonEvent] в очередь, флоу доставит.
+ * - [throwAtNextEvent] — следующий «тик» `events(after)` бросит этот Throwable
+ *   (симулирует network error / stream break).
+ *
+ * Сигнатура [events] идентична боевой — её можно подменить боевым
+ * `HttpEventStore`, контракт один и тот же.
+ */
+internal class FakeOutbox : OutboxStore {
+    private sealed interface Msg {
+        data class Ev(val event: CommonEvent) : Msg
+        data class Err(val throwable: Throwable) : Msg
+    }
+
+    private val channel = Channel<Msg>(Channel.UNLIMITED)
+
+    override fun events(after: Instant?): Flow<CommonEvent> = flow {
+        for (msg in channel) {
+            when (msg) {
+                is Msg.Err -> throw msg.throwable
+                is Msg.Ev -> emit(msg.event)
+            }
+        }
+    }
+
+    fun push(event: CommonEvent) { channel.trySend(Msg.Ev(event)) }
+    fun throwAtNextEvent(t: Throwable) { channel.trySend(Msg.Err(t)) }
+
+    override fun agentEvents(after: Instant?): Flow<CommonEvent.Agent> = emptyFlow()
+    override fun conversationEvents(
+        after: Instant?,
+        conversationId: String?,
+    ): Flow<CommonEvent.Conversation> = emptyFlow()
+    override suspend fun earliestEventDate(): Instant = Instant.DISTANT_PAST
+    override fun close() { channel.close() }
+}
+
+private fun testEvent(dateMs: Long): CommonEvent =
+    CommonEvent.Conversation(
+        date = Instant.fromEpochMilliseconds(dateMs),
+        conversationId = "test",
+        event = Event.End(date = Instant.fromEpochMilliseconds(dateMs)),
+    )
+
+@OptIn(ExperimentalCoroutinesApi::class)
+class ReconnectingOutboxTest {
+
+    @Test
+    fun `first event after connect emits Connecting then Connected`() = runConnectionTest(
+        attempts = 5,
+    ) { ctx ->
+        val fake = ctx.fake
+        val status = ctx.statusLog
+        val events = ctx.eventsLog
+
+        fake.push(testEvent(1000))
+        ctx.advanceAndDrain(50)
+
+        assertEquals(1, status.count { it is ConnectionStatus.Connecting && it.attempt == 1 })
+        assertEquals(1, status.count { it is ConnectionStatus.Connected })
+        assertEquals(1, events.size)
+        assertEquals(Instant.fromEpochMilliseconds(1000), events[0].date)
+    }
+
+    @Test
+    fun `disconnect mid-stream triggers retry with backoff and resumes from last seen`() =
+        runConnectionTest(attempts = 5) { ctx ->
+            val fake = ctx.fake
+            val status = ctx.statusLog
+            val events = ctx.eventsLog
+
+            fake.push(testEvent(1000))
+            ctx.advanceAndDrain(50)
+            assertEquals(1, events.size)
+
+            // Имитируем обрыв стрима после первого события.
+            fake.throwAtNextEvent(RuntimeException("simulated network error"))
+            ctx.advanceAndDrain(50)
+
+            // После Disconnected должен прийти Connecting(2), затем Connected,
+            // затем новые события без дубля предыдущего.
+            val disconnectedIndex = status.indexOfFirst { it is ConnectionStatus.Disconnected }
+            val connecting2Index = status.indexOfFirst {
+                it is ConnectionStatus.Connecting && it.attempt == 2
+            }
+            assertTrue(disconnectedIndex >= 0, "no Disconnected emitted, got: $status")
+            assertTrue(connecting2Index > disconnectedIndex,
+                "expected Connecting(2) after Disconnected, got: $status")
+
+            // Push a new event with later date — cursor preserves lastSeen.
+            fake.push(testEvent(2000))
+            ctx.advanceAndDrain(50)
+
+            assertEquals(2, events.size)
+            assertEquals(Instant.fromEpochMilliseconds(1000), events[0].date)
+            assertEquals(Instant.fromEpochMilliseconds(2000), events[1].date)
+        }
+
+    @Test
+    fun `exhausted attempts emits Failed and closes flow`() = runConnectionTest(
+        attempts = 3,
+    ) { ctx ->
+        val fake = ctx.fake
+
+        // Каждая попытка connect бросает — все 3 попытки fail.
+        for (i in 0 until 3) {
+            fake.throwAtNextEvent(RuntimeException("server is dead #${i + 1}"))
+            ctx.advanceAndDrain(50)
+        }
+
+        val failed = ctx.statusLog.filterIsInstance<ConnectionStatus.Failed>().firstOrNull()
+        assertNotNull(failed) { "expected Failed status, got: ${ctx.statusLog}" }
+        assertTrue(failed.cause is RuntimeException)
+        assertEquals(0, ctx.eventsLog.size)
+    }
+
+    @Test
+    fun `close cancels background loop`() = runConnectionTest(
+        attempts = 5,
+    ) { ctx ->
+        val fake = ctx.fake
+        fake.push(testEvent(1000))
+        ctx.advanceAndDrain(50)
+        assertEquals(1, ctx.eventsLog.size)
+
+        ctx.recon.close()
+        ctx.advanceAndDrain(100)
+
+        // После close запуск новых эмиссий не должен происходить.
+        val beforePush = ctx.eventsLog.size
+        fake.push(testEvent(2000))
+        ctx.advanceAndDrain(100)
+        assertEquals(beforePush, ctx.eventsLog.size)
+    }
+
+    private data class TestCtx(
+        val fake: FakeOutbox,
+        val recon: ReconnectingOutbox,
+        val statusLog: MutableList<ConnectionStatus>,
+        val eventsLog: MutableList<CommonEvent>,
+        val jobs: List<Job>,
+        val scope: CoroutineScope,
+        val advanceAndDrain: (Long) -> Unit,
+    )
+
+    /**
+     * Запускает [ReconnectingOutbox] с policy из `attempts` попыток по 10ms,
+     * сабскрайбит на оба потока в собирающие лист, и возвращает [TestCtx]
+     * с управляемым `advanceAndDrain(ms)` — прокрутить виртуальное время.
+     */
+    @OptIn(ExperimentalCoroutinesApi::class)
+    private fun runConnectionTest(
+        attempts: Int,
+        block: suspend (TestCtx) -> Unit,
+    ) = runTest {
+        val policy = BackoffPolicy.Fixed(
+            delay = Duration.parse("10ms"),
+            attempts = attempts,
+        )
+        val fake = FakeOutbox()
+        val recon = ReconnectingOutbox(
+            outbox = fake,
+            scope = this,
+            policy = policy,
+        )
+        val statusLog = mutableListOf<ConnectionStatus>()
+        val eventsLog = mutableListOf<CommonEvent>()
+        val jobs = listOf(
+            launch { recon.connectionStatus().collect { statusLog.add(it) } },
+            launch { recon.events().collect { eventsLog.add(it) } },
+        )
+        val advanceAndDrain: (Long) -> Unit = { ms ->
+            if (ms > 0) advanceTimeBy(ms)
+            runCurrent()
+        }
+        try {
+            TestCtx(fake, recon, statusLog, eventsLog, jobs, this, advanceAndDrain).also { block(it) }
+        } finally {
+            recon.close()
+            jobs.forEach { it.cancel() }
+            fake.close()
+        }
+    }
+}

client/src/commonTest/kotlin/pw/binom/agentik/client/SseTimeoutTest.kt

@@ -0,0 +1,148 @@
+package pw.binom.agentik.client
+
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.plugins.HttpRequestTimeoutException
+import io.ktor.client.request.header
+import io.ktor.client.request.prepareGet
+import io.ktor.client.statement.bodyAsChannel
+import io.ktor.server.application.call
+import io.ktor.server.engine.embeddedServer
+import io.ktor.server.response.respondBytesWriter
+import io.ktor.server.routing.get
+import io.ktor.server.routing.routing
+import io.ktor.http.ContentType
+import io.ktor.utils.io.writeStringUtf8
+import io.ktor.utils.io.readUTF8Line
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.runBlocking
+import kotlinx.coroutines.withTimeout
+import java.net.ServerSocket
+import kotlin.test.Test
+import kotlin.test.assertFalse
+import kotlin.test.assertNotNull
+import kotlin.test.assertTrue
+import kotlin.test.fail
+
+/**
+ * Репродукция бага Ktor CIO: дефолтный [io.ktor.client.engine.cio.CIOEngineConfig.requestTimeout]
+ * = 15 с убивает SSE read. Наш fix — [noSseReadTimeout] ставит capability
+ * [io.ktor.client.plugins.HttpTimeoutCapability] со всеми таймаутами = INFINITE
+ * перед каждым read-стримом.
+ *
+ * Тест запускает встроенный Ktor CIO-сервер на свободном порту. Сервер шлёт
+ * "hello", ждёт 20 с (дольше дефолтного requestTimeout = 15 с), затем шлёт
+ * "done". Без capability клиент отвалился бы на ~15 с; с capability — второе
+ * сообщение доходит.
+ *
+ * Читаем строки пока не найдём "data: done" или пока не сработает
+ * [withTimeout] (18 с — запас над server delay 20 с).
+ */
+class SseTimeoutTest {
+
+    private fun freePort(): Int = ServerSocket(0).use { it.localPort }
+
+    @Test
+    fun `sse read survives past default cio timeout with noSseReadTimeout`(): Unit = runBlocking {
+        val port = freePort()
+        val server = embeddedServer(io.ktor.server.cio.CIO, port = port) {
+            routing {
+                get("/sse") {
+                    call.respondBytesWriter(contentType = ContentType.Text.EventStream) {
+                        writeStringUtf8("data: hello\n\n")
+                        flush()
+                        // 17 с — чуть больше дефолтного CIO requestTimeout = 15 с.
+                        // Если capability сломана, клиент упадёт на 15 с и не получит "done".
+                        delay(17_000)
+                        writeStringUtf8("data: done\n\n")
+                    }
+                }
+            }
+        }.start(wait = false)
+
+        try {
+            val client = HttpClient(CIO)
+            val received = mutableListOf<String>()
+            client.prepareGet("http://127.0.0.1:$port/sse") {
+                header("Accept", "text/event-stream")
+                noSseReadTimeout()
+            }.execute { resp ->
+                val ch = resp.bodyAsChannel()
+                // 19 с запас: ждём, пока сервер пошлёт "done" после 17 с.
+                // Если capability сломана, клиент упадёт на 15 с и мы словим исключение.
+                val deadline = 19_000L
+                val start = System.currentTimeMillis()
+                while (System.currentTimeMillis() - start < deadline) {
+                    val line = withTimeout<String?>(deadline) { ch.readUTF8Line() } ?: break
+                    if (line.startsWith("data: ")) {
+                        received.add(line)
+                    }
+                    if (line == "data: done") break
+                }
+            }
+            assertTrue(received.contains("data: hello"), "должно получить hello: $received")
+            assertTrue(
+                received.contains("data: done"),
+                "должно получить done (SSE read не должен падать на 15 с): $received",
+            )
+            assertFalse(
+                received.any { it == "<timeout>" },
+                "SSE read упал в timeout (capability не сработал): $received",
+            )
+        } finally {
+            server.stop(100, 200)
+        }
+    }
+
+    /**
+     * Контр-тест: убеждаемся что БЕЗ [noSseReadTimeout] дефолтный
+     * CIO requestTimeout = 15 с действительно убивает SSE-стрим.
+     * Сервер держит stream 17 с; если клиент не выставил capability —
+     * мы должны получить [HttpRequestTimeoutException] на ~15 с, не
+     * дожидаясь "done".
+     */
+    @Test
+    fun `without noSseReadTimeout default cio requestTimeout kills the stream`(): Unit = runBlocking {
+        val port = freePort()
+        val server = embeddedServer(io.ktor.server.cio.CIO, port = port) {
+            routing {
+                get("/sse") {
+                    call.respondBytesWriter(contentType = ContentType.Text.EventStream) {
+                        writeStringUtf8("data: hello\n\n")
+                        flush()
+                        delay(17_000)
+                        writeStringUtf8("data: done\n\n")
+                    }
+                }
+            }
+        }.start(wait = false)
+
+        try {
+            val client = HttpClient(CIO)
+            val start = System.currentTimeMillis()
+            try {
+                client.prepareGet("http://127.0.0.1:$port/sse") {
+                    header("Accept", "text/event-stream")
+                    // НАМЕРЕННО без noSseReadTimeout.
+                }.execute { resp ->
+                    val ch = resp.bodyAsChannel()
+                    // Читаем строки, пока не придёт "data: done" — без capability
+                    // клиент упадёт на ~15 с до того, как сервер пошлёт done.
+                    while (true) {
+                        val line = ch.readUTF8Line() ?: break
+                        if (line == "data: done") break
+                    }
+                }
+                fail("без capability клиент должен словить HttpRequestTimeoutException")
+            } catch (e: HttpRequestTimeoutException) {
+                val elapsed = System.currentTimeMillis() - start
+                assertTrue(
+                    elapsed in 14_000..17_000,
+                    "timeout должен сработать в районе 15 с (default), elapsed=$elapsed",
+                )
+            }
+        } finally {
+            server.stop(100, 200)
+        }
+    }
+}

client/src/main/kotlin/pw/binom/agentik/client/AgentikAgent.kt

@@ -1,43 +0,0 @@
-package pw.binom.agentik.client
-
-import io.ktor.client.HttpClient
-import io.ktor.client.engine.cio.CIO
-import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
-import io.ktor.serialization.kotlinx.json.json
-import pw.binom.agentik.proto.Agent
-
-/**
- * Создаёт [Agent], который под капотом ходит в HTTP-фасад `agentikAgent`
- * (модуль `:server`).
- *
- * ```
- * val client = AgentikAgent(
- *     id = "my-agent",
- *     baseUrl = "http://localhost:8080/agentik",
- * )
- * val conv = client.createConversation(temp = false)
- * conv.send(listOf(Content.Text("hi")))
- * conv.events(Instant.DISTANT_PAST).collect { ev -> ... }
- * ```
- *
- * [id] пробрасывается в реализацию [Agent.id] — сервер про идентичность
- * агента не знает, поэтому клиент должен её знать сам (или взять из
- * конфига).
- *
- * [httpClient] по умолчанию — [defaultAgentikHttpClient] (CIO + JSON +
- * SSE). Можно передать свой, если нужен свой engine/логирование/аутентификация.
- */
-fun AgentikAgent(
-    id: String,
-    baseUrl: String,
-    httpClient: HttpClient = defaultAgentikHttpClient(),
-): Agent = AgentClient(httpClient = httpClient, baseUrl = baseUrl, id = id)
-
-/**
- * Дефолтный [HttpClient] для общения с `agentikAgent`: CIO-движок и
- * kotlinx-serialization с тем же wire-форматом, что на сервере. SSE-парсер
- * (см. [readSse]) живёт в общем коде и плагина не требует.
- */
-fun defaultAgentikHttpClient(): HttpClient = HttpClient(CIO) {
-    install(ContentNegotiation) { json(agentikJson) }
-}

context-api/build.gradle.kts

@@ -0,0 +1,38 @@
+plugins {
+    alias(libs.plugins.kotlin.multiplatform)
+    alias(libs.plugins.kotlin.serialization)
+}
+
+// Public API для runtime context агента (compaction, order_idx, summary entries).
+// Зависит от :journal-api для типов `Content` / `MessageContext` (audit-log
+// payload'ы, которые рабочая память ссылает).
+//
+// НЕ нужен тонким клиентам — только серверному рантайму (`:standalone`, `:agentik-cli`,
+// будущий `:android-agent` core).
+
+kotlin {
+    jvmToolchain(21)
+
+    jvm()
+    macosX64()
+    macosArm64()
+    iosX64()
+    iosArm64()
+    iosSimulatorArm64()
+    linuxX64()
+    linuxArm64()
+    mingwX64()
+
+    sourceSets {
+        commonMain.dependencies {
+            api(project(":journal-api"))
+            api(libs.kotlinx.coroutines.core)
+            api(libs.kotlinx.serialization.core)
+            api(libs.kotlinx.serialization.json)
+        }
+        commonTest.dependencies {
+            implementation(kotlin("test"))
+            implementation(libs.kotlinx.coroutines.test)
+        }
+    }
+}

context-api/src/commonMain/kotlin/pw/binom/agentik/context/ContextStore.kt

@@ -1,4 +1,4 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.context
 
 import kotlin.time.Instant
 
@@ -7,7 +7,7 @@ import kotlin.time.Instant
  *
  * Используется для тестов и для перестроения [WorkingMemoryEntry] из row.
  * Агент не должен с этим типом работать напрямую — он работает с
- * [WorkingMemoryEntry] через [WorkingMemoryStore].
+ * [WorkingMemoryEntry] через [ContextStore].
  */
 data class WorkingMemoryRow(
     val id: String,
@@ -28,7 +28,7 @@ data class WorkingMemoryRow(
  *
  * Суммаризация / чистка — один атомарный вызов [compact].
  */
-interface WorkingMemoryStore : AutoCloseable {
+interface ContextStore : AutoCloseable {
 
     /** Добавить запись в конец working memory (новый максимальный `order_idx`). */
     suspend fun append(conversationId: String, entry: WorkingMemoryEntry, now: Instant)

context-api/src/commonMain/kotlin/pw/binom/agentik/context/WorkingMemoryEntry.kt

@@ -1,7 +1,9 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.context
 
 import kotlinx.serialization.SerialName
 import kotlinx.serialization.Serializable
+import pw.binom.agentik.journal.Content
+import pw.binom.agentik.journal.MessageContext
 
 /**
  * Запись в working memory диалога: ровно то, что агент сейчас видит в

context-ksqlite/build.gradle.kts

@@ -0,0 +1,43 @@
+plugins {
+    alias(libs.plugins.kotlin.multiplatform)
+    alias(libs.plugins.kotlin.serialization)
+}
+
+// KMP-реализация :context-api (ContextStore) поверх ksqlite.
+// Минимальная — только таблица `working_memory` + 2 индекса по ней.
+// Остальные таблицы (`conversation`, `message`, `reflection`) живут в
+// других ksqlite-модулях; этот модуль не претендует на полную схему
+// агента.
+//
+// Цели сборки — jvm() + linuxX64() + mingwX64(); Apple targets auto-disabled
+// на Linux (см. KDoc :storage-ksqlite).
+
+kotlin {
+    jvmToolchain(21)
+
+    jvm()
+    linuxX64()
+    mingwX64()
+
+    sourceSets {
+        commonMain.dependencies {
+            // ksqlite 0.1.2 опубликован в Maven Central — обычный
+            // `mavenCentral()` в settings.gradle.kts его подтянет.
+            implementation("pw.binom.db:ksqlite:0.1.2")
+            implementation(libs.kotlinx.serialization.json)
+
+            api(project(":context-api"))
+            api(project(":journal-api"))
+            api(project(":reflection-api"))
+            // :context-api ссылается на Content / MessageContext из
+            // :message-log-api (старый canonical). Транзитивно через api,
+            // но фиксируем явно чтобы тестовый код видел Content без
+            // обхода через :context-api.
+//            api(project(":message-log-api"))
+        }
+        commonTest.dependencies {
+            implementation(kotlin("test"))
+            implementation(libs.kotlinx.coroutines.test)
+        }
+    }
+}

context-ksqlite/src/commonMain/kotlin/pw/binom/agentik/context/ksqlite/KsqliteContextStore.kt

@@ -0,0 +1,200 @@
+package pw.binom.agentik.context.ksqlite
+
+import kotlinx.serialization.json.Json
+import pw.binom.agentik.context.ContextStore
+import pw.binom.agentik.context.WorkingMemoryEntry
+import pw.binom.agentik.context.WorkingMemoryRow
+import pw.binom.agentik.journal.Ids
+import pw.binom.db.ksqlite.SQLiteConnection
+import pw.binom.db.ksqlite.SQLitePreparedStatement
+import kotlin.time.Clock
+import kotlin.time.Instant
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.sync.Mutex
+import kotlinx.coroutines.sync.withLock
+import kotlinx.coroutines.withContext
+
+/**
+ * ksqlite-реализация [ContextStore] (таблица `working_memory`).
+ *
+ * Структура — копия [pw.binom.agentik.storage.ksqlite.KsqliteWorkingMemoryStore]
+ * из `:storage-ksqlite`, но:
+ *   - лежит в собственном модуле `:context-ksqlite`;
+ *   - реализует переименованный [ContextStore] (раньше был `WorkingMemoryStore`,
+ *     теперь главный класс — `ContextStore`); сами типы строк
+ *     [WorkingMemoryEntry] / [WorkingMemoryRow] не переименовывались.
+ *
+ * ВНИМАНИЕ: `:storage-ksqlite/KsqliteWorkingMemoryStore.kt` остаётся на диске —
+ * это копия, не замена. Не удалять старый файл; миграция consumers'ов — отдельно.
+ */
+class KsqliteContextStore(
+    private val connection: SQLiteConnection,
+) : ContextStore {
+
+    private val mutex = Mutex()
+    private val json = Json { ignoreUnknownKeys = true }
+
+    // pre-prepare (см. KsqliteMessageStore KDoc — почему это критично против
+    // SIGSEGV в StmtHolder.finalize на закрытой connection).
+    private val insertStmt: SQLitePreparedStatement = connection.prepare(
+        """
+        INSERT INTO ${Schema.TABLE_WORKING_MEMORY}
+            (${Schema.COL_ID}, ${Schema.COL_CONVERSATION_ID}, ${Schema.COL_ORDER_IDX},
+             ${Schema.COL_SOURCE_MESSAGE_ID}, ${Schema.COL_KIND},
+             ${Schema.COL_PAYLOAD_JSON}, ${Schema.COL_CREATED_AT})
+        VALUES (?, ?, ?, ?, ?, ?, ?)
+        """.trimIndent()
+    )
+    private val listStmt: SQLitePreparedStatement = connection.prepare(
+        """
+        SELECT ${Schema.COL_ID}, ${Schema.COL_CONVERSATION_ID}, ${Schema.COL_ORDER_IDX},
+               ${Schema.COL_SOURCE_MESSAGE_ID}, ${Schema.COL_PAYLOAD_JSON}, ${Schema.COL_CREATED_AT}
+        FROM ${Schema.TABLE_WORKING_MEMORY}
+        WHERE ${Schema.COL_CONVERSATION_ID} = ?
+        ORDER BY ${Schema.COL_ORDER_IDX} ASC
+        """.trimIndent()
+    )
+    private val clearStmt: SQLitePreparedStatement = connection.prepare(
+        "DELETE FROM ${Schema.TABLE_WORKING_MEMORY} WHERE ${Schema.COL_CONVERSATION_ID} = ?"
+    )
+    private val maxOrderIdxStmt: SQLitePreparedStatement = connection.prepare(
+        """
+        SELECT COALESCE(MAX(${Schema.COL_ORDER_IDX}), 0)
+        FROM ${Schema.TABLE_WORKING_MEMORY}
+        WHERE ${Schema.COL_CONVERSATION_ID} = ?
+        """.trimIndent()
+    )
+    private val dropFromIdxStmt: SQLitePreparedStatement = connection.prepare(
+        """
+        DELETE FROM ${Schema.TABLE_WORKING_MEMORY}
+        WHERE ${Schema.COL_CONVERSATION_ID} = ? AND ${Schema.COL_ORDER_IDX} >= ?
+        """.trimIndent()
+    )
+    private val insertSummaryStmt: SQLitePreparedStatement = connection.prepare(
+        """
+        INSERT INTO ${Schema.TABLE_WORKING_MEMORY}
+            (${Schema.COL_ID}, ${Schema.COL_CONVERSATION_ID}, ${Schema.COL_ORDER_IDX},
+             ${Schema.COL_SOURCE_MESSAGE_ID}, ${Schema.COL_KIND},
+             ${Schema.COL_PAYLOAD_JSON}, ${Schema.COL_CREATED_AT})
+        VALUES (?, ?, ?, NULL, ?, ?, ?)
+        """.trimIndent()
+    )
+
+    override suspend fun append(conversationId: String, entry: WorkingMemoryEntry, now: Instant): Unit = withContext(Dispatchers.Default) {
+        mutex.withLock {
+            val newIdx = maxOrderIdx(conversationId) + 1
+            insertStmt.reset()
+            insertStmt.clearBindings()
+            insertStmt.bindText(1, Ids.new("wm"))
+            insertStmt.bindText(2, conversationId)
+            insertStmt.bindLong(3, newIdx)
+            val srcId = entry.sourceMessageId
+            if (srcId != null) insertStmt.bindText(4, srcId) else insertStmt.bindNull(4)
+            insertStmt.bindText(5, entryKind(entry))
+            insertStmt.bindText(6, json.encodeToString(WorkingMemoryEntry.serializer(), entry))
+            insertStmt.bindLong(7, now.toEpochMilliseconds())
+            insertStmt.executeUpdate()
+        }
+    }
+
+    override suspend fun list(conversationId: String): List<WorkingMemoryRow> = withContext(Dispatchers.Default) {
+        mutex.withLock {
+            listStmt.reset()
+            listStmt.clearBindings()
+            listStmt.bindText(1, conversationId)
+            val out = mutableListOf<WorkingMemoryRow>()
+            listStmt.executeQuery().use { rs ->
+                while (rs.next()) {
+                    out.add(
+                        WorkingMemoryRow(
+                            id = rs.getText(0)!!,
+                            conversationId = rs.getText(1)!!,
+                            orderIdx = rs.getLong(2)!!,
+                            sourceMessageId = rs.getText(3),
+                            entry = Json.decodeFromString(WorkingMemoryEntry.serializer(), rs.getText(4)!!),
+                            createdAt = Instant.fromEpochMilliseconds(rs.getLong(5)!!),
+                        )
+                    )
+                }
+            }
+            out
+        }
+    }
+
+    override suspend fun clear(conversationId: String): Unit = withContext(Dispatchers.Default) {
+        mutex.withLock {
+            clearStmt.reset()
+            clearStmt.clearBindings()
+            clearStmt.bindText(1, conversationId)
+            clearStmt.executeUpdate()
+        }
+    }
+
+    override suspend fun compact(
+        dropFromOrderIdx: Long,
+        conversationId: String,
+        summaryText: String?,
+    ): Long = withContext(Dispatchers.Default) {
+        mutex.withLock {
+            var newMax = 0L
+            val nowMs = Clock.System.now().toEpochMilliseconds()
+            val summaryId = Ids.new("wm")
+            connection.exec("BEGIN")
+            try {
+                dropFromIdxStmt.reset()
+                dropFromIdxStmt.clearBindings()
+                dropFromIdxStmt.bindText(1, conversationId)
+                dropFromIdxStmt.bindLong(2, dropFromOrderIdx)
+                dropFromIdxStmt.executeUpdate()
+
+                if (!summaryText.isNullOrBlank()) {
+                    val afterDelete = maxOrderIdx(conversationId)
+                    val newIdx = afterDelete + 1
+                    insertSummaryStmt.reset()
+                    insertSummaryStmt.clearBindings()
+                    insertSummaryStmt.bindText(1, summaryId)
+                    insertSummaryStmt.bindText(2, conversationId)
+                    insertSummaryStmt.bindLong(3, newIdx)
+                    insertSummaryStmt.bindText(4, "summary")
+                    insertSummaryStmt.bindText(5, json.encodeToString(WorkingMemoryEntry.serializer(), WorkingMemoryEntry.Summary(text = summaryText)))
+                    insertSummaryStmt.bindLong(6, nowMs)
+                    insertSummaryStmt.executeUpdate()
+                    newMax = newIdx
+                } else {
+                    newMax = maxOrderIdx(conversationId)
+                }
+                connection.exec("COMMIT")
+            } catch (t: Throwable) {
+                runCatching { connection.exec("ROLLBACK") }
+                throw t
+            }
+            newMax
+        }
+    }
+
+    override fun close() {
+        insertStmt.close()
+        listStmt.close()
+        clearStmt.close()
+        maxOrderIdxStmt.close()
+        dropFromIdxStmt.close()
+        insertSummaryStmt.close()
+    }
+
+    private fun maxOrderIdx(conversationId: String): Long {
+        maxOrderIdxStmt.reset()
+        maxOrderIdxStmt.clearBindings()
+        maxOrderIdxStmt.bindText(1, conversationId)
+        maxOrderIdxStmt.executeQuery().use { rs ->
+            if (rs.next()) return rs.getLong(0) ?: 0L
+        }
+        return 0L
+    }
+
+    private fun entryKind(e: WorkingMemoryEntry): String = when (e) {
+        is WorkingMemoryEntry.User -> "user"
+        is WorkingMemoryEntry.Assistant -> "assistant"
+        is WorkingMemoryEntry.ToolExchange -> "tool_exchange"
+        is WorkingMemoryEntry.Summary -> "summary"
+    }
+}

context-ksqlite/src/commonMain/kotlin/pw/binom/agentik/context/ksqlite/Schema.kt

@@ -0,0 +1,98 @@
+package pw.binom.agentik.context.ksqlite
+
+import pw.binom.db.ksqlite.SQLiteConnection
+
+/**
+ * Имена таблиц/колонок/индексов для ksqlite-бэкенда `:context-api`.
+ *
+ * Минимум — только то, что относится к `working_memory` (реализация
+ * [KsqliteContextStore]). Остальные таблицы агента (`conversation`,
+ * `message`, `reflection`) живут в других ksqlite-модулях.
+ *
+ * Все DDL/DML в этом модуле должны ссылаться на эти константы — никаких
+ * хардкоженных литералов в `prepare("SELECT ... FROM foo ...")` в store'е.
+ */
+internal object Schema {
+
+    /** Версия схемы модуля. Увеличивать при ЛЮБОМ изменении DDL. */
+    const val CURRENT_VERSION: Int = 1
+
+    // ───── Таблица ─────
+    const val TABLE_WORKING_MEMORY = "working_memory"
+
+    // ───── Колонки ─────
+    const val COL_ID = "id"
+    const val COL_CONVERSATION_ID = "conversation_id"
+    const val COL_ORDER_IDX = "order_idx"
+    const val COL_SOURCE_MESSAGE_ID = "source_message_id"
+    const val COL_KIND = "kind"
+    const val COL_PAYLOAD_JSON = "payload_json"
+    const val COL_CREATED_AT = "created_at"
+
+    // ───── Индексы ─────
+    const val IDX_WM_UNIQUE = "idx_wm_unique"
+    const val IDX_WM_CONV = "idx_wm_conv"
+
+    private val v1Ddl = """
+        CREATE TABLE IF NOT EXISTS $TABLE_WORKING_MEMORY (
+            $COL_ID                TEXT NOT NULL PRIMARY KEY,
+            $COL_CONVERSATION_ID   TEXT NOT NULL,
+            $COL_ORDER_IDX         INTEGER NOT NULL,
+            $COL_SOURCE_MESSAGE_ID TEXT,
+            $COL_KIND              TEXT NOT NULL,
+            $COL_PAYLOAD_JSON      TEXT NOT NULL,
+            $COL_CREATED_AT        INTEGER NOT NULL
+        );
+    """.trimIndent()
+
+    private val v1IndexesDdl = """
+        CREATE UNIQUE INDEX IF NOT EXISTS $IDX_WM_UNIQUE
+            ON $TABLE_WORKING_MEMORY($COL_CONVERSATION_ID, $COL_ORDER_IDX);
+        CREATE INDEX IF NOT EXISTS $IDX_WM_CONV
+            ON $TABLE_WORKING_MEMORY($COL_CONVERSATION_ID, $COL_ORDER_IDX);
+    """.trimIndent()
+
+    /**
+     * Прогоняет миграцию схемы до [CURRENT_VERSION] на пустой или существующей БД.
+     *
+     * Версия хранится в `PRAGMA user_version` (стандартный SQLite-механизм,
+     * 32-bit int в заголовке БД — без своей таблицы). Каждая миграция —
+     * блок DDL под номером `fromV+1`, выполняется в транзакции. Если миграция
+     * упадёт посередине — `ROLLBACK` оставит БД на предыдущей версии.
+     *
+     * Идемпотентен: повторный вызов на уже мигрированной БД — no-op.
+     */
+    fun migrate(conn: SQLiteConnection) {
+        val current = readUserVersion(conn)
+        if (current >= CURRENT_VERSION) return
+
+        conn.exec("BEGIN")
+        try {
+            if (current < 1) {
+                conn.exec(v1Ddl)
+                conn.exec(v1IndexesDdl)
+            }
+            // future: if (current < 2) { conn.exec(v2Ddl) }
+            writeUserVersion(conn, CURRENT_VERSION)
+            conn.exec("COMMIT")
+        } catch (t: Throwable) {
+            runCatching { conn.exec("ROLLBACK") }
+            throw t
+        }
+    }
+
+    private fun readUserVersion(conn: SQLiteConnection): Int {
+        conn.prepare("PRAGMA user_version").use { stmt ->
+            stmt.executeQuery().use { rs ->
+                if (rs.next()) return rs.getLong(0)?.toInt() ?: 0
+            }
+        }
+        return 0
+    }
+
+    private fun writeUserVersion(conn: SQLiteConnection, version: Int) {
+        // SQLite PRAGMA с literal-аргументом нельзя параметризовать через `?`,
+        // поэтому собираем SQL строкой (значение контролируемое, не user input).
+        conn.exec("PRAGMA user_version = $version")
+    }
+}

context-ksqlite/src/commonTest/kotlin/pw/binom/agentik/context/ksqlite/KsqliteContextStoreTest.kt

@@ -0,0 +1,107 @@
+package pw.binom.agentik.context.ksqlite
+
+import kotlinx.coroutines.test.runTest
+import pw.binom.agentik.context.WorkingMemoryEntry
+import pw.binom.agentik.journal.Content
+import pw.binom.db.ksqlite.SQLiteConnection
+import kotlin.test.AfterTest
+import kotlin.test.BeforeTest
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertTrue
+import kotlin.time.Instant
+
+/**
+ * Тесты для [KsqliteContextStore] — точная копия
+ * `KsqliteWorkingMemoryStoreTest` из `:storage-ksqlite`, с переименованием
+ * типов (`WorkingMemoryStore` → `ContextStore`) и обновлённым пакетом для
+ * `Content` (`pw.binom.agentik.journal` — новый canonical, но структура
+ * та же).
+ *
+ * Тестовая фикстура: in-memory SQLiteConnection, [Schema.migrate] в @BeforeTest,
+ * `KsqliteContextStore(conn)` + ручной close в @AfterTest. Никакой внешней
+ * зависимости от `KsqliteStores` из `:storage-ksqlite` — этот модуль
+ * автономный.
+ */
+class KsqliteContextStoreTest {
+
+    private lateinit var conn: SQLiteConnection
+    private lateinit var store: KsqliteContextStore
+
+    @BeforeTest
+    fun setup() {
+        conn = SQLiteConnection.memory("ctx-${kotlin.random.Random.nextLong()}")
+        Schema.migrate(conn)
+        store = KsqliteContextStore(conn)
+    }
+
+    @AfterTest
+    fun tearDown() {
+        store.close()
+        conn.close()
+    }
+
+    private fun userMsg(content: String, srcId: String = "m-${content.hashCode()}"): WorkingMemoryEntry.User =
+        WorkingMemoryEntry.User(sourceMessageId = srcId, content = listOf(Content.Text(content)))
+
+    private fun asstMsg(content: String): WorkingMemoryEntry.Assistant =
+        WorkingMemoryEntry.Assistant(sourceMessageId = "m-${content.hashCode()}", content = listOf(Content.Text(content)))
+
+    @Test
+    fun testAppendAndListReturnsInOrder() = runTest {
+        val t = Instant.parse("2026-09-15T10:00:00Z")
+        store.append("c1", userMsg("first"), t)
+        store.append("c1", asstMsg("reply"), t)
+        val list = store.list("c1")
+        assertEquals(2, list.size)
+        assertEquals(1L, list[0].orderIdx)
+        assertEquals(2L, list[1].orderIdx)
+    }
+
+    @Test
+    fun testListIsolatesConversations() = runTest {
+        val t = Instant.parse("2026-09-15T10:00:00Z")
+        store.append("c1", userMsg("c1-msg"), t)
+        store.append("c2", userMsg("c2-msg"), t)
+        assertEquals(1, store.list("c1").size)
+        assertEquals(1, store.list("c2").size)
+    }
+
+    @Test
+    fun testClearRemovesAllForConversation() = runTest {
+        val t = Instant.parse("2026-09-15T10:00:00Z")
+        store.append("c1", userMsg("a"), t)
+        store.append("c1", userMsg("b"), t)
+        store.clear("c1")
+        assertEquals(emptyList(), store.list("c1"))
+    }
+
+    @Test
+    fun testCompactDeletesAndInsertsSummary() = runTest {
+        val t = Instant.parse("2026-09-15T10:00:00Z")
+        store.append("c1", userMsg("a"), t)
+        store.append("c1", userMsg("b"), t)
+        store.append("c1", userMsg("c"), t)
+        // dropFromOrderIdx=2: удаляет idx=2 и idx=3 (b и c), остаётся idx=1 (a).
+        // Summary встаёт на idx=2 (= max(remaining)+1). Возвращает newMax=2.
+        val newMax = store.compact(dropFromOrderIdx = 2, conversationId = "c1", summaryText = "summary")
+        assertEquals(2L, newMax)
+        val remaining = store.list("c1")
+        assertEquals(2, remaining.size)
+        assertEquals(1L, remaining[0].orderIdx)
+        assertEquals(2L, remaining[1].orderIdx)
+        assertTrue(remaining[1].entry is WorkingMemoryEntry.Summary)
+    }
+
+    @Test
+    fun testCompactWithoutSummaryKeepsTailBelow() = runTest {
+        val t = Instant.parse("2026-09-15T10:00:00Z")
+        store.append("c1", userMsg("a"), t)
+        // dropFromOrderIdx=2: удаляет idx >= 2, остаётся idx=1.
+        val newMax = store.compact(dropFromOrderIdx = 2, conversationId = "c1", summaryText = null)
+        assertEquals(1L, newMax)
+        val remaining = store.list("c1")
+        assertEquals(1, remaining.size)
+        assertEquals(1L, remaining[0].orderIdx)
+    }
+}

docs/ARCHITECTURE.md

@@ -118,7 +118,7 @@ Main.kt
 - `compact(dropFromOrderIdx, conversationId)` — v1: DELETE rows ≥ order_idx,
   summarization-вставка отложена (нужен дизайн-проработка).
 
-**`MessageStore`** — append-only аудит. На каждый ход дописываются
+**`JournalStore`** — append-only аудит. На каждый ход дописываются
 `UserMessage`, `AssistantMessage`, `ToolCall`, `ToolResult`, `Error`. Никаких
 update/delete кроме каскада из `ConversationStore.delete`.
 

docs/STANDALONE.md

@@ -175,7 +175,7 @@ fun main() {
 
 **Ошибки хода персистятся.** Если ход провалился (LLM/движок недоступны — например, HTTP 400 от endpoint'а), `ChatConversation.failTurn` пишет терминальную запись `MessageRecord.Error` в audit и эмитит `Event.Error` + `Event.End`. Благодаря audit-записи ошибка видна не только подписчику live-SSE, но и клиенту, который делает backfill через `getMessages` (polling/переподключение): в истории будет `Message.Error(id, message, code?)`, а для этого user-сообщения не будет `AssistantMessage`. При ошибке стрима живой `LiteConversation` сбрасывается — следующий `send` пересоберёт его из `working_memory`. В working_memory `Error` не пишется (модель не должна видеть ошибки прошлых ходов).
 
-### `MessageStore`
+### `JournalStore`
 
 ```kotlin
 suspend fun append(record: MessageRecord)
@@ -183,7 +183,7 @@ suspend fun list(conversationId: String, after: Instant, offset: Int, limit: Int
 suspend fun listAll(conversationId: String): List<MessageRecord>
 ```
 
-### `WorkingMemoryStore`
+### `ContextStore`
 
 ```kotlin
 suspend fun append(conversationId: String, entry: WorkingMemoryEntry, now: Instant)

docs/diagrams/01-module-layers.md

@@ -0,0 +1,158 @@
+# 01 — Слои модулей (целевое состояние)
+
+Целевая модульная структура agentik. Снизу вверх:
+**приложения → runtime → домен → абстракции → платформенные impl**.
+
+![Module Layers](./01-module-layers.svg)
+
+PlantUML source (для редактирования; требует Graphviz `dot` для рендеринга):
+
+```plantuml
+@startuml agentik-module-layers
+skinparam componentStyle rectangle
+skinparam ranksep 60
+skinparam nodesep 30
+skinparam packageStyle rectangle
+
+title agentik — слои модулей (целевое состояние)
+
+' --- Applications: entry points (thin wrappers) ---
+package "Applications\n(entry points, тонкие)" {
+    [Standalone\nHTTP+AG-UI+A2A] as Standalone
+    [AgentikCli\nREPL] as Cli
+    [AgentikAndroid\nCompose UI] as Android
+}
+
+' --- Agent runtime ---
+package "Agent Runtime\n(композиция, lifecycle)" {
+    [AgentCore\nBaseAgent] as AgentCore
+    [AgentBuilder\nDSL] as Builder
+}
+
+' --- Background work ---
+package "Background Work\n(event-driven triggers)" {
+    [BackgroundEvents\nbus + events] as Ev
+    [BackgroundScheduler\npolicy] as Sched
+}
+
+' --- Domain logic (generic, переиспользуется) ---
+package "Domain Logic\n(generic tools)" {
+    [LlmTools\nReflector/Reviewer/Miner] as LlmT
+    [McpBridge\nMCP-SDK → LiteTool] as Mcp
+    [Skills\nparse + store] as Skills
+}
+
+' --- Storage abstractions + impls ---
+package "Storage\n(abstractions)" as StoragePkg {
+    [StorageCore\ninterfaces] as StorageCore
+}
+
+package "Storage\n(JVM impls)" {
+    [StorageSqlite\nJDBC] as StorageSql
+    [StorageInmemory\ntests] as StorageInmem
+}
+
+package "Storage\n(Android impl)" {
+    [StorageSqliteAndroid\nRoom/sqlite] as StorageSqlA
+}
+
+' --- Memory backends ---
+package "Memory\n(abstractions)" {
+    [MemoryApi\nMemorySystem/MemoryTools] as MemApi
+}
+
+package "Memory\n(impls)" {
+    [MemoryMd\nHermes §-files] as MemMd
+    [MemoryVector\nJVector+JVM] as MemVec
+    [MemoryVectorAndroid\nONNX+ANN] as MemVecA
+}
+
+' --- LLM backends ---
+package "LLM\n(abstractions)" {
+    [LitertApi\nLiteLlm контракт] as Litert
+}
+
+package "LLM\n(impls)" {
+    [LitertOpenai\nHTTP] as LitertO
+    [LitertGoogle\nLiteRT JVM] as LitertG
+    [LitertAndroid\nLiteRT Android] as LitertA
+}
+
+' --- Inter-app protocol ---
+package "Inter-app" {
+    [Proto\nAgent/Conversation] as Proto
+    [A2AServer] as A2A
+}
+
+' --- Зависимости (приложения → runtime → домен → абстракции → платформенные импл) ---
+Standalone ..> Builder
+Cli ..> Builder
+Android ..> Builder
+
+Builder ..> AgentCore
+AgentCore ..> Proto
+AgentCore ..> StorageCore
+AgentCore ..> MemApi
+AgentCore ..> Litert
+AgentCore ..> Mcp
+AgentCore ..> Skills
+
+Sched ..> Ev
+AgentCore ..> Sched
+AgentCore ..> Ev
+
+Mcp ..> Litert
+LlmT ..> Litert
+
+MemMd ..> MemApi
+MemVec ..> MemApi
+MemVecA ..> MemApi
+
+StorageSql ..> StorageCore
+StorageInmem ..> StorageCore
+StorageSqlA ..> StorageCore
+
+LitertO ..> Litert
+LitertG ..> Litert
+LitertA ..> Litert
+
+Standalone ..> A2A
+Standalone ..> LitertO
+Standalone ..> LitertG
+Standalone ..> StorageSql
+Standalone ..> MemMd
+Standalone ..> MemVec
+Standalone ..> Mcp
+
+Android ..> LitertA
+Android ..> StorageSqlA
+Android ..> MemMd
+Android ..> MemVecA
+
+@enduml
+```
+
+## Что показывает
+
+- **Applications** — три точки входа: web-сервер, CLI REPL, Android-приложение. Каждое тонкое, не содержит бизнес-логики.
+- **Agent Runtime** — `BaseAgent` + `AgentBuilder` DSL. Вся композиция и lifecycle.
+- **Background Work** — `BackgroundEvents` (event-bus) + `BackgroundScheduler` (policy подписки). Event-driven, не interval-polling.
+- **Domain Logic** — generic переиспользуемые модули (`:llm-tools`, `:mcp-bridge`, `:skills`).
+- **Storage / Memory / LLM** — каждая с абстракцией и одним или несколькими impl (JVM-only или Android-only).
+- **Inter-app** — `:proto` контракты + `:a2a-server` для межагентного общения.
+
+## Текущее состояние vs целевое
+
+✅ Уже сделано (в этом цикле правок):
+- `:llm-tools` extracted
+- `:mcp-bridge` extracted
+- `BackgroundScheduler` стал event-driven
+- `ConversationLoop` стал отдельным компонентом (typealias `ChatConversation`)
+
+⏳ Не сделано:
+- `:agent-core` (выделить `BaseAgent` + builder в отдельный KMP-модуль)
+- `:background-events` (выделить events + scheduler — пока в `:standalone`)
+- `:storage-sqlite-android`
+- `:memory-vector-android`
+- `:litert-android`
+- `:agentik-android` (само приложение)

docs/diagrams/02-agent-composition.md

@@ -0,0 +1,127 @@
+# 02 — Agent Builder: композиция (целевое API)
+
+Как `AgentBuilder` собирает `BaseAgent` из компонентов. **Memory backend сам объявляет свои tools** — builder их авто-мержит. BackgroundScheduler подписан на события, не interval-poll.
+
+![Agent Composition](./02-agent-composition.svg)
+
+PlantUML source (для редактирования; требует Graphviz `dot` для рендеринга):
+
+```plantuml
+@startuml agent-composition
+skinparam componentStyle rectangle
+
+title Agent Builder — композиция (целевое API)
+
+' --- Builder ---
+rectangle "AgentBuilder" as Builder {
+    rectangle "llm: LiteLlm (обязательно)" as Llm
+    rectangle "storage: StorageBundle (обязательно)" as Storage
+    rectangle "memory: MemorySystem (обязательно)" as Mem
+    rectangle "soul: SoulProvider (default NoopSoul)" as Soul
+    rectangle "tools: List<NamedTool> (авто-сборка из backends)" as Tools
+    rectangle "background: BackgroundConfig (default EmptyBg)" as Bg
+    rectangle "toolset: List<ToolsetContribution> (default empty)" as Ts
+}
+
+' --- Backends with their tool side-effects ---
+rectangle "MemoryMd" as MdMem {
+    interface "MemorySystem" as MemSys
+    interface "List<NamedTool>" as MdTools
+    note right
+        MemoryMd.exposesTools() →
+        memory_save / memory_read /
+        memory_list / memory_delete
+    end note
+}
+
+rectangle "McpRegistry" as McpReg {
+    interface "List<NamedTool>" as McpTools
+    note right
+        McpRegistry.namedTools →
+        server__tool1, server__tool2,
+        ...
+    end note
+}
+
+rectangle "BackgroundEvents" as Events {
+    interface "MutableSharedFlow<CompactionEvent|ToolCallEvent|LifecycleEvent>" as Flow
+    note right
+        Эмитится из:
+        - CompactionCoordinator
+        - ToolDispatcher
+        - ConversationLoop.close()
+    end note
+}
+
+rectangle "BackgroundScheduler" as Sched {
+    interface "policy: trigger + debounce" as Policy
+    note right
+        Подписан на Events.
+        НИКАКОГО interval-polling.
+    end note
+}
+
+' --- Получаемый Agent ---
+rectangle "BaseAgent\n(impl: ConversationLoop)" as Agent {
+    rectangle "send / interrupt / events" as API
+    rectangle "BackgroundScheduler\nподписка" as Sub
+}
+
+' --- Стрелки зависимостей ---
+Builder --> Llm
+Builder --> Storage
+Builder --> Mem
+Builder --> Soul
+Builder --> Tools
+Builder --> Bg
+Builder --> Ts
+
+MdMem --> Mem : implements
+MdMem --> MdTools : exposes
+
+McpReg --> McpTools : exposes
+
+Bg --> Events : subscribes-to
+Bg --> Sched : holds
+
+Tools <-- MdTools : auto-merge
+Tools <-- McpTools : auto-merge
+
+Builder --> Agent : build()
+Agent --> API
+Agent --> Sub
+
+@enduml
+```
+
+## Целевой Kotlin DSL
+
+```kotlin
+val agent = agentBuilder {
+    // Обязательные
+    llm(OpenAiLlm.fromEnv())           // или LitertAndroid.onDevice(context)
+    storage(SqliteStorage(path))         // или SqliteStorage.android(context)
+    memory(MemoryMd(root = "~/memory")) // или MemoryVector(embedding = HttpEmbedding(...))
+
+    // Опциональные
+    soul(FileSoul("~/SOUL.md"))          // или HttpSoul(url), NoopSoul()
+    background {
+        // triggers: OnClosing (reflection+mining), OnCompaction(minTurns=10, mining=true)
+        // event-driven, не interval
+    }
+    tools {
+        // memoryMd.exposesTools() + mcpRegistry.namedTools авто-подцепляются
+        +FileReadTool(root = "/data")
+    }
+    toolset {
+        +MemoryToolsToolset(memoryMd)
+    }
+}.build()
+```
+
+## Ключевые решения
+
+- **`MemoryBackend.exposesTools()`** — backend декларирует свои tools. Не «подставить любой backend», а «backend сообщает что он умеет». Это убирает coupling «какие tools совместимы с какими backends».
+- **Builder требует только `llm + storage + memory`** как обязательные. Всё остальное — опционально с разумными default'ами (`NoopSoul`, `EmptyBackground`, `empty toolset`).
+- **`BaseAgent`** — реализация `ConversationLoop` через builder. Конструктор принимает все нужные компоненты. **Один и тот же `BaseAgent` в `:standalone`, `:agentik-cli`, `:agentik-android`** — отличается только wiring через builder.
+- **BackgroundScheduler подписан на `BackgroundEvents`** — это даёт event-driven по умолчанию. `OnEvery(n)` interval-режим — опциональный fallback (не default).

docs/diagrams/03-multi-user-chat.md

@@ -0,0 +1,129 @@
+# 03 — Multi-user chat с mention-detection
+
+Точка 1 из планов. Один `BaseAgent` обслуживает N пользователей. Отвечает только когда addressed (mention или admin-команда).
+
+![Multi-user chat](./03-multi-user-chat.svg)
+
+PlantUML source (для редактирования; требует Graphviz `dot` для рендеринга):
+
+```plantuml
+@startuml multi-user-chat
+skinparam componentStyle rectangle
+skinparam participantPadding 15
+skinparam boxPadding 10
+
+title Multi-user chat с mention-detection (точка 1 из планов)
+
+' --- Участники ---
+actor "User A" as UA
+actor "User B" as UB
+actor "User C\n(админ)" as UC
+participant "Telegram /\nSlack /\nMatrix" as Channel
+participant "AgentRuntime\n(BaseAgent)" as Runtime
+participant "MentionDetector" as Detector
+participant "SoulProvider" as Soul
+participant "MemorySystem\n(MdMemory)" as Memory
+participant "LlmBackend\n(LiteLlm)" as Llm
+
+' --- Сценарий ---
+UA -> Channel : "@bot, что нового?"
+UB -> Channel : "люблю котов"
+UC -> Channel : "/bot status"
+Channel -> Runtime : событие чата
+
+' --- Внутри Runtime ---
+Runtime -> Detector : isMentioned(message, botName)
+
+note right of Detector
+    variants:
+    - SimpleMentionDetector (regex: @bot)
+    - LlmMentionDetector (mini-classifier)
+    - AdminCommandDetector (/command)
+end note
+
+Detector --> Runtime : MatchResult{isMentioned, isCommand}
+
+alt isMentioned или isCommand
+    Runtime -> Soul : read()
+    Runtime -> Memory : prefetch(query, topK)
+    Runtime -> Llm : send(system + history + memory + user)
+    Llm --> Runtime : response + tool_calls
+    Runtime -> Memory : save(decision)
+    Runtime --> Channel : ответ в нужный канал/thread
+else NOT mentioned и NOT command
+    Runtime -> Runtime : drop (если не админ)
+    note right
+        Не отвечаем, но возможно:
+        - запоминаем факт (memory-only update)
+        - summary на long conversation
+    end note
+end
+
+@enduml
+```
+
+## Ключевые модули (что нужно будет добавить)
+
+### `MentionDetector` interface
+
+```kotlin
+interface MentionDetector {
+    data class Result(
+        val isMentioned: Boolean,
+        val isAdminCommand: Boolean,
+        val isPrivateMessage: Boolean,  // DM — всегда отвечаем
+    )
+
+    fun detect(message: ChatMessage, botName: String): Result
+}
+```
+
+Имплементации:
+- `SimpleMentionDetector` — regex `@bot`, `/command` (дешёво, latency ~0)
+- `LlmMentionDetector` — маленькая классификация через тот же LLM (точнее, но +1 LLM-вызов на каждое сообщение)
+- `HybridMentionDetector` — fast regex → fallback на LLM только если ambiguous
+
+### `ChatAdapter` interface
+
+```kotlin
+interface ChatAdapter {
+    val channel: String  // "telegram" / "slack" / "matrix"
+    suspend fun listen(onMessage: (ChatMessage) -> Unit): Job
+    suspend fun reply(messageId: String, text: String, threadId: String? = null)
+    suspend fun isAdmin(userId: String): Boolean
+}
+```
+
+Имплементации per platform. Каждая адаптирует формат platform → `ChatMessage`.
+
+### Конфигурация builder'а
+
+```kotlin
+agentBuilder {
+    llm(...)
+    storage(...)
+    memory(...)
+    soul(...)
+    background { ... }
+    chat {
+        mentionDetector = HybridMentionDetector(regex = "@bot|@Agent", llmClassifier = false)
+        chatAdapter = TelegramChatAdapter(token = "...")
+        // На каждое сообщение:
+        // 1. mentionDetector.detect()
+        // 2. если isMentioned || isAdminCommand || isPrivate → process
+        // 3. иначе — опционально memory-only save (тихий режим)
+    }
+}
+```
+
+## Что это даёт
+
+- Один `BaseAgent` обслуживает чат целиком (один LLM, одна память — общий контекст команды)
+- `@bot` — explicit invocation, не «agent отвечает на всё подряд»
+- `/bot status` / `/bot clear-memory` — admin-команды (отдельный канал, без LLM)
+- DM — всегда отвечает (это личное обращение)
+- В групповом чате без mention — agent может **молча учить** (memory update без ответа). Полезно для «запомнил что Вася любит котов».
+
+## Текущее состояние vs целевое
+
+⏳ Ничего из этого нет. Сейчас `:standalone` — это HTTP API, к которому подключаются clients. Для multi-user chat нужен новый `:chat-adapter-telegram` (или -slack / -matrix) модуль + `MentionDetector` interface.

docs/diagrams/04-sub-agents.md

@@ -0,0 +1,119 @@
+# 04 — Sub-agents + A2A между агентами
+
+Точки 2 и 3 из планов. Orchestrator-агент spawn'ит sub-агентов с изолированным контекстом. Независимые агенты общаются через A2A.
+
+![Sub-agents + A2A](./04-sub-agents.svg)
+
+PlantUML source (для редактирования; требует Graphviz `dot` для рендеринга):
+
+```plantuml
+@startuml sub-agents-and-a2a
+skinparam componentStyle rectangle
+
+title Sub-agents + A2A между агентами (точка 2+3 из планов)
+
+' --- Orchestrator ---
+rectangle "OrchestratorAgent\n(BaseAgent + tools)" as Orch {
+    rectangle "ConversationLoop\n(main user)" as MainConv
+}
+
+' --- Sub-agent spawn ---
+rectangle "subAgent(\n  task: String,\n  config: AgentConfig\n): Flow<SubAgentEvent>" as SpawnAPI
+note right of SpawnAPI
+    Spawn API — НЕ отдельный модуль,
+    а convenience поверх BaseAgent:
+    val sub = agent.spawnChild(config) {
+        systemPrompt = "..."
+        tools = [ReadTool, WriteTool]
+        memory = EmptyMemory  // изолированно
+    }
+    sub.events.collect { ... }
+end note
+
+' --- Дочерний агент (изолированный контекст) ---
+rectangle "SubAgent\n(изолированный scope)" as Sub {
+    rectangle "ConversationLoop\n(child)" as SubConv
+    rectangle "backgroundScope\n(lifecycle scoped)" as SubBg
+}
+
+' --- A2A между независимыми агентами ---
+rectangle "Agent A\n(BaseAgent)" as AgentA
+rectangle "Agent B\n(BaseAgent)" as AgentB
+rectangle "A2A Server\n(:a2a-server)" as A2ASrv
+
+AgentA -> A2ASrv : POST /\n(application/json)
+A2ASrv -> AgentB : dispatch(message)
+AgentB --> A2ASrv : response
+A2ASrv --> AgentA : SSE / JSON-RPC
+
+' --- Стрелки ---
+Orch -> SpawnAPI : calls
+SpawnAPI -> Sub : creates with custom config
+Sub -> SubBg : has its own
+Orch -> Orch : main flow continues
+Sub --> Orch : Flow<SubAgentEvent> emits\n(Started / ToolCalled / ToolResult /\nAssistantMessage / Done / Failed)
+
+Orch -> A2ASrv : can also delegate to remote agent
+
+@enduml
+```
+
+## Sub-agents API
+
+```kotlin
+sealed interface SubAgentEvent {
+    data class Started(val taskId: String) : SubAgentEvent
+    data class AssistantMessage(val text: String) : SubAgentEvent
+    data class ToolCalled(val toolName: String, val args: JsonObject) : SubAgentEvent
+    data class ToolResult(val toolName: String, val result: String) : SubAgentEvent
+    data class Done(val taskId: String, val finalResult: String) : SubAgentEvent
+    data class Failed(val taskId: String, val error: String) : SubAgentEvent
+}
+
+interface BaseAgent {
+    // ... existing methods ...
+
+    /**
+     * Spawn дочерний агент с изолированным контекстом (memory, system prompt,
+     * tools). Возвращает Flow событий жизненного цикла + результата.
+     * Cancellation родителя НЕ отменяет sub-agent — sub-agent живёт до Done/Failed.
+     */
+    fun spawnChild(config: SubAgentConfig): Flow<SubAgentEvent>
+}
+
+data class SubAgentConfig(
+    val systemPrompt: String,
+    val tools: List<NamedTool> = emptyList(),
+    val memory: MemorySystem = EmptyMemory(),
+    val model: LiteLlm? = null,  // если null — делит LLM родителя
+    val maxTurns: Int = 10,
+    val timeoutMs: Long = 60_000,
+)
+```
+
+## Зачем изолированный scope
+
+Sub-agent получает **свою копию контекста**, не делит memory с родителем. Это критично:
+- `research_subagent` — должен исследовать тему, не отвечать на основные сообщения пользователя
+- `summarize_subagent` — суммаризировать документ, не трогать основной диалог
+- `code_review_subagent` — ревьюить PR, не видеть разговор
+
+Если нужно расшарить контекст — это explicit через `sharedMemory: SharedMemoryHandle` параметр, не default.
+
+## A2A между независимыми агентами
+
+Уже есть `:a2a-server` модуль (см. `standalone/build.gradle.kts` — `implementation(libs.a2a.server)`). Использовался для AG-UI/A2A протокола в `:standalone`. Можно переиспользовать для межагентного общения.
+
+Сценарий: orchestrator-agent не может сам решить задачу → делегирует remote-агенту через A2A → получает response → продолжает. Это уже работающая инфраструктура.
+
+## Текущее состояние vs целевое
+
+✅ Уже есть:
+- `:a2a-server` подключён
+- `BaseAgent.spawnChild` — **не существует**, но `ConversationLoop` уже умеет создавать изолированный scope через свой `agentScope` — нужна только обёртка
+
+⏳ Не сделано:
+- `SubAgentConfig` + `Flow<SubAgentEvent>` API
+- `EmptyMemory` (null-object для изолированного scope)
+- Lifecycle management (parent dies → child должен complete or be cancelled?)
+- Сериализация sub-agent state для отладки (event log)

docs/diagrams/05-android-stack.md

@@ -0,0 +1,171 @@
+# 05 — Android Agent Stack
+
+Что меняется vs `:standalone`. Цель: `BaseAgent` тот же самый, но platform-impl разные (Storage, LLM, Vector Memory, MCP).
+
+![Android Agent Stack](./05-android-stack.svg)
+
+PlantUML source (для редактирования; требует Graphviz `dot` для рендеринга):
+
+```plantuml
+@startuml android-agent-stack
+skinparam componentStyle rectangle
+
+title Android Agent Stack — что меняется vs Standalone
+
+' --- Android side ---
+package "Android Application" {
+    [MainActivity\n(Compose)] as Activity
+    [AndroidAgentRunner\n(workmanager / service)] as Runner
+    [AndroidAgentBuilder] as AndroidBuilder
+}
+
+package "Android-specific impls" {
+    [StorageSqliteAndroid\n(Room/sqlite)] as StorageA
+    [MemoryVectorAndroid\n(ONNX runtime + ANN)] as MemVecA
+    [LitertAndroid\n(NNAPI delegate)] as LitertA
+    [SoulFileAndroid\n(context.filesDir)] as SoulA
+    [McpRegistry\nstdio: ProcessBuilder] as McpA
+}
+
+' --- Shared (KMP) ---
+package "Agent Runtime (shared)" {
+    [AgentCore\nBaseAgent] as AgentCore
+    [AgentBuilder] as Builder
+}
+
+package "Domain (shared)" {
+    [LlmTools\ncommonMain] as LlmT
+    [BackgroundEvents\ncommonMain] as Ev
+    [McpBridge\njvmMain] as McpB
+    [Skills\ncommonMain] as Skills
+}
+
+package "Memory (shared impl)" {
+    [MemoryMd\n(commonMain)] as MemMd
+    [MemoryApi\ninterfaces] as MemApi
+}
+
+' --- Зависимости ---
+Activity --> Runner
+Runner --> AndroidBuilder
+AndroidBuilder --> AgentCore
+
+AndroidBuilder --> StorageA
+AndroidBuilder --> MemVecA
+AndroidBuilder --> LitertA
+AndroidBuilder --> SoulA
+AndroidBuilder --> McpA
+
+AgentCore --> LlmT
+AgentCore --> Ev
+AgentCore --> McpB
+AgentCore --> Skills
+AgentCore --> MemMd
+
+' --- Главные отличия от Standalone ---
+note right of LitertA
+    On-device inference.
+    LiteRT с NNAPI delegate →
+    работает на CPU/GPU/NPU
+    прямо на устройстве, без сети.
+    
+    vs Standalone: HTTP-only
+    (OpenAI-compatible).
+end note
+
+note right of StorageA
+    android.database.sqlite
+    через Room или сырой API.
+    
+    vs Standalone: JDBC +
+    Sqlite-JDBC driver
+    (только JVM).
+end note
+
+note right of MemVecA
+    JVector JVM-only. На Android
+    нужна альтернатива —
+    ONNX Runtime + какой-нибудь
+    ANN (Annoy/HNSW).
+    
+    Или пока без vector memory,
+    только MemoryMd.
+end note
+
+note right of McpA
+    MCP через ProcessBuilder
+    на Android работает, но
+    subprocess lifecycle
+    сложнее (foreground service
+    нужен для долгого subprocess).
+end note
+
+@enduml
+```
+
+## Что общего с `:standalone`
+
+**`BaseAgent`, `BackgroundScheduler`, `LlmTools`, `McpBridge`, `Skills`, `MemoryMd` — всё KMP (commonMain).** Android-agent = `:standalone` с другим wiring'ом. Не нужно переписывать agent logic.
+
+## Что другое
+
+| Компонент | `:standalone` (JVM) | `:agentik-android` (Android) | Сложность |
+|---|---|---|---|
+| Storage | `:storage-sqlite` (JDBC + Sqlite-JDBC) | `:storage-sqlite-android` (Room или raw) | Низкая — тот же `StorageBundle` interface |
+| LLM | `:litert-openai` (HTTP), `:litert-google` (LiteRT JVM) | `:litert-android` (LiteRT Android, NNAPI delegate) | Средняя — нужен новый модуль |
+| Vector memory | `:memory-vector` (JVector) | `:memory-vector-android` (ONNX Runtime + HNSW/Annoy) | Высокая — JVector JVM-only, нужна альтернатива |
+| SOUL provider | `FileSoulProvider` (path) | `SoulFileAndroid` (`context.filesDir`) | Низкая |
+| MCP | `McpRegistry` (ProcessBuilder, stdio subprocess) | Тот же `McpRegistry`, но subprocess в foreground service | Средняя — нужен Android service |
+| Embedding | `HttpEmbeddingClient` (HTTP) | Тот же ИЛИ on-device (ONNX) | Средняя |
+
+## Минимальный Android agent (v1)
+
+Если не нужны все фичи сразу — минимум:
+
+```kotlin
+val agent = androidAgentBuilder(context) {
+    llm(LitertAndroid.onDevice(context, modelPath = "/data/local/tmp/model.litertlm"))
+    storage(SqliteStorage.android(context, "agent.db"))
+    memory(MemoryMd.root(context.filesDir.resolve("memory")))
+    soul(FileSoul(context.filesDir.resolve("SOUL.md")))
+    background {
+        // OnClosing + OnCompaction работают так же как на JVM
+    }
+}
+```
+
+Без MCP, без vector memory (только MemoryMd на файлах), только on-device LLM. Достаточно для off-line агента.
+
+## Foreground service для MCP
+
+Если нужны MCP-серверы (например, локальный file-system MCP) — subprocess нужен foreground service чтобы Android не убил его при выключении экрана. Это добавляет сложности:
+
+```kotlin
+class McpForegroundService : Service() {
+    override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
+        startForeground(NOTIFICATION_ID, notification)
+        val proc = ProcessBuilder(command, args).start()
+        // ... route stdio to McpLiteToolAdapter ...
+        return START_STICKY
+    }
+}
+```
+
+Пока можно без этого (только если MCP нужен на Android).
+
+## Текущее состояние vs целевое
+
+✅ KMP-ready:
+- `:llm-tools` (commonMain, платформо-агностик)
+- `:mcp-bridge` (jvmMain — Android-вариант через `:mcp-bridge-android`)
+- `:skills` (commonMain)
+- `:memory-md` (commonMain)
+- `:proto` (commonMain)
+
+⏳ Не существует:
+- `:storage-sqlite-android`
+- `:memory-vector-android`
+- `:litert-android`
+- `:agentik-android` (само приложение)
+- `:agent-core` (выделить BaseAgent + builder)
+- `:background-events` (выделить events + scheduler)

docs/diagrams/README.md

@@ -0,0 +1,64 @@
+# agentik — диаграммы архитектуры
+
+PlantUML-схемы для обсуждения будущей структуры (Android agent, multi-user chat, sub-agents, A2A). Это **целевое состояние**, не текущее.
+
+## Файлы
+
+Каждый `.md` содержит:
+- Краткое описание (что показывает)
+- **Пред-рендеренный SVG** (`![Diagram](file.svg)`) — гарантированно показывается **везде**
+- PlantUML source в ` ```plantuml ` блоке — для редактирования (требует Graphviz `dot` для рендеринга)
+- Дополнительный markdown-текст (что нужно сделать, текущее vs целевое)
+
+| Файл | Что показывает |
+|---|---|
+| [01-module-layers.md](./01-module-layers.md) | Целевая модульная структура (приложения → runtime → домен → абстракции → платформенные impl). Что в каком слое и кто от кого зависит. |
+| [02-agent-composition.md](./02-agent-composition.md) | Как `AgentBuilder` собирает `BaseAgent` из компонентов. Memory backend сам объявляет свои tools. BackgroundScheduler подписан на события (НЕ interval-poll). |
+| [03-multi-user-chat.md](./03-multi-user-chat.md) | Сценарий: чат с N пользователями, mention-detection, админ-команды, agent отвечает только когда addressed. |
+| [04-sub-agents.md](./04-sub-agents.md) | Orchestrator spawn'ит sub-agent с изолированным контекстом, получает `Flow<SubAgentEvent>`. A2A между независимыми агентами через `:a2a-server`. |
+| [05-android-stack.md](./05-android-stack.md) | Что меняется на Android: on-device LLM (NNAPI), Room/sqlite, ONNX-based vector memory, foreground-service для MCP subprocess. |
+
+## Почему SVG + PlantUML source
+
+PlantUML требует Java + (для component/class/deployment диаграмм) Graphviz `dot`. Если `dot` не установлен — рендерер падает с ошибкой "Executable dot does not exist".
+
+Решение: **пре-рендерим в SVG один раз** и вставляем как `<img>`. Диаграмма гарантированно показывается в любом markdown-viewer (GitHub, IntelliJ, VSCode, GitLab) без зависимостей. PlantUML source в code block остаётся для редактирования.
+
+## Как редактировать диаграмму
+
+1. Меняешь PlantUML-source в ` ```plantuml ` блоке `.md` файла.
+2. Ре-рендеришь SVG:
+   ```bash
+   mkdir -p /tmp/plantuml-work && chmod 777 /tmp/plantuml-work
+   cp docs/diagrams/*.md /tmp/plantuml-work/
+   docker run --rm -v /tmp/plantuml-work:/work plantuml/plantuml -tsvg /work/*.md
+   cp /tmp/plantuml-work/*.svg docs/diagrams/
+   ```
+3. Проверяешь что SVG обновился:
+   ```bash
+   ls -la docs/diagrams/*.svg
+   ```
+4. Коммитишь оба файла: `.md` (source) и `.svg` (rendered).
+
+Требует Docker (или локального PlantUML+Graphviz). `apt install graphviz` для Arch/Manjaro.
+
+## Контекст
+
+Текущий код движется в эту сторону:
+- `:llm-tools` extracted ✅
+- `:mcp-bridge` extracted ✅
+- `BackgroundScheduler` стал event-driven ✅
+- `ConversationLoop` стал отдельным компонентом ✅
+
+Не сделано (см. детали в каждом .md):
+- `:agent-core` (выделить `BaseAgent` + builder)
+- `:background-events` (выделить events + scheduler)
+- `:storage-sqlite-android`, `:memory-vector-android`, `:litert-android`
+- `:agentik-android` (само приложение)
+- `MentionDetector` interface + adapters для multi-user chat
+- `BaseAgent.spawnChild` + `Flow<SubAgentEvent>`
+
+Подробнее:
+- `STANDALONE-REVIEW.md` — что плохо в текущем коде
+- `MEMORY-DESIGN.md` — детали memory архитектуры
+- `STANDALONE.md` — текущий standalone

event-store/README.md

@@ -0,0 +1,137 @@
+# `:event-store` — bounded-tail event log (KMP)
+
+## Что это
+
+Двухуровневое хранилище событий агента. Этот модуль — **короткий
+bounded tail** для live-SSE и недавнего replay. Полный audit log
+живёт в `:message-store-api` (никогда не эвиктится, source of truth).
+
+Три принципа:
+
+1. **Tail управляет TTL сам.** Никаких `prune`/`cleanup` методов наружу —
+   implementation решает, когда выкинуть старый event. Caller'ы не
+   могут забыть cleanup.
+2. **Catchup + live в одном Flow.** `events(after)` сначала отдаёт
+   буферизованный диапазон, потом переключается на live tail — клиент
+   не должен знать, где у него "разрыв".
+3. **Read-only контракт для consumer'ов.** Запись через
+   [MutableEventStore], чтение через [EventStore]. Compile-time
+   гарантия что observer не сможет писать в store.
+
+## Где используется
+
+- `:standalone` ChatAgent — append через `MutableOutboxStore` (заменяет
+  текущий `agentEvents: MutableSharedFlow` + `persistAgentEvent`).
+- `:server` Routes.kt — `/events/all` SSE endpoint читает через
+  `EventStore.events(after)`.
+- Будущий `:android-agent` core — same интерфейс для локального
+  bounded tail без dedicated server connection.
+
+## Архитектура
+
+```
+┌─ :event-store (этот модуль) ────────────────────────┐
+│ Bounded tail с auto-TTL:                           │
+│   • append(event)  ← producer                      │
+│   • events(after): Flow  ← consumer                │
+│   • earliestEventDate() для gap detection          │
+│   TTL/cap eviction — внутри impl                   │
+└───────────────────────────────────────────────────┘
+                         ▲ gap detected
+                         │
+┌─ :message-store-api (полный audit log) ───────────┐
+│ MessageStore: query(after, before, limit)         │
+│ Никогда не эвиктится. Source of truth.            │
+└───────────────────────────────────────────────────┘
+```
+
+**Reconnect pattern** (caller делает):
+
+```kotlin
+val earliest = eventStore.earliestEventDate()
+if (client.lastSeen < earliest) {
+    // gap: догоняем через :message-store-api
+    val gap = messageStore.query(after = client.lastSeen, before = earliest)
+    applyAll(gap)
+    client.lastSeen = gap.last().createdAt
+}
+eventStore.events(after = client.lastSeen).collect { apply(it) }
+```
+
+## API
+
+### `OutboxStore` (read-only, для consumer'ов)
+
+```kotlin
+interface EventStore : AutoCloseable {
+    fun events(after: Instant?): Flow<CommonEvent>
+    fun conversationEvents(
+        after: Instant?,
+        conversationId: String? = null,  // null = все диалоги
+    ): Flow<CommonEvent.Conversation>
+    fun agentEvents(after: Instant?): Flow<CommonEvent.Agent>
+    suspend fun earliestEventDate(): Instant  // non-null: now() для пустого буфера
+    override fun close()
+}
+```
+
+**Семантика фильтров**:
+- `conversationEvents(null)` — все диалоги.
+- `conversationEvents("c-123")` — один конкретный диалог.
+- `agentEvents(...)` — только lifecycle (Created/Deleted/Renamed).
+
+Все три возвращают **типизированные** subtype'ы [CommonEvent], так что
+caller'у не нужно `.filterIsInstance` на клиентской стороне.
+
+### `MutableEventStore : EventStore` (для producer'ов)
+
+```kotlin
+interface MutableEventStore : EventStore {
+    suspend fun append(event: CommonEvent)
+}
+```
+
+**Append НЕ идемпотентен**: [CommonEvent] не имеет уникального id,
+retry даст дубликат. Для exactly-once — dedup через
+`:message-store-api` (там есть монотонный `id`).
+
+**Silently evicted**: implementation может выкинуть event сразу после
+append по TTL/cap. Producer не должен полагаться на то, что event
+дойдёт до клиента, если он вне retention window.
+
+## Когда использовать какой интерфейс
+
+| Caller | Method |
+|---|---|
+| Server `/events/all` SSE (mixed) | `events(after)` |
+| Server `/conversations/{id}/events` SSE | `conversationEvents(after, conversationId)` |
+| Server `/agent/events` SSE (lifecycle only) | `agentEvents(after)` |
+| Admin dashboard (lifecycle) | `agentEvents(after)` |
+| Parent orchestrator (mixed) | `events(after)` |
+| Тесты | `events(after)` + projection через фильтр |
+
+## Как добавить новый implementation
+
+1. Создать класс с конструктором и lifecycle (`close()` обязан
+   освободить ресурсы).
+2. Реализовать минимум: append (с TTL eviction), events (Flow с
+   catchup + live), earliestEventDate (non-null Instant, now() если
+   буфер пуст).
+3. Для persistent impl: SQL/ksqlite таблица с индексом по date,
+   вставка = `INSERT OR IGNORE` для дедупликации на уровне БД
+   (если в схеме будет id).
+
+## Текущее состояние
+
+- ✅ Interface дизайн (`OutboxStore` + `MutableOutboxStore`)
+- ✅ KMP build (jvm + linuxX64 + mingwX64)
+- ⏳ Нет implementations (next: `InMemoryEventStore` для тестов)
+- ⏳ Не интегрирован в `:standalone`/`:server`
+
+## Зависимости
+
+- `:proto` (api) — тип `CommonEvent` (3 AgentEvent + 9 Conversation.Event вариантов).
+- `kotlinx-coroutines-core` (api) — `Flow`.
+
+Никаких `kotlinx-serialization`, `kotlin-logging`, platform-specific
+зависимостей — этот модуль намеренно minimal.

event-store/build.gradle.kts

@@ -0,0 +1,32 @@
+plugins {
+    alias(libs.plugins.kotlin.multiplatform)
+}
+
+// KMP-интерфейс bounded-tail event log'а. Implementation-specific TTL/cap
+// eviction — caller's responsibility НЕ вызывать cleanup() (метод не существует).
+//
+// Тип [AllEvent] из :proto — typed envelope (3 AgentEvent + 9 Conversation.Event
+// вариантов). :event-store отвечает за bounded-tail с auto-TTL, но не за
+// сериализацию envelope'а — это делает :proto (уже @Serializable).
+
+kotlin {
+    jvmToolchain(21)
+
+    jvm()
+    macosX64()
+    macosArm64()
+    linuxX64()
+    linuxArm64()
+    mingwX64()
+
+    sourceSets {
+        commonMain.dependencies {
+            api(project(":proto"))
+            api(libs.kotlinx.coroutines.core)
+        }
+        commonTest.dependencies {
+            implementation(kotlin("test"))
+            implementation(libs.kotlinx.coroutines.test)
+        }
+    }
+}

gradle.properties

@@ -1,5 +1,9 @@
-# Default version for local builds; overridden by `-Pversion=<tag>` from CI/CD.
-version=0.1.0
+# Default version for local builds only (когда CI/CD не передал -Pversion=<tag>).
+# Имя ключа специально НЕ 'version' — иначе Gradle-мерж gradle.properties и
+# -Pversion= возьмёт default из gradle.properties. Передавай через CICD:
+#   ./gradlew ... -Pversion=$(git describe --tags)
+# см. .gitea/workflows/release.yml (использует -Pversion=$GITHUB_REF_NAME).
+agentik.version.default=0.1.0-SNAPSHOT
 
 # KMP jvm target uses JDK 21 for both compilation and toolchain.
 org.gradle.jvmargs=-Xmx4096M -XX:+UseG1GC

gradle/libs.versions.toml

@@ -10,11 +10,12 @@ litert = "8"
 sqldelight = "2.3.2"
 shadow = "8.3.5"
 jvector = "3.0.6"
-text-embedding-kmp = "3.0.0-SNAPSHOT"
+text-embedding-kmp = "5"
 kotlin-logging = "3.0.5"
 logback = "1.5.18"
-jline = "3.30.0"
 mosaic = "0.18.0"
+clikt = "5.0.3"
+kotlinx-cli = "0.3.6"
 
 [plugins]
 kotlin-multiplatform = { id = "org.jetbrains.kotlin.multiplatform", version.ref = "kotlin" }
@@ -54,6 +55,7 @@ ktor-server-content-negotiation = { module = "io.ktor:ktor-server-content-negoti
 ktor-serialization-kotlinx-json = { module = "io.ktor:ktor-serialization-kotlinx-json", version.ref = "ktor" }
 ktor-client-core = { module = "io.ktor:ktor-client-core", version.ref = "ktor" }
 ktor-client-cio = { module = "io.ktor:ktor-client-cio", version.ref = "ktor" }
+ktor-client-curl = { module = "io.ktor:ktor-client-curl", version.ref = "ktor" }
 ktor-client-content-negotiation = { module = "io.ktor:ktor-client-content-negotiation", version.ref = "ktor" }
 ktor-server-test-host = { module = "io.ktor:ktor-server-test-host", version.ref = "ktor" }
 ktor-client-sse = { module = "io.ktor:ktor-client-sse", version.ref = "ktor" }
@@ -61,8 +63,12 @@ ktor-client-sse = { module = "io.ktor:ktor-client-sse", version.ref = "ktor" }
 # --- Model Context Protocol (MCP) ---
 mcp-sdk-client = { module = "io.modelcontextprotocol:kotlin-sdk-client", version = "0.15.0" }
 
-# --- CLI: JLine (readline для JVM-таргета) ---
-jline = { module = "org.jline:jline", version.ref = "jline" }
+# --- CLI: clikt (ajalt). KMP, native Linux/macOS/Windows включая linuxArm64. ---
+# https://ajalt.github.io/clikt/
+# Артефакт один и тот же — `com.github.ajalt.clikt:clikt` — Gradle module
+# metadata резолвит per-target variant (clikt-jvm / clikt-linuxarm64 / ...).
+clikt = { module = "com.github.ajalt.clikt:clikt-core", version.ref = "clikt" }
+kotlinx-cli = { module = "org.jetbrains.kotlinx:kotlinx-cli", version.ref = "kotlinx-cli" }
 
 # --- TUI: Mosaic (Jetpack Compose → ANSI-терминал), jvm + desktop-native. ---
 # https://github.com/JakeWharton/mosaic
@@ -91,8 +97,15 @@ kotlinx-io-core = { module = "org.jetbrains.kotlinx:kotlinx-io-core", version.re
 jvector = { module = "io.github.jbellis:jvector", version.ref = "jvector" }
 
 # --- text-embedding-kmp (pw.binom.ai.embeddingtext) — on-device SigLIP2 эмбеддинг через ONNX. ---
-# Артефакты публикуются под именами `-jvm` (KMP convention для JVM-таргета).
-text-embedding-api = { module = "pw.binom.ai.embeddingtext:api-jvm", version.ref = "text-embedding-kmp" }
+# `api` — KMP с jvm + android + linuxX64/Arm64 + macos + ios + mingwX64
+# (с 2026-09-21, когда мы добавили нативные цели в text-embedding-kmp:api).
+# Версия 5 — первый релиз с реальными нативными klib-вариантами в caffeine
+# (v4 имел только jvm+android, что ломало native-resolve в :memory-md-vector).
+# Используется из :memory-md-vector и :memory-vector напрямую через
+# `libs.text.embedding.api` (без суффикса `-jvm` — Gradle сам выберет
+# нужный variant под target).
+# `siglip` — JVM+Android only (onnx-runtime), подключается в jvmMain.
+text-embedding-api = { module = "pw.binom.ai.embeddingtext:api", version.ref = "text-embedding-kmp" }
 text-embedding-siglip = { module = "pw.binom.ai.embeddingtext:siglip-jvm", version.ref = "text-embedding-kmp" }
 
 # --- Логирование: kotlin-logging (тонкая обёртка над slf4j-api) + logback-classic (binding). ---

journal-api/build.gradle.kts

@@ -0,0 +1,29 @@
+plugins {
+    alias(libs.plugins.kotlin.multiplatform)
+    alias(libs.plugins.kotlin.serialization)
+}
+
+kotlin {
+    jvmToolchain(21)
+    jvm()
+    macosX64()
+    macosArm64()
+    iosX64()
+    iosArm64()
+    iosSimulatorArm64()
+    linuxX64()
+    linuxArm64()
+    mingwX64()
+
+    sourceSets {
+        commonMain.dependencies {
+            api(libs.kotlinx.coroutines.core)
+            api(libs.kotlinx.serialization.core)
+            api(libs.kotlinx.serialization.json)
+        }
+        commonTest.dependencies {
+            implementation(kotlin("test"))
+            implementation(libs.kotlinx.coroutines.test)
+        }
+    }
+}

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/Content.kt

@@ -1,17 +1,12 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.journal
 
 import kotlinx.serialization.SerialName
 import kotlinx.serialization.Serializable
 
 /**
- * Часть контента сообщения на уровне хранилища.
- *
- * Намеренно НЕ зависит от [pw.binom.agentik.proto.Content] — маппинг
- * `:proto.Content ↔ Content` живёт в `Mapping.kt`. Структурно типы
- * идентичны, но даёт возможность заменить transport-протокол без миграции
- * таблиц.
- *
- * Image сериализуется в JSON через base64 (стандарт для kotlinx-serialization).
+ * Часть контента сообщения на уровне хранилища. Намеренно НЕ зависит от
+ * `pw.binom.agentik.proto.Content` — маппинг `:proto.Content ↔ Content` живёт
+ * в `Mapping.kt` storage impl'ов.
  */
 @Serializable
 sealed interface Content {

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/ConversationRecord.kt

@@ -1,4 +1,4 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.journal
 
 import kotlin.time.Instant
 

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/ConversationStore.kt

@@ -1,4 +1,4 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.journal
 
 import kotlin.time.Instant
 

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/Ids.kt

@@ -1,4 +1,4 @@
-package pw.binom.agentik.storage
+package pw.binom.agentik.journal
 
 import kotlin.uuid.Uuid
 
@@ -11,5 +11,4 @@ import kotlin.uuid.Uuid
  */
 object Ids {
     fun new(prefix: String): String = "$prefix-${Uuid.random()}"
-    fun reflection(): String = new("refl")
 }

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/JournalStore.kt

@@ -0,0 +1,41 @@
+package pw.binom.agentik.journal
+
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+import kotlin.time.Instant
+
+/**
+ * Append-only audit log сообщений — read-only представление.
+ *
+ * Producer-операция [MutableJournalStore.append] находится на
+ * [MutableJournalStore] — этот интерфейс только для чтения, чтобы
+ * consumer'ы физически не могли писать в audit log.
+ *
+ * Никаких обновлений, никакого удаления (кроме каскадного вместе
+ * с ConversationStore.delete).
+ */
+interface JournalStore : AutoCloseable {
+
+    suspend fun list(conversationId: String, after: Instant, offset: Int, limit: Int): List<MessageRecord>
+
+    /**
+     * Cold-flow paging через [list]. Default-реализация делает N+1 round-trip
+     * (по странице через `list()` пока не получит короткую страницу). Для
+     * in-memory backend'ов это OK; remote/SQLite impl'ы могут override'нуть
+     * на `Channel` / cursor-батчинг, чтобы избежать per-page round-trip.
+     */
+    fun listFlow(conversationId: String, after: Instant, pageSize: Int = PAGE_SIZE): Flow<MessageRecord> = flow {
+        var offset = 0
+        while (true) {
+            val page = list(conversationId, after, offset, pageSize)
+            if (page.isEmpty()) return@flow
+            for (rec in page) emit(rec)
+            if (page.size < pageSize) return@flow
+            offset += page.size
+        }
+    }
+
+    companion object {
+        const val PAGE_SIZE = 100
+    }
+}

journal-api/src/commonMain/kotlin/pw/binom/agentik/journal/MessageContext.kt

@@ -0,0 +1,12 @@
+package pw.binom.agentik.journal
+
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.json.JsonElement
+
+@Serializable
+data class MessageContext(
+    val origin: MessageOrigin,
+    val sourceId: String? = null,
+    val description: String? = null,
+    val metadata: JsonElement? = null,
+)