[App] 회원가입 페이지/기능 구현

src/main/java/app/db/UserRepository.java

@@ -0,0 +1,11 @@
+package app.db;
+
+import app.model.User;
+import database.ConnectionManager;
+import database.CrudRepository;
+
+public class UserRepository extends CrudRepository<User> {
+    public UserRepository(ConnectionManager connectionManager) {
+        super(connectionManager, User.class);
+    }
+}

src/main/java/app/handler/RegisterWithPost.java

@@ -1,7 +1,8 @@
 package app.handler;
 
-import app.db.Database;
+import app.db.UserRepository;
 import app.model.User;
+import config.VariableConfig;
 import exception.ErrorCode;
 import exception.ServiceException;
 import http.HttpMethod;
@@ -14,19 +15,58 @@
 import web.response.RedirectResponse;
 
 public class RegisterWithPost extends SingleArgHandler<QueryParameters> {
+    private static final String EMAIL = "email";
+    private static final String NICKNAME = "nickname";
+    private static final String PASSWORD = "password";
+
     private static final Logger log = LoggerFactory.getLogger(RegisterWithPost.class);
 
-    public RegisterWithPost() {
+    private final UserRepository userRepository;
+
+    public RegisterWithPost(UserRepository userRepository) {
         super(HttpMethod.POST, "/user/create");
+        this.userRepository = userRepository;
     }
 
     @Override
     public HandlerResponse handle(QueryParameters params) {
-        String email = params.getQueryValue("email").orElseThrow(()-> new ServiceException(ErrorCode.MISSING_REGISTER_TOKEN, "email required"));
-        String nickname = params.getQueryValue("nickname").orElseThrow(()-> new ServiceException(ErrorCode.MISSING_REGISTER_TOKEN, "nickname required"));
-        String password = params.getQueryValue("password").orElseThrow(()-> new ServiceException(ErrorCode.MISSING_REGISTER_TOKEN, "password required"));
-        Database.addUser(new User(password, nickname, email, UserRole.MEMBER.toString()));
-        log.info("Registered - password:{}, nickname:{}, email:{}", password, nickname, email);
+        String email = getRequired(params, EMAIL);
+        String nickname = getRequired(params, NICKNAME);
+        String password = getRequired(params, PASSWORD);
+
+        validate(email, nickname, password);
+
+        User saved = userRepository.save(
+                new User(password, nickname, email, UserRole.MEMBER.toString()));
+
+        log.info("Registered id:{}, email:{}, nickname:{}, password:{}",
+                saved.getId(), email, nickname, password);
         return RedirectResponse.to("/login");
     }
+
+    private void validate(String email, String nickname, String password) {
+        validateDuplicate(email, nickname);
+        validateLength(email, VariableConfig.EMAIL_MIN, VariableConfig.EMAIL_MAX, ErrorCode.EMAIL_LENGTH_INVALID);
+        validateLength(nickname, VariableConfig.NICKNAME_MIN, VariableConfig.NICKNAME_MAX, ErrorCode.NICKNAME_LENGTH_INVALID);
+        validateLength(password, VariableConfig.PASSWORD_MIN, VariableConfig.PASSWORD_MAX, ErrorCode.PASSWORD_LENGTH_INVALID);
+    }
+
+    private String getRequired(QueryParameters params, String key) {
+        return params.getQueryValue(key)
+                .orElseThrow(() -> new ServiceException(ErrorCode.MISSING_REGISTER_TOKEN, key + " required"));
+    }
+
+    private void validateLength(String value, int min, int max, ErrorCode code) {
+        int len = value.length();
+        if (len < min || len > max)
+            throw new ServiceException(code);
+    }
+
+    private void validateDuplicate(String email, String nickname) {
+        if (!userRepository.findByColumn(EMAIL, email).isEmpty())
+            throw new ServiceException(ErrorCode.EMAIL_ALREADY_EXISTS);
+
+        if (!userRepository.findByColumn(NICKNAME, nickname).isEmpty())
+            throw new ServiceException(ErrorCode.NICKNAME_ALREADY_EXISTS);
+    }
 }

src/main/java/app/model/User.java

@@ -14,6 +14,9 @@ public User(String password, String nickname, String email, String userRole) {
         this.userRole = userRole;
     }
 
+    public User() {
+    }
+
     public Long getId() {
         return id;
     }

src/main/java/config/AppConfig.java

@@ -1,5 +1,6 @@
 package config;
 
+import app.db.UserRepository;
 import app.handler.*;
 import database.ConnectionManager;
 import database.H2DbManager;
@@ -120,8 +121,7 @@ public RegisterWithGet registerWithGet() {
     public RegisterWithPost registerWithPost() {
         return getOrCreate(
                 "registerWithPost",
-                RegisterWithPost::new
-        );
+                () -> new RegisterWithPost(userRepository()));
     }
 
     public LoginWithPost loginWithPost() {
@@ -233,8 +233,8 @@ public QueryParamsResolver queryParamsResolver() {
     }
 
     public MultipartFormResolver multipartFormResolver(){
-        return getOrCreate("multipartFormResolver", () ->
-                new MultipartFormResolver(multipartFormParser()));
+        return getOrCreate("multipartFormResolver",
+                () -> new MultipartFormResolver(multipartFormParser()));
     }
 
     public MultipartFormParser multipartFormParser(){
@@ -250,10 +250,7 @@ public ExceptionHandlerMapping exceptionHandlerMapping() {
                         List.of(
                                 serviceExceptionHandler(),
                                 errorExceptionHandler(),
-                                unhandledErrorHandler()
-                        )
-                )
-        );
+                                unhandledErrorHandler())));
     }
 
     public ServiceExceptionHandler serviceExceptionHandler() {
@@ -325,8 +322,13 @@ public H2DbManager h2DbManager(){
     }
 
     public DdlGenerator ddlGenerator(){
-        return getOrCreate(DdlGenerator.class.getSimpleName(), () ->
-                new DdlGenerator(connectionManager()));
+        return getOrCreate(DdlGenerator.class.getSimpleName(),
+                () -> new DdlGenerator(connectionManager()));
+    }
+
+    public UserRepository userRepository(){
+        return getOrCreate(UserRepository.class.getSimpleName(),
+                ()-> new UserRepository(connectionManager()));
     }
 }
 

src/main/java/config/DdlGenerator.java

@@ -57,7 +57,7 @@ private String buildDdlForEntity(Class<?> entityClass, String tableName) {
                 continue;
             }
 
-            String columnName = field.getName();
+            String columnName = toColumnName(field.getName());
             Class<?> fieldType = field.getType();
 
             if (!firstColumn) {
@@ -108,4 +108,9 @@ private String toTableName(Class<?> clazz) {
         }
         return name;
     }
+
+    private String toColumnName(String str){
+        String snake = str.replaceAll("(?<!^)([A-Z])", "_$1");
+        return snake.toLowerCase();
+    }
 }

src/main/java/config/VariableConfig.java

@@ -12,4 +12,11 @@ public class VariableConfig {
 
     public static final long IDLE_MS = 30*60*100;
     public static final long ABSOLUTE_MS = 180*60*100;
+
+    public static final int EMAIL_MAX = 50;
+    public static final int EMAIL_MIN = 4;
+    public static final int NICKNAME_MAX = 12;
+    public static final int NICKNAME_MIN = 4;
+    public static final int PASSWORD_MAX = 16;
+    public static final int PASSWORD_MIN = 4;
 }

src/main/java/database/CrudRepository.java

@@ -43,10 +43,10 @@ public T save(T entity) {
                 if (Modifier.isStatic(field.getModifiers())) {
                     continue;
                 }
-                if ("id".equals(field.getName())) {
+                if ("id".equals(toColumnName(field.getName()))) {
                     continue;
                 }
-                sqlBuilder.append(field.getName()).append(", ");
+                sqlBuilder.append(toColumnName(field.getName())).append(", ");
                 placeholder.append("?, ");
                 insertFields.add(field);
             }
@@ -128,7 +128,7 @@ public List<T> findAll() {
     }
 
     public List<T> findByColumn(String columnName, Object value) {
-        String sql = "SELECT * FROM " + tableName + " WHERE " + columnName + " = ?";
+        String sql = "SELECT * FROM " + tableName + " WHERE " + toColumnName(columnName) + " = ?";
 
         try (Connection conn = connectionManager.getConnection();
              PreparedStatement pstmt = conn.prepareStatement(sql)) {
@@ -145,7 +145,7 @@ public List<T> findByColumn(String columnName, Object value) {
             }
 
         } catch (SQLException e) {
-            throw new ErrorException("엔티티 조회 중 오류 (column=" + columnName + ", value=" + value + ")", e);
+            throw new ErrorException("엔티티 조회 중 오류 (column=" + toColumnName(columnName) + ", value=" + value + ")", e);
         }
     }
 
@@ -167,10 +167,10 @@ public void update(T entity) {
             if (Modifier.isStatic(field.getModifiers())) {
                 continue;
             }
-            if ("id".equals(field.getName())) {
+            if ("id".equals(toColumnName(field.getName()))) {
                 continue;
             }
-            sql.append(field.getName()).append(" = ?, ");
+            sql.append(toColumnName(field.getName())).append(" = ?, ");
             updateFields.add(field);
         }
 
@@ -264,7 +264,7 @@ private T mapRow(ResultSet resultSet) {
                     continue;
                 }
 
-                String columnName = field.getName();
+                String columnName = toColumnName(field.getName());
                 field.setAccessible(true);
 
                 Class<?> fieldType = field.getType();
@@ -311,4 +311,9 @@ private String toTableName(Class<?> clazz) {
         }
         return name;
     }
+
+    private String toColumnName(String str){
+        String snake = str.replaceAll("(?<!^)([A-Z])", "_$1");
+        return snake.toLowerCase();
+    }
 }

src/main/java/exception/ErrorCode.java

@@ -9,6 +9,13 @@ public enum ErrorCode {
             HttpStatus.BAD_REQUEST, "400_MISSING_REGISTER_TOKEN", "회원가입에 필요한 토큰이 누락되었습니다."),
     LOGIN_FAILED(
             HttpStatus.BAD_REQUEST, "400_LOGIN_FAILED", "아이디 혹은 비밀번호가 잘못되었습니다."),
+    EMAIL_LENGTH_INVALID(HttpStatus.BAD_REQUEST, "400_EMAIL_LENGTH_INVALID", "이메일은 4 ~ 50글자 사이여야합니다."),
+    NICKNAME_LENGTH_INVALID(HttpStatus.BAD_REQUEST, "400_NICKNAME_LENGTH_INVALID", "닉네임은 4 ~ 12글자 사이여야합니다."),
+    PASSWORD_LENGTH_INVALID(HttpStatus.BAD_REQUEST, "400_PASSWORD_LENGTH_INVALID", "비밀번호는 4 ~ 16글자 사이여야합니다."),
+
+
+    EMAIL_ALREADY_EXISTS(HttpStatus.CONFLICT, "409_EMAIL_ALREADY_EXISTS", "이미 가입된 Email입니다."),
+    NICKNAME_ALREADY_EXISTS(HttpStatus.CONFLICT, "409_NICKNAME_ALREADY_EXISTS", "이미 사용중인 닉네임입니다."),
 
     /* Internal Error */
     INTERNAL_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "500_INTERNAL", "서버 내부 오류가 발생했습니다."),

src/main/java/exception/handler/ErrorExceptionHandler.java

@@ -24,11 +24,11 @@ public boolean support(Throwable e) {
     @Override
     public void handle(Throwable t, Socket connection) {
         ErrorException error = (ErrorException) t;
-        logger.debug(error.getThrowable().toString());
+        logger.debug("{} - {}", error.getMessage(), error.getThrowable().toString());
         ErrorCode errorCode = error.getErrorCode();
         HttpStatus status = errorCode.getStatus();
 
-        String body = toJson(errorCode.getCode(), error.getMessage());
+        String body = toJson(errorCode.getCode(), errorCode.getMessage());
         byte[] bodyBytes = body.getBytes(StandardCharsets.UTF_8);
 
         StringBuilder sb = new StringBuilder();