From 244aa3b0d3defe9394bab02e313ba8bc8f43bc4b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Mon, 15 Jul 2024 20:25:01 +0200
Subject: [PATCH] fix delayed jobs

---
 apps/worker/src/jobs/events.incoming-event.ts | 16 ++++------------
 1 file changed, 4 insertions(+), 12 deletions(-)

diff --git a/apps/worker/src/jobs/events.incoming-event.ts b/apps/worker/src/jobs/events.incoming-event.ts
index f0422a8c..67460d02 100644
--- a/apps/worker/src/jobs/events.incoming-event.ts
+++ b/apps/worker/src/jobs/events.incoming-event.ts
@@ -125,24 +125,16 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
 
   if (sessionEndJobCurrentDeviceId) {
     deviceId = currentDeviceId;
-    const diff = Date.now() - sessionEndJobCurrentDeviceId.timestamp;
-    sessionEndJobCurrentDeviceId.changeDelay(diff + SESSION_END_TIMEOUT);
+    sessionEndJobCurrentDeviceId.changeDelay(SESSION_END_TIMEOUT);
   } else if (sessionEndJobPreviousDeviceId) {
     deviceId = previousDeviceId;
-    const diff = Date.now() - sessionEndJobPreviousDeviceId.timestamp;
-    sessionEndJobPreviousDeviceId.changeDelay(diff + SESSION_END_TIMEOUT);
+    sessionEndJobPreviousDeviceId.changeDelay(SESSION_END_TIMEOUT);
   } else if (sessionEndJobCurrentDeviceIdDeprecated) {
     deviceId = currentDeviceIdDeprecated;
-    const diff = Date.now() - sessionEndJobCurrentDeviceIdDeprecated.timestamp;
-    sessionEndJobCurrentDeviceIdDeprecated.changeDelay(
-      diff + SESSION_END_TIMEOUT
-    );
+    sessionEndJobCurrentDeviceIdDeprecated.changeDelay(SESSION_END_TIMEOUT);
   } else if (sessionEndJobPreviousDeviceIdDeprecated) {
     deviceId = previousDeviceIdDeprecated;
-    const diff = Date.now() - sessionEndJobPreviousDeviceIdDeprecated.timestamp;
-    sessionEndJobPreviousDeviceIdDeprecated.changeDelay(
-      diff + SESSION_END_TIMEOUT
-    );
+    sessionEndJobPreviousDeviceIdDeprecated.changeDelay(SESSION_END_TIMEOUT);
   } else {
     deviceId = currentDeviceId;
     createSessionStart = true;