GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2025-09-08 18:35:03 +07:00
parent 458fc16dcb
commit f57cc0f796
1 changed files with 30 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

32
data/wallet-connect/src/main/kotlin/com/tangem/data/walletconnect/request/DefaultWcRequestService.kt
View file

@ -1,6 +1,8 @@
package com.tangem.data.walletconnect.request
import com.reown.walletkit.client.Wallet
import com.tangem.common.extensions.calculateSha256
import com.tangem.common.extensions.toHexString
import com.tangem.data.walletconnect.respond.WcRespondService
import com.tangem.data.walletconnect.utils.WC_TAG
import com.tangem.data.walletconnect.utils.WcSdkObserver
@ -9,8 +11,9 @@ import com.tangem.domain.walletconnect.WcRequestService
import com.tangem.domain.walletconnect.model.WcMethodName
import com.tangem.domain.walletconnect.model.sdkcopy.WcSdkSessionRequest
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.receiveAsFlow
import kotlinx.coroutines.flow.*
import org.joda.time.DateTime
import org.joda.time.Duration
import timber.log.Timber
internal class DefaultWcRequestService(
@ -18,8 +21,12 @@ internal class DefaultWcRequestService(
private val respondService: WcRespondService,
) : WcSdkObserver, WcRequestService {
private val expireDuration = Duration.standardSeconds(120)
private val cachedRequest = MutableStateFlow<Set<Pair<Long, String>>>(setOf())
private val _wcRequest: Channel<Pair<WcMethodName, WcSdkSessionRequest>> = Channel(Channel.BUFFERED)
override val wcRequest: Flow<Pair<WcMethodName, WcSdkSessionRequest>> = _wcRequest.receiveAsFlow()
.filter { filterDuplicateRequest(request = it.second) }
.onEach { saveRequest(request = it.second) }
override fun onSessionRequest(
sessionRequest: Wallet.Model.SessionRequest,
@ -42,4 +49,25 @@ internal class DefaultWcRequestService(
}
_wcRequest.trySend(name to sr)
}
private fun filterDuplicateRequest(request: WcSdkSessionRequest): Boolean {
val hash = request.request.params.calculateSha256().toHexString()
val now = DateTime.now().millis
val expiredMillis = now - expireDuration.millis
val cachedRequest = cachedRequest.updateAndGet {
it.filterTo(mutableSetOf()) { (millis, _) -> millis > expiredMillis }
}
val noHaveCached = cachedRequest.none { (_, hashParams) -> hash == hashParams }
if (!noHaveCached) {
Timber.tag(WC_TAG).i("filter request $request")
}
return noHaveCached
}
private fun saveRequest(request: WcSdkSessionRequest) {
val hash = request.request.params.calculateSha256().toHexString()
val now = DateTime.now().millis
cachedRequest.update { it + (now to hash) }
}
}