Updated on 2026-08-14

domain/yield-supply/src/main/java/com/tangem/domain/yield/supply/usecase/YieldSupplyApyFlowUseCase.kt

@@ -0,0 +1,26 @@
+package com.tangem.domain.yield.supply.usecase
+
+import com.tangem.domain.yield.supply.YieldSupplyMarketRepository
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
+
+/**
+ * Emits a map of APY values per token.
+ *
+ * Return map:
+ * - key: token contract address
+ * - value: APY as string
+ */
+class YieldSupplyApyFlowUseCase(
+    private val yieldSupplyMarketRepository: YieldSupplyMarketRepository,
+) {
+
+    operator fun invoke(): Flow<Map<String, String>> {
+        return yieldSupplyMarketRepository.getMarketsFlow()
+            .map { yieldMarketTokenList ->
+                yieldMarketTokenList.filter { it.isActive }.associate {
+                    it.tokenAddress to it.apy.toString()
+                }
+            }
+    }
+}

domain/yield-supply/src/main/java/com/tangem/domain/yield/supply/usecase/YieldSupplyApyUpdateUseCase.kt

@@ -0,0 +1,25 @@
+package com.tangem.domain.yield.supply.usecase
+
+import arrow.core.Either
+import com.tangem.domain.yield.supply.YieldSupplyMarketRepository
+import kotlin.collections.filter
+
+/**
+ * Updates and returns a map of APY values per token.
+ *
+ * Return map:
+ * - key: token contract address
+ * - value: APY as string
+ */
+class YieldSupplyApyUpdateUseCase(
+    private val yieldSupplyMarketRepository: YieldSupplyMarketRepository,
+) {
+
+    suspend operator fun invoke(): Either<Throwable, Map<String, String>> = Either.catch {
+        yieldSupplyMarketRepository.updateMarkets()
+            .filter { it.isActive }
+            .associate {
+                it.tokenAddress to it.apy.toString()
+            }
+    }
+}