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

app.js

@@ -11,6 +11,9 @@ const AppMiddlewares = require("./middlewares");
 // import routes
 const indexRouter = require("./routes/index");
 
+// processors
+require("./processors/index");
+
 const app = express();
 
 // Add Middlewares, routes

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 logger = require("../utils/logger");
 const obfuscate = require("../utils/obfuscate");
 const { getPaginationLink, getUsernamesFromPRs } = 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 Queue = require("bull");
+const { REDIS_PORT, REDIS_URI } = require("../redisCredentials");
 
 const verifyUser = async (req, res) => {
   const userId = req.userData.id;
@@ -466,6 +468,74 @@ const filterUsers = async (req, res) => {
   }
 };
 
+const DISCORD_BASE_URL = config.get("services.discordBot.baseUrl");
+
+// wroker queue created with Bull
+const syncQueue = new Queue("syncQueue", {
+  redis: {
+    port: REDIS_PORT,
+    host: REDIS_URI,
+  },
+});
+
+/*
+ * Sync user data with the data present in our discord server
+ *
+ */
+
+const syncInDiscordRole = async (req, res) => {
+  try {
+    // create a authToken to verify on discord bot
+    const authToken = jwt.sign({}, config.get("rdsServerlessBot.rdsServerLessPrivateKey"), {
+      algorithm: "RS256",
+      expiresIn: config.get("rdsServerlessBot.ttl"),
+    });
+
+    // fetch the data of member in discord server
+    const response = await fetch(`${DISCORD_BASE_URL}/discord-members`, {
+      headers: {
+        "Content-Type": "application/json",
+        Authorization: `Bearer ${authToken}`,
+      },
+    });
+    const discordMembers = await response.json();
+
+    // get the data of the users from our database
+    const allUsers = await userQuery.getAllUsers();
+
+    allUsers.forEach((doc) => {
+      const user = { id: doc.id, ...doc.data() };
+
+      if (user.roles.archived) {
+        // Update: If the user is archived change the role in_discord: false
+        user.roles = { ...user.roles, in_discord: false };
+        syncQueue.add({ user });
+
+        // If the user has verified them self and has discordId in the database
+      } else if (user.discordId) {
+        // find that users data from the discord members data we have
+        const discordUserData = discordMembers.find((item) => item.user.id === user.discordId);
+
+        // if data exists that means the user is present in our discord derver
+        if (discordUserData) {
+          // Update: the user role in_dicord: true and the joined_discord date
+          user.roles = { ...user.roles, in_discord: true };
+          user.joined_discord = discordUserData.joined_at;
+          syncQueue.add({ user });
+        } else {
+          user.roles = { ...user.roles, in_discord: false };
+          syncQueue.add({ user });
+        }
+      }
+    });
+
+    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,
@@ -485,4 +555,5 @@ module.exports = {
   addDefaultArchivedRole,
   getUserSkills,
   filterUsers,
+  syncInDiscordRole,
 };

models/users.js

@@ -450,6 +450,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,
@@ -465,4 +481,5 @@ module.exports = {
   getRdsUserInfoByGitHubUsername,
   fetchUsers,
   getUsersBasedOnFilter,
+  getAllUsers,
 };

package.json

@@ -15,6 +15,7 @@
   },
   "dependencies": {
     "axios": "^1.0.0",
+    "bull": "^4.10.4",
     "cloudinary": "^1.25.1",
     "config": "^3.3.6",
     "cookie-parser": "~1.4.5",

processors/index.js

@@ -0,0 +1,12 @@
+const Queue = require("bull");
+const path = require("path");
+const { REDIS_PORT, REDIS_URI } = require("../redisCredentials");
+
+const syncQueue = new Queue("syncQueue", {
+  redis: {
+    port: REDIS_PORT,
+    host: REDIS_URI,
+  },
+});
+
+syncQueue.process(path.join(__dirname, "syncQueue.js"));

processors/syncQueue.js

@@ -0,0 +1,8 @@
+const userQuery = require("../models/users");
+
+const syncQueueProcessor = (job, done) => {
+  userQuery.addOrUpdate(job.data.user, job.data.user.id);
+  done();
+};
+
+module.exports = syncQueueProcessor;

redisCredentials.js

@@ -0,0 +1,4 @@
+const REDIS_PORT = 6379;
+const REDIS_URI = "127.0.0.1";
+
+module.exports = { REDIS_PORT, REDIS_URI };

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);