Sdk : use latest apis for space

appnav/src/main/kotlin/io/element/android/appnav/LoggedInFlowNode.kt

@@ -366,8 +366,8 @@ class LoggedInFlowNode(
                     }
                 }
                 val spaceCallback = object : SpaceEntryPoint.Callback {
-                    override fun onOpenRoom(roomId: RoomId) {
-                        backstack.push(NavTarget.Room(roomId.toRoomIdOrAlias()))
+                    override fun onOpenRoom(roomId: RoomId, viaParameters: List<String>) {
+                        backstack.push(NavTarget.Room(roomId.toRoomIdOrAlias(), serverNames = viaParameters))
                     }
                 }
                 val inputs = RoomFlowNode.Inputs(

features/joinroom/impl/src/main/kotlin/io/element/android/features/joinroom/impl/JoinRoomPresenter.kt

@@ -94,9 +94,7 @@ class JoinRoomPresenter(
         val roomInfo by remember {
             matrixClient.getRoomInfoFlow(roomId)
         }.collectAsState(initial = Optional.empty())
-        val spaceRoom by remember {
-            spaceList.currentSpaceFlow()
-        }.collectAsState()
+        val spaceRoom by spaceList.currentSpaceFlow.collectAsState()
         val joinAction: MutableState<AsyncAction<Unit>> = remember { mutableStateOf(AsyncAction.Uninitialized) }
         val knockAction: MutableState<AsyncAction<Unit>> = remember { mutableStateOf(AsyncAction.Uninitialized) }
         val cancelKnockAction: MutableState<AsyncAction<Unit>> = remember { mutableStateOf(AsyncAction.Uninitialized) }

features/space/api/src/main/kotlin/io/element/android/features/space/api/SpaceEntryPoint.kt

@@ -31,6 +31,6 @@ interface SpaceEntryPoint : FeatureEntryPoint {
     ) : NodeInputs
 
     interface Callback : Plugin {
-        fun onOpenRoom(roomId: RoomId)
+        fun onOpenRoom(roomId: RoomId, viaParameters: List<String>)
     }
 }

features/space/impl/src/main/kotlin/io/element/android/features/space/impl/SpaceNode.kt

@@ -36,8 +36,8 @@ class SpaceNode(
         SpaceView(
             state = state,
             onBackClick = ::navigateUp,
-            onRoomClick = { roomId ->
-                callback.onOpenRoom(roomId)
+            onRoomClick = { spaceRoom ->
+                callback.onOpenRoom(spaceRoom.roomId, spaceRoom.via)
             },
             modifier = modifier
         )

features/space/impl/src/main/kotlin/io/element/android/features/space/impl/SpacePresenter.kt

@@ -29,7 +29,6 @@ import kotlinx.collections.immutable.toPersistentSet
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.launch
-import java.util.Optional
 import kotlin.jvm.optionals.getOrNull
 
 @Inject
@@ -66,7 +65,7 @@ class SpacePresenter(
             }
         }.collectAsState()
 
-        val currentSpace by remember { spaceRoomList.currentSpaceFlow() }.collectAsState(Optional.empty())
+        val currentSpace by spaceRoomList.currentSpaceFlow.collectAsState()
 
         fun handleEvents(event: SpaceEvents) {
             when (event) {

features/space/impl/src/main/kotlin/io/element/android/features/space/impl/SpaceView.kt

@@ -39,7 +39,6 @@ import io.element.android.libraries.designsystem.theme.components.CircularProgre
 import io.element.android.libraries.designsystem.theme.components.Scaffold
 import io.element.android.libraries.designsystem.theme.components.Text
 import io.element.android.libraries.designsystem.theme.components.TopAppBar
-import io.element.android.libraries.matrix.api.core.RoomId
 import io.element.android.libraries.matrix.api.room.CurrentUserMembership
 import io.element.android.libraries.matrix.api.spaces.SpaceRoom
 import io.element.android.libraries.matrix.ui.components.SpaceHeaderView
@@ -52,7 +51,7 @@ import kotlinx.collections.immutable.toImmutableList
 fun SpaceView(
     state: SpaceState,
     onBackClick: () -> Unit,
-    onRoomClick: (roomId: RoomId) -> Unit,
+    onRoomClick: (spaceRoom: SpaceRoom) -> Unit,
     modifier: Modifier = Modifier,
 ) {
     Scaffold(
@@ -76,7 +75,7 @@ fun SpaceView(
 @Composable
 private fun SpaceViewContent(
     state: SpaceState,
-    onRoomClick: (roomId: RoomId) -> Unit,
+    onRoomClick: (spaceRoom: SpaceRoom) -> Unit,
     modifier: Modifier = Modifier,
 ) {
     LazyColumn(modifier.fillMaxSize()) {
@@ -102,7 +101,7 @@ private fun SpaceViewContent(
                     showUnreadIndicator = isInvitation && spaceRoom.roomId !in state.seenSpaceInvites,
                     hideAvatars = isInvitation && state.hideInvitesAvatar,
                     onClick = {
-                        onRoomClick(spaceRoom.roomId)
+                        onRoomClick(spaceRoom)
                     },
                     onLongClick = {
                         // TODO

features/space/impl/src/test/kotlin/io/element/android/features/space/impl/DefaultSpaceEntryPointTest.kt

@@ -49,7 +49,7 @@ class DefaultSpaceEntryPointTest {
             )
         }
         val callback = object : SpaceEntryPoint.Callback {
-            override fun onOpenRoom(roomId: RoomId) {
+            override fun onOpenRoom(roomId: RoomId, viaParameters: List<String>) {
                 lambdaError()
             }
         }

libraries/matrix/api/src/main/kotlin/io/element/android/libraries/matrix/api/spaces/SpaceRoom.kt

@@ -28,6 +28,10 @@ data class SpaceRoom(
     val state: CurrentUserMembership?,
     val topic: String?,
     val worldReadable: Boolean,
+    /**
+     * The via parameters of the room.
+     */
+    val via: List<String>,
 ) {
     val isSpace = roomType == RoomType.Space
 }

libraries/matrix/api/src/main/kotlin/io/element/android/libraries/matrix/api/spaces/SpaceRoomList.kt

@@ -17,7 +17,7 @@ interface SpaceRoomList {
         data class Idle(val hasMoreToLoad: Boolean) : PaginationStatus
     }
 
-    fun currentSpaceFlow(): StateFlow<Optional<SpaceRoom>>
+    val currentSpaceFlow: StateFlow<Optional<SpaceRoom>>
 
     val spaceRoomsFlow: Flow<List<SpaceRoom>>
     val paginationStatusFlow: StateFlow<PaginationStatus>

libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/spaces/RustSpaceRoomList.kt

@@ -8,41 +8,36 @@
 package io.element.android.libraries.matrix.impl.spaces
 
 import io.element.android.libraries.core.extensions.runCatchingExceptions
-import io.element.android.libraries.matrix.api.core.RoomId
 import io.element.android.libraries.matrix.api.spaces.SpaceRoom
 import io.element.android.libraries.matrix.api.spaces.SpaceRoomList
 import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.MutableStateFlow
-import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.launch
 import uniffi.matrix_sdk_ui.SpaceRoomListPaginationState
 import java.util.Optional
 import org.matrix.rustcomponents.sdk.SpaceRoomList as InnerSpaceRoomList
 
 class RustSpaceRoomList(
-    private val roomId: RoomId,
     private val innerProvider: suspend () -> InnerSpaceRoomList,
     sessionCoroutineScope: CoroutineScope,
     spaceRoomMapper: SpaceRoomMapper,
-    private val spaceRoomCache: SpaceRoomCache,
 ) : SpaceRoomList {
     private val inner = CompletableDeferred<InnerSpaceRoomList>()
 
-    override fun currentSpaceFlow(): StateFlow<Optional<SpaceRoom>> {
-        return spaceRoomCache.getSpaceRoomFlow(roomId)
-    }
+    override val currentSpaceFlow = MutableStateFlow<Optional<SpaceRoom>>(Optional.empty())
 
     override val spaceRoomsFlow = MutableSharedFlow<List<SpaceRoom>>(replay = 1, extraBufferCapacity = Int.MAX_VALUE)
+
     override val paginationStatusFlow: MutableStateFlow<SpaceRoomList.PaginationStatus> =
         MutableStateFlow(SpaceRoomList.PaginationStatus.Idle(hasMoreToLoad = false))
     private val spaceListUpdateProcessor = SpaceListUpdateProcessor(
         spaceRoomsFlow = spaceRoomsFlow,
-        mapper = spaceRoomMapper,
-        spaceRoomCache = spaceRoomCache
+        mapper = spaceRoomMapper
     )
 
     init {
@@ -64,6 +59,14 @@ class RustSpaceRoomList(
                 }
                 .collect()
         }
+        sessionCoroutineScope.launch {
+            inner.await().spaceUpdateFlow()
+                .map { space -> space.map(spaceRoomMapper::map) }
+                .onEach { space ->
+                    currentSpaceFlow.emit(space)
+                }
+                .collect()
+        }
     }
 
     override suspend fun paginate(): Result<Unit> {

libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/spaces/RustSpaceService.kt

@@ -38,12 +38,10 @@ class RustSpaceService(
     private val sessionDispatcher: CoroutineDispatcher,
 ) : SpaceService {
     private val spaceRoomMapper = SpaceRoomMapper()
-    private val spaceRoomCache = SpaceRoomCache()
     override val spaceRoomsFlow = MutableSharedFlow<List<SpaceRoom>>(replay = 1, extraBufferCapacity = 1)
     private val spaceListUpdateProcessor = SpaceListUpdateProcessor(
         spaceRoomsFlow = spaceRoomsFlow,
-        mapper = spaceRoomMapper,
-        spaceRoomCache = spaceRoomCache
+        mapper = spaceRoomMapper
     )
 
     override suspend fun joinedSpaces(): Result<List<SpaceRoom>> = withContext(sessionDispatcher) {
@@ -57,11 +55,9 @@ class RustSpaceService(
 
     override fun spaceRoomList(id: RoomId): SpaceRoomList {
         return RustSpaceRoomList(
-            roomId = id,
             innerProvider = { innerSpaceService.spaceRoomList(id.value) },
             sessionCoroutineScope = sessionCoroutineScope,
             spaceRoomMapper = spaceRoomMapper,
-            spaceRoomCache = spaceRoomCache,
         )
     }
 

libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/spaces/SpaceListUpdateProcessor.kt

@@ -18,7 +18,6 @@ import timber.log.Timber
 internal class SpaceListUpdateProcessor(
     private val spaceRoomsFlow: MutableSharedFlow<List<SpaceRoom>>,
     private val mapper: SpaceRoomMapper,
-    private val spaceRoomCache: SpaceRoomCache,
 ) {
     private val mutex = Mutex()
 
@@ -37,7 +36,6 @@ internal class SpaceListUpdateProcessor(
                 mutableListOf()
             }
             block(spaceRooms)
-            spaceRoomCache.update(spaceRooms)
             spaceRoomsFlow.emit(spaceRooms)
         }
 

libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/spaces/SpaceRoomListExtensions.kt

@@ -16,11 +16,14 @@ import kotlinx.coroutines.flow.buffer
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.flow.catch
 import org.matrix.rustcomponents.sdk.SpaceListUpdate
+import org.matrix.rustcomponents.sdk.SpaceRoom
 import org.matrix.rustcomponents.sdk.SpaceRoomListEntriesListener
 import org.matrix.rustcomponents.sdk.SpaceRoomListInterface
 import org.matrix.rustcomponents.sdk.SpaceRoomListPaginationStateListener
+import org.matrix.rustcomponents.sdk.SpaceRoomListSpaceListener
 import timber.log.Timber
 import uniffi.matrix_sdk_ui.SpaceRoomListPaginationState
+import java.util.Optional
 
 internal fun SpaceRoomListInterface.paginationStateFlow(): Flow<SpaceRoomListPaginationState> = callbackFlow {
     val listener = object : SpaceRoomListPaginationStateListener {
@@ -55,3 +58,21 @@ internal fun SpaceRoomListInterface.spaceListUpdateFlow(): Flow<List<SpaceListUp
     }.catch {
         Timber.d(it, "spaceListUpdateFlow() failed")
     }.buffer(Channel.UNLIMITED)
+
+internal fun SpaceRoomListInterface.spaceUpdateFlow(): Flow<Optional<SpaceRoom>> =
+    callbackFlow {
+        val listener = object : SpaceRoomListSpaceListener {
+            override fun onUpdate(space: SpaceRoom?) {
+                trySendBlocking(Optional.ofNullable(space))
+            }
+        }
+        Timber.d("Open spaceUpdateFlow for SpaceRoomListInterface ${this@spaceUpdateFlow}")
+        trySendBlocking(Optional.ofNullable(space()))
+        val taskHandle = subscribeToSpaceUpdates(listener)
+        awaitClose {
+            Timber.d("Close spaceUpdateFlow for SpaceRoomListInterface ${this@spaceUpdateFlow}")
+            taskHandle.cancelAndDestroy()
+        }
+    }.catch {
+        Timber.d(it, "spaceUpdateFlow() failed")
+    }.buffer(Channel.UNLIMITED)

libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/spaces/SpaceRoomMapper.kt

@@ -31,6 +31,7 @@ class SpaceRoomMapper {
             state = spaceRoom.state?.map(),
             topic = spaceRoom.topic,
             worldReadable = spaceRoom.worldReadable.orFalse(),
+            via = spaceRoom.via,
         )
     }
 }

libraries/matrix/impl/src/test/kotlin/io/element/android/libraries/matrix/impl/spaces/RoomSummaryListProcessorTest.kt

@@ -185,6 +185,5 @@ class RoomSummaryListProcessorTest {
     ) = SpaceListUpdateProcessor(
         spaceRoomsFlow = spaceRoomsFlow,
         mapper = SpaceRoomMapper(),
-        spaceRoomCache = SpaceRoomCache(),
     )
 }

libraries/matrix/impl/src/test/kotlin/io/element/android/libraries/matrix/impl/spaces/RustSpaceRoomListTest.kt

@@ -11,13 +11,10 @@ package io.element.android.libraries.matrix.impl.spaces
 
 import app.cash.turbine.test
 import com.google.common.truth.Truth.assertThat
-import io.element.android.libraries.matrix.api.core.RoomId
 import io.element.android.libraries.matrix.api.spaces.SpaceRoomList
 import io.element.android.libraries.matrix.impl.fixtures.factories.aRustSpaceRoom
 import io.element.android.libraries.matrix.impl.fixtures.fakes.FakeFfiSpaceRoomList
-import io.element.android.libraries.matrix.test.A_ROOM_ID
 import io.element.android.libraries.matrix.test.A_ROOM_ID_2
-import io.element.android.libraries.previewutils.room.aSpaceRoom
 import io.element.android.tests.testutils.lambda.lambdaRecorder
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.test.TestScope
@@ -26,7 +23,6 @@ import kotlinx.coroutines.test.runTest
 import org.junit.Test
 import org.matrix.rustcomponents.sdk.SpaceListUpdate
 import uniffi.matrix_sdk_ui.SpaceRoomListPaginationState
-import kotlin.jvm.optionals.getOrNull
 import org.matrix.rustcomponents.sdk.SpaceRoomList as InnerSpaceRoomList
 
 class RustSpaceRoomListTest {
@@ -87,33 +83,15 @@ class RustSpaceRoomListTest {
         paginateResult.assertions().isCalledOnce()
     }
 
-    @Test
-    fun `currentSpaceFlow reads value from the SpaceRoomCache`() = runTest {
-        val spaceRoomCache = SpaceRoomCache()
-        val sut = createRustSpaceRoomList(
-            spaceRoomCache = spaceRoomCache,
-        )
-        sut.currentSpaceFlow().test {
-            assertThat(awaitItem().getOrNull()).isNull()
-            val spaceRoom = aSpaceRoom(roomId = A_ROOM_ID)
-            spaceRoomCache.update(listOf(spaceRoom))
-            assertThat(awaitItem().getOrNull()).isEqualTo(spaceRoom)
-        }
-    }
-
     private fun TestScope.createRustSpaceRoomList(
-        roomId: RoomId = A_ROOM_ID,
         innerSpaceRoomList: InnerSpaceRoomList = FakeFfiSpaceRoomList(),
         innerProvider: suspend () -> InnerSpaceRoomList = { innerSpaceRoomList },
         spaceRoomMapper: SpaceRoomMapper = SpaceRoomMapper(),
-        spaceRoomCache: SpaceRoomCache = SpaceRoomCache(),
     ): RustSpaceRoomList {
         return RustSpaceRoomList(
-            roomId = roomId,
             innerProvider = innerProvider,
             sessionCoroutineScope = backgroundScope,
             spaceRoomMapper = spaceRoomMapper,
-            spaceRoomCache = spaceRoomCache,
         )
     }
 }