Sulkta-OSS/element-x-ada
3
0
Fork 0
Code Issues 1 Pull requests 10 Projects Releases Packages Wiki Activity Actions

Remove session preferences on logout

Browse source 
Observe the sessions in `DefaultSessionPreferencesFactory` and remove the session preferences from both the cache and disk when a session is finished.
This commit is contained in:
Jorge Martín 2024-01-31 10:35:09 +01:00
parent 3e9f8bd024
commit a497227396
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
libraries/preferences/impl/src/main/kotlin/io/element/android/libraries/preferences/impl/store/DefaultSessionPreferencesStoreFactory.kt
View file

@ -21,6 +21,8 @@ import io.element.android.libraries.di.AppScope
import io.element.android.libraries.di.ApplicationContext import io.element.android.libraries.di.ApplicationContext
import io.element.android.libraries.di.SingleIn import io.element.android.libraries.di.SingleIn
import io.element.android.libraries.matrix.api.core.SessionId import io.element.android.libraries.matrix.api.core.SessionId
import io.element.android.libraries.sessionstorage.api.observer.SessionListener
import io.element.android.libraries.sessionstorage.api.observer.SessionObserver
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import java.util.concurrent.ConcurrentHashMap import java.util.concurrent.ConcurrentHashMap
import javax.inject.Inject import javax.inject.Inject
@ -28,9 +30,20 @@ import javax.inject.Inject
@SingleIn(AppScope::class) @SingleIn(AppScope::class)
class DefaultSessionPreferencesStoreFactory @Inject constructor( class DefaultSessionPreferencesStoreFactory @Inject constructor(
@ApplicationContext private val context: Context, @ApplicationContext private val context: Context,
sessionObserver: SessionObserver,
) { ) {
private val cache = ConcurrentHashMap<SessionId, DefaultSessionPreferencesStore>() private val cache = ConcurrentHashMap<SessionId, DefaultSessionPreferencesStore>()
init {
sessionObserver.addListener(object : SessionListener {
override suspend fun onSessionCreated(userId: String) = Unit
override suspend fun onSessionDeleted(userId: String) {
val sessionPreferences = cache.remove(SessionId(userId))
sessionPreferences?.clear()
}
})
}
fun get(sessionId: SessionId, sessionCoroutineScope: CoroutineScope): DefaultSessionPreferencesStore = cache.getOrPut(sessionId) { fun get(sessionId: SessionId, sessionCoroutineScope: CoroutineScope): DefaultSessionPreferencesStore = cache.getOrPut(sessionId) {
DefaultSessionPreferencesStore(context, sessionId, sessionCoroutineScope) DefaultSessionPreferencesStore(context, sessionId, sessionCoroutineScope)
} }