2주차 미션 / 서버 1조 주민석

src/main/java/controller/AbstractController.java

@@ -0,0 +1,21 @@
+package controller;
+
+import http.constants.HttpMethod;
+import http.request.HttpRequest;
+import http.response.HttpResponse;
+
+import java.io.IOException;
+
+public abstract class AbstractController implements Controller {
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        if(request.getMethod().equals(HttpMethod.GET.get())){
+            doGet(request, response);
+            return;
+        }
+        doPost(request, response);
+    }
+
+    public abstract void doGet(HttpRequest request, HttpResponse response) throws IOException;
+    public abstract void doPost(HttpRequest request, HttpResponse response) throws IOException;
+}

src/main/java/controller/Controller.java

@@ -0,0 +1,10 @@
+package controller;
+
+import http.request.HttpRequest;
+import http.response.HttpResponse;
+
+import java.io.IOException;
+
+public interface Controller {
+    void execute(HttpRequest request, HttpResponse response) throws IOException;
+}

src/main/java/controller/ForwardController.java

@@ -0,0 +1,13 @@
+package controller;
+
+import http.request.HttpRequest;
+import http.response.HttpResponse;
+
+import java.io.IOException;
+
+public class ForwardController implements Controller {
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        response.forward(request.getPath());
+    }
+}

src/main/java/controller/HomeController.java

@@ -0,0 +1,14 @@
+package controller;
+
+import http.request.HttpRequest;
+import http.request.RequestURL;
+import http.response.HttpResponse;
+
+import java.io.IOException;
+
+public class HomeController implements Controller {
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        response.forward(RequestURL.HOME_URL.get());
+    }
+}

src/main/java/controller/ListController.java

@@ -0,0 +1,22 @@
+package controller;
+
+import http.request.HttpRequest;
+import http.request.RequestURL;
+import http.response.HttpResponse;
+
+import java.io.IOException;
+
+public class ListController implements Controller {
+
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        // 비로그인 상태 : redirect to /user/login.html
+        String cookie = request.getField("Cookie");
+        if (cookie == null || !cookie.equals("logined=true")) {
+            response.redirect(RequestURL.LOGIN_URL.get());
+            return;
+        }
+        // 로그인 상태 : user/list.html 반환
+        response.forward(RequestURL.LIST_URL.get());
+    }
+}

src/main/java/controller/LoginController.java

@@ -0,0 +1,26 @@
+package controller;
+
+import db.MemoryUserRepository;
+import db.Repository;
+import http.request.HttpRequest;
+import http.request.RequestURL;
+import http.response.HttpResponse;
+import model.User;
+
+import java.io.IOException;
+
+public class LoginController implements Controller {
+    private final Repository repository = MemoryUserRepository.getInstance();
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        User user = repository.findUserById(request.getQueryParameter("userId"));
+
+        // 로그인 성공
+        if (user != null && user.getPassword().equals(request.getQueryParameter("password"))) {
+            response.redirectWithCookie(RequestURL.HOME_URL.get());
+            return;
+        }
+        // 로그인 실패
+        response.redirect(RequestURL.LOGIN_FAILED_URL.get());
+    }
+}

src/main/java/controller/SignUpController.java

@@ -0,0 +1,24 @@
+package controller;
+
+import db.MemoryUserRepository;
+import db.Repository;
+import http.request.HttpRequest;
+import http.request.RequestURL;
+import http.response.HttpResponse;
+import model.User;
+
+import java.io.IOException;
+
+public class SignUpController implements Controller {
+    private final Repository repository = MemoryUserRepository.getInstance();
+
+    @Override
+    public void execute(HttpRequest request, HttpResponse response) throws IOException {
+        User user = new User(request.getQueryParameter("userId"),
+                request.getQueryParameter("password"),
+                request.getQueryParameter("name"),
+                request.getQueryParameter("email"));
+        repository.addUser(user);
+        response.redirect(RequestURL.HOME_URL.get());
+    }
+}

src/main/java/http/constants/HttpMethod.java

@@ -0,0 +1,16 @@
+package http.constants;
+
+public enum HttpMethod {
+    GET("GET"),
+    POST("POST");
+
+    private final String method;
+
+    HttpMethod(String method) {
+        this.method = method;
+    }
+
+    public String get() {
+        return method;
+    }
+}

src/main/java/http/request/HttpHeader.java

@@ -0,0 +1,58 @@
+package http.request;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+public class HttpHeader {
+    private final Map<String, String> header; // header fields
+
+    public HttpHeader(Map<String, String> header) {
+        this.header = header;
+    }
+
+    public static HttpHeader from(BufferedReader br) throws IOException {
+        return new HttpHeader(readHeader(br));
+    }
+
+    private static Map<String, String> readHeader(BufferedReader br) throws IOException {
+        Map<String, String> header = new HashMap<>();
+        String field = "";
+
+        while (!(field = br.readLine()).isEmpty()) {
+            String[] pair = field.split(": ");
+            String name = pair[0];
+            String value = pair[1];
+            header.put(name, value);
+        }
+
+        return header;
+    }
+
+    public boolean contains(String fieldName) {
+        return header.containsKey(fieldName);
+    }
+
+    public String get(String fieldName) {
+        return header.get(fieldName);
+    }
+
+    public void put(String name, String value) {
+        header.put(name, value);
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+
+        for (String name : header.keySet()) {
+            sb.append(name)
+                    .append(": ")
+                    .append(header.get(name))
+                    .append("\r\n");
+        }
+
+        return sb.append("\r\n").toString();
+    }
+}

