️ fix: Fix logic in isExceedLimit method to ensure accurate checking of message exceedances.

This commit is contained in:
jarvis2f 2024-12-24 09:29:56 +08:00
parent 7be1301f7c
commit 442c609167

View file

@ -174,7 +174,7 @@ public class AutoDownloadVerticle extends AbstractVerticle {
private boolean isExceedLimit(long telegramId) { private boolean isExceedLimit(long telegramId) {
List<TdApi.Message> waitingMessages = this.waitingDownloadMessages.get(telegramId); List<TdApi.Message> waitingMessages = this.waitingDownloadMessages.get(telegramId);
return getSurplusSize(telegramId) == 0 || (waitingMessages != null && waitingMessages.size() > limit); return getSurplusSize(telegramId) <= 0 || (waitingMessages != null && waitingMessages.size() > limit);
} }
private int getSurplusSize(long telegramId) { private int getSurplusSize(long telegramId) {
@ -214,7 +214,7 @@ public class AutoDownloadVerticle extends AbstractVerticle {
log.debug("Download start! TelegramId: %d size: %d".formatted(telegramId, messages.size())); log.debug("Download start! TelegramId: %d size: %d".formatted(telegramId, messages.size()));
TelegramVerticle telegramVerticle = this.getTelegramVerticle(telegramId); TelegramVerticle telegramVerticle = this.getTelegramVerticle(telegramId);
int surplusSize = getSurplusSize(telegramId); int surplusSize = getSurplusSize(telegramId);
if (surplusSize == 0) { if (surplusSize <= 0) {
return; return;
} }