chore: Sync Services to update external tools

.env.example

@@ -130,3 +130,9 @@ EMAIL_SERVER_PASSWORD='<office365_password>'
 
 # Set the following value to true if you wish to enable Team Impersonation
 NEXT_PUBLIC_TEAM_IMPERSONATION=false
+
+# Close.com internal CRM
+CLOSECOM_API_KEY=
+
+# Sendgrid internal email sender
+SENDGRID_API_KEY=

apps/web/package.json

@@ -97,6 +97,7 @@
     "nodemailer": "^6.7.7",
     "otplib": "^12.0.1",
     "qrcode": "^1.5.1",
+    "raw-body": "^2.5.1",
     "react": "^18.2.0",
     "react-colorful": "^5.5.1",
     "react-date-picker": "^8.3.6",

apps/web/pages/api/auth/signup.ts

@@ -1,6 +1,7 @@
 import { IdentityProvider } from "@prisma/client";
 import { NextApiRequest, NextApiResponse } from "next";
 
+import { closeComUpsertTeamUser } from "@calcom/lib/sync/SyncServiceManager";
 import prisma from "@calcom/prisma";
 
 import { hashPassword } from "@lib/auth";
@@ -71,14 +72,23 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
 
   // If user has been invitedTo a team, we accept the membership
   if (user.invitedTo) {
-    await prisma.membership.update({
-      where: {
-        userId_teamId: { userId: user.id, teamId: user.invitedTo },
-      },
-      data: {
-        accepted: true,
-      },
+    const team = await prisma.team.findFirst({
+      where: { id: user.invitedTo },
     });
+
+    if (team) {
+      const membership = await prisma.membership.update({
+        where: {
+          userId_teamId: { userId: user.id, teamId: user.invitedTo },
+        },
+        data: {
+          accepted: true,
+        },
+      });
+
+      // Sync Services: Close.com
+      closeComUpsertTeamUser(team, user, membership.role);
+    }
   }
 
   res.status(201).json({ message: "Created user" });

apps/web/pages/api/book/event.ts

@@ -28,6 +28,7 @@ import isOutOfBounds, { BookingDateInPastError } from "@calcom/lib/isOutOfBounds
 import logger from "@calcom/lib/logger";
 import { getLuckyUser } from "@calcom/lib/server";
 import { defaultResponder } from "@calcom/lib/server";
+import { updateWebUser as syncServicesUpdateWebUser } from "@calcom/lib/sync/SyncServiceManager";
 import prisma, { userSelect } from "@calcom/prisma";
 import { extendedBookingCreateBody } from "@calcom/prisma/zod-utils";
 import type { BufferedBusyTime } from "@calcom/types/BufferedBusyTime";
@@ -673,6 +674,14 @@ async function handler(req: NextApiRequest) {
   let booking: Booking | null = null;
   try {
     booking = await createBooking();
+    // Sync Services
+    await syncServicesUpdateWebUser(
+      currentUser &&
+        (await prisma.user.findFirst({
+          where: { id: currentUser.id },
+          select: { id: true, email: true, name: true, plan: true, username: true, createdDate: true },
+        }))
+    );
     evt.uid = booking?.uid ?? null;
   } catch (_err) {
     const err = getErrorFromUnknown(_err);

apps/web/pages/api/sync/helpscout/index.ts

@@ -0,0 +1,89 @@
+import { createHmac } from "crypto";
+import type { NextApiRequest, NextApiResponse } from "next";
+import getRawBody from "raw-body";
+import z from "zod";
+
+import { default as webPrisma } from "@calcom/prisma";
+
+export const config = {
+  api: {
+    bodyParser: false,
+  },
+};
+
+const helpscoutRequestBodySchema = z.object({
+  customer: z.object({
+    email: z.string().email(),
+  }),
+});
+
+/**
+ * API for Helpscout to retrieve key information about a user from a ticket
+ * Note: HelpScout expects a JSON with a `html` prop to show its content as HTML
+ */
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  if (req.method !== "POST") return res.status(405).json({ message: "Method not allowed" });
+
+  const hsSignature = req.headers["x-helpscout-signature"];
+  if (!hsSignature) return res.status(400).end();
+
+  if (!process.env.CALENDSO_ENCRYPTION_KEY) return res.status(500).end();
+
+  const rawBody = await getRawBody(req);
+  const parsedBody = helpscoutRequestBodySchema.safeParse(JSON.parse(rawBody.toString()));
+
+  if (!parsedBody.success) return res.status(400).end();
+
+  const calculatedSig = createHmac("sha1", process.env.CALENDSO_ENCRYPTION_KEY)
+    .update(rawBody)
+    .digest("base64");
+
+  if (req.headers["x-helpscout-signature"] !== calculatedSig) return res.status(400).end();
+
+  const user = await webPrisma.user.findFirst({
+    where: {
+      email: parsedBody.data.customer.email,
+    },
+    select: {
+      username: true,
+      id: true,
+      plan: true,
+      createdDate: true,
+    },
+  });
+
+  if (!user) return res.status(200).json({ html: "User not found" });
+
+  const lastBooking = await webPrisma.attendee.findFirst({
+    where: {
+      email: parsedBody.data.customer.email,
+    },
+    select: {
+      booking: {
+        select: {
+          createdAt: true,
+        },
+      },
+    },
+    orderBy: {
+      booking: {
+        createdAt: "desc",
+      },
+    },
+  });
+
+  return res.status(200).json({
+    html: `
+      <ul>
+        <li><b>Username:</b>&nbsp;${user.username}</li>
+        <li><b>Last booking:</b>&nbsp;${
+          lastBooking && lastBooking.booking
+            ? new Date(lastBooking.booking.createdAt).toLocaleDateString("en-US")
+            : "No info"
+        }</li>
+        <li><b>Plan:</b>&nbsp;${user.plan}</li>
+        <li><b>Account created:</b>&nbsp;${new Date(user.createdDate).toLocaleDateString("en-US")}</li>
+      </ul>
+    `,
+  });
+}

apps/web/pages/api/teams.ts

@@ -1,5 +1,7 @@
+import { MembershipRole } from "@prisma/client";
 import type { NextApiRequest, NextApiResponse } from "next";
 
+import { closeComUpsertTeamUser } from "@calcom/lib/sync/SyncServiceManager";
 import prisma from "@calcom/prisma";
 
 import { getSession } from "@lib/auth";
@@ -13,6 +15,20 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
     return;
   }
 
+  const ownerUser = await prisma.user.findFirst({
+    where: {
+      id: session.user.id,
+    },
+    select: {
+      id: true,
+      username: true,
+      createdDate: true,
+      name: true,
+      plan: true,
+      email: true,
+    },
+  });
+
   if (req.method === "POST") {
     const slug = slugify(req.body.name);
 
@@ -37,11 +53,14 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
       data: {
         teamId: createTeam.id,
         userId: session.user.id,
-        role: "OWNER",
+        role: MembershipRole.OWNER,
         accepted: true,
       },
     });
 
+    // Sync Services: Close.com
+    closeComUpsertTeamUser(createTeam, ownerUser, MembershipRole.OWNER);
+
     return res.status(201).json({ message: "Team created" });
   }
 

