domain_event_api 모듈 제거 (#222)

app-server/subprojects/spring_message/build.gradle.kts

@@ -7,7 +7,6 @@ dependencies {
     val kotlinLoggingVersion: String by project
 
     implementation(projects.stdlib)
-    implementation(projects.domainEventApi)
 
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("io.github.microutils:kotlin-logging-jvm:$kotlinLoggingVersion")

app-server/subprojects/spring_message/src/main/kotlin/club/staircrusher/spring_message/JacksonSerializedSpringEvent.kt

@@ -0,0 +1,9 @@
+package club.staircrusher.spring_message
+
+import club.staircrusher.stdlib.domain.event.DomainEvent
+import org.springframework.context.ApplicationEvent
+
+data class JacksonSerializedSpringEvent<T : DomainEvent>(
+    val type: Class<T>,
+    val value: String,
+): ApplicationEvent(value)

app-server/subprojects/spring_message/src/main/kotlin/club/staircrusher/spring_message/SpringEventListener.kt

@@ -1,21 +1,21 @@
 package club.staircrusher.spring_message
 
-import club.staircrusher.domain_event_api.ProtoEventConverter
 import club.staircrusher.stdlib.di.annotation.Component
 import club.staircrusher.stdlib.domain.event.DomainEventSubscriber
+import com.fasterxml.jackson.databind.ObjectMapper
 import mu.KotlinLogging
 import org.springframework.context.ApplicationListener
 
 @Component
 class SpringEventListener(
     private val domainEventSubscribers: List<DomainEventSubscriber<*>>,
-    private val protoEventConverter: ProtoEventConverter,
-): ApplicationListener<ProtoSpringEvent> {
+    private val objectMapper: ObjectMapper,
+): ApplicationListener<JacksonSerializedSpringEvent<*>> {
     private val logger = KotlinLogging.logger {}
 
     @Suppress("TooGenericExceptionCaught")
-    override fun onApplicationEvent(springEvent: ProtoSpringEvent) {
-        val event = protoEventConverter.convertProtoToEvent(springEvent.proto)
+    override fun onApplicationEvent(springEvent: JacksonSerializedSpringEvent<*>) {
+        val event = objectMapper.readValue(springEvent.value, springEvent.type)
         domainEventSubscribers.forEach {
             try {
                 it(event)

app-server/subprojects/spring_message/src/main/kotlin/club/staircrusher/spring_message/SpringEventPublisher.kt

@@ -1,15 +1,15 @@
 package club.staircrusher.spring_message
 
-import club.staircrusher.domain_event_api.ProtoEventConverter
 import club.staircrusher.stdlib.di.annotation.Component
 import club.staircrusher.stdlib.domain.event.DomainEvent
 import club.staircrusher.stdlib.domain.event.DomainEventPublisher
+import com.fasterxml.jackson.databind.ObjectMapper
 import org.springframework.context.ApplicationEventPublisher
 import org.springframework.context.ApplicationEventPublisherAware
 
 @Component
 class SpringEventPublisher(
-    private val protoEventConverter: ProtoEventConverter,
+    private val objectMapper: ObjectMapper,
 ): ApplicationEventPublisherAware, DomainEventPublisher {
     lateinit var eventPublisher: ApplicationEventPublisher
 
@@ -18,7 +18,10 @@ class SpringEventPublisher(
     }
 
     override suspend fun publishEvent(event: DomainEvent) {
-        val message = protoEventConverter.convertEventToProto(event)
-        eventPublisher.publishEvent(ProtoSpringEvent(message))
+        val value = objectMapper.writeValueAsString(event)
+        eventPublisher.publishEvent(JacksonSerializedSpringEvent(
+            type = event.javaClass,
+            value = value,
+        ))
     }
 }

app-server/subprojects/spring_web/src/main/kotlin/club/staircrusher/spring_web/jackson/SccJacksonConfig.kt

@@ -0,0 +1,20 @@
+package club.staircrusher.spring_web.jackson
+
+import com.fasterxml.jackson.annotation.JsonInclude
+import org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder
+
+
+@Configuration(proxyBeanMethods = false)
+open class SccJacksonConfig {
+    @Bean
+    open fun jsonCustomizer(): Jackson2ObjectMapperBuilderCustomizer? {
+        return Jackson2ObjectMapperBuilderCustomizer { builder: Jackson2ObjectMapperBuilder ->
+            builder
+                .serializationInclusion(JsonInclude.Include.NON_ABSENT)
+                .failOnUnknownProperties(false)
+        }
+    }
+}

docs/architecture-app-server.md

@@ -63,7 +63,7 @@ Bounded context의 경계는 프로젝트가 발전함에 따라 얼마든지 
 
 Domain event의 발행과 구독은 아래의 workflow로 작업할 수 있습니다.
 
-1. Domain event 정의 - `domain_event` 모듈과 `domain_event_api` 모듈에서 domain event를 정의합니다. 정의하는 방식은 다른 domain event가 정의된 방식을 참고해 주세요.
+1. Domain event 정의 - `domain_event` 모듈에서 domain event를 정의합니다. 정의하는 방식은 다른 domain event가 정의된 방식을 참고해 주세요.
 2. Domain event 발행 - `stdlib` 모듈의 `DomainEventPublisher`를 사용해서 domain event를 발행할 수 있습니다.
 3. Domain event 구독 - `stdlib` 모듈의 `DomainEventSubscriber`를 사용해서 domain event를 구독할 수 있습니다.