feat(videoCall): add video call integration using daily.co

Closes erxes/erxes#1638
erxes · Feb 4, 2020 · bb25bf9 · bb25bf9
1 parent 77e79eb
commit bb25bf9
Show file tree

Hide file tree

Showing 12 changed files with 237 additions and 5 deletions.
diff --git a/src/__tests__/conversationDb.test.ts b/src/__tests__/conversationDb.test.ts
@@ -122,8 +122,7 @@ describe('Conversation db', () => {
     expect(updatedConversation.messageCount).toBe(2);
 
     expect(messageObj.content).toBe(_conversationMessage.content);
-    expect(messageObj.attachments.length).toBe(1);
-    expect(messageObj.attachments[0].toJSON()).toEqual(_conversationMessage.attachments[0].toJSON());
+    expect(messageObj.attachments.length).toBe(0);
     expect(messageObj.mentionedUserIds[0]).toBe(_conversationMessage.mentionedUserIds[0]);
 
     expect(messageObj.conversationId).toBe(_conversation._id);

diff --git a/src/__tests__/conversationMutations.test.ts b/src/__tests__/conversationMutations.test.ts
@@ -163,6 +163,8 @@ describe('Conversation message mutations', () => {
   });
 
   test('Add conversation message using third party integration', async () => {
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
+
     const mock = sinon.stub(messageBroker, 'sendMessage').callsFake(() => {
       return Promise.resolve('success');
     });
@@ -363,4 +365,49 @@ describe('Conversation message mutations', () => {
 
     expect(conversation.readUserIds).toContain(user._id);
   });
+
+  test('Delete video chat room', async () => {
+    expect.assertions(1);
+
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
+
+    const mutation = `
+      mutation conversationDeleteVideoChatRoom($name: String!) {
+        conversationDeleteVideoChatRoom(name: $name)
+      }
+    `;
+
+    const dataSources = { IntegrationsAPI: new IntegrationsAPI() };
+
+    try {
+      await graphqlRequest(mutation, 'conversationDeleteVideoChatRoom', { name: 'fakeId' }, { dataSources });
+    } catch (e) {
+      expect(e[0].message).toBe('Integrations api is not running');
+    }
+  });
+
+  test('Create video chat room', async () => {
+    expect.assertions(1);
+
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
+
+    const mutation = `
+      mutation conversationCreateVideoChatRoom($_id: String!) {
+        conversationCreateVideoChatRoom(_id: $_id) {
+          url
+          name
+          status
+        }
+      }
+    `;
+
+    const conversation = await conversationFactory();
+    const dataSources = { IntegrationsAPI: new IntegrationsAPI() };
+
+    try {
+      await graphqlRequest(mutation, 'conversationCreateVideoChatRoom', { _id: conversation._id }, { dataSources });
+    } catch (e) {
+      expect(e[0].message).toBe('Integrations api is not running');
+    }
+  });
 });
diff --git a/src/__tests__/conversationQueries.test.ts b/src/__tests__/conversationQueries.test.ts
@@ -12,6 +12,7 @@ import {
 import { Brands, Channels, Conversations, Integrations, Tags, Users } from '../db/models';
 
 import { IntegrationsAPI } from '../data/dataSources';
+import { MESSAGE_TYPES } from '../db/models/definitions/constants';
 import './setup.ts';
 
 describe('conversationQueries', () => {
@@ -87,6 +88,11 @@ describe('conversationQueries', () => {
         messageCount
         number
         tagIds
+        videoCallData {
+          url
+          name
+           status
+        }
         messages {
           _id
           content
@@ -155,6 +161,11 @@ describe('conversationQueries', () => {
           mailData {
             messageId
           }
+          videoCallData {
+            url
+            name
+             status
+          }
         }
       }
     `;
@@ -228,6 +239,48 @@ describe('conversationQueries', () => {
     expect(responses.length).toBe(4);
   });
 
+  test('Conversation message video call', async () => {
+    const conversation = await conversationFactory();
+    await conversationMessageFactory({ conversationId: conversation._id });
+
+    let responses = await graphqlRequest(qryConversationMessage, 'conversationMessages', {
+      conversationId: conversation._id,
+    });
+
+    expect(responses[0].videoCallData).toBeNull();
+
+    await conversationMessageFactory({ internal: false, conversationId: conversation._id });
+
+    responses = await graphqlRequest(qryConversationMessage, 'conversationMessages', {
+      conversationId: conversation._id,
+    });
+
+    expect(responses[0].videoCallData).toBeNull();
+
+    await conversationMessageFactory({
+      conversationId: conversation._id,
+      contentType: MESSAGE_TYPES.VIDEO_CALL,
+      internal: false,
+    });
+
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
+
+    const dataSources = { IntegrationsAPI: new IntegrationsAPI() };
+
+    try {
+      await graphqlRequest(
+        qryConversationMessage,
+        'conversationMessages',
+        {
+          conversationId: conversation._id,
+        },
+        { dataSources },
+      );
+    } catch (e) {
+      expect(e[0].message).toBe('Integrations api is not running');
+    }
+  });
+
   test('Conversation messages (messenger kind)', async () => {
     const messageIntegration = await integrationFactory({ kind: 'messenger' });
     const messageIntegrationConversation = await conversationFactory({ integrationId: messageIntegration._id });
@@ -915,6 +968,39 @@ describe('conversationQueries', () => {
     }
   });
 
+  test('Conversation detail video call', async () => {
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
+
+    const messengerConversation = await conversationFactory();
+
+    const dataSources = { IntegrationsAPI: new IntegrationsAPI() };
+
+    const response = await graphqlRequest(
+      qryConversationDetail,
+      'conversationDetail',
+      { _id: messengerConversation._id },
+      { user, dataSources },
+    );
+
+    expect(response.videoCallData).toBeNull();
+
+    await conversationMessageFactory({
+      conversationId: messengerConversation._id,
+      contentType: MESSAGE_TYPES.VIDEO_CALL,
+    });
+
+    try {
+      await graphqlRequest(
+        qryConversationDetail,
+        'conversationDetail',
+        { _id: messengerConversation._id },
+        { user, dataSources },
+      );
+    } catch (e) {
+      expect(e[0].message).toBe('Integrations api is not running');
+    }
+  });
+
   test('Conversation detail callpro audio', async () => {
     process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
 
@@ -994,7 +1080,7 @@ describe('conversationQueries', () => {
   });
 
   test('Facebook comments', async () => {
-    process.env.INTEGRATION_API_DOMAIN = 'http://fake.erxes.io';
+    process.env.INTEGRATIONS_API_DOMAIN = 'http://fake.erxes.io';
 
     const qry = `
       query converstationFacebookComments($postId: String!) {

diff --git a/src/data/dataSources/integrations.ts b/src/data/dataSources/integrations.ts
@@ -47,6 +47,14 @@ export default class IntegrationsAPI extends RESTDataSource {
     return this.post(`/${kind}/send`, params);
   }
 
+  public async deleteDailyVideoChatRoom(name) {
+    return this.delete(`/daily/rooms/${name}`);
+  }
+
+  public async createDailyVideoChatRoom(params) {
+    return this.post('/daily/room', params);
+  }
+
   public async fetchApi(path, params) {
     return this.get(path, params);
   }

diff --git a/src/data/resolvers/conversation.ts b/src/data/resolvers/conversation.ts
@@ -1,4 +1,5 @@
 import { ConversationMessages, Customers, Integrations, Tags, Users } from '../../db/models';
+import { MESSAGE_TYPES } from '../../db/models/definitions/constants';
 import { IConversationDocument } from '../../db/models/definitions/conversations';
 import { debugExternalApi } from '../../debuggers';
 import { IContext } from '../types';
@@ -92,4 +93,19 @@ export default {
   tags(conv: IConversationDocument) {
     return Tags.find({ _id: { $in: conv.tagIds || [] } });
   },
+
+  async videoCallData(conversation: IConversationDocument, _args, { dataSources }: IContext) {
+    const message = await ConversationMessages.findOne({
+      conversationId: conversation._id,
+      contentType: MESSAGE_TYPES.VIDEO_CALL,
+    });
+
+    if (!message) {
+      return null;
+    }
+
+    return dataSources.IntegrationsAPI.fetchApi('/daily/get-active-room', {
+      erxesApiConversationId: conversation._id,
+    });
+  },
 };
diff --git a/src/data/resolvers/conversationMessage.ts b/src/data/resolvers/conversationMessage.ts
@@ -1,4 +1,5 @@
 import { Conversations, Customers, Integrations, Users } from '../../db/models';
+import { MESSAGE_TYPES } from '../../db/models/definitions/constants';
 import { IMessageDocument } from '../../db/models/definitions/conversationMessages';
 import { IContext } from '../types';
 
@@ -38,4 +39,18 @@ export default {
       integrationId: integration._id,
     });
   },
+
+  async videoCallData(message: IMessageDocument, _args, { dataSources }: IContext) {
+    const conversation = await Conversations.findOne({ _id: message.conversationId });
+
+    if (!conversation || message.internal) {
+      return null;
+    }
+
+    if (message.contentType !== MESSAGE_TYPES.VIDEO_CALL) {
+      return null;
+    }
+
+    return dataSources.IntegrationsAPI.fetchApi('/daily/room', { erxesApiMessageId: message._id });
+  },
 };
diff --git a/src/data/resolvers/mutations/conversations.ts b/src/data/resolvers/mutations/conversations.ts
@@ -5,6 +5,7 @@ import Messages from '../../../db/models/ConversationMessages';
 import {
   CONVERSATION_STATUSES,
   KIND_CHOICES,
+  MESSAGE_TYPES,
   NOTIFICATION_CONTENT_TYPES,
   NOTIFICATION_TYPES,
 } from '../../../db/models/definitions/constants';
@@ -399,6 +400,37 @@ const conversationMutations = {
   async conversationMarkAsRead(_root, { _id }: { _id: string }, { user }: IContext) {
     return Conversations.markAsReadConversation(_id, user._id);
   },
+
+  async conversationDeleteVideoChatRoom(_root, { name }, { dataSources }: IContext) {
+    try {
+      return await dataSources.IntegrationsAPI.deleteDailyVideoChatRoom(name);
+    } catch (e) {
+      debugExternalApi(e.message);
+
+      throw new Error(e.message);
+    }
+  },
+
+  async conversationCreateVideoChatRoom(_root, { _id }, { dataSources, user }: IContext) {
+    try {
+      const doc = {
+        conversationId: _id,
+        internal: false,
+        contentType: MESSAGE_TYPES.VIDEO_CALL,
+      };
+
+      const message = await ConversationMessages.addMessage(doc, user._id);
+
+      return await dataSources.IntegrationsAPI.createDailyVideoChatRoom({
+        erxesApiConversationId: _id,
+        erxesApiMessageId: message._id,
+      });
+    } catch (e) {
+      debugExternalApi(e.message);
+
+      throw new Error(e.message);
+    }
+  },
 };
 
 requireLogin(conversationMutations, 'conversationMarkAsRead');

diff --git a/src/data/schema/conversation.ts b/src/data/schema/conversation.ts
@@ -35,6 +35,7 @@ export const types = `
     assignedUser: User
     participatedUsers: [User]
     participatorCount: Int
+    videoCallData: VideoCallData
   }
 
   type EngageData {
@@ -72,6 +73,8 @@ export const types = `
     user: User
     customer: Customer
     mailData: MailData
+    videoCallData: VideoCallData
+    contentType: String
   }
 
   type FacebookPost {
@@ -148,6 +151,12 @@ export const types = `
     unreadCount: Int
   }
 
+  type VideoCallData {
+    url: String
+    name: String
+    status: String
+  }
+
   input ConversationMessageParams {
     content: String,
     mentionedUserIds: [String],
@@ -215,10 +224,13 @@ export const mutations = `
     mentionedUserIds: [String],
     internal: Boolean,
     attachments: [AttachmentInput],
+    contentType: String
   ): ConversationMessage
   conversationsReplyFacebookComment(conversationId: String, commentId: String, content: String): FacebookComment
   conversationsAssign(conversationIds: [String]!, assignedUserId: String): [Conversation]
   conversationsUnassign(_ids: [String]!): [Conversation]
   conversationsChangeStatus(_ids: [String]!, status: String!): [Conversation]
   conversationMarkAsRead(_id: String): Conversation
+  conversationDeleteVideoChatRoom(name: String!): Boolean
+  conversationCreateVideoChatRoom(_id: String!): VideoCallData
 `;
diff --git a/src/db/factories.ts b/src/db/factories.ts
@@ -53,6 +53,7 @@ import {
   BOARD_TYPES,
   CONVERSATION_STATUSES,
   FORM_TYPES,
+  MESSAGE_TYPES,
   NOTIFICATION_TYPES,
   PROBABILITY,
   PRODUCT_TYPES,
@@ -597,6 +598,7 @@ interface IConversationMessageFactoryInput {
   engageData?: any;
   formWidgetData?: any;
   kind?: string;
+  contentType?: string;
 }
 
 export const conversationMessageFactory = async (params: IConversationMessageFactoryInput) => {
@@ -614,7 +616,7 @@ export const conversationMessageFactory = async (params: IConversationMessageFac
 
   return ConversationMessages.createMessage({
     content: params.content,
-    attachments: {},
+    attachments: [],
     mentionedUserIds: params.mentionedUserIds || [Random.id()],
     conversationId,
     internal: params.internal === undefined || params.internal === null ? true : params.internal,
@@ -623,6 +625,7 @@ export const conversationMessageFactory = async (params: IConversationMessageFac
     isCustomerRead: params.isCustomerRead,
     engageData: params.engageData || {},
     formWidgetData: params.formWidgetData || {},
+    contentType: params.contentType || MESSAGE_TYPES.TEXT,
   });
 };