Moved send invitation to kafka event processer

Author: painterner

src/eventHandlers/InterviewEventHandler.js

@@ -193,6 +193,7 @@ async function checkOverlapping (payload) {
  * @returns {undefined}
  */
 async function processRequest (payload) {
+  await sendInterviewInvitationNotifications(payload.value)
   await checkOverlapping(payload)
 }
 
@@ -208,6 +209,5 @@ async function processUpdate (payload) {
 
 module.exports = {
   processRequest,
-  processUpdate,
-  sendInterviewInvitationNotifications
+  processUpdate
 }

src/services/InterviewService.js

@@ -32,7 +32,6 @@ const {
   patchSchedulingPage
 } = require('./NylasService')
 const { createUserMeetingSettingsIfNotExisting } = require('./UserMeetingSettingsService')
-const interviewEventHandler = require('../eventHandlers/InterviewEventHandler')
 /**
   * Ensures user is permitted for the operation.
   *
@@ -325,7 +324,6 @@ async function requestInterview (currentUser, jobCandidateId, interview) {
     // if reaches here, it's not one of the common errors handled in `handleSequelizeError`
     throw err
   }
-  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