feat: Canva OAuth Configuration (#337)

Author: siddharth-bhansali

oauth/src/connections/canva/init.ts

@@ -0,0 +1,56 @@
+import axios from 'axios';
+import { DataObject, OAuthResponse } from '../../lib/types';
+import qs from 'qs';
+import 'dotenv/config';
+import { base64UrlEncode } from '../../lib/helpers';
+
+export const init = async ({ body }: DataObject): Promise<OAuthResponse> => {
+    try {
+        const {
+            clientId: client_id,
+            clientSecret: client_secret,
+            metadata: { code, redirectUri: redirect_uri } = {},
+        } = body;
+
+        const data = qs.stringify({
+            code,
+            redirect_uri,
+            grant_type: 'authorization_code',
+            code_verifier: process.env.CANVA_CODE_VERIFIER,
+        });
+
+        const authorizationToken = await base64UrlEncode(
+            `${client_id}:${client_secret}`,
+        );
+
+        const response = await axios({
+            url: 'https://api.canva.com/rest/v1/oauth/token',
+            method: 'POST',
+            headers: {
+                Accept: 'application/json',
+                'Content-Type': 'application/x-www-form-urlencoded',
+                Authorization: `Basic ${authorizationToken}`,
+            },
+            data,
+        });
+
+        const {
+            data: {
+                access_token: accessToken,
+                refresh_token: refreshToken,
+                token_type: tokenType,
+                expires_in: expiresIn,
+            },
+        } = response;
+
+        return {
+            accessToken,
+            refreshToken,
+            expiresIn,
+            tokenType: tokenType === 'bearer' ? 'Bearer' : tokenType,
+            meta: {},
+        };
+    } catch (error) {
+        throw new Error(`Error fetching access token for Canva: ${error}`);
+    }
+};

oauth/src/connections/canva/refresh.ts

@@ -0,0 +1,53 @@
+import { DataObject, OAuthResponse } from '../../lib/types';
+import axios from 'axios';
+import { base64UrlEncode } from '../../lib/helpers';
+import qs from 'qs';
+
+export const refresh = async ({ body }: DataObject): Promise<OAuthResponse> => {
+    try {
+        const {
+            OAUTH_CLIENT_ID: client_id,
+            OAUTH_CLIENT_SECRET: client_secret,
+            OAUTH_REFRESH_TOKEN: refresh_token,
+        } = body;
+
+        const data = qs.stringify({
+            refresh_token,
+            grant_type: 'refresh_token',
+        });
+
+        const authorizationToken = await base64UrlEncode(
+            `${client_id}:${client_secret}`,
+        );
+
+        const response = await axios({
+            url: 'https://api.canva.com/rest/v1/oauth/token',
+            method: 'POST',
+            headers: {
+                Accept: 'application/json',
+                'Content-Type': 'application/x-www-form-urlencoded',
+                Authorization: `Basic ${authorizationToken}`,
+            },
+            data,
+        });
+
+        const {
+            data: {
+                access_token: accessToken,
+                refresh_token: refreshToken,
+                token_type: tokenType,
+                expires_in: expiresIn,
+            },
+        } = response;
+
+        return {
+            accessToken,
+            refreshToken,
+            expiresIn,
+            tokenType,
+            meta: {},
+        };
+    } catch (error) {
+        throw new Error(`Error fetching refresh token for Canva: ${error}`);
+    }
+};

oauth/src/connections/contentstackContentManagement/init.ts

@@ -0,0 +1,68 @@
+import axios from 'axios';
+import qs from 'qs';
+import { DataObject, OAuthResponse } from '../../lib/types';
+
+export const init = async ({ body }: DataObject): Promise<OAuthResponse> => {
+    try {
+        const {
+            clientId: client_id,
+            clientSecret: client_secret,
+            metadata: {
+                code,
+                redirectUri: redirect_uri,
+                formData: { CONTENTSTACK_CONTENT_MANAGEMENT_STACK_API_KEY },
+            },
+        } = body;
+
+        const requestBody = {
+            grant_type: 'authorization_code',
+            code,
+            client_id,
+            client_secret,
+            redirect_uri,
+        };
+
+        const response = await axios({
+            url: 'https://app.contentstack.com/apps-api/token',
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/x-www-form-urlencoded',
+                Accept: 'application/json',
+            },
+            data: qs.stringify(requestBody),
+        });
+
+        const {
+            access_token: accessToken,
+            refresh_token: refreshToken,
+            token_type: tokenType,
+            expires_in: expiresIn,
+            organization_uid: organizationUid,
+        } = response.data;
+
+        await axios({
+            url: 'https://api.contentstack.io/v3/stacks/settings',
+            method: 'GET',
+            headers: {
+                'Content-Type': 'application/json',
+                Authorization: `Bearer ${accessToken}`,
+                api_key: CONTENTSTACK_CONTENT_MANAGEMENT_STACK_API_KEY,
+            },
+        });
+
+        return {
+            accessToken,
+            refreshToken,
+            expiresIn,
+            tokenType: tokenType === 'bearer' ? 'Bearer' : tokenType,
+            meta: {
+                organizationUid,
+                stackApiKey: CONTENTSTACK_CONTENT_MANAGEMENT_STACK_API_KEY,
+            },
+        };
+    } catch (error) {
+        throw new Error(
+            `Error fetching access token for Contentstack Content Management: ${error}`,
+        );
+    }
+};

oauth/src/connections/contentstackContentManagement/refresh.ts

@@ -0,0 +1,52 @@
+import axios from 'axios';
+import qs from 'qs';
+import { DataObject, OAuthResponse } from '../../lib/types';
+
+export const refresh = async ({ body }: DataObject): Promise<OAuthResponse> => {
+    try {
+        const {
+            OAUTH_CLIENT_ID: client_id,
+            OAUTH_CLIENT_SECRET: client_secret,
+            OAUTH_REFRESH_TOKEN: refresh_token,
+            OAUTH_METADATA: { meta },
+            OAUTH_REQUEST_PAYLOAD: { redirectUri: redirect_uri },
+        } = body;
+
+        const requestBody = {
+            grant_type: 'refresh_token',
+            refresh_token,
+            client_id,
+            client_secret,
+            redirect_uri,
+        };
+
+        const response = await axios({
+            url: 'https://app.contentstack.com/apps-api/token',
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/x-www-form-urlencoded',
+                Accept: 'application/json',
+            },
+            data: qs.stringify(requestBody),
+        });
+
+        const {
+            access_token: accessToken,
+            refresh_token: refreshToken,
+            token_type: tokenType,
+            expires_in: expiresIn,
+        } = response.data;
+
+        return {
+            accessToken,
+            refreshToken,
+            expiresIn,
+            tokenType: tokenType === 'bearer' ? 'Bearer' : tokenType,
+            meta,
+        };
+    } catch (error) {
+        throw new Error(
+            `Error fetching access token for Contentstack Content Management: ${error}`,
+        );
+    }
+};

oauth/src/connections/zoho/refresh.ts

@@ -26,7 +26,7 @@ export const refresh = async ({ body }: DataObject): Promise<OAuthResponse> => {
             },
         } = response;
 
-        // Update refresh token if a new token is allocated
+        // Update the refresh token if a new token is allocated
         if (response.data.refresh_token) {
             refreshToken = response.data.refresh_token;
         }