IOS-8316 [Casper] Make blockchain implementation

BlockchainSdk/Blockchains/Casper/CasperAddressService.swift

@@ -68,7 +68,7 @@ extension CasperAddressService {
 
 // MARK: - Helpers
 
-fileprivate extension String {
+private extension String {
     func isSameCase() -> Bool {
         lowercased() == self || uppercased() == self
     }

BlockchainSdk/Blockchains/Casper/CasperWalletAssembly.swift

@@ -10,6 +10,18 @@ import Foundation
 
 struct CasperWalletAssembly: WalletManagerAssembly {
     func make(with input: WalletManagerAssemblyInput) throws -> WalletManager {
-        CasperWalletManager(wallet: input.wallet)
+        CasperWalletManager(
+            wallet: input.wallet,
+            networkService: CasperNetworkService(
+                providers: APIResolver(blockchain: input.blockchain, config: input.blockchainSdkConfig)
+                    .resolveProviders(apiInfos: input.apiInfo) { nodeInfo, _ in
+                        CasperNetworkProvider(
+                            node: nodeInfo,
+                            configuration: input.networkConfig
+                        )
+                    },
+                blockchainDecimalValue: input.blockchain.decimalValue
+            )
+        )
     }
 }

BlockchainSdk/Blockchains/Casper/CasperWalletManager.swift

@@ -11,16 +11,43 @@ import Combine
 
 class CasperWalletManager: BaseManager, WalletManager {
     var currentHost: String {
-        // TODO: - https://tangem.atlassian.net/browse/IOS-8316
-        ""
+        networkService.host
     }
 
     var allowsFeeSelection: Bool {
         false
     }
 
+    // MARK: - Private Implementation
+
+    private let networkService: CasperNetworkService
+
+    // MARK: - Init
+
+    init(wallet: Wallet, networkService: CasperNetworkService) {
+        self.networkService = networkService
+        super.init(wallet: wallet)
+    }
+
+    // MARK: - Manager Implementation
+
     override func update(completion: @escaping (Result<Void, any Error>) -> Void) {
-        // TODO: - https://tangem.atlassian.net/browse/IOS-8316
+        let balanceInfoPublisher = networkService
+            .getBalance(address: wallet.address)
+
+        cancellable = balanceInfoPublisher
+            .withWeakCaptureOf(self)
+            .sink(receiveCompletion: { [weak self] result in
+                switch result {
+                case .failure(let error):
+                    self?.wallet.clearAmounts()
+                    completion(.failure(error))
+                case .finished:
+                    completion(.success(()))
+                }
+            }, receiveValue: { walletManager, balanceInfo in
+                walletManager.updateWallet(balanceInfo: balanceInfo)
+            })
     }
 
     func getFee(amount: Amount, destination: String) -> AnyPublisher<[Fee], any Error> {
@@ -32,4 +59,20 @@ class CasperWalletManager: BaseManager, WalletManager {
         // TODO: - https://tangem.atlassian.net/browse/IOS-8316
         return .anyFail(error: SendTxError(error: WalletError.empty))
     }
+
+    // MARK: - Private Implementation
+
+    private func updateWallet(balanceInfo: CasperBalance) {
+        if balanceInfo.value != wallet.amounts[.coin]?.value {
+            wallet.clearPendingTransaction()
+        }
+
+        wallet.add(amount: Amount(with: wallet.blockchain, type: .coin, value: balanceInfo.value))
+    }
+}
+
+extension CasperWalletManager {
+    enum Constants {
+        static let constantFeeValue = Decimal(stringValue: "0.1")
+    }
 }

BlockchainSdk/Blockchains/Casper/DTO/CasperNetworkRequest.QueryBalance.swift

@@ -0,0 +1,19 @@
+//
+//  CasperNetworkRequest.QueryBalance.swift
+//  BlockchainSdk
+//
+//  Created by Alexander Skibin on 29.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+
+extension CasperNetworkRequest {
+    struct QueryBalance: Encodable {
+        let purseIdentifier: PurseIdentifier
+    }
+
+    struct PurseIdentifier: Encodable {
+        let mainPurseUnderPublicKey: String
+    }
+}

BlockchainSdk/Blockchains/Casper/DTO/CasperNetworkRequest.swift

@@ -0,0 +1,12 @@
+//
+//  CasperNetworkRequest.swift
+//  BlockchainSdk
+//
+//  Created by Alexander Skibin on 29.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+
+/// A top-level namespace.
+enum CasperNetworkRequest {}

BlockchainSdk/Blockchains/Casper/DTO/CasperNetworkResponse.Balance.swift

@@ -0,0 +1,17 @@
+//
+//  CasperNetworkResult.BalanceInfo.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 24.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+
+extension CasperNetworkResponse {
+    /// The balance represented in motes.
+    struct Balance: Decodable {
+        let apiVersion: String
+        let balance: String
+    }
+}

BlockchainSdk/Blockchains/Casper/DTO/CasperNetworkResponse.swift

@@ -0,0 +1,12 @@
+//
+//  CasperNetworkResponse.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 24.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+
+/// A top-level namespace.
+enum CasperNetworkResponse {}

BlockchainSdk/Blockchains/Casper/Domain/CasperBalance.swift

@@ -0,0 +1,13 @@
+//
+//  CasperBalance.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 24.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+
+struct CasperBalance {
+    let value: Decimal
+}

BlockchainSdk/Blockchains/Casper/Network/CasperNetworkProvider.swift

@@ -0,0 +1,53 @@
+//
+//  CasperNetworkProvider.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 22.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Combine
+import Foundation
+
+final class CasperNetworkProvider: HostProvider {
+    var host: String {
+        node.url.absoluteString
+    }
+
+    // MARK: - Private Properties
+
+    private let node: NodeInfo
+    private let provider: NetworkProvider<CasperTarget>
+
+    // MARK: - Init
+
+    init(
+        node: NodeInfo,
+        configuration: NetworkProviderConfiguration
+    ) {
+        self.node = node
+        provider = NetworkProvider<CasperTarget>(configuration: configuration)
+    }
+
+    // MARK: - Implementation
+
+    func getBalance(address: String) -> AnyPublisher<CasperNetworkResponse.Balance, Error> {
+        let query = CasperNetworkRequest.QueryBalance(purseIdentifier: .init(mainPurseUnderPublicKey: address))
+        return requestPublisher(for: .getBalance(data: query))
+    }
+
+    // MARK: - Private Implementation
+
+    private func requestPublisher<T: Decodable>(for type: CasperTarget.TargetType) -> AnyPublisher<T, Error> {
+        let decoder = JSONDecoder()
+        decoder.keyDecodingStrategy = .convertFromSnakeCase
+
+        return provider.requestPublisher(CasperTarget(node: node, type: type))
+            .filterSuccessfulStatusAndRedirectCodes()
+            .map(JSONRPC.Response<T, JSONRPC.APIError>.self, using: decoder)
+            .tryMap {
+                try $0.result.get()
+            }
+            .eraseToAnyPublisher()
+    }
+}

BlockchainSdk/Blockchains/Casper/Network/CasperNetworkService.swift

@@ -0,0 +1,64 @@
+//
+//  CasperNetworkService.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 24.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+import Combine
+
+final class CasperNetworkService: MultiNetworkProvider {
+    // MARK: - MultiNetwork Provider
+
+    var currentProviderIndex: Int = 0
+
+    // MARK: - Properties
+
+    let providers: [CasperNetworkProvider]
+    let blockchainDecimalValue: Decimal
+
+    // MARK: - Init
+
+    init(providers: [CasperNetworkProvider], blockchainDecimalValue: Decimal) {
+        self.providers = providers
+        self.blockchainDecimalValue = blockchainDecimalValue
+    }
+
+    // MARK: - Implementation
+
+    func getBalance(address: String) -> AnyPublisher<CasperBalance, Error> {
+        return providerPublisher { provider in
+            return provider
+                .getBalance(address: address)
+                .withWeakCaptureOf(self)
+                .tryMap { service, result in
+                    guard let balanceValue = Decimal(string: result.balance) else {
+                        throw WalletError.failedToParseNetworkResponse()
+                    }
+
+                    let decimalBalanceValue = balanceValue / service.blockchainDecimalValue
+                    return .init(value: decimalBalanceValue)
+                }
+                .tryCatch { error -> AnyPublisher<CasperBalance, Error> in
+                    if let error = error as? JSONRPC.APIError, error.code == Constants.ERROR_CODE_QUERY_FAILED {
+                        return .anyFail(
+                            error: WalletError.noAccount(
+                                message: Localization.noAccountSendToCreate,
+                                amountToCreate: 0
+                            )
+                        )
+                    }
+                    return .anyFail(error: error)
+                }
+                .eraseToAnyPublisher()
+        }
+    }
+}
+
+extension CasperNetworkService {
+    enum Constants {
+        static let ERROR_CODE_QUERY_FAILED = -32003
+    }
+}

BlockchainSdk/Blockchains/Casper/Network/CasperTarget.swift

@@ -0,0 +1,71 @@
+//
+//  CasperTarget.swift
+//  BlockchainSdk
+//
+//  Created by skibinalexander on 22.10.2024.
+//  Copyright © 2024 Tangem AG. All rights reserved.
+//
+
+import Foundation
+import Moya
+
+struct CasperTarget: TargetType {
+    // MARK: - Properties
+
+    let node: NodeInfo
+    let type: TargetType
+
+    // MARK: - Init
+
+    init(node: NodeInfo, type: TargetType) {
+        self.node = node
+        self.type = type
+    }
+
+    // MARK: - TargetType
+
+    var baseURL: URL {
+        node.url
+    }
+
+    var path: String {
+        ""
+    }
+
+    var method: Moya.Method {
+        .post
+    }
+
+    var task: Task {
+        switch type {
+        case .getBalance(let data):
+            let encoder = JSONEncoder()
+            encoder.keyEncodingStrategy = .convertToSnakeCase
+
+            return .requestJSONRPC(
+                id: Constants.jsonRPCMethodId,
+                method: Method.queryBalance.rawValue,
+                params: data,
+                encoder: encoder
+            )
+        }
+    }
+
+    var headers: [String: String]?
+}
+
+extension CasperTarget {
+    enum TargetType {
+        case getBalance(data: CasperNetworkRequest.QueryBalance)
+    }
+
+    enum Method: String, Encodable {
+        case queryBalance = "query_balance"
+    }
+}
+
+private extension CasperTarget {
+    enum Constants {
+        static let jsonRPCMethodId: Int = 1
+    }
+}

BlockchainSdk/Common/API/APIResolvers/NowNodes/NowNodesAPIResolver.swift

@@ -70,6 +70,8 @@ struct NowNodesAPIResolver {
             link = "https://blast.nownodes.io/\(apiKey)"
         case .filecoin:
             link = "https://fil.nownodes.io/\(apiKey)/rpc/v1"
+        case .casper:
+            link = "https://casper.nownodes.io/\(apiKey)/rpc"
         default:
             return nil
         }