Restructuring the register vs resource create

Author: rootelement

config/default.js

@@ -20,6 +20,8 @@ module.exports = {
   KAFKA_CLIENT_CERT: process.env.KAFKA_CLIENT_CERT,
   KAFKA_CLIENT_CERT_KEY: process.env.KAFKA_CLIENT_CERT_KEY,
 
+  SUBMITTER_ROLE_ID: process.env.SUBMITTER_ROLE_ID || '732339e7-8e30-49d7-9198-cccf9451e221',
+
   CREATE_CHALLENGE_RESOURCE_TOPIC: process.env.CREATE_CHALLENGE_RESOURCE_TOPIC || 'challenge.action.resource.create',
   DELETE_CHALLENGE_RESOURCE_TOPIC: process.env.DELETE_CHALLENGE_RESOURCE_TOPIC || 'challenge.action.resource.delete',
 

src/services/ProcessorService.js

@@ -69,24 +69,33 @@ async function _updateChallengeResource (message, isDelete) {
   }
   resourceRole = resourceRoleResponse.body[0]
   logger.debug(`Resource Role Response ${JSON.stringify(resourceRole)}`)
-  const body = {}
   const userId = _.get(message, 'payload.memberId')
-  // const body = {
-  //   roleId: resourceRole.legacyId,
-  //   resourceUserId: _.get(message, 'payload.memberId'),
-  //   isStudio: isStudio(v5Challenge.type)
-  // }
+  const body = {
+    roleId: resourceRole.legacyId,
+    resourceUserId: userId,
+    isStudio: isStudio(v5Challenge.type)
+  }
 
   // create or delete the challenge resource from V4 API
   let response = null
-  if (isDelete) {
-    logger.debug(`Deleteing Challenge Resource ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/register?userId=${userId} - ${JSON.stringify(body)}`)
-    response = await helper.deleteRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/register?userId=${userId}`, body, m2mToken)
+  if (resourceRole.id === config.SUBMITTER_ROLE_ID) {
+    if (isDelete) {
+      logger.debug(`Unregistering Submitter ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/unregister?userId=${userId} - ${JSON.stringify(body)}`)
+      response = await helper.deleteRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/unregister?userId=${userId}`, {}, m2mToken)
+    } else {
+      logger.debug(`Registering Submitter ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/register?userId=${userId} - ${JSON.stringify(body)}`)
+      response = await helper.postRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/register?userId=${userId}`, {}, m2mToken)
+    }
   } else {
-    logger.debug(`POSTING Challenge Resource ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/unregister?userId=${userId} - ${JSON.stringify(body)}`)
-    response = await helper.postRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/unregister?userId=${userId}`, body, m2mToken)
+    if (isDelete) {
+      logger.debug(`Deleteing Challenge Resource ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/resources - ${JSON.stringify(body)}`)
+      response = await helper.deleteRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/resources`, body, m2mToken)
+    } else {
+      logger.debug(`Creating Challenge Resource ${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/resources - ${JSON.stringify(body)}`)
+      response = await helper.postRequest(`${config.CHALLENGE_API_V4_URL}/${_.get(v5Challenge, 'legacyId')}/resources`, body, m2mToken)
+    }
+    logger.debug(`Update Challenge Response ${JSON.stringify(response)}`)
   }
-  logger.debug(`Update Challenge Response ${JSON.stringify(response)}`)
 }
 
 /**