Feature: inDiscord

constants/roles.js

@@ -4,6 +4,7 @@ const ROLES = {
   APPOWNER: "app_owner",
   MEMBER: "member",
   ARCHIVED: "archived",
+  IN_DISCORD: "inDiscord",
 };
 
 module.exports = ROLES;

controllers/users.js

@@ -5,13 +5,15 @@ const logsQuery = require("../models/logs");
 const imageService = require("../services/imageService");
 const { profileDiffStatus } = require("../constants/profileDiff");
 const { logType } = require("../constants/logs");
-const { fetch } = require("../utils/fetch");
+
 const logger = require("../utils/logger");
 const obfuscate = require("../utils/obfuscate");
-const { getPaginationLink, getUsernamesFromPRs } = require("../utils/users");
+const { getPaginationLink, getUsernamesFromPRs, mapDiscordMembersDataAndSyncRole } = require("../utils/users");
 const { getQualifiers } = require("../utils/helper");
 const { SOMETHING_WENT_WRONG, INTERNAL_SERVER_ERROR } = require("../constants/errorMessages");
 const { getFilteredPRsOrIssues } = require("../utils/pullRequests");
+const { IN_DISCORD } = require("../constants/roles");
+const jwt = require("jsonwebtoken");
 
 const verifyUser = async (req, res) => {
   const userId = req.userData.id;
@@ -24,7 +26,11 @@ const verifyUser = async (req, res) => {
     logger.error(`Error while verifying user: ${error}`);
     return res.boom.serverUnavailable(SOMETHING_WENT_WRONG);
   }
-  fetch(process.env.IDENTITY_SERVICE_URL, "POST", null, { userId }, { "Content-Type": "application/json" });
+  fetch(process.env.IDENTITY_SERVICE_URL, {
+    method: "POST",
+    body: { userId },
+    headers: { "Content-Type": "application/json" },
+  });
   return res.json({
     message: "Your request has been queued successfully",
   });
@@ -461,6 +467,55 @@ const filterUsers = async (req, res) => {
     return res.boom.serverUnavailable("Something went wrong please contact admin");
   }
 };
