OfficialDakari
/
matrix-dart-sdk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #1805 from famedly/karthi/update-event-error 

fix: update event status to error on EventTooLarge
This commit is contained in:
Krille-chan 2024-05-16 16:03:16 +02:00 committed by GitHub
parent b50bab6b29 eef3fd1dfc
commit 7d6bd1ab9d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/src/room.dart
View File

@ -1127,9 +1127,7 @@ class Room {
txid: messageID, txid: messageID,
); );
} catch (e, s) { } catch (e, s) {
if (e is EventTooLarge) { if (e is MatrixException &&
rethrow;
} else if (e is MatrixException &&
e.retryAfterMs != null && e.retryAfterMs != null &&
!DateTime.now() !DateTime.now()
.add(Duration(milliseconds: e.retryAfterMs!)) .add(Duration(milliseconds: e.retryAfterMs!))
@ -1138,6 +1136,7 @@ class Room {
'Ratelimited while sending message, waiting for ${e.retryAfterMs}ms'); 'Ratelimited while sending message, waiting for ${e.retryAfterMs}ms');
await Future.delayed(Duration(milliseconds: e.retryAfterMs!)); await Future.delayed(Duration(milliseconds: e.retryAfterMs!));
} else if (e is MatrixException || } else if (e is MatrixException ||
e is EventTooLarge ||
DateTime.now().isAfter(timeoutDate)) { DateTime.now().isAfter(timeoutDate)) {
Logs().w('Problem while sending message', e, s); Logs().w('Problem while sending message', e, s);
syncUpdate.rooms!.join!.values.first.timeline!.events!.first syncUpdate.rooms!.join!.values.first.timeline!.events!.first
@ -1145,6 +1144,7 @@ class Room {
await _handleFakeSync(syncUpdate); await _handleFakeSync(syncUpdate);
completer.complete(); completer.complete();
_sendingQueue.remove(completer); _sendingQueue.remove(completer);
if (e is EventTooLarge) rethrow;
return null; return null;
} else { } else {
Logs() Logs()