twonly/twonly-app
1
0
Fork 0
mirror of https://github.com/twonlyapp/twonly-app.git synced 2026-01-15 16:28:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

improve logging for retransmission

Browse source
This commit is contained in:
otsmr 2025-06-06 09:17:54 +02:00
parent 7157d286a0
commit 0bd810f82c
2 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/src/services/api.service.dart
View file

@ -210,7 +210,8 @@ class ApiService {
Future retransmitRawBytes() async { Future retransmitRawBytes() async {
await lockRetransStore.protect(() async { await lockRetransStore.protect(() async {
var retransmit = await getRetransmission(); var retransmit = await getRetransmission();
Log.info("retransmitting ${retransmit.keys.length} messages"); if (retransmit.keys.isEmpty) return;
Log.info("retransmitting ${retransmit.keys.length} raw bytes messages");
bool gotError = false; bool gotError = false;
for (final seq in retransmit.keys) { for (final seq in retransmit.keys) {
try { try {

4
lib/src/services/api/messages.dart
View file

@ -17,6 +17,10 @@ Future tryTransmitMessages() async {
final retransIds = final retransIds =
await twonlyDB.messageRetransmissionDao.getRetransmitAbleMessages(); await twonlyDB.messageRetransmissionDao.getRetransmitAbleMessages();
if (retransIds.isEmpty) return;
Log.info("Retransmitting ${retransIds.length} text messages");
for (final retransId in retransIds) { for (final retransId in retransIds) {
sendRetransmitMessage(retransId); sendRetransmitMessage(retransId);
} }