diff --git a/lib/src/services/api.service.dart b/lib/src/services/api.service.dart index a48df1c..d9134ed 100644 --- a/lib/src/services/api.service.dart +++ b/lib/src/services/api.service.dart @@ -210,7 +210,8 @@ class ApiService { Future retransmitRawBytes() async { await lockRetransStore.protect(() async { 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; for (final seq in retransmit.keys) { try { diff --git a/lib/src/services/api/messages.dart b/lib/src/services/api/messages.dart index b2af649..0c685ec 100644 --- a/lib/src/services/api/messages.dart +++ b/lib/src/services/api/messages.dart @@ -17,6 +17,10 @@ Future tryTransmitMessages() async { final retransIds = await twonlyDB.messageRetransmissionDao.getRetransmitAbleMessages(); + if (retransIds.isEmpty) return; + + Log.info("Retransmitting ${retransIds.length} text messages"); + for (final retransId in retransIds) { sendRetransmitMessage(retransId); }