From f57cc0f7965fee1edd28b9ffb060a069944fdaa5 Mon Sep 17 00:00:00 2001
From: Tangem <git@tangem.com>
Date: Mon, 8 Sep 2025 18:35:03 +0700
Subject: [PATCH] Updated on 2026-08-14

---
 .../request/DefaultWcRequestService.kt        | 32 +++++++++++++++++--
 1 file changed, 30 insertions(+), 2 deletions(-)

diff --git a/data/wallet-connect/src/main/kotlin/com/tangem/data/walletconnect/request/DefaultWcRequestService.kt b/data/wallet-connect/src/main/kotlin/com/tangem/data/walletconnect/request/DefaultWcRequestService.kt
index 92e8b87959..c04fa9a1c7 100644
--- a/data/wallet-connect/src/main/kotlin/com/tangem/data/walletconnect/request/DefaultWcRequestService.kt
+++ b/data/wallet-connect/src/main/kotlin/com/tangem/data/walletconnect/request/DefaultWcRequestService.kt
@@ -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) }
+    }
 }
\ No newline at end of file