Issues-94

Author: atelomycterus

docker-compose.yml

@@ -17,4 +17,4 @@ services:
       KAFKA_ADVERTISED_HOST_NAME: localhost
       KAFKA_ADVERTISED_PORT: 9092
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
-      KAFKA_CREATE_TOPICS: "challenge.notification.create:1:1,challenge.notification.events:1:1,challenge.action.resource.create:1:1,challenge.action.resource.delete:1:1"
+      KAFKA_CREATE_TOPICS: "challenge.notification.create:1:1,challenge.notification.update:1:1,challenge.notification.events:1:1,challenge.action.resource.create:1:1,challenge.action.resource.delete:1:1"

src/constants.js

@@ -9,6 +9,8 @@ module.exports = {
     TOPICS: {
       // For challenge creation
       CHALLENGE_CREATE_TOPIC: 'challenge.notification.create',
+      // For challenge update
+      CHALLENGE_UPDATE_TOPIC: 'challenge.notification.update',
       // For member registrations and de-registrations
       CHALLENGE_NOTIFICATION_TOPIC: 'challenge.notification.events',
       // For co-pilots,PMs,etc.

src/modules/index.js

@@ -1,6 +1,7 @@
 const createChallenge = require('./create_challenge')
+const updateChallenge = require('./update_challenge')
 const userManagement = require('./user_management')
 
 module.exports = {
-  kafkaModules: [createChallenge, userManagement]
+  kafkaModules: [createChallenge, updateChallenge, userManagement]
 }

src/modules/update_challenge/handler.js

@@ -0,0 +1,34 @@
+const config = require('config')
+const util = require('util')
+const logger = require('../../utils/logger.util')
+const { updateVanillaGroup } = require('../../services/vanilla')
+const { processPayload } = require('./helpers')
+
+const services = []
+
+if (config.VANILLA_ENABLED) {
+  services.push(updateVanillaGroup)
+}
+
+/**
+ * Handle a set of messages from the Kafka topic
+ * @param {Array} messageSet
+ * @param {String} topic
+ */
+async function handler (messageSet, topic) {
+  if (services.length === 0) {
+    logger.warn('No enabled services to handle messages')
+    return
+  }
+  for (const item of messageSet) {
+    const challenge = processPayload(item, topic)
+    for (const service of services) {
+      await service(challenge)
+        .catch(err => {
+          logger.error(util.inspect(err))
+        })
+    }
+  }
+}
+
+module.exports = handler

src/modules/update_challenge/helpers.js

@@ -0,0 +1,16 @@
+const config = require('config')
+const _ = require('lodash')
+
+/**
+ * Processes a payload from the topic, to be consumed by the handler
+ * @param {Object} payload
+ */
+function processPayload (payload, topic) {
+  // Set the url of the challenge
+  payload.url = `${config.TOPCODER.ROOT_URL}/challenges/${payload.id}`
+  return payload
+}
+
+module.exports = {
+  processPayload
+}

src/modules/update_challenge/index.js

@@ -0,0 +1,11 @@
+const Kafka = require('no-kafka')
+const constants = require('../../constants')
+const handler = require('./handler')
+
+module.exports = {
+  topics: [constants.KAFKA.TOPICS.CHALLENGE_UPDATE_TOPIC],
+  handler: handler,
+  options: {
+    time: Kafka.LATEST_OFFSET
+  }
+}

src/services/vanilla.js

@@ -265,6 +265,28 @@ async function createVanillaGroup (challenge) {
   }
 }
 
+/**
+ * Update a vanilla forum group.
+ *
+ * @param {Object} challenge the challenge data
+ */
+async function updateVanillaGroup (challenge) {
+  logger.info(`The challenge with challengeID=${challenge.id}:`)
+
+  const { body: groups } = await vanillaClient.searchGroups(challenge.id)
+  if (groups.length == 0) {
+      throw new Error('The group wasn\'t found for this challenge')
+  }
+
+  if (groups.length > 1) {
+    throw new Error('Multiple groups were found for this challenge')
+  }
+
+  const {body: updatedGroup} = await vanillaClient.updateGroup(groups[0].groupID, {name: challenge.name})
+
+  logger.info(`The group was updated: ${JSON.stringify(updatedGroup)}`)
+}
+
 async function createDiscussions (group, challenge, templateDiscussions, vanillaCategory) {
     for (const discussion of templateDiscussions) {
       // create a discussion
@@ -284,5 +306,6 @@ async function createDiscussions (group, challenge, templateDiscussions, vanilla
 
 module.exports = {
   manageVanillaUser,
-  createVanillaGroup
+  createVanillaGroup,
+  updateVanillaGroup
 }

src/utils/vanilla-client.util.js

@@ -107,6 +107,11 @@ function getVanillaClient () {
         .query({ access_token: config.VANILLA.ADMIN_ACCESS_TOKEN })
         .send(data)
     },
+    updateGroup: (groupId, data) => {
+      return request.patch(`${config.VANILLA.API_URL}/groups/${groupId}`)
+        .query({ access_token: config.VANILLA.ADMIN_ACCESS_TOKEN })
+        .send(data)
+    },
     searchGroups: (query) => {
       const queryParams = { access_token: config.VANILLA.ADMIN_ACCESS_TOKEN }
       queryParams.challengeID = query