src/main/java/http/request/HttpRequest.java

@@ -0,0 +1,78 @@
+package http.request;
+
+import http.constants.HttpMethod;
+import http.util.HttpRequestUtils;
+import http.util.IOUtils;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.HashMap;
+import java.util.Map;
+
+public class HttpRequest {
+    private final HttpRequestStartLine startLine;   // request start-line
+    private final HttpHeader header;  // request header (fields)
+    private final String body;  // request body
+    private final Map<String, String> query;
+
+    private HttpRequest(HttpRequestStartLine startLine, HttpHeader header, String body, Map<String, String> query) {
+        this.startLine = startLine;
+        this.header = header;
+        this.body = body;
+        this.query = query;
+    }
+
+    public static HttpRequest from(InputStream in) throws IOException {
+        BufferedReader br = new BufferedReader(new InputStreamReader(in));
+        String startLine = br.readLine();
+        if (startLine == null) {
+            throw new IllegalArgumentException("request is empty.");
+        }
+
+        HttpRequestStartLine httpRequestStartLine = HttpRequestStartLine.from(startLine);
+        HttpHeader header = HttpHeader.from(br);
+        String body = readBody(br, header);
+        Map<String, String> query = createQuery(body);
+
+        return new HttpRequest(httpRequestStartLine, header, body, query);
+    }
+
+    private static String readBody(BufferedReader br, HttpHeader header) throws IOException {
+        if (!header.contains("Content-Length")) {
+            return "";
+        }
+
+        int contentLength = Integer.parseInt(header.get("Content-Length"));
+        return IOUtils.readData(br, contentLength);
+    }
+
+    private static Map<String, String> createQuery(String body) {
+        // GET 방식인 경우
+        if (body.isEmpty()) {
+            return new HashMap<>();
+        }
+
+        // POST 방식인 경우
+        return HttpRequestUtils.parseQueryParameter(body);
+    }
+
+    public String getPath() {
+        return startLine.getPath();
+    }
+
+    public String getMethod() {
+        return startLine.getMethod();
+    }
+
+    public String getQueryParameter(String fieldName) {
+        if (getMethod().equals(HttpMethod.GET.get()))
+            return startLine.getQueryParameter(fieldName);
+        return query.get(fieldName);
+    }
+
+    public String getField(String fieldName) {
+        return header.get(fieldName);
+    }
+}

src/main/java/http/request/HttpRequestStartLine.java

@@ -0,0 +1,59 @@
+package http.request;
+
+import http.util.HttpRequestUtils;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class HttpRequestStartLine {
+    private final String method;
+    private final String path;
+    private final String version;
+    private final Map<String, String> query;
+
+    public HttpRequestStartLine(String method, String path, String version, Map<String, String> query) {
+        this.method = method;
+        this.path = path;
+        this.version = version;
+        this.query = query;
+    }
+
+    public static HttpRequestStartLine from(String startLine) {
+        String[] elements = startLine.split(" ");
+
+        String method = elements[0];
+        String path = elements[1];
+        String version = elements[2];
+        Map<String, String> query = createQuery(path);
+
+        return new HttpRequestStartLine(method, path, version, query);
+    }
+
+    private static Map<String, String> createQuery(String path) {
+        // POST 방식인 경우
+        int index = path.indexOf("?");
+        if (index == -1) {
+            return new HashMap<>();
+        }
+
+        // GET 방식인 경우
+        String queryString = path.substring(index + 1);
+        return HttpRequestUtils.parseQueryParameter(queryString);
+    }
+
+    public String getMethod() {
+        return method;
+    }
+
+    public String getPath() {
+        return path;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public String getQueryParameter(String queryParameter) {
+        return query.get(queryParameter);
+    }
+}

src/main/java/http/request/RequestURL.java

@@ -0,0 +1,22 @@
+package http.request;
+
+public enum RequestURL {
+    ROOT("./webapp"),
+    HOME_URL("/index.html"),
+    LOGIN_FAILED_URL("/user/login_failed.html"),
+    LOGIN_URL("/user/login.html"),
+    LIST_URL("/user/list.html"),
+    SIGN_UP("/user/signup"),
+    LOGIN("/user/login"),
+    USER_LIST("/user/userList");
+
+    private final String url;
+
+    RequestURL(String url) {
+        this.url = url;
+    }
+
+    public String get() {
+        return url;
+    }
+}