import { DateTime } from "luxon";
import { factories } from "@strapi/strapi";

export default factories.createCoreService(
  "api::event.event",
  ({ strapi }) => ({
    getWaitingPassengers: async (event) => {
      return strapi.entityService.findMany("api::passenger.passenger", {
        filters: {
          event: { id: event.id },
          travel: {
            id: {
              $null: true,
            },
          },
        },
        populate: ["travel", "user"],
      });
    },
    getTripAlerts: async (event) => {
      const tripAlerts = await strapi.entityService.findMany(
        "api::trip-alert.trip-alert",
        {
          filters: {
            event: { id: event.id },
            user: { $not: null },
            enabled: true,
          },
          populate: ["user"],
        }
      );
      const eventPassengers = await strapi.entityService.findMany(
        "api::passenger.passenger",
        {
          filters: {
            event: { id: event.id },
            travel: {
              id: {
                $null: false,
              },
            },
          },
          populate: ["user"],
        }
      );
      const usersInTravel = eventPassengers
        .map((passenger) => passenger.user?.id)
        .filter(Boolean);
      return tripAlerts.filter(
        (tripAlert) => !usersInTravel.includes(tripAlert.user.id)
      );
    },
    sendDailyRecap: async (event) => {
      const returnEvent = event.linkedEvent;
      const referenceDate = DateTime.now().minus({ day: 1 });
      const hasBeenModified =
        referenceDate <= DateTime.fromISO(event.updatedAt);
      const returnEventHasBeenModified =
        returnEvent && referenceDate <= DateTime.fromISO(returnEvent.updatedAt);
      if (hasBeenModified || returnEventHasBeenModified) {
        strapi.log.debug(`Send daily recap to admins of event #${event.id}`);

        const travelsCount =
          (event.travels?.length || 0) + (returnEvent?.travels?.length || 0);

        let waitingListCount = 0;
        const waitingPassengers = await strapi
          .service("api::event.event")
          .getWaitingPassengers(event);
        waitingListCount += waitingPassengers?.length || 0;

        let newTravelsCount = 0;
        const newTravels = event.travels?.filter(
          (travel) => referenceDate <= DateTime.fromISO(travel.createdAt)
        );
        newTravelsCount += newTravels?.length || 0;

        if (returnEvent) {
          const returningWaitingPassengers = await strapi
            .service("api::event.event")
            .getWaitingPassengers(returnEvent);
          waitingListCount += returningWaitingPassengers?.length || 0;

          const returningNewTravels = returnEvent.travels?.filter(
            (travel) => referenceDate <= DateTime.fromISO(travel.createdAt)
          );
          newTravelsCount += returningNewTravels?.length || 0;
        }

        const administratorEmails = event.administrators?.split(/, ?/) || [];
        administratorEmails.push(event.email);

        for (const email of administratorEmails) {
          await strapi
            .service("api::email.email")
            .sendEmailNotif(email, "EventRecap", event.lang, {
              event,
              travelsCount,
              waitingListCount,
              newTravelsCount,
            });
        }
      }
    },

    sendEndRecap: async (event) => {
      const returnEvent = event.linkedEvent;
      const travelsCount =
        (event.travels?.length || 0) + (returnEvent?.travels?.length || 0);
      const passengersCount =
        (event.passengers?.filter((passenger) => passenger.travel).length ||
          0) +
        (returnEvent.passengers?.filter((passenger) => passenger.travel)
          .length || 0);

      const administratorEmails = event.administrators?.split(/, ?/) || [];
      administratorEmails.push(event.email);

      for (const email of administratorEmails) {
        await strapi
          .service("api::email.email")
          .sendEmailNotif(email, "EventEnded", event.lang, {
            event,
            travelsCount,
            passengersCount,
          });
      }
    },
  })
);