비즈니스 로직에 트랜잭션을 추가한다. (#79)

fix: add transactions

Author: earlgrey02

domain/src/main/kotlin/com/gotchai/domain/auth/adapter/in/AuthCommandService.kt

@@ -44,6 +44,7 @@ class AuthCommandService(
     @Value("\${jwt.refresh-token-expiration}")
     private val refreshTokenExpiration: Duration
 ) : AuthCommandUseCase {
+    @Transactional
     override fun login(
         deviceId: String?,
         command: LoginCommand

domain/src/main/kotlin/com/gotchai/domain/badge/adapter/in/BadgeQueryService.kt

@@ -7,16 +7,19 @@ import com.gotchai.domain.badge.port.`in`.BadgeQueryUseCase
 import com.gotchai.domain.badge.port.out.BadgeQueryPort
 import com.gotchai.domain.badge.port.out.UserBadgeQueryPort
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
 
 @Service
 class BadgeQueryService(
     private val badgeQueryPort: BadgeQueryPort,
     private val userBadgeQueryPort: UserBadgeQueryPort
 ) : BadgeQueryUseCase {
+    @Transactional(readOnly = true)
     override fun getBadgeById(badgeId: Long): Badge =
         badgeQueryPort.getBadgeById(badgeId)
             ?: throw BadgeNotFoundException()
 
+    @Transactional(readOnly = true)
     override fun getMyBadges(userId: Long): List<Badge> {
         val userBadges = userBadgeQueryPort.getUserBadgesByUserId(userId)
         val badges =
@@ -26,6 +29,7 @@ class BadgeQueryService(
         return badges
     }
 
+    @Transactional(readOnly = true)
     override fun getBadgeByExamIdAndTier(
         examId: Long,
         tier: Tier

domain/src/main/kotlin/com/gotchai/domain/exam/adapter/in/ExamQueryService.kt

@@ -7,24 +7,29 @@ import com.gotchai.domain.exam.port.out.ExamHistoryQueryPort
 import com.gotchai.domain.exam.port.out.ExamQueryPort
 import com.gotchai.domain.quiz.port.out.QuizQueryPort
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
 
 @Service
 class ExamQueryService(
     private val examQueryPort: ExamQueryPort,
     private val examHistoryQueryPort: ExamHistoryQueryPort,
     private val quizQueryPort: QuizQueryPort
 ) : ExamQueryUseCase {
+    @Transactional(readOnly = true)
     override fun getExamById(examId: Long): Exam = examQueryPort.getExamById(examId) ?: throw ExamNotFoundException()
 
+    @Transactional(readOnly = true)
     override fun getExams(): List<Exam> = examQueryPort.getExams()
 
+    @Transactional(readOnly = true)
     override fun getExamsByUserId(userId: Long): List<Exam> {
         val examHistories = examHistoryQueryPort.getExamHistoriesByUserIdAndSolvedTrue(userId)
         val exams = examQueryPort.getExamsByInIn(examHistories.map { it.id })
 
         return exams
     }
 
+    @Transactional(readOnly = true)
     override fun getExamParticipantCountById(examId: Long): Int =
         examHistoryQueryPort
             .getExamHistoriesByExamIdAndSolvedTrue(examId)

domain/src/main/kotlin/com/gotchai/domain/quiz/adapter/in/QuizQueryService.kt

@@ -7,12 +7,14 @@ import com.gotchai.domain.quiz.port.`in`.QuizQueryUseCase
 import com.gotchai.domain.quiz.port.out.QuizPickQueryPort
 import com.gotchai.domain.quiz.port.out.QuizQueryPort
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
 
 @Service
 class QuizQueryService(
     private val quizQueryPort: QuizQueryPort,
     private val quizPickQueryPort: QuizPickQueryPort
 ) : QuizQueryUseCase {
+    @Transactional(readOnly = true)
     override fun getQuizById(quizId: Long): GetQuizResult {
         val quiz = quizQueryPort.getQuizById(quizId) ?: throw QuizNotFoundException()
         val quizPicks = quizPickQueryPort.getQuizPicksByQuizId(quiz.id)

domain/src/main/kotlin/com/gotchai/domain/user/adapter/in/ProfileQueryService.kt

@@ -5,11 +5,13 @@ import com.gotchai.domain.user.exception.ProfileNotFoundException
 import com.gotchai.domain.user.port.`in`.ProfileQueryUseCase
 import com.gotchai.domain.user.port.out.ProfileQueryPort
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
 
 @Service
 class ProfileQueryService(
     private val profileQueryPort: ProfileQueryPort
 ) : ProfileQueryUseCase {
+    @Transactional(readOnly = true)
     override fun getProfileByUserId(userId: Long): Profile? =
         profileQueryPort.getProfileByUserId(userId) ?: throw ProfileNotFoundException()
 }

storage/rdb/src/main/kotlin/com/gotchai/storage/rdb/user/adapter/out/UserQueryAdapter.kt

@@ -3,18 +3,21 @@ package com.gotchai.storage.rdb.user.adapter.out
 import com.gotchai.domain.user.entity.User
 import com.gotchai.domain.user.port.out.UserQueryPort
 import com.gotchai.storage.rdb.global.annotation.Adapter
+import com.gotchai.storage.rdb.global.annotation.ReadOnlyTransactional
 import com.gotchai.storage.rdb.user.repository.UserJpaRepository
 import org.springframework.data.repository.findByIdOrNull
 
 @Adapter
 class UserQueryAdapter(
     private val userRepository: UserJpaRepository
 ) : UserQueryPort {
+    @ReadOnlyTransactional
     override fun getUserById(id: Long): User? =
         userRepository
             .findByIdOrNull(id)
             ?.toUser()
 
+    @ReadOnlyTransactional
     override fun getUserByEmail(email: String): User? =
         userRepository
             .findByEmail(email)