Updated on 2026-08-14
This commit is contained in:
parent
744185dfa5
commit
be2ba06031
4 changed files with 31 additions and 19 deletions
|
|
@ -23,20 +23,22 @@ internal class DefaultStakingYieldsStore(
|
|||
return withTimeoutOrNull(timeout = YIELDS_WAITING_TIMEOUT, block = { get().firstOrNull() })
|
||||
}
|
||||
|
||||
override suspend fun store(items: List<YieldDTO>) {
|
||||
dataStore.updateData { data ->
|
||||
val updatedItems = data.toMutableList()
|
||||
items.forEach { newItem ->
|
||||
val existingItemIndex = data.indexOfFirst { it.id == newItem.id }
|
||||
if (existingItemIndex != -1) {
|
||||
// Update existing item
|
||||
updatedItems[existingItemIndex] = newItem
|
||||
} else {
|
||||
// Add new item
|
||||
updatedItems.add(newItem)
|
||||
override suspend fun store(items: List<YieldDTO>, force: Boolean) {
|
||||
if (force) {
|
||||
dataStore.updateData { items }
|
||||
} else {
|
||||
dataStore.updateData { data ->
|
||||
val updatedItems = data.toMutableList()
|
||||
items.forEach { newItem ->
|
||||
val existingItemIndex = data.indexOfFirst { it.id == newItem.id }
|
||||
if (existingItemIndex != -1) {
|
||||
updatedItems[existingItemIndex] = newItem
|
||||
} else {
|
||||
updatedItems.add(newItem)
|
||||
}
|
||||
}
|
||||
updatedItems
|
||||
}
|
||||
updatedItems
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -11,5 +11,5 @@ interface StakingYieldsStore {
|
|||
|
||||
suspend fun getSyncWithTimeout(): List<YieldDTO>?
|
||||
|
||||
suspend fun store(items: List<YieldDTO>)
|
||||
suspend fun store(items: List<YieldDTO>, force: Boolean = false)
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue