[refactor] change database to MongoDB

src/controller/auth.ts

@@ -70,7 +70,7 @@ const getEmailController = async (req: Request, res: Response) => {
       { isValid: true }
     );
   } catch (err) {
-    slack.slackWebhook(req, err.message);
+    // slack.slackWebhook(req, err.message);
     console.error(err.message);
     return response.basicResponse(
       res,
@@ -308,18 +308,18 @@ const postSignupController = async (req: Request, res: Response) => {
  *  @로그인_여부_검사
  *  @route GET /auth/check
  *  @access public
- *  @err 
+ *  @err
  */
-const getLoginFlagController = async(req: Request, res: Response) => {
+const getLoginFlagController = async (req: Request, res: Response) => {
   try {
     const resData = await authService.getLoginFlagService(
       req.user ? true : false
-    )
+    );
     return response.dataResponse(
-      res, 
+      res,
       returnCode.OK,
-      "로그인 여부 확인 성공.", 
-      true, 
+      "로그인 여부 확인 성공.",
+      true,
       resData
     );
   } catch (err) {
@@ -332,7 +332,7 @@ const getLoginFlagController = async(req: Request, res: Response) => {
       "서버 오류"
     );
   }
-}
+};
 
 const authController = {
   getEmailController,

src/controller/book.ts

@@ -22,7 +22,7 @@ const postBookController = async (req: Request, res: Response) => {
   try {
     const resData = await bookService.postBookService(
       req.user ? true : false,
-      req.user ? Number(req.user.id) : constant.ANONYMOUS_USER,
+      req.user ? req.user.id : constant.ANONYMOUS_USER,
       req.body.isbn,
       req.body.thumbnail,
       req.body.title,
@@ -70,7 +70,7 @@ const postBookController = async (req: Request, res: Response) => {
       resData
     );
   } catch (err) {
-    slack.slackWebhook(req, err.message);
+    // slack.slackWebhook(req, err.message);
     console.error(err.message);
     return response.basicResponse(
       res,

src/library/convertSnakeToCamel.ts

@@ -0,0 +1,51 @@
+import _ from "lodash";
+
+export const toCamel = (s) => {
+  return s.replace(/([-_][a-z])/gi, ($1) => {
+    return $1.toUpperCase().replace("-", "").replace("_", "");
+  });
+};
+
+export const isArray = (a) => {
+  return Array.isArray(a);
+};
+
+export const isObject = (o) => {
+  return o === Object(o) && !isArray(o) && typeof o !== "function";
+};
+
+export const keysToCamel = (o) => {
+  if (isObject(o)) {
+    const n = {};
+
+    Object.keys(o).forEach((k) => {
+      n[toCamel(k)] = o[k];
+    });
+
+    return n;
+  } else if (isArray(o)) {
+    return o.map((i) => {
+      return keysToCamel(i);
+    });
+  }
+
+  return o;
+};
+
+export const keysToSnake = (o) => {
+  if (isObject(o)) {
+    const n = {};
+
+    Object.keys(o).forEach((k) => {
+      n[_.snakeCase(k)] = o[k];
+    });
+
+    return n;
+  } else if (isArray(o)) {
+    return o.map((i) => {
+      return _.snakeCase(i);
+    });
+  }
+
+  return o;
+};

src/router/book.ts

@@ -10,8 +10,8 @@ const router = express.Router();
 
 router.post("/", isLogin, bookController.postBookController);
 router.get("/", auth, bookController.getBookController);
-router.get("/pre", auth, bookController.getBookPreController);
-router.get("/peri", auth, bookController.getBookPeriController);
-router.get("/post", auth, bookController.getBookPostController);
+// router.get("/pre", auth, bookController.getBookPreController);
+// router.get("/peri", auth, bookController.getBookPeriController);
+// router.get("/post", auth, bookController.getBookPostController);
 
 module.exports = router;

src/router/index.ts

@@ -19,9 +19,9 @@ router.get("", async (req: Request, res: Response) => {
   }
 });
 
-// router.use("/auth", require("./auth"));
+router.use("/auth", require("./auth"));
 router.use("/book", require("./book"));
-// router.use("/user", require("./user"));
+router.use("/user", require("./user"));
 router.use("/review", require("./review"));
 
 export default router;

src/service/auth.ts

@@ -1,5 +1,5 @@
 import index from "../config";
-import mongoose from "mongoose"
+import mongoose from "mongoose";
 
 // library
 import jwt from "jsonwebtoken";
@@ -10,6 +10,7 @@ import {
   checkNicknameValid,
   checkPasswordValid,
 } from "../library/checkValidation";
+import { keysToSnake } from "../library/convertSnakeToCamel";
 
 // model
 import User from "../models/User";
@@ -20,35 +21,33 @@ import User from "../models/User";
  *  @access public
  *  @err 1. 필요한 값이 없을 때
  */
-// const getEmailService = async (email?: string) => {
-//   // 잘못된 요청값이 들어왔을 때 (query !== email)
-//   if (email === undefined) {
-//     return constant.WRONG_REQUEST_VALUE;
-//   }
-
-//   // 필요한 값이 존재하지 않는 경우
-//   if (!email) {
-//     return constant.NULL_VALUE;
-//   }
-
-//   // email 형식이 잘못되었을 때
-//   if (!isEmail(email)) {
-//     return constant.WRONG_EMAIL_CONVENTION;
-//   }
-
-//   // email이 이미 존재할 때
-//   const emailExist = await User.findAll({
-//     where: {
-//       email,
-//       isDeleted: false,
-//     },
-//   });
-//   if (emailExist.length > 0) {
-//     return constant.EMAIL_ALREADY_EXIST;
-//   }
-
-//   return constant.SUCCESS;
-// };
+const getEmailService = async (email?: string) => {
+  // 잘못된 요청값이 들어왔을 때 (query !== email)
+  if (email === undefined) {
+    return constant.WRONG_REQUEST_VALUE;
+  }
+
+  // 필요한 값이 존재하지 않는 경우
+  if (!email) {
+    return constant.NULL_VALUE;
+  }
+
+  // email 형식이 잘못되었을 때
+  if (!isEmail(email)) {
+    return constant.WRONG_EMAIL_CONVENTION;
+  }
+
+  // email이 이미 존재할 때
+  // TODO: DB에서 isDeleted string으로 되있는 것 변경
+  const emailExist = await User.exists(
+    keysToSnake({ email, isDeleted: false })
+  );
+  if (emailExist) {
+    return constant.EMAIL_ALREADY_EXIST;
+  }
+
+  return constant.SUCCESS;
+};
 
 /**
  *  @닉네임_유효성_검사
@@ -73,12 +72,10 @@ const getNicknameService = async (nickname?: string) => {
   }
 
   // nickname이 이미 존재할 때
-  const nicknameExist = await User.find(
-    {
-      nickname,
-      isDeleted: false
-    },
-  )
+  const nicknameExist = await User.find({
+    nickname,
+    isDeleted: false,
+  });
 
   if (nicknameExist.length > 0) {
     return constant.NICKNAME_ALREADY_EXIST;
@@ -102,12 +99,10 @@ const postLoginService = async (email: string, password: string) => {
   }
 
   // 존재하지 않는 이메일
-  const user = await User.findOne(
-    { 
-      email, 
-      isDeleted: false 
-    }
-  );
+  const user = await User.findOne({
+    email,
+    isDeleted: false,
+  });
   if (!user) {
     return constant.EMAIL_NOT_FOUND;
   }
@@ -141,73 +136,67 @@ const postLoginService = async (email: string, password: string) => {
  *       5. 이메일이 이미 존재할 때
  *       6. 닉네임이 이미 존재할 때
  */
-// const postSignupService = async (
-//   email: string,
-//   nickname: string,
-//   password: string
-// ) => {
-//   // 필요한 값이 존재하지 않는 경우
-//   if (!email || !nickname || !password) {
-//     return constant.NULL_VALUE;
-//   }
-
-//   // email 형식이 잘못되었을 때
-//   if (!isEmail(email)) {
-//     return constant.WRONG_EMAIL_CONVENTION;
-//   }
-
-//   // nickname 형식이 잘못되었을 때
-//   if (!checkNicknameValid(nickname)) {
-//     return constant.WRONG_NICKNAME_CONVENTION;
-//   }
-
-//   // password 형식이 잘못되었을 때
-//   if (!checkPasswordValid(password)) {
-//     return constant.WRONG_PASSWORD_CONVENTION;
-//   }
-
-//   // email이 이미 존재할 때
-//   const emailExist = await User.findAll({
-//     where: {
-//       email,
-//       isDeleted: false,
-//     },
-//   });
-//   if (emailExist.length > 0) {
-//     return constant.EMAIL_ALREADY_EXIST;
-//   }
-
-//   // nickname이 이미 존재할 때
-//   const nicknameExist = await User.findAll({
-//     where: {
-//       nickname,
-//       isDeleted: false,
-//     },
-//   });
-//   if (nicknameExist.length > 0) {
-//     return constant.NICKNAME_ALREADY_EXIST;
-//   }
-
-//   // 새로운 유저 생성 & 토큰 발급
-//   const salt = await bcrypt.genSalt(10);
-//   const hashedPassword = await bcrypt.hash(password, salt);
-//   const user = await User.create({
-//     email,
-//     password: hashedPassword,
-//     nickname,
-//   });
-
-//   const payload = {
-//     user: {
-//       id: user.id,
-//     },
-//   };
-
-//   const token = jwt.sign(payload, index.jwtSecret, {
-//     expiresIn: "14d",
-//   });
-//   return token;
-// };
+const postSignupService = async (
+  email: string,
+  nickname: string,
+  password: string
+) => {
+  // 필요한 값이 존재하지 않는 경우
+  if (!email || !nickname || !password) {
+    return constant.NULL_VALUE;
+  }
+
+  // email 형식이 잘못되었을 때
+  if (!isEmail(email)) {
+    return constant.WRONG_EMAIL_CONVENTION;
+  }
+
+  // nickname 형식이 잘못되었을 때
+  if (!checkNicknameValid(nickname)) {
+    return constant.WRONG_NICKNAME_CONVENTION;
+  }
+
+  // password 형식이 잘못되었을 때
+  if (!checkPasswordValid(password)) {
+    return constant.WRONG_PASSWORD_CONVENTION;
+  }
+
+  // email이 이미 존재할 때
+  const emailExist = await User.exists(
+    keysToSnake({ email, isDeleted: false })
+  );
+  if (emailExist) {
+    return constant.EMAIL_ALREADY_EXIST;
+  }
+
+  // nickname이 이미 존재할 때
+  const nicknameExist = await User.exists(
+    keysToSnake({ nickname, isDeleted: false })
+  );
+  if (nicknameExist) {
+    return constant.NICKNAME_ALREADY_EXIST;
+  }
+
+  // 새로운 유저 생성 & 토큰 발급
+  const salt = await bcrypt.genSalt(10);
+  const hashedPassword = await bcrypt.hash(password, salt);
+  const user = await User.create({
+    email,
+    password: hashedPassword,
+    nickname,
+  });
+
+  const payload = {
+    user: {
+      id: user.id,
+    },
+  };
+
+  const token = jwt.sign(payload, index.jwtSecret, {
+    expiresIn: "14d",
+  });
+  return token;
+};
 
 /**
  *  @로그인_여부_검사
@@ -220,10 +209,10 @@ const getLoginFlagService = async (isLogin: Boolean) => {
 };
 
 const authService = {
-  // getEmailService,
+  getEmailService,
   getNicknameService,
   postLoginService,
-  // postSignupService,
+  postSignupService,
   getLoginFlagService,
 };