Comment: comment 모듈 추가 및 application, api 작성

monolith/main-runner/build.gradle.kts

@@ -9,6 +9,7 @@ dependencies {
     implementation(project(":cors-webmvc"))
     // service
     implementation(project(":board"))
+    implementation(project(":comment"))
     // webmvc
     implementation("org.springframework.boot:spring-boot-starter-web")
     // db

monolith/main-runner/src/main/resources/application.yml

@@ -6,6 +6,7 @@ spring:
     import:
       - properties.web/main.cors.yml
       - board.yml
+      - comment.yml
 
 server:
   port: 5000

services/board/driven/rdb/src/main/resources/properties/db/board.database-local.yml

@@ -1,5 +1,11 @@
 spring:
   datasource:
+    driver-class-name: org.postgresql.Driver
     url: ${BOARD_POSTGRESQL_URL:jdbc:postgresql://localhost:5433/demo}
     username: ${BOARD_POSTGRESQL_USERNAME:root}
     password: ${BOARD_POSTGRESQL_PASSWORD:root}
+
+  flyway:
+    baseline-on-migrate: true
+    locations:
+      - db/postgresql/migration/v1_0

services/comment/api/build.gradle.kts

@@ -0,0 +1,5 @@
+dependencies {
+    api(project(":comment:api:domain"))
+    api(project(":comment:api:exception"))
+    api(project(":comment:api:readmodel"))
+}

services/comment/api/domain/src/main/java/nettee/comment/Comment.java

@@ -0,0 +1,43 @@
+package nettee.comment;
+
+import java.time.Instant;
+import java.util.Objects;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import nettee.comment.type.CommentStatus;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Comment {
+
+    private Long id;
+
+    private String content;
+
+    private CommentStatus status;
+
+    private Instant createdAt;
+
+    private Instant updatedAt;
+
+    @Builder(
+        builderClassName = "updateCommentBuilder",
+        builderMethodName = "prepareUpdate",
+        buildMethodName = "update"
+    )
+    public void update(String content) {
+        Objects.requireNonNull(content, "content cannot be null");
+
+        this.content = content;
+        this.updatedAt = Instant.now();
+    }
+
+    public void softDelete() {
+        this.status = CommentStatus.REMOVED;
+    }
+
+}

services/comment/api/domain/src/main/java/nettee/comment/type/CommentStatus.java

@@ -0,0 +1,18 @@
+package nettee.comment.type;
+
+import java.util.EnumSet;
+import java.util.Set;
+
+public enum CommentStatus {
+
+    PENDING,
+    ACTIVE,
+    REMOVED;
+
+    private static final Set<CommentStatus> GENERAL_QUERY_STATUS = EnumSet.of(ACTIVE);
+
+    public static Set<CommentStatus> getGeneralQueryStatus() {
+        return GENERAL_QUERY_STATUS;
+    }
+
+}

services/comment/api/domain/src/main/java/nettee/reply/Reply.java

@@ -0,0 +1,44 @@
+package nettee.reply;
+
+import java.time.Instant;
+import java.util.Objects;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import nettee.reply.type.ReplyStatus;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Reply {
+
+    private Long id;
+
+    private Long parentId;
+
+    private String content;
+
+    private ReplyStatus status;
+
+    private Instant createdAt;
+
+    private Instant updatedAt;
+
+    @Builder(
+        builderClassName = "updateReplyBuilder",
+        builderMethodName = "prepareUpdate",
+        buildMethodName = "update"
+    )
+    public void update(String content) {
+        Objects.requireNonNull(content, "content cannot be null");
+
+        this.content = content;
+        this.updatedAt = Instant.now();
+    }
+
+    public void softDelete() {
+        this.status = ReplyStatus.REMOVED;
+    }
+}

services/comment/api/domain/src/main/java/nettee/reply/type/ReplyStatus.java

@@ -0,0 +1,18 @@
+package nettee.reply.type;
+
+import java.util.EnumSet;
+import java.util.Set;
+
+public enum ReplyStatus {
+
+    PENDING,
+    ACTIVE,
+    REMOVED;
+
+    private static final Set<ReplyStatus> GENERAL_QUERY_STATUS = EnumSet.of(ACTIVE);
+
+    public static Set<ReplyStatus> getGeneralQueryStatus() {
+        return GENERAL_QUERY_STATUS;
+    }
+
+}

services/comment/api/exception/src/main/java/nettee/comment/CommentCommandErrorCode.java

@@ -0,0 +1,62 @@
+package nettee.comment;
+
+import java.util.Map;
+import java.util.function.Supplier;
+import nettee.common.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+public enum CommentCommandErrorCode implements ErrorCode {
+    COMMENT_NOT_FOUND("댓글을 찾을 수 없습니다.", HttpStatus.NOT_FOUND),
+    COMMENT_GONE("더 이상 존재하지 않는 댓글입니다.", HttpStatus.GONE),
+    COMMENT_FORBIDDEN("권한이 없습니다.", HttpStatus.FORBIDDEN),
+    DEFAULT("댓글 조작 오류", HttpStatus.INTERNAL_SERVER_ERROR),
+    COMMENT_ALREADY_EXIST("댓글이 이미 존재합니다.", HttpStatus.CONFLICT);
+
+    private final String message;
+    private final HttpStatus httpStatus;
+
+    CommentCommandErrorCode(String message, HttpStatus httpStatus) {
+        this.message = message;
+        this.httpStatus = httpStatus;
+    }
+
+    @Override
+    public String message() {
+        return message;
+    }
+
+    @Override
+    public HttpStatus httpStatus() {
+        return httpStatus;
+    }
+
+    @Override
+    public CommentCommandException exception() {
+        return new CommentCommandException(this);
+    }
+
+    @Override
+    public CommentCommandException exception(Throwable cause) {
+        return new CommentCommandException(this, cause);
+    }
+
+    @Override
+    public RuntimeException exception(Runnable runnable) {
+        return new CommentCommandException(this, runnable);
+    }
+
+    @Override
+    public RuntimeException exception(Runnable runnable, Throwable cause) {
+        return new CommentCommandException(this, runnable, cause);
+    }
+
+    @Override
+    public RuntimeException exception(Supplier<Map<String, Object>> payload) {
+        return new CommentCommandException(this, payload);
+    }
+
+    @Override
+    public RuntimeException exception(Supplier<Map<String, Object>> payload, Throwable cause) {
+        return new CommentCommandException(this, payload, cause);
+    }
+}

services/comment/api/exception/src/main/java/nettee/comment/CommentCommandException.java

@@ -0,0 +1,36 @@
+package nettee.comment;
+
+import java.util.Map;
+import java.util.function.Supplier;
+import nettee.common.CustomException;
+import nettee.common.ErrorCode;
+
+public class CommentCommandException extends CustomException {
+
+    /**
+     * CommentErrorCodeLazyHolder를 파라미터로 받기 위해, ErrorCode 타입으로 임시 설정함.
+     */
+    public CommentCommandException(ErrorCode errorCode) {
+        super(errorCode);
+    }
+
+    public CommentCommandException(ErrorCode errorCode, Throwable cause) {
+        super(errorCode, cause);
+    }
+
+    public CommentCommandException(ErrorCode errorCode, Runnable runnable) {
+        super(errorCode, runnable);
+    }
+
+    public CommentCommandException(ErrorCode errorCode, Runnable runnable, Throwable cause) {
+        super(errorCode, runnable, cause);
+    }
+
+    public CommentCommandException(ErrorCode errorCode, Supplier<Map<String, Object>> payload) {
+        super(errorCode, payload);
+    }
+
+    public CommentCommandException(ErrorCode errorCode, Supplier<Map<String, Object>> payload, Throwable cause) {
+        super(errorCode, payload, cause);
+    }
+}

services/comment/api/exception/src/main/java/nettee/comment/CommentQueryErrorCode.java

@@ -0,0 +1,61 @@
+package nettee.comment;
+
+import java.util.Map;
+import java.util.function.Supplier;
+import nettee.common.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+public enum CommentQueryErrorCode implements ErrorCode {
+    COMMENT_NOT_FOUND("댓글을 찾을 수 없습니다.", HttpStatus.NOT_FOUND),
+    COMMENT_GONE("더 이상 존재하지 않는 댓글입니다.", HttpStatus.GONE),
+    COMMENT_FORBIDDEN("권한이 없습니다.", HttpStatus.FORBIDDEN),
+    DEFAULT("댓글 조작 오류", HttpStatus.INTERNAL_SERVER_ERROR);
+
+    private final String message;
+    private final HttpStatus httpStatus;
+
+    CommentQueryErrorCode(String message, HttpStatus httpStatus) {
+        this.message = message;
+        this.httpStatus = httpStatus;
+    }
+
+    @Override
+    public String message() {
+        return message;
+    }
+
+    @Override
+    public HttpStatus httpStatus() {
+        return httpStatus;
+    }
+
+    @Override
+    public CommentQueryException exception() {
+        return new CommentQueryException(this);
+    }
+
+    @Override
+    public CommentQueryException exception(Throwable cause) {
+        return new CommentQueryException(this, cause);
+    }
+
+    @Override
+    public RuntimeException exception(Runnable runnable) {
+        return new CommentQueryException(this, runnable);
+    }
+
+    @Override
+    public RuntimeException exception(Runnable runnable, Throwable cause) {
+        return new CommentQueryException(this, runnable, cause);
+    }
+
+    @Override
+    public RuntimeException exception(Supplier<Map<String, Object>> payload) {
+        return new CommentQueryException(this, payload);
+    }
+
+    @Override
+    public RuntimeException exception(Supplier<Map<String, Object>> payload, Throwable cause) {
+        return new CommentQueryException(this, payload, cause);
+    }
+}

services/comment/api/exception/src/main/java/nettee/comment/CommentQueryException.java

@@ -0,0 +1,31 @@
+package nettee.comment;
+
+import java.util.Map;
+import java.util.function.Supplier;
+import nettee.common.CustomException;
+
+public class CommentQueryException extends CustomException {
+    public CommentQueryException(CommentQueryErrorCode errorCode) {
+        super(errorCode);
+    }
+
+    public CommentQueryException(CommentQueryErrorCode errorCode, Throwable cause) {
+        super(errorCode, cause);
+    }
+
+    public CommentQueryException(CommentQueryErrorCode errorCode, Runnable runnable) {
+        super(errorCode, runnable);
+    }
+
+    public CommentQueryException(CommentQueryErrorCode errorCode, Runnable runnable, Throwable cause) {
+        super(errorCode, runnable, cause);
+    }
+
+    public CommentQueryException(CommentQueryErrorCode errorCode, Supplier<Map<String, Object>> payload) {
+        super(errorCode, payload);
+    }
+
+    public CommentQueryException(CommentQueryErrorCode errorCode, Supplier<Map<String, Object>> payload, Throwable cause) {
+        super(errorCode, payload, cause);
+    }
+}