Let RootFlowNode manage MatrixClientsHolder save and restoration.

This commit is contained in:
Benoit Marty 2023-07-12 12:23:46 +02:00
parent 93c918ea2a
commit a9720e36c1
4 changed files with 23 additions and 25 deletions

View file

@ -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)
}
} }

View file

@ -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
} }

View file

@ -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(),

View file

@ -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,18 @@ 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 if (state == null || sessionIdsToMatrixClient.isNotEmpty()) return Unit.also {
val userIds = savedInstanceState.getSerializable(SAVE_INSTANCE_KEY) as? Array<UserId> Timber.w("Restore with non-empty map")
if (userIds.isNullOrEmpty()) return }
val sessionIds = state[SAVE_INSTANCE_KEY] as? Array<SessionId>
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 +74,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")
outState.putSerializable(SAVE_INSTANCE_KEY, sessionKeys) state[SAVE_INSTANCE_KEY] = sessionKeys
} }
} }