add support for groups

Author: ThomasKranitsas

ReadMe.md

@@ -50,7 +50,7 @@ The following parameters can be set in config files or in env variables:
 - V4_TECHNOLOGIES_API_URL: v4 technologies api url, default value is 'http://localhost:4000/v4/technologies'
 - V4_PLATFORMS_API_URL: v4 platforms api url, default value is 'http://localhost:4000/v4/platforms'
 - V5_CHALLENGE_MIGRATION_API_URL: v5 challenge migration API URL, default value is https://api.topcoder-dev.com/v5/challenge-migration
-
+- V5_GROUPS_API_URL: v5 groups API URL, default value is https://api.topcoder-dev.com/v5/groups
 There is a `/health` endpoint that checks for the health of the app. This sets up an expressjs server and listens on the environment variable `PORT`. It's not part of the configuration file and needs to be passed as an environment variable
 
 Configuration for the tests is at `config/test.js`, only add such new configurations different from `config/default.js`

config/default.js

@@ -39,6 +39,8 @@ module.exports = {
   V5_PROJECTS_API_URL: process.env.V5_PROJECTS_API_URL || 'https://api.topcoder-dev.com/v5/projects',
   V5_CHALLENGE_MIGRATION_API_URL: process.env.V5_CHALLENGE_MIGRATION_API_URL || 'https://api.topcoder-dev.com/v5/challenge-migration',
 
+  V5_GROUPS_API_URL: process.env.V5_GROUPS_API_URL || 'https://api.topcoder-dev.com/v5/groups',
+
   // PHASE IDs
   REGISTRATION_PHASE_ID: process.env.REGISTRATION_PHASE_ID || 'a93544bc-c165-4af4-b55e-18f3593b457a',
   SUBMISSION_PHASE_ID: process.env.SUBMISSION_PHASE_ID || '6950164f-3c5e-4bdc-abc8-22aaf5a1bd49',

src/services/ProcessorService.js

@@ -14,6 +14,16 @@ const constants = require('../constants')
 // const showdown = require('showdown')
 // const converter = new showdown.Converter()
 
+/**
+ * Get group information by V5 UUID
+ * @param {String} v5GroupId the v5 group UUID
+ * @param {String} m2mToken token for accessing the API
+ */
+async function getGroup (v5GroupId, m2mToken) {
+  const response = await helper.getRequest(`${config.V5_GROUPS_API_URL}/${v5GroupId}`, m2mToken)
+  return response.body
+}
+
 /**
  * Get technologies from V4 API
  * @param {String} m2mToken token for accessing the API
@@ -188,6 +198,22 @@ async function parsePayload (payload, m2mToken, isCreated = true) {
       const platResult = await getPlatforms(m2mToken)
       data.platforms = _.filter(platResult.result.content, e => payload.tags.includes(e.name))
     }
+    if (payload.groups && _.get(payload, 'groups.length', 0) > 0) {
+      const legacyGroups = []
+      for (const group of payload.groups) {
+        try {
+          const groupInfo = await getGroup(group, m2mToken)
+          if (!_.isEmpty(_.get(groupInfo, 'oldId'))) {
+            legacyGroups.push(_.get(groupInfo, 'oldId'))
+          }
+        } catch (e) {
+          logger.warn(`Failed to load details for group ${group}`)
+        }
+      }
+      if (legacyGroups.length > 0) {
+        data.groups = legacyGroups
+      }
+    }
     return data
   } catch (err) {
     // Debugging
@@ -297,6 +323,7 @@ processCreate.schema = {
       projectId: Joi.number().integer().positive().required(),
       copilotId: Joi.number().integer().positive().optional(),
       status: Joi.string().valid(_.values(Object.keys(constants.createChallengeStatusesMap))).required(),
+      groups: Joi.array().items(Joi.string()),
       startDate: Joi.date()
     }).unknown(true).required()
   }).required()
@@ -416,6 +443,7 @@ processUpdate.schema = {
       }).unknown(true)).min(1),
       tags: Joi.array().items(Joi.string().required()).min(1), // tag names
       projectId: Joi.number().integer().positive().allow(null),
+      groups: Joi.array().items(Joi.string()),
       startDate: Joi.date()
     }).unknown(true).required()
   }).required()