#29 - Proxy to EMSI if the org use EMSI as skill provider

Author: callmekatootie

config/default.js

@@ -36,6 +36,17 @@ module.exports = {
   UBAHN_UPDATE_TOPIC: process.env.UBAHN_UPDATE_TOPIC || 'u-bahn.action.update',
   UBAHN_DELETE_TOPIC: process.env.UBAHN_DELETE_TOPIC || 'u-bahn.action.delete',
 
+  EMSI: {
+    CLIENT_ID: process.env.EMSI_CLIENT_ID,
+    CLIENT_SECRET: process.env.EMSI_CLIENT_SECRET,
+    GRANT_TYPE: process.env.EMSI_GRANT_TYPE || 'client_credentials',
+    SCOPE: process.env.EMSI_SCOPE || 'emsi_open',
+    AUTH_URL: process.env.EMSI_AUTH_URL || 'https://auth.emsicloud.com/connect/token',
+    BASE_URL: process.env.EMSI_BASE_URL || 'https://skills.emsicloud.com/versions/latest'
+  },
+
+  EMSI_SKILLPROVIDER_ID: process.env.EMSI_SKILLPROVIDER_ID || '7637ae1a-3b7c-44eb-a5ed-10ea02f1885d',
+
   // ElasticSearch
   ES: {
     HOST: process.env.ES_HOST || 'localhost:9200',

package-lock.json

@@ -29,6 +29,7 @@
     "ion-js": "^3.1.2",
     "js-yaml": "^3.13.1",
     "lodash": "^4.17.19",
+    "node-cache": "^5.1.2",
     "querystring": "^0.2.0",
     "swagger-ui-express": "^4.1.4",
     "tc-bus-api-wrapper": "github:topcoder-platform/tc-bus-api-wrapper",

package.json

@@ -3,6 +3,7 @@
  */
 const esHelper = require('../../common/es-helper')
 const { injectSearchMeta } = require('../../common/helper')
+const service = require('./service')
 
 /**
  * Search for users. Returns enriched users
@@ -17,7 +18,7 @@ async function searchUsers (req, res) {
  * Search for skills in organization
  */
 async function searchSkills (req, res) {
-  const result = await esHelper.searchSkillsInOrganization(req.query)
+  const result = await service.getSkills(req.query, req.auth)
   res.send(result.result)
 }
 

src/modules/search/controller.js

@@ -0,0 +1,84 @@
+const axios = require('axios')
+const config = require('config')
+const querystring = require('querystring')
+const NodeCache = require('node-cache')
+const joi = require('@hapi/joi')
+const orgSkillsProviderService = require('../organizationSkillsProvider/service')
+const esHelper = require('../../common/es-helper')
+
+// cache the emsi token
+const tokenCache = new NodeCache()
+
+/**
+ * Format EMSI skills like the ones returned by the ES query
+ * @param {Array} emsiSkills Array of skills
+ */
+function formatEmsiSkills (emsiSkills) {
+  return emsiSkills.skills.slice(0, 10).map(skill => ({
+    name: skill.name,
+    skillId: skill.id,
+    skillProviderId: config.EMSI_SKILLPROVIDER_ID
+  }))
+}
+
+/**
+ * Get emsi token
+ * @returns {string} the emsi token
+ */
+async function getEmsiToken () {
+  let token = tokenCache.get('emsi_token')
+  if (!token) {
+    const res = await axios.post(config.EMSI.AUTH_URL, querystring.stringify({
+      client_id: config.EMSI.CLIENT_ID,
+      client_secret: config.EMSI.CLIENT_SECRET,
+      grant_type: config.EMSI.GRANT_TYPE,
+      scope: config.EMSI.SCOPE
+    }))
+    token = res.data.access_token
+    tokenCache.set('emsi_token', token, res.data.expires_in)
+  }
+  return token
+}
+
+/**
+ * Get data from emsi
+ * @param {String} path the emsi endpoint path
+ * @param {String} params get params
+ * @returns {Object} response data
+ */
+async function getEmsiObject (path, params) {
+  const token = await getEmsiToken()
+  const res = await axios.get(`${config.EMSI.BASE_URL}${path}`, { params, headers: { authorization: `Bearer ${token}` } })
+  return res.data
+}
+
+/**
+ * Get skills by query.
+// !Proxies request to EMSI if org uses it as its skill provider
+ * @param {String} query the query
+ * @param {Object} auth the auth object
+ * @returns {Object} the Object with skills
+ */
+async function getSkills (query, auth) {
+  let result
+  const skillProviderIds = await orgSkillsProviderService.search({ organizationId: query.organizationId }, auth)
+
+  if (skillProviderIds.result.length === 1 && skillProviderIds.result[0].skillProviderId === config.EMSI_SKILLPROVIDER_ID) {
+    result = await getEmsiObject('/skills', { q: query.keyword })
+    return { result: formatEmsiSkills(result) }
+  }
+
+  result = await esHelper.searchSkillsInOrganization(query)
+
+  return result
+}
+
+getSkills.schema = {
+  query: joi.object().keys({
+    organizationId: joi.string().required(),
+    keyword: joi.string().required()
+  }),
+  auth: joi.object()
+}
+
+module.exports = { getSkills }