[톰캣 구현하기 3, 4단계] 루쿠(백경환) 미션 제출합니다.

tomcat/src/main/java/org/apache/catalina/connector/Connector.java

@@ -1,30 +1,34 @@
 package org.apache.catalina.connector;
 
-import org.apache.coyote.http11.Http11Processor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.net.ServerSocket;
 import java.net.Socket;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import org.apache.coyote.http11.Http11Processor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class Connector implements Runnable {
 
     private static final Logger log = LoggerFactory.getLogger(Connector.class);
 
     private static final int DEFAULT_PORT = 8080;
     private static final int DEFAULT_ACCEPT_COUNT = 100;
+    private static final int DEFAULT_MAX_THREADS = 10;
 
     private final ServerSocket serverSocket;
+    private final ExecutorService executorService;
     private boolean stopped;
 
     public Connector() {
-        this(DEFAULT_PORT, DEFAULT_ACCEPT_COUNT);
+        this(DEFAULT_PORT, DEFAULT_ACCEPT_COUNT, DEFAULT_MAX_THREADS);
     }
 
-    public Connector(final int port, final int acceptCount) {
+    public Connector(final int port, final int acceptCount, final int maxThreads) {
         this.serverSocket = createServerSocket(port, acceptCount);
+        this.executorService = Executors.newFixedThreadPool(maxThreads);
         this.stopped = false;
     }
 
@@ -67,7 +71,7 @@ private void process(final Socket connection) {
             return;
         }
         var processor = new Http11Processor(connection);
-        new Thread(processor).start();
+        executorService.execute(processor);
     }
 
     public void stop() {

tomcat/src/main/java/org/apache/coyote/controller/AbstractController.java

@@ -0,0 +1,29 @@
+package org.apache.coyote.controller;
+
+import static org.apache.coyote.http11.HttpMethod.GET;
+import static org.apache.coyote.http11.HttpMethod.POST;
+
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+
+public abstract class AbstractController implements Controller {
+
+    @Override
+    public void service(HttpRequest request, HttpResponse response) throws Exception {
+        if (request.getMethod() == GET) {
+            doGet(request, response);
+            return;
+        }
+
+        if (request.getMethod() == POST) {
+            doPost(request, response);
+            return;
+        }
+
+        throw new IllegalArgumentException("지원하지 않는 메서드 입니다.");
+    }
+
+    protected void doPost(HttpRequest request, HttpResponse response) throws Exception { /* NOOP */ }
+
+    protected void doGet(HttpRequest request, HttpResponse response) throws Exception { /* NOOP */ }
+}

tomcat/src/main/java/org/apache/coyote/controller/Controller.java

@@ -0,0 +1,9 @@
+package org.apache.coyote.controller;
+
+
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+
+public interface Controller {
+    void service(HttpRequest request, HttpResponse response) throws Exception;
+}

tomcat/src/main/java/org/apache/coyote/controller/LoginController.java

@@ -0,0 +1,65 @@
+package org.apache.coyote.controller;
+
+import static org.apache.coyote.http11.HttpStatus.FOUND;
+import static org.apache.coyote.http11.HttpStatus.OK;
+
+import java.util.Map;
+import java.util.UUID;
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.model.User;
+import org.apache.coyote.http11.HttpCookie;
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.Session;
+import org.apache.coyote.http11.SessionManager;
+import org.apache.coyote.http11.Utils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class LoginController extends AbstractController {
+    private static final Logger log = LoggerFactory.getLogger(LoginController.class);
+    private static final SessionManager sessionManager = new SessionManager();
+
+    @Override
+    protected void doPost(HttpRequest request, HttpResponse response) throws Exception {
+        Map<String, String> queryParms = Utils.parseToQueryParms(request.getBody());
+
+        try {
+            User user = InMemoryUserRepository.findByAccount(queryParms.get("account"))
+                    .orElseThrow(() -> new IllegalArgumentException("해당 사용자 없음"));
+
+            if (!user.checkPassword(queryParms.get("password"))) {
+                throw new IllegalArgumentException("비밀번호 불일치");
+            }
+            log.info("user: {}", user);
+
+            Session session = new Session(UUID.randomUUID().toString());
+            session.setAttribute("user", user);
+            sessionManager.add(session);
+            response.setStatus(FOUND);
+            response.setRedirectUrl("/index.html");
+            response.setCookie("JSESSIONID=" + session.getId());
+
+        } catch (IllegalArgumentException e) {
+            log.error("error : {}", e);
+            response.setStatus(FOUND);
+            response.setRedirectUrl("/401.html");
+
+        }
+    }
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) throws Exception {
+        HttpCookie cookie = new HttpCookie(request.getHeaders().get("Cookie"));
+
+        String sessionId = cookie.findValue("JSESSIONID");
+        if (sessionManager.isExist(sessionId)) {
+            response.setStatus(FOUND);
+            response.setRedirectUrl("/index.html");
+        } else {
+            response.setStatus(OK);
+            response.setContentType("text/html");
+            response.setBody(Utils.readFile("static", "login.html"));
+        }
+    }
+}

tomcat/src/main/java/org/apache/coyote/controller/RegisterController.java

@@ -0,0 +1,35 @@
+package org.apache.coyote.controller;
+
+import static org.apache.coyote.http11.HttpStatus.FOUND;
+import static org.apache.coyote.http11.HttpStatus.OK;
+
+import java.util.Map;
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.model.User;
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.Utils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class RegisterController extends AbstractController {
+    private static final Logger log = LoggerFactory.getLogger(RegisterController.class);
+
+    @Override
+    protected void doPost(HttpRequest request, HttpResponse response) throws Exception {
+        Map<String, String> queryParms = Utils.parseToQueryParms(request.getBody());
+        User user = new User(queryParms.get("account"), queryParms.get("password"),
+                queryParms.get("email"));
+        InMemoryUserRepository.save(user);
+        response.setStatus(FOUND);
+        response.setRedirectUrl("/index.html");
+    }
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) throws Exception {
+        response.setStatus(OK);
+        response.setContentType("text/html");
+        response.setBody(Utils.readFile("static", "register.html"));
+    }
+}
+

