feat: 도메인 타입으로 검증할 수 있도록 수정

Author: rnqhstmd

apps/commerce-streamer/src/main/java/com/loopers/application/auditlog/AuditLogFacade.java

@@ -18,7 +18,7 @@ public class AuditLogFacade {
 
     @Transactional
     public void processAuditLog(AuditLogCommand command) {
-        if (eventHandledService.isEventHandled(command.eventId())) {
+        if (eventHandledService.isEventHandled(command.eventId(), DOMAIN_TYPE)) {
             return;
         }
 

apps/commerce-streamer/src/main/java/com/loopers/domain/eventhandled/EventHandled.java

@@ -9,7 +9,12 @@
 
 @Entity
 @Getter
-@Table(name = "event_handled")
+@Table(
+        name = "event_handled",
+        uniqueConstraints = {
+                @UniqueConstraint(columnNames = {"event_id", "domain_type"})
+        }
+)
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class EventHandled {
 

apps/commerce-streamer/src/main/java/com/loopers/domain/eventhandled/EventHandledRepository.java

@@ -4,5 +4,7 @@ public interface EventHandledRepository {
 
     boolean existsByEventId(String eventId);
 
+    boolean existsByEventIdAndDomainType(String eventId, EventHandledDomainType domainType);
+
     EventHandled save(EventHandled eventHandled);
 }

apps/commerce-streamer/src/main/java/com/loopers/domain/eventhandled/EventHandledService.java

@@ -15,6 +15,11 @@ public boolean isEventHandled(String eventId) {
         return eventHandledRepository.existsByEventId(eventId);
     }
 
+    @Transactional(readOnly = true)
+    public boolean isEventHandled(String eventId, EventHandledDomainType domainType) {
+        return eventHandledRepository.existsByEventIdAndDomainType(eventId, domainType);
+    }
+
     @Transactional
     public void saveEventHandled(String eventId, EventHandledDomainType domainType, String eventType) {
         EventHandled eventHandled = EventHandled.create(eventId, domainType, eventType);

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/eventhandled/EventHandledJpaRepository.java

@@ -1,9 +1,12 @@
 package com.loopers.infrastructure.eventhandled;
 
 import com.loopers.domain.eventhandled.EventHandled;
+import com.loopers.domain.eventhandled.EventHandledDomainType;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface EventHandledJpaRepository extends JpaRepository<EventHandled, String> {
 
     boolean existsByEventId(String eventId);
+
+    boolean existsByEventIdAndDomainType(String eventId, EventHandledDomainType domainType);
 }

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/eventhandled/EventHandledRepositoryImpl.java

@@ -1,6 +1,7 @@
 package com.loopers.infrastructure.eventhandled;
 
 import com.loopers.domain.eventhandled.EventHandled;
+import com.loopers.domain.eventhandled.EventHandledDomainType;
 import com.loopers.domain.eventhandled.EventHandledRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
@@ -16,6 +17,11 @@ public boolean existsByEventId(String eventId) {
         return eventHandledJpaRepository.existsByEventId(eventId);
     }
 
+    @Override
+    public boolean existsByEventIdAndDomainType(String eventId, EventHandledDomainType domainType) {
+        return eventHandledJpaRepository.existsByEventIdAndDomainType(eventId, domainType);
+    }
+
     @Override
     public EventHandled save(EventHandled eventHandled) {
         return eventHandledJpaRepository.save(eventHandled);