improve(api): ensure we do 3 attempts to add events to the queue

apps/api/src/controllers/event.controller.ts

@@ -49,7 +49,7 @@ export async function postEvent(
     'NX',
   );
 
-  eventsQueue.add(
+  await eventsQueue.add(
     'event',
     {
       type: 'incomingEvent',
@@ -68,6 +68,11 @@ export async function postEvent(
       },
     },
     {
+      attempts: 3,
+      backoff: {
+        type: 'exponential',
+        delay: 200,
+      },
       // 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

apps/api/src/controllers/track.controller.ts

@@ -248,7 +248,7 @@ async function track({
     'NX',
   );
 
-  eventsQueue.add(
+  await eventsQueue.add(
     'event',
     {
       type: 'incomingEvent',
@@ -267,6 +267,11 @@ async function track({
       },
     },
     {
+      attempts: 3,
+      backoff: {
+        type: 'exponential',
+        delay: 200,
+      },
       // 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

apps/worker/src/utils/session-handler.ts

@@ -27,6 +27,11 @@ export async function createSessionEnd({
     {
       delay: SESSION_TIMEOUT,
       jobId: getSessionEndJobId(payload.projectId, payload.deviceId),
+      attempts: 3,
+      backoff: {
+        type: 'exponential',
+        delay: 200,
+      },
     },
   );