From 18007a78c56886381b6c60ea2f01e33cecdd804a Mon Sep 17 00:00:00 2001
From: Hwee-Boon Yar <hboon@motionobj.com>
Date: Sun, 2 Jun 2024 15:34:13 +0800
Subject: [PATCH] SwiftFormat

---
 .../Tokens/TokensProcessingPipeline.swift     | 52 +++++++++----------
 1 file changed, 25 insertions(+), 27 deletions(-)

diff --git a/modules/AlphaWalletFoundation/AlphaWalletFoundation/Tokens/TokensProcessingPipeline.swift b/modules/AlphaWalletFoundation/AlphaWalletFoundation/Tokens/TokensProcessingPipeline.swift
index 1c5fd35d0..5eff2e7d7 100644
--- a/modules/AlphaWalletFoundation/AlphaWalletFoundation/Tokens/TokensProcessingPipeline.swift
+++ b/modules/AlphaWalletFoundation/AlphaWalletFoundation/Tokens/TokensProcessingPipeline.swift
@@ -5,8 +5,9 @@
 //  Created by Vladyslav Shepitko on 09.07.2022.
 //
 
-import Foundation
 import Combine
+import Foundation
+
 import AlphaWalletCore
 import CombineExt
 
@@ -75,11 +76,11 @@ public final class WalletDataProcessingPipeline: TokensProcessingPipeline {
             .receive(on: queue)
 
         let whenCollectionHasChanged = Publishers.Merge5(whenTokensHasChanged, whenTickersChanged, whenSignatureOrBodyChanged, whenAttestationXMLChanged, whenCurrencyChanged)
-                .map { $0.map { TokenViewModel(token: $0) } }
-                .flatMapLatest { tokenViewModels in asFuture { await self.applyTickers(tokens: tokenViewModels) ?? [] } }
-                .flatMap { self.applyTokenScriptOverrides(tokens: $0) }
-                .receive(on: RunLoop.main)
-                .eraseToAnyPublisher()
+            .map { $0.map { TokenViewModel(token: $0) } }
+            .flatMapLatest { tokenViewModels in asFuture { await self.applyTickers(tokens: tokenViewModels) ?? [] } }
+            .flatMap { self.applyTokenScriptOverrides(tokens: $0) }
+            .receive(on: RunLoop.main)
+            .eraseToAnyPublisher()
 
         let initialSnapshot: AnyPublisher<[TokenViewModel], Never> = asFuture { await self.tokensService.tokens }
             .map { $0.map { TokenViewModel(token: $0) } }
@@ -100,7 +101,6 @@ public final class WalletDataProcessingPipeline: TokensProcessingPipeline {
                 eventsDataStore: NonActivityEventsDataStore,
                 currencyService: CurrencyService,
                 sessionsProvider: SessionsProvider) {
-
         self.sessionsProvider = sessionsProvider
         self.wallet = wallet
         self.currencyService = currencyService
@@ -211,11 +211,11 @@ public final class WalletDataProcessingPipeline: TokensProcessingPipeline {
                     let tokens = (tokens + nativeCryptoForAllChains).filter { !$0.server.isTestnet && ($0.type == .nativeCryptocurrency || $0.type == .erc20) }
                     let uniqueTokens = Set(tokens).map {
                         TokenMappedToTicker(
-                                symbol: $0.symbol,
-                                name: $0.name,
-                                contractAddress: $0.contractAddress,
-                                server: $0.server,
-                                coinGeckoId: $0.info.coinGeckoId)
+                            symbol: $0.symbol,
+                            name: $0.name,
+                            contractAddress: $0.contractAddress,
+                            server: $0.server,
+                            coinGeckoId: $0.info.coinGeckoId)
                     }
 
                     await coinTickersFetcher.fetchTickers(for: uniqueTokens, force: false, currency: currency)
@@ -224,22 +224,22 @@ public final class WalletDataProcessingPipeline: TokensProcessingPipeline {
             }.store(in: &cancelable)
 
         coinTickersProvider.updateTickerIds
-                .flatMap { [tokensService] (data: [(tickerId: TickerIdString, key: AddressAndRPCServer)]) in
-                    asFuture { () -> [(Token, TickerIdString)] in
-                        await data.asyncCompactMap { each in
-                            await tokensService.token(for: each.key.address, server: each.key.server).flatMap {
-                                ($0, each.tickerId)
-                            }
+            .flatMap { [tokensService] (data: [(tickerId: TickerIdString, key: AddressAndRPCServer)]) in
+                asFuture { () -> [(Token, TickerIdString)] in
+                    await data.asyncCompactMap { each in
+                        await tokensService.token(for: each.key.address, server: each.key.server).flatMap {
+                            ($0, each.tickerId)
                         }
                     }
                 }
-                .map { (each: [(Token, TickerIdString)]) in each.map { AddOrUpdateTokenAction.update(token: $0.0, field: .coinGeckoTickerId($0.1)) } }
-                .eraseToAnyPublisher()
-                .sink { [tokensService] actions in
-                    Task { @MainActor in
-                        await tokensService.addOrUpdate(with: actions)
-                    }
-                }.store(in: &cancelable)
+            }
+            .map { (each: [(Token, TickerIdString)]) in each.map { AddOrUpdateTokenAction.update(token: $0.0, field: .coinGeckoTickerId($0.1)) } }
+            .eraseToAnyPublisher()
+            .sink { [tokensService] actions in
+                Task { @MainActor in
+                    await tokensService.addOrUpdate(with: actions)
+                }
+            }.store(in: &cancelable)
     }
 
     private func applyTokenScriptOverrides(tokens: [TokenViewModel]) -> AnyPublisher<[TokenViewModel], Never> {
@@ -287,7 +287,6 @@ public final class WalletDataProcessingPipeline: TokensProcessingPipeline {
 }
 
 public extension TokensProcessingPipeline {
-
     func tokenViewModelPublisher(for token: Token) -> AnyPublisher<TokenViewModel?, Never> {
         return tokenViewModelPublisher(for: token.contractAddress, server: token.server)
     }
@@ -295,4 +294,3 @@ public extension TokensProcessingPipeline {
     func tokenViewModel(for token: Token) async -> TokenViewModel? {
         return await tokenViewModel(for: token.contractAddress, server: token.server)
     }
-}
\ No newline at end of file