Browse Source

Check for message removed exception

main
M66B 6 years ago
parent
commit
e68142de47
1 changed files with 12 additions and 14 deletions
  1. +12
    -14
      app/src/main/java/eu/faircode/email/ServiceSynchronize.java

+ 12
- 14
app/src/main/java/eu/faircode/email/ServiceSynchronize.java View File

@ -419,12 +419,15 @@ public class ServiceSynchronize extends LifecycleService {
public void messagesRemoved(MessageCountEvent e) { public void messagesRemoved(MessageCountEvent e) {
try { try {
Log.i(Helper.TAG, folder.name + " messages removed"); Log.i(Helper.TAG, folder.name + " messages removed");
for (Message imessage : e.getMessages()) {
long uid = ffolder.getUID(imessage);
DB db = DB.getInstance(ServiceSynchronize.this);
db.message().deleteMessage(folder.id, uid);
Log.i(Helper.TAG, "Deleted uid=" + uid);
}
for (Message imessage : e.getMessages())
try {
long uid = ffolder.getUID(imessage);
DB db = DB.getInstance(ServiceSynchronize.this);
db.message().deleteMessage(folder.id, uid);
Log.i(Helper.TAG, "Deleted uid=" + uid);
} catch (MessageRemovedException ex) {
Log.w(Helper.TAG, folder.name + " " + ex + "\n" + Log.getStackTraceString(ex));
}
} catch (Throwable ex) { } catch (Throwable ex) {
Log.e(Helper.TAG, folder.name + " " + ex + "\n" + Log.getStackTraceString(ex)); Log.e(Helper.TAG, folder.name + " " + ex + "\n" + Log.getStackTraceString(ex));
reportError(account.name, folder.name, ex); reportError(account.name, folder.name, ex);
@ -804,10 +807,12 @@ public class ServiceSynchronize extends LifecycleService {
List<Message> added = new ArrayList<>(); List<Message> added = new ArrayList<>();
for (Message imessage : imessages) for (Message imessage : imessages)
if (!imessage.isExpunged() && !imessage.isSet(Flags.Flag.DELETED)) {
try {
long uid = ifolder.getUID(imessage); long uid = ifolder.getUID(imessage);
if (!uids.remove(uid)) if (!uids.remove(uid))
added.add(imessage); added.add(imessage);
} catch (MessageRemovedException ex) {
Log.w(Helper.TAG, folder.name + " " + ex + "\n" + Log.getStackTraceString(ex));
} }
// Delete local messages not at remote // Delete local messages not at remote
@ -845,13 +850,6 @@ public class ServiceSynchronize extends LifecycleService {
fp.add(IMAPFolder.FetchProfileItem.FLAGS); fp.add(IMAPFolder.FetchProfileItem.FLAGS);
ifolder.fetch(new Message[]{imessage}, fp); ifolder.fetch(new Message[]{imessage}, fp);
boolean expunged = imessage.isExpunged();
boolean deleted = (!expunged && imessage.isSet(Flags.Flag.DELETED));
if (expunged || deleted) {
Log.i(Helper.TAG, "Message gone expunged=" + expunged + " deleted=" + deleted);
return;
}
long uid = ifolder.getUID(imessage); long uid = ifolder.getUID(imessage);
Log.i(Helper.TAG, folder.name + " sync uid=" + uid); Log.i(Helper.TAG, folder.name + " sync uid=" + uid);


Loading…
Cancel
Save