Move Json provider from Network module to AppModule to reuse it.

This commit is contained in:
Benoit Marty
2025-10-16 16:37:08 +02:00
parent 14c7a63f45
commit 276c707e42
10 changed files with 34 additions and 25 deletions

View File

@@ -35,6 +35,7 @@ import kotlinx.coroutines.CoroutineName
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.MainScope import kotlinx.coroutines.MainScope
import kotlinx.coroutines.plus import kotlinx.coroutines.plus
import kotlinx.serialization.json.Json
import java.io.File import java.io.File
@BindingContainer @BindingContainer
@@ -120,4 +121,10 @@ object AppModule {
fun providesEmojibaseProvider(@ApplicationContext context: Context): EmojibaseProvider { fun providesEmojibaseProvider(@ApplicationContext context: Context): EmojibaseProvider {
return DefaultEmojibaseProvider(context) return DefaultEmojibaseProvider(context)
} }
@Provides
@SingleIn(AppScope::class)
fun providesJson(): Json = Json {
ignoreUnknownKeys = true
}
} }

View File

@@ -64,6 +64,7 @@ class CallScreenPresenter(
private val appForegroundStateService: AppForegroundStateService, private val appForegroundStateService: AppForegroundStateService,
@AppCoroutineScope @AppCoroutineScope
private val appCoroutineScope: CoroutineScope, private val appCoroutineScope: CoroutineScope,
private val widgetMessageSerializer: WidgetMessageSerializer,
) : Presenter<CallScreenState> { ) : Presenter<CallScreenState> {
@AssistedFactory @AssistedFactory
interface Factory { interface Factory {
@@ -258,7 +259,7 @@ class CallScreenPresenter(
} }
private fun parseMessage(message: String): WidgetMessage? { private fun parseMessage(message: String): WidgetMessage? {
return WidgetMessageSerializer.deserialize(message).getOrNull() return widgetMessageSerializer.deserialize(message).getOrNull()
} }
private fun sendHangupMessage(widgetId: String, messageInterceptor: WidgetMessageInterceptor) { private fun sendHangupMessage(widgetId: String, messageInterceptor: WidgetMessageInterceptor) {
@@ -269,7 +270,7 @@ class CallScreenPresenter(
action = WidgetMessage.Action.HangUp, action = WidgetMessage.Action.HangUp,
data = null, data = null,
) )
messageInterceptor.sendMessage(WidgetMessageSerializer.serialize(message)) messageInterceptor.sendMessage(widgetMessageSerializer.serialize(message))
} }
private fun CoroutineScope.close(widgetDriver: MatrixWidgetDriver?, navigator: CallScreenNavigator) = launch(dispatchers.io) { private fun CoroutineScope.close(widgetDriver: MatrixWidgetDriver?, navigator: CallScreenNavigator) = launch(dispatchers.io) {

View File

@@ -7,18 +7,20 @@
package io.element.android.features.call.impl.utils package io.element.android.features.call.impl.utils
import dev.zacsweers.metro.Inject
import io.element.android.features.call.impl.data.WidgetMessage import io.element.android.features.call.impl.data.WidgetMessage
import io.element.android.libraries.core.extensions.runCatchingExceptions import io.element.android.libraries.core.extensions.runCatchingExceptions
import kotlinx.serialization.json.Json import kotlinx.serialization.json.Json
object WidgetMessageSerializer { @Inject
private val coder = Json { ignoreUnknownKeys = true } class WidgetMessageSerializer(
private val json: Json,
) {
fun deserialize(message: String): Result<WidgetMessage> { fun deserialize(message: String): Result<WidgetMessage> {
return runCatchingExceptions { coder.decodeFromString(WidgetMessage.serializer(), message) } return runCatchingExceptions { json.decodeFromString(WidgetMessage.serializer(), message) }
} }
fun serialize(message: WidgetMessage): String { fun serialize(message: WidgetMessage): String {
return coder.encodeToString(WidgetMessage.serializer(), message) return json.encodeToString(WidgetMessage.serializer(), message)
} }
} }

View File

@@ -16,6 +16,7 @@ import io.element.android.features.call.api.CallType
import io.element.android.features.call.impl.ui.CallScreenEvents import io.element.android.features.call.impl.ui.CallScreenEvents
import io.element.android.features.call.impl.ui.CallScreenNavigator import io.element.android.features.call.impl.ui.CallScreenNavigator
import io.element.android.features.call.impl.ui.CallScreenPresenter import io.element.android.features.call.impl.ui.CallScreenPresenter
import io.element.android.features.call.impl.utils.WidgetMessageSerializer
import io.element.android.features.call.utils.FakeActiveCallManager import io.element.android.features.call.utils.FakeActiveCallManager
import io.element.android.features.call.utils.FakeCallWidgetProvider import io.element.android.features.call.utils.FakeCallWidgetProvider
import io.element.android.features.call.utils.FakeWidgetMessageInterceptor import io.element.android.features.call.utils.FakeWidgetMessageInterceptor
@@ -46,11 +47,13 @@ import kotlinx.coroutines.test.UnconfinedTestDispatcher
import kotlinx.coroutines.test.advanceTimeBy import kotlinx.coroutines.test.advanceTimeBy
import kotlinx.coroutines.test.runCurrent import kotlinx.coroutines.test.runCurrent
import kotlinx.coroutines.test.runTest import kotlinx.coroutines.test.runTest
import kotlinx.serialization.json.Json
import org.junit.Rule import org.junit.Rule
import org.junit.Test import org.junit.Test
import kotlin.time.Duration.Companion.seconds import kotlin.time.Duration.Companion.seconds
@OptIn(ExperimentalCoroutinesApi::class) class CallScreenPresenterTest { @OptIn(ExperimentalCoroutinesApi::class)
class CallScreenPresenterTest {
@get:Rule @get:Rule
val warmUpRule = WarmUpRule() val warmUpRule = WarmUpRule()
@@ -409,6 +412,7 @@ import kotlin.time.Duration.Companion.seconds
languageTagProvider = FakeLanguageTagProvider("en-US"), languageTagProvider = FakeLanguageTagProvider("en-US"),
appForegroundStateService = appForegroundStateService, appForegroundStateService = appForegroundStateService,
appCoroutineScope = backgroundScope, appCoroutineScope = backgroundScope,
widgetMessageSerializer = WidgetMessageSerializer(Json { ignoreUnknownKeys = true }),
) )
} }
} }

