Updated on 2026-08-14

data/push-notification-preferences/src/main/kotlin/com/tangem/data/pushnotificationpreferences/DefaultWalletPushNotificationPreferencesRepository.kt

@@ -14,6 +14,8 @@ import com.tangem.domain.pushnotificationpreferences.models.PushNotificationCate
 import com.tangem.domain.pushnotificationpreferences.models.WalletPushNotificationPreferences
 import com.tangem.domain.pushnotificationpreferences.repository.WalletPushNotificationPreferencesRepository
 import com.tangem.utils.coroutines.CoroutineDispatcherProvider
+import com.tangem.utils.coroutines.runSuspendCatching
+import com.tangem.utils.logging.TangemLogger
 import java.util.concurrent.ConcurrentHashMap
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.distinctUntilChanged
@@ -49,6 +51,16 @@ internal class DefaultWalletPushNotificationPreferencesRepository(
     }
 
     override suspend fun preload(userWalletId: UserWalletId) {
+        runSuspendCatching { preloadOrThrow(userWalletId) }
+            .onFailure { error ->
+                TangemLogger.e(
+                    "Failed to preload push notification preferences for wallet ${userWalletId.stringValue}",
+                    error,
+                )
+            }
+    }
+
+    private suspend fun preloadOrThrow(userWalletId: UserWalletId) {
         if (isCached(userWalletId)) return
         mutexFor(userWalletId).withLock {
             if (isCached(userWalletId)) return
@@ -64,7 +76,7 @@ internal class DefaultWalletPushNotificationPreferencesRepository(
     }
 
     override fun observePreferences(userWalletId: UserWalletId): Flow<WalletPushNotificationPreferences> = cache.get()
-        .onStart { preload(userWalletId) }
+        .onStart { preloadOrThrow(userWalletId) }
         .map { it[userWalletId.stringValue] }
         .filterNotNull()
         .distinctUntilChanged()

data/push-notification-preferences/src/test/kotlin/com/tangem/data/pushnotificationpreferences/DefaultWalletPushNotificationPreferencesRepositoryTest.kt

@@ -76,6 +76,34 @@ class DefaultWalletPushNotificationPreferencesRepositoryTest {
         coVerify(exactly = 1) { tangemTechApi.getPushNotificationPreferences(userWalletId.stringValue) }
     }
 
+    @Test
+    fun `GIVEN server fails WHEN preload THEN does not throw AND does not cache`() = runTest {
+        // Arrange
+        coEvery { tangemTechApi.getPushNotificationPreferences(userWalletId.stringValue) } throws
+            IllegalStateException("boom")
+
+        // Act
+        val thrown = runCatching { repository.preload(userWalletId) }.exceptionOrNull()
+
+        // Assert
+        assertThat(thrown).isNull()
+        stubGet(userWalletId, transaction = true, offers = true, price = false)
+        repository.preload(userWalletId)
+        coVerify(exactly = 2) { tangemTechApi.getPushNotificationPreferences(userWalletId.stringValue) }
+    }
+
+    @Test
+    fun `GIVEN server fails WHEN observePreferences THEN flow errors for collectors`() = runTest {
+        // Arrange
+        coEvery { tangemTechApi.getPushNotificationPreferences(userWalletId.stringValue) } throws
+            IllegalStateException("boom")
+
+        // Act & Assert
+        repository.observePreferences(userWalletId).test {
+            assertThat(awaitError()).isInstanceOf(IllegalStateException::class.java)
+        }
+    }
+
     @Test
     fun `GIVEN cache miss WHEN updatePreference THEN fetches baseline AND sends full-replace PUT AND caches echo`() =
         runTest {