feat: Outlook calendar cache

.env.example

@@ -145,9 +145,12 @@ GOOGLE_WEBHOOK_TOKEN=
 # Optional URL to override for tunelling webhooks. Defaults to NEXT_PUBLIC_WEBAPP_URL.
 GOOGLE_WEBHOOK_URL=
 
+# Microsoft Graph Client ID (required for Outlook calendar cache token refresh)
+MS_GRAPH_CLIENT_ID=
+# Microsoft Graph Client Secret (required for Outlook calendar cache token refresh)
+MS_GRAPH_CLIENT_SECRET=
 # Token to verify incoming webhooks from Microsoft Calendar
 MICROSOFT_WEBHOOK_TOKEN=
-
 # Optional URL to override for tunelling webhooks. Defaults to NEXT_PUBLIC_WEBAPP_URL.
 MICROSOFT_WEBHOOK_URL=
 

apps/web/app/api/webhooks/calendar-subscription/[provider]/__tests__/route.test.ts

@@ -160,7 +160,7 @@ describe("/api/webhooks/calendar-subscription/[provider]", () => {
 
       expect(response.status).toBe(200);
       const body = await response.json();
-      expect(body.message).toBe("Webhook processed");
+      expect(body).toEqual({});
       expect(mockProcessWebhook).toHaveBeenCalledWith("google_calendar", request);
     });
 
@@ -184,7 +184,7 @@ describe("/api/webhooks/calendar-subscription/[provider]", () => {
 
       expect(response.status).toBe(200);
       const body = await response.json();
-      expect(body.message).toBe("Webhook processed");
+      expect(body).toEqual({});
       expect(mockProcessWebhook).toHaveBeenCalledWith("google_calendar", request);
     });
 
@@ -208,7 +208,7 @@ describe("/api/webhooks/calendar-subscription/[provider]", () => {
 
       expect(response.status).toBe(200);
       const body = await response.json();
-      expect(body.message).toBe("Webhook processed");
+      expect(body).toEqual({});
       expect(mockProcessWebhook).toHaveBeenCalledWith("google_calendar", request);
     });
   });

apps/web/app/api/webhooks/calendar-subscription/[provider]/route.ts

@@ -67,6 +67,13 @@ async function postHandler(request: NextRequest, ctx: { params: Promise<Params>
       calendarCacheEventService,
     });
 
+    // only for office365 handshake validation
+    const url = new URL(request.url);
+    const validationToken = url.searchParams.get("validationToken");
+    if (validationToken) {
+      return new NextResponse(validationToken, { status: 200, headers: { "Content-Type": "text/plain" } });
+    }
+
     // are features globally enabled
     const [isCacheEnabled, isSyncEnabled] = await Promise.all([
       calendarSubscriptionService.isCacheEnabled(),
@@ -79,7 +86,7 @@ async function postHandler(request: NextRequest, ctx: { params: Promise<Params>
     }
 
     await calendarSubscriptionService.processWebhook(providerFromParams, request);
-    return NextResponse.json({ message: "Webhook processed" }, { status: 200 });
+    return NextResponse.json({}, { status: 200 });
   } catch (error) {
     log.error("Error processing webhook", { error });
     const message = error instanceof Error ? error.message : "Unknown error";

packages/features/calendar-subscription/adapters/AdaptersFactory.ts

@@ -54,6 +54,7 @@ export class DefaultAdapterFactory implements AdapterFactory {
    * @returns
    */
   getProviders(): CalendarSubscriptionProvider[] {
+    // TODO: add "office365_calendar" once the adapter is validated in production
     const providers: CalendarSubscriptionProvider[] = ["google_calendar"];
     return providers;
   }