TheArchive/session-android
1
0
Fork 0
mirror of https://github.com/oxen-io/session-android.git synced 2024-11-25 02:55:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: maybe syncing read statuses are working now

Browse Source
This commit is contained in:
0x330a 2023-06-28 11:07:42 +10:00
parent df39194024
commit df0bcf8bc5
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
libsession/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt
View File

@ -229,8 +229,10 @@ class BatchMessageReceiveJob(
if (!openGroupID.isNullOrEmpty()) { if (!openGroupID.isNullOrEmpty()) {
Log.d("Loki-DBG", "new-lastSeen for: $openGroupID is $currentLastSeen") Log.d("Loki-DBG", "new-lastSeen for: $openGroupID is $currentLastSeen")
} }
storage.markConversationAsRead(threadId, newLastSeen, force = true) if (newLastSeen > 0) {
storage.updateThread(threadId, true) storage.markConversationAsRead(threadId, newLastSeen, force = true)
storage.updateThread(threadId, true)
}
SSKEnvironment.shared.notificationManager.updateNotification(context, threadId) SSKEnvironment.shared.notificationManager.updateNotification(context, threadId)
} }
@ -241,7 +243,9 @@ class BatchMessageReceiveJob(
} }
// await all thread processing // await all thread processing
deferredThreadMap.awaitAll() deferredThreadMap.awaitAll()
processMessages(NO_THREAD_MAPPING, noThreadMessages).await() if (noThreadMessages.isNotEmpty()) {
processMessages(NO_THREAD_MAPPING, noThreadMessages).await()
}
} }
if (failures.isEmpty()) { if (failures.isEmpty()) {
handleSuccess(dispatcherName) handleSuccess(dispatcherName)