mirror of
https://github.com/signalapp/Signal-Android.git
synced 2026-04-17 23:43:34 +01:00
Fix story download bug.
This commit is contained in:
committed by
Cody Henthorne
parent
46e6ae915c
commit
782c83cc4e
@@ -104,7 +104,7 @@ open class StoryViewerPageRepository(context: Context, private val storyViewStat
|
|||||||
val messageUpdateObserver = DatabaseObserver.MessageObserver {
|
val messageUpdateObserver = DatabaseObserver.MessageObserver {
|
||||||
if (it.id == recordId) {
|
if (it.id == recordId) {
|
||||||
try {
|
try {
|
||||||
val messageRecord = SignalDatabase.messages.getMessageRecord(recordId)
|
val messageRecord = SignalDatabase.messages.getMessageRecord(recordId).withAttachments()
|
||||||
if (messageRecord.isRemoteDelete) {
|
if (messageRecord.isRemoteDelete) {
|
||||||
emitter.onComplete()
|
emitter.onComplete()
|
||||||
} else {
|
} else {
|
||||||
@@ -118,7 +118,7 @@ open class StoryViewerPageRepository(context: Context, private val storyViewStat
|
|||||||
|
|
||||||
val conversationObserver = DatabaseObserver.Observer {
|
val conversationObserver = DatabaseObserver.Observer {
|
||||||
try {
|
try {
|
||||||
refresh(SignalDatabase.messages.getMessageRecord(recordId))
|
refresh(SignalDatabase.messages.getMessageRecord(recordId).withAttachments())
|
||||||
} catch (e: NoSuchMessageException) {
|
} catch (e: NoSuchMessageException) {
|
||||||
Log.w(TAG, "Message deleted during content refresh.", e)
|
Log.w(TAG, "Message deleted during content refresh.", e)
|
||||||
}
|
}
|
||||||
@@ -128,7 +128,7 @@ open class StoryViewerPageRepository(context: Context, private val storyViewStat
|
|||||||
AppDependencies.databaseObserver.registerMessageUpdateObserver(messageUpdateObserver)
|
AppDependencies.databaseObserver.registerMessageUpdateObserver(messageUpdateObserver)
|
||||||
|
|
||||||
val messageInsertObserver = DatabaseObserver.MessageObserver {
|
val messageInsertObserver = DatabaseObserver.MessageObserver {
|
||||||
refresh(SignalDatabase.messages.getMessageRecord(recordId))
|
refresh(SignalDatabase.messages.getMessageRecord(recordId).withAttachments())
|
||||||
}
|
}
|
||||||
|
|
||||||
if (recipient.isGroup) {
|
if (recipient.isGroup) {
|
||||||
@@ -156,7 +156,7 @@ open class StoryViewerPageRepository(context: Context, private val storyViewStat
|
|||||||
val records = if (isFromArchive && initialStoryId > 0) {
|
val records = if (isFromArchive && initialStoryId > 0) {
|
||||||
Observable.fromCallable {
|
Observable.fromCallable {
|
||||||
try {
|
try {
|
||||||
listOf(SignalDatabase.messages.getMessageRecord(initialStoryId))
|
listOf(SignalDatabase.messages.getMessageRecord(initialStoryId).withAttachments())
|
||||||
} catch (e: NoSuchMessageException) {
|
} catch (e: NoSuchMessageException) {
|
||||||
emptyList()
|
emptyList()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user