[Han, Jay] 웹서버 1단계 구현

README.md

@@ -1,11 +1,4 @@
-# 웹 애플리케이션 서버
-## 진행 방법
-* 웹 애플리케이션 서버 요구사항을 파악한다.
-* 요구사항에 대한 구현을 완료한 후 자신의 github 아이디에 해당하는 브랜치에 Pull Request(이하 PR)를 통해 코드 리뷰 요청을 한다.
-* 다음 단계를 도전하고 앞의 과정을 반복한다.
-* 코드 리뷰가 완료되면 피드백에 대한 개선 작업을 한다.
-* 다음 단계 PR 보낼 때 이전 단계 피드백이 잘 반영되었는지 점검한다.
-
-## 온라인 코드 리뷰 과정
-* [텍스트와 이미지로 살펴보는 코드스쿼드의 온라인 코드 리뷰 과정](https://github.com/code-squad/codesquad-docs/blob/master/codereview/README.md)
-* [동영상으로 살펴보는 코드스쿼드의 온라인 코드 리뷰 과정](https://youtu.be/a5c9ku-_fok)
+# 웹서버 구현
+### [Ground Rule](https://github.com/beginin15/java-was/wiki/Ground-Rule)
+### [Han's README](https://github.com/beginin15/java-was/wiki/%5BHan%5D-README)
+### [Jay's README](https://github.com/beginin15/java-was/wiki/%5BJay%5D-README)

src/main/java/db/DataBase.java

@@ -2,6 +2,8 @@
 
 import java.util.Collection;
 import java.util.Map;
+import java.util.NoSuchElementException;
+import java.util.Optional;
 
 import com.google.common.collect.Maps;
 
@@ -10,12 +12,16 @@
 public class DataBase {
     private static Map<String, User> users = Maps.newHashMap();
 
+    public static int getSizeOfUsers() {
+        return users.size();
+    }
+
     public static void addUser(User user) {
         users.put(user.getUserId(), user);
     }
 
-    public static User findUserById(String userId) {
-        return users.get(userId);
+    public static User findUserById(String userId) throws NoSuchElementException{
+        return Optional.ofNullable(users.get(userId)).orElseThrow(NoSuchElementException::new);
     }
 
     public static Collection<User> findAll() {

src/main/java/db/SessionDataBase.java

@@ -0,0 +1,23 @@
+package db;
+
+import com.google.common.collect.Maps;
+import model.User;
+
+import java.util.Collection;
+import java.util.Map;
+
+public class SessionDataBase {
+    private static Map<String, User> sessions = Maps.newHashMap();
+
+    public static void addSession(String sessionId, User user) {
+        sessions.put(sessionId, user);
+    }
+
+    public static User getSessionedUser(String sessionId) {
+        return sessions.get(sessionId);
+    }
+
+    public static boolean isSessionIdExist(String sessionId) {
+        return sessions.containsKey(sessionId);
+    }
+}

src/main/java/http/HttpMethod.java

@@ -0,0 +1,6 @@
+package http;
+
+public enum HttpMethod {
+    GET,
+    POST;
+}

src/main/java/http/HttpRequest.java

@@ -0,0 +1,64 @@
+package http;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import util.HttpRequestUtils;
+import util.IOUtils;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.util.Map;
+
+public class HttpRequest {
+
+    private static final Logger log = LoggerFactory.getLogger(HttpRequest.class);
+
+    private HttpMethod httpMethod;
+    private String path;
+    private Map<String, String> header;
+    private Map<String, String> parameter;
+
+    public HttpRequest(BufferedReader br) {
+        parseRequest(br);
+    }
+
+    public HttpMethod getMethod() {
+        return httpMethod;
+    }
+
+    public String getPath() {
+        return path;
+    }
+
+    public String getHeader(String key) {
+        return header.get(key);
+    }
+
+    public String getParameter(String key) {
+        return parameter.get(key);
+    }
+
+    private void parseRequest(BufferedReader br) {
+        String requestLine;
+
+        try {
+            requestLine = br.readLine();
+            httpMethod = HttpMethod.valueOf(HttpRequestUtils.getMethod(requestLine));
+            path = HttpRequestUtils.getURL(requestLine);
+            changePathIfRoot();
+            header = HttpRequestUtils.extractHeader(br);
+            if (httpMethod.equals(HttpMethod.POST)) {
+                String body = IOUtils.readData(br, Integer.parseInt(getHeader("Content-Length")));
+                parameter = HttpRequestUtils.parseQueryString(body);
+            }
+        } catch (IOException e) {
+            log.error("HttpRequest parse 과정 에러");
+        }
+    }
+
+    private void changePathIfRoot() {
+        if (this.path.equals("/")) {
+            path = "/index.html";
+        }
+    }
+}

src/main/java/http/HttpResponse.java

@@ -0,0 +1,118 @@
+package http;
+
+
+import model.User;
+import util.HttpResponseUtils;
+
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class HttpResponse {
+
+    private Map<String, String> header;
+    private DataOutputStream dos;
+
+    public HttpResponse() {
+        header = new HashMap<>();
+    }
+
+    public HttpResponse(DataOutputStream dos) {
+        header = new HashMap<>();
+        this.dos = dos;
+    }
+
+//    public void addHeader(String key, String value) {
+//        header.put(key, value);
+//    }
+
+    public void forward(String path) throws IOException {
+        byte[] body;
+        if (HttpResponseUtils.isFileExist(path)) {
+            body = HttpResponseUtils.readFile(path);
+            response200Header(body.length);
+            responseBody(body);
+            return;
+        }
+        body = HttpResponseUtils.notExistPage();
+        response404Header(body.length);
+        responseBody(body);
+    }
+
+    public void forwardBody(String responseBody) {
+
+    }
+
+    public void response200Header(int lengthOfBodyContent) throws IOException {
+        dos.writeBytes("HTTP/1.1 200 OK \r\n");
+        dos.writeBytes("Content-Type: text/html;charset=utf-8\r\n");
+        dos.writeBytes("Content-Length: " + lengthOfBodyContent + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+
+    public void sendRedirect(String location) throws IOException {
+        dos.writeBytes("HTTP/1.1 302 Found \r\n");
+        dos.writeBytes("Location: " + location + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+
+    public void sendRedirect(String location, String sessionId) throws IOException {
+        dos.writeBytes("HTTP/1.1 302 Found \r\n");
+        dos.writeBytes("Location: " + location + "\r\n");
+        dos.writeBytes("Set-Cookie: JSESSIONID=" + sessionId + "; Path=/" + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+
+    public void readUserList(List<User> users) throws IOException {
+        byte[] body = HttpResponseUtils.readFile("/user/list.html");
+        String userListHtml = HttpResponseUtils.getUserListHTML(body, users);
+        response200Header(userListHtml.length());
+        responseBody(userListHtml.getBytes());
+    }
+
+    public void readCss(String path) throws IOException {
+        byte[] body = Files.readAllBytes(new File("./webapp" + path).toPath());
+        responseCssHeader(body.length);
+        responseBody(body);
+    }
+
+    public String processHeaders() {
+        StringBuilder sb = new StringBuilder();
+        header.entrySet().stream()
+                .map(entry -> entry.getKey() + ": " + entry.getValue())
+                .forEach(header -> sb.append(header).append("\r\n"));
+
+        sb.append("\r\n");
+        return sb.toString();
+    }
+
+    private void responseCssHeader(int lengthOfBodyContent) throws IOException {
+        dos.writeBytes("HTTP/1.1 200 OK \r\n");
+        dos.writeBytes("Content-Type: text/css;charset=utf-8\r\n");
+        dos.writeBytes("Content-Length: " + lengthOfBodyContent + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+
+    private void response401Header(int lengthOfBodyContent) throws IOException {
+        dos.writeBytes("HTTP/1.1 401 Unauthorized \r\n");
+        dos.writeBytes("Content-Type: text/html;charset=utf-8\r\n");
+        dos.writeBytes("Content-Length: " + lengthOfBodyContent + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+
+    private void responseBody(byte[] body) throws IOException {
+        dos.write(body, 0, body.length);
+        dos.flush();
+    }
+
+    private void response404Header(int lengthOfBodyContent) throws IOException {
+        dos.writeBytes("HTTP/1.1 404 Not Found \r\n");
+        dos.writeBytes("Content-Type: text/html;charset=utf-8\r\n");
+        dos.writeBytes("Content-Length: " + lengthOfBodyContent + "\r\n");
+        dos.writeBytes("\r\n");
+    }
+}

src/main/java/model/User.java

@@ -13,6 +13,11 @@ public User(String userId, String password, String name, String email) {
         this.email = email;
     }
 
+    public User(String userId, String password) {
+        this.userId = userId;
+        this.password = password;
+    }
+
     public String getUserId() {
         return userId;
     }
@@ -29,6 +34,10 @@ public String getEmail() {
         return email;
     }
 
+    public boolean isSameUser(User loginedUser) {
+        return this.password.equals(loginedUser.password);
+    }
+
     @Override
     public String toString() {
         return "User [userId=" + userId + ", password=" + password + ", name=" + name + ", email=" + email + "]";

src/main/java/util/HttpRequestUtils.java

@@ -1,25 +1,60 @@
 package util;
 
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.Map;
 import java.util.stream.Collectors;
 
 import com.google.common.base.Strings;
 import com.google.common.collect.Maps;
 
 public class HttpRequestUtils {
+
+    private static final int INDEX_PATH = 1;
+    private static final int INDEX_METHOD = 0;
+
+
+    public static Map<String, String> extractHeader(BufferedReader br) throws IOException {
+        Map<String, String> header = new HashMap<>();
+        String requestLine;
+
+        while (!(requestLine = br.readLine()).equals("")) {
+            Pair pair = parseHeader(requestLine);
+            header.put(pair.getKey(), pair.getValue());
+        }
+        return header;
+    }
+
+    public static String getURL(String line) throws IOException {
+        if (line == null) throw new IOException("잘못된 Request Start Line");
+        return line.split(" ")[INDEX_PATH];
+    }
+
+    public static String getMethod(String line) throws IOException {
+        if (line == null) throw new IOException("잘못된 Request Start Line");
+        return line.split(" ")[INDEX_METHOD];
+    }
+
+
+    public static String decode(String line) throws UnsupportedEncodingException {
+        return URLDecoder.decode(line, StandardCharsets.UTF_8.toString());
+    }
+
     /**
-     * @param queryString은
-     *            URL에서 ? 이후에 전달되는 field1=value1&field2=value2 형식임
+     * @param queryString은 URL에서 ? 이후에 전달되는 field1=value1&field2=value2 형식임
      * @return
      */
     public static Map<String, String> parseQueryString(String queryString) {
         return parseValues(queryString, "&");
     }
 
     /**
-     * @param 쿠키
-     *            값은 name1=value1; name2=value2 형식임
+     * @param 쿠키 값은 name1=value1; name2=value2 형식임
      * @return
      */
     public static Map<String, String> parseCookies(String cookies) {