Refactor | CAKK-83 | 통합테스트 kt 전환 및 kotest 도입

cakk-api/build.gradle.kts

@@ -12,6 +12,7 @@ dependencies {
 	implementation("org.springframework.boot:spring-boot-starter-validation")
 	implementation("org.springframework.boot:spring-boot-starter-aop:3.3.0")
 	implementation("org.springframework:spring-tx")
+	implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
 	annotationProcessor("org.springframework.boot:spring-boot-configuration-processor")
 
 	// Security & OAuth
@@ -30,6 +31,8 @@ dependencies {
 	testImplementation("org.springframework.boot:spring-boot-starter-test")
 	testImplementation("org.springframework.security:spring-security-test")
 	testImplementation("com.navercorp.fixturemonkey:fixture-monkey-starter:1.0.23")
+	testImplementation("io.kotest:kotest-runner-junit5:${property("kotestVersion")}")
+	testImplementation("io.mockk:mockk:${property("mockKVersion")}")
 
 	// test container
 	testImplementation("org.testcontainers:junit-jupiter:1.19.7")

cakk-api/src/main/java/com/cakk/api/annotation/ApplicationEventListener.kt

@@ -0,0 +1,25 @@
+package com.cakk.api.annotation
+
+import org.springframework.core.annotation.AliasFor
+import org.springframework.stereotype.Component
+
+/**
+ * Indicates that an annotated class is a "ApplicationEventListener" (e.g. an event publish object).
+ *
+ *
+ * This annotation serves as a specialization of [@Component][Component],
+ * allowing for implementation classes to be autodetected through classpath scanning.
+ *
+ * @author komment
+ * @see Component
+ */
+@Target(AnnotationTarget.CLASS)
+@Retention(AnnotationRetention.RUNTIME)
+@MustBeDocumented
+@Component
+annotation class ApplicationEventListener(
+    /**
+     * Alias for [Component.value].
+     */
+    @get:AliasFor(annotation = Component::class) val value: String = ""
+)

cakk-api/src/main/java/com/cakk/api/dto/event/EmailWithVerificationCodeSendEvent.kt

@@ -0,0 +1,6 @@
+package com.cakk.api.dto.event
+
+data class EmailWithVerificationCodeSendEvent(
+    val email: String,
+    val code: String
+)

cakk-api/src/main/java/com/cakk/api/dto/event/ErrorAlertEvent.kt

@@ -0,0 +1,9 @@
+package com.cakk.api.dto.event
+
+import jakarta.servlet.http.HttpServletRequest
+
+data class ErrorAlertEvent(
+	val exception: Exception,
+	val request: HttpServletRequest,
+	val profile: String
+)

cakk-api/src/main/java/com/cakk/api/dto/event/IncreaseSearchCountEvent.kt

@@ -0,0 +1,5 @@
+package com.cakk.api.dto.event
+
+data class IncreaseSearchCountEvent(
+    val keyword: String
+)

cakk-api/src/main/java/com/cakk/api/listener/SearchEventListener.kt

@@ -0,0 +1,21 @@
+package com.cakk.api.listener
+
+import org.springframework.scheduling.annotation.Async
+import org.springframework.transaction.event.TransactionPhase
+import org.springframework.transaction.event.TransactionalEventListener
+
+import com.cakk.api.annotation.ApplicationEventListener
+import com.cakk.api.dto.event.IncreaseSearchCountEvent
+import com.cakk.domain.redis.repository.KeywordRedisRepository
+
+@ApplicationEventListener
+class SearchEventListener(
+	private val keywordRedisRepository: KeywordRedisRepository
+) {
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    fun increaseSearchCount(event: IncreaseSearchCountEvent) {
+        keywordRedisRepository.saveOrIncreaseSearchCount(event.keyword)
+    }
+}

cakk-api/src/main/java/com/cakk/api/mapper/EventMapper.java

@@ -58,13 +58,13 @@ public static CertificationMessage supplyCertificationMessageBy(final Certificat
 	}
 
 	public static VerificationMessage supplyVerificationMessageBy(final EmailWithVerificationCodeSendEvent event) {
-		return new VerificationMessage(event.email(), event.code());
+		return new VerificationMessage(event.getEmail(), event.getCode());
 	}
 
 	public static ErrorAlertMessage supplyErrorAlertMessageBy(final ErrorAlertEvent event) {
-		final String profile = event.profile();
-		final String stackTrace = Arrays.toString(event.exception().getStackTrace());
-		final HttpServletRequest request = event.request();
+		final String profile = event.getProfile();
+		final String stackTrace = Arrays.toString(event.getException().getStackTrace());
+		final HttpServletRequest request = event.getRequest();
 
 		return new ErrorAlertMessage(
 			profile,

cakk-api/src/main/java/com/cakk/api/service/cake/CakeService.java

@@ -62,9 +62,11 @@ public CakeImageListResponse findCakeImagesByCursorAndCakeShopId(final CakeSearc
 	public CakeImageListResponse findCakeImagesByCursorAndSearch(final CakeSearchByLocationRequest dto) {
 		final List<CakeImageResponseParam> cakeImages
 			= cakeReadFacade.searchCakeImagesByCursorAndSearchKeyword(dto.toParam());
-		final IncreaseSearchCountEvent event = new IncreaseSearchCountEvent(dto.keyword());
 
-		publisher.publishEvent(event);
+		if (nonNull(dto.keyword())) {
+			final IncreaseSearchCountEvent event = new IncreaseSearchCountEvent(dto.keyword());
+			publisher.publishEvent(event);
+		}
 
 		return CakeMapper.supplyCakeImageListResponse(cakeImages);
 	}

cakk-api/src/main/java/com/cakk/api/service/shop/ShopService.java

@@ -176,9 +176,11 @@ public CakeShopSearchResponse searchShopByKeyword(final CakeShopSearchRequest dt
 		final List<CakeShopBySearchParam> cakeShopBySearchParams = ShopMapper.supplyCakeShopBySearchParamListBy(result);
 
 		final CakeShops<CakeShopBySearchParam> cakeShops = new CakeShops<>(cakeShopBySearchParams, 4, pageSize);
-		final IncreaseSearchCountEvent event = com.cakk.api.mapper.EventMapper.supplyIncreaseSearchCountEventBy(dto.keyword());
 
-		publisher.publishEvent(event);
+		if (nonNull(dto.keyword())) {
+			final IncreaseSearchCountEvent event = com.cakk.api.mapper.EventMapper.supplyIncreaseSearchCountEventBy(dto.keyword());
+			publisher.publishEvent(event);
+		}
 
 		return ShopMapper.supplyCakeShopSearchResponseBy(cakeShops.getCakeShops());
 	}