From 0e26ac63475e0a89926598e9ac9a77624a243058 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= Date: Tue, 27 Aug 2024 22:59:48 +0200 Subject: [PATCH] Revert "wip" This reverts commit 336ba116a19ef4e44fd9785c65e0a04614789b92. --- apps/api/src/controllers/event.controller.ts | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/apps/api/src/controllers/event.controller.ts b/apps/api/src/controllers/event.controller.ts index 68858e8d..24e9ef11 100644 --- a/apps/api/src/controllers/event.controller.ts +++ b/apps/api/src/controllers/event.controller.ts @@ -38,14 +38,14 @@ export async function postEvent( ua, }); - // // this will ensure that we don't have multiple events creating sessions - // const locked = await getRedisCache().set( - // `request:priority:${currentDeviceId}-${previousDeviceId}`, - // 'locked', - // 'EX', - // 10, - // 'NX' - // ); + // this will ensure that we don't have multiple events creating sessions + const locked = await getRedisCache().set( + `request:priority:${currentDeviceId}-${previousDeviceId}`, + 'locked', + 'EX', + 10, + 'NX' + ); eventsQueue.add('event', { type: 'incomingEvent', @@ -60,7 +60,7 @@ export async function postEvent( geo, currentDeviceId, previousDeviceId, - priority: false, + priority: locked === 'OK', }, });