Board Service 구현 및 단위 테스트

src/main/java/me/nettee/board/application/model/BoardReadDetailModel.java

@@ -0,0 +1,14 @@
+package me.nettee.board.application.model;
+
+import java.time.Instant;
+import me.nettee.board.application.domain.type.BoardStatus;
+
+public record BoardReadDetailModel(
+    Long id,
+    String title,
+    String content,
+    BoardStatus status,
+    Instant createdAt,
+    Instant updatedAt,
+    Instant deletedAt
+) {}

src/main/java/me/nettee/board/application/model/BoardReadSummaryModel.java

@@ -0,0 +1,11 @@
+package me.nettee.board.application.model;
+
+import java.time.Instant;
+
+public record BoardReadSummaryModel(
+    Long id,
+    String title,
+    String content,
+    Instant createdAt,
+    Instant updatedAt
+){}

src/main/java/me/nettee/board/application/port/BoardCommandPort.java

@@ -1,13 +1,15 @@
 package me.nettee.board.application.port;
 
+import java.util.Optional;
 import me.nettee.board.application.domain.Board;
 
 public interface BoardCommandPort {
 
+    Optional<Board> findById(Long id);
+
     Board create(Board board);
 
     Board update(Board board);
 
-    void delete(Long id);
-
+    void delete(Board id);
 }

src/main/java/me/nettee/board/application/port/BoardQueryPort.java

@@ -1,15 +1,17 @@
 package me.nettee.board.application.port;
 
-import me.nettee.board.application.domain.Board;
+import java.util.Optional;
+import java.util.Set;
+import me.nettee.board.application.domain.type.BoardStatus;
+import me.nettee.board.application.model.BoardReadDetailModel;
+import me.nettee.board.application.model.BoardReadSummaryModel;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 
-import java.util.Optional;
-
 public interface BoardQueryPort {
 
-    Page<Board> findAll(Pageable pageable);
+    Optional<BoardReadDetailModel> findById(Long id);
 
-    Optional<Board> findById(Long id);
+    Page<BoardReadSummaryModel> findByStatusesList(Pageable pageable, Set<BoardStatus> statuses);
 
 }

src/main/java/me/nettee/board/application/service/BoardCommandService.java

@@ -0,0 +1,35 @@
+package me.nettee.board.application.service;
+
+import lombok.RequiredArgsConstructor;
+import me.nettee.board.application.domain.Board;
+import me.nettee.board.application.model.BoardReadDetailModel;
+import me.nettee.board.application.port.BoardCommandPort;
+import me.nettee.board.application.port.BoardQueryPort;
+import me.nettee.board.application.usecase.BoardCreateUseCase;
+import me.nettee.board.application.usecase.BoardDeleteUseCase;
+import me.nettee.board.application.usecase.BoardUpdateUseCase;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class BoardCommandService implements BoardCreateUseCase, BoardUpdateUseCase, BoardDeleteUseCase {
+
+    private final BoardCommandPort boardCommandPort;
+
+    public Board createBoard(Board board) {
+        return boardCommandPort.create(board);
+    }
+
+    public Board updateBoard(Board board) {
+        return boardCommandPort.update(board);
+    }
+
+    public void deleteBoard(Long id) {
+        Board board = boardCommandPort.findById(id).orElseThrow(
+                () -> new IllegalArgumentException("게시글을 찾을 수 없습니다."));
+
+        board.softDelete();
+
+        boardCommandPort.delete(board);
+    }
+}

src/main/java/me/nettee/board/application/service/BoardQueryService.java

@@ -0,0 +1,31 @@
+package me.nettee.board.application.service;
+
+import java.util.Set;
+import lombok.RequiredArgsConstructor;
+import me.nettee.board.application.domain.type.BoardStatus;
+import me.nettee.board.application.model.BoardReadDetailModel;
+import me.nettee.board.application.model.BoardReadSummaryModel;
+import me.nettee.board.application.port.BoardQueryPort;
+import me.nettee.board.application.usecase.BoardReadByStatusesUseCase;
+import me.nettee.board.application.usecase.BoardReadUseCase;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class BoardQueryService implements BoardReadUseCase, BoardReadByStatusesUseCase {
+
+    private final BoardQueryPort boardQueryPort;
+
+    @Override
+    public BoardReadDetailModel getBoard(Long id) {
+        return boardQueryPort.findById(id).orElseThrow(
+                () -> new IllegalArgumentException("게시글을 찾을 수 없습니다."));
+    }
+
+    @Override
+    public Page<BoardReadSummaryModel> findByStatuses(Set<BoardStatus> statuses, Pageable pageable) {
+        return boardQueryPort.findByStatusesList(pageable, statuses);
+    }
+}

src/main/java/me/nettee/board/application/usecase/BoardCreateUseCase.java

@@ -5,4 +5,5 @@
 public interface BoardCreateUseCase {
 
     Board createBoard(Board board);
+
 }

src/main/java/me/nettee/board/application/usecase/BoardDeleteUseCase.java

@@ -3,4 +3,5 @@
 public interface BoardDeleteUseCase {
 
     void deleteBoard(Long id);
+
 }

src/main/java/me/nettee/board/application/usecase/BoardReadByStatusesUseCase.java

@@ -0,0 +1,14 @@
+package me.nettee.board.application.usecase;
+
+import java.util.Set;
+import me.nettee.board.application.domain.type.BoardStatus;
+import me.nettee.board.application.model.BoardReadSummaryModel;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+public interface BoardReadByStatusesUseCase {
+
+    Page<BoardReadSummaryModel> findByStatuses(Set<BoardStatus> statuses, Pageable pageable);
+
+}
+

src/main/java/me/nettee/board/application/usecase/BoardReadUseCase.java

