Merge pull request #38 from topcoder-platform/issues-99

Issues-93:follow/unfollow categories, Issues-129, Issues-112

Author: jmgasper

src/constants.js

@@ -40,7 +40,8 @@ module.exports = {
     KICK: 'kick'
   },
   TOPCODER: {
-    ROLE_COPILOT: 'copilot'
+    ROLE_COPILOT: 'copilot',
+    ROLE_MANAGER: 'manager'
   },
   VANILLA: {
     CHALLENGES_FORUM: 'Challenges Forums',

src/modules/user_management/helpers.js

@@ -30,13 +30,16 @@ function processPayload (payload, topic) {
         action: constants.USER_ACTIONS.KICK
       }
     case constants.KAFKA.TOPICS.CHALLENGE_NOTIFICATION_TOPIC:
+      if (!(payload.type in actionMap)) {
+        throw new Error(`Not supported ${payload.type}. Only message types ${JSON.stringify(Object.keys(eventTypes))} are processed from '${topic}'`)
+      }
       return {
         challengeId: payload.data.challengeId,
         userId: payload.data.userId,
         action: actionMap[payload.type]
       }
     default:
-      throw new Error('Received message from unrecognized topic')
+      throw new Error(`Received message from unrecognized '${topic}'`)
   }
 }
 

src/services/vanilla.js

@@ -87,7 +87,15 @@ async function manageVanillaUser (data) {
     await vanillaClient.updateUser(vanillaUser.userID, userData)
   }
 
-  const { body: categories } = await vanillaClient.getCategoriesByParentUrlCode(challengeId)
+  let categories = []
+  const { body: nestedCategories } = await vanillaClient.getCategoriesByParentUrlCode(challengeId)
+  categories = nestedCategories
+
+  // Some group might not have nested categories
+  if (categories.length === 0) {
+    const { body: parentCategory } = await vanillaClient.getCategoryByUrlcode(challengeId)
+    categories.push(parentCategory)
+  }
 
   // Choose action to perform
   switch (action) {
@@ -100,6 +108,8 @@ async function manageVanillaUser (data) {
       for (const category of categories) {
         await vanillaClient.watchCategory(category.categoryID, vanillaUser.userID, { watched: true })
         logger.info(`The user ${vanillaUser.name} watches categoryID=${category.categoryID} associated with challenge ${challengeId}`)
+        await vanillaClient.followCategory(category.categoryID, { followed: true, userID: vanillaUser.userID })
+        logger.info(`The user ${vanillaUser.name} follows categoryID=${category.categoryID} associated with challenge ${challengeId}`)
       }
       break
     }
@@ -108,6 +118,8 @@ async function manageVanillaUser (data) {
       for (const category of categories) {
         await vanillaClient.watchCategory(category.categoryID, vanillaUser.userID, { watched: false })
         logger.info(`The user ${vanillaUser.name} stopped watching categoryID=${category.categoryID} associated with challenge ${challengeId}`)
+        await vanillaClient.followCategory(category.categoryID, { followed: false, userID: vanillaUser.userID })
+        logger.info(`The user ${vanillaUser.name} unfollows categoryID=${category.categoryID} associated with challenge ${challengeId}`)
       }
       await vanillaClient.removeUserFromGroup(group.groupID, vanillaUser.userID)
       logger.info(`The user '${vanillaUser.name}' was removed from the group '${group.name}'`)
@@ -169,7 +181,10 @@ async function createVanillaGroup (challenge) {
   }
 
   const { body: project } = await topcoderApi.getProject(challenge.projectId)
-  const copilots = _.filter(project.members, { role: constants.TOPCODER.ROLE_COPILOT })
+  const members = _.filter(project.members, member => {
+    return member.role === constants.TOPCODER.ROLE_COPILOT || member.role === constants.TOPCODER.ROLE_MANAGER
+  })
+
   const challengesForums = _.filter(template.categories, ['name', constants.VANILLA.CHALLENGES_FORUM])
   if (!challengesForums) {
     throw new Error(`The '${constants.VANILLA.CHALLENGES_FORUM}' category wasn't found in the template json file`)
@@ -253,8 +268,8 @@ async function createVanillaGroup (challenge) {
         await createDiscussions(group, challenge, groupTemplate.discussions, challengeCategory)
       }
 
-      for (const copilot of copilots) {
-        await manageVanillaUser({ challengeId: challenge.id, action: constants.USER_ACTIONS.INVITE, handle: copilot.handle })
+      for (const member of members) {
+        await manageVanillaUser({ challengeId: challenge.id, action: constants.USER_ACTIONS.INVITE, handle: member.handle })
       }
 
       challengeDetailsDiscussion.url = `${challengeCategory.url}`

src/utils/vanilla-client.util.js

@@ -24,6 +24,11 @@ function getVanillaClient () {
           throw err
         })
     },
+    followCategory: (categoryId, data) => {
+      return request.put(`${config.VANILLA.API_URL}/categories/${categoryId}/follow`)
+        .query({ access_token: config.VANILLA.ADMIN_ACCESS_TOKEN })
+        .send(data)
+    },
     updateCategory: (categoryId, data) => {
       return request.patch(`${config.VANILLA.API_URL}/categories/${categoryId}`)
         .query({ access_token: config.VANILLA.ADMIN_ACCESS_TOKEN })