[톰캣 구현하기 - 1, 2단계] 말랑(신동훈) 미션 제출합니다.

study/src/test/java/study/FileTest.java

@@ -1,54 +1,49 @@
 package study;
 
-import org.junit.jupiter.api.DisplayName;
-import org.junit.jupiter.api.Test;
+import static org.assertj.core.api.Assertions.assertThat;
 
-import java.nio.file.Path;
-import java.util.Collections;
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.URL;
 import java.util.List;
-
-import static org.assertj.core.api.Assertions.assertThat;
+import java.util.stream.Collectors;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
 
 /**
- * 웹서버는 사용자가 요청한 html 파일을 제공 할 수 있어야 한다.
- * File 클래스를 사용해서 파일을 읽어오고, 사용자에게 전달한다.
+ * 웹서버는 사용자가 요청한 html 파일을 제공 할 수 있어야 한다. File 클래스를 사용해서 파일을 읽어오고, 사용자에게 전달한다.
  */
 @DisplayName("File 클래스 학습 테스트")
 class FileTest {
 
     /**
      * resource 디렉터리 경로 찾기
-     *
-     * File 객체를 생성하려면 파일의 경로를 알아야 한다.
-     * 자바 애플리케이션은 resource 디렉터리에 HTML, CSS 같은 정적 파일을 저장한다.
-     * resource 디렉터리의 경로는 어떻게 알아낼 수 있을까?
+     * <p>
+     * File 객체를 생성하려면 파일의 경로를 알아야 한다. 자바 애플리케이션은 resource 디렉터리에 HTML, CSS 같은 정적 파일을 저장한다. resource 디렉터리의 경로는 어떻게 알아낼 수
+     * 있을까?
      */
     @Test
     void resource_디렉터리에_있는_파일의_경로를_찾는다() {
-        final String fileName = "nextstep.txt";
-
-        // todo
-        final String actual = "";
-
+        String fileName = "nextstep.txt";
+        URL resource = getClass().getClassLoader().getResource(fileName);
+        String actual = resource.getFile();
         assertThat(actual).endsWith(fileName);
     }
 
     /**
      * 파일 내용 읽기
-     *
-     * 읽어온 파일의 내용을 I/O Stream을 사용해서 사용자에게 전달 해야 한다.
-     * File, Files 클래스를 사용하여 파일의 내용을 읽어보자.
+     * <p>
+     * 읽어온 파일의 내용을 I/O Stream을 사용해서 사용자에게 전달 해야 한다. File, Files 클래스를 사용하여 파일의 내용을 읽어보자.
      */
     @Test
     void 파일의_내용을_읽는다() {
-        final String fileName = "nextstep.txt";
-
-        // todo
-        final Path path = null;
-
-        // todo
-        final List<String> actual = Collections.emptyList();
-
-        assertThat(actual).containsOnly("nextstep");
+        String fileName = "nextstep.txt";
+        InputStream inputStream = getClass().getClassLoader().getResourceAsStream(fileName);
+        try (BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream))) {
+            List<String> actual = bufferedReader.lines().collect(Collectors.toList());
+            assertThat(actual).containsOnly("nextstep");
+        } catch (Exception e) {
+        }
     }
 }

tomcat/src/main/java/nextstep/Application.java

@@ -1,11 +1,27 @@
 package nextstep;
 
+import java.util.List;
+import nextstep.jwp.handler.DispatcherServlet;
+import nextstep.jwp.handler.LoginPageHandler;
+import nextstep.jwp.handler.LoginRequestHandler;
+import nextstep.jwp.handler.RootPageRequestHandler;
+import nextstep.jwp.handler.SignUpRequestHandler;
+import nextstep.jwp.handler.StaticResourceRequestHandler;
+import nextstep.jwp.handler.mappaing.HandlerMapping;
 import org.apache.catalina.startup.Tomcat;
 
 public class Application {
 
     public static void main(String[] args) {
-        final var tomcat = new Tomcat();
+        HandlerMapping mapping = new HandlerMapping(List.of(
+                new RootPageRequestHandler(),
+                new LoginPageHandler(),
+                new LoginRequestHandler(),
+                new SignUpRequestHandler(),
+                new StaticResourceRequestHandler()
+        ));
+        DispatcherServlet dispatcherServlet = new DispatcherServlet(mapping);
+        final var tomcat = new Tomcat(dispatcherServlet);
         tomcat.start();
     }
 }

tomcat/src/main/java/nextstep/jwp/exception/UnAuthenticatedException.java

