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

Sync on move/fetch failure

This commit is contained in:
M66B 2021-02-06 18:30:26 +01:00
parent 1e508c0cd1
commit e3843fce91
1 changed files with 36 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
app/src/main/java/eu/faircode/email/Core.java
View File

@ -1118,44 +1118,48 @@ class Core {
Log.i(target.name + " moved message fetch=" + fetch);
itarget.open(READ_WRITE);
boolean sync = false;
for (EntityMessage message : map.values())
if (!TextUtils.isEmpty(message.msgid))
try {
Long uid = findUid(itarget, message.msgid, false);
if (uid != null) {
if (draft) {
Message icopy = itarget.getMessageByUID(uid);
if (icopy == null) {
Log.w(target.name + " Gone uid=" + uid);
continue;
}
try {
if (TextUtils.isEmpty(message.msgid))
throw new IllegalArgumentException("move: msgid missing");
// Mark read
if (seen && !icopy.isSet(Flags.Flag.SEEN) && flags.contains(Flags.Flag.SEEN))
icopy.setFlag(Flags.Flag.SEEN, true);
Long uid = findUid(itarget, message.msgid, false);
if (uid == null)
throw new IllegalArgumentException("move: uid not found");
// Remove star
if (unflag && icopy.isSet(Flags.Flag.FLAGGED) && flags.contains(Flags.Flag.FLAGGED))
icopy.setFlag(Flags.Flag.FLAGGED, false);
if (draft) {
Message icopy = itarget.getMessageByUID(uid);
if (icopy != null)
throw new IllegalArgumentException("move: gone uid=" + uid);
// Set drafts flag
if (flags.contains(Flags.Flag.DRAFT))
icopy.setFlag(Flags.Flag.DRAFT, EntityFolder.DRAFTS.equals(target.type));
}
// Mark read
if (seen && !icopy.isSet(Flags.Flag.SEEN) && flags.contains(Flags.Flag.SEEN))
icopy.setFlag(Flags.Flag.SEEN, true);
if (fetch)
try {
Log.i(target.name + " Fetching uid=" + uid);
JSONArray fargs = new JSONArray();
fargs.put(uid);
onFetch(context, fargs, target, istore, itarget, state);
} catch (Throwable ex) {
Log.e(ex);
}
}
} catch (Throwable ex) {
Log.w(ex);
// Remove star
if (unflag && icopy.isSet(Flags.Flag.FLAGGED) && flags.contains(Flags.Flag.FLAGGED))
icopy.setFlag(Flags.Flag.FLAGGED, false);
// Set drafts flag
if (flags.contains(Flags.Flag.DRAFT))
icopy.setFlag(Flags.Flag.DRAFT, EntityFolder.DRAFTS.equals(target.type));
}
if (fetch) {
Log.i(target.name + " Fetching uid=" + uid);
JSONArray fargs = new JSONArray();
fargs.put(uid);
onFetch(context, fargs, target, istore, itarget, state);
}
} catch (Throwable ex) {
Log.w(ex);
if (fetch)
sync = true;
}
if (sync)
EntityOperation.sync(context, target.id, false);
} catch (Throwable ex) {
Log.w(ex);
} finally {