Skip to content
Snippets Groups Projects
Commit 24886436 authored by Taras's avatar Taras
Browse files

Rename getAllRooms

parent 702b7a04
No related branches found
No related tags found
No related merge requests found
...@@ -6,7 +6,7 @@ import kotlinx.coroutines.CoroutineScope ...@@ -6,7 +6,7 @@ import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.SupervisorJob import kotlinx.coroutines.SupervisorJob
import kotlinx.coroutines.flow.mapLatest import kotlinx.coroutines.flow.mapLatest
import org.futo.circles.core.utils.getAllCirclesRoomsLiveData import org.futo.circles.core.utils.getAllRoomsLiveData
import org.matrix.android.sdk.api.session.Session import org.matrix.android.sdk.api.session.Session
import org.matrix.android.sdk.api.session.content.ContentUrlResolver import org.matrix.android.sdk.api.session.content.ContentUrlResolver
import org.matrix.android.sdk.api.session.getRoom import org.matrix.android.sdk.api.session.getRoom
...@@ -52,7 +52,7 @@ fun Session.getServerDomain() = myUserId.substringAfter(":") ...@@ -52,7 +52,7 @@ fun Session.getServerDomain() = myUserId.substringAfter(":")
fun Session.getKnownUsersFlow() = fun Session.getKnownUsersFlow() =
getAllCirclesRoomsLiveData(listOf(Membership.JOIN)).asFlow().mapLatest { roomSummaries -> getAllRoomsLiveData(listOf(Membership.JOIN)).asFlow().mapLatest { roomSummaries ->
val knowUsers = mutableSetOf<User>() val knowUsers = mutableSetOf<User>()
roomSummaries.forEach { summary -> roomSummaries.forEach { summary ->
val joinedMembersIds = getRoom(summary.roomId)?.membershipService() val joinedMembersIds = getRoom(summary.roomId)?.membershipService()
......
...@@ -12,7 +12,7 @@ import kotlinx.coroutines.flow.flowOn ...@@ -12,7 +12,7 @@ import kotlinx.coroutines.flow.flowOn
import kotlinx.coroutines.flow.launchIn import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.onEach import kotlinx.coroutines.flow.onEach
import org.futo.circles.core.R import org.futo.circles.core.R
import org.futo.circles.core.utils.getAllCirclesRoomsLiveData import org.futo.circles.core.utils.getAllRoomsLiveData
import org.matrix.android.sdk.api.session.room.model.Membership import org.matrix.android.sdk.api.session.room.model.Membership
import org.matrix.android.sdk.api.session.room.model.RoomSummary import org.matrix.android.sdk.api.session.room.model.RoomSummary
import javax.inject.Inject import javax.inject.Inject
...@@ -30,7 +30,7 @@ class ShortcutsHandler @Inject constructor( ...@@ -30,7 +30,7 @@ class ShortcutsHandler @Inject constructor(
fun observeRoomsAndBuildShortcuts(coroutineScope: CoroutineScope): Job { fun observeRoomsAndBuildShortcuts(coroutineScope: CoroutineScope): Job {
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.N_MR1) return Job() if (Build.VERSION.SDK_INT < Build.VERSION_CODES.N_MR1) return Job()
return getAllCirclesRoomsLiveData(listOf(Membership.JOIN)).asFlow().onEach { rooms -> return getAllRoomsLiveData(listOf(Membership.JOIN)).asFlow().onEach { rooms ->
removeDeadShortcuts(rooms.map { it.roomId }) removeDeadShortcuts(rooms.map { it.roomId })
createShortcuts(rooms) createShortcuts(rooms)
} }
......
...@@ -8,7 +8,6 @@ import kotlinx.coroutines.flow.combine ...@@ -8,7 +8,6 @@ import kotlinx.coroutines.flow.combine
import kotlinx.coroutines.flow.distinctUntilChanged import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.update import kotlinx.coroutines.flow.update
import kotlinx.coroutines.withContext import kotlinx.coroutines.withContext
import org.futo.circles.core.extensions.createResult
import org.futo.circles.core.extensions.getKnownUsersFlow import org.futo.circles.core.extensions.getKnownUsersFlow
import org.futo.circles.core.model.GALLERY_TYPE import org.futo.circles.core.model.GALLERY_TYPE
import org.futo.circles.core.model.GROUP_TYPE import org.futo.circles.core.model.GROUP_TYPE
...@@ -18,8 +17,7 @@ import org.futo.circles.core.model.TIMELINE_TYPE ...@@ -18,8 +17,7 @@ import org.futo.circles.core.model.TIMELINE_TYPE
import org.futo.circles.core.model.convertToCircleRoomType import org.futo.circles.core.model.convertToCircleRoomType
import org.futo.circles.core.model.toRoomInviteListItem import org.futo.circles.core.model.toRoomInviteListItem
import org.futo.circles.core.provider.MatrixSessionProvider import org.futo.circles.core.provider.MatrixSessionProvider
import org.futo.circles.core.utils.getAllCirclesRoomsLiveData import org.futo.circles.core.utils.getAllRoomsLiveData
import org.matrix.android.sdk.api.session.getRoom
import org.matrix.android.sdk.api.session.room.model.Membership import org.matrix.android.sdk.api.session.room.model.Membership
import org.matrix.android.sdk.api.session.room.model.RoomSummary import org.matrix.android.sdk.api.session.room.model.RoomSummary
import javax.inject.Inject import javax.inject.Inject
...@@ -31,7 +29,7 @@ class InvitesDataSource @Inject constructor() { ...@@ -31,7 +29,7 @@ class InvitesDataSource @Inject constructor() {
fun getRoomInvitesFlow( fun getRoomInvitesFlow(
inviteType: InviteTypeArg inviteType: InviteTypeArg
): Flow<List<RoomInviteListItem>> = combine( ): Flow<List<RoomInviteListItem>> = combine(
getAllCirclesRoomsLiveData(listOf(Membership.INVITE)).asFlow(), getAllRoomsLiveData(listOf(Membership.INVITE)).asFlow(),
MatrixSessionProvider.getSessionOrThrow().getKnownUsersFlow(), MatrixSessionProvider.getSessionOrThrow().getKnownUsersFlow(),
roomIdsToUnblurProfile roomIdsToUnblurProfile
) { roomSummaries, knownUsers, roomIdsToUnblur -> ) { roomSummaries, knownUsers, roomIdsToUnblur ->
......
...@@ -10,7 +10,7 @@ import org.futo.circles.core.extensions.createResult ...@@ -10,7 +10,7 @@ import org.futo.circles.core.extensions.createResult
import org.futo.circles.core.extensions.getKnownUsersFlow import org.futo.circles.core.extensions.getKnownUsersFlow
import org.futo.circles.core.extensions.getServerDomain import org.futo.circles.core.extensions.getServerDomain
import org.futo.circles.core.provider.MatrixSessionProvider import org.futo.circles.core.provider.MatrixSessionProvider
import org.futo.circles.core.utils.getAllCirclesRooms import org.futo.circles.core.utils.getAllRooms
import org.matrix.android.sdk.api.session.getRoom import org.matrix.android.sdk.api.session.getRoom
import org.matrix.android.sdk.api.session.user.model.User import org.matrix.android.sdk.api.session.user.model.User
import javax.inject.Inject import javax.inject.Inject
...@@ -20,7 +20,7 @@ class SearchUserDataSource @Inject constructor() { ...@@ -20,7 +20,7 @@ class SearchUserDataSource @Inject constructor() {
private val session = MatrixSessionProvider.currentSession private val session = MatrixSessionProvider.currentSession
suspend fun loadAllRoomMembersIfNeeded() { suspend fun loadAllRoomMembersIfNeeded() {
getAllCirclesRooms().forEach { getAllRooms().forEach {
session?.getRoom(it.roomId)?.membershipService()?.loadRoomMembersIfNeeded() session?.getRoom(it.roomId)?.membershipService()?.loadRoomMembersIfNeeded()
} }
} }
......
...@@ -78,11 +78,11 @@ private fun getAllRoomsFiler(membershipFilter: List<Membership>) = roomSummaryQu ...@@ -78,11 +78,11 @@ private fun getAllRoomsFiler(membershipFilter: List<Membership>) = roomSummaryQu
memberships = membershipFilter memberships = membershipFilter
} }
fun getAllCirclesRoomsLiveData(membershipFilter: List<Membership> = Membership.activeMemberships()) = fun getAllRoomsLiveData(membershipFilter: List<Membership> = Membership.activeMemberships()) =
MatrixSessionProvider.getSessionOrThrow().roomService() MatrixSessionProvider.getSessionOrThrow().roomService()
.getRoomSummariesLive(getAllRoomsFiler(membershipFilter)) .getRoomSummariesLive(getAllRoomsFiler(membershipFilter))
fun getAllCirclesRooms(membershipFilter: List<Membership> = Membership.activeMemberships()) = fun getAllRooms(membershipFilter: List<Membership> = Membership.activeMemberships()) =
MatrixSessionProvider.getSessionOrThrow().roomService() MatrixSessionProvider.getSessionOrThrow().roomService()
.getRoomSummaries(getAllRoomsFiler(membershipFilter)) .getRoomSummaries(getAllRoomsFiler(membershipFilter))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment