Show pending edits by fading the event body #193

+ Fix issues with edits local echo management in aggregation

matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/session/room/EventRelationsAggregationTask.kt

@@ -83,21 +83,21 @@ internal class DefaultEventRelationsAggregationTask @Inject constructor(
                         if (event.unsignedData?.relations?.annotations != null) {
                             Timber.v("###REACTION Agreggation in room $roomId for event ${event.eventId}")
                             handleInitialAggregatedRelations(event, roomId, event.unsignedData.relations.annotations, realm)
-                        } else {
+
-                            val content: MessageContent? = event.content.toModel()
+                            EventAnnotationsSummaryEntity.where(realm, event.eventId
-                            if (content?.relatesTo?.type == RelationType.REPLACE) {
+                                    ?: "").findFirst()?.let {
-                                Timber.v("###REPLACE in room $roomId for event ${event.eventId}")
+                                TimelineEventEntity.where(realm, eventId = event.eventId
-                                //A replace!
+                                        ?: "").findFirst()?.let { tet ->
-                                handleReplace(realm, event, content, roomId, isLocalEcho)
+                                    tet.annotations = it
+                                }
                             }
                         }
 
-                        EventAnnotationsSummaryEntity.where(realm, event.eventId
+                        val content: MessageContent? = event.content.toModel()
-                                ?: "").findFirst()?.let {
+                        if (content?.relatesTo?.type == RelationType.REPLACE) {
-                            TimelineEventEntity.where(realm, eventId = event.eventId
+                            Timber.v("###REPLACE in room $roomId for event ${event.eventId}")
-                                    ?: "").findFirst()?.let { tet ->
+                            //A replace!
-                                tet.annotations = it
+                            handleReplace(realm, event, content, roomId, isLocalEcho)
-                            }
                         }
 
 
@@ -178,11 +178,12 @@ internal class DefaultEventRelationsAggregationTask @Inject constructor(
             Timber.v("###REPLACE new edit summary for ${targetEventId}, creating one (localEcho:$isLocalEcho)")
             //create the edit summary
             val editSummary = realm.createObject(EditAggregatedSummaryEntity::class.java)
-            editSummary.lastEditTs = event.originServerTs ?: System.currentTimeMillis()
             editSummary.aggregatedContent = ContentMapper.map(newContent)
             if (isLocalEcho) {
+                editSummary.lastEditTs = 0
                 editSummary.sourceLocalEchoEvents.add(eventId)
             } else {
+                editSummary.lastEditTs = event.originServerTs ?: 0
                 editSummary.sourceEvents.add(eventId)
             }
 
@@ -200,13 +201,26 @@ internal class DefaultEventRelationsAggregationTask @Inject constructor(
                 Timber.v("###REPLACE Receiving remote echo of edit (edit already done)")
                 existingSummary.sourceLocalEchoEvents.remove(txId)
                 existingSummary.sourceEvents.add(event.eventId)
-            } else if (event.originServerTs ?: 0 > existingSummary.lastEditTs) {
+            } else if (
+                    isLocalEcho // do not rely on ts for local echo, take it
+                    || event.originServerTs ?: 0 >= existingSummary.lastEditTs
+            ) {
                 Timber.v("###REPLACE Computing aggregated edit summary (isLocalEcho:$isLocalEcho)")
-                existingSummary.lastEditTs = event.originServerTs ?: System.currentTimeMillis()
+                if (!isLocalEcho) {
+                    //Do not take local echo originServerTs here, could mess up ordering (keep old ts)
+                    existingSummary.lastEditTs = event.originServerTs ?: System.currentTimeMillis()
+                }
                 existingSummary.aggregatedContent = ContentMapper.map(newContent)
-                existingSummary.sourceEvents.add(eventId)
+                if (isLocalEcho) {
+                    existingSummary.sourceLocalEchoEvents.add(eventId)
+                } else {
+                    existingSummary.sourceEvents.add(eventId)
+                }
             } else {
-                //ignore this event for the summary
+                //ignore this event for the summary (back paginate)
+                if (!isLocalEcho) {
+                    existingSummary.sourceEvents.add(eventId)
+                }
                 Timber.v("###REPLACE ignoring event for summary, it's to old $eventId")
             }
         }

vector/src/main/java/im/vector/riotx/features/home/room/detail/timeline/item/AbsMessageItem.kt

@@ -29,6 +29,7 @@ import androidx.core.view.children
 import androidx.core.view.isGone
 import androidx.core.view.isVisible
 import com.airbnb.epoxy.EpoxyAttribute
+import im.vector.matrix.android.api.session.room.send.SendState
 import im.vector.riotx.R
 import im.vector.riotx.core.resources.ColorProvider
 import im.vector.riotx.core.utils.DebouncedClickListener
@@ -163,7 +164,9 @@ abstract class AbsMessageItem<H : AbsMessageItem.Holder> : BaseEventItem<H>() {
 
     protected fun renderSendState(root: View, textView: TextView?) {
         root.isClickable = informationData.sendState.isSent()
-        textView?.setTextColor(colorProvider.getMessageTextColor(informationData.sendState))
+        val state = SendState.UNSENT.takeIf { informationData.hasPendingEdits }
+                ?: informationData.sendState
+        textView?.setTextColor(colorProvider.getMessageTextColor(state))
     }
 
     abstract class Holder(@IdRes stubId: Int) : BaseHolder(stubId) {

vector/src/main/java/im/vector/riotx/features/home/room/detail/timeline/item/MessageInformationData.kt

@@ -31,7 +31,8 @@ data class MessageInformationData(
         val showInformation: Boolean = true,
         /*List of reactions (emoji,count,isSelected)*/
         var orderedReactionList: List<ReactionInfoData>? = null,
-        var hasBeenEdited: Boolean = false
+        var hasBeenEdited: Boolean = false,
+        var hasPendingEdits: Boolean = false
 ) : Parcelable
 
 

vector/src/main/java/im/vector/riotx/features/home/room/detail/timeline/util/MessageInformationDataFactory.kt

@@ -74,7 +74,8 @@ class MessageInformationDataFactory @Inject constructor(private val timelineDate
                         ?.map {
                             ReactionInfoData(it.key, it.count, it.addedByMe, it.localEchoEvents.isEmpty())
                         },
-                hasBeenEdited = hasBeenEdited
+                hasBeenEdited = hasBeenEdited,
+                hasPendingEdits = event.annotations?.editSummary?.localEchos?.any() ?: false
         )
     }
 }