new changes

Author: Prakalp23

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' | 'discord' |'gdrive';
+export type CHAT_TP_ID = 'slack' | 'discord' | 'gdrive';
 export type TICKET_TP_ID = 'linear' | 'clickup' | 'asana' | 'jira' | 'trello' ;
 
 export const DEFAULT_SCOPE = {

packages/backend/prisma/fields.ts

@@ -787,15 +787,15 @@ export const chatFields = {
             source_field_name: {
                 [TP_ID.slack]: 'id',
                 [TP_ID.discord]: 'id',
-                [TP_ID.gdrive]: 'id',
+                [TP_ID.gdrive]: undefined,
             },
             target_field_name: 'id',
         },
         {
             source_field_name: {
                 [TP_ID.slack]: 'name',
                 [TP_ID.discord]: 'name',
-                [TP_ID.gdrive]: 'name',
+                [TP_ID.gdrive]: undefined,
             },
             target_field_name: 'name',
         },
@@ -813,15 +813,15 @@ export const chatFields = {
             source_field_name: {
                 [TP_ID.slack]: 'id',
                 [TP_ID.discord]: 'user.id',
-                [TP_ID.gdrive]: 'id',
+                [TP_ID.gdrive]: undefined,
             },
             target_field_name: 'id',
         },
         {
             source_field_name: {
                 [TP_ID.slack]: 'profile.real_name',
                 [TP_ID.discord]: 'user.global_name',
-                [TP_ID.gdrive]: 'realName',
+                [TP_ID.gdrive]: undefined,
             },
             target_field_name: 'name',
         },

packages/backend/prisma/seed.ts

@@ -133,7 +133,7 @@ async function main() {
 
     Object.values(ChatStandardObjects).forEach((obj) => {
         Object.values(TP_ID).forEach(async (tpId) => {
-            if (!(tpId === 'slack' || tpId === 'discord' || tpId==='gdrive')) return;
+            if (!(tpId === 'slack' || tpId === 'discord' || tpId ==='gdrive')) return;
             const objSchema = chatSchemas.find((s: any) => s.object === obj);
             const fieldMappings = objSchema?.fields.map((field: any) => {
                 const sourceFields: any = (chatFields[obj] as { target_field_name: string }[]).find(

packages/backend/routes/v1/chat/auth.ts

@@ -4,7 +4,7 @@ import prisma, { xprisma } from '../../../prisma/client';
 import { logError, logInfo, logDebug } from '../../../helpers/logger';
 import { Prisma, TP_ID } from '@prisma/client';
 import AuthService from '../../../services/auth';
-import axios, { isAxiosError } from 'axios';
+import axios from 'axios';
 import qs from 'qs';
 import { randomUUID } from 'crypto';
 import redis from '../../../redis/client';

packages/backend/services/chat/channels.ts

@@ -2,7 +2,7 @@ import revertTenantMiddleware from '../../helpers/tenantIdMiddleware';
 import { ChannelsService } from '../../generated/typescript/api/resources/chat/resources/channels/service/ChannelsService';
 import { logError, logInfo } from '../../helpers/logger';
 import { isStandardError } from '../../helpers/error';
-import { InternalServerError } from '../../generated/typescript/api/resources/common';
+import { InternalServerError, NotFoundError } from '../../generated/typescript/api/resources/common';
 import { TP_ID } from '@prisma/client';
 import axios from 'axios';
 import { UnifiedChannel } from '../../models/unified/channel';
@@ -25,6 +25,8 @@ const channelsService = new ChannelsService(
                 const tenantId = connection.t_id;
                 const customerId = connection.tp_customer_id;
                 const botToken = connection.app_bot_token;
+                const fields=req.query.fields;
+
                 logInfo(
                     'Revert::GET ALL CHANNELS',
                     connection.app?.env?.accountId,
@@ -86,9 +88,31 @@ const channelsService = new ChannelsService(
                             )
                         );
 
+
                         res.send({ status: 'ok', next: undefined, results: channels });
                         break;
                     }
+                    case TP_ID.gdrive: {
+                        const url = `https://discord.com/api/guilds/${customerId}/channels`;
+                        let channels: any = await axios.get(url, {
+                            headers: { Authorization: `Bot ${botToken}` },
+                        });
+                        channels = await Promise.all(
+                            channels.data?.map(
+                                async (l: any) =>
+                                    await unifyObject<any, UnifiedChannel>({
+                                        obj: l,
+                                        tpId: thirdPartyId,
+                                        objType,
+                                        tenantSchemaMappingId: connection.schema_mapping_id,
+                                        accountFieldMappingConfig: account.accountFieldMappingConfig,
+                                    })
+                            )
+                        );
+
+
+                        res.send({ status: 'ok', next: undefined, results: channels });
+                        break;
                 }
             } catch (error: any) {
                 logError(error);

packages/js/src/index.ts

@@ -1249,7 +1249,7 @@ const createIntegrationBlock = function (self, integration) {
             }
         };
     }
-    revert = new Revert();
+    revert = new revert();
 })();
 module.exports = revert;
 (window as any).Revert = revert;