Feat/#35 - Feed/FeedComment CQRS 적용

src/main/java/com/example/bak/comment/application/command/CommentCommandService.java

@@ -0,0 +1,52 @@
+package com.example.bak.comment.application.command;
+
+import com.example.bak.comment.application.command.port.CommentCommandPort;
+import com.example.bak.comment.application.command.port.ProfileDataPort;
+import com.example.bak.comment.domain.Comment;
+import com.example.bak.comment.domain.ProfileSnapShot;
+import com.example.bak.feed.application.command.port.FeedValidationPort;
+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 CommentCommandService {
+
+    private final CommentCommandPort commentCommandPort;
+    private final FeedValidationPort feedValidationPort;
+    private final ProfileDataPort profileDataPort;
+
+    public void createComment(Long feedId, String content, Long userId) {
+        if (!feedValidationPort.existsById(feedId)) {
+            throw new BusinessException(ErrorCode.FEED_NOT_FOUND);
+        }
+
+        ProfileSnapShot userProfile = profileDataPort.findSnapshotByUserId(userId)
+                .orElseThrow(() -> new BusinessException(ErrorCode.USER_NOT_FOUND));
+
+        Comment newComment = Comment.create(
+                feedId,
+                content,
+                userProfile.userId(),
+                userProfile.nickname()
+        );
+
+        commentCommandPort.save(newComment);
+    }
+
+    public void updateComment(Long commentId, String content, Long userId) {
+        Comment comment = commentCommandPort.findById(commentId)
+                .orElseThrow(() -> new BusinessException(ErrorCode.COMMENT_NOT_FOUND));
+
+        if (!comment.isWrittenBy(userId)) {
+            throw new BusinessException(ErrorCode.UNAUTHORIZED_ACTION);
+        }
+
+        comment.updateComment(content);
+        commentCommandPort.save(comment);
+    }
+}

src/main/java/com/example/bak/comment/application/command/port/CommentCommandPort.java

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

src/main/java/com/example/bak/comment/application/command/port/ProfileDataPort.java

@@ -0,0 +1,9 @@
+package com.example.bak.comment.application.command.port;
+
+import com.example.bak.comment.domain.ProfileSnapShot;
+import java.util.Optional;
+
+public interface ProfileDataPort {
+
+    Optional<ProfileSnapShot> findSnapshotByUserId(Long userId);
+}

src/main/java/com/example/bak/comment/application/query/CommentQueryService.java

@@ -0,0 +1,20 @@
+package com.example.bak.comment.application.query;
+
+import com.example.bak.comment.application.query.dto.CommentInfo;
+import com.example.bak.comment.application.query.port.CommentQueryPort;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class CommentQueryService {
+
+    private final CommentQueryPort commentQueryPort;
+
+    public List<CommentInfo> getComments(Long feedId) {
+        return commentQueryPort.findByFeedId(feedId);
+    }
+}

src/main/java/com/example/bak/comment/application/query/dto/CommentInfo.java

@@ -0,0 +1,23 @@
+package com.example.bak.comment.application.query.dto;
+
+import com.example.bak.comment.domain.Comment;
+
+/**
+ * Comment의 기본 정보를 담는 DTO Feed 상세 조회 시 포함됨
+ */
+public record CommentInfo(
+        Long id,
+        Long authorId,
+        String authorName,
+        String content
+) {
+
+    public static CommentInfo from(Comment comment) {
+        return new CommentInfo(
+                comment.getId(),
+                comment.getAuthorId(),
+                comment.getAuthorNickname(),
+                comment.getContent()
+        );
+    }
+}

src/main/java/com/example/bak/comment/application/query/port/CommentQueryPort.java

@@ -0,0 +1,9 @@
+package com.example.bak.comment.application.query.port;
+
+import com.example.bak.comment.application.query.dto.CommentInfo;
+import java.util.List;
+
+public interface CommentQueryPort {
+
+    List<CommentInfo> findByFeedId(Long feedId);
+}

src/main/java/com/example/bak/comment/domain/Comment.java

@@ -0,0 +1,69 @@
+package com.example.bak.comment.domain;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import java.util.Objects;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity(name = "comments")
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+public class Comment {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "feed_id", nullable = false)
+    private Long feedId;
+
+    @Column(nullable = false)
+    private Long authorId;
+
+    @Column(nullable = false)
+    private String authorNickname;
+
+    @Column(nullable = false)
+    private String content;
+
+    private Comment(Long id, Long feedId, String content, Long authorId,
+            String authorNickname) {
+        this.id = id;
+        this.feedId = feedId;
+        this.content = content;
+        this.authorId = authorId;
+        this.authorNickname = authorNickname;
+    }
+
+    private Comment(Long feedId, String content, Long authorId, String authorNickname) {
+        this.feedId = feedId;
+        this.content = content;
+        this.authorId = authorId;
+        this.authorNickname = authorNickname;
+    }
+
+    public static Comment create(Long feedId, String comment, Long authorId,
+            String authorNickname) {
+        return new Comment(feedId, comment, authorId, authorNickname);
+    }
+
+    public static Comment testInstance(Long id, Long feedId, String comment, Long authorId,
+            String authorNickname) {
+        return new Comment(id, feedId, comment, authorId, authorNickname);
+    }
+
+    public void updateComment(String comment) {
+        this.content = comment;
+    }
+
+    public boolean isWrittenBy(Long authorId) {
+        return Objects.equals(this.authorId, authorId);
+    }
+}

src/main/java/com/example/bak/comment/domain/ProfileSnapShot.java

