From c707bef9a3a7c8af8622c93acc7ff9ffe8909734 Mon Sep 17 00:00:00 2001
From: Tangem <git@tangem.com>
Date: Mon, 22 Dec 2025 09:41:07 +0200
Subject: [PATCH] Updated on 2026-08-14

---
 .../data/staking/DefaultP2PEthPoolRepository.kt       | 11 +++++++++--
 .../com/tangem/data/staking/di/StakingDataModule.kt   |  2 ++
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/data/staking/src/main/java/com/tangem/data/staking/DefaultP2PEthPoolRepository.kt b/data/staking/src/main/java/com/tangem/data/staking/DefaultP2PEthPoolRepository.kt
index 85f3038652..1f2f75086b 100644
--- a/data/staking/src/main/java/com/tangem/data/staking/DefaultP2PEthPoolRepository.kt
+++ b/data/staking/src/main/java/com/tangem/data/staking/DefaultP2PEthPoolRepository.kt
@@ -17,6 +17,7 @@ import com.tangem.domain.staking.model.StakingOption
 import com.tangem.domain.staking.model.ethpool.*
 import com.tangem.domain.staking.repositories.P2PEthPoolRepository
 import com.tangem.domain.staking.model.stakekit.StakingError
+import com.tangem.domain.staking.toggles.StakingFeatureToggles
 import com.tangem.utils.coroutines.CoroutineDispatcherProvider
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.distinctUntilChanged
@@ -31,6 +32,7 @@ internal class DefaultP2PEthPoolRepository(
     private val p2pApi: P2PEthPoolApi,
     private val p2pEthPoolVaultsStore: P2PEthPoolVaultsStore,
     private val dispatchers: CoroutineDispatcherProvider,
+    private val stakingFeatureToggles: StakingFeatureToggles,
 ) : P2PEthPoolRepository {
 
     private val vaultConverter = P2PEthPoolVaultConverter
@@ -40,10 +42,15 @@ internal class DefaultP2PEthPoolRepository(
     private val errorConverter = P2PEthPoolErrorConverter
 
     override suspend fun fetchVaults(network: P2PEthPoolNetwork) {
-        val vaults = getVaults(network).getOrElse { error ->
-            Timber.e("Error fetching P2P vaults: $error")
+        val vaults = if (stakingFeatureToggles.isEthStakingEnabled) {
+            getVaults(network).getOrElse { error ->
+                Timber.e("Error fetching P2P vaults: $error")
+                emptyList()
+            }
+        } else {
             emptyList()
         }
+
         p2pEthPoolVaultsStore.store(vaults)
     }
 
diff --git a/data/staking/src/main/java/com/tangem/data/staking/di/StakingDataModule.kt b/data/staking/src/main/java/com/tangem/data/staking/di/StakingDataModule.kt
index 22164269fd..95f7430209 100644
--- a/data/staking/src/main/java/com/tangem/data/staking/di/StakingDataModule.kt
+++ b/data/staking/src/main/java/com/tangem/data/staking/di/StakingDataModule.kt
@@ -78,11 +78,13 @@ internal object StakingDataModule {
         p2pApi: P2PEthPoolApi,
         p2pEthPoolVaultsStore: P2PEthPoolVaultsStore,
         dispatchers: CoroutineDispatcherProvider,
+        stakingFeatureToggles: StakingFeatureToggles,
     ): P2PEthPoolRepository {
         return DefaultP2PEthPoolRepository(
             p2pApi = p2pApi,
             p2pEthPoolVaultsStore = p2pEthPoolVaultsStore,
             dispatchers = dispatchers,
+            stakingFeatureToggles = stakingFeatureToggles,
         )
     }