If we don't get up to now, at least get recent messages

Stephen Paul Weber created 1 year ago

Change summary

src/main/java/eu/siacs/conversations/Config.java                         |  1 
src/main/java/eu/siacs/conversations/services/MessageArchiveService.java | 14 
2 files changed, 15 insertions(+)

Detailed changes

src/main/java/eu/siacs/conversations/Config.java

@@ -145,6 +145,7 @@ public final class Config {
 
     public static final boolean USE_LMC_VERSION_1_1 = true;
 
+    public static final long MAM_MIN_CATCHUP = MILLISECONDS_IN_DAY * 2;
     public static final long MAM_MAX_CATCHUP = MILLISECONDS_IN_DAY * 5;
     public static final int MAM_MAX_MESSAGES = 750;
 

src/main/java/eu/siacs/conversations/services/MessageArchiveService.java

@@ -387,6 +387,15 @@ public class MessageArchiveService implements OnAdvancedStreamFeaturesLoaded {
             if (query.isCatchup() && query.getActualMessageCount() > 0) {
                 mXmppConnectionService.getNotificationService().finishBacklog(true, query.getAccount());
             }
+            if (query.isCatchup() && query.getPagingOrder() == PagingOrder.NORMAL && !complete) {
+                // Going forward we stopped without completing due to limits
+                // So we don't have the most recent messages yet
+                synchronized (this.queries) {
+                    final var q = new Query(query.getConversation(), new MamReference(System.currentTimeMillis() - Config.MAM_MIN_CATCHUP), 0, true, PagingOrder.REVERSE);
+                    this.queries.add(q);
+                    this.execute(q);
+                }
+            }
             processPostponed(query);
         } else {
             final Query nextQuery;
@@ -492,6 +501,11 @@ public class MessageArchiveService implements OnAdvancedStreamFeaturesLoaded {
         public final Version version;
 
 
+        Query(Conversation conversation, MamReference start, long end, boolean catchup, PagingOrder order) {
+            this(conversation, start, end, catchup);
+            this.pagingOrder = order;
+        }
+
         Query(Conversation conversation, MamReference start, long end, boolean catchup) {
             this(conversation.getAccount(), Version.get(conversation.getAccount(), conversation), catchup ? start : start.timeOnly(), end);
             this.conversation = conversation;