Moved sendInterviewInvitationNotifications from services/NotificationsSchedulerService to eventHandles/InterviewEventHandler

Author: painterner

app.js

@@ -26,17 +26,17 @@ app.use(cors({
   exposedHeaders: ['X-Page', 'X-Per-Page', 'X-Total', 'X-Total-Pages', 'X-Prev-Page', 'X-Next-Page']
 }))
 app.use((...args) => {
-  const [req, res, next] = args;
+  const [req, res, next] = args
   // For test nylas webhook, we need raw buffer
   // Here i sCustom Middleware to compute rawBody. Unfortunately using
   // JSON.stringify(req.body) will remove spaces and newlines, so verification
   // will fail. We must add this middleware to ensure we're computing the correct
   // signature
-  if(req.path === `${config.BASE_PATH}/taas/nylas-webhooks`) {
+  if (req.path === `${config.BASE_PATH}/taas/nylas-webhooks`) {
     req.rawBody = ''
     req.on('data', (chunk) => (req.rawBody += chunk))
     req.on('error', () => res.status(500).send('Error parsing body'))
-  
+
     req.on('end', () => {
       // because the stream has been consumed, other parsers like bodyParser.json
       // cannot stream the request data and will time out so we must explicitly parse the body

src/eventHandlers/InterviewEventHandler.js

@@ -9,6 +9,62 @@ const models = require('../models')
 const logger = require('../common/logger')
 const helper = require('../common/helper')
 const Constants = require('../../app-constants')
+const notificationsSchedulerService = require('../services/NotificationsSchedulerService')
+
+/**
+ * Send interview invitaion notifications
+ * @param {*} interview the requested interview
+ * @returns
+ */
+async function sendInterviewInvitationNotifications (interview) {
+  logger.debug({
+    component: 'InterviewEventHandler',
+    context: 'sendInterviewInvitationNotifications',
+    message: `send to interview ${interview.id}`
+  })
+
+  try {
+    const template = 'taas.notification.interview-invitation'
+
+    // const jobCandidate = await models.JobCandidate.findById(interview.jobCandidateId)
+    // const { email, firstName, lastName } = await helper.getUserDetailsByUserUUID(interview.hostUserId)
+
+    // send host email
+    const data = await notificationsSchedulerService.getDataForInterview(interview)
+    if (!data) { return }
+
+    if (!_.isEmpty(data.guestEmail)) {
+      // send guest emails
+      await notificationsSchedulerService.sendNotification({}, {
+        template,
+        recipients: [{ email: data.guestEmail }],
+        data: {
+          ...data,
+          subject: `${data.duration} minutes tech interview with ${data.guestFullName} for ${data.jobTitle} is requested by the Customer`,
+          nylasPageSlug: interview.nylasPageSlug
+        }
+      })
+    } else {
+      logger.error({
+        component: 'InterviewEventHandler',
+        context: 'sendInterviewInvitationNotifications',
+        message: `Interview id: ${interview.id} guest emails not present`
+      })
+    }
+  } catch (e) {
+    logger.error({
+      component: 'InterviewEventHandler',
+      context: 'sendInterviewInvitationNotifications',
+      message: `Send email to interview ${interview.id}: ${e}`
+    })
+  }
+
+  logger.debug({
+    component: 'InterviewEventHandler',
+    context: 'sendInterviewInvitationNotifications',
+    message: `Sent notifications for interview ${interview.id}`
+  })
+}
 
 /**
  * Check if there is overlapping interview, if there is overlapping, then send notifications.
@@ -152,5 +208,6 @@ async function processUpdate (payload) {
 
 module.exports = {
   processRequest,
-  processUpdate
+  processUpdate,
+  sendInterviewInvitationNotifications
 }

src/services/InterviewService.js

@@ -32,7 +32,7 @@ const {
   patchSchedulingPage
 } = require('./NylasService')
 const { createUserMeetingSettingsIfNotExisting } = require('./UserMeetingSettingsService')
-const notificationsSchedulerService = require('./NotificationsSchedulerService')
+const interviewEventHandler = require('../eventHandlers/InterviewEventHandler')
 /**
   * Ensures user is permitted for the operation.
   *
@@ -325,7 +325,7 @@ async function requestInterview (currentUser, jobCandidateId, interview) {
     // if reaches here, it's not one of the common errors handled in `handleSequelizeError`
     throw err
   }
-  await notificationsSchedulerService.sendInterviewInvitationNotifications(interview)
+  await interviewEventHandler.sendInterviewInvitationNotifications(interview)
   await helper.postEvent(config.TAAS_INTERVIEW_REQUEST_TOPIC, entity)
   await helper.postEvent(config.TAAS_JOB_CANDIDATE_UPDATE_TOPIC, jobCandidateEntity)
   // return created interview

src/services/NotificationsSchedulerService.js

@@ -740,41 +740,6 @@ async function sendInterviewExpiredNotifications () {
   localLogger.debug(`[sendInterviewExpiredNotifications]: Sent notifications for ${interviews.length} interviews which are expired.`)
 }
 
-// Think it as only once scheduler when create an interview record
-async function sendInterviewInvitationNotifications (interview) {
-  localLogger.debug(`[sendInterviewInvitationNotifications]: send to interview ${interview.id}`)
-
-  try {
-    const template = 'taas.notification.interview-invitation'
-
-    // const jobCandidate = await models.JobCandidate.findById(interview.jobCandidateId)
-    // const { email, firstName, lastName } = await helper.getUserDetailsByUserUUID(interview.hostUserId)
-
-    // send host email
-    const data = await getDataForInterview(interview)
-    if (!data) { return }
-
-    if (!_.isEmpty(data.guestEmail)) {
-      // send guest emails
-      await sendNotification({}, {
-        template,
-        recipients: [{ email: data.guestEmail }],
-        data: {
-          ...data,
-          subject: `${data.duration} minutes tech interview with ${data.guestFullName} for ${data.jobTitle} is requested by the Customer`,
-          nylasPageSlug: interview.nylasPageSlug
-        }
-      })
-    } else {
-      localLogger.error(`Interview id: ${interview.id} guest emails not present`, 'sendInterviewExpiredNotifications')
-    }
-  } catch (e) {
-    localLogger.error(`Send email to interview ${interview.id}: ${e}`)
-  }
-
-  localLogger.debug(`[sendInterviewInvitationNotifications]: Sent notifications for interview ${interview.id}`)
-}
-
 /**
  * For preventing app crashing by scheduler function, use this function to wrapper target handler.
  * @param {*} callback : function handler
@@ -797,7 +762,7 @@ module.exports = {
   sendInterviewExpiredNotifications: errorCatchWrapper(sendInterviewExpiredNotifications, 'sendInterviewExpiredNotifications'),
   sendInterviewScheduleReminderNotifications: errorCatchWrapper(sendInterviewScheduleReminderNotifications, 'sendInterviewScheduleReminderNotifications'),
   updateInterviewStatus,
-  sendInterviewInvitationNotifications,
+  getDataForInterview,
   sendPostInterviewActionNotifications: errorCatchWrapper(sendPostInterviewActionNotifications, 'sendPostInterviewActionNotifications'),
   sendResourceBookingExpirationNotifications: errorCatchWrapper(sendResourceBookingExpirationNotifications, 'sendResourceBookingExpirationNotifications')
 }