+const DISCORD_BASE_URL = "https://89d4-49-36-233-201.ngrok.io";
+const syncInDiscordRole = async (req, res) => {
+  try {
+    const authToken = jwt.sign({}, config.get("botToken.botPrivateKey"), {
+      algorithm: "RS256",
+    });
+    // console.log(authToken);
+    const response = await fetch(`${DISCORD_BASE_URL}/discord-members`, {
+      headers: {
+        "Content-Type": "application/json",
+        Authorization: `Bearer ${authToken}`,
+      },
+    });
+    const discordMembers = await response.json();
+
+    const allUsers = await userQuery.getAllUsers();
+    mapDiscordMembersDataAndSyncRole(allUsers, discordMembers);
+
+    return res.json({ message: "Synced with discord members " });
+  } catch (error) {
+    logger.error(`Error while fetching all users: ${error}`);
+    return res.boom.serverUnavailable("Something went wrong please contact admin");
+  }
+};
+
+const fetchVerifiedUsers = async (req, res) => {
+  try {
+    const verifiedUsers = await userQuery.fetchUsersWhereFieldNotNull("discordId");
+    return res.json(verifiedUsers);
+  } catch (error) {
+    logger.error(`Error while fetching all users: ${error}`);
+    return res.boom.serverUnavailable("Something went wrong please contact admin");
+  }
+};
+
+const fetchInDiscordUsers = async (req, res) => {
+  try {
+    const usersInDiscord = await userQuery.fetchUsersWithRole(IN_DISCORD);
+
+    return res.json({
+      message: "Users found successfully!",
+      users: usersInDiscord,
+      count: usersInDiscord.length,
+    });
+  } catch (error) {
+    logger.error(`Error while fetching all users: ${error}`);
+    return res.boom.serverUnavailable("Something went wrong please contact admin");
+  }
+};
 
 module.exports = {
   verifyUser,
@@ -481,4 +536,7 @@ module.exports = {
   addDefaultArchivedRole,
   getUserSkills,
   filterUsers,
+  fetchInDiscordUsers,
+  syncInDiscordRole,
+  fetchVerifiedUsers,
 };

models/users.js

@@ -408,6 +408,62 @@ const getUsersBasedOnFilter = async (query) => {
   const userDocs = (await firestore.getAll(...userRefs)).map((doc) => ({ id: doc.id, ...doc.data() }));
   return userDocs;
 };
+const getAllUsers = async () => {
+  try {
+    const usersRef = await userModel.get();
+    return usersRef;
+  } catch (err) {
+    logger.error("Error retrieving users data with roles of inDiscord", err);
+    throw err;
+  }
+};
+const fetchUsersWithRole = async (role) => {
+  try {
+    // console.log(role);
+    const snapshot = await userModel.where(`roles.${role}`, "==", true).get();
+    const onlyMembers = [];
+
+    if (!snapshot.empty) {
+      snapshot.forEach((doc) => {
+        onlyMembers.push({
+          id: doc.id,
+          ...doc.data(),
+          phone: undefined,
+          email: undefined,
+          tokens: undefined,
+        });
+      });
+    }
+
+    return onlyMembers;
+  } catch (err) {
+    logger.error("Error retrieving users data with roles of inDiscord", err);
+    throw err;
+  }
+};
+const fetchUsersWhereFieldNotNull = async (field) => {
+  try {
+    const snapshot = await userModel.where(field, "!=", null).get();
+    const users = [];
+
+    if (!snapshot.empty) {
+      snapshot.forEach((doc) => {
+        users.push({
+          id: doc.id,
+          ...doc.data(),
+          phone: undefined,
+          email: undefined,
+          tokens: undefined,
+        });
+      });
+    }
+
+    return users;
+  } catch (err) {
+    logger.error("Error retrieving users data with roles of inDiscord", err);
+    throw err;
+  }
+};
 
 module.exports = {
   addOrUpdate,
@@ -424,4 +480,7 @@ module.exports = {
   getRdsUserInfoByGitHubUsername,
   fetchUsers,
   getUsersBasedOnFilter,
+  fetchUsersWithRole,
+  fetchUsersWhereFieldNotNull,
+  getAllUsers,
 };

routes/users.js

@@ -16,6 +16,9 @@ router.get("/self", authenticate, users.getSelfDetails);
 router.get("/isUsernameAvailable/:username", authenticate, users.getUsernameAvailabilty);
 router.get("/chaincode", authenticate, users.generateChaincode);
 router.get("/search", userValidator.validateUserQueryParams, users.filterUsers);
+router.get("/inDiscord", authenticate, users.fetchInDiscordUsers);
+router.post("/syncInDiscord", authenticate, users.syncInDiscordRole);
+router.get("/verified", authenticate, users.fetchVerifiedUsers);
 router.get("/:username", users.getUser);
 router.get("/:userId/intro", authenticate, authorizeRoles([SUPERUSER]), users.getUserIntro);
 router.put("/self/intro", authenticate, userValidator.validateJoinData, users.addUserIntro);

utils/users.js

@@ -142,6 +142,29 @@ function getUsernamesFromPRs(allPRs) {
 
   return usernames;
 }
+function mapDiscordMembersDataAndSyncRole(allUsers, discordMembers) {
+  try {
+    allUsers.forEach((doc) => {
+      const user = doc.data();
+
+      if (user.roles.archived) {
+        const roles = user.roles ? { ...user.roles, inDiscord: false } : { inDiscord: false };
+        doc.ref.update({ roles });
+      } else if (user.discordId) {
+        const discordUserData = discordMembers.find((item) => item.user.id === user.discordId);
+        if (discordUserData) {
+          const roles = user.roles ? { ...user.roles, inDiscord: true } : { inDiscord: true };
+          doc.ref.update({ roles, joined_RDS: discordUserData.joined_at });
+        } else {
+          const roles = user.roles ? { ...user.roles, inDiscord: false } : { inDiscord: false };
+          doc.ref.update({ roles });
+        }
+      }
+    });
+  } catch (err) {
+    logger.error(err);
+  }
+}
 
 module.exports = {
   addUserToDBForTest,
@@ -152,4 +175,5 @@ module.exports = {
   getLowestLevelSkill,
   getPaginationLink,
   getUsernamesFromPRs,
+  mapDiscordMembersDataAndSyncRole,
 };