|
|
@ -589,7 +589,10 @@ public class SmsDatabase extends MessagingDatabase {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
notifyConversationListeners(threadId);
|
|
|
|
notifyConversationListeners(threadId);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!message.isIdentityUpdate() && !message.isIdentityVerified() && !message.isIdentityDefault()) {
|
|
|
|
jobManager.add(new TrimThreadJob(context, threadId));
|
|
|
|
jobManager.add(new TrimThreadJob(context, threadId));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return Optional.of(new InsertResult(messageId, threadId));
|
|
|
|
return Optional.of(new InsertResult(messageId, threadId));
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -637,10 +640,16 @@ public class SmsDatabase extends MessagingDatabase {
|
|
|
|
insertListener.onComplete();
|
|
|
|
insertListener.onComplete();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!message.isIdentityVerified() && !message.isIdentityDefault()) {
|
|
|
|
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
|
|
|
|
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
|
|
|
|
DatabaseFactory.getThreadDatabase(context).setLastSeen(threadId);
|
|
|
|
DatabaseFactory.getThreadDatabase(context).setLastSeen(threadId);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
notifyConversationListeners(threadId);
|
|
|
|
notifyConversationListeners(threadId);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!message.isIdentityVerified() && !message.isIdentityDefault()) {
|
|
|
|
jobManager.add(new TrimThreadJob(context, threadId));
|
|
|
|
jobManager.add(new TrimThreadJob(context, threadId));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return messageId;
|
|
|
|
return messageId;
|
|
|
|
}
|
|
|
|
}
|
|
|
|