From 401312327902acef1e616b0a5dc7563686e00746 Mon Sep 17 00:00:00 2001
From: Daniel Gultsch <daniel@gultsch.de>
Date: Sat, 24 Feb 2018 10:57:11 +0100
Subject: [PATCH] =?UTF-8?q?MAM:=20rework=20hasMessagesLeft=20to=20account?=
 =?UTF-8?q?=20for=20prosody=E2=80=99s=20missing=20count?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../services/MessageArchiveService.java        | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

diff --git a/src/main/java/eu/siacs/conversations/services/MessageArchiveService.java b/src/main/java/eu/siacs/conversations/services/MessageArchiveService.java
index d075c0164..cff6da497 100644
--- a/src/main/java/eu/siacs/conversations/services/MessageArchiveService.java
+++ b/src/main/java/eu/siacs/conversations/services/MessageArchiveService.java
@@ -270,12 +270,18 @@ public class MessageArchiveService implements OnAdvancedStreamFeaturesLoaded {
 			query.getConversation().setFirstMamReference(first == null ? null : first.getContent());
 		}
 		if (complete || relevant == null || abort) {
-			boolean done = !query.isCatchup();
-			if (count != null && !query.isCatchup()) {
-				try {
-					done = Integer.parseInt(count) <= query.getTotalCount();
-				} catch (NumberFormatException e) {
-					done = false;
+			boolean done;
+			if (query.isCatchup()) {
+				done = false;
+			} else {
+				if (count != null) {
+					try {
+						done = Integer.parseInt(count) <= query.getTotalCount();
+					} catch (NumberFormatException e) {
+						done = false;
+					}
+				} else {
+					done = query.getTotalCount() == 0;
 				}
 			}
 			done = done || (query.getActualMessageCount() == 0 && !query.isCatchup());