apps/web/pages/api/teams/[team]/index.ts

@@ -1,6 +1,7 @@
 import type { NextApiRequest, NextApiResponse } from "next";
 
 import { getTeamWithMembers } from "@calcom/lib/server/queries/teams";
+import { closeComDeleteTeam } from "@calcom/lib/sync/SyncServiceManager";
 import prisma from "@calcom/prisma";
 
 import { getSession } from "@lib/auth";
@@ -45,11 +46,15 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
         userId_teamId: { userId: session.user.id, teamId },
       },
     });
-    await prisma.team.delete({
+    const deletedTeam = await prisma.team.delete({
       where: {
         id: teamId,
       },
     });
+
+    // Sync Services: Close.com
+    closeComDeleteTeam(deletedTeam);
+
     return res.status(204).send(null);
   }
 }

apps/web/pages/api/teams/[team]/membership.ts

@@ -1,5 +1,6 @@
 import type { NextApiRequest, NextApiResponse } from "next";
 
+import { closeComDeleteTeamMembership } from "@calcom/lib/sync/SyncServiceManager";
 import prisma from "@calcom/prisma";
 
 import { getSession } from "@lib/auth";
@@ -63,11 +64,19 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
 
   // Cancel a membership (invite)
   if (req.method === "DELETE") {
+    const user = await prisma.user.findFirst({
+      where: {
+        id: req.body.userId,
+      },
+    });
     await prisma.membership.delete({
       where: {
         userId_teamId: { userId: req.body.userId, teamId: parseInt(req.query.team as string) },
       },
     });
+    // Sync Services: Close.com
+    closeComDeleteTeamMembership(user);
+
     return res.status(204).send(null);
   }
 

apps/web/pages/api/user/me.ts

@@ -1,6 +1,7 @@
 import type { NextApiRequest, NextApiResponse } from "next";
 
 import { deleteStripeCustomer } from "@calcom/app-store/stripepayment/lib/customer";
+import { deleteWebUser as syncServicesDeleteWebUser } from "@calcom/lib/sync/SyncServiceManager";
 import prisma from "@calcom/prisma";
 
 import { getSession } from "@lib/auth";
@@ -24,8 +25,13 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
         id: session.user?.id,
       },
       select: {
+        id: true,
         email: true,
         metadata: true,
+        username: true,
+        createdDate: true,
+        name: true,
+        plan: true,
       },
     });
     // Delete from stripe
@@ -37,6 +43,9 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
       },
     });
 
+    // Sync Services
+    syncServicesDeleteWebUser(user);
+
     return res.status(204).end();
   }
 }