tomcat/src/main/java/org/apache/coyote/controller/RequestMapping.java

@@ -0,0 +1,23 @@
+package org.apache.coyote.controller;
+
+import org.apache.coyote.http11.HttpRequest;
+
+public class RequestMapping {
+
+    public Controller getController(HttpRequest request) {
+        if (request.getPath().equals("/login")) {
+            return new LoginController();
+        }
+
+        if (request.getPath().equals("/register")) {
+            return new RegisterController();
+        }
+
+        if (request.getPath().equals("/")) {
+            return new RootController();
+        }
+
+        return new ResourceController();
+    }
+
+}

tomcat/src/main/java/org/apache/coyote/controller/ResourceController.java

@@ -0,0 +1,53 @@
+package org.apache.coyote.controller;
+
+import static org.apache.coyote.http11.HttpStatus.FOUND;
+import static org.apache.coyote.http11.HttpStatus.OK;
+
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.Utils;
+
+public class ResourceController extends AbstractController {
+
+    protected void doGet(HttpRequest request, HttpResponse response) throws Exception {
+        response.setStatus(OK);
+
+        String path = request.getPath();
+        String fileName = path.substring(path.lastIndexOf('/') + 1);
+
+        if (fileName.endsWith(".html")) {
+            response.setContentType("text/html");
+            response.setBody(Utils.readFile("static", fileName));
+            return;
+        }
+
+        if (fileName.equals("styles.css")) {
+            response.setContentType("text/css");
+            response.setBody(Utils.readFile("static/css", fileName));
+            return;
+        }
+
+        if (fileName.endsWith(".js") && !fileName.equals("scripts.js")) {
+            response.setContentType("text/javascript");
+            response.setBody(Utils.readFile("static/assets", fileName));
+            return;
+        }
+
+        if (fileName.equals("scripts.js")) {
+            response.setContentType("text/javascript");
+            response.setBody(Utils.readFile("static/js", fileName));
+            return;
+        }
+
+        if (fileName.equals("favicon.ico")) {
+            response.setContentType("text/javascript");
+            response.setBody("Hello world!");
+            return;
+        }
+
+        response.setStatus(FOUND);
+        response.setRedirectUrl("404.html");
+    }
+
+
+}

tomcat/src/main/java/org/apache/coyote/controller/RootController.java

@@ -0,0 +1,16 @@
+package org.apache.coyote.controller;
+
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.HttpStatus;
+
+public class RootController extends AbstractController {
+
+    @Override
+    protected void doGet(HttpRequest request, HttpResponse response) throws Exception {
+        response.setStatus(HttpStatus.OK);
+        response.setContentType("text/html");
+        response.setBody("Hello world!");
+    }
+
+}