Feat/#35 - Feed/FeedComment CQRS 적용

src/main/java/com/example/bak/community/infra/command/CommunityCommandAdaptor.java

@@ -8,8 +8,7 @@
 
 @Repository
 @RequiredArgsConstructor
-public class CommunityCommandAdaptor
-        implements CommunityCommandPort, com.example.bak.feed.application.port.CommunityCommandPort {
+public class CommunityCommandAdaptor implements CommunityCommandPort {
 
     private final CommunityJpaRepository communityJpaRepository;
 

src/main/java/com/example/bak/community/infra/command/CommunityValidationAdapter.java

@@ -0,0 +1,17 @@
+package com.example.bak.community.infra.command;
+
+import com.example.bak.feed.application.command.port.CommunityValidationPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class CommunityValidationAdapter implements CommunityValidationPort {
+
+    private final CommunityJpaRepository communityJpaRepository;
+
+    @Override
+    public boolean isCommunityExists(Long communityId) {
+        return communityJpaRepository.existsById(communityId);
+    }
+}

src/main/java/com/example/bak/feed/application/command/FeedCommandService.java

@@ -0,0 +1,32 @@
+package com.example.bak.feed.application.command;
+
+import com.example.bak.feed.application.command.port.CommunityValidationPort;
+import com.example.bak.feed.application.command.port.FeedCommandPort;
+import com.example.bak.feed.application.query.dto.FeedResult;
+import com.example.bak.feed.domain.Feed;
+import com.example.bak.global.exception.BusinessException;
+import com.example.bak.global.exception.ErrorCode;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional
+public class FeedCommandService {
+
+    private final FeedCommandPort feedCommandPort;
+    private final CommunityValidationPort communityValidationPort;
+
+    public FeedResult createFeed(String title, String content, Long communityId, Long userId) {
+
+        if (!communityValidationPort.isCommunityExists(communityId)) {
+            throw new BusinessException(ErrorCode.COMMUNITY_NOT_FOUND);
+        }
+
+        Feed newFeed = Feed.create(title, content, communityId, userId);
+        Feed savedFeed = feedCommandPort.save(newFeed);
+
+        return FeedResult.of(savedFeed.getId());
+    }
+}

src/main/java/com/example/bak/feed/application/command/port/CommunityValidationPort.java

@@ -0,0 +1,6 @@
+package com.example.bak.feed.application.command.port;
+
+public interface CommunityValidationPort {
+
+    boolean isCommunityExists(Long communityId);
+}

src/main/java/com/example/bak/feed/application/command/port/FeedCommandPort.java

@@ -0,0 +1,11 @@
+package com.example.bak.feed.application.command.port;
+
+import com.example.bak.feed.domain.Feed;
+import java.util.Optional;
+
+public interface FeedCommandPort {
+
+    Feed save(Feed feed);
+
+    Optional<Feed> findById(Long id);
+}

src/main/java/com/example/bak/feed/application/query/FeedQueryService.java

@@ -0,0 +1,40 @@
+package com.example.bak.feed.application.query;
+
+import com.example.bak.feed.application.query.dto.FeedDetail;
+import com.example.bak.feed.application.query.dto.FeedSummary;
+import com.example.bak.feed.application.query.port.FeedQueryPort;
+import com.example.bak.global.exception.BusinessException;
+import com.example.bak.global.exception.ErrorCode;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class FeedQueryService {
+
+    private final FeedQueryPort feedQueryPort;
+
+    @Transactional(readOnly = true)
+    public FeedDetail getFeedDetail(Long feedId) {
+        return feedQueryPort.findDetailById(feedId)
+                .orElseThrow(() -> new BusinessException(ErrorCode.FEED_NOT_FOUND));
+    }
+
+    @Transactional(readOnly = true)
+    public FeedSummary getFeedSummary(Long feedId) {
+        return feedQueryPort.findSummaryById(feedId)
+                .orElseThrow(() -> new BusinessException(ErrorCode.FEED_NOT_FOUND));
+    }
+
+    @Transactional(readOnly = true)
+    public List<FeedSummary> getFeeds(int page, int size) {
+        Pageable pageable = PageRequest.of(page, size);
+        Page<FeedSummary> feedPage = feedQueryPort.findAll(pageable);
+        return feedPage.getContent();
+    }
+}

src/main/java/com/example/bak/feed/application/query/dto/FeedDetail.java

@@ -0,0 +1,16 @@
+package com.example.bak.feed.application.query.dto;
+
+import com.example.bak.community.application.query.dto.CommunityResult;
+import com.example.bak.user.application.dto.UserInfo;
+
+/**
+ * Feed 도메인의 상세 정보를 담는 DTO 단건 조회 시 사용
+ */
+public record FeedDetail(
+        Long id,
+        String title,
+        String content,
+        UserInfo author,
+        CommunityResult.Detail community
+) {
+}

src/main/java/com/example/bak/feed/application/dto/FeedResult.java → src/main/java/com/example/bak/feed/application/query/dto/FeedResult.java

@@ -1,4 +1,4 @@
-package com.example.bak.feed.application.dto;
+package com.example.bak.feed.application.query.dto;
 
 public record FeedResult(
         Long id

src/main/java/com/example/bak/feed/application/query/dto/FeedSummary.java

@@ -0,0 +1,16 @@
+package com.example.bak.feed.application.query.dto;
+
+import com.example.bak.community.application.query.dto.CommunityResult;
+import com.example.bak.user.application.dto.UserInfo;
+
+/**
+ * Feed 도메인의 간단한 정보를 담는 DTO 목록 조회 시 사용
+ */
+public record FeedSummary(
+        Long id,
+        String title,
+        UserInfo author,
+        CommunityResult.Detail community,
+        int commentCount
+) {
+}

src/main/java/com/example/bak/feed/application/query/port/FeedQueryPort.java

@@ -0,0 +1,16 @@
+package com.example.bak.feed.application.query.port;
+
+import com.example.bak.feed.application.query.dto.FeedDetail;
+import com.example.bak.feed.application.query.dto.FeedSummary;
+import java.util.Optional;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+public interface FeedQueryPort {
+
+    Page<FeedSummary> findAll(Pageable pageable);
+
+    Optional<FeedSummary> findSummaryById(Long feedId);
+
+    Optional<FeedDetail> findDetailById(Long feedId);
+}