diff --git a/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/ArchiveReaderWorkItem.java b/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/ArchiveReaderWorkItem.java index eced3e439..71c2380df 100644 --- a/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/ArchiveReaderWorkItem.java +++ b/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/ArchiveReaderWorkItem.java @@ -57,7 +57,7 @@ public boolean concurrentWith(WorkItem other) { @Override public void run(Path scratchPath) { // Give the bot a chance to act on all found messages - var conversations = list.conversations(Duration.ofDays(60)); + var conversations = list.conversations(Duration.ofDays(365)); for (var conversation : conversations) { bot.inspect(conversation); } diff --git a/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/MailingListArchiveReaderBot.java b/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/MailingListArchiveReaderBot.java index 0e6584df9..b657992c6 100644 --- a/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/MailingListArchiveReaderBot.java +++ b/bots/mlbridge/src/main/java/org/openjdk/skara/bots/mlbridge/MailingListArchiveReaderBot.java @@ -27,6 +27,7 @@ import org.openjdk.skara.forge.*; import org.openjdk.skara.mailinglist.*; +import java.time.*; import java.util.*; import java.util.concurrent.*; import java.util.logging.Logger; @@ -92,8 +93,10 @@ synchronized void inspect(Conversation conversation) { parsedEmailIds.remove(first.id()); } - // Are there any new messages? + // Are there any new messages? We avoid looking further back than 14 days. If the bridge has been down + // for more than 14 days, this may have to be temporarily increased. var newMessages = conversation.allMessages().stream() + .filter(email -> email.date().isAfter(ZonedDateTime.now().minus(Duration.ofDays(14)))) .filter(email -> !parsedEmailIds.contains(email.id())) .collect(Collectors.toList()); if (newMessages.isEmpty()) {