Mirrors/SnapEnhance
1
0
Fork 0
mirror of https://github.com/rhunk/SnapEnhance.git synced 2025-05-29 04:50:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(core/media_downloader): missing attachments

Browse Source
This commit is contained in:
rhunk 2023-12-21 22:44:13 +01:00
parent 0d3bffb05b
commit 699da49743
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
core/src/main/kotlin/me/rhunk/snapenhance/core/features/impl/downloader/MediaDownloader.kt
View File

@ -549,11 +549,26 @@ class MediaDownloader : MessagingRuleFeature("MediaDownloader", MessagingRuleTyp
val friendInfo: FriendInfo = context.database.getFriendInfo(message.senderId!!) ?: throw Exception("Friend not found in database") val friendInfo: FriendInfo = context.database.getFriendInfo(message.senderId!!) ?: throw Exception("Friend not found in database")
val authorName = friendInfo.usernameForSorting!! val authorName = friendInfo.usernameForSorting!!
val decodedAttachments = messageLogger.takeIf { it.isEnabled }?.getMessageObject(message.clientConversationId!!, message.clientMessageId.toLong())?.let { val decodedAttachments = (messageLogger.takeIf { it.isEnabled }?.getMessageObject(message.clientConversationId!!, message.clientMessageId.toLong())?.let {
MessageDecoder.decode(it.getAsJsonObject("mMessageContent")) MessageDecoder.decode(it.getAsJsonObject("mMessageContent"))
} ?: MessageDecoder.decode( } ?: MessageDecoder.decode(
protoReader = ProtoReader(message.messageContent!!) protoReader = ProtoReader(message.messageContent!!)
) )).toMutableList()
context.feature(Messaging::class).conversationManager?.takeIf {
decodedAttachments.isEmpty()
}?.also { conversationManager ->
runBlocking {
suspendCoroutine { continuation ->
conversationManager.fetchMessage(message.clientConversationId!!, message.clientMessageId.toLong(), onSuccess = { message ->
decodedAttachments.addAll(MessageDecoder.decode(message.messageContent!!))
continuation.resumeWith(Result.success(Unit))
}, onError = {
continuation.resumeWith(Result.success(Unit))
})
}
}
}
if (decodedAttachments.isEmpty()) { if (decodedAttachments.isEmpty()) {
context.shortToast(translations["no_attachments_toast"]) context.shortToast(translations["no_attachments_toast"])