Merge branch 'dev' into #315-bump-mongoose-version-to-6.11.3

sparcs-kaist · Aug 5, 2023 · 48253fb · 48253fb
2 parents 4ba65e5 + ca31167
commit 48253fb
Show file tree

Hide file tree

Showing 17 changed files with 4,218 additions and 3,785 deletions.
diff --git a/loadenv.js b/loadenv.js
@@ -35,4 +35,5 @@ module.exports = {
     JSON.parse(process.env.GOOGLE_APPLICATION_CREDENTIALS),
   testAccounts:
     process.env.TEST_ACCOUNTS && JSON.parse(process.env.TEST_ACCOUNTS),
+  slackWebhookUrl: { report: process.env.SLACK_REPORT_WEBHOOK_URL || "" },
 };
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -10,7 +10,7 @@
     "ajv": "^8.12.0",
     "ajv-errors": "^3.0.0",
     "ajv-formats": "^2.1.1",
-    "aws-sdk": "^2.1182.0",
+    "aws-sdk": "^2.1386.0",
     "axios": "^0.27.2",
     "ci": "^2.2.0",
     "connect-mongo": "^4.6.0",

diff --git a/src/modules/slackNotification.js b/src/modules/slackNotification.js
@@ -0,0 +1,28 @@
+const { slackWebhookUrl: slackUrl } = require("../../loadenv");
+const axios = require("axios");
+const logger = require("../modules/logger");
+
+module.exports.notifyToReportChannel = (reportUser, report) => {
+  if (!slackUrl.report) return;
+
+  const data = {
+    text: `${reportUser}님으로부터 신고가 접수되었습니다.
+
+    신고자 ID: ${report.creatorId}
+    신고 ID: ${report.reportedId}
+    방 ID: ${report.roomId ?? ""}
+    사유: ${report.type}
+    기타: ${report.etcDetail}
+    `,
+  };
+  const config = { "Content-Type": "application/json" };
+
+  axios
+    .post(slackUrl.report, data, config)
+    .then((res) => {
+      logger.info("Slack webhook sent successfully");
+    })
+    .catch((err) => {
+      logger.error("Fail to send slack webhook", err);
+    });
+};
diff --git a/src/modules/socket.js b/src/modules/socket.js
@@ -4,7 +4,7 @@ const sessionMiddleware = require("../middlewares/session");
 const logger = require("./logger");
 const { getLoginInfo } = require("./auths/login");
 const { roomModel, userModel, chatModel } = require("./stores/mongo");
-const { getS3Url } = require("./stores/awsS3");
+const { getS3Url } = require("./stores/aws");
 const { getTokensOfUsers, sendMessageByTokens } = require("./fcm");
 
 const { frontUrl } = require("../../loadenv");
@@ -53,7 +53,7 @@ const transformChatsForRoom = async (chats) => {
       inOutNames: chat.inOutNames,
     });
   }
-  
+
   return chatsToSend;
 };
 

diff --git a/src/modules/stores/awsS3.js → src/modules/stores/aws.js b/src/modules/stores/awsS3.js → src/modules/stores/aws.js
@@ -1,12 +1,15 @@
 const { aws: awsEnv } = require("../../../loadenv");
 
+const logger = require("../logger");
 // Load the AWS-SDK and s3
 const AWS = require("aws-sdk");
 AWS.config.update({
   region: "ap-northeast-2",
   signatureVersion: "v4",
 });
+
 const s3 = new AWS.S3({ apiVersion: "2006-03-01" });
