feat: discord integration

fern/definition/internal/account.yml

@@ -44,6 +44,7 @@ service:
                         tpId: types.TPID
                         isRevertApp: boolean
                         appId: string
+                        botToken: optional<string>
             response: types.App
             errors:
                 - errors.UnAuthorizedError

packages/backend/config.ts

@@ -33,6 +33,9 @@ const config = {
     LOOPS_API_KEY: process.env.LOOPS_API_KEY,
     CLOSECRM_CLIENT_ID: process.env.CLOSECRM_CLIENT_ID!,
     CLOSECRM_CLIENT_SECRET: process.env.CLOSECRM_CLIENT_SECRET!,
+    DISCORD_CLIENT_ID: process.env.DISCORD_CLIENT_ID!,
+    DISCORD_CLIENT_SECRET: process.env.DISCORD_CLIENT_SECRET!,
+    DISCORD_BOT_TOKEN: process.env.DISCORD_BOT_TOKEN!,
 };
 
 export default config;

packages/backend/constants/common.ts

@@ -1,7 +1,7 @@
 import { TP_ID } from '@prisma/client';
 
 export type CRM_TP_ID = 'zohocrm' | 'sfdc' | 'pipedrive' | 'hubspot' | 'closecrm';
-// export type CHAT_TP_ID = 'slack';
+export type CHAT_TP_ID = 'slack' | 'discord';
 
 export const DEFAULT_SCOPE = {
     [TP_ID.hubspot]: [
@@ -39,6 +39,7 @@ export const DEFAULT_SCOPE = {
     [TP_ID.pipedrive]: [],
     [TP_ID.slack]: ['users:read', 'users.profile:read'],
     [TP_ID.closecrm]: [],
+    [TP_ID.discord]: ['identify', 'bot'],
 };
 
 export const mapIntegrationIdToIntegrationName = {
@@ -48,6 +49,7 @@ export const mapIntegrationIdToIntegrationName = {
     [TP_ID.zohocrm]: 'Zoho',
     [TP_ID.slack]: 'Slack',
     [TP_ID.closecrm]: 'Close',
+    [TP_ID.discord]: 'Discord',
 };
 
 export const rootSchemaMappingId = 'revertRootSchemaMapping';
@@ -63,6 +65,12 @@ export enum StandardObjects {
     user = 'user',
 }
 
+export enum ChatStandardObjects {
+    channel = 'channel',
+    chatUser = 'chatUser',
+    message = 'message',
+}
+
 export const objectNameMapping: Record<string, Record<CRM_TP_ID, string | undefined>> = {
     [StandardObjects.company]: {
         [TP_ID.hubspot]: 'companies',

packages/backend/helpers/crm/transform/disunify.ts

@@ -1,5 +1,5 @@
 import { TP_ID, accountFieldMappingConfig } from '@prisma/client';
-import { CRM_TP_ID, StandardObjects } from '../../../constants/common';
+import { CHAT_TP_ID, CRM_TP_ID, ChatStandardObjects, StandardObjects } from '../../../constants/common';
 import { transformModelToFieldMapping } from '.';
 import { handleHubspotDisunify, handlePipedriveDisunify, handleSfdcDisunify, handleZohoDisunify } from '..';
 import { postprocessDisUnifyObject } from './preprocess';
@@ -46,3 +46,35 @@ export async function disunifyObject<T extends Record<string, any>>({
         }
     }
 }
+
+export async function disunifyChatObject<T extends Record<string, any>>({
+    obj,
+    tpId,
+    objType,
+    tenantSchemaMappingId,
+    accountFieldMappingConfig,
+}: {
+    obj: T;
+    tpId: CHAT_TP_ID;
+    objType: ChatStandardObjects;
+    tenantSchemaMappingId?: string;
+    accountFieldMappingConfig?: accountFieldMappingConfig;
+}) {
+    const flattenedObj = flattenObj(obj, ['additional']);
+    const transformedObj = await transformModelToFieldMapping({
+        unifiedObj: flattenedObj,
+        tpId,
+        objType,
+        tenantSchemaMappingId,
+        accountFieldMappingConfig,
+    });
+
+    switch (tpId) {
+        case TP_ID.slack: {
+            return transformedObj;
+        }
+        case TP_ID.discord: {
+            return transformedObj;
+        }
+    }
+}

packages/backend/helpers/crm/transform/preprocess.ts

@@ -1,5 +1,5 @@
 import { TP_ID } from '@prisma/client';
-import { CRM_TP_ID, StandardObjects } from '../../../constants/common';
+import { CRM_TP_ID, ChatStandardObjects, StandardObjects } from '../../../constants/common';
 import { PipedriveDealStatus } from '../../../constants/pipedrive';
 import { convertToHHMMInUTC, getDuration, getFormattedDate } from '../../../helpers/timeZoneHelper';
 
@@ -10,7 +10,7 @@ export const preprocessUnifyObject = <T extends Record<string, any>>({
 }: {
     obj: T;
     tpId: CRM_TP_ID;
-    objType: StandardObjects;
+    objType: StandardObjects | ChatStandardObjects;
 }) => {
     const preprocessMap: any = {
         [TP_ID.pipedrive]: {

packages/backend/helpers/crm/transform/transformSchemaMapping.ts

@@ -1,6 +1,6 @@
 import { get, merge } from 'lodash';
 import { Prisma, PrismaClient, TP_ID, accountFieldMappingConfig } from '@prisma/client';
-import { StandardObjects, rootSchemaMappingId } from '../../../constants/common';
+import { ChatStandardObjects, StandardObjects, rootSchemaMappingId } from '../../../constants/common';
 import { logDebug } from '../../logger';
 
 const prisma = new PrismaClient();
@@ -14,7 +14,7 @@ export const transformFieldMappingToModel = async ({
 }: {
     obj: any;
     tpId: TP_ID;
-    objType: StandardObjects;
+    objType: StandardObjects | ChatStandardObjects;
     tenantSchemaMappingId?: string;
     accountFieldMappingConfig?: accountFieldMappingConfig;
 }) => {
@@ -67,7 +67,7 @@ export const transformModelToFieldMapping = async ({
 }: {
     unifiedObj: any;
     tpId: TP_ID;
-    objType: StandardObjects;
+    objType: StandardObjects | ChatStandardObjects;
     tenantSchemaMappingId?: string;
     accountFieldMappingConfig?: accountFieldMappingConfig;
 }) => {

packages/backend/helpers/crm/transform/unify.ts

@@ -1,5 +1,5 @@
 import { accountFieldMappingConfig } from '@prisma/client';
-import { CRM_TP_ID, StandardObjects } from '../../../constants/common';
+import { CRM_TP_ID, ChatStandardObjects, StandardObjects } from '../../../constants/common';
 import { transformFieldMappingToModel } from '.';
 import { preprocessUnifyObject } from './preprocess';
 
@@ -12,7 +12,7 @@ export async function unifyObject<T extends Record<string, any>, K>({
 }: {
     obj: T;
     tpId: CRM_TP_ID;
-    objType: StandardObjects;
+    objType: StandardObjects | ChatStandardObjects;
     tenantSchemaMappingId?: string;
     accountFieldMappingConfig?: accountFieldMappingConfig;
 }): Promise<K> {

packages/backend/helpers/tenantIdMiddleware.ts

@@ -32,6 +32,7 @@ const revertTenantMiddleware = () => async (req: Request, res: Response, next: (
                 t_id: true,
                 tp_account_url: true,
                 tp_customer_id: true,
+                app_bot_token: true,
                 app: {
                     include: {
                         env: {

packages/backend/models/unified/channel.ts

@@ -1,15 +1,15 @@
 export interface UnifiedChannel {
     id: string;
     name: string;
-    createdTimeStamp: string;
+    createdTimeStamp: string | null;
     additional: any;
 }
 
 export function unifyChannel(channel: any) {
     const unifiedChannel: UnifiedChannel = {
         id: channel.id,
-        name: channel.name_normalized,
-        createdTimeStamp: new Date(channel.created * 1000).toISOString(),
+        name: channel.name_normalized || channel.name,
+        createdTimeStamp: channel.created ? new Date(channel.created * 1000).toISOString() : null,
         additional: {},
     };
 

packages/backend/models/unified/chatUsers.ts

@@ -7,9 +7,9 @@ export interface UnifiedChatUser {
 
 export function unifyChatUser(user: any): UnifiedChatUser {
     const unifiedUser: UnifiedChatUser = {
-        id: user.id,
-        name: user.real_name,
-        createdTimeStamp: new Date(user.updated * 1000).toISOString(),
+        id: user.id || user.user.id,
+        name: user.profile.real_name || user.user.global_name,
+        createdTimeStamp: user.joined_at || new Date(user.updated * 1000).toISOString(),
         additional: {},
     };
 

packages/backend/models/unified/message.ts

@@ -2,7 +2,7 @@ import { TP_ID } from '@prisma/client';
 
 export interface UnifiedMessage {
     text: string;
-    channelId: string;
+    channelId: string | undefined;
     additional?: any;
 }
 
@@ -26,6 +26,8 @@ export function unifyMessage(message: any) {
 export function disunifyMessage(message: UnifiedMessage, integrationId: string): any {
     if (integrationId === TP_ID.slack) {
         return toSlackMessage(message);
+    } else if (integrationId === TP_ID.discord) {
+        return toDiscordMessage(message);
     }
 }
 
@@ -44,3 +46,17 @@ function toSlackMessage(message: UnifiedMessage): any {
 
     return slackMessage;
 }
+function toDiscordMessage(message: UnifiedMessage): any {
+    const discordMessage: any = {
+        content: message.text,
+    };
+
+    // Map custom fields, if any
+    if (message.additional) {
+        Object.keys(message.additional).forEach((key) => {
+            discordMessage[key] = message.additional?.[key];
+        });
+    }
+
+    return discordMessage;
+}

packages/backend/prisma/migrations/20231123075418_discord_enum_added/migration.sql

@@ -0,0 +1,2 @@
+-- AlterEnum
+ALTER TYPE "TP_ID" ADD VALUE 'discord';

packages/backend/prisma/migrations/20231123105415_app_bot_token_column_added/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "apps" ADD COLUMN     "app_bot_token" TEXT;

packages/backend/prisma/migrations/20231123124417_app_bot_token_added_to_connections/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "connections" ADD COLUMN     "app_bot_token" TEXT;

packages/backend/prisma/schema.prisma

@@ -14,6 +14,7 @@ enum TP_ID {
   pipedrive
   closecrm
   slack
+  discord
 }
 
 enum ENV {
@@ -55,6 +56,7 @@ model apps {
   app_client_id              String?
   app_client_secret          String?
   owner_account_public_token String?
+  app_bot_token              String?
   environmentId              String
   env                        environments  @relation(fields: [environmentId], references: [id])
   connections                connections[]
@@ -84,6 +86,7 @@ model connections {
   owner_account_public_token String
   app_client_id              String?
   app_client_secret          String?
+  app_bot_token              String?
   app                        apps?           @relation(fields: [appId], references: [id])
   appId                      String?
   schema_mapping_id          String?