subochev 4ad59d5f5d
ci / JVM build + tests (push) Has been cancelled
release / Publish KMP libraries → caffeine Nexus (release) Successful in 32s
feat(events): EventStore + AllEvent unified stream + replay endpoints
EventStore (persistent event log) и AllEvent (sealed wrapper для
третьего типа подписки — ВСЕ events в одном потоке). Touches 7 modules.

Архитектура:
  Producer (ChatAgent + ConversationEvents) → EventStore + SharedFlow
  ↓                                            ↓
  Live SSE (cold, no replay)         Replay endpoints (cursor-based)

(1) :storage-core — EventStore interface
  - append(record): idempotent по record.id (INSERT OR IGNORE)
  - query(conversationId?, afterId?, limit): пагинированный catchup
  - pruneOlderThan(instant): TTL cleanup
  - count(): maintenance метрика
  - @Serializable EventRecord(id, conversationId?, createdAt, type, payload)
  - enum EventType: AGENT_*/CONVERSATION_* (forward-compat fallback)
  - StorageBundle дополнен eventStore: EventStore? = null (backward-compat)

(2) :storage-inmemory — InMemoryEventStore
  - Thread-safe (Mutex), binarySearch для упорядоченной вставки
  - Записи сортируются по createdAt ASC, ties по id ASC (стабильно)
  - Idempotency по id (повторный append no-op)

(3) :storage-sqlite — SqliteEventStore
  - sqldelight schema: agent_event (id PK, conversation_id?, created_at,
    type, payload BLOB) + 2 индекса (conversation_id+created_at,
    created_at)
  - Миграция v3: CREATE TABLE IF NOT EXISTS (additive)
  - 5 запросов: insert, queryGlobal, queryByConv, pruneOlderThan, count
  - Forward-compat: неизвестный EventType в БД → fallback AGENT_CREATED
    (чтобы старые клиенты не падали на новых enum values)
  - Добавлен в SqliteStores (open/inMemory + asBundle())

(4) :standalone — Producer wiring
  - ChatAgent.persistAgentEvent() — fire-and-forget append при каждом
    AgentEvent (Created/Deleted/Renamed)
  - ConversationEvents — персистит в EventStore при каждом tryEmit/emit
    (концертный случай от connect disconnect)
  - ChatAgent.allEvents() — merge agent-events + snapshot всех живых
    диалогов в единый Flow<AllEvent>

(5) :proto — AllEvent sealed interface
  - AllEvent.Agent(date, event: AgentEvent)
  - AllEvent.Conversation(date, conversationId, event: Event)
  - Agent.allEvents(after): Flow<AllEvent> — третий тип подписки
    (в дополнение к events() и Conversation.events)

(6) :server — Endpoints
  - GET /events/all — SSE поток AllEvent (cold)
  - GET /events/replay?after_id=&limit= — пагинированный catchup
    (503 если EventStore не сконфигурирован)
  - GET /conversations/{id}/events/replay?after_id=&limit= — то же per-conv
  - Module.kt принимает eventStore: EventStore? параметром

(7) :client — Client API
  - AgentClient.allEvents(after) — подписка на /events/all SSE
  - AgentClient.replayAllEvents(afterId, limit) — catchup /events/replay
  - AgentClient.replayConversationEvents(convId, afterId, limit)
  - EventRecordDto — wire-зеркало EventRecord (клиент не зависит
    от :storage-core, определяет DTO локально; формат совместим с
    серверным JSON)

Тесты: 22 новых теста (12 InMemory + 10 Sqlite), все зелёные.
Все три слоя синхронизированы: proto contract + standalone impl +
server endpoint + client API.
2026-09-20 02:51:58 +03:00

agentik

Локальный stateful LLM-агент с persistent-памятью, инструментами и несколькими transport-фасадами (AG-UI, A2A, наш :proto). Реализован на Kotlin Multiplatform, выполняется как single JVM-jar. Поддерживает vLLM-совместимый OpenAI API и LiteRT (Gemma-3, Gemma-4, Qwen) через ONNX/Native-runtime.

Что внутри