@@ -0,0 +1,5 @@
+package com.example.bak.comment.domain;
+
+public record ProfileSnapShot(Long userId, String nickname) {
+
+}

src/main/java/com/example/bak/comment/infra/persistence/CommentCommandAdapter.java

@@ -0,0 +1,24 @@
+package com.example.bak.comment.infra.persistence;
+
+import com.example.bak.comment.application.command.port.CommentCommandPort;
+import com.example.bak.comment.domain.Comment;
+import java.util.Optional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class CommentCommandAdapter implements CommentCommandPort {
+
+    private final CommentJpaRepository commentJpaRepository;
+
+    @Override
+    public Comment save(Comment comment) {
+        return commentJpaRepository.save(comment);
+    }
+
+    @Override
+    public Optional<Comment> findById(Long commentId) {
+        return commentJpaRepository.findById(commentId);
+    }
+}

src/main/java/com/example/bak/comment/infra/persistence/CommentJpaRepository.java

@@ -0,0 +1,10 @@
+package com.example.bak.comment.infra.persistence;
+
+import com.example.bak.comment.domain.Comment;
+import java.util.List;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface CommentJpaRepository extends JpaRepository<Comment, Long> {
+
+    List<Comment> findByFeedId(Long feedId);
+}

src/main/java/com/example/bak/comment/infra/persistence/CommentQueryAdapter.java

@@ -0,0 +1,21 @@
+package com.example.bak.comment.infra.persistence;
+
+import com.example.bak.comment.application.query.dto.CommentInfo;
+import com.example.bak.comment.application.query.port.CommentQueryPort;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class CommentQueryAdapter implements CommentQueryPort {
+
+    private final CommentJpaRepository commentJpaRepository;
+
+    @Override
+    public List<CommentInfo> findByFeedId(Long feedId) {
+        return commentJpaRepository.findByFeedId(feedId).stream()
+                .map(CommentInfo::from)
+                .toList();
+    }
+}

src/main/java/com/example/bak/feedcomment/presentation/FeedCommentController.java → src/main/java/com/example/bak/comment/presentation/CommentController.java

@@ -1,12 +1,14 @@
-package com.example.bak.feedcomment.presentation;
+package com.example.bak.comment.presentation;
 
-import com.example.bak.feedcomment.application.FeedCommentService;
-import com.example.bak.feedcomment.application.dto.CommentInfo;
-import com.example.bak.feedcomment.presentation.dto.CommentRequest;
-import com.example.bak.feedcomment.presentation.swagger.FeedCommentSwagger;
+import com.example.bak.comment.application.command.CommentCommandService;
+import com.example.bak.comment.application.query.CommentQueryService;
+import com.example.bak.comment.application.query.dto.CommentInfo;
+import com.example.bak.comment.presentation.dto.CommentRequest;
+import com.example.bak.comment.presentation.swagger.FeedCommentSwagger;
 import com.example.bak.global.common.response.ApiResponse;
 import com.example.bak.global.common.response.ApiResponseFactory;
 import com.example.bak.global.common.utils.UriUtils;
+import com.example.bak.global.security.annotation.AuthUser;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
@@ -21,38 +23,44 @@
 @RestController
 @RequestMapping("/api/v1")
 @RequiredArgsConstructor
-public class FeedCommentController implements FeedCommentSwagger {
+public class CommentController implements FeedCommentSwagger {
 
-    private final FeedCommentService feedCommentService;
+    private final CommentCommandService commentCommandService;
+    private final CommentQueryService commentQueryService;
 
+    @Override
     @PostMapping("/feeds/{feedId}/comments")
     public ResponseEntity<ApiResponse> createComment(
             @PathVariable Long feedId,
-            @RequestBody CommentRequest request
+            @RequestBody CommentRequest request,
+            @AuthUser Long userId
     ) {
-        feedCommentService.createComment(
+        commentCommandService.createComment(
                 feedId,
                 request.content(),
-                request.userId()
+                userId
         );
         ApiResponse response = ApiResponseFactory.successVoid("댓글을 성공적으로 생성하였습니다.");
         return ResponseEntity.created(UriUtils.current())
                 .body(response);
     }
 
+    @Override
     @GetMapping("/feeds/{feedId}/comments")
-    public ResponseEntity<ApiResponse> getComment(@PathVariable Long feedId) {
-        List<CommentInfo> comments = feedCommentService.getComments(feedId);
+    public ResponseEntity<ApiResponse> getComments(@PathVariable Long feedId) {
+        List<CommentInfo> comments = commentQueryService.getComments(feedId);
         ApiResponse response = ApiResponseFactory.success("댓글을 성공적으로 조회하였습니다.", comments);
         return ResponseEntity.ok(response);
     }
 
+    @Override
     @PutMapping("/comments/{commentId}")
     public ResponseEntity<ApiResponse> updateComment(
             @PathVariable Long commentId,
-            @RequestBody CommentRequest request
+            @RequestBody CommentRequest request,
+            @AuthUser Long userId
     ) {
-        feedCommentService.updateComment(commentId, request.content(), request.userId());
+        commentCommandService.updateComment(commentId, request.content(), userId);
         ApiResponse response = ApiResponseFactory.successVoid("댓글을 성공적으로 수정하였습니다.");
         return ResponseEntity.ok(response);
     }

src/main/java/com/example/bak/comment/presentation/dto/CommentRequest.java

@@ -0,0 +1,5 @@
+package com.example.bak.comment.presentation.dto;
+
+public record CommentRequest(String content) {
+
+}