diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/EventRelationsAggregationProcessor.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/EventRelationsAggregationProcessor.kt index f3f55466da..d186f74a94 100644 --- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/EventRelationsAggregationProcessor.kt +++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/EventRelationsAggregationProcessor.kt @@ -385,7 +385,7 @@ internal class EventRelationsAggregationProcessor @Inject constructor( } val closedTime = existingPollSummary?.closedTime - if (closedTime != null && eventTimestamp > closedTime) { + if (closedTime != null) { Timber.v("## POLL is closed ignore event poll:$targetEventId, event :${event.eventId}") return } @@ -499,8 +499,6 @@ internal class EventRelationsAggregationProcessor @Inject constructor( } val txId = event.unsignedData?.transactionId - existingPollSummary.closedTime = event.originServerTs - // is it a remote echo? if (!isLocalEcho && existingPollSummary.sourceLocalEchoEvents.contains(txId)) { // ok it has already been managed @@ -509,6 +507,8 @@ internal class EventRelationsAggregationProcessor @Inject constructor( existingPollSummary.sourceEvents.add(event.eventId) return } + + existingPollSummary.closedTime = event.originServerTs } private fun getPollEvent(roomId: String, eventId: String): TimelineEvent? {