Fix findExistingConversation ref

techmatters · Jun 25, 2024 · b8c4fee · b8c4fee
1 parent c47e7f0
commit b8c4fee
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 5 deletions.
diff --git a/functions/helpers/customChannels/customChannelToFlex.private.ts b/functions/helpers/customChannels/customChannelToFlex.private.ts
@@ -55,7 +55,7 @@ export const findExistingConversation = async (
 ): Promise<ConversationSid | undefined> => {
   const conversations = await context
     .getTwilioClient()
-    .conversations.participantConversations.list({ identity });
+    .conversations.v1.participantConversations.list({ identity });
   const existing = conversations.find((conversation) =>
     ['active', 'inactive'].includes(conversation.conversationState),
   );
@@ -540,4 +540,5 @@ export type ChannelToFlex = {
   retrieveChannelFromUserChannelMap: typeof retrieveChannelFromUserChannelMap;
   AseloCustomChannels: typeof AseloCustomChannels;
   isAseloCustomChannel: typeof isAseloCustomChannel;
+  findExistingConversation: typeof findExistingConversation;
 };
diff --git a/functions/helpers/customChannels/flexToCustomChannel.private.ts b/functions/helpers/customChannels/flexToCustomChannel.private.ts
@@ -95,7 +95,7 @@ export const redirectConversationMessageToExternalChat = async (
     shouldSend = true;
   } else if (Source === 'API' && EventType === 'onMessageAdded') {
     const client = context.getTwilioClient();
-    const conversation = await client.conversations.conversations.get(ConversationSid).fetch();
+    const conversation = await client.conversations.v1.conversations.get(ConversationSid).fetch();
     const { attributes } = conversation;
     const { participantSid } = JSON.parse(attributes);
 

diff --git a/functions/webhooks/instagram/InstagramToFlex.ts b/functions/webhooks/instagram/InstagramToFlex.ts
@@ -30,7 +30,6 @@ import {
   ChannelToFlex,
   ChatChannelSid,
   ConversationSid,
-  findExistingConversation,
 } from '../../helpers/customChannels/customChannelToFlex.private';
 
 type EnvVars = {
@@ -199,7 +198,10 @@ export const handler = async (
     if (useConversations) {
       // Handle message deletion for active conversations
       if (isMessageDeleted(message)) {
-        const conversationSid = await findExistingConversation(context, uniqueUserName);
+        const conversationSid = await channelToFlex.findExistingConversation(
+          context,
+          uniqueUserName,
+        );
 
         if (conversationSid) {
           // const unsentMessage =
@@ -222,7 +224,10 @@ export const handler = async (
 
       // Handle story tags for active conversations
       if (isStoryMention(message)) {
-        const conversationSid = await findExistingConversation(context, uniqueUserName);
+        const conversationSid = await channelToFlex.findExistingConversation(
+          context,
+          uniqueUserName,
+        );
 
         if (conversationSid) {
           messageText = getStoryMentionText(message);