From 7a27e8d96d5a23dab291638e760d5bd4131fde9f Mon Sep 17 00:00:00 2001
From: Maksym Mykhailenko <maxceem@gmail.com>
Date: Thu, 2 Sep 2021 18:38:54 +0300
Subject: [PATCH] improve scheduled notifications robustness

---
 src/services/NotificationsSchedulerService.js | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/services/NotificationsSchedulerService.js b/src/services/NotificationsSchedulerService.js
index 8a7c288d..3bd24704 100644
--- a/src/services/NotificationsSchedulerService.js
+++ b/src/services/NotificationsSchedulerService.js
@@ -192,7 +192,7 @@ async function sendCandidatesAvailableNotifications () {
  */
 async function sendInterviewComingUpNotifications () {
   localLogger.debug('[sendInterviewComingUpNotifications]: Looking for due records...')
-  const currentTime = moment.utc()
+  const currentTime = moment.utc().startOf('minute')
   const timestampFilter = {
     [Op.or]: []
   }
@@ -204,10 +204,10 @@ async function sendInterviewComingUpNotifications () {
     timestampFilter[Op.or].push({
       [Op.and]: [
         {
-          [Op.gt]: rangeStart
+          [Op.gte]: rangeStart
         },
         {
-          [Op.lte]: rangeEnd
+          [Op.lt]: rangeEnd
         }
       ]
     })
@@ -290,7 +290,7 @@ async function sendInterviewComingUpNotifications () {
 async function sendInterviewCompletedNotifications () {
   localLogger.debug('[sendInterviewCompletedNotifications]: Looking for due records...')
   const window = moment.duration(config.INTERVIEW_COMPLETED_MATCH_WINDOW)
-  const rangeStart = moment.utc().subtract(moment.duration(config.INTERVIEW_COMPLETED_PAST_TIME))
+  const rangeStart = moment.utc().startOf('minute').subtract(moment.duration(config.INTERVIEW_COMPLETED_PAST_TIME))
   const rangeEnd = rangeStart.clone().add(window)
   const filter = {
     [Op.and]: [