Map the new fields of SessionData.
This commit is contained in:
parent
87fa394b93
commit
fea1fe0f3c
7 changed files with 83 additions and 5 deletions
|
|
@ -136,7 +136,12 @@ class RustMatrixClient constructor(
|
||||||
override fun didRefreshTokens() {
|
override fun didRefreshTokens() {
|
||||||
Timber.w("didRefreshTokens()")
|
Timber.w("didRefreshTokens()")
|
||||||
appCoroutineScope.launch {
|
appCoroutineScope.launch {
|
||||||
sessionStore.updateData(client.session().toSessionData())
|
val existingData = sessionStore.getSession(client.userId()) ?: return@launch
|
||||||
|
val newData = client.session().toSessionData(
|
||||||
|
isTokenValid = existingData.isTokenValid,
|
||||||
|
loginType = existingData.loginType,
|
||||||
|
)
|
||||||
|
sessionStore.updateData(newData)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -30,6 +30,7 @@ import io.element.android.libraries.matrix.impl.RustMatrixClientFactory
|
||||||
import io.element.android.libraries.matrix.impl.exception.mapClientException
|
import io.element.android.libraries.matrix.impl.exception.mapClientException
|
||||||
import io.element.android.libraries.matrix.impl.mapper.toSessionData
|
import io.element.android.libraries.matrix.impl.mapper.toSessionData
|
||||||
import io.element.android.libraries.network.useragent.UserAgentProvider
|
import io.element.android.libraries.network.useragent.UserAgentProvider
|
||||||
|
import io.element.android.libraries.sessionstorage.api.LoginType
|
||||||
import io.element.android.libraries.sessionstorage.api.SessionStore
|
import io.element.android.libraries.sessionstorage.api.SessionStore
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
import kotlinx.coroutines.flow.MutableStateFlow
|
import kotlinx.coroutines.flow.MutableStateFlow
|
||||||
|
|
@ -102,7 +103,12 @@ class RustMatrixAuthenticationService @Inject constructor(
|
||||||
withContext(coroutineDispatchers.io) {
|
withContext(coroutineDispatchers.io) {
|
||||||
runCatching {
|
runCatching {
|
||||||
val client = authService.login(username, password, "Element X Android", null)
|
val client = authService.login(username, password, "Element X Android", null)
|
||||||
val sessionData = client.use { it.session().toSessionData() }
|
val sessionData = client.use {
|
||||||
|
it.session().toSessionData(
|
||||||
|
isTokenValid = true,
|
||||||
|
loginType = LoginType.PASSWORD,
|
||||||
|
)
|
||||||
|
}
|
||||||
sessionStore.storeData(sessionData)
|
sessionStore.storeData(sessionData)
|
||||||
SessionId(sessionData.userId)
|
SessionId(sessionData.userId)
|
||||||
}.mapFailure { failure ->
|
}.mapFailure { failure ->
|
||||||
|
|
@ -144,7 +150,12 @@ class RustMatrixAuthenticationService @Inject constructor(
|
||||||
runCatching {
|
runCatching {
|
||||||
val urlForOidcLogin = pendingOidcAuthenticationData ?: error("You need to call `getOidcUrl()` first")
|
val urlForOidcLogin = pendingOidcAuthenticationData ?: error("You need to call `getOidcUrl()` first")
|
||||||
val client = authService.loginWithOidcCallback(urlForOidcLogin, callbackUrl)
|
val client = authService.loginWithOidcCallback(urlForOidcLogin, callbackUrl)
|
||||||
val sessionData = client.use { it.session().toSessionData() }
|
val sessionData = client.use {
|
||||||
|
it.session().toSessionData(
|
||||||
|
isTokenValid = true,
|
||||||
|
loginType = LoginType.OIDC,
|
||||||
|
)
|
||||||
|
}
|
||||||
pendingOidcAuthenticationData?.close()
|
pendingOidcAuthenticationData?.close()
|
||||||
pendingOidcAuthenticationData = null
|
pendingOidcAuthenticationData = null
|
||||||
sessionStore.storeData(sessionData)
|
sessionStore.storeData(sessionData)
|
||||||
|
|
|
||||||
|
|
@ -16,11 +16,15 @@
|
||||||
|
|
||||||
package io.element.android.libraries.matrix.impl.mapper
|
package io.element.android.libraries.matrix.impl.mapper
|
||||||
|
|
||||||
|
import io.element.android.libraries.sessionstorage.api.LoginType
|
||||||
import io.element.android.libraries.sessionstorage.api.SessionData
|
import io.element.android.libraries.sessionstorage.api.SessionData
|
||||||
import org.matrix.rustcomponents.sdk.Session
|
import org.matrix.rustcomponents.sdk.Session
|
||||||
import java.util.Date
|
import java.util.Date
|
||||||
|
|
||||||
internal fun Session.toSessionData() = SessionData(
|
internal fun Session.toSessionData(
|
||||||
|
isTokenValid: Boolean,
|
||||||
|
loginType: LoginType,
|
||||||
|
) = SessionData(
|
||||||
userId = userId,
|
userId = userId,
|
||||||
deviceId = deviceId,
|
deviceId = deviceId,
|
||||||
accessToken = accessToken,
|
accessToken = accessToken,
|
||||||
|
|
@ -29,4 +33,6 @@ internal fun Session.toSessionData() = SessionData(
|
||||||
oidcData = oidcData,
|
oidcData = oidcData,
|
||||||
slidingSyncProxy = slidingSyncProxy,
|
slidingSyncProxy = slidingSyncProxy,
|
||||||
loginTimestamp = Date(),
|
loginTimestamp = Date(),
|
||||||
|
isTokenValid = isTokenValid,
|
||||||
|
loginType = loginType,
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,43 @@
|
||||||
|
/*
|
||||||
|
* Copyright (c) 2022 The Matrix.org Foundation C.I.C.
|
||||||
|
*
|
||||||
|
* 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.sessionstorage.api
|
||||||
|
|
||||||
|
// Imported from Element Android, to be able to migrate from EA to EXA.
|
||||||
|
enum class LoginType {
|
||||||
|
PASSWORD,
|
||||||
|
OIDC,
|
||||||
|
SSO,
|
||||||
|
UNSUPPORTED,
|
||||||
|
CUSTOM,
|
||||||
|
DIRECT,
|
||||||
|
UNKNOWN,
|
||||||
|
QR;
|
||||||
|
|
||||||
|
companion object {
|
||||||
|
|
||||||
|
fun fromName(name: String) = when (name) {
|
||||||
|
PASSWORD.name -> PASSWORD
|
||||||
|
OIDC.name -> OIDC
|
||||||
|
SSO.name -> SSO
|
||||||
|
UNSUPPORTED.name -> UNSUPPORTED
|
||||||
|
CUSTOM.name -> CUSTOM
|
||||||
|
DIRECT.name -> DIRECT
|
||||||
|
QR.name -> QR
|
||||||
|
else -> UNKNOWN
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -27,4 +27,6 @@ data class SessionData(
|
||||||
val oidcData: String?,
|
val oidcData: String?,
|
||||||
val slidingSyncProxy: String?,
|
val slidingSyncProxy: String?,
|
||||||
val loginTimestamp: Date?,
|
val loginTimestamp: Date?,
|
||||||
|
val isTokenValid: Boolean,
|
||||||
|
val loginType: LoginType,
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -16,6 +16,7 @@
|
||||||
|
|
||||||
package io.element.android.libraries.sessionstorage.impl
|
package io.element.android.libraries.sessionstorage.impl
|
||||||
|
|
||||||
|
import io.element.android.libraries.sessionstorage.api.LoginType
|
||||||
import io.element.android.libraries.sessionstorage.api.SessionData
|
import io.element.android.libraries.sessionstorage.api.SessionData
|
||||||
import java.util.Date
|
import java.util.Date
|
||||||
import io.element.android.libraries.matrix.session.SessionData as DbSessionData
|
import io.element.android.libraries.matrix.session.SessionData as DbSessionData
|
||||||
|
|
@ -30,6 +31,8 @@ internal fun SessionData.toDbModel(): DbSessionData {
|
||||||
oidcData = oidcData,
|
oidcData = oidcData,
|
||||||
slidingSyncProxy = slidingSyncProxy,
|
slidingSyncProxy = slidingSyncProxy,
|
||||||
loginTimestamp = loginTimestamp?.time,
|
loginTimestamp = loginTimestamp?.time,
|
||||||
|
isTokenValid = if (isTokenValid) 1L else 0L,
|
||||||
|
loginType = loginType.name,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -42,6 +45,8 @@ internal fun DbSessionData.toApiModel(): SessionData {
|
||||||
homeserverUrl = homeserverUrl,
|
homeserverUrl = homeserverUrl,
|
||||||
oidcData = oidcData,
|
oidcData = oidcData,
|
||||||
slidingSyncProxy = slidingSyncProxy,
|
slidingSyncProxy = slidingSyncProxy,
|
||||||
loginTimestamp = loginTimestamp?.let { Date(it) }
|
loginTimestamp = loginTimestamp?.let { Date(it) },
|
||||||
|
isTokenValid = (isTokenValid ?: 1) == 1L,
|
||||||
|
loginType = LoginType.fromName(loginType ?: LoginType.UNKNOWN.name),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -38,6 +38,8 @@ class DatabaseSessionStoreTests {
|
||||||
slidingSyncProxy = null,
|
slidingSyncProxy = null,
|
||||||
loginTimestamp = null,
|
loginTimestamp = null,
|
||||||
oidcData = "aOidcData",
|
oidcData = "aOidcData",
|
||||||
|
isTokenValid = null,
|
||||||
|
loginType = null,
|
||||||
)
|
)
|
||||||
|
|
||||||
@Before
|
@Before
|
||||||
|
|
@ -121,6 +123,8 @@ class DatabaseSessionStoreTests {
|
||||||
slidingSyncProxy = "slidingSyncProxy",
|
slidingSyncProxy = "slidingSyncProxy",
|
||||||
loginTimestamp = 1,
|
loginTimestamp = 1,
|
||||||
oidcData = "aOidcData",
|
oidcData = "aOidcData",
|
||||||
|
isTokenValid = null,
|
||||||
|
loginType = null,
|
||||||
)
|
)
|
||||||
val secondSessionData = SessionData(
|
val secondSessionData = SessionData(
|
||||||
userId = "userId",
|
userId = "userId",
|
||||||
|
|
@ -131,6 +135,8 @@ class DatabaseSessionStoreTests {
|
||||||
slidingSyncProxy = "slidingSyncProxyAltered",
|
slidingSyncProxy = "slidingSyncProxyAltered",
|
||||||
loginTimestamp = 2,
|
loginTimestamp = 2,
|
||||||
oidcData = "aOidcDataAltered",
|
oidcData = "aOidcDataAltered",
|
||||||
|
isTokenValid = null,
|
||||||
|
loginType = null,
|
||||||
)
|
)
|
||||||
assertThat(firstSessionData.userId).isEqualTo(secondSessionData.userId)
|
assertThat(firstSessionData.userId).isEqualTo(secondSessionData.userId)
|
||||||
assertThat(firstSessionData.loginTimestamp).isNotEqualTo(secondSessionData.loginTimestamp)
|
assertThat(firstSessionData.loginTimestamp).isNotEqualTo(secondSessionData.loginTimestamp)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue