From cd563d556b124d7c8c6ba4bb7f3146073455432f Mon Sep 17 00:00:00 2001
From: Ilya Laktyushin <ilya@laktyush.in>
Date: Thu, 28 Mar 2024 19:57:42 +0400
Subject: [PATCH] Fix revenue transactions loading

---
 .../Statistics/RevenueStatistics.swift        | 23 ++++---------------
 1 file changed, 5 insertions(+), 18 deletions(-)

diff --git a/submodules/TelegramCore/Sources/Statistics/RevenueStatistics.swift b/submodules/TelegramCore/Sources/Statistics/RevenueStatistics.swift
index 323b47fe43..7c15126a48 100644
--- a/submodules/TelegramCore/Sources/Statistics/RevenueStatistics.swift
+++ b/submodules/TelegramCore/Sources/Statistics/RevenueStatistics.swift
@@ -220,34 +220,21 @@ private final class RevenueStatsTransactionsContextImpl {
         let peerId = self.peerId
         let lastOffset = self.lastOffset
         
-        self.disposable.set((self.account.postbox.transaction { transaction -> (Peer, Int32?)? in
-            let statsDatacenterId = (transaction.getPeerCachedData(peerId: peerId) as? CachedChannelData)?.statsDatacenterId
+        self.disposable.set((self.account.postbox.transaction { transaction -> Peer? in
             guard let peer = transaction.getPeer(peerId) else {
                 return nil
             }
-            return (peer, statsDatacenterId)
+            return peer
         }
-        |> mapToSignal { data -> Signal<([RevenueStatsTransactionsContext.State.Transaction], Int32, Int32?), NoError> in
-            if let (peer, statsDatacenterId) = data {
+        |> mapToSignal { peer -> Signal<([RevenueStatsTransactionsContext.State.Transaction], Int32, Int32?), NoError> in
+            if let peer {
                 guard let inputChannel = apiInputChannel(peer) else {
                     return .complete()
                 }
                 let offset = lastOffset ?? 0
                 let limit: Int32 = lastOffset == nil ? 25 : 50
                 
-                let request = Api.functions.stats.getBroadcastRevenueTransactions(channel: inputChannel, offset: offset, limit: limit)
-                let signal: Signal<Api.stats.BroadcastRevenueTransactions, MTRpcError>
-                if let statsDatacenterId = statsDatacenterId, account.network.datacenterId != statsDatacenterId {
-                    signal = account.network.download(datacenterId: Int(statsDatacenterId), isMedia: false, tag: nil)
-                    |> castError(MTRpcError.self)
-                    |> mapToSignal { worker in
-                        return worker.request(request)
-                    }
-                } else {
-                    signal = account.network.request(request, automaticFloodWait: false)
-                }
-                
-                return signal
+                return account.network.request(Api.functions.stats.getBroadcastRevenueTransactions(channel: inputChannel, offset: offset, limit: limit), automaticFloodWait: false)
                 |> map(Optional.init)
                 |> `catch` { _ -> Signal<Api.stats.BroadcastRevenueTransactions?, NoError> in
                     return .single(nil)