+const ses = new AWS.SES({ apiVersion: "2010-12-01" });
 
 // function to list Object
 module.exports.getList = (directoryPath, cb) => {
@@ -80,3 +83,37 @@ module.exports.foundObject = (filePath, cb) => {
 module.exports.getS3Url = (filePath) => {
   return `${awsEnv.s3Url}${filePath}`;
 };
+
+module.exports.sendReportEmail = (reportedEmail, report, html) => {
+  const reportTypeMap = {
+    "no-settlement": "정산을 하지 않음",
+    "no-show": "택시에 동승하지 않음",
+    "etc-reason": "기타 사유",
+  };
+
+  const params = {
+    Destination: {
+      ToAddresses: [reportedEmail],
+    },
+    Message: {
+      Body: {
+        Html: {
+          Data: html,
+        },
+      },
+      Subject: {
+        Charset: "UTF-8",
+        Data: `[SPARCS TAXI] 신고가 접수되었습니다 (사유: ${reportTypeMap[report.type]})`,
+      },
+    },
+    Source: "[email protected]",
+  };
+
+  ses.sendEmail(params, (err, data) => {
+    if (err) {
+      logger.error("Fail to send email", err);
+    } else {
+      logger.info("Email sent successfully");
+    }
+  });
+};
diff --git a/src/modules/stores/mongo.js b/src/modules/stores/mongo.js
@@ -140,6 +140,7 @@ const reportSchema = Schema({
   },
   etcDetail: { type: String, default: "" }, // 기타 세부 사유
   time: { type: Date, required: true },
+  roomId: { type: Schema.Types.ObjectId, ref: "Room" }, // 신고한 방 id
 });
 
 const adminIPWhitelistSchema = Schema({

diff --git a/src/routes/docs/reportsSchema.js b/src/routes/docs/reportsSchema.js
@@ -1,7 +1,7 @@
 const reportsSchema = {
   createHandler: {
     type: "object",
-    required: ["reportedId", "type", "time"],
+    required: ["reportedId", "type", "time", "roomId"],
     properties: {
       reportedId: {
         type: "string",
@@ -14,11 +14,16 @@ const reportsSchema = {
       etcDetail: {
         type: "string",
         maxLength: 30,
+        default: "",
       },
       time: {
         type: "string",
         format: "date-time",
       },
+      roomId: {
+        type: "string",
+        pattern: "^[a-fA-F\\d]{24}$",
+      },
     },
     errorMessage: "validation: bad request",
   },

diff --git a/src/services/auth.replace.js b/src/services/auth.replace.js
@@ -11,54 +11,7 @@ const logger = require("../modules/logger");
 const jwt = require("../modules/auths/jwt");
 
 const { registerDeviceTokenHandler } = require("../services/auth");
-
-const loginHtmlBuilder = (redirectPath) => `
-<!DOCTYPE html>
-<html lang="ko">
-    <head>
-        <title>replace Login</title>
-        <meta charset="utf-8" />
-        <meta name="viewport" content="width=device-width,initial-scale=1.0,minium-scale=1.0,maxinum-scale=1.0,user-scalable=no" />
-        <script src="https://code.jquery.com/jquery-latest.min.js"></script>
-        <script>
-            $(document).ready(function(){
-                const post = (path, params) => {
-                    var form = document.createElement("form");
-                    form.setAttribute("method", "post");
-                    form.setAttribute("action", path);
-                    for(var key in params) {
-                        var hiddenField = document.createElement("input");
-                        hiddenField.setAttribute("type", "hidden");
-                        hiddenField.setAttribute("name", key);
-                        hiddenField.setAttribute("value", params[key]);
-                        form.appendChild(hiddenField);
-                    }
-                    document.body.appendChild(form);
-                    form.submit();
-                }
-                const submitHandler = () => {
-                    const value = document.getElementById("input-id").value;
-                    if(value) post('/auth/login/replace', {
-                      id: value,
-                      redirect: "${encodeURIComponent(redirectPath)}",
-                    });
-                }
-                const enterHandler = (e) => {
-                    if (e.keyCode === 13) submitHandler();
-                }
-                $('#btn').click(submitHandler);
-                $('#input-id').on("keyup", enterHandler);
-                $('#input-id').focus();
-            });
-        </script>
-    </head>
-    <body>
-        <div>아이디 입력</div>
-        <input id="input-id">
-        <div id="btn">로그인</div>
-    </body>
-</html>
-`;
+const loginReplacePage = require("../views/loginReplacePage");
 
 const makeInfo = (id) => {
   const info = {
@@ -144,7 +97,7 @@ const sparcsssoHandler = (req, res) => {
   const isApp = !!req.query.isApp;
 
   req.session.isApp = isApp;
-  res.end(loginHtmlBuilder(redirectPath));
+  res.end(loginReplacePage(redirectPath));
 };
 
 const logoutHandler = async (req, res) => {

diff --git a/src/services/chats.js b/src/services/chats.js
@@ -1,6 +1,6 @@
 const { chatModel, userModel, roomModel } = require("../modules/stores/mongo");
 const { chatPopulateOption } = require("../modules/populates/chats");
-const awsS3 = require("../modules/stores/awsS3");
+const aws = require("../modules/stores/aws");
 const { transformChatsForRoom, emitChatEvent } = require("../modules/socket");
 
 const chatCount = 60;
@@ -188,7 +188,7 @@ const uploadChatImgGetPUrlHandler = async (req, res) => {
     });
     const chat = await chatDocument.save();
     const key = `chat-img/${chat._id}`;
-    awsS3.getUploadPUrlPost(key, type, (err, data) => {
+    aws.getUploadPUrlPost(key, type, (err, data) => {
       if (err) {
         return res
           .status(500)
@@ -234,7 +234,7 @@ const uploadChatImgDoneHandler = async (req, res) => {
       });
     }
     const key = `chat-img/${chat._id}`;
-    awsS3.foundObject(key, async (err, data) => {
+    aws.foundObject(key, async (err, data) => {
       if (err) {
         return res
           .status(500)

diff --git a/src/services/reports.js b/src/services/reports.js
@@ -1,10 +1,17 @@
-const { userModel, reportModel } = require("../modules/stores/mongo");
+const {
+  userModel,
+  reportModel,
+  roomModel,
+} = require("../modules/stores/mongo");
 const { reportPopulateOption } = require("../modules/populates/reports");
+const { sendReportEmail } = require("../modules/stores/aws");
 const logger = require("../modules/logger");
+const emailPage = require("../views/emailNoSettlementPage");
+const { notifyToReportChannel } = require("../modules/slackNotification");
 
 const createHandler = async (req, res) => {
   try {
-    const { reportedId, type, etcDetail, time } = req.body;
+    const { reportedId, type, etcDetail, time, roomId } = req.body;
     const user = await userModel.findOne({ id: req.userId });
     const creatorId = user._id;
 
@@ -15,15 +22,39 @@ const createHandler = async (req, res) => {
       });
     }
 
+    const room = await roomModel.findById(roomId);
+    if (!room) {
+      return res.status(400).json({
+        error: "User/report: no corresponding room",
+      });
+    }
+
     const report = new reportModel({
       creatorId,
       reportedId,
       type,
       etcDetail,
       time,
+      roomId
     });
 
     await report.save();
+
+    notifyToReportChannel(user.nickname, report);
+
+    if (report.type === "no-settlement") {
+      const emailRoomName = room ? room.name : "";
+      const emailRoomId = room ? room._id : "";
+      const emailHtml = emailPage(
+        reported.name,
+        reported.nickname,
+        emailRoomName,
+        user.nickname,
+        emailRoomId
+      );
+      sendReportEmail(reported.email, report, emailHtml);
+    }
+
     res.status(200).send("User/report : report successful");
   } catch (err) {
     logger.error(err);

diff --git a/src/services/users.js b/src/services/users.js
@@ -1,6 +1,6 @@
 const { userModel } = require("../modules/stores/mongo");
 const logger = require("../modules/logger");
-const awsS3 = require("../modules/stores/awsS3");
+const aws = require("../modules/stores/aws");
 
 const agreeOnTermsOfServiceHandler = async (req, res) => {
   try {
@@ -83,7 +83,7 @@ const editProfileImgGetPUrlHandler = async (req, res) => {
         .send("User/editProfileImg/getPUrl : internal server error");
     }
     const key = `profile-img/${user._id}`;
-    awsS3.getUploadPUrlPost(key, type, (err, data) => {
+    aws.getUploadPUrlPost(key, type, (err, data) => {
       if (err) {
         return res
           .status(500)
@@ -110,7 +110,7 @@ const editProfileImgDoneHandler = async (req, res) => {
         .send("User/editProfileImg/done : internal server error");
     }
     const key = `profile-img/${user._id}`;
-    awsS3.foundObject(key, async (err) => {
+    aws.foundObject(key, async (err) => {
       if (err) {
         logger.error(err);
         return res

diff --git a/src/views/emailNoSettlementPage.js b/src/views/emailNoSettlementPage.js
@@ -0,0 +1,31 @@
+const { frontUrl } = require("../../loadenv");
+const emailPage = require("./emailPage");
+
+module.exports = (name, nickname, roomName, payer, roomId) =>
+  emailPage(
+    "미정산 내역 관련 안내",
+    `<b><font color="#6E3678">${name} (${nickname})</font></b> 님께<br /><br />
+    안녕하세요, ${name} (${nickname}) 님.<br />
+    KAIST 학부 총학생회 산하 특별기구 SPARCS의 Taxi 팀입니다.<br /><br />
+    최근 참여하신 방에서 정산이 이루어지지 않았다는 사용자의 문의가 접수되어 메일을 보내드립니다.<br /><br />
+    <div style="background: #EEEEEE; border-radius: 20px; margin: padding: 16px 24px; padding: 16px 24px; ">
+      <div style="margin: 0; padding: 0;">
+        <span style="width: 64px; display: inline-block;"><b>방 제목</b></span>
+        ${roomName}
+      </div>
+      <div style="margin: 0; padding: 0;">
+        <span style="width: 64px; display: inline-block;"><b>결제자</b></span>
+        ${payer}
+      </div>
+      <div style="margin: 0; padding: 0;">
+        <span style="width: 64px; display: inline-block;"><b>링크</b></span>
+        <a href="${frontUrl}/myroom/${roomId}" target="_blank">${frontUrl}/myroom/${roomId}</a>
+      </div>
+    </div><br />
+    위 방에서 채팅을 확인하실 수 있으며, <b>결제하신 분께 해당 금액을 정산</b>해주시기를 부탁드립니다.<br />
+    <b>미정산이 반복되는 경우 Taxi 서비스 이용이 제한</b>될 수 있음을 알려드립니다.<br />
+    문의가 필요하신 경우, <a href="${frontUrl}/mypage" target="_blank">택시 서비스 내부</a>의 &quot;채널톡 문의하기&quot; 혹은 메일 회신 주시면 됩니다.<br /><br />
+    감사합니다.<br />
+    SPARCS Taxi팀 드림.
+    `
+  );
diff --git a/src/views/emailPage.js b/src/views/emailPage.js
@@ -0,0 +1,31 @@
+const { getS3Url } = require("../modules/stores/aws");
+
+module.exports = (
+  title,
+  content
+) => `<div style="font-family: system-ui; position: relative; background: #ffffff; margin: 0; padding: 72px;">
+  <div style="width: max(min(100%, 800px), 320px); margin: 0 auto; padding 0;">
+    <div style="height: 102px; background: #6E3678; margin: 0 0 48px; padding: 0;">
+      <img style="height: 54px; margin: 24px 32px; padding: 0;" src="${getS3Url(
+        "/assets/email-taxi-logo-white.svg"
+      )}" alt="Taxi" />
+    </div>
+    ${
+      title
+        ? `<div style="font-family: system-ui; line-height: 160%; letter-spacing: 0px; font-size: 32px; font-weight: bold; color: #000000; margin: 0 0 32px; padding: 0;">${title}</div>`
+        : ""
+    }
+    <div style="font-family: system-ui; line-height: 160%; letter-spacing: 0px; font-size: 16px; font-weight: regular; color: #000000; margin: 0; padding: 0;">${content}</div>
+    <div style="border-top: 2px solid #999999; text-align: center; margin: 120px 0 0; padding: 24px 0 0;">
+      <img style="height: 54px; margin: 0; padding: 0;" src="${getS3Url(
+        "/assets/email-sparcs-logo-black.svg"
+      )}" alt="SPARCS" />
+      <a href="https://www.sparcs.org" target="_blank">
+        <div style="margin: 0; padding: 0;">
+          <u style="font-family: system-ui; font-size: 12px; font-weight: lighter; color: #999999;">www.sparcs.org</u>
+        </div>
+      </a>
+      <div style="font-family: system-ui; font-size: 12px; font-weight: lighter; color: #999999; margin: 0; padding: 0;">[email protected]</div>
+    </div>
+  </div>
+</div>`;