CognxSafeTrack commited on
Commit
caa20c8
·
1 Parent(s): 9f4922e

chore: Add observability log for feedback enqueuing

Browse files
apps/whatsapp-worker/src/services/whatsapp-logic.ts CHANGED
@@ -296,6 +296,7 @@ export class WhatsAppLogic {
296
  const previousResponsesData = await prisma.response.findMany({ where: { userId: user.id, enrollmentId: activeEnrollment.id }, orderBy: { dayNumber: 'asc' }, take: 5 });
297
  const previousResponses = previousResponsesData.map(r => ({ day: r.dayNumber, response: r.content }));
298
 
 
299
  await whatsappQueue.add('generate-feedback', {
300
  userId: user.id, text, trackId: activeEnrollment.trackId, trackDayId: trackDay.id,
301
  enrollmentId: activeEnrollment.id,
 
296
  const previousResponsesData = await prisma.response.findMany({ where: { userId: user.id, enrollmentId: activeEnrollment.id }, orderBy: { dayNumber: 'asc' }, take: 5 });
297
  const previousResponses = previousResponsesData.map(r => ({ day: r.dayNumber, response: r.content }));
298
 
299
+ console.log(`[LOGIC] 🚀 Enqueuing generate-feedback for User ${user.id} (Day ${activeEnrollment.currentDay}, DeepDive: ${isDeepDiveAction})`);
300
  await whatsappQueue.add('generate-feedback', {
301
  userId: user.id, text, trackId: activeEnrollment.trackId, trackDayId: trackDay.id,
302
  enrollmentId: activeEnrollment.id,