fix(kernel,server): wire JournalCompactionService in production + fix SessionSummaryProjector import

This commit is contained in:
2026-06-08 10:20:30 +04:00
parent 7cec168e86
commit 2b1faeaadd
@@ -26,6 +26,7 @@ import com.correx.core.inference.InferenceRouter
import com.correx.core.inference.ModelCapability import com.correx.core.inference.ModelCapability
import com.correx.core.kernel.orchestration.DefaultOrchestrationReducer import com.correx.core.kernel.orchestration.DefaultOrchestrationReducer
import com.correx.core.kernel.orchestration.DefaultSessionOrchestrator import com.correx.core.kernel.orchestration.DefaultSessionOrchestrator
import com.correx.core.kernel.orchestration.JournalCompactionService
import com.correx.core.kernel.orchestration.OrchestrationConfig import com.correx.core.kernel.orchestration.OrchestrationConfig
import com.correx.core.kernel.orchestration.OrchestrationProjector import com.correx.core.kernel.orchestration.OrchestrationProjector
import com.correx.core.kernel.orchestration.OrchestrationRepository import com.correx.core.kernel.orchestration.OrchestrationRepository
@@ -235,6 +236,18 @@ fun main() {
workspaceToolRegistryProvider = wsToolRegistryProvider, workspaceToolRegistryProvider = wsToolRegistryProvider,
) )
val decisionJournalRepository = InfrastructureModule.createDecisionJournalRepository(eventStore) val decisionJournalRepository = InfrastructureModule.createDecisionJournalRepository(eventStore)
val defaultOrchestrationConfig = OrchestrationConfig(
sandboxRoot = sandboxRoot,
defaultSystemPromptPath = toolsConfig.defaultSystemPromptPath,
)
val journalCompactionService = JournalCompactionService(
artifactStore = artifactStore,
summarize = { prompt ->
// TODO: wire real LLM summarizer — returns placeholder until inference is wired here
"Compacted journal summary (${prompt.lines().size} records)"
},
tokenThreshold = defaultOrchestrationConfig.journalCompactionTokenThreshold,
)
val orchestrator = DefaultSessionOrchestrator( val orchestrator = DefaultSessionOrchestrator(
repositories = repositories, repositories = repositories,
engines = engines, engines = engines,
@@ -242,10 +255,7 @@ fun main() {
artifactStore = artifactStore, artifactStore = artifactStore,
tokenizer = firstProvider.tokenizer, tokenizer = firstProvider.tokenizer,
decisionJournalRepository = decisionJournalRepository, decisionJournalRepository = decisionJournalRepository,
) compactionService = journalCompactionService,
val defaultOrchestrationConfig = OrchestrationConfig(
sandboxRoot = sandboxRoot,
defaultSystemPromptPath = toolsConfig.defaultSystemPromptPath,
) )
val routerConfig = correxConfig.router val routerConfig = correxConfig.router
val embedder = InfrastructureModule.createEmbedderFromConfig(routerConfig.embedder) val embedder = InfrastructureModule.createEmbedderFromConfig(routerConfig.embedder)