View File

@@ -26,10 +26,10 @@ interface MessageParser {
@Inject @Inject
class DefaultMessageParser( class DefaultMessageParser(
private val accountProviderDataSource: AccountProviderDataSource, private val accountProviderDataSource: AccountProviderDataSource,
private val json: Json,
) : MessageParser { ) : MessageParser {
override fun parse(message: String): ExternalSession { override fun parse(message: String): ExternalSession {
val parser = Json { ignoreUnknownKeys = true } val response = json.decodeFromString(MobileRegistrationResponse.serializer(), message)
val response = parser.decodeFromString(MobileRegistrationResponse.serializer(), message)
val userId = response.userId ?: error("No user ID in response") val userId = response.userId ?: error("No user ID in response")
val homeServer = response.homeServer ?: accountProviderDataSource.flow.value.url val homeServer = response.homeServer ?: accountProviderDataSource.flow.value.url
val accessToken = response.accessToken ?: error("No access token in response") val accessToken = response.accessToken ?: error("No access token in response")

View File

@@ -13,6 +13,7 @@ import io.element.android.features.enterprise.test.FakeEnterpriseService
import io.element.android.features.login.impl.accountprovider.AccountProviderDataSource import io.element.android.features.login.impl.accountprovider.AccountProviderDataSource
import io.element.android.libraries.matrix.api.auth.external.ExternalSession import io.element.android.libraries.matrix.api.auth.external.ExternalSession
import kotlinx.serialization.SerializationException import kotlinx.serialization.SerializationException
import kotlinx.serialization.json.Json
import org.junit.Assert.assertThrows import org.junit.Assert.assertThrows
import org.junit.Test import org.junit.Test
@@ -68,7 +69,8 @@ class DefaultMessageParserTest {
private fun createDefaultMessageParser(): DefaultMessageParser { private fun createDefaultMessageParser(): DefaultMessageParser {
return DefaultMessageParser( return DefaultMessageParser(
AccountProviderDataSource(FakeEnterpriseService()) accountProviderDataSource = AccountProviderDataSource(FakeEnterpriseService()),
json = Json { ignoreUnknownKeys = true },
) )
} }
} }

View File

@@ -15,7 +15,6 @@ import dev.zacsweers.metro.SingleIn
import io.element.android.libraries.core.meta.BuildMeta import io.element.android.libraries.core.meta.BuildMeta
import io.element.android.libraries.network.interceptors.FormattedJsonHttpLogger import io.element.android.libraries.network.interceptors.FormattedJsonHttpLogger
import io.element.android.libraries.network.interceptors.UserAgentInterceptor import io.element.android.libraries.network.interceptors.UserAgentInterceptor
import kotlinx.serialization.json.Json
import okhttp3.OkHttpClient import okhttp3.OkHttpClient
import okhttp3.logging.HttpLoggingInterceptor import okhttp3.logging.HttpLoggingInterceptor
import java.util.concurrent.TimeUnit import java.util.concurrent.TimeUnit
@@ -35,12 +34,6 @@ object NetworkModule {
addInterceptor(userAgentInterceptor) addInterceptor(userAgentInterceptor)
if (buildMeta.isDebuggable) addInterceptor(providesHttpLoggingInterceptor()) if (buildMeta.isDebuggable) addInterceptor(providesHttpLoggingInterceptor())
}.build() }.build()
@Provides
@SingleIn(AppScope::class)
fun providesJson(): Json = Json {
ignoreUnknownKeys = true
}
} }
private fun providesHttpLoggingInterceptor(): HttpLoggingInterceptor { private fun providesHttpLoggingInterceptor(): HttpLoggingInterceptor {

View File

@@ -13,9 +13,9 @@ import io.element.android.libraries.pushproviders.api.PushData
import kotlinx.serialization.json.Json import kotlinx.serialization.json.Json
@Inject @Inject
class UnifiedPushParser { class UnifiedPushParser(
private val json by lazy { Json { ignoreUnknownKeys = true } } private val json: Json,
) {
fun parse(message: ByteArray, clientSecret: String): PushData? { fun parse(message: ByteArray, clientSecret: String): PushData? {
return tryOrNull { json.decodeFromString<PushDataUnifiedPush>(String(message)) }?.toPushData(clientSecret) return tryOrNull { json.decodeFromString<PushDataUnifiedPush>(String(message)) }?.toPushData(clientSecret)
} }

View File

@@ -22,7 +22,7 @@ import timber.log.Timber
@Inject @Inject
class DefaultSessionWellknownRetriever( class DefaultSessionWellknownRetriever(
private val matrixClient: MatrixClient, private val matrixClient: MatrixClient,
private val parser: Json, private val json: Json,
) : SessionWellknownRetriever { ) : SessionWellknownRetriever {
private val domain by lazy { matrixClient.userIdServerName() } private val domain by lazy { matrixClient.userIdServerName() }
@@ -32,7 +32,7 @@ class DefaultSessionWellknownRetriever(
.getUrl(url) .getUrl(url)
.mapCatchingExceptions { .mapCatchingExceptions {
val data = String(it) val data = String(it)
parser.decodeFromString(InternalWellKnown.serializer(), data) json.decodeFromString(InternalWellKnown.serializer(), data)
} }
.onFailure { Timber.e(it, "Failed to retrieve .well-known from $domain") } .onFailure { Timber.e(it, "Failed to retrieve .well-known from $domain") }
.map { it.map() } .map { it.map() }
@@ -45,7 +45,7 @@ class DefaultSessionWellknownRetriever(
.getUrl(url) .getUrl(url)
.mapCatchingExceptions { .mapCatchingExceptions {
val data = String(it) val data = String(it)
parser.decodeFromString(InternalElementWellKnown.serializer(), data) json.decodeFromString(InternalElementWellKnown.serializer(), data)
} }
.onFailure { Timber.e(it, "Failed to retrieve Element .well-known from $domain") } .onFailure { Timber.e(it, "Failed to retrieve Element .well-known from $domain") }
.map { it.map() } .map { it.map() }

View File

@@ -244,6 +244,6 @@ class DefaultSessionWellknownRetrieverTest {
userIdServerNameLambda = { "user.domain.org" }, userIdServerNameLambda = { "user.domain.org" },
getUrlLambda = getUrlLambda, getUrlLambda = getUrlLambda,
), ),
parser = Json { ignoreUnknownKeys = true } json = Json { ignoreUnknownKeys = true },
) )
} }