import pMap from "p-map";
import moment from "moment";

const createPassenger = {
  description: "Create a passenger",
  async resolve(_root, args) {
    const { data: passengerInput } = args;
    const { user: userId, event: eventId } = passengerInput;

    //Avoid duplicity when the connected users add themself
    if (userId) {
      const userPassengersInEvent = (await strapi.entityService.findMany(
        "api::passenger.passenger",
        {
          filters: {
            event: { id: eventId },
            user: { id: userId },
          },
        }
      )) as { id: string }[];

      // Delete existing passenger linked to the user in targeted event
      await pMap(
        userPassengersInEvent,
        async (passenger) =>
          strapi.entityService.delete("api::passenger.passenger", passenger.id),
        { concurrency: 5 }
      );
    }

    const createdPassenger = await strapi.entityService.create(
      "api::passenger.passenger",
      {
        data: passengerInput,
        populate: ["event", "user", "travel"],
      }
    );

    // If event is Caroster Plus, send notification to user
    const enabledModules = createdPassenger.event?.enabled_modules as string[];
    const isCarosterPlus = enabledModules?.includes("caroster-plus");
    if (isCarosterPlus && createdPassenger.user) {
      const travel = createdPassenger.travel;
      const datetime = travel.departure
        ? moment(travel.departure)
            .locale(createdPassenger.user.lang || "en")
            .format("LLLL")
        : null;
      strapi.entityService.create("api::notification.notification", {
        data: {
          type: "ContactTripCreator",
          event: createdPassenger.event.id,
          user: createdPassenger.user.id,
          // @ts-expect-error
          payload: { travel, datetime },
        },
      });
    }

    const { toEntityResponse } = strapi
      .plugin("graphql")
      .service("format").returnTypes;

    return toEntityResponse(createdPassenger, {
      args,
      resourceUID: "api::passenger.passenger",
    });
  },
};

export default createPassenger;