Clear notification for a room left on another client

CHANGES.md

@@ -13,6 +13,7 @@ Other changes:
 Bugfix:
  - Edited message: link confusion when (edited) appears in body (#398)
  - Close detail room screen when the room is left with another client (#256)
+ - Clear notification for a room left on another client
 
 Translations:
  -

matrix-sdk-android/src/main/java/im/vector/matrix/android/api/pushrules/PushRuleService.kt

@@ -41,6 +41,7 @@ interface PushRuleService {
 
     interface PushRuleListener {
         fun onMatchRule(event: Event, actions: List<Action>)
+        fun onRoomLeft(roomId: String)
         fun batchFinish()
     }
 }

matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/session/notification/DefaultPushRuleService.kt

@@ -20,12 +20,10 @@ import im.vector.matrix.android.api.MatrixCallback
 import im.vector.matrix.android.api.auth.data.SessionParams
 import im.vector.matrix.android.api.pushrules.Action
 import im.vector.matrix.android.api.pushrules.PushRuleService
-import im.vector.matrix.android.api.pushrules.rest.GetPushRulesResponse
 import im.vector.matrix.android.api.pushrules.rest.PushRule
 import im.vector.matrix.android.api.session.events.model.Event
 import im.vector.matrix.android.internal.database.mapper.PushRulesMapper
 import im.vector.matrix.android.internal.database.model.PushRulesEntity
-import im.vector.matrix.android.internal.database.model.PusherEntityFields
 import im.vector.matrix.android.internal.database.query.where
 import im.vector.matrix.android.internal.session.SessionScope
 import im.vector.matrix.android.internal.session.pushers.GetPushRulesTask
@@ -122,13 +120,23 @@ internal class DefaultPushRuleService @Inject constructor(
         }
     }
 
+    fun dispatchRoomLeft(roomid: String) {
+        try {
+            listeners.forEach {
+                it.onRoomLeft(roomid)
+            }
+        } catch (e: Throwable) {
+            Timber.e(e, "Error while dispatching room left")
+        }
+    }
+
     fun dispatchFinish() {
         try {
             listeners.forEach {
                 it.batchFinish()
             }
         } catch (e: Throwable) {
-
+            Timber.e(e, "Error while dispatching finish")
         }
     }
 }

matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/session/notification/ProcessEventForPushTask.kt

@@ -44,6 +44,10 @@ internal class DefaultProcessEventForPushTask @Inject constructor(
 
     override suspend fun execute(params: ProcessEventForPushTask.Params): Try<Unit> {
         return Try {
+            // Handle left rooms
+            params.syncResponse.leave.keys.forEach {
+                defaultPushRuleService.dispatchRoomLeft(it)
+            }
             val newJoinEvents = params.syncResponse.join
                     .map { entries ->
                         entries.value.timeline?.events?.map { it.copy(roomId = entries.key) }

vector/src/main/java/im/vector/riotx/features/notifications/PushRuleTriggerListener.kt

@@ -56,6 +56,10 @@ class PushRuleTriggerListener @Inject constructor(
         }
     }
 
+    override fun onRoomLeft(roomId: String) {
+        notificationDrawerManager.clearMessageEventOfRoom(roomId)
+    }
+
     override fun batchFinish() {
         notificationDrawerManager.refreshNotificationDrawer()
     }