We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7227991 commit b37a0b8Copy full SHA for b37a0b8
app/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt
@@ -173,7 +173,11 @@ class BatchMessageReceiveJob @AssistedInject constructor(
173
else -> message.senderOrSync.toAddress()
174
}
175
176
- val threadID = threadAddress.let(threadDatabase::getThreadIdIfExistsFor)
+ val threadID = if (shouldCreateThread(parsedParams)) {
177
+ threadDatabase.getOrCreateThreadIdFor(threadAddress)
178
+ } else {
179
180
+ }
181
threadMap.getOrPut(threadID) { mutableListOf() } += parsedParams
182
} catch (e: Exception) {
183
when (e) {
0 commit comments