msb-public
/
FairEmail
mirror of https://github.com/M66B/FairEmail.git
1
0
Code Issues Projects Releases Wiki Activity

Removed countermeasures, rewritten operation handling

Browse Source
pull/12/head
M66B 6 years ago
parent bb63ef2cfa
commit 921b31abec
2 changed files with 105 additions and 133 deletions
Show Stats Download Patch File Download Diff File

3
app/src/main/java/eu/faircode/email/EntityOperation.java
Unescape View File

@ -80,6 +80,9 @@ public class EntityOperation {
return; return;
} }
purged = dao.deleteOperations(message.id, name); purged = dao.deleteOperations(message.id, name);
} else if (DELETE.equals(name)) {
if (message.uid == null)
return;
} }
EntityOperation operation = new EntityOperation(); EntityOperation operation = new EntityOperation();

105
app/src/main/java/eu/faircode/email/ServiceSynchronize.java
Unescape View File

@ -498,7 +498,7 @@ public class ServiceSynchronize extends LifecycleService {
}; };
// Listen for process operations requests // Listen for process operations requests
LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(ServiceSynchronize.this); LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(this);
lbm.registerReceiver(receiver, new IntentFilter(ACTION_PROCESS_OPERATIONS + folder.id)); lbm.registerReceiver(receiver, new IntentFilter(ACTION_PROCESS_OPERATIONS + folder.id));
Log.i(Helper.TAG, folder.name + " listen process id=" + folder.id); Log.i(Helper.TAG, folder.name + " listen process id=" + folder.id);
try { try {
@ -561,7 +561,7 @@ public class ServiceSynchronize extends LifecycleService {
try { try {
Log.i(Helper.TAG, folder.name + " start process"); Log.i(Helper.TAG, folder.name + " start process");
DB db = DB.getInstance(ServiceSynchronize.this); DB db = DB.getInstance(this);
DaoOperation operation = db.operation(); DaoOperation operation = db.operation();
DaoMessage message = db.message(); DaoMessage message = db.message();
for (TupleOperationEx op : operation.getOperations(folder.id)) { for (TupleOperationEx op : operation.getOperations(folder.id)) {
@ -571,91 +571,52 @@ public class ServiceSynchronize extends LifecycleService {
" msg=" + op.message); " msg=" + op.message);
JSONArray jargs = new JSONArray(op.args); JSONArray jargs = new JSONArray(op.args);
try {
if (EntityOperation.SEEN.equals(op.name)) { if (EntityOperation.SEEN.equals(op.name)) {
// Mark message (un)seen // Mark message (un)seen
try {
Message imessage = ifolder.getMessageByUID(op.uid); Message imessage = ifolder.getMessageByUID(op.uid);
if (imessage != null) if (imessage == null)
throw new MessageRemovedException();
imessage.setFlag(Flags.Flag.SEEN, jargs.getBoolean(0)); imessage.setFlag(Flags.Flag.SEEN, jargs.getBoolean(0));
else
Log.w(Helper.TAG, "Remote message not found uid=" + op.uid);
} catch (MessagingException ex) {
// Countermeasure
Log.i(Helper.TAG, folder.name + " countermeasure " + op.id + "/" + op.name);
EntityMessage msg = message.getMessage(op.message);
msg.ui_seen = msg.seen;
message.updateMessage(msg);
throw ex;
}
} else if (EntityOperation.ADD.equals(op.name)) { } else if (EntityOperation.ADD.equals(op.name)) {
// Append message // Append message
try {
EntityMessage msg = message.getMessage(op.message); EntityMessage msg = message.getMessage(op.message);
Properties props = MessageHelper.getSessionProperties(); Properties props = MessageHelper.getSessionProperties();
Session isession = Session.getDefaultInstance(props, null); Session isession = Session.getDefaultInstance(props, null);
MimeMessage imessage = MessageHelper.from(msg, isession); MimeMessage imessage = MessageHelper.from(msg, isession);
ifolder.appendMessages(new Message[]{imessage}); ifolder.appendMessages(new Message[]{imessage});
// Draft can be saved multiple times // Drafts can be appended multiple times
try {
if (msg.uid != null) { if (msg.uid != null) {
Message previously = ifolder.getMessageByUID(msg.uid); Message previously = ifolder.getMessageByUID(msg.uid);
previously.setFlag(Flags.Flag.DELETED, true); previously.setFlag(Flags.Flag.DELETED, true);
ifolder.expunge(); ifolder.expunge();
} }
} finally {
// Remote will report appended
message.deleteMessage(op.message); message.deleteMessage(op.message);
} catch (MessagingException ex) {
// Countermeasure
// TODO: try again?
throw ex;
} }
} else if (EntityOperation.MOVE.equals(op.name)) { } else if (EntityOperation.MOVE.equals(op.name)) {
// Move message // Move message
try {
Message imessage = ifolder.getMessageByUID(op.uid);
EntityFolder archive = db.folder().getFolder(jargs.getLong(0)); EntityFolder archive = db.folder().getFolder(jargs.getLong(0));
Message imessage = ifolder.getMessageByUID(op.uid);
Folder target = istore.getFolder(archive.name); Folder target = istore.getFolder(archive.name);
ifolder.moveMessages(new Message[]{imessage}, target); ifolder.moveMessages(new Message[]{imessage}, target);
message.deleteMessage(op.message); message.deleteMessage(op.message);
} catch (MessagingException ex) {
// Countermeasure
Log.i(Helper.TAG, folder.name + " countermeasure " + op.id + "/" + op.name);
EntityMessage msg = message.getMessage(op.message);
msg.ui_hide = false;
message.updateMessage(msg);
throw ex;
}
} else if (EntityOperation.DELETE.equals(op.name)) { } else if (EntityOperation.DELETE.equals(op.name)) {
// Delete message // Delete message
try {
if (op.uid != null) {
Message imessage = ifolder.getMessageByUID(op.uid); Message imessage = ifolder.getMessageByUID(op.uid);
if (imessage != null) { if (imessage == null)
throw new MessageRemovedException();
imessage.setFlag(Flags.Flag.DELETED, true); imessage.setFlag(Flags.Flag.DELETED, true);
ifolder.expunge(); ifolder.expunge();
} else
Log.w(Helper.TAG, "Remote message not found uid=" + op.uid);
} else {
// Not appended draft
Log.w(Helper.TAG, "Delete without uid id=" + op.message);
}
message.deleteMessage(op.message); message.deleteMessage(op.message);
} catch (MessagingException ex) {
// Countermeasure
Log.i(Helper.TAG, folder.name + " countermeasure " + op.id + "/" + op.name);
EntityMessage msg = message.getMessage(op.message);
msg.ui_hide = false;
message.updateMessage(msg);
throw ex;
}
} else if (EntityOperation.SEND.equals(op.name)) { } else if (EntityOperation.SEND.equals(op.name)) {
// Send message // Send message
@ -663,7 +624,6 @@ public class ServiceSynchronize extends LifecycleService {
EntityMessage reply = (msg.replying == null ? null : message.getMessage(msg.replying)); EntityMessage reply = (msg.replying == null ? null : message.getMessage(msg.replying));
EntityIdentity ident = db.identity().getIdentity(msg.identity); EntityIdentity ident = db.identity().getIdentity(msg.identity);
try {
Properties props = MessageHelper.getSessionProperties(); Properties props = MessageHelper.getSessionProperties();
Session isession = Session.getDefaultInstance(props, null); Session isession = Session.getDefaultInstance(props, null);
@ -686,26 +646,22 @@ public class ServiceSynchronize extends LifecycleService {
// Make sure the message is sent only once // Make sure the message is sent only once
operation.deleteOperation(op.id); operation.deleteOperation(op.id);
message.deleteMessage(op.message); message.deleteMessage(op.message);
} finally { } finally {
itransport.close(); itransport.close();
} }
} catch (MessagingException ex) {
// Countermeasure
Log.i(Helper.TAG, folder.name + " countermeasure " + op.id + "/" + op.name);
EntityFolder drafts = db.folder().getPrimaryDraftFolder();
msg.folder = drafts.id;
message.updateMessage(msg);
// Message will not be sent to remote
throw ex;
}
} else } else
throw new MessagingException("Unknown operation name=" + op.name); throw new MessagingException("Unknown operation name=" + op.name);
// Operation succeeded
operation.deleteOperation(op.id); operation.deleteOperation(op.id);
} catch (MessageRemovedException ex) {
// There is no use in repeating
operation.deleteOperation(op.id);
throw ex;
}
} }
} finally { } finally {
Log.i(Helper.TAG, folder.name + " end process"); Log.i(Helper.TAG, folder.name + " end process");
@ -769,7 +725,7 @@ public class ServiceSynchronize extends LifecycleService {
try { try {
Log.i(Helper.TAG, folder.name + " start sync after=" + folder.after); Log.i(Helper.TAG, folder.name + " start sync after=" + folder.after);
DB db = DB.getInstance(ServiceSynchronize.this); DB db = DB.getInstance(this);
DaoMessage dao = db.message(); DaoMessage dao = db.message();
// Get reference times // Get reference times
@ -851,12 +807,22 @@ public class ServiceSynchronize extends LifecycleService {
ifolder.fetch(new Message[]{imessage}, fp); ifolder.fetch(new Message[]{imessage}, fp);
long uid = ifolder.getUID(imessage); long uid = ifolder.getUID(imessage);
Log.i(Helper.TAG, folder.name + " sync uid=" + uid); try {
Log.i(Helper.TAG, folder.name + " start sync uid=" + uid);
if (imessage.isExpunged()) {
Log.i(Helper.TAG, folder.name + " expunged uid=" + uid);
return;
}
if (imessage.isSet(Flags.Flag.DELETED)) {
Log.i(Helper.TAG, folder.name + " deleted uid=" + uid);
return;
}
MessageHelper helper = new MessageHelper(imessage); MessageHelper helper = new MessageHelper(imessage);
boolean seen = helper.getSeen(); boolean seen = helper.getSeen();
DB db = DB.getInstance(ServiceSynchronize.this); DB db = DB.getInstance(this);
EntityMessage message = db.message().getMessage(folder.id, uid); EntityMessage message = db.message().getMessage(folder.id, uid);
if (message == null) { if (message == null) {
FetchProfile fp1 = new FetchProfile(); FetchProfile fp1 = new FetchProfile();
@ -888,13 +854,16 @@ public class ServiceSynchronize extends LifecycleService {
message.ui_hide = false; message.ui_hide = false;
message.id = db.message().insertMessage(message); message.id = db.message().insertMessage(message);
Log.i(Helper.TAG, folder.name + " added uid=" + uid + " id=" + message.id); Log.i(Helper.TAG, folder.name + " added id=" + message.id);
} else if (message.seen != seen) { } else if (message.seen != seen) {
message.seen = seen; message.seen = seen;
message.ui_seen = seen; message.ui_seen = seen;
db.message().updateMessage(message); db.message().updateMessage(message);
Log.i(Helper.TAG, folder.name + " updated uid=" + uid + " id=" + message.id); Log.i(Helper.TAG, folder.name + " updated id=" + message.id);
}
} finally {
Log.i(Helper.TAG, folder.name + " end sync uid=" + uid);
} }
} }

Write Preview
Loading…
Cancel
Save