@@ -1,12 +1,9 @@
 package me.nettee.board.application.usecase;
 
-import me.nettee.board.application.domain.Board;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.Pageable;
+import me.nettee.board.application.model.BoardReadDetailModel;
 
 public interface BoardReadUseCase {
 
-    Board getBoard(Long id);
+   BoardReadDetailModel getBoard(Long id);
 
-    Page<Board> findGeneralBy(Pageable pageable);
 }

src/main/java/me/nettee/board/application/usecase/BoardUpdateUseCase.java

@@ -4,4 +4,5 @@
 public interface BoardUpdateUseCase {
 
     Board updateBoard(Board board);
+
 }

src/test/kotlin/me/nettee/board/application/service/BoardCommandServiceTest.kt

@@ -0,0 +1,62 @@
+package me.nettee.board.application.service
+
+import io.kotest.core.spec.style.FreeSpec
+import io.kotest.matchers.should
+import io.kotest.matchers.shouldBe
+import io.mockk.every
+import io.mockk.mockk
+import io.mockk.verify
+import me.nettee.board.application.domain.Board
+import me.nettee.board.application.port.BoardCommandPort
+
+class BoardCommandServiceTest : FreeSpec({
+
+    val boardCommandPort = mockk<BoardCommandPort>()
+    val boardCommandService = BoardCommandService(boardCommandPort)
+
+    "BoardCommandService" - {
+        "create" {
+            // given
+            var board = Board()
+            every {
+                boardCommandPort.create(board)
+            } returns board
+
+            // when
+            val result = boardCommandService.createBoard(board)
+
+            // then
+            result shouldBe board
+            verify { boardCommandPort.create(board) }
+        }
+
+        "update" {
+            // given
+            val board = Board()
+            every {
+                boardCommandPort.update(board)
+            } returns board
+
+            // when
+            val result = boardCommandService.updateBoard(board)
+
+            // then
+            result shouldBe board
+            verify { boardCommandPort.update(board) }
+        }
+
+        "delete" {
+            // given
+            val boardId = 1L
+            every {
+                boardCommandPort.delete(boardId)
+            } returns Unit
+
+            // when
+            boardCommandService.deleteBoard(boardId)
+
+            // then
+            verify { boardCommandPort.delete(boardId) }
+        }
+    }
+})

src/test/kotlin/me/nettee/board/application/service/BoardQueryServiceTest.kt

@@ -0,0 +1,97 @@
+package me.nettee.board.application.service
+
+import io.kotest.core.spec.style.FreeSpec
+import io.kotest.matchers.shouldBe
+import io.mockk.every
+import io.mockk.mockk
+import io.mockk.verify
+import me.nettee.board.application.domain.Board
+import me.nettee.board.application.domain.type.BoardStatus
+import me.nettee.board.application.port.BoardQueryPort
+import org.springframework.data.domain.PageImpl
+import org.springframework.data.domain.PageRequest
+import java.util.*
+
+class BoardQueryServiceTest : FreeSpec({
+
+    val boardQueryPort = mockk<BoardQueryPort>() // mocking
+    val boardQueryService = BoardQueryService(boardQueryPort) // 주입
+
+    "BoardQueryService" - {
+        "findById" - {
+            "존재하는 ID로 조회한다." {
+                // given
+                val boardId = 1L
+                val expectedBoard = Board.builder().id(boardId).title("test title").build()
+                every {
+                    boardQueryPort.findById(boardId)
+                } returns Optional.of(expectedBoard)
+
+                // when
+                val result = boardQueryService.getBoard(boardId)
+
+                // then
+                result shouldBe expectedBoard
+                verify { boardQueryPort.findById(boardId) }
+            }
+
+            "존재하지 않는 ID로 예외를 발생시킨다." {
+                // given
+                val boardId = 1L
+                every {
+                    boardQueryPort.findById(boardId)
+                } returns Optional.empty()
+
+                // when
+                val result = runCatching {
+                    boardQueryService.getBoard(boardId) // Optional이 비어있을 때, orElseThrow()에서 예외가 발생한다.
+                }
+
+                // then
+                result.isFailure shouldBe true
+                verify { boardQueryPort.findById(boardId) }
+            }
+        }
+
+        "findByStatuses" - {
+            "상태 목록으로 조회 시, 페이징 조회한다." {
+                // given
+                val statuses = listOf(BoardStatus.ACTIVE, BoardStatus.SUSPENDED)
+                val pageable = PageRequest.of(0, 10)
+                val boards = listOf(
+                    Board.builder().id(1L).title("Active Board").status(BoardStatus.ACTIVE).build(),
+                    Board.builder().id(2L).title("Suspended Board").status(BoardStatus.SUSPENDED).build()
+                )
+                val expectedPage = PageImpl(boards, pageable, boards.size.toLong())
+                every {
+                    boardQueryPort.findByStatusesList(pageable, statuses)
+                } returns expectedPage
+
+                // when
+                val result = boardQueryService.findByStatuses(pageable, statuses)
+
+                // then
+                result shouldBe expectedPage
+                verify { boardQueryPort.findByStatusesList(pageable, statuses) }
+            }
+
+            "빈 상태 목록으로 조회 시, 빈 페이지를 조회한다." {
+                // given
+                val statuses = emptyList<BoardStatus>()
+                val pageable = PageRequest.of(0, 10)
+                val boards: List<Board> = emptyList()
+                val expectedPage = PageImpl(boards, pageable, 0)
+                every {
+                    boardQueryPort.findByStatusesList(pageable, statuses)
+                } returns expectedPage
+
+                // when
+                val result = boardQueryService.findByStatuses(pageable, statuses)
+
+                // then
+                result shouldBe expectedPage
+                verify { boardQueryPort.findByStatusesList(pageable, statuses) }
+            }
+        }
+    }
+})