ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2026-01-07 05:25:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

- statistic

Browse Source
This commit is contained in:
overtake
2020-02-25 11:38:13 +04:00
parent bad8625c30
commit 7c54e6953d
2 changed files with 50 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
submodules/TelegramCore/Sources/ChannelStatistics.swift
View File

@@ -132,40 +132,50 @@ public struct ChannelStatsContextState: Equatable {
public var stats: ChannelStats?
}
private func requestStats(network: Network, datacenterId: Int32, peer: Peer, dark: Bool = false) -> Signal<ChannelStats?, NoError> {
return .never()
/*guard let inputChannel = apiInputChannel(peer) else {
return .never()
}
private func requestStats(network: Network, postbox: Postbox, datacenterId: Int32, peerId: PeerId, dark: Bool = false) -> Signal<ChannelStats?, NoError> {
//return .never()
var flags: Int32 = 0
if dark {
flags |= (1 << 1)
}
let signal: Signal<Api.stats.BroadcastStats, MTRpcError>
if network.datacenterId != datacenterId {
signal = network.download(datacenterId: Int(datacenterId), isMedia: false, tag: nil)
|> castError(MTRpcError.self)
|> mapToSignal { worker in
return worker.request(Api.functions.stats.getBroadcastStats(flags: flags, channel: inputChannel))
return postbox.transaction { transaction -> Api.InputChannel? in
if let peer = transaction.getPeer(peerId) {
return apiInputChannel(peer)
} else {
return nil
}
} |> mapToSignal { inputChannel -> Signal<ChannelStats?, NoError> in
guard let inputChannel = inputChannel else {
return .complete()
}
var flags: Int32 = 0
if dark {
flags |= (1 << 1)
}
let signal: Signal<Api.stats.BroadcastStats, MTRpcError>
if network.datacenterId != datacenterId {
signal = network.download(datacenterId: Int(datacenterId), isMedia: false, tag: nil)
|> castError(MTRpcError.self)
|> mapToSignal { worker in
return worker.request(Api.functions.stats.getBroadcastStats(flags: flags, channel: inputChannel))
}
} else {
signal = network.request(Api.functions.stats.getBroadcastStats(flags: flags, channel: inputChannel))
}
return signal
|> map { result -> ChannelStats? in
return ChannelStats(apiBroadcastStats: result)
}
|> `catch` { error -> Signal<ChannelStats?, NoError> in
return .single(nil)
}
} else {
signal = network.request(Api.functions.stats.getBroadcastStats(flags: flags, channel: inputChannel))
}
return signal
|> map { result -> ChannelStats? in
return ChannelStats(apiBroadcastStats: result)
}
|> `catch` { _ -> Signal<ChannelStats?, NoError> in
return .single(nil)
}*/
}
private func requestGraph(network: Network, datacenterId: Int32, token: String) -> Signal<ChannelStatsGraph?, NoError> {
return .never()
/*let signal: Signal<Api.StatsGraph, MTRpcError>
let signal: Signal<Api.StatsGraph, MTRpcError>
if network.datacenterId != datacenterId {
signal = network.download(datacenterId: Int(datacenterId), isMedia: false, tag: nil)
|> castError(MTRpcError.self)
@@ -182,12 +192,13 @@ private func requestGraph(network: Network, datacenterId: Int32, token: String)
}
|> `catch` { _ -> Signal<ChannelStatsGraph?, NoError> in
return .single(nil)
}*/
}
}
private final class ChannelStatsContextImpl {
private let network: Network
private let peer: Peer
private let postbox: Postbox
private let peerId: PeerId
private let datacenterId: Int32
private var _state: ChannelStatsContextState {
@@ -205,11 +216,11 @@ private final class ChannelStatsContextImpl {
private let disposable = MetaDisposable()
private let disposables = DisposableDict<String>()
init(network: Network, datacenterId: Int32, peer: Peer) {
init(network: Network, postbox: Postbox, datacenterId: Int32, peerId: PeerId) {
assert(Queue.mainQueue().isCurrent())
self.postbox = postbox
self.network = network
self.peer = peer
self.peerId = peerId
self.datacenterId = datacenterId
self._state = ChannelStatsContextState(stats: nil)
self._statePromise.set(.single(self._state))
@@ -226,7 +237,7 @@ private final class ChannelStatsContextImpl {
private func load() {
assert(Queue.mainQueue().isCurrent())
self.disposable.set((requestStats(network: self.network, datacenterId: self.datacenterId, peer: self.peer)
self.disposable.set((requestStats(network: self.network, postbox: self.postbox, datacenterId: self.datacenterId, peerId: self.peerId)
|> deliverOnMainQueue).start(next: { [weak self] stats in
if let strongSelf = self {
strongSelf._state = ChannelStatsContextState(stats: stats)
@@ -326,9 +337,9 @@ public final class ChannelStatsContext {
}
}
public init(network: Network, datacenterId: Int32, peer: Peer) {
public init(network: Network, postbox: Postbox, datacenterId: Int32, peerId: PeerId) {
self.impl = QueueLocalObject(queue: Queue.mainQueue(), generate: {
return ChannelStatsContextImpl(network: network, datacenterId: datacenterId, peer: peer)
return ChannelStatsContextImpl(network: network, postbox: postbox, datacenterId: datacenterId, peerId: peerId)
})
}
@@ -363,7 +374,7 @@ public final class ChannelStatsContext {
}
}
/*extension ChannelStatsGraph {
extension ChannelStatsGraph {
init(apiStatsGraph: Api.StatsGraph) {
switch apiStatsGraph {
case let .statsGraph(json):
@@ -424,4 +435,4 @@ extension ChannelStats {
}
}
}
*/

4
submodules/TelegramCore/Sources/UpdateCachedPeerData.swift
View File

@@ -319,7 +319,7 @@ func fetchAndUpdateCachedPeerData(accountPeerId: PeerId, peerId rawPeerId: PeerI
}
switch fullChat {
case let .channelFull(flags, _, about, participantsCount, adminsCount, kickedCount, bannedCount, _, _, _, _, _, _, apiExportedInvite, apiBotInfos, migratedFromChatId, migratedFromMaxId, pinnedMsgId, stickerSet, minAvailableMsgId, folderId, linkedChatId, location, slowmodeSeconds, slowmodeNextSendDate, _, pts):
case let .channelFull(flags, _, about, participantsCount, adminsCount, kickedCount, bannedCount, _, _, _, _, _, _, apiExportedInvite, apiBotInfos, migratedFromChatId, migratedFromMaxId, pinnedMsgId, stickerSet, minAvailableMsgId, folderId, linkedChatId, location, slowmodeSeconds, slowmodeNextSendDate, statsDc, pts):
var channelFlags = CachedChannelFlags()
if (flags & (1 << 3)) != 0 {
channelFlags.insert(.canDisplayParticipants)
@@ -450,7 +450,7 @@ func fetchAndUpdateCachedPeerData(accountPeerId: PeerId, peerId rawPeerId: PeerI
.withUpdatedSlowModeTimeout(slowmodeSeconds)
.withUpdatedSlowModeValidUntilTimestamp(slowmodeNextSendDate)
.withUpdatedHasScheduledMessages(hasScheduledMessages)
// .withUpdatedStatsDatacenterId(statsDc ?? 0)
.withUpdatedStatsDatacenterId(statsDc ?? 0)
})
if let minAvailableMessageId = minAvailableMessageId, minAvailableMessageIdUpdated {