feat: outlook cache and change notifications webhook

.env.example

@@ -149,6 +149,11 @@ GOOGLE_WEBHOOK_TOKEN=
 # Optional URL to override for tunelling webhooks. Defaults to NEXT_PUBLIC_WEBAPP_URL.
 GOOGLE_WEBHOOK_URL=
 
+# Token to verify incoming webhooks from Microsoft Outlook
+OUTLOOK_WEBHOOK_TOKEN=
+# Optional URL to override for tunelling webhooks. Defaults to NEXT_PUBLIC_WEBAPP_URL.
+OUTLOOK_WEBHOOK_URL=
+
 # Inbox to send user feedback
 SEND_FEEDBACK_EMAIL=
 

apps/api/v1/test/lib/selected-calendars/_post.test.ts

@@ -89,6 +89,8 @@ describe("POST /api/selected-calendars", () => {
         googleChannelResourceUri: null,
         googleChannelExpiration: null,
         error: null,
+        outlookSubscriptionExpiration: null,
+        outlookSubscriptionId: null,
         lastErrorAt: null,
         watchAttempts: 0,
         maxAttempts: 3,
@@ -134,6 +136,8 @@ describe("POST /api/selected-calendars", () => {
         domainWideDelegationCredentialId: null,
         eventTypeId: null,
         error: null,
+        outlookSubscriptionExpiration: null,
+        outlookSubscriptionId: null,
         lastErrorAt: null,
         watchAttempts: 0,
         maxAttempts: 3,

packages/app-store/office365calendar/api/index.ts

@@ -1,2 +1,3 @@
 export { default as add } from "./add";
 export { default as callback } from "./callback";
+export { default as webhook } from "./webhook";

packages/app-store/office365calendar/api/webhook.ts

@@ -0,0 +1,106 @@
+import type { NextApiRequest, NextApiResponse } from "next";
+
+import { uniqueBy } from "@calcom/lib/array";
+import { getCredentialForCalendarCache } from "@calcom/lib/delegationCredential/server";
+import logger from "@calcom/lib/logger";
+import { safeStringify } from "@calcom/lib/safeStringify";
+import { SelectedCalendarRepository } from "@calcom/lib/server/repository/selectedCalendar";
+
+import { getCalendar } from "../../_utils/getCalendar";
+import { graphValidationTokenChallengeSchema, changeNotificationWebhookPayloadSchema } from "../zod";
+
+const log = logger.getSubLogger({ prefix: ["Office365CalendarWebhook"] });
+
+interface WebhookResponse {
+  [key: string]: {
+    processed: boolean;
+    message?: string;
+  };
+}
+
+function isApiKeyValid(clientState?: string) {
+  return clientState === process.env.OUTLOOK_WEBHOOK_TOKEN;
+}
+
+function getValidationToken(req: NextApiRequest) {
+  const graphValidationTokenChallengeParseRes = graphValidationTokenChallengeSchema.safeParse(req.query);
+  if (!graphValidationTokenChallengeParseRes.success) {
+    return null;
+  }
+
+  return graphValidationTokenChallengeParseRes.data.validationToken;
+}
+
+async function postHandler(req: NextApiRequest, res: NextApiResponse) {
+  const validationToken = getValidationToken(req);
+  if (validationToken) {
+    res.setHeader("Content-Type", "text/plain");
+    return res.status(200).send(validationToken);
+  }
+
+  const webhookBodyParseRes = changeNotificationWebhookPayloadSchema.safeParse(req.body);
+
+  if (!webhookBodyParseRes.success) {
+    log.error("postHandler", safeStringify(webhookBodyParseRes.error));
+    return res.status(400).json({
+      message: "Invalid request body",
+    });
+  }
+
+  const events = webhookBodyParseRes.data.value;
+  const body: WebhookResponse = {};
+
+  const uniqueEvents = uniqueBy(events, ["subscriptionId"]);
+
+  const promises = uniqueEvents.map(async (event) => {
+    if (!isApiKeyValid(event.clientState)) {
+      body[event.subscriptionId] = {
+        processed: false,
+        message: "Invalid API key",
+      };
+      return;
+    }
+
+    const selectedCalendar = await SelectedCalendarRepository.findByOutlookSubscriptionId(
+      event.subscriptionId
+    );
+    if (!selectedCalendar) {
+      body[event.subscriptionId] = {
+        processed: false,
+        message: `No selected calendar found for outlookSubscriptionId: ${event.subscriptionId}`,
+      };
+      return;
+    }
+
+    const { credential } = selectedCalendar;
+    if (!credential) {
+      body[event.subscriptionId] = {
+        processed: false,
+        message: `No credential found for selected calendar for outlookSubscriptionId: ${event.subscriptionId}`,
+      };
+      return;
+    }
+
+    const { selectedCalendars } = credential;
+    const credentialForCalendarCache = await getCredentialForCalendarCache({ credentialId: credential.id });
+    const calendarServiceForCalendarCache = await getCalendar(credentialForCalendarCache);
+
+    await calendarServiceForCalendarCache?.fetchAvailabilityAndSetCache?.(selectedCalendars);
+    body[event.subscriptionId] = {
+      processed: true,
+      message: "ok",
+    };
+    return;
+  });
+
+  await Promise.all(promises);
+
+  return res.status(200).json(body);
+}
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+  if (req.method === "POST") return postHandler(req, res);
+
+  res.setHeader("Allow", "POST");
+  return res.status(405).json({});
+}