Multi-user/multi-ticket creation API (#265)

fforres · web-flow · commit 550d61e81517 · 2024-08-21T15:51:01.000-04:00
diff --git a/src/generated/schema.gql b/src/generated/schema.gql
@@ -277,8 +277,9 @@ input GeneratePaymentLinkInput {
 
 input GiftTicketsToUserInput {
   allowMultipleTicketsPerUsers: Boolean!
+  autoApproveTickets: Boolean!
   notifyUsers: Boolean!
-  ticketId: String!
+  ticketIds: [String!]!
   userIds: [String!]!
 }
 
@@ -1261,8 +1262,15 @@ type WorkSeniority {
 }
 
 input placeHolderUsersInput {
+  ciudad: String
   email: String!
+  emergencyPhoneNumber: String
+  foodAllergies: String
   name: String!
+  nombreOrganizacion: String
+  pais: String
+  rolEnOrganizacion: String
+  trabajasEnOrganizacion: String
 }
 
 input updateUserDataInput {
diff --git a/src/generated/types.ts b/src/generated/types.ts
@@ -295,8 +295,9 @@ export type GeneratePaymentLinkInput = {
 
 export type GiftTicketsToUserInput = {
   allowMultipleTicketsPerUsers: Scalars["Boolean"]["input"];
+  autoApproveTickets: Scalars["Boolean"]["input"];
   notifyUsers: Scalars["Boolean"]["input"];
-  ticketId: Scalars["String"]["input"];
+  ticketIds: Array<Scalars["String"]["input"]>;
   userIds: Array<Scalars["String"]["input"]>;
 };
 
@@ -1279,8 +1280,15 @@ export type WorkSeniority = {
 };
 
 export type PlaceHolderUsersInput = {
+  ciudad?: InputMaybe<Scalars["String"]["input"]>;
   email: Scalars["String"]["input"];
+  emergencyPhoneNumber?: InputMaybe<Scalars["String"]["input"]>;
+  foodAllergies?: InputMaybe<Scalars["String"]["input"]>;
   name: Scalars["String"]["input"];
+  nombreOrganizacion?: InputMaybe<Scalars["String"]["input"]>;
+  pais?: InputMaybe<Scalars["String"]["input"]>;
+  rolEnOrganizacion?: InputMaybe<Scalars["String"]["input"]>;
+  trabajasEnOrganizacion?: InputMaybe<Scalars["String"]["input"]>;
 };
 
 export type UpdateUserDataInput = {
diff --git a/src/notifications/tickets.ts b/src/notifications/tickets.ts
@@ -1,5 +1,4 @@
 import { ORM_TYPE } from "~/datasources/db";
-import { USER } from "~/datasources/db/users";
 import {
   insertUserTicketsEmailLogSchema,
   userTicketsEmailLogSchema,
@@ -89,7 +88,6 @@ export const sendAddedToWaitlistEmail = async ({
 
 export const sendTicketInvitationEmails = async ({
   DB,
-  logger,
   userTicketIds,
   RPC_SERVICE_EMAIL,
 }: {
diff --git a/src/schema/events/types.ts b/src/schema/events/types.ts
@@ -20,7 +20,7 @@ import {
 import { getImagesBySanityEventId } from "~/datasources/sanity/images";
 import { eventsFetcher } from "~/schema/events/eventsFetcher";
 import { schedulesFetcher } from "~/schema/schedules/schedulesFetcher";
-import { ScheduleLoadable, ScheduleRef } from "~/schema/schedules/types";
+import { ScheduleRef } from "~/schema/schedules/types";
 import {
   CommunityRef,
   EventRef,
diff --git a/src/schema/invitations/mutations.ts b/src/schema/invitations/mutations.ts
@@ -1,4 +1,3 @@
-import { eq } from "drizzle-orm";
 import { GraphQLError } from "graphql";
 
 import { builder } from "~/builder";
@@ -8,16 +7,20 @@ import {
   userTicketsSchema,
 } from "~/datasources/db/schema";
 import { applicationError, ServiceErrors } from "~/errors";
-import { sendTicketInvitationEmails } from "~/notifications/tickets";
+import {
+  sendActualUserTicketQREmails,
+  sendTicketInvitationEmails,
+} from "~/notifications/tickets";
 import { createInitialPurchaseOrder } from "~/schema/purchaseOrder/helpers";
 import { UserTicketRef } from "~/schema/shared/refs";
 import { ticketsFetcher } from "~/schema/ticket/ticketsFetcher";
 
 const GiftTicketsToUserInput = builder.inputType("GiftTicketsToUserInput", {
   fields: (t) => ({
-    ticketId: t.string({ required: true }),
+    ticketIds: t.stringList({ required: true }),
     userIds: t.stringList({ required: true }),
     allowMultipleTicketsPerUsers: t.boolean({ required: true }),
+    autoApproveTickets: t.boolean({ required: true }),
     notifyUsers: t.boolean({ required: true }),
   }),
 });
@@ -43,8 +46,13 @@ builder.mutationField("giftTicketsToUsers", (t) =>
         throw new GraphQLError("User not found");
       }
 
-      const { ticketId, allowMultipleTicketsPerUsers, notifyUsers } = input;
-      let userIds = input.userIds;
+      const {
+        ticketIds,
+        allowMultipleTicketsPerUsers,
+        notifyUsers,
+        autoApproveTickets,
+        userIds,
+      } = input;
 
       if (userIds.length === 0) {
         throw applicationError(
@@ -54,46 +62,92 @@ builder.mutationField("giftTicketsToUsers", (t) =>
         );
       }
 
-      const tickets = await ticketsFetcher.searchTickets({
+      const actualTickets = await ticketsFetcher.searchTickets({
         DB,
         search: {
-          ticketIds: [ticketId],
+          ticketIds,
         },
       });
+      const actualTicketIds = actualTickets.map((ticket) => ticket.id);
 
-      const ticket = tickets[0];
+      const usersWithTickets = await DB.query.userTicketsSchema.findMany({
+        where: (u, { and, inArray }) =>
+          and(
+            inArray(u.userId, userIds),
+            inArray(u.ticketTemplateId, actualTicketIds),
+          ),
+      });
 
-      if (!ticket) {
+      let ticketTemplatesUsersMap = new Map<string, Set<string>>();
+
+      for (const ticket of actualTickets) {
+        ticketTemplatesUsersMap.set(ticket.id, new Set());
+      }
+
+      usersWithTickets.forEach((userWithTicket) => {
+        if (userWithTicket.userId) {
+          ticketTemplatesUsersMap
+            .get(userWithTicket.ticketTemplateId)
+            ?.add(userWithTicket.userId);
+        }
+      });
+
+      if (ticketTemplatesUsersMap.size === 0) {
         throw applicationError(
           "Ticket not found",
           ServiceErrors.NOT_FOUND,
           logger,
         );
       }
 
+      if (!allowMultipleTicketsPerUsers) {
+        const clearedTicketTemplatesUserMap = new Map<string, Set<string>>();
+
+        ticketTemplatesUsersMap.forEach((existingUserSet, ticketTemplateId) => {
+          const newUserSet = new Set<string>();
+
+          userIds.forEach((userId) => {
+            if (!existingUserSet.has(userId)) {
+              newUserSet.add(userId);
+            }
+          });
+
+          clearedTicketTemplatesUserMap.set(ticketTemplateId, newUserSet);
+        });
+
+        ticketTemplatesUsersMap = clearedTicketTemplatesUserMap;
+      }
+
+      if (userIds.length === 0) {
+        throw applicationError(
+          "All provided users already have tickets",
+          ServiceErrors.INVALID_ARGUMENT,
+          logger,
+        );
+      }
+
       const purchaseOrder = await createInitialPurchaseOrder({
         DB,
         logger,
         userId: USER.id,
       });
 
-      if (!allowMultipleTicketsPerUsers) {
-        const usersWithTickets = await DB.query.userTicketsSchema.findMany({
-          where: (u, { and, inArray }) =>
-            and(inArray(u.userId, userIds), eq(u.ticketTemplateId, ticket.id)),
-          columns: {
-            userId: true,
-          },
-        });
+      const ticketsToInsert: (typeof insertUserTicketsSchema._type)[] = [];
 
-        const userIdsWithTickets = new Set(
-          usersWithTickets.map((user) => user.userId),
-        );
+      ticketTemplatesUsersMap.forEach((userSet, ticketTemplateId) => {
+        userSet.forEach((userId) => {
+          const parsedData = insertUserTicketsSchema.parse({
+            userId,
+            ticketTemplateId,
+            purchaseOrderId: purchaseOrder.id,
+            approvalStatus: autoApproveTickets ? "approved" : "gifted",
+          });
 
-        userIds = userIds.filter((userId) => !userIdsWithTickets.has(userId));
-      }
+          ticketsToInsert.push(parsedData);
+        });
+      });
 
-      if (userIds.length === 0) {
+      if (!ticketsToInsert.length) {
         throw applicationError(
           "All provided users already have tickets",
           ServiceErrors.INVALID_ARGUMENT,
@@ -102,29 +156,29 @@ builder.mutationField("giftTicketsToUsers", (t) =>
       }
 
       const createdUserTickets = await DB.insert(userTicketsSchema)
-        .values(
-          userIds.map((userId) =>
-            insertUserTicketsSchema.parse({
-              userId,
-              ticketTemplateId: ticket.id,
-              purchaseOrderId: purchaseOrder.id,
-              approvalStatus: "gifted",
-            }),
-          ),
-        )
+        .values(ticketsToInsert)
         .returning();
 
       if (notifyUsers) {
         const userTicketIds = createdUserTickets.map(
           (userTicket) => userTicket.id,
         );
 
-        await sendTicketInvitationEmails({
-          DB,
-          logger,
-          userTicketIds,
-          RPC_SERVICE_EMAIL,
-        });
+        if (autoApproveTickets) {
+          await sendActualUserTicketQREmails({
+            DB,
+            logger,
+            userTicketIds,
+            RPC_SERVICE_EMAIL,
+          });
+        } else {
+          await sendTicketInvitationEmails({
+            DB,
+            logger,
+            userTicketIds,
+            RPC_SERVICE_EMAIL,
+          });
+        }
       }
 
       return createdUserTickets.map((userTicket) =>
diff --git a/src/schema/invitations/tests/giftTicketsToUsers.test.ts b/src/schema/invitations/tests/giftTicketsToUsers.test.ts
@@ -29,10 +29,11 @@ describe("Should send tickets to users in bulk", () => {
       document: GiftTicketsToUsers,
       variables: {
         input: {
-          allowMultipleTicketsPerUsers: true,
-          ticketId: ticket.id,
+          allowMultipleTicketsPerUsers: false,
+          ticketIds: [ticket.id],
           userIds: [user1.id, user2.id],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
@@ -57,10 +58,11 @@ describe("Should send tickets to users in bulk", () => {
       document: GiftTicketsToUsers,
       variables: {
         input: {
-          allowMultipleTicketsPerUsers: true,
-          ticketId: ticket.id,
+          allowMultipleTicketsPerUsers: false,
+          ticketIds: [ticket.id],
           userIds: [user1.id],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
@@ -73,9 +75,10 @@ describe("Should send tickets to users in bulk", () => {
       variables: {
         input: {
           allowMultipleTicketsPerUsers: false,
-          ticketId: ticket.id,
+          ticketIds: [ticket.id],
           userIds: [user1.id, user2.id],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
@@ -100,10 +103,11 @@ describe("Should fail send tickets to users in bulk", () => {
       document: GiftTicketsToUsers,
       variables: {
         input: {
-          allowMultipleTicketsPerUsers: true,
-          ticketId: ticket.id,
+          allowMultipleTicketsPerUsers: false,
+          ticketIds: [ticket.id],
           userIds: [],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
@@ -127,9 +131,10 @@ describe("Should fail send tickets to users in bulk", () => {
       variables: {
         input: {
           allowMultipleTicketsPerUsers: false,
-          ticketId: ticket.id,
+          ticketIds: [ticket.id],
           userIds: [user1.id, user2.id],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
@@ -141,9 +146,10 @@ describe("Should fail send tickets to users in bulk", () => {
       variables: {
         input: {
           allowMultipleTicketsPerUsers: false,
-          ticketId: ticket.id,
+          ticketIds: [ticket.id],
           userIds: [user1.id, user2.id],
           notifyUsers: false,
+          autoApproveTickets: false,
         },
       },
     });
