zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix delayed jobs

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-07-15 20:25:01 +02:00
parent ffc7b5ef54
commit 244aa3b0d3
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
apps/worker/src/jobs/events.incoming-event.ts
View File

@@ -125,24 +125,16 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
if (sessionEndJobCurrentDeviceId) { if (sessionEndJobCurrentDeviceId) {
deviceId = currentDeviceId; deviceId = currentDeviceId;
const diff = Date.now() - sessionEndJobCurrentDeviceId.timestamp; sessionEndJobCurrentDeviceId.changeDelay(SESSION_END_TIMEOUT);
sessionEndJobCurrentDeviceId.changeDelay(diff + SESSION_END_TIMEOUT);
} else if (sessionEndJobPreviousDeviceId) { } else if (sessionEndJobPreviousDeviceId) {
deviceId = previousDeviceId; deviceId = previousDeviceId;
const diff = Date.now() - sessionEndJobPreviousDeviceId.timestamp; sessionEndJobPreviousDeviceId.changeDelay(SESSION_END_TIMEOUT);
sessionEndJobPreviousDeviceId.changeDelay(diff + SESSION_END_TIMEOUT);
} else if (sessionEndJobCurrentDeviceIdDeprecated) { } else if (sessionEndJobCurrentDeviceIdDeprecated) {
deviceId = currentDeviceIdDeprecated; deviceId = currentDeviceIdDeprecated;
const diff = Date.now() - sessionEndJobCurrentDeviceIdDeprecated.timestamp; sessionEndJobCurrentDeviceIdDeprecated.changeDelay(SESSION_END_TIMEOUT);
sessionEndJobCurrentDeviceIdDeprecated.changeDelay(
diff + SESSION_END_TIMEOUT
);
} else if (sessionEndJobPreviousDeviceIdDeprecated) { } else if (sessionEndJobPreviousDeviceIdDeprecated) {
deviceId = previousDeviceIdDeprecated; deviceId = previousDeviceIdDeprecated;
const diff = Date.now() - sessionEndJobPreviousDeviceIdDeprecated.timestamp; sessionEndJobPreviousDeviceIdDeprecated.changeDelay(SESSION_END_TIMEOUT);
sessionEndJobPreviousDeviceIdDeprecated.changeDelay(
diff + SESSION_END_TIMEOUT
);
} else { } else {
deviceId = currentDeviceId; deviceId = currentDeviceId;
createSessionStart = true; createSessionStart = true;