refactor: Implement EventProjector → EventPublisher pattern and fix Konsist violations

apps/scopes/build.gradle.kts

@@ -79,8 +79,25 @@ dependencies {
     testImplementation(libs.kotlinx.coroutines.test)
 }
 
+// Add a dedicated sourceSet for Native Image (separated from JVM main)
+sourceSets {
+    create("native") {
+        java.srcDir("src/native/kotlin")
+        resources.srcDir("src/native/resources")
+    }
+}
+
+// Inherit dependencies from main for the native sourceSet
+configurations.named("nativeImplementation").configure {
+    extendsFrom(configurations.getByName("implementation"))
+}
+configurations.named("nativeRuntimeOnly").configure {
+    extendsFrom(configurations.getByName("runtimeOnly"))
+}
+
+// Use the standard entrypoint for JVM runs
 application {
-    mainClass.set("io.github.kamiazya.scopes.apps.cli.MainKt")
+    mainClass.set("io.github.kamiazya.scopes.apps.cli.Main")
 }
 
 tasks.test {
@@ -90,9 +107,10 @@ tasks.test {
 graalvmNative {
     binaries {
         named("main") {
+            classpath.from(sourceSets.getByName("native").runtimeClasspath)
             imageName.set("scopes")
-            mainClass.set("io.github.kamiazya.scopes.apps.cli.MainKt")
-            useFatJar.set(true)
+            mainClass.set("io.github.kamiazya.scopes.apps.cli.nativeimage.NativeImageMain")
+            useFatJar.set(false)
 
             buildArgs.addAll(
                 listOf(
@@ -111,9 +129,10 @@ graalvmNative {
                     "--exclude-config",
                     ".*sqlite-jdbc.*\\.jar",
                     ".*native-image.*",
-                    "-H:ResourceConfigurationFiles=${layout.buildDirectory.get()}/resources/main/META-INF/native-image/resource-config.json",
-                    "-H:ReflectionConfigurationFiles=${layout.buildDirectory.get()}/resources/main/META-INF/native-image/reflect-config.json",
-                    "-H:JNIConfigurationFiles=${layout.buildDirectory.get()}/resources/main/META-INF/native-image/jni-config.json",
+                    "-H:ResourceConfigurationFiles=${layout.buildDirectory.get()}/resources/native/META-INF/native-image/resource-config.json",
+                    "-H:ReflectionConfigurationFiles=${layout.buildDirectory.get()}/resources/native/META-INF/native-image/reflect-config.json",
+                    "-H:JNIConfigurationFiles=${layout.buildDirectory.get()}/resources/native/META-INF/native-image/jni-config.json",
+                    "-H:SerializationConfigurationFiles=${layout.buildDirectory.get()}/resources/native/META-INF/native-image/serialization-config.json",
                 ),
             )
         }
@@ -215,3 +234,9 @@ tasks.register("nativeE2eTest") {
 // tasks.named("check") {
 //     dependsOn("nativeSmokeTest")
 // }
+
+
+// Avoid duplicate META-INF/native-image entries in native resources
+tasks.named<org.gradle.language.jvm.tasks.ProcessResources>("processNativeResources") {
+    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
+}

apps/scopes/src/main/kotlin/io/github/kamiazya/scopes/apps/cli/bootstrap/EventTypeRegistrar.kt

@@ -17,6 +17,10 @@ import io.github.kamiazya.scopes.scopemanagement.domain.event.ScopeDescriptionUp
 import io.github.kamiazya.scopes.scopemanagement.domain.event.ScopeParentChanged
 import io.github.kamiazya.scopes.scopemanagement.domain.event.ScopeRestored
 import io.github.kamiazya.scopes.scopemanagement.domain.event.ScopeTitleUpdated
+import io.github.kamiazya.scopes.scopemanagement.domain.event.AliasAssigned
+import io.github.kamiazya.scopes.scopemanagement.domain.event.AliasRemoved
+import io.github.kamiazya.scopes.scopemanagement.domain.event.AliasNameChanged
+import io.github.kamiazya.scopes.scopemanagement.domain.event.CanonicalAliasReplaced
 
 /**
  * Bootstrapper responsible for registering all domain event types.
@@ -56,6 +60,7 @@ class EventTypeRegistrar(private val eventTypeMapping: EventTypeMapping, private
 
     private fun registerScopeManagementEvents() {
         val events = listOf(
+            // Scope events
             ScopeCreated::class,
             ScopeDeleted::class,
             ScopeArchived::class,
@@ -67,6 +72,11 @@ class EventTypeRegistrar(private val eventTypeMapping: EventTypeMapping, private
             ScopeAspectRemoved::class,
             ScopeAspectsCleared::class,
             ScopeAspectsUpdated::class,
+            // Alias events
+            AliasAssigned::class,
+            AliasRemoved::class,
+            AliasNameChanged::class,
+            CanonicalAliasReplaced::class,
         )
 
         events.forEach { eventClass ->
@@ -81,6 +91,7 @@ class EventTypeRegistrar(private val eventTypeMapping: EventTypeMapping, private
         // This allows reading events that were persisted before stable IDs were introduced
         if (eventTypeMapping is DefaultEventTypeMapping) {
             val legacyEvents = listOf(
+                // Scope events
                 ScopeCreated::class,
                 ScopeDeleted::class,
                 ScopeArchived::class,
@@ -92,6 +103,11 @@ class EventTypeRegistrar(private val eventTypeMapping: EventTypeMapping, private
                 ScopeAspectRemoved::class,
                 ScopeAspectsCleared::class,
                 ScopeAspectsUpdated::class,
+                // Alias events
+                AliasAssigned::class,
+                AliasRemoved::class,
+                AliasNameChanged::class,
+                CanonicalAliasReplaced::class,
             )
 
             legacyEvents.forEach { eventClass ->

apps/scopes/src/main/kotlin/io/github/kamiazya/scopes/apps/cli/di/scopemanagement/ScopeManagementInfrastructureModule.kt

@@ -1,7 +1,17 @@
 package io.github.kamiazya.scopes.apps.cli.di.scopemanagement
 
+import io.github.kamiazya.scopes.contracts.eventstore.EventStoreCommandPort
+import io.github.kamiazya.scopes.contracts.eventstore.EventStoreQueryPort
+import io.github.kamiazya.scopes.platform.application.lifecycle.ApplicationBootstrapper
 import io.github.kamiazya.scopes.platform.application.port.TransactionManager
+import io.github.kamiazya.scopes.platform.domain.event.DomainEvent
 import io.github.kamiazya.scopes.platform.infrastructure.transaction.SqlDelightTransactionManager
+import io.github.kamiazya.scopes.platform.observability.logging.Logger
+import io.github.kamiazya.scopes.platform.observability.metrics.DefaultProjectionMetrics
+import io.github.kamiazya.scopes.platform.observability.metrics.InMemoryMetricsRegistry
+import io.github.kamiazya.scopes.platform.observability.metrics.MetricsRegistry
+import io.github.kamiazya.scopes.platform.observability.metrics.ProjectionMetrics
+import io.github.kamiazya.scopes.scopemanagement.application.port.EventPublisher
 import io.github.kamiazya.scopes.scopemanagement.db.ScopeManagementDatabase
 import io.github.kamiazya.scopes.scopemanagement.domain.repository.ActiveContextRepository
 import io.github.kamiazya.scopes.scopemanagement.domain.repository.AspectDefinitionRepository
@@ -17,13 +27,20 @@ import io.github.kamiazya.scopes.scopemanagement.infrastructure.adapters.ErrorMa
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.alias.generation.DefaultAliasGenerationService
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.alias.generation.providers.DefaultWordProvider
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.alias.generation.strategies.HaikunatorStrategy
+import io.github.kamiazya.scopes.scopemanagement.infrastructure.bootstrap.ActiveContextBootstrap
+import io.github.kamiazya.scopes.scopemanagement.infrastructure.bootstrap.AspectPresetBootstrap
+import io.github.kamiazya.scopes.scopemanagement.infrastructure.factory.EventSourcingRepositoryFactory
+import io.github.kamiazya.scopes.scopemanagement.infrastructure.projection.EventProjectionService
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightActiveContextRepository
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightAspectDefinitionRepository
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightContextViewRepository
+import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightEventOutboxRepository
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightScopeAliasRepository
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.repository.SqlDelightScopeRepository
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.service.AspectQueryFilterValidator
 import io.github.kamiazya.scopes.scopemanagement.infrastructure.sqldelight.SqlDelightDatabaseProvider
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.modules.SerializersModule
 import org.koin.core.qualifier.named
 import org.koin.dsl.module
 
@@ -98,32 +115,82 @@ val scopeManagementInfrastructureModule = module {
         ErrorMapper(logger = get())
     }
 
+    // Metrics infrastructure
+    single<MetricsRegistry> { InMemoryMetricsRegistry() }
+    single<ProjectionMetrics> {
+        DefaultProjectionMetrics(metricsRegistry = get())
+    }
+
+    // Serializers for domain events (Scope context)
+    single<SerializersModule> { io.github.kamiazya.scopes.scopemanagement.infrastructure.serialization.ScopeEventSerializersModule.create() }
+    single<Json>(named("scopeEventJson")) {
+        val module: SerializersModule = get()
+        Json {
+            serializersModule = module
+            ignoreUnknownKeys = true
+            isLenient = true
+            classDiscriminator = "type"
+        }
+    }
+
+    // Event projector for RDB projection
+    single {
+        EventProjectionService(
+            scopeRepository = get(),
+            scopeAliasRepository = get(),
+            logger = get(),
+            projectionMetrics = get(),
+        )
+    }
+
+    // Outbox repository + projector + publisher (processImmediately to preserve current behavior)
+    single<SqlDelightEventOutboxRepository> { SqlDelightEventOutboxRepository(get(named("scopeManagement"))) }
+    single {
+        io.github.kamiazya.scopes.scopemanagement.infrastructure.projection.OutboxProjectionService(
+            outboxRepository = get(),
+            projectionService = get(),
+            json = get(named("scopeEventJson")),
+            logger = get(),
+        )
+    }
+    single<EventPublisher> {
+        io.github.kamiazya.scopes.scopemanagement.infrastructure.projection.OutboxEventProjectionService(
+            outboxRepository = get(),
+            projector = get(),
+            json = get(named("scopeEventJson")),
+            logger = get(),
+            processImmediately = true,
+        )
+    }
+
     // Event Sourcing Repository using contracts
-    single<EventSourcingRepository<io.github.kamiazya.scopes.platform.domain.event.DomainEvent>> {
-        val eventStoreCommandPort: io.github.kamiazya.scopes.contracts.eventstore.EventStoreCommandPort = get()
-        val eventStoreQueryPort: io.github.kamiazya.scopes.contracts.eventstore.EventStoreQueryPort = get()
-        val logger: io.github.kamiazya.scopes.platform.observability.logging.Logger = get()
+    single<EventSourcingRepository<DomainEvent>> {
+        val eventStoreCommandPort: EventStoreCommandPort = get()
+        val eventStoreQueryPort: EventStoreQueryPort = get()
+        val logger: Logger = get()
+        val serializersModule: SerializersModule? = getOrNull()
 
-        io.github.kamiazya.scopes.scopemanagement.infrastructure.factory.EventSourcingRepositoryFactory.createContractBased(
+        EventSourcingRepositoryFactory.createContractBased(
             eventStoreCommandPort = eventStoreCommandPort,
             eventStoreQueryPort = eventStoreQueryPort,
             logger = logger,
+            serializersModule = serializersModule,
         )
     }
 
     // External Services are now provided by their own modules
     // UserPreferencesService is provided by UserPreferencesModule
 
     // Bootstrap services - registered as ApplicationBootstrapper for lifecycle management
-    single<io.github.kamiazya.scopes.platform.application.lifecycle.ApplicationBootstrapper>(qualifier = named("AspectPresetBootstrap")) {
-        io.github.kamiazya.scopes.scopemanagement.infrastructure.bootstrap.AspectPresetBootstrap(
+    single<ApplicationBootstrapper>(qualifier = named("AspectPresetBootstrap")) {
+        AspectPresetBootstrap(
             aspectDefinitionRepository = get(),
             logger = get(),
         )
     }
 
-    single<io.github.kamiazya.scopes.platform.application.lifecycle.ApplicationBootstrapper>(qualifier = named("ActiveContextBootstrap")) {
-        io.github.kamiazya.scopes.scopemanagement.infrastructure.bootstrap.ActiveContextBootstrap(
+    single<ApplicationBootstrapper>(qualifier = named("ActiveContextBootstrap")) {
+        ActiveContextBootstrap(
             activeContextRepository = get(),
             logger = get(),
         )

apps/scopes/src/main/kotlin/io/github/kamiazya/scopes/apps/cli/di/scopemanagement/ScopeManagementModule.kt

@@ -17,6 +17,7 @@ import io.github.kamiazya.scopes.scopemanagement.application.command.handler.con
 import io.github.kamiazya.scopes.scopemanagement.application.factory.ScopeFactory
 import io.github.kamiazya.scopes.scopemanagement.application.mapper.ApplicationErrorMapper
 import io.github.kamiazya.scopes.scopemanagement.application.port.DomainEventPublisher
+import io.github.kamiazya.scopes.scopemanagement.application.port.EventPublisher
 import io.github.kamiazya.scopes.scopemanagement.application.query.handler.aspect.GetAspectDefinitionHandler
 import io.github.kamiazya.scopes.scopemanagement.application.query.handler.aspect.ListAspectDefinitionsHandler
 import io.github.kamiazya.scopes.scopemanagement.application.query.handler.context.GetContextViewHandler
@@ -119,24 +120,27 @@ val scopeManagementModule = module {
         )
     }
 
-    // Use Case Handlers
+    // Use Case Handlers - Event Sourcing
     single {
         CreateScopeHandler(
-            scopeFactory = get(),
+            eventSourcingRepository = get(),
             scopeRepository = get(),
-            scopeAliasRepository = get(),
-            aliasGenerationService = get(),
+            hierarchyApplicationService = get(),
+            hierarchyService = get(),
             transactionManager = get(),
             hierarchyPolicyProvider = get(),
+            eventPublisher = get<io.github.kamiazya.scopes.scopemanagement.application.port.EventPublisher>(),
+            aliasGenerationService = get(),
             applicationErrorMapper = get(),
             logger = get(),
         )
     }
 
     single {
         UpdateScopeHandler(
+            eventSourcingRepository = get(),
+            eventPublisher = get<io.github.kamiazya.scopes.scopemanagement.application.port.EventPublisher>(),
             scopeRepository = get(),
-            scopeAliasRepository = get(),
             transactionManager = get(),
             applicationErrorMapper = get(),
             logger = get(),
@@ -145,7 +149,10 @@ val scopeManagementModule = module {
 
     single {
         DeleteScopeHandler(
+            eventSourcingRepository = get(),
+            eventPublisher = get<io.github.kamiazya.scopes.scopemanagement.application.port.EventPublisher>(),
             scopeRepository = get(),
+            scopeHierarchyService = get(),
             transactionManager = get(),
             applicationErrorMapper = get(),
             logger = get(),