Merge pull request #16 from boostcampwm-2022/feat/#15-K

Feat/#15-K: 워크스페이스 생성, 참여 API 및 서버 utils 약간

Author: se030

package-lock.json

@@ -1,37 +1,38 @@
 import express, { Request, Response, NextFunction } from "express";
+import asyncWrapper from "@utils/async-wrapper";
 import * as authService from "./service";
+import { OK } from "@constants/http-status";
 
 const router = express.Router();
 
 router.post(
   "/login",
-  async (req: Request, res: Response, next: NextFunction) => {
-    try {
-      const { code } = req.body;
-
-      const { loginToken, refreshToken } = await authService.login(code);
-
-      const cookieOptions = {
-        httpOnly: true,
-        sameSite: "lax",
-        maxAge: 1000 * 60 * 60 * 24,
-        signed: true,
-      };
-      res.cookie("accessToken", loginToken, cookieOptions);
-      res.cookie("refreshToken", refreshToken, cookieOptions);
-
-      res.status(200).send();
-    } catch (e) {
-      next(e);
-    }
-  }
+  asyncWrapper(async (req: Request, res: Response, next: NextFunction) => {
+    const { code } = req.body;
+
+    const { loginToken, refreshToken } = await authService.login(code);
+
+    const cookieOptions = {
+      httpOnly: true,
+      sameSite: "lax",
+      maxAge: 1000 * 60 * 60 * 24,
+      signed: true,
+    };
+    res.cookie("accessToken", loginToken, cookieOptions);
+    res.cookie("refreshToken", refreshToken, cookieOptions);
+
+    res.status(OK).send();
+  })
 );
 
-router.delete("/logout", (req: Request, res: Response) => {
-  authService.logout(req.signedCookies.accessToken);
+router.delete(
+  "/logout",
+  asyncWrapper(async (req: Request, res: Response) => {
+    await authService.logout(req.signedCookies.accessToken);
 
-  res.clearCookie("accessToken");
-  res.status(200).send();
-});
+    res.clearCookie("accessToken");
+    res.status(OK).send();
+  })
+);
 
 export default router;

server/apis/auth/controller.ts

@@ -2,6 +2,7 @@ import axios from "axios";
 import env from "@config";
 import userModel from "@apis/user/model";
 import * as jwt from "@utils/jwt";
+import AuthorizationError from "@errors/authorization-error";
 
 interface TokenResponse {
   access_token: string;
@@ -31,7 +32,7 @@ const getAccessToken = async (code: string) => {
   );
 
   if (accessTokenResponse.error) {
-    throw new Error("access token 생성 요청 실패");
+    throw new AuthorizationError("access token 생성 요청 실패");
   }
 
   return accessTokenResponse;
@@ -45,7 +46,7 @@ const getGithubUser = async (accessToken: string, tokenType: string) => {
   });
 
   if (user.error) {
-    throw new Error("OAuth 유저 정보 요청 실패");
+    throw new AuthorizationError("OAuth 유저 정보 요청 실패");
   }
 
   return user;
@@ -64,7 +65,7 @@ export const login = async (code: string) => {
   const isSignedUp = userModel.exists({ id });
 
   if (!isSignedUp) {
-    userModel.create({
+    await userModel.create({
       id,
       name,
       avatarUrl,

server/apis/auth/service.ts

@@ -0,0 +1,32 @@
+import express, { Request, Response, NextFunction } from "express";
+import asyncWrapper from "@utils/async-wrapper";
+import jwtAuthenticator from "@middlewares/jwt-authenticator";
+import * as workspaceService from "./service";
+import { OK } from "@constants/http-status";
+
+const router = express.Router();
+
+router.post(
+  "/",
+  asyncWrapper(async (req: Request, res: Response, next: NextFunction) => {
+    const { name } = req.body;
+
+    const workspace = await workspaceService.create(name);
+
+    res.status(OK).send({ ...workspace });
+  })
+);
+
+router.post(
+  "/join",
+  jwtAuthenticator,
+  asyncWrapper(async (req: Request, res: Response, next: NextFunction) => {
+    const { code } = req.body;
+
+    const joinedWorkspace = await workspaceService.join(req.user.id, code);
+
+    res.status(OK).send(joinedWorkspace);
+  })
+);
+
+export default router;

server/apis/workspace/controller.ts

@@ -1,18 +1,27 @@
 import { Schema } from "mongoose";
 import mongoose from "@db";
+import autoIncrement from "mongoose-auto-increment";
 
 interface Workspace {
   id: number;
   name: string;
+  code: string;
   users: number[];
   moms: number[];
 }
 
 const workspaceSchema = new Schema<Workspace>({
   id: { type: Number, required: true },
   name: { type: String, required: true },
-  users: Array<Number>,
-  moms: Array<Number>,
+  code: { type: String, required: true },
+  users: { type: [Number], default: [] },
+  moms: { type: [Number], default: [] },
+});
+workspaceSchema.plugin(autoIncrement.plugin, {
+  model: "workspace",
+  field: "id",
+  startAt: 1,
+  increment: 1,
 });
 
 const workspaceModel = mongoose.model("Workspace", workspaceSchema);

server/apis/workspace/index.ts

@@ -0,0 +1,30 @@
+import { v4 as uuidv4 } from "uuid";
+import workspaceModel from "./model";
+import userModel from "@apis/user/model";
+import AuthorizationError from "@errors/authorization-error";
+import InvalidJoinError from "@errors/invalid-join-error";
+
+export const create = async (name: string) => {
+  const code = uuidv4();
+
+  const workspace = await workspaceModel.create({ name, code });
+
+  return { name: workspace.name, code: workspace.code };
+};
+
+export const join = async (userId: number, code: string) => {
+  if (!userId) throw new AuthorizationError("유저 인증 실패");
+
+  if (!code) throw new InvalidJoinError("참여코드를 입력하세요 ^^");
+
+  const workspace = await workspaceModel.findOne({ code });
+
+  if (!workspace) throw new InvalidJoinError("잘못된 참여코드에요 ^^");
+
+  const { id, name } = workspace;
+
+  await workspaceModel.updateOne({ id }, { $push: { users: userId } });
+  await userModel.updateOne({ id: userId }, { $push: { workspaces: id } });
+
+  return { id, name, code };
+};

server/apis/workspace/model.ts

@@ -0,0 +1,6 @@
+export const OK = 200;
+
+export const BAD_REQUEST = 400;
+export const UNAUTHORIZED = 401;
+
+export const INTERNAL_SERVER_ERROR = 500;

server/apis/workspace/service.ts

@@ -1,4 +1,5 @@
 import mongoose from "mongoose";
+import autoIncrement from "mongoose-auto-increment";
 import env from "../config";
 
 const options = {
@@ -8,4 +9,6 @@ const options = {
 const DATABASE_URL = `mongodb://${env.DATABASE_USER}:${env.DATABASE_PASSWORD}@${env.DATABASE_HOST}:${env.DATABASE_PORT}/${env.DATABASE_NAME}`;
 mongoose.connect(DATABASE_URL, options);
 
+autoIncrement.initialize(mongoose.connection);
+
 export default mongoose;