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', }, });