Merge pull request #1553 from famedly/nico/handle-send-event-ratelimits

fix: Wait for rate limit to pass while sending messages
famedly · Sep 22, 2023 · 8b6bc12 · 8b6bc12
2 parents fa73ab3 + 97bf772
commit 8b6bc12
Showing 1 changed file with 14 additions and 3 deletions.
diff --git a/lib/src/room.dart b/lib/src/room.dart
@@ -1100,17 +1100,28 @@ class Room {
           txid: messageID,
         );
       } catch (e, s) {
-        if (e is MatrixException || DateTime.now().isAfter(timeoutDate)) {
+        if (e is MatrixException &&
+            e.retryAfterMs != null &&
+            !DateTime.now()
+                .add(Duration(milliseconds: e.retryAfterMs!))
+                .isAfter(timeoutDate)) {
+          Logs().w(
+              'Ratelimited while sending message, waiting for ${e.retryAfterMs}ms');
+          await Future.delayed(Duration(milliseconds: e.retryAfterMs!));
+        } else if (e is MatrixException ||
+            DateTime.now().isAfter(timeoutDate)) {
           Logs().w('Problem while sending message', e, s);
           syncUpdate.rooms!.join!.values.first.timeline!.events!.first
               .unsigned![messageSendingStatusKey] = EventStatus.error.intValue;
           await _handleFakeSync(syncUpdate);
           completer.complete();
           _sendingQueue.remove(completer);
           return null;
+        } else {
+          Logs()
+              .w('Problem while sending message: $e Try again in 1 seconds...');
+          await Future.delayed(Duration(seconds: 1));
         }
-        Logs().w('Problem while sending message: $e Try again in 1 seconds...');
-        await Future.delayed(Duration(seconds: 1));
       }
     }
     syncUpdate.rooms!.join!.values.first.timeline!.events!.first