Get Microsoft access and refresh tokens for outlook calendar

controllers/calendar.ts

@@ -2,6 +2,8 @@ import { Request, Response } from "express";
 import Boom from "@hapi/boom";
 import { google } from "googleapis";
 import config from "config";
+import axios from "axios";
+import url from "url";
 import prisma from "../prisma/prisma";
 import {
   apiResponse,
@@ -12,6 +14,12 @@ import {
 
 const gcalClientId = config.get("providers.googleOauth20.clientId");
 const gcalClientSecret = config.get("providers.googleOauth20.clientSecret");
+const microsoftClientId: string = config.get(
+  "providers.microsoftOauth20.clientId"
+);
+const microsoftClientSecret: string = config.get(
+  "providers.microsoftOauth20.clientSecret"
+);
 const calApiUrl = config.get("services.calendarApi.baseUrl");
 
 const oauth2Client = new google.auth.OAuth2(
@@ -21,6 +29,7 @@ const oauth2Client = new google.auth.OAuth2(
 );
 
 const scopes = ["https://www.googleapis.com/auth/calendar"];
+const microsoftCalendarOAuthScopes = ["Calendars.ReadWrite", "offline_access"];
 
 const googleConnectHandler = (_: Request, res: Response): void => {
   const url = oauth2Client.generateAuthUrl({
@@ -39,6 +48,107 @@ const googleCallbackHandler = (_: Request, res: Response): void => {
   return res.redirect(redirectUrl);
 };
 
+const microsoftAuthorizationUrl = ({
+  tenant = "common",
+  clientId,
+  responseType = "code",
+  redirectUri,
+  responseMode = "query",
+  scope,
+  state,
+}: {
+  tenant?: string;
+  clientId: string;
+  responseType?: string;
+  redirectUri: string;
+  responseMode?: string;
+  scope: string[];
+  state?: string;
+}): string => {
+  return `https://login.microsoftonline.com/${tenant}/oauth2/v2.0/authorize?
+  client_id=${clientId}
+  &response_type=${responseType}
+  &redirect_uri=${redirectUri}
+  &response_mode=${responseMode}
+  &scope=${scope}
+  ${state ? `&state=${state}` : ""}
+`;
+};
+
+const microsoftConnectHandler = (_: Request, res: Response): void => {
+  const url = microsoftAuthorizationUrl({
+    clientId: microsoftClientId,
+    redirectUri: `${String(calApiUrl)}/api/v1/calendar/microsoft/callback`,
+    scope: microsoftCalendarOAuthScopes,
+  });
+  return res.redirect(url);
+};
+
+const microsoftCallbackHandler = async (
+  req: Request,
+  res: Response
+): Promise<any> => {
+  // TODO: fix return type
+  try {
+    const code = req.query.code as string;
+    if (!code) {
+      return res.boom(Boom.unauthorized("Cannot authorize"));
+    }
+    // const userData = req.userData;
+    const params = new url.URLSearchParams({
+      client_id: microsoftClientId,
+      scope: microsoftCalendarOAuthScopes,
+      code,
+      redirect_uri: `${String(calApiUrl)}/api/v1/calendar/microsoft/callback`,
+      grant_type: "authorization_code",
+      client_secret: microsoftClientSecret,
+    });
+
+    // TODO: Move axios call to wrapper
+    const responseTokens = await axios.post(
+      "https://login.microsoftonline.com/common/oauth2/v2.0/token",
+      params,
+      { headers: { "Content-Type": "application/x-www-form-urlencoded" } }
+    );
+
+    // TODO: add cases for 4xx and 5xx
+    if (responseTokens.status !== 200) {
+      return res.boom(Boom.unauthorized("Do not have enough permission"));
+    }
+
+    // TODO: verify the formate
+    // Add access tokens to db
+    /*
+    await prisma.accessToken.create({
+      data: {
+        userId: userData?.id as number,
+        associatedEmail: userData?.email as string, // TODO: add correct email here, assiciated with the microsoft account
+        calendarId: "1", // TODO: Add correct calendarId here
+        calendarType: "OUTLOOKCAL",
+        tokenType: "BEARER",
+        scope: responseTokens.data.scope,
+        expiry: new Date(
+          Number(new Date().getSeconds()) +
+          Number(responseTokens.data.expires_in)
+          ), // TODO: add expires_in seconds to current time
+          accessToken: responseTokens.data.access_token, // TODO: fix token too long error
+          refreshToken: responseTokens.data.refresh_token,
+        },
+      });
+    */
+
+    // Redirect to onbording after success
+    const redirectUrl = `${String(
+      config.get("services.rCalUi.baseUrl")
+    )}/onboarding`;
+
+    return res.redirect(redirectUrl);
+  } catch (err) {
+    logger.error("Error while fetching user microsoft calendar tokens", err);
+    return res.boom(Boom.badImplementation());
+  }
+};
+
 const getUserCalendar = async (
   req: Request,
   res: Response
@@ -105,4 +215,10 @@ const getUserCalendar = async (
   }
 };
 
-export { googleConnectHandler, googleCallbackHandler, getUserCalendar };
+export {
+  googleConnectHandler,
+  googleCallbackHandler,
+  getUserCalendar,
+  microsoftConnectHandler,
+  microsoftCallbackHandler,
+};