[refactor] Change database to MongoDB

package.json

@@ -24,6 +24,8 @@
     "gravatar": "^1.8.1",
     "jsonwebtoken": "^8.5.1",
     "moment": "^2.29.1",
+    "mongoose": "^6.2.2",
+    "mongoose-validator": "^2.1.0",
     "multer": "^1.4.2",
     "multer-s3": "^2.9.0",
     "pg": "^8.7.1",
@@ -38,6 +40,7 @@
     "@types/bcryptjs": "^2.4.2",
     "@types/cors": "^2.8.12",
     "@types/express": "^4.17.11",
+    "@types/mongoose": "^5.11.97",
     "@types/mocha": "^9.0.0",
     "@types/node": "^14.18.5",
     "@types/sequelize": "^4.28.9",

src/config/index.ts

@@ -19,6 +19,8 @@ export default {
   /**
    * Your secret sauce
    */
+  mongoURI: process.env.MONGODB_URI,
+
   jwtSecret: process.env.JWT_SECRET,
   jwtAlgorithm: process.env.JWT_ALGO,
 

src/controller/auth.ts

@@ -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,

src/controller/review.ts

@@ -22,7 +22,7 @@ import reviewService from "../service/review";
 const patchReviewPreController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.patchReviewPreService(
-      Number(req.params.reviewId),
+      req.params.reviewId,
       req.user.id,
       req.body.answerOne,
       req.body.answerTwo,
@@ -78,8 +78,8 @@ const patchReviewPreController = async (req: Request, res: Response) => {
 const getQuestionController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.getQuestionService(
-      Number(req.user.id),
-      Number(req.params.reviewId)
+      req.user.id,
+      req.params.reviewId
     );
 
     if (resData === constant.NULL_VALUE) {
@@ -91,7 +91,7 @@ const getQuestionController = async (req: Request, res: Response) => {
       );
     }
 
-    if (resData === constant.WRONG_REQUEST_VALUE) {
+    if (resData === constant.DB_NOT_FOUND) {
       return response.basicResponse(
         res,
         returnCode.BAD_REQUEST,
@@ -130,7 +130,7 @@ const getQuestionController = async (req: Request, res: Response) => {
 const patchReviewPeriController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.patchReviewPeriService(
-      Number(req.params.reviewId),
+      req.params.reviewId,
       req.user.id,
       req.body.answerThree,
       req.body.reviewSt
@@ -184,8 +184,8 @@ const patchReviewPeriController = async (req: Request, res: Response) => {
 const getReviewController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.getReviewService(
-      Number(req.user.id),
-      Number(req.params.reviewId)
+      req.user.id,
+      req.params.reviewId
     );
 
     if (resData === constant.NULL_VALUE) {
@@ -236,8 +236,8 @@ const getReviewController = async (req: Request, res: Response) => {
 const getReviewPreController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.getReviewPreService(
-      Number(req.user.id),
-      Number(req.params.reviewId)
+      req.user.id,
+      req.params.reviewId
     );
 
     if (resData === constant.NULL_VALUE) {
@@ -288,8 +288,8 @@ const getReviewPreController = async (req: Request, res: Response) => {
 const getReviewPeriController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.getReviewPeriService(
-      Number(req.user.id),
-      Number(req.params.reviewId)
+      req.user.id,
+      req.params.reviewId
     );
 
     if (resData === constant.NULL_VALUE) {
@@ -340,7 +340,7 @@ const getReviewPeriController = async (req: Request, res: Response) => {
 const patchReviewController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.patchReviewService(
-      Number(req.params.reviewId),
+      req.params.reviewId,
       req.body.answerOne,
       req.body.answerTwo,
       req.body.answerThree
@@ -355,7 +355,7 @@ const patchReviewController = async (req: Request, res: Response) => {
       );
     }
 
-    if (resData === constant.WRONG_REQUEST_VALUE) {
+    if (resData === constant.DB_NOT_FOUND) {
       return response.basicResponse(
         res,
         returnCode.BAD_REQUEST,
@@ -394,8 +394,8 @@ const patchReviewController = async (req: Request, res: Response) => {
 const deleteReviewController = async (req: Request, res: Response) => {
   try {
     const resData = await reviewService.deleteReviewService(
-      Number(req.user.id),
-      Number(req.params.reviewId)
+      req.user.id,
+      req.params.reviewId
     );
 
     if (resData === constant.NULL_VALUE) {
@@ -412,7 +412,7 @@ const deleteReviewController = async (req: Request, res: Response) => {
         res,
         returnCode.BAD_REQUEST,
         false,
-        "존재하지 않는 Review입니다."
+        "존재하지 않거나 삭제된 Review입니다."
       );
     }
 

src/index.ts

@@ -1,10 +1,13 @@
 import express from "express";
 import cors from "cors";
-import { sequelize } from "./models";
 import router from "./router";
+import connectDB from "./loader/db";
 
 const app = express();
 
+// Connect Database
+connectDB();
+
 app.use(express.urlencoded());
 app.use(express.json());
 
@@ -47,26 +50,6 @@ const server = app
     ##############################################
   `
     );
-
-    // 시퀄라이즈 연결
-    sequelize
-      .authenticate()
-      .then(async () => {
-        console.log("✅ Connect PostgreSQL");
-      })
-      .catch((err) => {
-        console.log("TT : ", err);
-      });
-
-    // 시퀄라이즈 모델 DB에 싱크
-    sequelize
-      .sync({ force: false })
-      .then(() => {
-        console.log("✅ Sync Models to DB");
-      })
-      .catch((err) => {
-        console.error(err);
-      });
   })
   .on("error", (err) => {
     console.error(err);

src/interface/IBook.ts

@@ -0,0 +1,12 @@
+import mongoose from "mongoose";
+
+export interface IBook {
+  _id: mongoose.Schema.Types.ObjectId;
+  isbn: number;
+  isbn_sub: number;
+  title: string;
+  author: [string];
+  translator: [string];
+  thumbnail: string;
+  publication_dt: string;
+}

src/interface/IReview.ts

@@ -0,0 +1,16 @@
+import mongoose from "mongoose";
+
+export interface IReview {
+  _id: mongoose.Schema.Types.ObjectId;
+  user_id: mongoose.Schema.Types.ObjectId;
+  book_id: mongoose.Schema.Types.ObjectId;
+  question_list: [string];
+  answer_one: string;
+  answer_two: string;
+  answer_three: object;
+  review_st: number;
+  finish_St: boolean;
+  created_at: Date;
+  updated_at: Date;
+  is_deleted: boolean;
+}

src/interface/IUser.ts

@@ -0,0 +1,14 @@
+import mongoose from "mongoose";
+
+export interface IUser {
+  _id: mongoose.Schema.Types.ObjectId;
+  email: string;
+  password: string;
+  nickname: string;
+  img: string;
+  refresh_token: string;
+  email_code: string;
+  created_at: Date;
+  updated_at: Date;
+  is_deleted: boolean;
+}

src/library/convertSnakeToCamel.ts

@@ -0,0 +1,62 @@
+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;
+};
+
+export const toSnakeString = (e) => {
+  return e
+    .match(/([A-Z])/g)
+    .reduce((str, c) => str.replace(new RegExp(c), "_" + c.toLowerCase()), e)
+    .substring(e.slice(0, 1).match(/([A-Z])/g) ? 1 : 0);
+};
+
+export const toCamelString = (e) => {
+  return e.replace(/_([a-z])/g, (g) => g[1].toUpperCase());
+};

src/loader/db.ts

@@ -0,0 +1,30 @@
+import mongoose from "mongoose";
+import config from "../config";
+
+// models
+import User from "../models/User";
+import Book from "../models/Book";
+import Review from "../models/Review";
+
+const connectDB = async () => {
+  try {
+    await mongoose.connect(config.mongoURI, {});
+
+    await User.createCollection().then((collection) => {
+      console.log("User Collection is created!");
+    });
+    await Book.createCollection().then((collection) => {
+      console.log("Book Collection is created!");
+    });
+    await Review.createCollection().then((collection) => {
+      console.log("Review Collection is created!");
+    });
+
+    console.log("Mongoose Connected ...");
+  } catch (err) {
+    console.error(err.message);
+    process.exit(1);
+  }
+};
+
+export default connectDB;