@@ -45,10 +45,10 @@ public protocol WalletUserAssetManagerType: AnyObject {
45
45
func updateBalance( for asset: BraveWallet . BlockchainToken , account: String , balance: String , completion: ( ( ) -> Void ) ? )
46
46
/// Remove a `WalletUserAssetBalance` representation of the given
47
47
/// `BraveWallet.BlockchainToken` from CoreData
48
- func removeBalance ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? )
48
+ func removeBalances ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? )
49
49
/// Remove a `WalletUserAssetBalance` representation of the given
50
50
/// `BraveWallet.NetworkInfo` from CoreData
51
- func removeBalance ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? )
51
+ func removeBalances ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? )
52
52
/// Add a user asset data observer
53
53
func addUserAssetDataObserver( _ observer: WalletUserAssetDataObserver )
54
54
/// Remove user assets and their cached balance that belongs to given network
@@ -187,7 +187,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
187
187
if existedAsset. isDeletedByUser { // this asset was added before but user marked as deleted after
188
188
WalletUserAsset . updateUserAsset ( for: asset, visible: true , isSpam: false , isDeletedByUser: false , completion: { [ weak self] in
189
189
self ? . refreshBalance ( for: asset)
190
- self ? . retriveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
190
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
191
191
completion ? ( )
192
192
} )
193
193
} else { // this asset already exists
@@ -199,7 +199,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
199
199
asset: asset,
200
200
completion: { [ weak self] in
201
201
self ? . refreshBalance ( for: asset)
202
- self ? . retriveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
202
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
203
203
completion ? ( )
204
204
}
205
205
)
@@ -208,8 +208,8 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
208
208
209
209
public func removeUserAsset( _ asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? ) {
210
210
WalletUserAsset . removeUserAsset ( asset: asset, completion: { [ weak self] in
211
- self ? . removeBalance ( for: asset, completion: nil )
212
- self ? . retriveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
211
+ self ? . removeBalances ( for: asset, completion: nil )
212
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
213
213
completion ? ( )
214
214
} )
215
215
}
@@ -230,7 +230,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
230
230
if visible {
231
231
self ? . refreshBalance ( for: asset)
232
232
}
233
- self ? . retriveAllDataObserver ( ) . forEach { observer in
233
+ self ? . retrieveAllDataObserver ( ) . forEach { observer in
234
234
observer. userAssetUpdated ( )
235
235
}
236
236
completion ? ( )
@@ -242,7 +242,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
242
242
WalletUserAssetGroup . removeGroup (
243
243
groupId,
244
244
completion: { [ weak self] in
245
- self ? . retriveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
245
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. userAssetUpdated ( ) }
246
246
completion ? ( )
247
247
} )
248
248
}
@@ -289,21 +289,21 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
289
289
)
290
290
}
291
291
292
- public func removeBalance ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? ) {
293
- WalletUserAssetBalance . removeBalance (
292
+ public func removeBalances ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? ) {
293
+ WalletUserAssetBalance . removeBalances (
294
294
for: asset,
295
295
completion: { [ weak self] in
296
- self ? . retriveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
296
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
297
297
completion ? ( )
298
298
}
299
299
)
300
300
}
301
301
302
- public func removeBalance ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? ) {
303
- WalletUserAssetBalance . removeBalance (
302
+ public func removeBalances ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? ) {
303
+ WalletUserAssetBalance . removeBalances (
304
304
for: network,
305
305
completion: { [ weak self] in
306
- self ? . retriveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
306
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
307
307
completion ? ( )
308
308
} )
309
309
}
@@ -326,9 +326,11 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
326
326
of: Void . self,
327
327
body: { @MainActor [ rpcService] group in
328
328
for account in accounts {
329
+ guard !Task. isCancelled else { return }
329
330
group. addTask { @MainActor in
330
331
let allTokenBalanceForAccount = await rpcService. fetchBalancesForTokens ( account: account, networkAssets: allUserAssets)
331
332
for tokenBalanceForAccount in allTokenBalanceForAccount {
333
+ guard !Task. isCancelled else { return }
332
334
let networkAssets = allUserAssets. first { oneNetworkAssets in
333
335
oneNetworkAssets. tokens. contains { asset in
334
336
asset. id == tokenBalanceForAccount. key
@@ -342,7 +344,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
342
344
}
343
345
}
344
346
)
345
- retriveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
347
+ retrieveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
346
348
completion ? ( )
347
349
}
348
350
}
@@ -355,7 +357,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
355
357
group. leave ( )
356
358
}
357
359
group. enter ( )
358
- WalletUserAssetBalance . removeBalance ( for: network) {
360
+ WalletUserAssetBalance . removeBalances ( for: network) {
359
361
group. leave ( )
360
362
}
361
363
} else {
@@ -364,7 +366,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
364
366
group. leave ( )
365
367
}
366
368
group. enter ( )
367
- WalletUserAssetBalance . removeBalance {
369
+ WalletUserAssetBalance . removeBalances {
368
370
group. leave ( )
369
371
}
370
372
}
@@ -394,7 +396,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
394
396
}
395
397
}
396
398
)
397
- retriveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
399
+ retrieveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
398
400
completion ? ( )
399
401
}
400
402
}
@@ -425,7 +427,7 @@ public class WalletUserAssetManager: WalletUserAssetManagerType, WalletObserverS
425
427
}
426
428
}
427
429
428
- private func retriveAllDataObserver ( ) -> [ WalletUserAssetDataObserver ] {
430
+ private func retrieveAllDataObserver ( ) -> [ WalletUserAssetDataObserver ] {
429
431
return dataObservers. allObjects as? [ WalletUserAssetDataObserver ] ?? [ ]
430
432
}
431
433
}
@@ -434,7 +436,7 @@ extension WalletUserAssetManager: PreferencesObserver {
434
436
public func preferencesDidChange( for key: String ) {
435
437
if key == Preferences . Wallet. showTestNetworks. key {
436
438
refreshBalances { [ weak self] in
437
- self ? . retriveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
439
+ self ? . retrieveAllDataObserver ( ) . forEach { $0. cachedBalanceRefreshed ( ) }
438
440
}
439
441
}
440
442
}
@@ -503,11 +505,11 @@ public class TestableWalletUserAssetManager: WalletUserAssetManagerType {
503
505
completion ? ( )
504
506
}
505
507
506
- public func removeBalance ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? ) {
508
+ public func removeBalances ( for asset: BraveWallet . BlockchainToken , completion: ( ( ) -> Void ) ? ) {
507
509
completion ? ( )
508
510
}
509
511
510
- public func removeBalance ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? ) {
512
+ public func removeBalances ( for network: BraveWallet . NetworkInfo , completion: ( ( ) -> Void ) ? ) {
511
513
completion ? ( )
512
514
}
513
515
0 commit comments