agentik/
├── proto/             stateful KMP protocol: Agent / Conversation / Message / Event
├── server/            Ktor-фасад → /agentik (HTTP+JSON+SSE)
├── client/            Ktor-клиент → тот же /agentik, с KMP-native
├── skills/            парсер SKILL.md / *.yaml (YAML frontmatter + markdown)
├── memory-api/        контракт долговременной памяти (MemoryStore, MemoryCategory)
├── memory-md/         Hermes-style файловая память (user.md / world.md / ...)
├── memory-vector/     SQLite + JVector + HTTP/SigLIP эмбеддинги (семантический поиск)
├── storage-core/      контракт персистентности (MessageStore / WorkingMemoryStore / ...)
├── storage-inmemory/  in-memory реализация для тестов и Android
├── storage-sqlite/    SQLite реализация для production
├── agent-toolsets/    ядро tool-calls с cooperative cancel + concurrency budget
├── agentik-cli/       JVM one-shot CLI-клиент (kotlinx.cli) к /agentik
├── ~~agentik-tui/~~  ~~Compose-for-Mosaic TUI-клиент (desktop)~~ — исключён 2026-09-17
└── standalone/        single-jar HTTP-сервер со всеми transport'ами и движками

Каждый подмодуль имеет собственный README.md с деталями (см. "Модули" ниже).

Quickstart

1. Скачать fatjar

CI артефакты доступны на Gitea через GitHub Actions artifacts на tag-релизах, либо соберите из исходников:

git clone https://git.binom.pw/subochev/agentik
cd agentik
./gradlew :standalone:shadowJar

Результат: standalone/build/libs/agentik-0.1.0-all.jar (~10–250 МБ, зависит от LLM-backend'а).

2. Запустить с OpenAI-compatible backend (vLLM / Ollama / OpenAI)

AGENTIK_LLM_BACKEND=openai \
AGENTIK_LLM_API_URL=http://192.168.88.135:8001/v1 \
AGENTIK_LLM_MODEL=Qwen3.8-27B-NVFP4 \
AGENTIK_LLM_CONTEXT_TOKENS=115000 \
java --enable-native-access=ALL-UNNAMED -jar agentik-0.1.0-all.jar

3. Запустить с локальной LiteRT-моделью (Gemma-4-E2B)

AGENTIK_LLM_BACKEND=google \
AGENTIK_GOOGLE_MODEL_PATH=/root/gemma-4-E2B-it.litertlm \
java --enable-native-access=ALL-UNNAMED -jar agentik-0.1.0-all.jar pull-model   # скачать
java --enable-native-access=ALL-UNNAMED -jar agentik-0.1.0-all.jar              # запустить

Больше деталей по env'ам — в standalone/README.md.

Подключиться

# CLI
java --enable-native-access=ALL-UNNAMED -jar agentik-cli-0.1.0-SNAPSHOT-all.jar --help

# curl
curl http://localhost:8080/health

Модули

Где смотреть версии

Каталог gradle/libs.versions.toml. Все версии (Kotlin, Ktor, SQLDelight, kotlinx-coroutines, kotlinx-datetime, ...) сгруппированы в секции [versions]; все dep-aliases — в секции [libraries].

Версия самого agentik (cм. <version> в nexus.pom) — тоже в gradle.properties (через $AgentikVersion или env AGENTIK_VERSION). На tag-релизе (например v0.2.0) — CI подставляет версию из тега и публикует.

Публикация

./gradlew :<module>:publish → в caffeine (Nexus). Параметры через:

  • binom.repo.url (http://<your-nexus>/repository/caffeine/)
  • binom.repo.user
  • binom.repo.password

…или через переменные BINOM_REPO_URL, BINOM_REPO_USER, BINOM_REPO_PASSWORD (читаются в release workflow из secret'ов репозитория). Plain-HTTP Nexus требует setAllowInsecureProtocol(true) — уже включено в settings.gradle.kts.

CI/CD

Gitea Actions (https://git.binom.pw/subochev/agentik/actions):

  • .gitea/workflows/ci.yml — PR-build, прогон тестов, проверка shadowjar'ов.
  • .gitea/workflows/release.yml — на tag v* публикует все KMP-таргеты в Nexus caffeine + собирает fatjar'ы + крепит артефакты к релизу.

Что отличает от других агентских фреймворков

  • Stateful protocol — сервер сам владеет диалогом; переписка не пересобирается клиентом на каждый send (в отличие от AG-UI).
  • Все три транспорта в одном процессе — AG-UI, A2A, наш proto. Один fatjar — три API.
  • Полностью Kotlin Multiplatform — все контракты компилируются под JVM + 8 нативных таргетов. Можно встроить в iOS / Android / Desktop / CLI.
  • Прерывание tool-calls сохраняется в working memory — нет потери контекста, если пользователь нажал Ctrl-C во время долгого tool-вызова.

Лицензия

Apache-2.0 — смотрите LICENSE.

Участие в проекте

PR-ы приветствуются. Не забывайте синхронизировать версии в gradle/libs.versions.toml и обновлять per-module README при изменении API.

S
Description
No description provided
Readme 3.4 MiB
16 Latest
2026-09-23 12:59:58 +00:00
Languages
Kotlin 99.8%
Shell 0.2%