From a05e260457748b23fe9a394550dbd8216d479eaf Mon Sep 17 00:00:00 2001
From: subochev <caffeine.mgn@gmail.com>
Date: Sun, 20 Sep 2026 15:56:59 +0300
Subject: [PATCH] refactor(event-store): default impls for
 conversationEvents/agentEvents
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Методы conversationEvents() и agentEvents() теперь default в интерфейсе:
реализуют фильтрацию через [events] + filterIsInstance.

Зачем:
  - Минимальный контракт для impl — достаточно реализовать только events().
  - InMemoryEventStore и любой новый backend получают работающие
    specialized views автоматически, без копипасты filterIsInstance.
  - Persistent impl'ы (SQL/ksqlite) могут override'нуть для эффективности
    (WHERE conversation_id = ? — не тянуть все events в память), но
    контракт корректен и без override.

Семантика идентична:
  - conversationEvents(after, null)   = events().filterIsInstance<Conversation>()
  - conversationEvents(after, "c-1") = events()...filter { it.conversationId == "c-1" }
  - agentEvents(after)               = events().filterIsInstance<Agent>()

Imports добавлены: kotlinx.coroutines.flow.filter, filterIsInstance.
---
 .../pw/binom/agentik/eventStore/EventStore.kt | 34 +++++++++++++++----
 1 file changed, 27 insertions(+), 7 deletions(-)

diff --git a/event-store/src/commonMain/kotlin/pw/binom/agentik/eventStore/EventStore.kt b/event-store/src/commonMain/kotlin/pw/binom/agentik/eventStore/EventStore.kt
index 3e1cbc0..8a54970 100644
--- a/event-store/src/commonMain/kotlin/pw/binom/agentik/eventStore/EventStore.kt
+++ b/event-store/src/commonMain/kotlin/pw/binom/agentik/eventStore/EventStore.kt
@@ -1,6 +1,8 @@
 package pw.binom.agentik.eventStore
 
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.filter
+import kotlinx.coroutines.flow.filterIsInstance
 import kotlin.time.Instant
 import pw.binom.agentik.proto.CommonEvent
 
@@ -72,13 +74,23 @@ interface EventStore : AutoCloseable {
      * - [conversationId] != null → события **только этого** диалога.
      *
      * Семантика `after` идентична [events] (catchup + live).
-     * Возвращаемый тип — конкретный subtype [CommonEvent.Conversation],
-     * так что caller'у не нужно `.filterIsInstance<...>()` на стороне клиента.
-     *
-     * Для реализации: самый дешёвый путь — `events(after).filterIsInstance<...>()`,
-     * но persistent impl'ы могут делать `WHERE conversation_id = ?` на уровне БД.
+     * Возвращаемый тип — конкретный subtype [CommonEvent.Conversation].
      */
-    fun conversationEvents(after: Instant?, conversationId: String? = null): Flow<CommonEvent.Conversation>
+    /**
+     * **Default implementation** (читает все events + фильтрует).
+     *
+     * Простая реализация через [events] + filterIsInstance. Реализации
+     * могут override'нуть для эффективности (например, добавить SQL
+     * `WHERE conversation_id = ?` чтобы не тянуть всё в память), но
+     * контракт корректен и без override.
+     */
+    fun conversationEvents(after: Instant?, conversationId: String? = null): Flow<CommonEvent.Conversation> =
+        events(after)
+            .filterIsInstance<CommonEvent.Conversation>()
+            .let { filtered ->
+                if (conversationId == null) filtered
+                else filtered.filter { it.conversationId == conversationId }
+            }
 
     /**
      * Subscribe на **только agent events** ([CommonEvent.Agent] —
@@ -90,7 +102,15 @@ interface EventStore : AutoCloseable {
      * Полезно для admin-дашборда, который хочет видеть только lifecycle
      * диалогов без деталей ходов.
      */
-    fun agentEvents(after: Instant?): Flow<CommonEvent.Agent>
+    /**
+     * **Default implementation** (читает все events + фильтрует по типу).
+     *
+     * Простая реализация через [events] + filterIsInstance. Реализации
+     * могут override'нуть для эффективности (например, читать только agent
+     * row'ы из БД), но контракт корректен и без override.
+     */
+    fun agentEvents(after: Instant?): Flow<CommonEvent.Agent> =
+        events(after).filterIsInstance<CommonEvent.Agent>()
 
     /**
      * Date **стартовой точки** буфера.