[신민경] 웹 서버 step 7 구현 (2)

.github/workflows/llm-code-review.yml

@@ -0,0 +1,24 @@
+name: Claude Auto PR Review
+on:
+  pull_request:
+    types: [opened, edited, synchronize]
+
+permissions:
+  contents: read
+  pull-requests: write
+  checks: write
+  id-token: write
+
+jobs:
+  review:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Simple LLM Code Review
+        uses: codingbaraGo/simple-llm-code-review@latest
+        with:
+          anthropic-api-key: ${{ secrets.ANTHROPIC_API_KEY }}
+          language: korean

build.gradle

@@ -16,7 +16,8 @@ dependencies {
     implementation 'ch.qos.logback:logback-classic:1.2.3'
     testImplementation 'org.assertj:assertj-core:3.16.1'
 
-
+    // h2 database
+    implementation 'com.h2database:h2:2.2.224'
 }
 
 test {

src/main/java/db/ArticleDao.java

@@ -0,0 +1,54 @@
+package db;
+
+import model.Article;
+
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.List;
+
+public class ArticleDao {
+
+    // 게시글 저장
+    public void insert(Article article) {
+        String sql = "INSERT INTO ARTICLE (writer, title, contents, imagePath) VALUES (?, ?, ?, ?)";
+
+        try (Connection connection = ConnectionManager.getConnection();
+        PreparedStatement pstmt = connection.prepareStatement(sql)) {
+
+            pstmt.setString(1, article.writer());
+            pstmt.setString(2, article.title());
+            pstmt.setString(3, article.contents());
+            pstmt.setString(4, article.imagePath());
+
+            pstmt.executeUpdate();
+        } catch (SQLException e) {
+            throw new RuntimeException("Failed to save article: " + e.getMessage());
+        }
+    }
+
+    // 게시글 조회
+    public List<Article> selectAll() {
+        String sql = "SELECT * FROM ARTICLE ORDER BY createdAt DESC";
+        List<Article> articles = new ArrayList<>();
+
+        try (Connection connection = ConnectionManager.getConnection();
+             Statement stmt = connection.createStatement();
+             ResultSet rs = stmt.executeQuery(sql)) {
+
+            while (rs.next()) {
+                Article article = new Article(
+                        rs.getLong("id"),
+                        rs.getString("writer"),
+                        rs.getString("title"),
+                        rs.getString("contents"),
+                        rs.getTimestamp("createdAt").toLocalDateTime(),
+                        rs.getString("imagePath")
+                );
+                articles.add(article);
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException("Failed to retrieve article list: {}", e);
+        }
+        return articles;
+    }
+}

src/main/java/db/ConnectionManager.java

@@ -0,0 +1,18 @@
+package db;
+
+import webserver.config.Config;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+
+public class ConnectionManager {
+    public static Connection getConnection() {
+        try {
+            Class.forName("org.h2.Driver");
+            return DriverManager.getConnection(Config.DB_URL, Config.DB_USER, Config.DB_PW);
+        } catch (ClassNotFoundException | SQLException e) {
+            throw new RuntimeException("Failed to Connect SQL: " + e.getMessage());
+        }
+    }
+}

src/main/java/db/UserDao.java

@@ -0,0 +1,77 @@
+package db;
+
+import model.User;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class UserDao {
+    private static final Logger logger = LoggerFactory.getLogger(UserDao.class);
+
+    // 회원가입
+    public void insert(User user) {
+        String sql = "INSERT INTO USERS (userId, name, password, email) VALUES (?, ?, ?, ?)";
+
+        try (Connection connection = ConnectionManager.getConnection();
+             PreparedStatement pstmt = connection.prepareStatement(sql)) {
+
+            pstmt.setString(1, user.userId());
+            pstmt.setString(2, user.name());
+            pstmt.setString(3, user.password());
+            pstmt.setString(4, user.email());
+
+            pstmt.executeUpdate();
+        } catch (SQLException e) {
+            throw new RuntimeException("Failed to save user", e);
+        }
+    }
+
+    // ID로 유저 정보 찾기
+    public User findUserById(String userId) {
+        String sql = "SELECT * FROM USERS WHERE userId = ?";
+
+        try (Connection connection = ConnectionManager.getConnection();
+        PreparedStatement pstmt = connection.prepareStatement(sql)) {
+
+            pstmt.setString(1, userId);
+            try (ResultSet rs = pstmt.executeQuery()) {
+                if (rs.next()) {
+                    return new User(
+                            rs.getString("userId"),
+                            rs.getString("password"),
+                            rs.getString("name"),
+                            rs.getString("email"),
+                            rs.getString("profileImage")
+                    );
+                }
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException("Failed to find user", e);
+        }
+        return null;
+    }
+
+    // 정보 갱신
+    public void update(User user) {
+        String sql = "UPDATE USERS SET name = ?, email = ?, profileImage = ? WHERE userId = ?";
+
+        try (Connection connection = ConnectionManager.getConnection();
+             PreparedStatement pstmt = connection.prepareStatement(sql)) {
+
+            pstmt.setString(1, user.name());
+            pstmt.setString(2, user.email());
+            pstmt.setString(3, user.profileImage());
+            pstmt.setString(4, user.userId());
+
+            pstmt.executeUpdate();
+            logger.debug("User updated in DB: {}", user.userId());
+
+        } catch (SQLException e) {
+            logger.error("DB Update Error (User): {}", e.getMessage());
+        }
+    }
+}

src/main/java/model/Article.java

@@ -0,0 +1,9 @@
+package model;
+
+import java.time.LocalDateTime;
+
+public record Article(Long id, String writer, String title, String contents, LocalDateTime createdAt, String imagePath) {
+    public Article(String writer, String title, String contents, String imagePath) {
+        this(null, writer, title, contents, null, imagePath);
+    }
+}

src/main/java/model/MultipartPart.java

@@ -0,0 +1,7 @@
+package model;
+
+public record MultipartPart (String name, String fileName, String contentType, byte[] data) {
+    public boolean isFile() {
+        return fileName != null;
+    }
+}

src/main/java/model/User.java

@@ -1,4 +1,4 @@
 package model;
 
-public record User(String userId, String password, String name, String email) {
+public record User(String userId, String password, String name, String email, String profileImage) {
 }

src/main/java/utils/HttpRequestUtils.java

@@ -1,11 +1,11 @@
 package utils;
 
+import model.MultipartPart;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import webserver.config.Pair;
 
-import java.util.HashMap;
-import java.util.Map;
+import java.util.*;
 
 public class HttpRequestUtils {
     private static final Logger logger = LoggerFactory.getLogger(HttpRequestUtils.class);
@@ -111,4 +111,57 @@ public static Pair parseHeader(String headerLine) {
         String value = headerLine.substring(index + 1).trim();
         return new Pair(key, value);
     }
+
+    // 멀티파트 파싱
+    public static List<MultipartPart> parseMultipartBody(byte[] body, String boundary) {
+        List<MultipartPart> parts = new ArrayList<>();
+        String delimiter = "--" + boundary;
+        byte[] delimiterBytes = delimiter.getBytes();
+
+        int start = 0;
+        while ((start = findIndex(body, delimiterBytes, start)) != -1) {
+            start += delimiterBytes.length;
+
+            if (start + 1 < body.length && body[start] == '-' && body[start + 1] == '-') break;
+
+            int headerEnd = findIndex(body, new byte[]{13, 10, 13, 10}, start);
+            if (headerEnd == -1) break;
+
+            String headerSection = new String(body, start + 2, headerEnd - start - 2);
+
+            String name = extractAttribute(headerSection, "name");
+            String fileName = extractAttribute(headerSection, "filename");
+            String contentType = extractAttribute(headerSection, "Content-Type");
+
+            int nextDelimiter = findIndex(body, delimiterBytes, headerEnd + 4);
+            if (nextDelimiter == -1) break;
+
+            byte[] partData = Arrays.copyOfRange(body, headerEnd + 4, nextDelimiter - 2);
+
+            parts.add(new MultipartPart(name, fileName, contentType, partData));
+            start = nextDelimiter;
+        }
+        return parts;
+    }
+
+    private static int findIndex(byte[] source, byte[] target, int start) {
+        for (int i = start; i <= source.length - target.length; i++) {
+            boolean match = true;
+            for (int j = 0; j < target.length; j++) {
+                if (source[i + j] != target[j]) {
+                    match = false;
+                    break;
+                }
+            }
+            if (match) return i;
+        }
+        return -1;
+    }
+
+    private static String extractAttribute(String header, String attr) {
+        int start = header.indexOf(attr + "=\"");
+        if (start == -1) return null;
+        start += attr.length() + 2;
+        return header.substring(start, header.indexOf("\"", start));
+    }
 }