Merge branch 'develop' into feature/fga/update-rust-sdk-0.1.31
This commit is contained in:
commit
bd04b579c6
29 changed files with 223 additions and 88 deletions
3
.github/workflows/nightlyReports.yml
vendored
3
.github/workflows/nightlyReports.yml
vendored
|
|
@ -26,6 +26,9 @@ jobs:
|
||||||
distribution: 'temurin' # See 'Supported distributions' for available options
|
distribution: 'temurin' # See 'Supported distributions' for available options
|
||||||
java-version: '17'
|
java-version: '17'
|
||||||
|
|
||||||
|
- name: ⚙️ Run unit & screenshot tests, debug and release
|
||||||
|
run: ./gradlew test $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
||||||
|
|
||||||
- name: ⚙️ Run unit & screenshot tests, generate kover report
|
- name: ⚙️ Run unit & screenshot tests, generate kover report
|
||||||
run: ./gradlew koverMergedReport $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
run: ./gradlew koverMergedReport $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
||||||
|
|
||||||
|
|
|
||||||
3
.github/workflows/tests.yml
vendored
3
.github/workflows/tests.yml
vendored
|
|
@ -37,6 +37,9 @@ jobs:
|
||||||
with:
|
with:
|
||||||
cache-read-only: ${{ github.ref != 'refs/heads/develop' }}
|
cache-read-only: ${{ github.ref != 'refs/heads/develop' }}
|
||||||
|
|
||||||
|
- name: ⚙️ Run unit & screenshot tests, debug and release
|
||||||
|
run: ./gradlew test $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
||||||
|
|
||||||
- name: ⚙️ Run unit & screenshot tests, generate kover report
|
- name: ⚙️ Run unit & screenshot tests, generate kover report
|
||||||
run: ./gradlew koverMergedReport $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
run: ./gradlew koverMergedReport $CI_GRADLE_ARG_PROPERTIES -Pci-build=true
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -52,8 +52,7 @@ class MainActivity : NodeComponentActivity() {
|
||||||
Timber.tag(loggerTag.value).w("onCreate, with savedInstanceState: ${savedInstanceState != null}")
|
Timber.tag(loggerTag.value).w("onCreate, with savedInstanceState: ${savedInstanceState != null}")
|
||||||
installSplashScreen()
|
installSplashScreen()
|
||||||
super.onCreate(savedInstanceState)
|
super.onCreate(savedInstanceState)
|
||||||
appBindings = bindings<AppBindings>()
|
appBindings = bindings()
|
||||||
appBindings.matrixClientsHolder().restore(savedInstanceState)
|
|
||||||
WindowCompat.setDecorFitsSystemWindows(window, false)
|
WindowCompat.setDecorFitsSystemWindows(window, false)
|
||||||
setContent {
|
setContent {
|
||||||
MainContent(appBindings)
|
MainContent(appBindings)
|
||||||
|
|
@ -125,9 +124,4 @@ class MainActivity : NodeComponentActivity() {
|
||||||
super.onDestroy()
|
super.onDestroy()
|
||||||
Timber.tag(loggerTag.value).w("onDestroy")
|
Timber.tag(loggerTag.value).w("onDestroy")
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun onSaveInstanceState(outState: Bundle) {
|
|
||||||
super.onSaveInstanceState(outState)
|
|
||||||
bindings<AppBindings>().matrixClientsHolder().onSaveInstanceState(outState)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -17,13 +17,11 @@
|
||||||
package io.element.android.x.di
|
package io.element.android.x.di
|
||||||
|
|
||||||
import com.squareup.anvil.annotations.ContributesTo
|
import com.squareup.anvil.annotations.ContributesTo
|
||||||
import io.element.android.appnav.di.MatrixClientsHolder
|
|
||||||
import io.element.android.libraries.designsystem.utils.SnackbarDispatcher
|
import io.element.android.libraries.designsystem.utils.SnackbarDispatcher
|
||||||
import io.element.android.libraries.di.AppScope
|
import io.element.android.libraries.di.AppScope
|
||||||
|
|
||||||
@ContributesTo(AppScope::class)
|
@ContributesTo(AppScope::class)
|
||||||
interface AppBindings {
|
interface AppBindings {
|
||||||
fun matrixClientsHolder(): MatrixClientsHolder
|
|
||||||
fun mainDaggerComponentOwner(): MainDaggerComponentsOwner
|
fun mainDaggerComponentOwner(): MainDaggerComponentsOwner
|
||||||
fun snackbarDispatcher(): SnackbarDispatcher
|
fun snackbarDispatcher(): SnackbarDispatcher
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -154,8 +154,6 @@ class LoggedInFlowNode @AssistedInject constructor(
|
||||||
syncService.stopSync()
|
syncService.stopSync()
|
||||||
},
|
},
|
||||||
onDestroy = {
|
onDestroy = {
|
||||||
val imageLoaderFactory = bindings<MatrixUIBindings>().notLoggedInImageLoaderFactory()
|
|
||||||
Coil.setImageLoader(imageLoaderFactory)
|
|
||||||
plugins<LifecycleCallback>().forEach { it.onFlowReleased(id, inputs.matrixClient) }
|
plugins<LifecycleCallback>().forEach { it.onFlowReleased(id, inputs.matrixClient) }
|
||||||
appNavigationStateService.onLeavingSpace(id)
|
appNavigationStateService.onLeavingSpace(id)
|
||||||
appNavigationStateService.onLeavingSession(id)
|
appNavigationStateService.onLeavingSession(id)
|
||||||
|
|
|
||||||
|
|
@ -19,6 +19,7 @@ package io.element.android.appnav
|
||||||
import android.os.Parcelable
|
import android.os.Parcelable
|
||||||
import androidx.compose.runtime.Composable
|
import androidx.compose.runtime.Composable
|
||||||
import androidx.compose.ui.Modifier
|
import androidx.compose.ui.Modifier
|
||||||
|
import coil.Coil
|
||||||
import com.bumble.appyx.core.composable.Children
|
import com.bumble.appyx.core.composable.Children
|
||||||
import com.bumble.appyx.core.lifecycle.subscribe
|
import com.bumble.appyx.core.lifecycle.subscribe
|
||||||
import com.bumble.appyx.core.modality.BuildContext
|
import com.bumble.appyx.core.modality.BuildContext
|
||||||
|
|
@ -34,8 +35,8 @@ import io.element.android.features.onboarding.api.OnBoardingEntryPoint
|
||||||
import io.element.android.libraries.architecture.BackstackNode
|
import io.element.android.libraries.architecture.BackstackNode
|
||||||
import io.element.android.libraries.architecture.animation.rememberDefaultTransitionHandler
|
import io.element.android.libraries.architecture.animation.rememberDefaultTransitionHandler
|
||||||
import io.element.android.libraries.di.AppScope
|
import io.element.android.libraries.di.AppScope
|
||||||
|
import io.element.android.libraries.matrix.ui.media.NotLoggedInImageLoaderFactory
|
||||||
import kotlinx.parcelize.Parcelize
|
import kotlinx.parcelize.Parcelize
|
||||||
import timber.log.Timber
|
|
||||||
|
|
||||||
@ContributesNode(AppScope::class)
|
@ContributesNode(AppScope::class)
|
||||||
class NotLoggedInFlowNode @AssistedInject constructor(
|
class NotLoggedInFlowNode @AssistedInject constructor(
|
||||||
|
|
@ -43,6 +44,7 @@ class NotLoggedInFlowNode @AssistedInject constructor(
|
||||||
@Assisted plugins: List<Plugin>,
|
@Assisted plugins: List<Plugin>,
|
||||||
private val onBoardingEntryPoint: OnBoardingEntryPoint,
|
private val onBoardingEntryPoint: OnBoardingEntryPoint,
|
||||||
private val loginEntryPoint: LoginEntryPoint,
|
private val loginEntryPoint: LoginEntryPoint,
|
||||||
|
private val notLoggedInImageLoaderFactory: NotLoggedInImageLoaderFactory,
|
||||||
) : BackstackNode<NotLoggedInFlowNode.NavTarget>(
|
) : BackstackNode<NotLoggedInFlowNode.NavTarget>(
|
||||||
backstack = BackStack(
|
backstack = BackStack(
|
||||||
initialElement = NavTarget.OnBoarding,
|
initialElement = NavTarget.OnBoarding,
|
||||||
|
|
@ -51,10 +53,12 @@ class NotLoggedInFlowNode @AssistedInject constructor(
|
||||||
buildContext = buildContext,
|
buildContext = buildContext,
|
||||||
plugins = plugins,
|
plugins = plugins,
|
||||||
) {
|
) {
|
||||||
init {
|
override fun onBuilt() {
|
||||||
|
super.onBuilt()
|
||||||
lifecycle.subscribe(
|
lifecycle.subscribe(
|
||||||
onCreate = { Timber.v("OnCreate") },
|
onCreate = {
|
||||||
onDestroy = { Timber.v("OnDestroy") }
|
Coil.setImageLoader(notLoggedInImageLoaderFactory)
|
||||||
|
},
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -30,6 +30,7 @@ import com.bumble.appyx.core.node.Node
|
||||||
import com.bumble.appyx.core.node.node
|
import com.bumble.appyx.core.node.node
|
||||||
import com.bumble.appyx.core.plugin.Plugin
|
import com.bumble.appyx.core.plugin.Plugin
|
||||||
import com.bumble.appyx.core.plugin.plugins
|
import com.bumble.appyx.core.plugin.plugins
|
||||||
|
import com.bumble.appyx.core.state.MutableSavedStateMap
|
||||||
import com.bumble.appyx.navmodel.backstack.BackStack
|
import com.bumble.appyx.navmodel.backstack.BackStack
|
||||||
import com.bumble.appyx.navmodel.backstack.operation.pop
|
import com.bumble.appyx.navmodel.backstack.operation.pop
|
||||||
import com.bumble.appyx.navmodel.backstack.operation.push
|
import com.bumble.appyx.navmodel.backstack.operation.push
|
||||||
|
|
@ -90,10 +91,16 @@ class RootFlowNode @AssistedInject constructor(
|
||||||
) {
|
) {
|
||||||
|
|
||||||
override fun onBuilt() {
|
override fun onBuilt() {
|
||||||
|
matrixClientsHolder.restore(buildContext.savedStateMap)
|
||||||
super.onBuilt()
|
super.onBuilt()
|
||||||
observeLoggedInState()
|
observeLoggedInState()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
override fun onSaveInstanceState(state: MutableSavedStateMap) {
|
||||||
|
super.onSaveInstanceState(state)
|
||||||
|
matrixClientsHolder.save(state)
|
||||||
|
}
|
||||||
|
|
||||||
private fun observeLoggedInState() {
|
private fun observeLoggedInState() {
|
||||||
combine(
|
combine(
|
||||||
cacheService.onClearedCacheEventFlow(),
|
cacheService.onClearedCacheEventFlow(),
|
||||||
|
|
|
||||||
|
|
@ -16,13 +16,11 @@
|
||||||
|
|
||||||
package io.element.android.appnav.di
|
package io.element.android.appnav.di
|
||||||
|
|
||||||
import android.os.Bundle
|
import com.bumble.appyx.core.state.MutableSavedStateMap
|
||||||
import io.element.android.libraries.di.AppScope
|
import com.bumble.appyx.core.state.SavedStateMap
|
||||||
import io.element.android.libraries.di.SingleIn
|
|
||||||
import io.element.android.libraries.matrix.api.MatrixClient
|
import io.element.android.libraries.matrix.api.MatrixClient
|
||||||
import io.element.android.libraries.matrix.api.auth.MatrixAuthenticationService
|
import io.element.android.libraries.matrix.api.auth.MatrixAuthenticationService
|
||||||
import io.element.android.libraries.matrix.api.core.SessionId
|
import io.element.android.libraries.matrix.api.core.SessionId
|
||||||
import io.element.android.libraries.matrix.api.core.UserId
|
|
||||||
import kotlinx.coroutines.runBlocking
|
import kotlinx.coroutines.runBlocking
|
||||||
import timber.log.Timber
|
import timber.log.Timber
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
import java.util.concurrent.ConcurrentHashMap
|
||||||
|
|
@ -30,7 +28,6 @@ import javax.inject.Inject
|
||||||
|
|
||||||
private const val SAVE_INSTANCE_KEY = "io.element.android.x.di.MatrixClientsHolder.SaveInstanceKey"
|
private const val SAVE_INSTANCE_KEY = "io.element.android.x.di.MatrixClientsHolder.SaveInstanceKey"
|
||||||
|
|
||||||
@SingleIn(AppScope::class)
|
|
||||||
class MatrixClientsHolder @Inject constructor(private val authenticationService: MatrixAuthenticationService) {
|
class MatrixClientsHolder @Inject constructor(private val authenticationService: MatrixAuthenticationService) {
|
||||||
|
|
||||||
private val sessionIdsToMatrixClient = ConcurrentHashMap<SessionId, MatrixClient>()
|
private val sessionIdsToMatrixClient = ConcurrentHashMap<SessionId, MatrixClient>()
|
||||||
|
|
@ -55,16 +52,20 @@ class MatrixClientsHolder @Inject constructor(private val authenticationService:
|
||||||
return sessionIdsToMatrixClient[sessionId]
|
return sessionIdsToMatrixClient[sessionId]
|
||||||
}
|
}
|
||||||
|
|
||||||
@Suppress("DEPRECATION")
|
@Suppress("UNCHECKED_CAST")
|
||||||
fun restore(savedInstanceState: Bundle?) {
|
fun restore(state: SavedStateMap?) {
|
||||||
if (savedInstanceState == null || sessionIdsToMatrixClient.isNotEmpty()) return
|
Timber.d("Restore state")
|
||||||
val userIds = savedInstanceState.getSerializable(SAVE_INSTANCE_KEY) as? Array<UserId>
|
if (state == null || sessionIdsToMatrixClient.isNotEmpty()) return Unit.also {
|
||||||
if (userIds.isNullOrEmpty()) return
|
Timber.w("Restore with non-empty map")
|
||||||
|
}
|
||||||
|
val sessionIds = state[SAVE_INSTANCE_KEY] as? Array<SessionId>
|
||||||
|
Timber.d("Restore matrix session keys = ${sessionIds?.map { it.value }}")
|
||||||
|
if (sessionIds.isNullOrEmpty()) return
|
||||||
// Not ideal but should only happens in case of process recreation. This ensure we restore all the active sessions before restoring the node graphs.
|
// Not ideal but should only happens in case of process recreation. This ensure we restore all the active sessions before restoring the node graphs.
|
||||||
runBlocking {
|
runBlocking {
|
||||||
userIds.forEach { userId ->
|
sessionIds.forEach { sessionId ->
|
||||||
Timber.v("Restore matrix session: $userId")
|
Timber.d("Restore matrix session: $sessionId")
|
||||||
authenticationService.restoreSession(userId)
|
authenticationService.restoreSession(sessionId)
|
||||||
.onSuccess { matrixClient ->
|
.onSuccess { matrixClient ->
|
||||||
add(matrixClient)
|
add(matrixClient)
|
||||||
}
|
}
|
||||||
|
|
@ -75,9 +76,9 @@ class MatrixClientsHolder @Inject constructor(private val authenticationService:
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fun onSaveInstanceState(outState: Bundle) {
|
fun save(state: MutableSavedStateMap) {
|
||||||
val sessionKeys = sessionIdsToMatrixClient.keys.toTypedArray()
|
val sessionKeys = sessionIdsToMatrixClient.keys.toTypedArray()
|
||||||
Timber.v("Save matrix session keys = $sessionKeys")
|
Timber.d("Save matrix session keys = ${sessionKeys.map { it.value }}")
|
||||||
outState.putSerializable(SAVE_INSTANCE_KEY, sessionKeys)
|
state[SAVE_INSTANCE_KEY] = sessionKeys
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -65,7 +65,6 @@ class ForwardMessagesPresenterTests {
|
||||||
}.test {
|
}.test {
|
||||||
val initialState = awaitItem()
|
val initialState = awaitItem()
|
||||||
skipItems(1)
|
skipItems(1)
|
||||||
val summary = aRoomSummaryDetail()
|
|
||||||
|
|
||||||
initialState.eventSink(ForwardMessagesEvents.ToggleSearchActive)
|
initialState.eventSink(ForwardMessagesEvents.ToggleSearchActive)
|
||||||
assertThat(awaitItem().isSearchActive).isTrue()
|
assertThat(awaitItem().isSearchActive).isTrue()
|
||||||
|
|
|
||||||
|
|
@ -25,28 +25,65 @@ import androidx.compose.ui.res.stringResource
|
||||||
import io.element.android.features.roomdetails.impl.R
|
import io.element.android.features.roomdetails.impl.R
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsEvents
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsEvents
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState
|
||||||
|
import io.element.android.libraries.architecture.Async
|
||||||
|
import io.element.android.libraries.core.bool.orFalse
|
||||||
import io.element.android.libraries.designsystem.components.dialogs.ConfirmationDialog
|
import io.element.android.libraries.designsystem.components.dialogs.ConfirmationDialog
|
||||||
|
import io.element.android.libraries.designsystem.components.dialogs.RetryDialog
|
||||||
import io.element.android.libraries.designsystem.components.preferences.PreferenceCategory
|
import io.element.android.libraries.designsystem.components.preferences.PreferenceCategory
|
||||||
import io.element.android.libraries.designsystem.components.preferences.PreferenceText
|
import io.element.android.libraries.designsystem.components.preferences.PreferenceText
|
||||||
|
import io.element.android.libraries.ui.strings.CommonStrings
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
internal fun BlockUserSection(state: RoomMemberDetailsState, modifier: Modifier = Modifier) {
|
internal fun BlockUserSection(state: RoomMemberDetailsState, modifier: Modifier = Modifier) {
|
||||||
PreferenceCategory(showDivider = false, modifier = modifier) {
|
PreferenceCategory(showDivider = false, modifier = modifier) {
|
||||||
if (state.isBlocked) {
|
when (state.isBlocked) {
|
||||||
PreferenceText(
|
is Async.Failure -> PreferenceBlockUser(isBlocked = state.isBlocked.prevData, isLoading = false, eventSink = state.eventSink)
|
||||||
title = stringResource(R.string.screen_dm_details_unblock_user),
|
is Async.Loading -> PreferenceBlockUser(isBlocked = state.isBlocked.prevData, isLoading = true, eventSink = state.eventSink)
|
||||||
icon = Icons.Outlined.Block,
|
is Async.Success -> PreferenceBlockUser(isBlocked = state.isBlocked.data, isLoading = false, eventSink = state.eventSink)
|
||||||
onClick = { state.eventSink(RoomMemberDetailsEvents.UnblockUser(needsConfirmation = true)) },
|
Async.Uninitialized -> PreferenceBlockUser(isBlocked = null, isLoading = true, eventSink = state.eventSink)
|
||||||
)
|
|
||||||
} else {
|
|
||||||
PreferenceText(
|
|
||||||
title = stringResource(R.string.screen_dm_details_block_user),
|
|
||||||
icon = Icons.Outlined.Block,
|
|
||||||
tintColor = MaterialTheme.colorScheme.error,
|
|
||||||
onClick = { state.eventSink(RoomMemberDetailsEvents.BlockUser(needsConfirmation = true)) },
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (state.isBlocked is Async.Failure) {
|
||||||
|
RetryDialog(
|
||||||
|
content = stringResource(CommonStrings.error_unknown),
|
||||||
|
onDismiss = { state.eventSink(RoomMemberDetailsEvents.ClearBlockUserError) },
|
||||||
|
onRetry = {
|
||||||
|
val event = when (state.isBlocked.prevData) {
|
||||||
|
true -> RoomMemberDetailsEvents.UnblockUser(needsConfirmation = false)
|
||||||
|
false -> RoomMemberDetailsEvents.BlockUser(needsConfirmation = false)
|
||||||
|
null -> /*Should not happen */ RoomMemberDetailsEvents.ClearBlockUserError
|
||||||
|
}
|
||||||
|
state.eventSink(event)
|
||||||
|
},
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Composable
|
||||||
|
private fun PreferenceBlockUser(
|
||||||
|
isBlocked: Boolean?,
|
||||||
|
isLoading: Boolean,
|
||||||
|
eventSink: (RoomMemberDetailsEvents) -> Unit,
|
||||||
|
modifier: Modifier = Modifier,
|
||||||
|
) {
|
||||||
|
if (isBlocked.orFalse()) {
|
||||||
|
PreferenceText(
|
||||||
|
title = stringResource(R.string.screen_dm_details_unblock_user),
|
||||||
|
icon = Icons.Outlined.Block,
|
||||||
|
onClick = { if (!isLoading) eventSink(RoomMemberDetailsEvents.UnblockUser(needsConfirmation = true)) },
|
||||||
|
loadingCurrentValue = isLoading,
|
||||||
|
modifier = modifier,
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
PreferenceText(
|
||||||
|
title = stringResource(R.string.screen_dm_details_block_user),
|
||||||
|
icon = Icons.Outlined.Block,
|
||||||
|
tintColor = MaterialTheme.colorScheme.error,
|
||||||
|
onClick = { if (!isLoading) eventSink(RoomMemberDetailsEvents.BlockUser(needsConfirmation = true)) },
|
||||||
|
loadingCurrentValue = isLoading,
|
||||||
|
modifier = modifier,
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
|
|
|
||||||
|
|
@ -19,5 +19,6 @@ package io.element.android.features.roomdetails.impl.members.details
|
||||||
sealed interface RoomMemberDetailsEvents {
|
sealed interface RoomMemberDetailsEvents {
|
||||||
data class BlockUser(val needsConfirmation: Boolean = false) : RoomMemberDetailsEvents
|
data class BlockUser(val needsConfirmation: Boolean = false) : RoomMemberDetailsEvents
|
||||||
data class UnblockUser(val needsConfirmation: Boolean = false) : RoomMemberDetailsEvents
|
data class UnblockUser(val needsConfirmation: Boolean = false) : RoomMemberDetailsEvents
|
||||||
|
object ClearBlockUserError : RoomMemberDetailsEvents
|
||||||
object ClearConfirmationDialog : RoomMemberDetailsEvents
|
object ClearConfirmationDialog : RoomMemberDetailsEvents
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -28,6 +28,7 @@ import androidx.compose.runtime.setValue
|
||||||
import dagger.assisted.Assisted
|
import dagger.assisted.Assisted
|
||||||
import dagger.assisted.AssistedInject
|
import dagger.assisted.AssistedInject
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState.ConfirmationDialog
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState.ConfirmationDialog
|
||||||
|
import io.element.android.libraries.architecture.Async
|
||||||
import io.element.android.libraries.architecture.Presenter
|
import io.element.android.libraries.architecture.Presenter
|
||||||
import io.element.android.libraries.core.bool.orFalse
|
import io.element.android.libraries.core.bool.orFalse
|
||||||
import io.element.android.libraries.matrix.api.MatrixClient
|
import io.element.android.libraries.matrix.api.MatrixClient
|
||||||
|
|
@ -53,8 +54,13 @@ class RoomMemberDetailsPresenter @AssistedInject constructor(
|
||||||
var confirmationDialog by remember { mutableStateOf<ConfirmationDialog?>(null) }
|
var confirmationDialog by remember { mutableStateOf<ConfirmationDialog?>(null) }
|
||||||
val roomMember by room.getRoomMemberAsState(roomMemberId)
|
val roomMember by room.getRoomMemberAsState(roomMemberId)
|
||||||
// the room member is not really live...
|
// the room member is not really live...
|
||||||
val isBlocked = remember {
|
val isBlocked: MutableState<Async<Boolean>> = remember(roomMember) {
|
||||||
mutableStateOf(roomMember?.isIgnored.orFalse())
|
val isIgnored = roomMember?.isIgnored
|
||||||
|
if (isIgnored == null) {
|
||||||
|
mutableStateOf(Async.Uninitialized)
|
||||||
|
} else {
|
||||||
|
mutableStateOf(Async.Success(isIgnored))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
LaunchedEffect(Unit) {
|
LaunchedEffect(Unit) {
|
||||||
room.updateMembers()
|
room.updateMembers()
|
||||||
|
|
@ -79,6 +85,9 @@ class RoomMemberDetailsPresenter @AssistedInject constructor(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
RoomMemberDetailsEvents.ClearConfirmationDialog -> confirmationDialog = null
|
RoomMemberDetailsEvents.ClearConfirmationDialog -> confirmationDialog = null
|
||||||
|
RoomMemberDetailsEvents.ClearBlockUserError -> {
|
||||||
|
isBlocked.value = Async.Success(isBlocked.value.dataOrNull().orFalse())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -105,20 +114,31 @@ class RoomMemberDetailsPresenter @AssistedInject constructor(
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun CoroutineScope.blockUser(userId: UserId, isBlockedState: MutableState<Boolean>) = launch {
|
private fun CoroutineScope.blockUser(userId: UserId, isBlockedState: MutableState<Async<Boolean>>) = launch {
|
||||||
|
isBlockedState.value = Async.Loading(false)
|
||||||
client.ignoreUser(userId)
|
client.ignoreUser(userId)
|
||||||
.map {
|
.fold(
|
||||||
isBlockedState.value = true
|
onSuccess = {
|
||||||
room.updateMembers()
|
isBlockedState.value = Async.Success(true)
|
||||||
}
|
room.updateMembers()
|
||||||
|
},
|
||||||
|
onFailure = {
|
||||||
|
isBlockedState.value = Async.Failure(it, false)
|
||||||
|
}
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun CoroutineScope.unblockUser(userId: UserId, isBlockedState: MutableState<Boolean>) = launch {
|
private fun CoroutineScope.unblockUser(userId: UserId, isBlockedState: MutableState<Async<Boolean>>) = launch {
|
||||||
|
isBlockedState.value = Async.Loading(true)
|
||||||
client.unignoreUser(userId)
|
client.unignoreUser(userId)
|
||||||
.map {
|
.fold(
|
||||||
isBlockedState.value = false
|
onSuccess = {
|
||||||
room.updateMembers()
|
isBlockedState.value = Async.Success(false)
|
||||||
}
|
room.updateMembers()
|
||||||
|
},
|
||||||
|
onFailure = {
|
||||||
|
isBlockedState.value = Async.Failure(it, true)
|
||||||
|
}
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -16,11 +16,13 @@
|
||||||
|
|
||||||
package io.element.android.features.roomdetails.impl.members.details
|
package io.element.android.features.roomdetails.impl.members.details
|
||||||
|
|
||||||
|
import io.element.android.libraries.architecture.Async
|
||||||
|
|
||||||
data class RoomMemberDetailsState(
|
data class RoomMemberDetailsState(
|
||||||
val userId: String,
|
val userId: String,
|
||||||
val userName: String?,
|
val userName: String?,
|
||||||
val avatarUrl: String?,
|
val avatarUrl: String?,
|
||||||
val isBlocked: Boolean,
|
val isBlocked: Async<Boolean>,
|
||||||
val displayConfirmationDialog: ConfirmationDialog? = null,
|
val displayConfirmationDialog: ConfirmationDialog? = null,
|
||||||
val isCurrentUser: Boolean,
|
val isCurrentUser: Boolean,
|
||||||
val eventSink: (RoomMemberDetailsEvents) -> Unit
|
val eventSink: (RoomMemberDetailsEvents) -> Unit
|
||||||
|
|
|
||||||
|
|
@ -17,15 +17,17 @@
|
||||||
package io.element.android.features.roomdetails.impl.members.details
|
package io.element.android.features.roomdetails.impl.members.details
|
||||||
|
|
||||||
import androidx.compose.ui.tooling.preview.PreviewParameterProvider
|
import androidx.compose.ui.tooling.preview.PreviewParameterProvider
|
||||||
|
import io.element.android.libraries.architecture.Async
|
||||||
|
|
||||||
open class RoomMemberDetailsStateProvider : PreviewParameterProvider<RoomMemberDetailsState> {
|
open class RoomMemberDetailsStateProvider : PreviewParameterProvider<RoomMemberDetailsState> {
|
||||||
override val values: Sequence<RoomMemberDetailsState>
|
override val values: Sequence<RoomMemberDetailsState>
|
||||||
get() = sequenceOf(
|
get() = sequenceOf(
|
||||||
aRoomMemberDetailsState(),
|
aRoomMemberDetailsState(),
|
||||||
aRoomMemberDetailsState().copy(userName = null),
|
aRoomMemberDetailsState().copy(userName = null),
|
||||||
aRoomMemberDetailsState().copy(isBlocked = true),
|
aRoomMemberDetailsState().copy(isBlocked = Async.Success(true)),
|
||||||
aRoomMemberDetailsState().copy(displayConfirmationDialog = RoomMemberDetailsState.ConfirmationDialog.Block),
|
aRoomMemberDetailsState().copy(displayConfirmationDialog = RoomMemberDetailsState.ConfirmationDialog.Block),
|
||||||
aRoomMemberDetailsState().copy(displayConfirmationDialog = RoomMemberDetailsState.ConfirmationDialog.Unblock),
|
aRoomMemberDetailsState().copy(displayConfirmationDialog = RoomMemberDetailsState.ConfirmationDialog.Unblock),
|
||||||
|
aRoomMemberDetailsState().copy(isBlocked = Async.Loading(true)),
|
||||||
// Add other states here
|
// Add other states here
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
@ -34,7 +36,7 @@ fun aRoomMemberDetailsState() = RoomMemberDetailsState(
|
||||||
userId = "@daniel:domain.com",
|
userId = "@daniel:domain.com",
|
||||||
userName = "Daniel",
|
userName = "Daniel",
|
||||||
avatarUrl = null,
|
avatarUrl = null,
|
||||||
isBlocked = false,
|
isBlocked = Async.Success(false),
|
||||||
isCurrentUser = false,
|
isCurrentUser = false,
|
||||||
eventSink = {},
|
eventSink = {},
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -25,7 +25,9 @@ import io.element.android.features.roomdetails.impl.members.aRoomMember
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsEvents
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsEvents
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsPresenter
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsPresenter
|
||||||
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState
|
import io.element.android.features.roomdetails.impl.members.details.RoomMemberDetailsState
|
||||||
|
import io.element.android.libraries.architecture.Async
|
||||||
import io.element.android.libraries.matrix.api.room.MatrixRoomMembersState
|
import io.element.android.libraries.matrix.api.room.MatrixRoomMembersState
|
||||||
|
import io.element.android.libraries.matrix.test.A_THROWABLE
|
||||||
import io.element.android.libraries.matrix.test.FakeMatrixClient
|
import io.element.android.libraries.matrix.test.FakeMatrixClient
|
||||||
import kotlinx.coroutines.ExperimentalCoroutinesApi
|
import kotlinx.coroutines.ExperimentalCoroutinesApi
|
||||||
import kotlinx.coroutines.test.runTest
|
import kotlinx.coroutines.test.runTest
|
||||||
|
|
@ -50,7 +52,7 @@ class RoomMemberDetailsPresenterTests {
|
||||||
Truth.assertThat(initialState.userId).isEqualTo(roomMember.userId.value)
|
Truth.assertThat(initialState.userId).isEqualTo(roomMember.userId.value)
|
||||||
Truth.assertThat(initialState.userName).isEqualTo(roomMember.displayName)
|
Truth.assertThat(initialState.userName).isEqualTo(roomMember.displayName)
|
||||||
Truth.assertThat(initialState.avatarUrl).isEqualTo(roomMember.avatarUrl)
|
Truth.assertThat(initialState.avatarUrl).isEqualTo(roomMember.avatarUrl)
|
||||||
Truth.assertThat(initialState.isBlocked).isEqualTo(roomMember.isIgnored)
|
Truth.assertThat(initialState.isBlocked).isEqualTo(Async.Success(roomMember.isIgnored))
|
||||||
skipItems(1)
|
skipItems(1)
|
||||||
val loadedState = awaitItem()
|
val loadedState = awaitItem()
|
||||||
Truth.assertThat(loadedState.userName).isEqualTo("A custom name")
|
Truth.assertThat(loadedState.userName).isEqualTo("A custom name")
|
||||||
|
|
@ -129,10 +131,33 @@ class RoomMemberDetailsPresenterTests {
|
||||||
}.test {
|
}.test {
|
||||||
val initialState = awaitItem()
|
val initialState = awaitItem()
|
||||||
initialState.eventSink(RoomMemberDetailsEvents.BlockUser(needsConfirmation = false))
|
initialState.eventSink(RoomMemberDetailsEvents.BlockUser(needsConfirmation = false))
|
||||||
Truth.assertThat(awaitItem().isBlocked).isTrue()
|
Truth.assertThat(awaitItem().isBlocked.isLoading()).isTrue()
|
||||||
|
Truth.assertThat(awaitItem().isBlocked.dataOrNull()).isTrue()
|
||||||
|
|
||||||
initialState.eventSink(RoomMemberDetailsEvents.UnblockUser(needsConfirmation = false))
|
initialState.eventSink(RoomMemberDetailsEvents.UnblockUser(needsConfirmation = false))
|
||||||
Truth.assertThat(awaitItem().isBlocked).isFalse()
|
Truth.assertThat(awaitItem().isBlocked.isLoading()).isTrue()
|
||||||
|
Truth.assertThat(awaitItem().isBlocked.dataOrNull()).isFalse()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun `present - BlockUser with error`() = runTest {
|
||||||
|
val room = aMatrixRoom()
|
||||||
|
val roomMember = aRoomMember()
|
||||||
|
val matrixClient = FakeMatrixClient()
|
||||||
|
matrixClient.givenIgnoreUserResult(Result.failure(A_THROWABLE))
|
||||||
|
val presenter = RoomMemberDetailsPresenter(matrixClient, room, roomMember.userId)
|
||||||
|
moleculeFlow(RecompositionClock.Immediate) {
|
||||||
|
presenter.present()
|
||||||
|
}.test {
|
||||||
|
val initialState = awaitItem()
|
||||||
|
initialState.eventSink(RoomMemberDetailsEvents.BlockUser(needsConfirmation = false))
|
||||||
|
Truth.assertThat(awaitItem().isBlocked.isLoading()).isTrue()
|
||||||
|
val errorState = awaitItem()
|
||||||
|
Truth.assertThat(errorState.isBlocked.errorOrNull()).isEqualTo(A_THROWABLE)
|
||||||
|
// Clear error
|
||||||
|
initialState.eventSink(RoomMemberDetailsEvents.ClearBlockUserError)
|
||||||
|
Truth.assertThat(awaitItem().isBlocked).isEqualTo(Async.Success(false))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -19,6 +19,7 @@ package io.element.android.libraries.architecture
|
||||||
import androidx.compose.runtime.Stable
|
import androidx.compose.runtime.Stable
|
||||||
import com.bumble.appyx.core.children.ChildEntry
|
import com.bumble.appyx.core.children.ChildEntry
|
||||||
import com.bumble.appyx.core.modality.BuildContext
|
import com.bumble.appyx.core.modality.BuildContext
|
||||||
|
import com.bumble.appyx.core.node.Node
|
||||||
import com.bumble.appyx.core.node.ParentNode
|
import com.bumble.appyx.core.node.ParentNode
|
||||||
import com.bumble.appyx.core.plugin.Plugin
|
import com.bumble.appyx.core.plugin.Plugin
|
||||||
import com.bumble.appyx.navmodel.backstack.BackStack
|
import com.bumble.appyx.navmodel.backstack.BackStack
|
||||||
|
|
@ -39,4 +40,15 @@ abstract class BackstackNode<NavTarget : Any>(
|
||||||
buildContext = buildContext,
|
buildContext = buildContext,
|
||||||
plugins = plugins,
|
plugins = plugins,
|
||||||
childKeepMode = childKeepMode,
|
childKeepMode = childKeepMode,
|
||||||
)
|
) {
|
||||||
|
override fun onBuilt() {
|
||||||
|
super.onBuilt()
|
||||||
|
lifecycle.logLifecycle(this::class.java.simpleName)
|
||||||
|
whenChildAttached<Node> { _, child ->
|
||||||
|
// BackstackNode will be logged by their parent.
|
||||||
|
if (child !is BackstackNode<*>) {
|
||||||
|
child.lifecycle.logLifecycle(child::class.java.simpleName)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,30 @@
|
||||||
|
/*
|
||||||
|
* Copyright (c) 2023 New Vector Ltd
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package io.element.android.libraries.architecture
|
||||||
|
|
||||||
|
import androidx.lifecycle.Lifecycle
|
||||||
|
import com.bumble.appyx.core.lifecycle.subscribe
|
||||||
|
import timber.log.Timber
|
||||||
|
|
||||||
|
fun Lifecycle.logLifecycle(name: String) {
|
||||||
|
subscribe(
|
||||||
|
onCreate = { Timber.tag("Lifecycle").d("onCreate $name") },
|
||||||
|
onPause = { Timber.tag("Lifecycle").d("onPause $name") },
|
||||||
|
onResume = { Timber.tag("Lifecycle").d("onResume $name") },
|
||||||
|
onDestroy = { Timber.tag("Lifecycle").d("onDestroy $name") },
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
@ -64,7 +64,7 @@ fun String?.insertBeforeLast(insert: String, delimiter: String = "."): String {
|
||||||
* Throws if length is < 1.
|
* Throws if length is < 1.
|
||||||
*/
|
*/
|
||||||
fun String.ellipsize(length: Int): String {
|
fun String.ellipsize(length: Int): String {
|
||||||
require(length > 1)
|
require(length >= 1)
|
||||||
|
|
||||||
if (this.length <= length) {
|
if (this.length <= length) {
|
||||||
return this
|
return this
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,6 @@ package io.element.android.libraries.deeplink
|
||||||
|
|
||||||
import android.content.Intent
|
import android.content.Intent
|
||||||
import android.net.Uri
|
import android.net.Uri
|
||||||
import io.element.android.libraries.core.data.tryOrNull
|
|
||||||
import io.element.android.libraries.matrix.api.core.RoomId
|
import io.element.android.libraries.matrix.api.core.RoomId
|
||||||
import io.element.android.libraries.matrix.api.core.SessionId
|
import io.element.android.libraries.matrix.api.core.SessionId
|
||||||
import io.element.android.libraries.matrix.api.core.ThreadId
|
import io.element.android.libraries.matrix.api.core.ThreadId
|
||||||
|
|
@ -37,21 +36,15 @@ class DeeplinkParser @Inject constructor() {
|
||||||
if (host != HOST) return null
|
if (host != HOST) return null
|
||||||
val pathBits = path.orEmpty().split("/").drop(1)
|
val pathBits = path.orEmpty().split("/").drop(1)
|
||||||
val sessionId = pathBits.elementAtOrNull(0)?.let(::SessionId) ?: return null
|
val sessionId = pathBits.elementAtOrNull(0)?.let(::SessionId) ?: return null
|
||||||
val screenPathComponent = pathBits.elementAtOrNull(1)
|
|
||||||
val roomId = tryOrNull { screenPathComponent?.let(::RoomId) }
|
|
||||||
|
|
||||||
return when {
|
return when (val screenPathComponent = pathBits.elementAtOrNull(1)) {
|
||||||
roomId != null -> {
|
null -> DeeplinkData.Root(sessionId)
|
||||||
|
DeepLinkPaths.INVITE_LIST -> DeeplinkData.InviteList(sessionId)
|
||||||
|
else -> {
|
||||||
|
val roomId = screenPathComponent.let(::RoomId)
|
||||||
val threadId = pathBits.elementAtOrNull(2)?.let(::ThreadId)
|
val threadId = pathBits.elementAtOrNull(2)?.let(::ThreadId)
|
||||||
DeeplinkData.Room(sessionId, roomId, threadId)
|
DeeplinkData.Room(sessionId, roomId, threadId)
|
||||||
}
|
}
|
||||||
screenPathComponent == DeepLinkPaths.INVITE_LIST -> {
|
|
||||||
DeeplinkData.InviteList(sessionId)
|
|
||||||
}
|
|
||||||
screenPathComponent == null -> {
|
|
||||||
DeeplinkData.Root(sessionId)
|
|
||||||
}
|
|
||||||
else -> null
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -34,7 +34,7 @@ class RoomMembershipContentFormatter @Inject constructor(
|
||||||
): CharSequence? {
|
): CharSequence? {
|
||||||
val userId = membershipContent.userId
|
val userId = membershipContent.userId
|
||||||
val memberIsYou = matrixClient.isMe(userId)
|
val memberIsYou = matrixClient.isMe(userId)
|
||||||
return when (val change = membershipContent.change) {
|
return when (membershipContent.change) {
|
||||||
MembershipChange.JOINED -> if (memberIsYou) {
|
MembershipChange.JOINED -> if (memberIsYou) {
|
||||||
sp.getString(R.string.state_event_room_join_by_you)
|
sp.getString(R.string.state_event_room_join_by_you)
|
||||||
} else {
|
} else {
|
||||||
|
|
|
||||||
|
|
@ -86,7 +86,7 @@ interface MatrixRoom : Closeable {
|
||||||
|
|
||||||
suspend fun toggleReaction(emoji: String, eventId: EventId): Result<Unit>
|
suspend fun toggleReaction(emoji: String, eventId: EventId): Result<Unit>
|
||||||
|
|
||||||
suspend fun forwardEvent(eventId: EventId, rooms: List<RoomId>): Result<Unit>
|
suspend fun forwardEvent(eventId: EventId, roomIds: List<RoomId>): Result<Unit>
|
||||||
|
|
||||||
suspend fun retrySendMessage(transactionId: String): Result<Unit>
|
suspend fun retrySendMessage(transactionId: String): Result<Unit>
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -38,12 +38,13 @@ interface RoomSummaryDataSource {
|
||||||
|
|
||||||
suspend fun RoomSummaryDataSource.awaitAllRoomsAreLoaded(timeout: Duration = Duration.INFINITE) {
|
suspend fun RoomSummaryDataSource.awaitAllRoomsAreLoaded(timeout: Duration = Duration.INFINITE) {
|
||||||
try {
|
try {
|
||||||
|
Timber.d("awaitAllRoomsAreLoaded: wait")
|
||||||
withTimeout(timeout) {
|
withTimeout(timeout) {
|
||||||
allRoomsLoadingState().firstOrNull {
|
allRoomsLoadingState().firstOrNull {
|
||||||
it is RoomSummaryDataSource.LoadingState.Loaded
|
it is RoomSummaryDataSource.LoadingState.Loaded
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (timeoutException: TimeoutCancellationException) {
|
} catch (timeoutException: TimeoutCancellationException) {
|
||||||
Timber.v("AwaitAllRooms: no response after $timeout")
|
Timber.d("awaitAllRoomsAreLoaded: no response after $timeout")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -62,7 +62,7 @@ fun RoomListService.roomOrNull(roomId: String): RoomListItem? {
|
||||||
return try {
|
return try {
|
||||||
room(roomId)
|
room(roomId)
|
||||||
} catch (exception: RoomListException) {
|
} catch (exception: RoomListException) {
|
||||||
Timber.e(exception, "Failed finding room with id=$roomId")
|
Timber.d(exception, "Failed finding room with id=$roomId.")
|
||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -38,6 +38,7 @@ import io.element.android.libraries.matrix.test.room.FakeMatrixRoom
|
||||||
import io.element.android.libraries.matrix.test.room.FakeRoomSummaryDataSource
|
import io.element.android.libraries.matrix.test.room.FakeRoomSummaryDataSource
|
||||||
import io.element.android.libraries.matrix.test.sync.FakeSyncService
|
import io.element.android.libraries.matrix.test.sync.FakeSyncService
|
||||||
import io.element.android.libraries.matrix.test.verification.FakeSessionVerificationService
|
import io.element.android.libraries.matrix.test.verification.FakeSessionVerificationService
|
||||||
|
import io.element.android.tests.testutils.simulateLongTask
|
||||||
import kotlinx.coroutines.delay
|
import kotlinx.coroutines.delay
|
||||||
|
|
||||||
class FakeMatrixClient(
|
class FakeMatrixClient(
|
||||||
|
|
@ -72,11 +73,11 @@ class FakeMatrixClient(
|
||||||
return findDmResult
|
return findDmResult
|
||||||
}
|
}
|
||||||
|
|
||||||
override suspend fun ignoreUser(userId: UserId): Result<Unit> {
|
override suspend fun ignoreUser(userId: UserId): Result<Unit> = simulateLongTask {
|
||||||
return ignoreUserResult
|
return ignoreUserResult
|
||||||
}
|
}
|
||||||
|
|
||||||
override suspend fun unignoreUser(userId: UserId): Result<Unit> {
|
override suspend fun unignoreUser(userId: UserId): Result<Unit> = simulateLongTask {
|
||||||
return unignoreUserResult
|
return unignoreUserResult
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -239,7 +239,7 @@ class FakeMatrixRoom(
|
||||||
|
|
||||||
override suspend fun sendFile(file: File, fileInfo: FileInfo, progressCallback: ProgressCallback?): Result<Unit> = fakeSendMedia(progressCallback)
|
override suspend fun sendFile(file: File, fileInfo: FileInfo, progressCallback: ProgressCallback?): Result<Unit> = fakeSendMedia(progressCallback)
|
||||||
|
|
||||||
override suspend fun forwardEvent(eventId: EventId, rooms: List<RoomId>): Result<Unit> = simulateLongTask {
|
override suspend fun forwardEvent(eventId: EventId, roomIds: List<RoomId>): Result<Unit> = simulateLongTask {
|
||||||
forwardEventResult
|
forwardEventResult
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -19,10 +19,8 @@ package io.element.android.libraries.matrix.ui.di
|
||||||
import com.squareup.anvil.annotations.ContributesTo
|
import com.squareup.anvil.annotations.ContributesTo
|
||||||
import io.element.android.libraries.di.SessionScope
|
import io.element.android.libraries.di.SessionScope
|
||||||
import io.element.android.libraries.matrix.ui.media.LoggedInImageLoaderFactory
|
import io.element.android.libraries.matrix.ui.media.LoggedInImageLoaderFactory
|
||||||
import io.element.android.libraries.matrix.ui.media.NotLoggedInImageLoaderFactory
|
|
||||||
|
|
||||||
@ContributesTo(SessionScope::class)
|
@ContributesTo(SessionScope::class)
|
||||||
interface MatrixUIBindings {
|
interface MatrixUIBindings {
|
||||||
fun loggedInImageLoaderFactory(): LoggedInImageLoaderFactory
|
fun loggedInImageLoaderFactory(): LoggedInImageLoaderFactory
|
||||||
fun notLoggedInImageLoaderFactory(): NotLoggedInImageLoaderFactory
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -123,7 +123,7 @@ class NotificationFactory @Inject constructor(
|
||||||
val roomMeta = roomNotifications.filterIsInstance<RoomNotification.Message>().map { it.meta }
|
val roomMeta = roomNotifications.filterIsInstance<RoomNotification.Message>().map { it.meta }
|
||||||
val invitationMeta = invitationNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
val invitationMeta = invitationNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
||||||
val simpleMeta = simpleNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
val simpleMeta = simpleNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
||||||
val fallbackMeta = simpleNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
val fallbackMeta = fallbackNotifications.filterIsInstance<OneShotNotification.Append>().map { it.meta }
|
||||||
return when {
|
return when {
|
||||||
roomMeta.isEmpty() && invitationMeta.isEmpty() && simpleMeta.isEmpty() -> SummaryNotification.Removed
|
roomMeta.isEmpty() && invitationMeta.isEmpty() && simpleMeta.isEmpty() -> SummaryNotification.Removed
|
||||||
else -> SummaryNotification.Update(
|
else -> SummaryNotification.Update(
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,3 @@
|
||||||
|
version https://git-lfs.github.com/spec/v1
|
||||||
|
oid sha256:c7ca068387cff8faf728a989488e7c4b5b07983c4b24162ff82a14fd90b82d05
|
||||||
|
size 20609
|
||||||
|
|
@ -0,0 +1,3 @@
|
||||||
|
version https://git-lfs.github.com/spec/v1
|
||||||
|
oid sha256:e1599be0c5a37083c015378ee47a78a90dcf670f4df5d85dd25d39f4b2edbdf6
|
||||||
|
size 21147
|
||||||
Loading…
Add table
Add a link
Reference in a new issue