From 3667bc468e01f22dc2b199384bf352b4261886ae Mon Sep 17 00:00:00 2001
From: M66B <M66B@users.noreply.github.com>
Date: Sun, 24 Mar 2024 19:21:17 +0100
Subject: [PATCH] Limit server browse to 100,000 messages

---
 .../faircode/email/BoundaryCallbackMessages.java | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/app/src/main/java/eu/faircode/email/BoundaryCallbackMessages.java b/app/src/main/java/eu/faircode/email/BoundaryCallbackMessages.java
index 86132b534f..91423288a2 100644
--- a/app/src/main/java/eu/faircode/email/BoundaryCallbackMessages.java
+++ b/app/src/main/java/eu/faircode/email/BoundaryCallbackMessages.java
@@ -104,6 +104,7 @@ public class BoundaryCallbackMessages extends PagedList.BoundaryCallback<TupleMe
     private static ExecutorService executor = Helper.getBackgroundExecutor(1, "boundary");
 
     private static final int SEARCH_LIMIT_DEVICE = 1000;
+    private static final int FETCH_LIMIT_SERVER = 100000;
 
     interface IBoundaryCallbackMessages {
         void onLoading();
@@ -470,7 +471,7 @@ public class BoundaryCallbackMessages extends PagedList.BoundaryCallback<TupleMe
                         and.add(new FlagTerm(new Flags(Flags.Flag.FLAGGED), true));
 
                     if (and.size() == 0)
-                        state.imessages = state.ifolder.getMessages();
+                        state.getMessages(FETCH_LIMIT_SERVER);
                     else
                         state.imessages = state.ifolder.search(new AndTerm(and.toArray(new SearchTerm[0])));
 
@@ -723,8 +724,10 @@ public class BoundaryCallbackMessages extends PagedList.BoundaryCallback<TupleMe
         EntityLog.log(context, "Search utf8=" + utf8);
 
         SearchTerm terms = criteria.getTerms(utf8, state.ifolder.getPermanentFlags(), keywords);
-        if (terms == null)
-            return state.ifolder.getMessages();
+        if (terms == null) {
+            state.getMessages(FETCH_LIMIT_SERVER);
+            return state.imessages;
+        }
 
         SearchSequence ss = new SearchSequence(protocol);
         Argument args = ss.generateSequence(terms, utf8 ? StandardCharsets.UTF_8.name() : null);
@@ -991,6 +994,13 @@ public class BoundaryCallbackMessages extends PagedList.BoundaryCallback<TupleMe
         IMAPFolder ifolder = null;
         Message[] imessages = null;
 
+        void getMessages(int max) throws MessagingException {
+            int total = Math.min(ifolder.getMessageCount(), max);
+            imessages = new Message[total];
+            for (int i = 1; i <= total; i++)
+                imessages[i - 1] = ifolder.getMessage(i);
+        }
+
         void reset() {
             Log.i("Boundary reset");
             queued.set(0);