diff --git a/apps/api/src/controllers/event.controller.ts b/apps/api/src/controllers/event.controller.ts index 24e9eb1e..189c66a5 100644 --- a/apps/api/src/controllers/event.controller.ts +++ b/apps/api/src/controllers/event.controller.ts @@ -49,31 +49,34 @@ export async function postEvent( 'NX', ); - eventsQueue.add( - 'event', - { - type: 'incomingEvent', - payload: { - projectId, - headers: getStringHeaders(request.headers), - event: { - ...request.body, - timestamp: timestamp.timestamp, - isTimestampFromThePast: timestamp.isTimestampFromThePast, + // TODO: remove this + if (process.env.DISABLE_ADD_JOBS === undefined) { + eventsQueue.add( + 'event', + { + type: 'incomingEvent', + payload: { + projectId, + headers: getStringHeaders(request.headers), + event: { + ...request.body, + timestamp: timestamp.timestamp, + isTimestampFromThePast: timestamp.isTimestampFromThePast, + }, + geo, + currentDeviceId, + previousDeviceId, + priority: locked === 'OK', }, - geo, - currentDeviceId, - previousDeviceId, - priority: locked === 'OK', }, - }, - { - // Prioritize 'screen_view' events by setting no delay - // This ensures that session starts are created from 'screen_view' events - // rather than other events, maintaining accurate session tracking - delay: request.body.name === 'screen_view' ? undefined : 1000, - }, - ); + { + // Prioritize 'screen_view' events by setting no delay + // This ensures that session starts are created from 'screen_view' events + // rather than other events, maintaining accurate session tracking + delay: request.body.name === 'screen_view' ? undefined : 1000, + }, + ); + } reply.status(202).send('ok'); } diff --git a/apps/api/src/controllers/track.controller.ts b/apps/api/src/controllers/track.controller.ts index 34b6fc90..b893f3fd 100644 --- a/apps/api/src/controllers/track.controller.ts +++ b/apps/api/src/controllers/track.controller.ts @@ -247,31 +247,34 @@ async function track({ 'NX', ); - eventsQueue.add( - 'event', - { - type: 'incomingEvent', - payload: { - projectId, - headers, - event: { - ...payload, - timestamp, - isTimestampFromThePast, + // TODO: remove this + if (process.env.DISABLE_ADD_JOBS === undefined) { + eventsQueue.add( + 'event', + { + type: 'incomingEvent', + payload: { + projectId, + headers, + event: { + ...payload, + timestamp, + isTimestampFromThePast, + }, + geo, + currentDeviceId, + previousDeviceId, + priority: locked === 'OK', }, - geo, - currentDeviceId, - previousDeviceId, - priority: locked === 'OK', }, - }, - { - // Prioritize 'screen_view' events by setting no delay - // This ensures that session starts are created from 'screen_view' events - // rather than other events, maintaining accurate session tracking - delay: payload.name === 'screen_view' ? undefined : 1000, - }, - ); + { + // Prioritize 'screen_view' events by setting no delay + // This ensures that session starts are created from 'screen_view' events + // rather than other events, maintaining accurate session tracking + delay: payload.name === 'screen_view' ? undefined : 1000, + }, + ); + } } async function identify({