[톰캣 구현하기 - 3, 4단계] 가비(이준희) 미션 제출합니다.

study/src/main/resources/application.yml

@@ -3,10 +3,10 @@ handlebars:
 
 server:
   tomcat:
-    accept-count: 1
-    max-connections: 1
+    accept-count: 2 # 쓰레드가 사용중일 때, 받은 요청이 대기하는 큐의 최대값
+    max-connections: 2 # 서버가 유지할 수 있는 최대 커넥션 수
     threads:
-      max: 2
+      max: 2 # 실행가능 쓰레드 수
   compression:
     enabled: true
     min-response-size : 10

study/src/test/java/thread/stage0/SynchronizationTest.java

@@ -41,7 +41,7 @@ private static final class SynchronizedMethods {
 
         private int sum = 0;
 
-        public void calculate() {
+        public synchronized void calculate() {
             setSum(getSum() + 1);
         }
 

study/src/test/java/thread/stage0/ThreadPoolsTest.java

@@ -31,8 +31,8 @@ void testNewFixedThreadPool() {
         executor.submit(logWithSleep("hello fixed thread pools"));
 
         // 올바른 값으로 바꿔서 테스트를 통과시키자.
-        final int expectedPoolSize = 0;
-        final int expectedQueueSize = 0;
+        final int expectedPoolSize = 2;
+        final int expectedQueueSize = 1;
 
         assertThat(expectedPoolSize).isEqualTo(executor.getPoolSize());
         assertThat(expectedQueueSize).isEqualTo(executor.getQueue().size());
@@ -46,7 +46,7 @@ void testNewCachedThreadPool() {
         executor.submit(logWithSleep("hello cached thread pools"));
 
         // 올바른 값으로 바꿔서 테스트를 통과시키자.
-        final int expectedPoolSize = 0;
+        final int expectedPoolSize = 3;
         final int expectedQueueSize = 0;
 
         assertThat(expectedPoolSize).isEqualTo(executor.getPoolSize());

tomcat/src/main/java/nextstep/jwp/controller/FrontController.java

@@ -0,0 +1,29 @@
+package nextstep.jwp.controller;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.catalina.controller.AbstractController;
+import org.apache.catalina.controller.Controller;
+import org.apache.coyote.http11.request.HttpRequest;
+import org.apache.coyote.http11.response.HttpResponse;
+
+public class FrontController extends AbstractController {
+
+    private static final Map<String, Controller> URIS = new HashMap<>();
+
+    static {
+        URIS.put("/", new HomeController());
+        URIS.put("/login", new LoginController());
+        URIS.put("/register", new RegisterController());
+        URIS.put("/index", new IndexController());
+    }
+
+    @Override
+    public void service(HttpRequest request, HttpResponse response) {
+        String uri = request.getResourceUri();
+        Controller controller = URIS.getOrDefault(uri, new ResourceController());
+        controller.service(request, response);
+    }
+
+}

tomcat/src/main/java/nextstep/jwp/controller/HomeController.java

@@ -0,0 +1,26 @@
+package nextstep.jwp.controller;
+
+import org.apache.catalina.controller.AbstractController;
+import org.apache.coyote.http11.request.HttpRequest;
+import org.apache.coyote.http11.response.HttpResponse;
+import org.apache.coyote.http11.response.HttpStatus;
+import org.apache.coyote.http11.response.ResponseBody;
+import org.apache.coyote.http11.response.StatusLine;
+
+import static org.apache.coyote.http11.request.ContentType.HTML;
+
+
+public class HomeController extends AbstractController {
+    private static final String DEFAULT_MESSAGE = "Hello world!";
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) {
+        StatusLine statusLine = new StatusLine(request.getProtocolVersion(), HttpStatus.OK);
+        response
+                .statusLine(statusLine)
+                .contentType(HTML.getValue())
+                .contentLength(DEFAULT_MESSAGE.getBytes().length)
+                .responseBody(new ResponseBody(DEFAULT_MESSAGE));
+    }
+
+}

tomcat/src/main/java/nextstep/jwp/controller/IndexController.java

@@ -0,0 +1,27 @@
+package nextstep.jwp.controller;
+
+import org.apache.catalina.controller.AbstractController;
+import org.apache.coyote.http11.request.HttpRequest;
+import org.apache.coyote.http11.response.HttpResponse;
+import org.apache.coyote.http11.response.HttpStatus;
+import org.apache.coyote.http11.response.ResponseBody;
+import org.apache.coyote.http11.response.StatusLine;
+import org.apache.coyote.http11.util.FileReader;
+
+import static org.apache.coyote.http11.request.ContentType.HTML;
+
+public class IndexController extends AbstractController {
+    private static final String RESOURCE = "/index.html";
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) {
+        ResponseBody responseBody = new ResponseBody(FileReader.read(RESOURCE));
+        StatusLine statusLine = new StatusLine(request.getProtocolVersion(), HttpStatus.OK);
+        response
+                .statusLine(statusLine)
+                .contentType(HTML.getValue())
+                .contentLength(responseBody.getValue().getBytes().length)
+                .responseBody(responseBody);
+    }
+
+}

tomcat/src/main/java/nextstep/jwp/controller/LoginController.java

@@ -0,0 +1,115 @@
+package nextstep.jwp.controller;
+
+import java.util.Optional;
+import java.util.UUID;
+
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.model.User;
+import org.apache.coyote.http11.common.HttpCookie;
+import org.apache.catalina.controller.AbstractController;
+import org.apache.coyote.http11.request.HttpRequest;
+import org.apache.coyote.http11.request.RequestBody;
+import org.apache.coyote.http11.response.HttpResponse;
+import org.apache.coyote.http11.response.HttpStatus;
+import org.apache.coyote.http11.response.ResponseBody;
+import org.apache.coyote.http11.response.StatusLine;
+import org.apache.catalina.Session;
+import org.apache.catalina.SessionManager;
+import org.apache.coyote.http11.util.FileReader;
+
+import static org.apache.coyote.http11.request.ContentType.HTML;
+
+public class LoginController extends AbstractController {
+
+    private static final String URI = "/login.html";
+    private static final String UNAUTHORIZED = "/401.html";
+    private static final String REDIRECT_HOME_URI = "/index.html";
+
+    public static final SessionManager SESSION_MANAGER = new SessionManager();
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) {
+        if (hasCookie(request)) {
+            redirectHome(request, response);
+            return;
+        }
+        showLoginPage(request, response);
+    }
+
+    private boolean hasCookie(HttpRequest httpRequest) {
+        HttpCookie cookie = HttpCookie.from(httpRequest.getHeaderValue("Cookie"));
+        return SESSION_MANAGER.findSession(cookie.getValue("JSESSIONID")) != null;
+    }
+
+    private void redirectHome(HttpRequest request, HttpResponse response) {
+        StatusLine statusLine = new StatusLine(request.getProtocolVersion(), HttpStatus.FOUND);
+        ResponseBody responseBody = new ResponseBody(FileReader.read(REDIRECT_HOME_URI));
+        response
+                .statusLine(statusLine)
+                .contentType(HTML.getValue())
+                .contentLength(responseBody.getValue().getBytes().length)
+                .redirect(REDIRECT_HOME_URI)
+                .responseBody(responseBody);
+    }
+
+    private void showLoginPage(HttpRequest request, HttpResponse response) {
+        ResponseBody responseBody = new ResponseBody(FileReader.read(URI));
+        StatusLine statusLine = new StatusLine(request.getProtocolVersion(), HttpStatus.OK);
+        response
+                .statusLine(statusLine)
+                .contentType(HTML.getValue())
+                .contentLength(responseBody.getValue().length())
+                .responseBody(responseBody);
+    }
+
+    @Override
+    protected void doPost(HttpRequest httpRequest, HttpResponse httpResponse) {
+        Optional<User> optionalUser = findUser(httpRequest);
+        if (optionalUser.isEmpty()) {
+            redirectUnauthorized(httpRequest, httpResponse);
+            return;
+        }
+
+        successLogin(httpRequest, httpResponse);
+    }
+
+    private Optional<User> findUser(HttpRequest request) {
+        RequestBody requestBody = request.getRequestBody();
+        String account = requestBody.getValueOf("account");
+        String password = requestBody.getValueOf("password");
+        return InMemoryUserRepository.findByAccount(account)
+                .stream()
+                .filter(it -> it.checkPassword(password))
+                .findFirst();
+    }
+
+    private void redirectUnauthorized(HttpRequest httpRequest, HttpResponse httpResponse) {
+        ResponseBody responseBody = new ResponseBody(FileReader.read(UNAUTHORIZED));
+        httpResponse
+                .statusLine(new StatusLine(httpRequest.getProtocolVersion(), HttpStatus.UNAUTHORIZED))
+                .contentType(HTML.getValue())
+                .contentLength(responseBody.getValue().getBytes().length)
+                .redirect(UNAUTHORIZED)
+                .responseBody(responseBody);
+    }
+
+    private void successLogin(HttpRequest httpRequest, HttpResponse httpResponse) {
+        String sessionId = addSession();
+
+        ResponseBody responseBody = new ResponseBody(FileReader.read(REDIRECT_HOME_URI));
+        httpResponse
+                .statusLine(new StatusLine(httpRequest.getProtocolVersion(), HttpStatus.FOUND))
+                .contentType(HTML.getValue())
+                .contentLength(responseBody.getValue().getBytes().length)
+                .setCookie(HttpCookie.jSessionId(sessionId))
+                .redirect(REDIRECT_HOME_URI)
+                .responseBody(responseBody);
+    }
+
+    private String addSession() {
+        String uuid = UUID.randomUUID().toString();
+        SESSION_MANAGER.add(new Session(uuid));
+        return uuid;
+    }
+
+}