feat: API to sync in_discord role with discord members and add joined_discord date

controllers/discordactions.js

@@ -11,7 +11,8 @@ const discordRolesModel = require("../models/discordactions");
  * @param res {Object} - Express response object
  */
 
-const DISCORD_BASE_URL = config.get("services.discordBot.baseUrl");
+const DISCORD_BASE_URL = "";
+// config.get("services.discordBot.baseUrl");
 
 const createGroupRole = async (req, res) => {
   try {

controllers/users.js

@@ -5,13 +5,13 @@ 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 jwt = require("jsonwebtoken");
 
 const verifyUser = async (req, res) => {
   const userId = req.userData.id;
@@ -462,6 +462,38 @@ const filterUsers = async (req, res) => {
   }
 };
 
+/*
+ * R
+ *
+ *
+ */
+const DISCORD_BASE_URL = "https://553e-49-36-233-201.ngrok.io";
+// config.get("services.discordBot.baseUrl");
+
+const syncInDiscordRole = async (req, res) => {
+  try {
+    const authToken = jwt.sign({}, config.get("botToken.botPrivateKey"), {
+      algorithm: "RS256",
+    });
+
+    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");
+  }
+};
+
 module.exports = {
   verifyUser,
   generateChaincode,
@@ -481,4 +513,5 @@ module.exports = {
   addDefaultArchivedRole,
   getUserSkills,
   filterUsers,
+  syncInDiscordRole,
 };

models/users.js

@@ -421,6 +421,22 @@ const getUsersBasedOnFilter = async (query) => {
   return [];
 };
 
+/**
+ * Fetch all users
+ *
+ * @return @return {Promise<users>}
+ */
+
+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;
+  }
+};
+
 module.exports = {
   addOrUpdate,
   fetchPaginatedUsers,
@@ -436,4 +452,5 @@ module.exports = {
   getRdsUserInfoByGitHubUsername,
   fetchUsers,
   getUsersBasedOnFilter,
+  getAllUsers,
 };

routes/users.js

@@ -21,6 +21,7 @@ router.get("/:userId/intro", authenticate, authorizeRoles([SUPERUSER]), users.ge
 router.put("/self/intro", authenticate, userValidator.validateJoinData, users.addUserIntro);
 router.get("/:id/skills", users.getUserSkills);
 router.get("/:id/badges", getUserBadges);
+router.post("/", authenticate, users.syncInDiscordRole);
 
 // upload.single('profile') -> multer inmemory storage of file for type multipart/form-data
 router.post("/picture", authenticate, upload.single("profile"), users.postUserPicture);

test/unit/utils/users.test.js

@@ -1,6 +1,7 @@
 const chai = require("chai");
 const { expect } = chai;
 
+const sinon = require("sinon");
 const usersUtils = require("../../../utils/users");
 const cleanDb = require("../../utils/cleanDb");
 const addUser = require("../../utils/addUser");
@@ -65,4 +66,60 @@ describe("users", function () {
       expect(participantUserId).to.include(userId);
     });
   });
+
+  describe("mapDiscordMembersDataAndSyncRole", function () {
+    it("should update roles and joined_discord fields for users with matching Discord IDs", function () {
+      const allUsers = [
+        {
+          data: () => ({ roles: { archived: false }, discordId: "123" }),
+          ref: { update: sinon.spy() },
+        },
+      ];
+      const discordMembers = [
+        {
+          user: { id: "123" },
+          joined_at: "2022-05-01T00:00:00.000Z",
+        },
+      ];
+
+      usersUtils.mapDiscordMembersDataAndSyncRole(allUsers, discordMembers);
+
+      sinon.assert.calledWithExactly(allUsers[0].ref.update, {
+        roles: { archived: false, inDiscord: true },
+        joined_discord: discordMembers[0].joined_at,
+      });
+    });
+
+    it("should update roles field to inDiscord: false for users with no matching Discord ID", function () {
+      const allUsers = [
+        {
+          data: () => ({ roles: { archived: false }, discordId: "123" }),
+          ref: { update: sinon.spy() },
+        },
+      ];
+      const discordMembers = [];
+
+      usersUtils.mapDiscordMembersDataAndSyncRole(allUsers, discordMembers);
+
+      sinon.assert.calledWithExactly(allUsers[0].ref.update, {
+        roles: { archived: false, inDiscord: false },
+      });
+    });
+
+    it("should update roles field to inDiscord: false for users with archived roles", function () {
+      const allUsers = [
+        {
+          data: () => ({ roles: { archived: true }, discordId: "123" }),
+          ref: { update: () => sinon.spy() },
+        },
+      ];
+      const discordMembers = [];
+
+      usersUtils.mapDiscordMembersDataAndSyncRole(allUsers, discordMembers);
+
+      expect(allUsers[0].ref.update).to.have.been.calledWith({
+        roles: { archived: true, inDiscord: false },
+      });
+    });
+  });
 });

utils/users.js

@@ -142,6 +142,35 @@ function getUsernamesFromPRs(allPRs) {
 
   return usernames;
 }
+/**
+ *
+ * @param allUsers{Array} - list of total users from firebase
+ * @param discordMembers{Array} - list of all members in discord server
+ *
+ */
+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_discord: 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 +181,5 @@ module.exports = {
   getLowestLevelSkill,
   getPaginationLink,
   getUsernamesFromPRs,
+  mapDiscordMembersDataAndSyncRole,
 };