thedevstack/PiratX-Archive
Archived
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

run expireOldMessages in background task

Browse source
This commit is contained in:
Christian Schneppe 2018-11-30 21:06:45 +01:00
parent be9c267a05
commit 17a326ecb4
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/main/java/de/pixart/messenger/services/XmppConnectionService.java
View file

@ -1027,10 +1027,10 @@ public class XmppConnectionService extends Service {
public void expireOldMessages(final boolean resetHasMessagesLeftOnServer) {
mLastExpiryRun.set(SystemClock.elapsedRealtime());
mDatabaseWriterExecutor.execute(() -> {
Runnable runnable = () -> {
long timestamp = getAutomaticMessageDeletionDate();
if (timestamp > 0) {
databaseBackend.expireOldMessages(timestamp);
expireOldMessages(timestamp);
synchronized (XmppConnectionService.this.conversations) {
for (Conversation conversation : XmppConnectionService.this.conversations) {
conversation.expireOldMessages(timestamp);
@ -1042,7 +1042,8 @@ public class XmppConnectionService extends Service {
}
updateConversationUi();
}
});
};
mDatabaseWriterExecutor.execute((runnable));
}
public boolean hasInternetConnection() {
@ -1716,7 +1717,7 @@ public class XmppConnectionService extends Service {
mLastExpiryRun.set(SystemClock.elapsedRealtime());
if (deletionDate > 0) {
Log.d(Config.LOGTAG, "deleting messages that are older than " + AbstractGenerator.getTimestamp(deletionDate));
databaseBackend.expireOldMessages(deletionDate);
expireOldMessages(deletionDate);
}
Log.d(Config.LOGTAG, "restoring roster...");
for (Account account : accounts) {
@ -4558,4 +4559,8 @@ public class XmppConnectionService extends Service {
onStartCommand(intent, 0, 0);
}
}
private void expireOldMessages(long timestamp) {
databaseBackend.expireOldMessages(timestamp);
}
}