Get User Meeting Settings Endpoint (topcoder-platform#16)

* Get User Meeting Settings Endpoint
Fixes topcoder-platform#9

Signed-off-by: Alessandro De Blasis <[email protected]>

* Get User Meeting Settings Endpoint
Fixes topcoder-platform#9

Signed-off-by: Alessandro De Blasis <[email protected]>

Author: deblasis

app-constants.js

@@ -58,7 +58,13 @@ const Scopes = {
   CREATE_ROLE: 'create:taas-roles',
   UPDATE_ROLE: 'update:taas-roles',
   DELETE_ROLE: 'delete:taas-roles',
-  ALL_ROLE: 'all:taas-roles'
+  ALL_ROLE: 'all:taas-roles',
+  // userMeetingSettings
+  READ_USER_MEETING_SETTINGS: 'read:taas-userMeetingsSettings',
+  CREATE_USER_MEETING_SETTINGS: 'create:taas-userMeetingsSettings',
+  UPDATE_USER_MEETING_SETTINGS: 'update:taas-userMeetingsSettings',
+  ALL_USER_MEETING_SETTINGS: 'all:taas-userMeetingsSettings'
+
 }
 
 // Interview related constants

config/default.js

@@ -82,6 +82,8 @@ module.exports = {
     ES_INDEX_RESOURCE_BOOKING: process.env.ES_INDEX_RESOURCE_BOOKING || 'resource_booking',
     // the role index
     ES_INDEX_ROLE: process.env.ES_INDEX_ROLE || 'role',
+    // the userMeetingSettings index
+    ES_INDEX_USER_MEETING_SETTINGS: process.env.ES_INDEX_USER_MEETING_SETTINGS || 'user_meeting_settings',
 
     // the max bulk size in MB for ES indexing
     MAX_BULK_REQUEST_SIZE_MB: process.env.MAX_BULK_REQUEST_SIZE_MB || 20,

package.json

@@ -16,6 +16,7 @@
     "index:jobs": "node scripts/es/reIndexJobs.js",
     "index:job-candidates": "node scripts/es/reIndexJobCandidates.js",
     "index:resource-bookings": "node scripts/es/reIndexResourceBookings.js",
+    "index:user-meeting-settings": "node scripts/es/reIndexUserMeetingSettings.js",
     "index:roles": "node scripts/es/reIndexRoles.js",
     "data:export": "node scripts/data/exportData.js",
     "data:import": "node scripts/data/importData.js",

scripts/es/createIndex.js

@@ -9,7 +9,8 @@ const indices = [
   config.get('esConfig.ES_INDEX_JOB'),
   config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
   config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'),
-  config.get('esConfig.ES_INDEX_ROLE')
+  config.get('esConfig.ES_INDEX_ROLE'),
+  config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS')
 ]
 const userPrompt = `WARNING: Are you sure want to create the following elasticsearch indices: ${indices}?`
 

scripts/es/deleteIndex.js

@@ -9,7 +9,8 @@ const indices = [
   config.get('esConfig.ES_INDEX_JOB'),
   config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
   config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'),
-  config.get('esConfig.ES_INDEX_ROLE')
+  config.get('esConfig.ES_INDEX_ROLE'),
+  config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS')
 ]
 const userPrompt = `WARNING: this would remove existent data! Are you sure want to delete the following eleasticsearch indices: ${indices}?`
 

scripts/es/reIndexAll.js

@@ -35,6 +35,7 @@ async function indexAll () {
       await helper.indexBulkDataToES(jobCandidateModelOpts, config.get('esConfig.ES_INDEX_JOB_CANDIDATE'), logger)
       await helper.indexBulkDataToES(resourceBookingModelOpts, config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'), logger)
       await helper.indexBulkDataToES('Role', config.get('esConfig.ES_INDEX_ROLE'), logger)
+      await helper.indexBulkDataToES('UserMeetingSettings', config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS'), logger)
       process.exit(0)
     } catch (err) {
       logger.logFullError(err, { component: 'indexAll' })

scripts/es/reIndexUserMeetingSettings.js

@@ -0,0 +1,41 @@
+/**
+ * Reindex UserMeetingSettings data in Elasticsearch using data from database
+ */
+const config = require('config')
+const logger = require('../../src/common/logger')
+const helper = require('../../src/common/helper')
+
+const userId = helper.getParamFromCliArgs()
+const index = config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS')
+const reIndexAllUserMeetingSettingsPrompt = `WARNING: this would remove existent data! Are you sure you want to reindex the index ${index}?`
+const reIndexUserMeetingSettingPrompt = `WARNING: this would remove existent data! Are you sure you want to reindex the document with id ${userId} in index ${index}?`
+
+const userMeetingSettingModelOpts = {
+  modelName: 'UserMeetingSettings'
+}
+
+async function reIndexUserMeetingSettings () {
+  if (userId === null) {
+    await helper.promptUser(reIndexAllUserMeetingSettingsPrompt, async () => {
+      try {
+        await helper.indexBulkDataToES(userMeetingSettingModelOpts, index, logger)
+        process.exit(0)
+      } catch (err) {
+        logger.logFullError(err, { component: 'reIndexUserMeetingSettings' })
+        process.exit(1)
+      }
+    })
+  } else {
+    await helper.promptUser(reIndexUserMeetingSettingPrompt, async () => {
+      try {
+        await helper.indexDataToEsById(userId, userMeetingSettingModelOpts, index, logger)
+        process.exit(0)
+      } catch (err) {
+        logger.logFullError(err, { component: 'reIndexUserMeetingSettings' })
+        process.exit(1)
+      }
+    })
+  }
+}
+
+reIndexUserMeetingSettings()

src/common/helper.js

@@ -1151,7 +1151,7 @@ async function getUserEmailByUserUUID (userUUID) {
 
   const handleQuery = `handleLower:${user.handle.toLowerCase()}`
   const userIdQuery = `userId:${user.userId}`
-
+  // eslint-disable-next-line
   const query = _.concat(handleQuery, userIdQuery).join(URI.encodeQuery(' OR ', 'utf8'))
   try {
     const searchResult = await searchUsersByQuery(query)

src/controllers/UserMeetingSettingsController.js

@@ -0,0 +1,18 @@
+/**
+ * Controller for UserMeetingSettings endpoints
+ */
+const service = require('../services/UserMeetingSettingsService')
+const helper = require('../common/helper')
+
+/**
+ * Get UserMeetingSettings for the provided userId
+ * @param req the request
+ * @param res the response
+ */
+async function getUserMeetingSettingsByUserId (req, res) {
+  const result = await service.getUserMeetingSettingsByUserId(req.authUser, req.params.userId, req.query.fromDb)
+  helper.setResHeaders(req, res, result)
+  res.send(result.result)
+}
+
+module.exports = { getUserMeetingSettingsByUserId }

src/esProcessors/UserMeetingSettingsProcessor.js

@@ -0,0 +1,54 @@
+/**
+ * UserMeetingSettings Processor
+ */
+
+const config = require('config')
+const helper = require('../common/helper')
+
+const esClient = helper.getESClient()
+
+/**
+  * Process create entity
+  * @param {Object} entity entity object
+  */
+async function processCreate (entity) {
+  await esClient.create({
+    index: config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS'),
+    id: entity.userId,
+    body: entity,
+    refresh: 'wait_for'
+  })
+}
+
+/**
+  * Process update entity
+  * @param {Object} entity entity object
+  */
+async function processUpdate (entity) {
+  await esClient.update({
+    index: config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS'),
+    id: entity.userId,
+    body: {
+      doc: entity
+    },
+    refresh: 'wait_for'
+  })
+}
+
+/**
+  * Process delete entity
+  * @param {Object} entity entity object
+  */
+async function processDelete (entity) {
+  await esClient.delete({
+    index: config.get('esConfig.ES_INDEX_USER_MEETING_SETTINGS'),
+    id: entity.userId,
+    refresh: 'wait_for'
+  })
+}
+
+module.exports = {
+  processCreate,
+  processUpdate,
+  processDelete
+}

src/routes/UserMeetingSettingsRoutes.js

@@ -0,0 +1,15 @@
+/**
+ * Contains taas routes
+ */
+const constants = require('../../app-constants')
+
+module.exports = {
+  '/taas/user-meeting-settings/:userId': {
+    get: {
+      controller: 'UserMeetingSettingsController',
+      method: 'getUserMeetingSettingsByUserId',
+      auth: 'jwt',
+      scopes: [constants.Scopes.READ_USER_MEETING_SETTINGS, constants.Scopes.ALL_USER_MEETING_SETTINGS]
+    }
+  }
+}

src/services/InterviewService.js

@@ -18,6 +18,7 @@ const {
   processUpdateInterview,
   processBulkUpdateInterviews
 } = require('../esProcessors/InterviewProcessor')
+
 const {
   processUpdate: jobCandidateProcessUpdate
 } = require('../esProcessors/JobCandidateProcessor')
@@ -26,6 +27,7 @@ const Interview = models.Interview
 const UserMeetingSettings = models.UserMeetingSettings
 const esClient = helper.getESClient()
 const NylasService = require('./NylasService')
+const UserMeetingSettingsService = require('./UserMeetingSettingsService')
 /**
   * Ensures user is permitted for the operation.
   *
@@ -41,7 +43,7 @@ async function ensureUserIsPermitted (currentUser, jobCandidateId, allowCandidat
     try {
       await helper.checkIsMemberOfProject(currentUser.userId, job.projectId)
     } catch (error) {
-      if (e instanceof errors.UnauthorizedError && allowCandidate === true) {
+      if (error instanceof errors.UnauthorizedError && allowCandidate === true) {
         const userId = await helper.getUserId(currentUser.userId)
         if (userId !== jobCandidate.userId) {
           throw error
@@ -80,7 +82,7 @@ function handleSequelizeError (err, jobCandidateId) {
  */
 async function getInterviewByRound (currentUser, jobCandidateId, round, fromDb = false) {
   // check permission
-  await ensureUserIsPermitted(currentUser, jobCandidateIdm, true)
+  await ensureUserIsPermitted(currentUser, jobCandidateId, true)
   if (!fromDb) {
     try {
       // get job candidate from ES
@@ -306,23 +308,10 @@ async function requestInterview (currentUser, jobCandidateId, interview) {
       interview.nylasPageSlug = schedulingPage.slug
       interview.nylasCalendarId = calendar.id
 
+      await UserMeetingSettingsService.createUserMeetingSettings(interview.hostUserId, calendar, schedulingPage, t)
+
       // create the interview
       const created = await Interview.create(interview, { transaction: t })
-
-      // create the userMeetingSettings
-      await UserMeetingSettings.create({
-        userId: interview.hostUserId,
-        defaultAvailableTime: NylasService.getAvailableTimeFromSchedulingPage(schedulingPage),
-        defaultTimezone: NylasService.getTimezoneFromSchedulingPage(schedulingPage),
-        nylasCalendars: [].concat({
-          accessToken: calendar.accessToken,
-          accountId: calendar.accountId,
-          accountProvider: 'nylas', // TODO 🤔
-          id: calendar.id,
-          isPrimary: calendar.is_primary
-        })
-      }, { transaction: t })
-
       entity = created.toJSON()
       await processRequestInterview(entity)
       // update jobCandidate.status to Interview
@@ -358,7 +347,14 @@ requestInterview.schema = Joi.object().keys({
     expireTimestamp: Joi.date(),
     availableTime: Joi.array().items(
       Joi.object({
-        days: Joi.array().items(Joi.string().valid(InterviewConstants.Nylas.Days.Monday, InterviewConstants.Nylas.Days.Tuesday, InterviewConstants.Nylas.Days.Wednesday, InterviewConstants.Nylas.Days.Thursday, InterviewConstants.Nylas.Days.Friday, InterviewConstants.Nylas.Days.Saturday, InterviewConstants.Nylas.Days.Sunday)).required(),
+        days: Joi.array().items(Joi.string().valid(
+          InterviewConstants.Nylas.Days.Monday,
+          InterviewConstants.Nylas.Days.Tuesday,
+          InterviewConstants.Nylas.Days.Wednesday,
+          InterviewConstants.Nylas.Days.Thursday,
+          InterviewConstants.Nylas.Days.Friday,
+          InterviewConstants.Nylas.Days.Saturday,
+          InterviewConstants.Nylas.Days.Sunday)).required(),
         end: Joi.string().regex(InterviewConstants.Nylas.StartEndRegex).required(),
         start: Joi.string().regex(InterviewConstants.Nylas.StartEndRegex).required()
       })

src/services/NylasService.js

@@ -65,28 +65,6 @@ async function _getAccessToken (code) {
   return { accountId, accessToken }
 }
 
-// Step 3
-async function getExistingCalendars (accessToken) {
-  const res = await axios.get('https://api.nylas.com/calendars', {
-    headers: {
-      Authorization: `Bearer ${accessToken}`
-    }
-  })
-
-  return res.data
-}
-
-// Step 5
-async function getSchedulingPages (accessToken) {
-  const res = await axios.get('https://api.schedule.nylas.com/manage/pages', {
-    headers: {
-      Authorization: `Bearer ${accessToken}`
-    }
-  })
-
-  return res.data
-}
-
 function getAvailableTimeFromSchedulingPage (page) {
   return page.config.booking.opening_hours
 }