@@ -0,0 +1,8 @@
+package nextstep.jwp.exception;
+
+public class UnAuthenticatedException extends RuntimeException {
+
+    public UnAuthenticatedException() {
+        super("인증에 실패하였습니다.");
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/DispatcherServlet.java

@@ -0,0 +1,22 @@
+package nextstep.jwp.handler;
+
+import nextstep.jwp.handler.mappaing.HandlerMapping;
+import org.apache.catalina.servlet.Servlet;
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+
+public class DispatcherServlet implements Servlet {
+
+    private final HandlerMapping mapping;
+
+    public DispatcherServlet(HandlerMapping mapping) {
+        this.mapping = mapping;
+    }
+
+    @Override
+    public void service(HttpRequest request, HttpResponse response) {
+        RequestHandler handler = mapping.getHandler(request);
+        // TODO null 처리
+        handler.handle(request, response);
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/LoginPageHandler.java

@@ -0,0 +1,38 @@
+package nextstep.jwp.handler;
+
+import static org.apache.catalina.servlet.response.HttpStatus.FOUND;
+import static org.apache.catalina.servlet.response.HttpStatus.OK;
+import static org.apache.catalina.servlet.session.SessionConstant.JSESSIONID;
+
+import nextstep.jwp.util.ResourceFileUtil;
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+import org.apache.catalina.servlet.response.StatusLine;
+import org.apache.catalina.servlet.session.SessionManager;
+
+public class LoginPageHandler implements RequestHandler {
+
+    @Override
+    public boolean canHandle(HttpRequest request) {
+        return request.startLine().uri().path().equals("/login")
+                && request.startLine().method().equals("GET");
+    }
+
+    @Override
+    public void handle(HttpRequest request, HttpResponse response) {
+        if (isAuthenticated(request)) {
+            response.setStatusLine(new StatusLine(FOUND));
+            response.addHeader("Location", "/index.html");
+        } else {
+            response.setStatusLine(new StatusLine(OK));
+            response.addHeader("Content-Type", "text/html;charset=utf-8");
+            String resource = ResourceFileUtil.readAll("static" + "/login.html");
+            response.setMessageBody(resource);
+        }
+    }
+
+    private boolean isAuthenticated(HttpRequest request) {
+        String id = request.cookies().get(JSESSIONID);
+        return SessionManager.findSession(id) != null;
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/LoginRequestHandler.java

@@ -0,0 +1,47 @@
+package nextstep.jwp.handler;
+
+import static org.apache.catalina.servlet.response.HttpStatus.FOUND;
+import static org.apache.catalina.servlet.session.SessionConstant.JSESSIONID;
+
+import java.util.Map;
+import java.util.UUID;
+import nextstep.jwp.exception.UnAuthenticatedException;
+import nextstep.jwp.model.User;
+import nextstep.jwp.service.AuthService;
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+import org.apache.catalina.servlet.response.StatusLine;
+import org.apache.catalina.servlet.session.Session;
+import org.apache.catalina.servlet.session.SessionManager;
+import org.apache.catalina.servlet.util.RequestParamUtil;
+import org.apache.coyote.http11.Http11Processor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class LoginRequestHandler implements RequestHandler {
+
+    private static final Logger log = LoggerFactory.getLogger(Http11Processor.class);
+    private final AuthService authService = new AuthService();
+
+    @Override
+    public boolean canHandle(HttpRequest request) {
+        return request.startLine().uri().path().equals("/login")
+                && request.startLine().method().equals("POST");
+    }
+
+    @Override
+    public void handle(HttpRequest request, HttpResponse response) {
+        Map<String, String> formData = RequestParamUtil.parse(request.body());
+        response.setStatusLine(new StatusLine(FOUND));
+        try {
+            User user = authService.login(formData.get("account"), formData.get("password"));
+            log.info("User={}", user);
+            response.addHeader("Location", "/index.html");
+            Session session = new Session(UUID.randomUUID().toString());
+            SessionManager.add(session);
+            response.addCookie(JSESSIONID, session.id());
+        } catch (UnAuthenticatedException e) {
+            response.addHeader("Location", "/401.html");
+        }
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/RequestHandler.java

@@ -0,0 +1,11 @@
+package nextstep.jwp.handler;
+
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+
+public interface RequestHandler {
+
+    boolean canHandle(HttpRequest request);
+
+    void handle(HttpRequest request, HttpResponse response);
+}

tomcat/src/main/java/nextstep/jwp/handler/RootPageRequestHandler.java

@@ -0,0 +1,23 @@
+package nextstep.jwp.handler;
+
+import static org.apache.catalina.servlet.response.HttpStatus.OK;
+
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+import org.apache.catalina.servlet.response.StatusLine;
+
+public class RootPageRequestHandler implements RequestHandler {
+
+    @Override
+    public boolean canHandle(HttpRequest request) {
+        return request.startLine().uri().path().equals("/");
+    }
+
+    @Override
+    public void handle(HttpRequest request, HttpResponse response) {
+        String responseBody = "Hello world!";
+        response.setStatusLine(new StatusLine(OK));
+        response.addHeader("Content-Type", "text/html;charset=utf-8");
+        response.setMessageBody(responseBody);
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/SignUpRequestHandler.java

@@ -0,0 +1,29 @@
+package nextstep.jwp.handler;
+
+import static org.apache.catalina.servlet.response.HttpStatus.FOUND;
+
+import java.util.Map;
+import nextstep.jwp.service.AuthService;
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.response.HttpResponse;
+import org.apache.catalina.servlet.response.StatusLine;
+import org.apache.catalina.servlet.util.RequestParamUtil;
+
+public class SignUpRequestHandler implements RequestHandler {
+
+    private final AuthService authService = new AuthService();
+
+    @Override
+    public boolean canHandle(HttpRequest request) {
+        return request.startLine().uri().path().equals("/register")
+                && request.startLine().method().equals("POST");
+    }
+
+    @Override
+    public void handle(HttpRequest request, HttpResponse response) {
+        Map<String, String> formData = RequestParamUtil.parse(request.body());
+        authService.signUp(formData.get("account"), formData.get("email"), formData.get("password"));
+        response.setStatusLine(new StatusLine(FOUND));
+        response.addHeader("Location", "/index.html");
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/StaticResourceRequestHandler.java

@@ -0,0 +1,41 @@
+package nextstep.jwp.handler;
+
+import static org.apache.catalina.servlet.response.HttpStatus.OK;
+
+import nextstep.jwp.util.ResourceFileUtil;
+import org.apache.catalina.servlet.request.HttpRequest;
+import org.apache.catalina.servlet.request.URI;
+import org.apache.catalina.servlet.response.HttpResponse;
+import org.apache.catalina.servlet.response.StatusLine;
+
+public class StaticResourceRequestHandler implements RequestHandler {
+
+    @Override
+    public boolean canHandle(HttpRequest request) {
+        return true;
+    }
+
+    @Override
+    public void handle(HttpRequest request, HttpResponse response) {
+        URI uri = request.startLine().uri();
+        String responseBody = ResourceFileUtil.readAll("static" + path(uri));
+        response.setStatusLine(new StatusLine(OK));
+        response.addHeader("Content-Type", contentType(uri) + "charset=utf-8");
+        response.setMessageBody(responseBody);
+    }
+
+    private String path(URI uri) {
+        if (uri.path().contains(".")) {
+            return uri.path();
+        } else {
+            return uri.path() + ".html";
+        }
+    }
+
+    private String contentType(URI uri) {
+        if (uri.path().endsWith(".css")) {
+            return "text/css;";
+        }
+        return "text/html;";
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/mappaing/HandlerMapping.java

@@ -0,0 +1,24 @@
+package nextstep.jwp.handler.mappaing;
+
+import java.util.List;
+import javax.annotation.Nullable;
+import nextstep.jwp.handler.RequestHandler;
+import org.apache.catalina.servlet.request.HttpRequest;
+
+public class HandlerMapping {
+
+    private final List<RequestHandler> handler;
+
+    public HandlerMapping(List<RequestHandler> handler) {
+        this.handler = handler;
+    }
+
+    public @Nullable RequestHandler getHandler(HttpRequest request) {
+        for (RequestHandler requestHandler : handler) {
+            if (requestHandler.canHandle(request)) {
+                return requestHandler;
+            }
+        }
+        return null;
+    }
+}

tomcat/src/main/java/nextstep/jwp/service/AuthService.java

@@ -0,0 +1,31 @@
+package nextstep.jwp.service;
+
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.exception.UnAuthenticatedException;
+import nextstep.jwp.model.User;
+
+public class AuthService {
+
+    public User login(String account, String password) {
+        validateNonNull(account, password);
+        User user = InMemoryUserRepository.findByAccount(account)
+                .orElseThrow(UnAuthenticatedException::new);
+        if (!user.checkPassword(password)) {
+            throw new UnAuthenticatedException();
+        }
+        return user;
+    }
+
+    private void validateNonNull(Object... objects) {
+        for (Object object : objects) {
+            if (object == null) {
+                throw new UnAuthenticatedException();
+            }
+        }
+    }
+
+    public void signUp(String account, String email, String password) {
+        validateNonNull(account, email, password);
+        InMemoryUserRepository.save(new User(account, password, email));
+    }
+}