mirror
/
FairEmail
mirror of https://github.com/M66B/FairEmail.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Limit server browse to 100,000 messages

This commit is contained in:
M66B 2024-03-24 19:21:17 +01:00
parent ce17db1e83
commit 3667bc468e
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
app/src/main/java/eu/faircode/email/BoundaryCallbackMessages.java
View File

@ -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);