Updated on 2026-08-14

data/tokensync/src/main/java/com/tangem/data/tokensync/store/DefaultTokenSyncStore.kt

@@ -0,0 +1,24 @@
+package com.tangem.data.tokensync.store
+
+import androidx.datastore.core.DataStore
+import com.tangem.datasource.api.tangemTech.models.UserTokensResponse
+import kotlinx.coroutines.flow.firstOrNull
+
+internal class DefaultTokenSyncStore(
+    private val persistenceStore: DataStore<List<UserTokensResponse.Token>>,
+) : TokenSyncStore {
+
+    override suspend fun get(): List<UserTokensResponse.Token> {
+        return persistenceStore.data.firstOrNull().orEmpty()
+    }
+
+    override suspend fun append(tokens: List<UserTokensResponse.Token>) {
+        persistenceStore.updateData { existing ->
+            (existing + tokens).distinct()
+        }
+    }
+
+    override suspend fun clear() {
+        persistenceStore.updateData { emptyList() }
+    }
+}

data/tokensync/src/main/java/com/tangem/data/tokensync/store/TokenSyncStore.kt

@@ -0,0 +1,12 @@
+package com.tangem.data.tokensync.store
+
+import com.tangem.datasource.api.tangemTech.models.UserTokensResponse
+
+interface TokenSyncStore {
+
+    suspend fun get(): List<UserTokensResponse.Token>
+
+    suspend fun append(tokens: List<UserTokensResponse.Token>)
+
+    suspend fun clear()
+}

data/tokensync/src/main/java/com/tangem/data/tokensync/store/TokenSyncStoreFactory.kt

@@ -0,0 +1,56 @@
+package com.tangem.data.tokensync.store
+
+import android.content.Context
+import androidx.datastore.core.DataStore
+import androidx.datastore.core.DataStoreFactory
+import androidx.datastore.dataStoreFile
+import com.squareup.moshi.Moshi
+import com.tangem.datasource.api.tangemTech.models.UserTokensResponse
+import com.tangem.datasource.di.NetworkMoshi
+import com.tangem.datasource.utils.MoshiDataStoreSerializer
+import com.tangem.datasource.utils.listTypes
+import com.tangem.domain.models.wallet.UserWalletId
+import com.tangem.utils.coroutines.AppCoroutineScope
+import dagger.hilt.android.qualifiers.ApplicationContext
+import java.util.concurrent.ConcurrentHashMap
+import javax.inject.Inject
+import javax.inject.Singleton
+
+@Singleton
+class TokenSyncStoreFactory @Inject constructor(
+    @NetworkMoshi private val moshi: Moshi,
+    @ApplicationContext private val context: Context,
+    private val appScope: AppCoroutineScope,
+) {
+
+    private val stores = ConcurrentHashMap<String, TokenSyncStore>()
+
+    fun provide(userWalletId: UserWalletId): TokenSyncStore {
+        val userWalletStringId = userWalletId.formatted()
+        return stores.computeIfAbsent(userWalletStringId) {
+            DefaultTokenSyncStore(
+                persistenceStore = createPersistenceStore(
+                    fileName = "token_sync_$userWalletStringId",
+                    types = listTypes<UserTokensResponse.Token>(),
+                    defaultValue = emptyList(),
+                ),
+            )
+        }
+    }
+
+    private fun <T> createPersistenceStore(
+        fileName: String,
+        types: java.lang.reflect.ParameterizedType,
+        defaultValue: T,
+    ): DataStore<T> = DataStoreFactory.create(
+        serializer = MoshiDataStoreSerializer(
+            moshi = moshi,
+            types = types,
+            defaultValue = defaultValue,
+        ),
+        produceFile = { context.dataStoreFile(fileName = fileName) },
+        scope = appScope,
+    )
+
+    private fun UserWalletId.formatted(): String = stringValue.lowercase()
+}