kami/correx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(server): reinstate JournalCompactionService with real inference

Browse Source
This commit is contained in:
kami
2026-06-08 11:02:14 +04:00
parent 5c03d1a772
commit 54a54f4760
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/server/src/main/kotlin/com/correx/apps/server/Main.kt
+7
View File
@@ -58,6 +58,7 @@ import com.correx.core.toolintent.rules.NetworkHostRule
import com.correx.core.toolintent.rules.PathContainmentRule import com.correx.core.toolintent.rules.PathContainmentRule
import com.correx.apps.server.freestyle.FreestyleDriver import com.correx.apps.server.freestyle.FreestyleDriver
import com.correx.apps.server.inference.summarizeWithInference import com.correx.apps.server.inference.summarizeWithInference
import com.correx.core.kernel.orchestration.JournalCompactionService
import com.correx.apps.server.personalization.ProfileAdaptationService import com.correx.apps.server.personalization.ProfileAdaptationService
import com.correx.core.artifacts.kind.DefaultArtifactKindRegistry import com.correx.core.artifacts.kind.DefaultArtifactKindRegistry
import com.correx.core.events.types.ArtifactId import com.correx.core.events.types.ArtifactId
@@ -247,6 +248,11 @@ fun main() {
sandboxRoot = sandboxRoot, sandboxRoot = sandboxRoot,
defaultSystemPromptPath = toolsConfig.defaultSystemPromptPath, defaultSystemPromptPath = toolsConfig.defaultSystemPromptPath,
) )
val journalCompactionService = JournalCompactionService(
artifactStore = artifactStore,
summarize = { prompt -> summarizeWithInference(prompt, SessionId("system"), inferenceRouter) },
tokenThreshold = defaultOrchestrationConfig.journalCompactionTokenThreshold,
)
val orchestrator = DefaultSessionOrchestrator( val orchestrator = DefaultSessionOrchestrator(
repositories = repositories, repositories = repositories,
engines = engines, engines = engines,
@@ -254,6 +260,7 @@ fun main() {
artifactStore = artifactStore, artifactStore = artifactStore,
tokenizer = firstProvider.tokenizer, tokenizer = firstProvider.tokenizer,
decisionJournalRepository = decisionJournalRepository, decisionJournalRepository = decisionJournalRepository,
compactionService = journalCompactionService,
) )
val routerConfig = correxConfig.router val routerConfig = correxConfig.router
val embedder = InfrastructureModule.createEmbedderFromConfig(routerConfig.embedder) val embedder = InfrastructureModule.createEmbedderFromConfig(routerConfig.embedder)