Merge pull request #5 from TeamSparker/feature/#3

[FEAT] GET /room/code/:code 참여코드로 대기방 조회 API 구현

functions/api/routes/room/index.js

@@ -2,6 +2,7 @@ const express = require('express');
 const router = express.Router();
 const { checkUser } = require('../../../middlewares/auth');
 
+router.get('/code/:code', checkUser, require('./roomCodeGET'));
 router.post('', checkUser, require('./roomPOST'));
 
 module.exports = router;

functions/api/routes/room/roomCodeGET.js

@@ -0,0 +1,86 @@
+/**
+ *  @코드로_대기_방_정보_확인
+ *  @route GET /room/code/:code
+ *  @error
+ *      1. 참여 코드가 전달되지 않음
+ *      2. 참여코드에 일치하는 방이 없는 경우
+ *      3. 이미 시작된 습관방인 경우
+ *      4. 이미 참여중인 방인 경우
+ *      5. 한번 내보내진 사용자인 경우
+ */
+
+const functions = require('firebase-functions');
+const util = require('../../../lib/util');
+const statusCode = require('../../../constants/statusCode');
+const responseMessage = require('../../../constants/responseMessage');
+const db = require('../../../db/db');
+const { userDB, roomDB } = require('../../../db');
+
+module.exports = async (req, res) => {
+  const { code } = req.params;
+  const user = req.user;
+  const userId = user.userId;
+
+  // @error 1. 참여 코드가 전달되지 않음
+  if (!code) {
+    return res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, responseMessage.NULL_VALUE));
+  }
+
+  let client;
+
+  try {
+    client = await db.connect(req);
+
+    const room = await roomDB.getRoomByCode(client, code);
+
+    // @error 2. 참여 코드에 일치하는 방이 없음
+    if (!room) {
+      return res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, responseMessage.GET_WAITROOM_DATA_NULL));
+    }
+
+    // @error 3. 참여 코드에 해당하는 방은 이미 습관 시작한 방임
+    if (room.isStarted) {
+      return res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, responseMessage.GET_WAITROOM_DATA_STARTED));
+    }
+
+    // @error 5. 한번 내보내진 사용자인 경우
+    const isKicked = await roomDB.checkKickedByRoomIdAndUserId(client, room.roomId, userId);
+    if (isKicked) {
+      return res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, responseMessage.GET_WAITROOM_DATA_KICKED));
+    }
+
+    const creator = await userDB.getUserById(client, room.creator);
+    const entries = await roomDB.getEntriesByRoomId(client, room.roomId);
+    const imageNum = 3;
+    let profileImgs = [];
+
+    for (let i = 0; i < entries.length; i++) {
+      if (i < imageNum) {
+        let user = await userDB.getUserById(client, entries[i].userId);
+        profileImgs.push(user.profileImg);
+      }
+
+      // @error 4. 이미 해당 습관에 참여중인 사용자
+      if (userId === entries[i].userId) {
+        return res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, responseMessage.GET_WAITROOM_DATA_ALREADY));
+      }
+    }
+
+    const data = {
+      roomId: room.roomId,
+      roomName: room.roomName,
+      creatorName: creator.nickname,
+      createrImg: creator.profileImg,
+      profileImgs,
+      totalNums: entries.length,
+    };
+
+    res.status(statusCode.OK).send(util.success(statusCode.OK, responseMessage.READ_ONE_POST_SUCCESS, data));
+  } catch (error) {
+    functions.logger.error(`[ERROR] [${req.method.toUpperCase()}] ${req.originalUrl}`, `[CONTENT] ${error}`);
+    console.log(error);
+    res.status(statusCode.INTERNAL_SERVER_ERROR).send(util.fail(statusCode.INTERNAL_SERVER_ERROR, responseMessage.INTERNAL_SERVER_ERROR));
+  } finally {
+    client.release();
+  }
+};

functions/constants/responseMessage.js

@@ -22,4 +22,10 @@ module.exports = {
   // Room
   CREATE_ROOM_SUCCESS: '습관 방 생성 성공',
   CREATE_ROOM_FAIL: '습관 방 생성 실패',
+  GET_WAITROOM_DATA_SUCCESS: '대기방 정보 확인 완료',
+  GET_WAITROOM_DATA_NULL: '참여코드와 일치하는 습관 방이 존재하지 않습니다',
+  GET_WAITROOM_DATA_STARTED: '이미 습관 형성에 도전중인 방입니다',
+  GET_WAITROOM_DATA_ALREADY: '이미 사용자가 참가중인 방입니다',
+  GET_WAITROOM_DATA_FAIL: '대기방 정보 확인 실패',
+  GET_WAITROOM_DATA_KICKED: '습관 방 생성자에 의해 내보내진 방입니다',
 };

functions/db/room.js

@@ -30,4 +30,45 @@ const isCodeUnique = async (client, code) => {
   return false;
 };
 
-module.exports = { addRoom, isCodeUnique };
+const getRoomByCode = async (client, code) => {
+  const { rows } = await client.query(
+    `
+    SELECT * FROM spark.room
+    WHERE code = $1
+      AND is_deleted = FALSE
+    `,
+    [code],
+  );
+  return convertSnakeToCamel.keysToCamel(rows[0]);
+};
+
+const getEntriesByRoomId = async (client, roomId) => {
+  const { rows } = await client.query(
+    `
+    SELECT * FROM spark.entry
+    WHERE room_id = $1
+      AND is_out = FALSE
+      AND is_kicked = FALSE
+      AND is_deleted = FALSE
+      ORDER BY created_at
+    `,
+    [roomId],
+  );
+  return convertSnakeToCamel.keysToCamel(rows);
+};
+
+const checkKickedByRoomIdAndUserId = async (client, roomId, userId) => {
+  const { rows } = await client.query(
+    `
+    SELECT * FROM spark.entry
+    WHERE room_id = $1
+      AND user_id = $2
+      AND is_kicked = TRUE
+      AND is_deleted = FALSE
+    `,
+    [roomId, userId],
+  );
+  return convertSnakeToCamel.keysToCamel(rows);
+};
+
+module.exports = { addRoom, isCodeUnique, getRoomByCode, getEntriesByRoomId, checkKickedByRoomIdAndUserId };