release: 1.3.3 (#143)

Author: devxb

src/main/kotlin/org/gitanimals/core/CoroutineScope.kt

@@ -1,10 +1,7 @@
 package org.gitanimals.core
 
 import jakarta.annotation.PreDestroy
-import kotlinx.coroutines.CoroutineDispatcher
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.asCoroutineDispatcher
-import kotlinx.coroutines.launch
+import kotlinx.coroutines.*
 import kotlinx.coroutines.slf4j.MDCContext
 import org.gitanimals.core.GracefulShutdownDispatcher.executorService
 import org.slf4j.LoggerFactory

src/main/kotlin/org/gitanimals/quiz/infra/hibernate/QuizDeletedHibernateEventListener.kt

@@ -1,30 +1,50 @@
 package org.gitanimals.quiz.infra.hibernate
 
+import org.gitanimals.core.GracefulShutdownDispatcher.gracefulLaunch
 import org.gitanimals.quiz.domain.approved.Quiz
 import org.gitanimals.quiz.infra.similarity.QuizSimilarityRepository
 import org.hibernate.event.spi.PostDeleteEvent
 import org.hibernate.event.spi.PostDeleteEventListener
 import org.hibernate.persister.entity.EntityPersister
 import org.slf4j.LoggerFactory
+import org.springframework.context.ApplicationEventPublisher
+import org.springframework.context.event.EventListener
 import org.springframework.stereotype.Component
 
 @Component
 class QuizDeletedHibernateEventListener(
-    private val quizSimilarityRepository: QuizSimilarityRepository,
+    private val applicationEventPublisher: ApplicationEventPublisher,
 ) : PostDeleteEventListener {
 
-    private val logger = LoggerFactory.getLogger(this::class.simpleName)
-
     override fun requiresPostCommitHandling(persister: EntityPersister): Boolean =
         persister.mappedClass == Quiz::class.java
 
     override fun onPostDelete(event: PostDeleteEvent) {
         if (event.entity is Quiz) {
             val quiz = event.entity as Quiz
+            applicationEventPublisher.publishEvent(QuizDeleteLogicDelegator.QuizDeleted(quiz.id))
+        }
+    }
+}
+
+@Component
+class QuizDeleteLogicDelegator(
+    private val quizSimilarityRepository: QuizSimilarityRepository,
+) {
+
+    private val logger = LoggerFactory.getLogger(this::class.simpleName)
+
+    data class QuizDeleted(
+        val quizId: Long,
+    )
+
+    @EventListener(QuizDeleted::class)
+    fun listenQuizDeleted(event: QuizDeleted) {
+        gracefulLaunch {
             runCatching {
-                quizSimilarityRepository.deleteByQuizId(quiz.id)
+                quizSimilarityRepository.deleteByQuizId(event.quizId)
             }.getOrElse {
-                logger.error("Cannot delete quiz similarity must fix it. quizId: \"${quiz.id}\"")
+                logger.error("Cannot delete quiz similarity must fix it. quizId: \"${event.quizId}\"")
             }
         }
     }

src/main/kotlin/org/gitanimals/quiz/infra/hibernate/QuizSolveContextDoneHibernateEventListener.kt

@@ -1,5 +1,6 @@
 package org.gitanimals.quiz.infra.hibernate
 
+import org.gitanimals.core.GracefulShutdownDispatcher.gracefulLaunch
 import org.gitanimals.core.IdGenerator
 import org.gitanimals.inbox.domain.InboxType
 import org.gitanimals.quiz.app.IdentityApi
@@ -12,45 +13,72 @@ import org.hibernate.event.spi.PostUpdateEvent
 import org.hibernate.event.spi.PostUpdateEventListener
 import org.hibernate.persister.entity.EntityPersister
 import org.slf4j.LoggerFactory
+import org.springframework.context.ApplicationEventPublisher
+import org.springframework.context.event.EventListener
 import org.springframework.stereotype.Component
 
 @Component
 class QuizSolveContextDoneHibernateEventListener(
-    private val inboxApi: InboxApi,
-    private val identityApi: IdentityApi,
+    private val applicationEventPublisher: ApplicationEventPublisher,
 ) : PostUpdateEventListener {
 
-    private val logger = LoggerFactory.getLogger(this::class.simpleName)
-
     override fun requiresPostCommitHandling(persister: EntityPersister): Boolean =
         persister.mappedClass == QuizSolveContext::class.java
 
     override fun onPostUpdate(event: PostUpdateEvent) {
         if (event.entity is QuizSolveContext) {
             val quizSolveContext = event.entity as QuizSolveContext
-            if (quizSolveContext.getStatus() == QuizSolveContextStatus.DONE) {
+            applicationEventPublisher.publishEvent(
+                QuizSolveContextDoneLogicDelegator.QuizSolveContextDone(
+                    userId = quizSolveContext.userId,
+                    prize = quizSolveContext.getPrize(),
+                    status = quizSolveContext.getStatus(),
+                )
+            )
+        }
+    }
+}
+
+@Component
+class QuizSolveContextDoneLogicDelegator(
+    private val inboxApi: InboxApi,
+    private val identityApi: IdentityApi,
+) {
+
+    private val logger = LoggerFactory.getLogger(this::class.simpleName)
+
+    data class QuizSolveContextDone(
+        val userId: Long,
+        val prize: Int,
+        val status: QuizSolveContextStatus,
+    )
+
+    @EventListener(QuizSolveContextDone::class)
+    fun listenQUizSolveContextDone(event: QuizSolveContextDone) {
+        gracefulLaunch {
+            if (event.status == QuizSolveContextStatus.DONE) {
                 runCatching {
                     identityApi.increaseUserPointsById(
-                        userId = quizSolveContext.userId,
-                        point = quizSolveContext.getPrize().toLong(),
+                        userId = event.userId,
+                        point = event.prize.toLong(),
                         idempotencyKey = IdGenerator.generate().toString(),
                     )
                 }.onSuccess {
                     inboxApi.inputInbox(
                         InboxInputRequest(
                             inboxData = InboxData(
-                                userId = quizSolveContext.userId,
+                                userId = event.userId,
                                 type = InboxType.INBOX,
                                 title = "Quiz prize arrived.",
-                                body = "Congratulations! You got ${quizSolveContext.getPrize()} point by solving quiz.",
+                                body = "Congratulations! You got ${event.prize} point by solving quiz.",
                                 image = "https://avatars.githubusercontent.com/u/171903401?s=200&v=4",
                                 redirectTo = "NO_REDIRECT",
                             )
                         )
                     )
                 }.onFailure {
                     logger.error(
-                        "Cannot give point to user. userId: \"${quizSolveContext.userId}\", missing point: \"${quizSolveContext.getPrize()}\"",
+                        "Cannot give point to user. userId: \"${event.userId}\", missing point: \"${event.prize}\"",
                         it
                     )
                 }