Merge pull request #197 from yeonjiyeon/feature/week8

Feature/week8

Author: yeonjiyeon

apps/commerce-api/build.gradle.kts

@@ -2,10 +2,12 @@ dependencies {
     // add-ons
     implementation(project(":modules:jpa"))
     implementation(project(":modules:redis"))
+    implementation(project(":modules:kafka"))
     implementation(project(":supports:jackson"))
     implementation(project(":supports:logging"))
     implementation(project(":supports:monitoring"))
 
+
     // web
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework.boot:spring-boot-starter-actuator")

apps/commerce-api/src/main/java/com/loopers/application/coupon/CouponUsageEventListener.java

@@ -6,6 +6,7 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.orm.ObjectOptimisticLockingFailureException;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
@@ -17,7 +18,7 @@ public class CouponUsageEventListener {
   private final FailedEventStore failedEventStore;
 
   @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-  @Transactional
+  @Transactional(propagation = Propagation.REQUIRES_NEW)
   public void handlePaymentCompletedEvent(PaymentCompletedEvent event) {
 
     if (event.couponId() == null) return;

apps/commerce-api/src/main/java/com/loopers/application/event/DeadLetterQueueProcessor.java

@@ -4,15 +4,13 @@
 import com.loopers.domain.event.DomainEvent;
 import com.loopers.domain.event.FailedEvent;
 import com.loopers.infrastructure.event.FailedEventRepository;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.List;
-
 @Component
 @RequiredArgsConstructor
 public class DeadLetterQueueProcessor {

apps/commerce-api/src/main/java/com/loopers/application/event/OutboxRelay.java

@@ -0,0 +1,49 @@
+package com.loopers.application.event;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.loopers.domain.event.OutboxEvent;
+import com.loopers.domain.event.OutboxStatus;
+import com.loopers.infrastructure.event.OutboxRepository;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class OutboxRelay {
+
+  private final OutboxRepository outboxRepository;
+  private final ApplicationEventPublisher eventPublisher;
+  private final ObjectMapper objectMapper;
+
+  @Scheduled(fixedDelay = 60000)
+  @Transactional
+  public void resendPendingEvents() {
+    List<OutboxEvent> pendingEvents = outboxRepository.findTop10ByStatusInAndRetryCountLessThanOrderByCreatedAtAsc(
+        List.of(OutboxStatus.INIT, OutboxStatus.FAILED), 5
+    );
+
+    if (pendingEvents.isEmpty()) return;
+
+    for (OutboxEvent outbox : pendingEvents) {
+      try {
+        Class<?> eventClass = Class.forName(outbox.getEventType());
+        Object originalEvent = objectMapper.readValue(outbox.getPayload(), eventClass);
+
+        eventPublisher.publishEvent(originalEvent);
+
+        log.info("[Outbox Relay] 이벤트 재발행 성공: {}", outbox.getEventId());
+        outbox.markPublished();
+
+      } catch (Exception e) {
+        log.error("[Outbox Relay] 재발행 실패: {}", outbox.getEventId());
+        outbox.markFailed();
+      }
+    }
+  }
+}

apps/commerce-api/src/main/java/com/loopers/application/like/LikeCreatedEvent.java

@@ -1,5 +1,7 @@
 package com.loopers.application.like;
 
+import com.loopers.application.like.event.LikeActionTrackEvent;
+import com.loopers.application.like.event.LikeCreatedEvent;
 import com.loopers.domain.like.Like;
 import com.loopers.domain.like.LikeService;
 import com.loopers.domain.product.Product;
@@ -29,7 +31,7 @@ public LikeInfo like(long userId, long productId) {
 
     Like newLike = likeService.save(userId, productId);
 
-    eventPublisher.publishEvent(new LikeCreatedEvent(productId, 1));
+    eventPublisher.publishEvent(LikeCreatedEvent.of(productId, 1));
 
     eventPublisher.publishEvent(new LikeActionTrackEvent(
         userId,
@@ -45,7 +47,7 @@ public int unLike(long userId, long productId) {
 
     likeService.unLike(userId, productId);
 
-    eventPublisher.publishEvent(new LikeCreatedEvent(productId, -1));
+    eventPublisher.publishEvent(LikeCreatedEvent.of(productId, -1));
 
     eventPublisher.publishEvent(new LikeActionTrackEvent(
         userId,

apps/commerce-api/src/main/java/com/loopers/application/like/LikeFacade.java

@@ -1,4 +1,4 @@
-package com.loopers.application.like;
+package com.loopers.application.like.event;
 
 import com.loopers.domain.event.UserActionTrackEvent;
 import java.time.ZonedDateTime;

…plication/like/LikeActionTrackEvent.java …ion/like/event/LikeActionTrackEvent.javaapps/commerce-api/src/main/java/com/loopers/application/like/LikeActionTrackEvent.java renamed to apps/commerce-api/src/main/java/com/loopers/application/like/event/LikeActionTrackEvent.java apps/commerce-api/src/main/java/com/loopers/application/like/LikeActionTrackEvent.java renamed to apps/commerce-api/src/main/java/com/loopers/application/like/event/LikeActionTrackEvent.java

@@ -0,0 +1,21 @@
+package com.loopers.application.like.event;
+
+import com.loopers.domain.event.DomainEvent;
+import java.util.UUID;
+
+public record LikeCreatedEvent(
+    String eventId,
+    long productId,
+    int increment,
+    long timestamp
+) implements DomainEvent {
+
+  public static LikeCreatedEvent of(Long productId, int increment) {
+    return new LikeCreatedEvent(
+        UUID.randomUUID().toString(),
+        productId,
+        increment,
+        System.currentTimeMillis()
+    );
+  }
+}

apps/commerce-api/src/main/java/com/loopers/application/like/event/LikeCreatedEvent.java

@@ -0,0 +1,30 @@
+package com.loopers.application.like.event;
+
+import com.loopers.domain.event.OutboxService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+@RequiredArgsConstructor
+public class LikeEventOutboxHandler {
+
+  private final KafkaTemplate<Object, Object> kafkaTemplate;
+  private final OutboxService outboxService;
+
+  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+  public void handle(LikeCreatedEvent event) {
+    outboxService.saveEvent("PRODUCT_METRICS", String.valueOf(event.productId()), event);
+
+    kafkaTemplate.send("catalog-events", String.valueOf(event.productId()), event)
+        .whenComplete((result, ex) -> {
+          if (ex == null) {
+            outboxService.markPublished(event.eventId());
+          } else {
+            outboxService.markFailed(event.eventId());
+          }
+        });
+  }
+}