refactor(metrics): MetricsApplicationService를 MetricsService로 이름 변경

- MetricsApplicationService 클래스를 MetricsService로 리팩토링
- 관련된 모든 의존성 및 호출 부분 수정

Author: hyujikoh

apps/commerce-streamer/src/main/java/com/loopers/application/event/EventProcessingFacade.java

@@ -7,7 +7,7 @@
 
 import com.loopers.application.event.dto.EventProcessingResult.CatalogEventResult;
 import com.loopers.application.event.dto.EventProcessingResult.OrderEventResult;
-import com.loopers.application.metrics.MetricsApplicationService;
+import com.loopers.application.metrics.MetricsService;
 import com.loopers.cache.dto.CachePayloads.RankingScore;
 import com.loopers.domain.ranking.RankingService;
 import com.loopers.infrastructure.event.DomainEventEnvelope;
@@ -47,7 +47,7 @@
 public class EventProcessingFacade {
 
     // Application Layer 의존성
-    private final MetricsApplicationService metricsApplicationService;
+    private final MetricsService metricsService;
 
     // Domain Layer 의존성
     private final RankingService rankingService;
@@ -76,12 +76,12 @@ public CatalogEventResult processCatalogEvent(Object eventValue) {
         if (isOldEvent(envelope.occurredAtEpochMillis())) {
             log.debug("Ignoring old event: eventId={}, occurredAt={}",
                     envelope.eventId(), envelope.occurredAtEpochMillis());
-            metricsApplicationService.tryMarkHandled(envelope.eventId());
+            metricsService.tryMarkHandled(envelope.eventId());
             return CatalogEventResult.notProcessed();
         }
 
         // 멱등성 체크
-        if (!metricsApplicationService.tryMarkHandled(envelope.eventId())) {
+        if (!metricsService.tryMarkHandled(envelope.eventId())) {
             log.debug("Event already processed: {}", envelope.eventId());
             return CatalogEventResult.notProcessed();
         }
@@ -116,12 +116,12 @@ public OrderEventResult processOrderEvent(Object eventValue) {
         if (isOldEvent(envelope.occurredAtEpochMillis())) {
             log.debug("Ignoring old event: eventId={}, occurredAt={}",
                     envelope.eventId(), envelope.occurredAtEpochMillis());
-            metricsApplicationService.tryMarkHandled(envelope.eventId());
+            metricsService.tryMarkHandled(envelope.eventId());
             return OrderEventResult.notProcessed();
         }
 
         // 멱등성 체크
-        if (!metricsApplicationService.tryMarkHandled(envelope.eventId())) {
+        if (!metricsService.tryMarkHandled(envelope.eventId())) {
             log.debug("Event already processed: {}", envelope.eventId());
             return OrderEventResult.notProcessed();
         }
@@ -163,7 +163,7 @@ private CatalogEventResult processProductView(DomainEventEnvelope envelope) {
             return CatalogEventResult.notProcessed();
         }
 
-        metricsApplicationService.incrementView(payload.productId(), envelope.occurredAtEpochMillis());
+        metricsService.incrementView(payload.productId(), envelope.occurredAtEpochMillis());
         log.debug("Processed PRODUCT_VIEW for productId: {}", payload.productId());
 
         RankingScore rankingScore = rankingService.generateRankingScore(envelope);
@@ -178,7 +178,7 @@ private CatalogEventResult processLikeAction(DomainEventEnvelope envelope) {
         }
 
         final int delta = "LIKE".equals(payload.action()) ? 1 : -1;
-        metricsApplicationService.applyLikeDelta(payload.productId(), delta, envelope.occurredAtEpochMillis());
+        metricsService.applyLikeDelta(payload.productId(), delta, envelope.occurredAtEpochMillis());
         log.debug("Processed LIKE_ACTION for productId: {}, action: {}", payload.productId(), payload.action());
 
         RankingScore rankingScore = rankingService.generateRankingScore(envelope);
@@ -192,7 +192,7 @@ private CatalogEventResult processStockDepleted(DomainEventEnvelope envelope) {
             return CatalogEventResult.notProcessed();
         }
 
-        metricsApplicationService.handleStockDepleted(
+        metricsService.handleStockDepleted(
                 payload.productId(),
                 payload.brandId(),
                 payload.remainingStock(),
@@ -218,7 +218,7 @@ private OrderEventResult processPaymentSuccess(DomainEventEnvelope envelope) {
             return OrderEventResult.notProcessed();
         }
 
-        metricsApplicationService.addSales(payload.productId(), payload.quantity(), envelope.occurredAtEpochMillis());
+        metricsService.addSales(payload.productId(), payload.quantity(), envelope.occurredAtEpochMillis());
 
         log.debug("Processed PAYMENT_SUCCESS - orderId: {}, productId: {}, quantity: {}, totalPrice: {}",
                 payload.orderId(), payload.productId(), payload.quantity(), payload.totalPrice());

…n/metrics/MetricsApplicationService.java …/application/metrics/MetricsService.javaapps/commerce-streamer/src/main/java/com/loopers/application/metrics/MetricsApplicationService.java renamed to apps/commerce-streamer/src/main/java/com/loopers/application/metrics/MetricsService.java apps/commerce-streamer/src/main/java/com/loopers/application/metrics/MetricsApplicationService.java renamed to apps/commerce-streamer/src/main/java/com/loopers/application/metrics/MetricsService.java

@@ -40,7 +40,7 @@
 @Service
 @RequiredArgsConstructor
 @Slf4j
-public class MetricsApplicationService {
+public class MetricsService {
 
     // Domain Layer 의존성
     private final ProductMetricsService productMetricsService;

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/scheduler/MetricsLockCleanupScheduler.java

@@ -3,7 +3,7 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import com.loopers.application.metrics.MetricsApplicationService;
+import com.loopers.application.metrics.MetricsService;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -21,15 +21,15 @@
 @Slf4j
 public class MetricsLockCleanupScheduler {
 
-    private final MetricsApplicationService metricsApplicationService;
+    private final MetricsService metricsService;
 
     /**
      * 사용하지 않는 락 정리 (5분마다)
      */
     @Scheduled(fixedRate = 5 * 60 * 1000) // 5분
     public void cleanupUnusedLocks() {
         try {
-            metricsApplicationService.cleanupUnusedLocks();
+            metricsService.cleanupUnusedLocks();
         } catch (Exception e) {
             log.error("락 정리 중 오류 발생", e);
         }
@@ -41,7 +41,7 @@ public void cleanupUnusedLocks() {
     @Scheduled(fixedRate = 10 * 60 * 1000) // 10분
     public void cleanupProcessedEvents() {
         try {
-            metricsApplicationService.cleanupProcessedEvents();
+            metricsService.cleanupProcessedEvents();
         } catch (Exception e) {
             log.error("처리된 이벤트 캐시 정리 중 오류 발생", e);
         }
@@ -53,7 +53,7 @@ public void cleanupProcessedEvents() {
     @Scheduled(fixedRate = 60 * 1000) // 1분
     public void monitorLockStatus() {
         try {
-            metricsApplicationService.logLockStatus();
+            metricsService.logLockStatus();
         } catch (Exception e) {
             log.error("락 상태 모니터링 중 오류 발생", e);
         }