Add: slack notification about detecting result

src/lottery/modules/slackNotification.js

@@ -1,15 +1,57 @@
 const { sendTextToReportChannel } = require("../../modules/slackNotification");
 
+const generateContent = (name, userIds, roomIds = []) => {
+  if (userIds.length === 0) return "";
+
+  const strUserIds = userIds.join(", ");
+  const strRoomIds =
+    roomIds.length > 0 ? ` (관련된 방: ${roomIds.join(", ")})` : "";
+  return `\n${name}: ${strUserIds}${strRoomIds}`;
+};
+
 const notifyAbuseDetectionResultToReportChannel = (
-  abusingUsers,
-  reports,
+  abusingUserIds,
   reportedUserIds,
   rooms,
   multiplePartUserIds,
   lessChatRooms,
   lessChatUserIds
 ) => {
-  // TODO
+  const title = `어제의 활동을 기준으로, ${abusingUserIds.length}명의 어뷰징 의심 사용자를 감지하였습니다.`;
+
+  if (abusingUserIds.length === 0) {
+    sendTextToReportChannel(title);
+    return;
+  }
+
+  const strAbusingUsers = generateContent(
+    "전체 어뷰징 의심 사용자",
+    abusingUserIds
+  );
+  const strReportedUsers = generateContent(
+    '"기타 사유"로 신고받은 사용자',
+    reportedUserIds
+  );
+  const strMultiplePartUsers = generateContent(
+    "하루에 탑승 기록이 많은 사용자",
+    multiplePartUserIds,
+    rooms.reduce((array, { roomIds }) => array.concat(roomIds), [])
+  );
+  const strLessChatUsers = generateContent(
+    "채팅 개수가 5개 미만인 방에 속한 사용자",
+    lessChatUserIds,
+    lessChatRooms.reduce(
+      (array, room) => (room ? array.concat([room.roomId]) : array),
+      []
+    )
+  );
+  const contents = strAbusingUsers.concat(
+    strReportedUsers,
+    strMultiplePartUsers,
+    strLessChatUsers
+  );
+
+  sendTextToReportChannel(`${title}\n${contents}`);
 };
 
 module.exports = {

src/lottery/schedules/detectAbusingUsers.js

@@ -183,7 +183,7 @@ module.exports = async () => {
     const candidateUserIds = candidateUsers.map((user) => user.userId);
 
     // 기준 1 ~ 기준 3에 각각 해당되는 사용자 목록
-    const { reports, reportedUserIds } = await detectReportedUsers(
+    const { reportedUserIds } = await detectReportedUsers(
       period,
       candidateUserIds
     );
@@ -197,25 +197,25 @@ module.exports = async () => {
     );
 
     // 기준 1 ~ 기준 3 중 하나라도 해당되는 사용자 목록
-    const abusingUsers = removeObjectIdDuplicates(
+    const abusingUserIds = removeObjectIdDuplicates(
       reportedUserIds.concat(multiplePartUserIds, lessChatUserIds)
     );
 
-    logger.info("Abusing user detection successfully finished");
     logger.info(
-      `Total ${abusingUsers.length} users detected! Refer to Slack for more information`
+      `Total ${abusingUserIds.length} users detected! Refer to Slack for more information`
     );
 
     // Slack으로 알림 전송
     notifyAbuseDetectionResultToReportChannel(
-      abusingUsers,
-      reports,
+      abusingUserIds,
       reportedUserIds,
       rooms,
       multiplePartUserIds,
       lessChatRooms,
       lessChatUserIds
     );
+
+    logger.info("Abusing user detection successfully finished");
   } catch (err) {
     logger.error(err);
     logger.error("Abusing user detection failed");