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

controllers/users.js

@@ -495,6 +495,11 @@ const filterUsers = async (req, res) => {
   }
 };
 
+const usersForInDiscord = async (req, res) => {
+  const data = await userQuery.getDiscordUsers();
+  return res.json(data);
+};
+
 module.exports = {
   verifyUser,
   generateChaincode,
@@ -514,4 +519,5 @@ module.exports = {
   addDefaultArchivedRole,
   getUserSkills,
   filterUsers,
+  usersForInDiscord,
 };

models/users.js

@@ -450,6 +450,30 @@ const getUsersBasedOnFilter = async (query) => {
   return [];
 };
 
+/**
+ * Fetch all users
+ *
+ * @return {Promise<users>}
+ */
+
+const getDiscordUsers = async () => {
+  try {
+    const usersRef = await userModel.where("roles.archived", "==", false).get();
+    const users = [];
+    usersRef.forEach((user) => {
+      if (user.data()?.discordId && user.data().roles?.in_discord === false)
+        users.push({
+          id: user.id,
+          ...user.data(),
+        });
+    });
+    return users;
+  } catch (err) {
+    logger.error(`Error while fetching all users: ${err}`);
+    throw err;
+  }
+};
+
 module.exports = {
   addOrUpdate,
   fetchPaginatedUsers,
@@ -465,4 +489,5 @@ module.exports = {
   getRdsUserInfoByGitHubUsername,
   fetchUsers,
   getUsersBasedOnFilter,
+  getDiscordUsers,
 };

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.patch("/", authenticate, authorizeRoles([SUPERUSER]), users.usersForInDiscord);
 
 // upload.single('profile') -> multer inmemory storage of file for type multipart/form-data
 router.post("/picture", authenticate, upload.single("profile"), users.postUserPicture);

test/fixtures/user/inDiscord.js

@@ -0,0 +1,51 @@
+module.exports = () => {
+  return [
+    {
+      discordId: "1234567890987543",
+      first_name: "jhon",
+      last_name: "doe",
+      username: "jhon-doe",
+      github_id: "jhon-doe",
+      github_display_name: "jhon-doe",
+      incompleteUserDetails: false,
+      roles: {
+        archived: false,
+        in_discord: true,
+      },
+      tokens: {
+        githubAccessToken: "weuytrertyuiiuyrtyui4567yyyuyghy",
+      },
+    },
+    {
+      discordId: "8494597689576953",
+      first_name: "test",
+      last_name: "user",
+      username: "test-user",
+      github_id: "test-user",
+      github_display_name: "test-user",
+      incompleteUserDetails: false,
+      roles: {
+        archived: false,
+        in_discord: false,
+      },
+      tokens: {
+        githubAccessToken: "weuytrertyuiiuyrtyui4567yyyuyghy",
+      },
+    },
+    {
+      first_name: "test",
+      last_name: "user",
+      username: "test-user",
+      github_id: "test-user",
+      github_display_name: "test-user",
+      incompleteUserDetails: false,
+      roles: {
+        archived: false,
+        in_discord: false,
+      },
+      tokens: {
+        githubAccessToken: "weuytrertyuiiuyrtyui4567yyyuyghy",
+      },
+    },
+  ];
+};

test/integration/users.test.js

@@ -13,6 +13,7 @@ const userData = require("../fixtures/user/user")();
 const profileDiffData = require("../fixtures/profileDiffs/profileDiffs")();
 const superUser = userData[4];
 const searchParamValues = require("../fixtures/user/search")();
+const inDiscordUsers = require("../fixtures/user/inDiscord")();
 
 const config = require("config");
 const joinData = require("../fixtures/user/join");
@@ -1071,4 +1072,27 @@ describe("Users", function () {
         });
     });
   });
+
+  describe("PATCH /users", function () {
+    beforeEach(async function () {
+      await addUser(inDiscordUsers[0]);
+      await addUser(inDiscordUsers[1]);
+      await addUser(inDiscordUsers[2]);
+    });
+    it("returns users with discord id and in_discord false", function (done) {
+      chai
+        .request(app)
+        .patch("/users")
+        .set("Cookie", `${cookieName}=${superUserAuthToken}`)
+        .end((err, res) => {
+          if (err) {
+            return done(err);
+          }
+          expect(res).to.have.status(200);
+          expect(res.body).to.have.length(1);
+          expect(res.body[0].username).equal("test-user");
+          return done();
+        });
+    });
+  });
 });