about summary refs log tree commit diff
path: root/src/state/messages/convo/agent.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/state/messages/convo/agent.ts')
-rw-r--r--src/state/messages/convo/agent.ts37
1 files changed, 16 insertions, 21 deletions
diff --git a/src/state/messages/convo/agent.ts b/src/state/messages/convo/agent.ts
index 4418eaae7..71b0b6f2d 100644
--- a/src/state/messages/convo/agent.ts
+++ b/src/state/messages/convo/agent.ts
@@ -793,15 +793,13 @@ export class Convo {
 
       const {id, message} = pendingMessage
 
-      const response = await networkRetry(2, () => {
-        return this.agent.api.chat.bsky.convo.sendMessage(
-          {
-            convoId: this.convoId,
-            message,
-          },
-          {encoding: 'application/json', headers: DM_SERVICE_HEADERS},
-        )
-      })
+      const response = await this.agent.api.chat.bsky.convo.sendMessage(
+        {
+          convoId: this.convoId,
+          message,
+        },
+        {encoding: 'application/json', headers: DM_SERVICE_HEADERS},
+      )
       const res = response.data
 
       // remove from queue
@@ -883,18 +881,15 @@ export class Convo {
     )
 
     try {
-      // throw new Error('UNCOMMENT TO TEST RETRY')
-      const {data} = await networkRetry(2, () => {
-        return this.agent.api.chat.bsky.convo.sendMessageBatch(
-          {
-            items: messageArray.map(({message}) => ({
-              convoId: this.convoId,
-              message,
-            })),
-          },
-          {encoding: 'application/json', headers: DM_SERVICE_HEADERS},
-        )
-      })
+      const {data} = await this.agent.api.chat.bsky.convo.sendMessageBatch(
+        {
+          items: messageArray.map(({message}) => ({
+            convoId: this.convoId,
+            message,
+          })),
+        },
+        {encoding: 'application/json', headers: DM_SERVICE_HEADERS},
+      )
       const {items} = data
 
       /*