1import { DateTime } from "luxon";
 2import { factories } from "@strapi/strapi";
 3
 4export default factories.createCoreService(
 5  "api::event.event",
 6  ({ strapi }) => ({
 7    getWaitingPassengers: async (event) => {
 8      return strapi.entityService.findMany("api::passenger.passenger", {
 9        filters: {
10          event: { id: event.id },
11          travel: {
12            id: {
13              $null: true,
14            },
15          },
16        },
17        populate: ["travel", "user"],
18      });
19    },
20    sendDailyRecap: async (event) => {
21      const referenceDate = DateTime.now().minus({ day: 1 });
22      const hasBeenModified =
23        referenceDate <= DateTime.fromISO(event.updatedAt);
24      if (hasBeenModified) {
25        strapi.log.debug(
26          `Send daily recap to ${event.email} for event #${event.id}`
27        );
28        const newTravels = event.travels?.filter(
29          (travel) => referenceDate <= DateTime.fromISO(travel.createdAt)
30        );
31        const waitingPassengers = await strapi
32          .service("api::event.event")
33          .getWaitingPassengers(event);
34
35        await strapi
36          .service("api::email.email")
37          .sendEmailNotif(event.email, "EventRecap", event.lang, {
38            event,
39            waitingListCount: waitingPassengers?.length || 0,
40            travelsCount: event.travels?.length || 0,
41            newTravelsCount: newTravels?.length || 0,
42          });
43      }
44    },
45
46    sendEndRecap: async (event) => {
47      const travelsCount = event.travels?.length || 0;
48      const passengersCount = event.passengers?.filter(
49        (passenger) => passenger.travel
50      ).length;
51      await strapi
52        .service("api::email.email")
53        .sendEmailNotif(event.email, "EventEnded", event.lang, {
54          event,
55          travelsCount,
56          passengersCount,
57        });
58    },
59  })
60);