#7 - Set external profile active or not

Author: callmekatootie

README.md

@@ -35,6 +35,7 @@ The following parameters can be set in config files or in env variables:
 - ATTRIBUTE_GROUP_NAME: The attribute group name
 - SKILL_PROVIDER_NAME: The skill provider name. Not in use anymore. Retained for any future use
 - ORGANIZATION_NAME: The organization name
+- MEMBER_PROFILE_URL_PREFIX: The member's profile url prefix. Defaults to `'https://www.topcoder.com/members/'` - don't forget the `/` at the end
 
 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
 

VERIFICATION.md

@@ -13,7 +13,7 @@ docker exec -it identity-data-processor_kafka /opt/kafka/bin/kafka-console-produ
 4. Write message: `{"topic":"identity.notification.create","originator":"identity-service","timestamp":"2019-07-08T00:00:00.000Z","mime-type":"application/json","payload":{"id":"10000001","modifiedBy":null,"modifiedAt":null,"createdBy":null,"createdAt":null,"handle":"theuserhandle","email":"theuserhandle@gmail.com","firstName":"User","lastName":"Member","credential":{"activationCode":"ABCDEFGHIJK","resetToken":null,"hasPassword":true},"profiles":null,"status":"U","country":{"code":"040","name":"Austria","isoAlpha2Code":"AT","isoAlpha3Code":"AUT"},"regSource":null,"utmSource":null,"utmMedium":null,"utmCampaign":null,"roles":null,"ssoLogin":false,"active":false,"profile":null,"emailActive":false}}`
 5. Watch the app console. It will show message successfully handled. The log should look like:
   ```
-  info: user: tezsachin78033 created
+  info: user: theuserhandle created
   debug: Sleeping for 1000 ms
   info: external profile: 36ed815b-3da1-49f1-a043-aaed0a4e81ad created
   debug: Sleeping for 1000 ms

config/default.js

@@ -30,5 +30,7 @@ module.exports = {
   ORGANIZATION_NAME: process.env.ORGANIZATION_NAME,
   ATTRIBUTE_GROUP_NAME: process.env.ATTRIBUTE_GROUP_NAME,
   SKILL_PROVIDER_NAME: process.env.SKILL_PROVIDER_NAME,
-  MEMBERS_API_URL: process.env.MEMBERS_API_URL || 'https://api.topcoder-dev.com/v5/members'
+  MEMBERS_API_URL: process.env.MEMBERS_API_URL || 'https://api.topcoder-dev.com/v5/members',
+
+  MEMBER_PROFILE_URL_PREFIX: process.env.MEMBER_PROFILE_URL_PREFIX || 'https://www.topcoder.com/members/'
 }

src/common/helper.js

@@ -223,6 +223,17 @@ async function createExternalProfile (userId, body, token) {
   await axios.post(`${config.UBAHN_API_URL}/users/${userId}/externalProfiles`, body, { headers: { Authorization: `Bearer ${token}` } })
 }
 
+/**
+ * Update external profile
+ * @param {String} userId
+ * @param {String} organizationId
+ * @param {Object} body
+ * @param {String} token
+ */
+async function updateExternalProfile (userId, organizationId, body, token) {
+  await axios.patch(`${config.UBAHN_API_URL}/users/${userId}/externalProfiles/${organizationId}`, body, { headers: { Authorization: `Bearer ${token}` } })
+}
+
 /**
  * Create user skill
  * * Unused for now. Retained for any future use
@@ -251,5 +262,6 @@ module.exports = {
   createExternalProfile,
   createUserSkill,
   getUserId,
-  updateUserAttribute
+  updateUserAttribute,
+  updateExternalProfile
 }

src/services/ProcessorService.js

@@ -6,8 +6,7 @@ const _ = require('lodash')
 const Joi = require('@hapi/joi')
 const logger = require('../common/logger')
 const helper = require('../common/helper')
-
-const MEMBER_PROFILE_URL_PREFIX = 'https://www.topcoder.com/members/'
+const config = require('config')
 
 /**
  * Process identity create entity message
@@ -60,7 +59,12 @@ async function processCreate (message, ubahnToken) {
   const userId = await helper.createUser(_.pick(message.payload, 'handle', 'firstName', 'lastName'), ubahnToken)
   logger.info(`user: ${message.payload.handle} created`)
   helper.sleep()
-  await helper.createExternalProfile(userId, { organizationId, uri: `${MEMBER_PROFILE_URL_PREFIX}${message.payload.handle}`, externalId: message.payload.id, isInactive: false }, ubahnToken)
+  await helper.createExternalProfile(userId, {
+    organizationId,
+    uri: `${config.MEMBER_PROFILE_URL_PREFIX}${message.payload.handle}`,
+    externalId: message.payload.id,
+    isInactive: !message.payload.active
+  }, ubahnToken)
   logger.info(`external profile: ${organizationId} created`)
   helper.sleep()
   await helper.createUserAttribute(userId, _.get(attributes, 'isAvailable'), message.payload.active.toString(), ubahnToken)
@@ -90,8 +94,12 @@ async function processCreate (message, ubahnToken) {
  * @param {String} ubahnToken the auth token
  */
 async function processUpdate (message, userId, ubahnToken) {
+  const organizationId = await helper.getOrganizationId(ubahnToken)
   const attributes = await helper.getAttributes(ubahnToken)
 
+  await helper.updateExternalProfile(userId, organizationId, { isInactive: !message.payload.active }, ubahnToken)
+  logger.info('user attribute: isAvailable updated')
+
   await helper.updateUserAttribute(userId, _.get(attributes, 'isAvailable'), message.payload.active.toString(), ubahnToken)
   logger.info('user attribute: isAvailable updated')
 }