diff options
author | Eric Bailey <git@esb.lol> | 2024-05-20 09:56:57 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-05-20 09:56:57 -0500 |
commit | 2414559b80ae9916aaa01bcc8da4f8b4cbf64238 (patch) | |
tree | e01669457a70c08c36b57692bf9f609cf5ea5ba0 /src/state/messages/convo/agent.ts | |
parent | 52beb29a0d96d8de731400aa654ca4c905c2aa48 (diff) | |
download | voidsky-2414559b80ae9916aaa01bcc8da4f8b4cbf64238.tar.zst |
[🐴] Don't retry sends (#4111)
* Don't retry sends * Don't retry batch sends
Diffstat (limited to 'src/state/messages/convo/agent.ts')
-rw-r--r-- | src/state/messages/convo/agent.ts | 37 |
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 /* |