Makes calendly api calls concurrent (#107)

package.json

@@ -47,6 +47,7 @@
     "next": "^13.5.6",
     "next-auth": "^4.24.5",
     "nodemailer": "^6.9.7",
+    "p-limit": "^6.1.0",
     "postcss": "^8.4.32",
     "react": "18.2.0",
     "react-calendar": "^5.0.0",

src/lib/volunteer/mentor.ts

@@ -2,6 +2,32 @@ import { prisma } from "@/lib/prisma";
 import { getAvailabilities } from "@/lib/calendly";
 import { getAccessToken } from "@/lib/oauth";
 import { UserAvailability } from "@/types/mentor.schema";
+import pLimit from "p-limit";
+import { ParticipationWithUserOauth } from "@/types/participation.schema";
+
+async function getAvailiabity(
+  participation: ParticipationWithUserOauth,
+  startTime: Date,
+  endTime: Date,
+): Promise<UserAvailability | null> {
+  const userOauth = participation.user.UserAuth.UserOauth[0];
+  const userAuthId = participation.user.UserAuth.id;
+  const availabilities = await getAvailabilities({
+    token: await getAccessToken(userAuthId, userOauth.provider, userOauth),
+    startTime,
+    endTime,
+  });
+
+  if (!availabilities) return null;
+
+  return {
+    volunteerAuthId: userAuthId,
+    volunteerParticipationId: participation.volunteerParticipationId!,
+    firstName: participation.user.firstName,
+    lastName: participation.user.lastName,
+    ...availabilities,
+  };
+}
 
 export async function getAllAvailabilities({
   ofmiEdition,
@@ -33,26 +59,23 @@ export async function getAllAvailabilities({
     },
   });
 
+  // Limit concurrent active promises to 5
+  const limit = pLimit(5);
   const mentors: Array<UserAvailability> = [];
-  for (const participation of mentorsDb) {
-    const userOauth = participation.user.UserAuth.UserOauth[0];
-    const userAuthId = participation.user.UserAuth.id;
-    const availabilities = await getAvailabilities({
-      token: await getAccessToken(userAuthId, userOauth.provider, userOauth),
-      startTime,
-      endTime,
-    });
-    if (!availabilities) {
-      continue;
+
+  const result = await Promise.allSettled(
+    mentorsDb.map((participation) =>
+      limit(() => getAvailiabity(participation, startTime, endTime)),
+    ),
+  );
+
+  result.map((res) => {
+    if (res.status === "fulfilled") {
+      if (res.value !== null) {
+        mentors.push(res.value);
+      }
     }
-    mentors.push({
-      volunteerAuthId: userAuthId,
-      volunteerParticipationId: participation.volunteerParticipationId!,
-      firstName: participation.user.firstName,
-      lastName: participation.user.lastName,
-      ...availabilities,
-    });
-  }
+  });
 
   return mentors;
 }

src/types/participation.schema.ts

@@ -2,6 +2,7 @@ import { Type, Static } from "@sinclair/typebox";
 import {
   Participation,
   ParticipationRole,
+  Prisma,
   SchoolStage,
   ShirtSize,
 } from "@prisma/client";
@@ -128,6 +129,20 @@ export const UpsertParticipationRequestSchema = Type.Omit(
   ["registeredAt"],
 );
 
+export type ParticipationWithUserOauth = Prisma.ParticipationGetPayload<{
+  include: {
+    user: {
+      include: {
+        UserAuth: {
+          include: {
+            UserOauth: true;
+          };
+        };
+      };
+    };
+  };
+}>;
+
 export interface UpsertParticipationResponse {
   participation: Participation;
 }