sync API

Author: bhtibrewal

controllers/users.js

@@ -5,14 +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;
@@ -25,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",
   });
@@ -108,7 +113,6 @@ const getUsers = async (req, res) => {
  */
 
 const getUser = async (req, res) => {
-  console.log(req.params.username);
   try {
     const result = await userQuery.fetchUser({ username: req.params.username });
     const { phone, email, ...user } = result.user;
@@ -463,23 +467,49 @@ 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 syncInDiscordRole = async (req, res) => {
-//   try {
-//   } catch (error) {
-//   logger.error(`Error while fetching all users: ${error}`);
-//   return res.boom.serverUnavailable("Something went wrong please contact admin");
-// }
-// };
+    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 allUsers = await userQuery.fetchUsersWithRole(IN_DISCORD);
+    const usersInDiscord = await userQuery.fetchUsersWithRole(IN_DISCORD);
 
     return res.json({
       message: "Users found successfully!",
-      users: allUsers,
-      count: allUsers.length,
+      users: usersInDiscord,
+      count: usersInDiscord.length,
     });
   } catch (error) {
     logger.error(`Error while fetching all users: ${error}`);
@@ -507,4 +537,6 @@ module.exports = {
   getUserSkills,
   filterUsers,
   fetchInDiscordUsers,
+  syncInDiscordRole,
+  fetchVerifiedUsers,
 };

models/users.js

@@ -408,7 +408,15 @@ 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);
@@ -426,12 +434,36 @@ const fetchUsersWithRole = async (role) => {
         });
       });
     }
+
     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,
@@ -449,4 +481,6 @@ module.exports = {
   fetchUsers,
   getUsersBasedOnFilter,
   fetchUsersWithRole,
+  fetchUsersWhereFieldNotNull,
+  getAllUsers,
 };

routes/users.js

@@ -16,7 +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.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);
@@ -30,6 +32,4 @@ router.patch("/rejectDiff", authenticate, authorizeRoles([SUPERUSER]), users.rej
 router.patch("/:userId", authenticate, authorizeRoles([SUPERUSER]), users.updateUser);
 router.get("/suggestedUsers/:skillId", authenticate, authorizeRoles([SUPERUSER]), users.getSuggestedUsers);
 
-router.post("/syncInDiscord", authenticate, users.getSelfDetails);
-
 module.exports = router;

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,
 };