[🚀 사이클2 - 미션 (기물 확장 + DB 적용)] 스타크 미션 제출합니다.

.gitignore

@@ -1,6 +1,10 @@
 HELP.md
 .gradle
+.gradle-local/
 build/
+data/
+*.mv.db
+*.trace.db
 !gradle/wrapper/gradle-wrapper.jar
 !**/src/main/**
 !**/src/test/**

README.md

@@ -99,27 +99,53 @@
     - [x] 기물 규칙 및 제약에 맞게 이동한다.
         - [차(車)]
             - [x] 상하좌우로 장애물을 만날 때까지 칸 수 제한 없이 이동한다.
+            - [x] 궁성 내부(진영 상관 X)에서 궁성의 대각선을 이용해 이동할 수 있다.
             - [x] 이동하려는 경로 중간에 다른 기물이 **있**다면 `IllegalArgumentException`을 발생시킨다.
 
         - [포(包)]
             - [x] 상하좌우로 이동하되, 반드시 중간에 다른 기물을 하나 뛰어넘어야 합니다.
+            - [x] 궁성 내부(진영 상관 X)에서 궁성의 대각선을 이용해 이동할 수 있다.
+                - 이때에도 경로 상에 반드시 기물이 있어야 한다.
             - [x] 이동하려는 경로 중간에 다른 기물이 **없**다면 `IllegalArgumentException`을 발생시킨다.
             - [x] 넘으려는 기물이 포(包) 일 경우 `IllegalArgumentException`을 발생시킨다.
             - [x] 목적지 좌표의 기물이 포(包)일 경우 `IllegalArgumentException`을 발생시킨다.
 
         - [마(馬)]
             - [x] 직선 1칸 + 대각선 1칸(日) 이동한다.
+                - 궁성 내부 대각선 이용 불가
             - [x] 목적지 좌표(직선 1칸 또는 대각선 1칸)에 다른 기물이 있으면 `IllegalArgumentException`을 발생시킨다.
 
         - [상(象)]
             - [x] 직선 1칸 + 대각선 2칸(用) 이동한다.
+                - 궁성 내부 대각선 이용 불가
             - [x] 목적지 좌표(직선 1칸 또는 대각선 1칸)에 다른 기물이 있으면 `IllegalArgumentException`을 발생시킨다.
 
-        - [궁(楚/漢), 사(士)]
+        - [궁(楚/漢)]
             - [x] 상하좌우 직선 1칸 이동한다.
+            - [x] 아군 궁성 내부에서만 대각선으로 1칸 이동할 수 있다.
+            - [x] 상대 기물에게 잡힐 경우 게임이 종료되며 상대방이 게임을 승리한다.
+
+        - [사(士)]
+            - [x] 상하좌우 직선 1칸 이동한다.
+            - [x] 아군 궁성 내부에서만 대각선으로 1칸 이동할 수 있다.
 
         - [졸/병(卒/兵)]
             - [x] 상좌우 직선 1칸 이동한다. 후진은 불가 주의
+            - [x] 상대 궁성 내부에서만 대각선으로 1칸 이동할 수 있다.
+                - 졸/병은 규칙에 의해 애초에 아군 궁성으로 이동조차 불가능하다.
+
+### 기물 별 점수
+
+『초』 총점 : 72.0점  
+『한』 총점 : 73.5점 (후수이기 때문에 점수 + 1.5)
+
+- [차(車)] : 13점
+- [포(包)] : 7점
+- [마(馬)] : 5점
+- [상(象)] : 3점
+- [사(士)] : 3점
+- [졸/병(卒/兵)] : 2점
+- [궁(楚/漢)] : 점수 없음 -> 죽는 순간 상대방 🥇게임 승리🥇
 
 ---
 

build.gradle

@@ -9,6 +9,7 @@ repositories {
 }
 
 dependencies {
+    runtimeOnly('com.h2database:h2:2.4.240')
     testImplementation platform('org.junit:junit-bom:5.11.4')
     testImplementation platform('org.assertj:assertj-bom:3.27.3')
     testImplementation('org.junit.jupiter:junit-jupiter')

src/main/java/janggi/GameRunner.java

@@ -0,0 +1,110 @@
+package janggi;
+
+import janggi.domain.Game;
+import janggi.domain.board.Board;
+import janggi.domain.board.Position;
+import janggi.domain.board.initializer.BoardInitializer;
+import janggi.domain.board.initializer.ElephantSetUp;
+import janggi.domain.board.initializer.StandardBoardInitializer;
+import janggi.domain.piece.Camp;
+import janggi.service.GameService;
+import janggi.view.InputView;
+import janggi.view.OutputView;
+import janggi.view.dto.CampDto;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.Supplier;
+
+public class GameRunner {
+    private static final String INVALID_GAME_ROOM = "[ERROR] 존재하지 않는 게임방 번호입니다.";
+
+    private final InputView inputView;
+    private final OutputView outputView;
+    private final GameService gameService;
+
+    public GameRunner(InputView inputView, OutputView outputView, GameService gameService) {
+        this.inputView = inputView;
+        this.outputView = outputView;
+        this.gameService = gameService;
+    }
+
+    public void run() {
+        Game game = retryOnInvalidInput(this::loadOrCreateGame);
+        outputView.printBoard(game.boardSnapshot());
+        play(game);
+    }
+
+    private Game loadOrCreateGame() {
+        outputView.printExistGameRoom(gameService.findAllIds());
+        long gameId = inputView.readSelectedGameRoom();
+
+        if (gameId == 0L) {
+            return createNewGame();
+        }
+
+        return gameService.findById(gameId)
+                .orElseThrow(() -> new IllegalArgumentException(INVALID_GAME_ROOM));
+    }
+
+    private Game createNewGame() {
+        Board board = createBoard();
+        return gameService.create(board);
+    }
+
+    private Board createBoard() {
+        Map<Camp, ElephantSetUp> elephantSetUps = new HashMap<>();
+        readElephantSetUp(elephantSetUps, Camp.HAN);
+        readElephantSetUp(elephantSetUps, Camp.CHO);
+
+        BoardInitializer initializer = new StandardBoardInitializer(elephantSetUps);
+        return new Board(initializer);
+    }
+
+    private void readElephantSetUp(Map<Camp, ElephantSetUp> elephantSetUps, Camp camp) {
+        ElephantSetUp elephantSetUp = retryOnInvalidInput(
+                () -> inputView.readElephantSetting(CampDto.from(camp))
+        );
+        elephantSetUps.put(camp, elephantSetUp);
+    }
+
+    private void play(Game game) {
+        boolean continueGame = true;
+        while (continueGame) {
+            outputView.printScore(game.calculateScore());
+            continueGame = retryOnInvalidInput(() -> playTurn(game));
+            outputView.printBoard(game.boardSnapshot());
+        }
+        outputView.printWinner(game.currentTurn());
+    }
+
+    private boolean playTurn(Game game) {
+        Camp currentTurn = game.currentTurn();
+
+        Position source = retryOnInvalidInput(() -> readSource(game, currentTurn));
+        Position destination = retryOnInvalidInput(inputView::readDestination);
+
+        boolean gameEnded = game.play(source, destination);
+        if (gameEnded) {
+            gameService.deleteById(game.id());
+            return false;
+        }
+        gameService.save(game);
+        return true;
+    }
+
+    private Position readSource(Game game, Camp currentTurn) {
+        Position source = inputView.readSource(CampDto.from(currentTurn));
+        game.validateSourceForCurrentTurn(source);
+        return source;
+    }
+
+    private <T> T retryOnInvalidInput(Supplier<T> input) {
+        while (true) {
+            try {
+                return input.get();
+            } catch (IllegalArgumentException e) {
+                outputView.printError(e.getMessage());
+            }
+        }
+    }
+}

src/main/java/janggi/JanggiApplication.java

@@ -1,9 +1,26 @@
 package janggi;
 
+import janggi.db.DatabaseInitializer;
+import janggi.db.H2ConnectionManager;
+import janggi.db.TransactionManager;
+import janggi.repository.GamePieceRepository;
+import janggi.repository.GameStateRepository;
+import janggi.service.GameService;
+import janggi.view.InputView;
+import janggi.view.OutputView;
+import java.util.Scanner;
+
 public class JanggiApplication {
     public static void main(String[] args) {
-        AppConfig app = new AppConfig();
-        JanggiGame janggi = app.janggi();
+        H2ConnectionManager connectionManager = new H2ConnectionManager();
+        new DatabaseInitializer(connectionManager).initialize();
+        TransactionManager transactionManager = new TransactionManager(connectionManager);
+
+        GameRunner janggi = new GameRunner(
+                new InputView(new Scanner(System.in)),
+                new OutputView(),
+                new GameService(transactionManager, new GameStateRepository(), new GamePieceRepository())
+        );
         janggi.run();
     }
 }

src/main/java/janggi/db/ConnectionManager.java

@@ -0,0 +1,8 @@
+package janggi.db;
+
+import java.sql.Connection;
+
+public interface ConnectionManager {
+
+    Connection createConnection();
+}

src/main/java/janggi/db/DatabaseInitializer.java

@@ -0,0 +1,49 @@
+package janggi.db;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public final class DatabaseInitializer {
+
+    private static final String SCHEMA_PATH = "/schema.sql";
+    private static final String SCHEMA_LOAD_FAILED = "[ERROR] DB 스키마를 읽을 수 없습니다.";
+    private static final String SCHEMA_INIT_FAILED = "[ERROR] DB 스키마를 초기화할 수 없습니다.";
+
+    private final ConnectionManager connectionManager;
+
+    public DatabaseInitializer(ConnectionManager connectionManager) {
+        this.connectionManager = connectionManager;
+    }
+
+    public void initialize() {
+        try (Connection connection = connectionManager.createConnection()) {
+            String schema = loadSchema();
+            for (String statement : schema.split(";")) {
+                String sql = statement.trim();
+                if (sql.isEmpty()) {
+                    continue;
+                }
+                try (Statement jdbcStatement = connection.createStatement()) {
+                    jdbcStatement.execute(sql);
+                }
+            }
+        } catch (SQLException e) {
+            throw new IllegalStateException(SCHEMA_INIT_FAILED, e);
+        }
+    }
+
+    private String loadSchema() {
+        try (InputStream inputStream = DatabaseInitializer.class.getResourceAsStream(SCHEMA_PATH)) {
+            if (inputStream == null) {
+                throw new IllegalStateException(SCHEMA_LOAD_FAILED);
+            }
+            return new String(inputStream.readAllBytes(), StandardCharsets.UTF_8);
+        } catch (IOException e) {
+            throw new IllegalStateException(SCHEMA_LOAD_FAILED, e);
+        }
+    }
+}