Add only retry on 429 error, add DOMAIN to .env.example

Author: cweems

.env.example

@@ -4,4 +4,5 @@ NUMBER_POOL=["+1234567890","+2345678901"]
 CALL_ANNOUCEMENT_VOICE=
 CALL_ANNOUCEMENT_LANGUAGE=
 OUT_OF_SESSION_MESSAGE_FOR_CALL=
-CONNECTING_CALL_ANNOUCEMENT=
+CONNECTING_CALL_ANNOUCEMENT=
+DOMAIN=

src/utils/addParticipant.util.ts

@@ -6,7 +6,7 @@ export const addParticipant = async (
   conversationSid: string,
   participant: ParticipantListInstanceCreateOptions
 ) : Promise<ParticipantInstance> => {
-  return retry(async () => {
+  return retry(async (quit) => {
     try {
       const createdParticipant = await client.conversations
         .conversations(conversationSid)
@@ -15,8 +15,13 @@ export const addParticipant = async (
 
       return createdParticipant
     } catch (err) {
-      console.log('Create participant err', err);
-      throw new Error(err)
+      if (err.status !== 429) {
+        quit(new Error(err));
+        return;
+      }
+
+      console.log('Re-trying on 429 error');
+      throw new Error(err);
     }
   })
 }

src/utils/createConversation.util.ts

@@ -5,12 +5,18 @@ import client from "../twilioClient";
 import retry from 'async-retry';
 
 export const createConversation = async (options: SessionPostBody) : Promise<ConversationInstance> => {
-  return retry(async () => {
+  return retry(async (quit) => {
     try {
       const conversation = await client.conversations.conversations.create(options);
       return conversation;
     } catch (err) {
-      throw `createConversation: ${err}`;
+      if (err.status !== 429) {
+        quit(new Error(err));
+        return;
+      }
+
+      console.log('Re-trying on 429 error');
+      throw new Error(err);
     }
   })
 }

src/utils/deleteConversation.util.ts

@@ -3,12 +3,18 @@ import client from "../twilioClient"
 import retry from 'async-retry'
 
 export const deleteConversation = async (conversationSid: string) : Promise<boolean> => {
-  return retry(async() => {
+  return retry(async(quit) => {
     try {
       await client.conversations.conversations(conversationSid).remove()
       return true
     } catch (err) {
-      throw err
+      if (err.status !== 429) {
+        quit(new Error(err));
+        return;
+      }
+
+      console.log('Re-trying on 429 error');
+      throw new Error(err);
     } 
   })
 }

src/utils/getConversationByAddressPair.util.ts

@@ -1,21 +1,34 @@
 import { ParticipantConversationInstance } from 'twilio/lib/rest/conversations/v1/participantConversation';
+import retry from 'async-retry'
 import client from '../twilioClient'
 
 export const getConversationByAddressPair = async (address: string, proxyAddress: string) : Promise<ParticipantConversationInstance> => {
-  if (address === undefined) {
-    throw "getOpenConversationsForAddressPair: address is missing";
-  }
+  return retry(async(quit) => {
+    try {
+      if (address === undefined) {
+        throw "getOpenConversationsForAddressPair: address is missing";
+      }
+    
+      const participantConversations = await client.conversations.v1
+        .participantConversations
+        .list({ address: address });
+    
+      const conversation = participantConversations.find(p => {
+        if (p.conversationState !== 'closed' && p.participantMessagingBinding.proxy_address === proxyAddress) {
+          console.log(`Found a non-closed conversation ${p.conversationSid} with proxy address ${p.participantMessagingBinding.proxy_address} for address ${address}`);
+          return p;
+        }
+      });
+    
+      return conversation;
+    } catch(err) {
+      if (err.status !== 429) {
+        quit(new Error(err));
+        return;
+      }
 
-  const participantConversations = await client.conversations.v1
-    .participantConversations
-    .list({ address: address });
-
-  const conversation = participantConversations.find(p => {
-    if (p.conversationState !== 'closed' && p.participantMessagingBinding.proxy_address === proxyAddress) {
-      console.log(`Found a non-closed conversation ${p.conversationSid} with proxy address ${p.participantMessagingBinding.proxy_address} for address ${address}`);
-      return p;
+      console.log('Re-trying on 429 error');
+      throw new Error(err);
     }
-  });
-
-  return conversation;
+  })
 }

src/utils/listParticipantConversations.util.ts

@@ -3,13 +3,18 @@ import { ParticipantConversationInstance } from 'twilio/lib/rest/conversations/v
 import client from '../twilioClient'
 
 export const listParticipantConversations = async (phoneNumber: string) : Promise<ParticipantConversationInstance[]> => {
-  return retry(async () => {
+  return retry(async (quit) => {
     try {
       const activeConversations = await client.conversations.participantConversations.list({address: phoneNumber})
       return activeConversations
     } catch (err) {
-      console.log(phoneNumber, err)
-      throw new Error(err)
+      if (err.status !== 429) {
+        quit(new Error(err));
+        return;
+      }
+
+      console.log('Re-trying on 429 error');
+      throw new Error(err);
     }
   })