Skip to content

Commit c67f50a

Browse files
committed
refactor: Repository를 infrastructure 레이어로 이동
- domain 패키지의 JpaRepository를 infrastructure/persistence로 이동 - Clean Architecture 의존성 방향 준수 - JpaConfig에서 domain 패키지 스캔 제거
1 parent 5193457 commit c67f50a

7 files changed

Lines changed: 14 additions & 10 deletions

File tree

apps/commerce-streamer/src/main/java/com/loopers/application/metrics/MetricsAggregationService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
import com.loopers.application.event.order.OrderCompletedEvent;
66
import com.loopers.application.event.product.ProductViewedEvent;
77
import com.loopers.domain.event.EventHandled;
8-
import com.loopers.domain.event.EventHandledRepository;
98
import com.loopers.domain.metrics.ProductMetrics;
10-
import com.loopers.domain.metrics.ProductMetricsRepository;
9+
import com.loopers.infrastructure.persistence.EventHandledRepository;
10+
import com.loopers.infrastructure.persistence.ProductMetricsRepository;
1111
import lombok.RequiredArgsConstructor;
1212
import lombok.extern.slf4j.Slf4j;
1313
import org.springframework.stereotype.Service;

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/kafka/DlqPublisher.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.loopers.infrastructure.kafka;
22

33
import com.loopers.domain.dlq.DlqMessage;
4-
import com.loopers.domain.dlq.DlqMessageRepository;
4+
import com.loopers.infrastructure.persistence.DlqMessageRepository;
55
import lombok.RequiredArgsConstructor;
66
import lombok.extern.slf4j.Slf4j;
77
import org.apache.kafka.clients.consumer.ConsumerRecord;

apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DlqMessageRepository.java renamed to apps/commerce-streamer/src/main/java/com/loopers/infrastructure/persistence/DlqMessageRepository.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
package com.loopers.domain.dlq;
1+
package com.loopers.infrastructure.persistence;
22

3+
import com.loopers.domain.dlq.DlqMessage;
34
import org.springframework.data.jpa.repository.JpaRepository;
45
import org.springframework.data.jpa.repository.Query;
56

apps/commerce-streamer/src/main/java/com/loopers/domain/event/EventHandledRepository.java renamed to apps/commerce-streamer/src/main/java/com/loopers/infrastructure/persistence/EventHandledRepository.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,12 @@
1-
package com.loopers.domain.event;
1+
package com.loopers.infrastructure.persistence;
22

3+
import com.loopers.domain.event.EventHandled;
34
import org.springframework.data.jpa.repository.JpaRepository;
45
import org.springframework.data.jpa.repository.Query;
56
import org.springframework.data.repository.query.Param;
67

78
import java.time.ZonedDateTime;
9+
import java.util.List;
810

911
public interface EventHandledRepository extends JpaRepository<EventHandled, String> {
1012

@@ -24,5 +26,5 @@ public interface EventHandledRepository extends JpaRepository<EventHandled, Stri
2426
* 특정 파티션 키의 처리 이력 조회 (디버깅용)
2527
*/
2628
@Query("SELECT e FROM EventHandled e WHERE e.partitionKey = :partitionKey ORDER BY e.handledAt DESC")
27-
java.util.List<EventHandled> findByPartitionKey(@Param("partitionKey") String partitionKey);
29+
List<EventHandled> findByPartitionKey(@Param("partitionKey") String partitionKey);
2830
}

apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java renamed to apps/commerce-streamer/src/main/java/com/loopers/infrastructure/persistence/ProductMetricsRepository.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
package com.loopers.domain.metrics;
1+
package com.loopers.infrastructure.persistence;
22

3+
import com.loopers.domain.metrics.ProductMetrics;
34
import org.springframework.data.jpa.repository.JpaRepository;
45
import org.springframework.data.jpa.repository.Lock;
56
import org.springframework.data.jpa.repository.Query;

apps/commerce-streamer/src/test/java/com/loopers/application/metrics/MetricsAggregationServiceIdempotencyTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
import com.loopers.application.event.order.OrderCompletedEvent;
66
import com.loopers.application.event.product.ProductViewedEvent;
77
import com.loopers.config.TestConfig;
8-
import com.loopers.domain.event.EventHandledRepository;
98
import com.loopers.domain.metrics.ProductMetrics;
10-
import com.loopers.domain.metrics.ProductMetricsRepository;
9+
import com.loopers.infrastructure.persistence.EventHandledRepository;
10+
import com.loopers.infrastructure.persistence.ProductMetricsRepository;
1111
import org.junit.jupiter.api.BeforeEach;
1212
import org.junit.jupiter.api.DisplayName;
1313
import org.junit.jupiter.api.Test;

apps/commerce-streamer/src/test/java/com/loopers/infrastructure/kafka/DlqPublisherTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.fasterxml.jackson.core.JsonProcessingException;
44
import com.loopers.domain.dlq.DlqMessage;
5-
import com.loopers.domain.dlq.DlqMessageRepository;
5+
import com.loopers.infrastructure.persistence.DlqMessageRepository;
66
import org.apache.kafka.clients.consumer.ConsumerRecord;
77
import org.junit.jupiter.api.DisplayName;
88
import org.junit.jupiter.api.Test;

0 commit comments

Comments
 (0)