Check for user existence before creating the user in Topcoder

Author: callmekatootie

src/common/helper.js

@@ -189,6 +189,34 @@ async function updateUBahnRecord (path, data) {
   }
 }
 
+/**
+ * Returns the user in Topcoder identified by the handle
+ * @param {String} handle The user handle
+ */
+async function getUserInTopcoder (handle) {
+  const url = config.TOPCODER_USERS_API
+  const params = { filter: `handle=${handle}` }
+  let token
+
+  try {
+    token = await getTopcoderM2Mtoken()
+  } catch (error) {
+    logger.error('An error occurred fetching the m2m token for Topcoder APIs')
+    logger.error(error)
+    throw error
+  }
+
+  logger.debug(`request GET ${url} with params: ${JSON.stringify(params)}`)
+
+  try {
+    const res = await axios.get(url, { headers: { Authorization: `Bearer ${token}` }, params })
+    return res.data
+  } catch (err) {
+    logger.error(err)
+    throw Error(`get ${url} with params: ${JSON.stringify(params)} failed`)
+  }
+}
+
 /**
  * Creates user in Topcoder (sso user)
  * @param {Object} user The user to create
@@ -207,7 +235,7 @@ async function createUserInTopcoder (user) {
 
   logger.debug(`request POST ${url} with data: ${JSON.stringify(user)}`)
   try {
-    const res = await axios.post(`${url}`, requestBody, { headers: { Authorization: `Bearer ${token}` } })
+    const res = await axios.post(url, requestBody, { headers: { Authorization: `Bearer ${token}` } })
     return res.data
   } catch (err) {
     logger.error(err)
@@ -276,6 +304,7 @@ module.exports = {
   getUbahnSingleRecord,
   createUbahnRecord,
   updateUBahnRecord,
+  getUserInTopcoder,
   createUserInTopcoder,
   updateProcessStatus,
   uploadFailedRecord

src/services/ProcessorService.js

@@ -76,8 +76,20 @@ async function createUserInTopcoder (user) {
  * @param {String} organizationId The org id to associate the new user with
  */
 async function createUser (user, organizationId) {
-  // Create the user in Topcoder
-  const topcoderUserId = await createUserInTopcoder(user)
+  let topcoderUserId
+  // Check if the user exists in Topcoder
+  const res = await helper.getUserInTopcoder(user.handle)
+
+  const topcoderUser = res.result.content.find(u => u.handle === user.handle)
+
+  if (!topcoderUser) {
+    logger.debug(`User with handle ${user.handle} not found in Topcoder. Creating it...`)
+    // Create the user in Topcoder
+    topcoderUserId = await createUserInTopcoder(user)
+  } else {
+    logger.debug(`User with handle ${user.handle} found in Topcoder. Not creating it again...`)
+    topcoderUserId = topcoderUser.id
+  }
 
   // Create the user in UBahn api
   const ubahnUserId = await createUserInUbahn(user)