🚑 fun facts worker loop

scripts/NGC-1784-20250331.ts

@@ -17,7 +17,7 @@ const main = async () => {
     let updatedPolls = 0
 
     for await (const poll of batchPolls) {
-      await updatePollFunFacts(poll.id, { session: prisma })
+      await updatePollFunFacts({ pollId: poll.id }, { session: prisma })
 
       updatedPolls++
 

src/adapters/redis/constant.ts

@@ -3,6 +3,7 @@ export const CHANNELS = {
 }
 
 export const KEYS = {
+  pollsFunFactsResults: 'pollsFunFactsResults',
   geolocationSortedIps: 'geolocationSortedIps',
   geolocationCountries: 'geolocationCountries',
 }

src/features/groups/groups.repository.ts

@@ -71,7 +71,7 @@ export const createGroupAndUser = async (
   const [participantDto] = participants || []
 
   // For now no relation
-  const [group, simulation] = await Promise.all([
+  const [group, simulationCreation] = await Promise.all([
     // create group
     session.group.create({
       data: {
@@ -111,7 +111,11 @@ export const createGroupAndUser = async (
       : []),
   ])
 
+  const { created, simulation, updated } = simulationCreation || {}
+
   return {
+    simulationUpdated: updated,
+    simulationCreated: created,
     administrator,
     simulation,
     group: {
@@ -185,7 +189,7 @@ export const createParticipantAndUser = async (
 
   // For now no relation
   const { id: simulationId } = simulationDto
-  const [simulation, participant] = await Promise.all([
+  const [simulationCreation, participant] = await Promise.all([
     createParticipantSimulation(
       {
         userId,
@@ -217,11 +221,19 @@ export const createParticipantAndUser = async (
     }),
   ])
 
+  const {
+    created: simulationCreated,
+    simulation,
+    updated: simulationUpdated,
+  } = simulationCreation
+
   return {
     participant: {
       ...participant,
       simulation,
     },
+    simulationUpdated,
+    simulationCreated,
     created: !existingParticipant,
     updated: !!existingParticipant,
   }

src/features/groups/groups.service.ts

@@ -106,9 +106,13 @@ export const createGroup = async ({
   groupDto: GroupCreateDto
   origin: string
 }) => {
-  const { group, administrator, simulation } = await transaction((session) =>
-    createGroupAndUser(groupDto, { session })
-  )
+  const {
+    group,
+    administrator,
+    simulation,
+    simulationUpdated,
+    simulationCreated,
+  } = await transaction((session) => createGroupAndUser(groupDto, { session }))
   const { participants } = group
 
   const events = []
@@ -130,6 +134,8 @@ export const createGroup = async ({
       administrator,
       sendEmail: true,
       user: administrator,
+      updated: simulationUpdated,
+      created: simulationCreated,
     })
 
     EventBus.emit(simulationUpsertedEvent)
@@ -180,9 +186,10 @@ export const createParticipant = async ({
   participantDto: ParticipantCreateDto
 }) => {
   try {
-    const { participant, created } = await transaction((session) =>
-      createParticipantAndUser(params, participantDto, { session })
-    )
+    const { participant, created, simulationCreated, simulationUpdated } =
+      await transaction((session) =>
+        createParticipantAndUser(params, participantDto, { session })
+      )
     const {
       user,
       group,
@@ -198,6 +205,8 @@ export const createParticipant = async ({
     })
 
     const simulationUpsertedEvent = new SimulationUpsertedEvent({
+      created: simulationCreated,
+      updated: simulationUpdated,
       sendEmail: created,
       administrator,
       simulation,