@@ -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',
|
||||
},
|
||||
});
|
||||
|
||||
|
||||
Reference in New Issue
Block a user