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

Subscribe to channel updates while in voice chat

Browse Source
This commit is contained in:
Ali
2021-03-12 17:52:45 +04:00
parent 0e44390a0f
commit 1e0a7559aa
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
submodules/TelegramCallsUI/Sources/PresentationGroupCall.swift
View File

@@ -530,6 +530,8 @@ public final class PresentationGroupCallImpl: PresentationGroupCall {
private var processedMissingSsrcs = Set<UInt32>()
private let missingSsrcsDisposable = MetaDisposable()
private var isRequestingMissingSsrcs: Bool = false
private var peerUpdatesSubscription: Disposable?
init(
accountContext: AccountContext,
@@ -761,6 +763,9 @@ public final class PresentationGroupCallImpl: PresentationGroupCall {
let _ = (self.account.postbox.loadedPeerWithId(peerId)
|> deliverOnMainQueue).start(next: { [weak self] peer in
guard let strongSelf = self else {
return
}
var canManageCall = false
if let peer = peer as? TelegramGroup {
if case .creator = peer.role {
@@ -774,14 +779,12 @@ public final class PresentationGroupCallImpl: PresentationGroupCall {
} else if (peer.adminRights?.rights.contains(.canManageCalls) == true) {
canManageCall = true
}
strongSelf.peerUpdatesSubscription = strongSelf.accountContext.account.viewTracker.polledChannel(peerId: peer.id).start()
}
if let strongSelf = self {
var updatedValue = strongSelf.stateValue
updatedValue.canManageCall = canManageCall
strongSelf.stateValue = updatedValue
}
var updatedValue = strongSelf.stateValue
updatedValue.canManageCall = canManageCall
strongSelf.stateValue = updatedValue
})
self.requestCall(movingFromBroadcastToRtc: false)
}
@@ -815,6 +818,8 @@ public final class PresentationGroupCallImpl: PresentationGroupCall {
self.audioOutputStateDisposable?.dispose()
self.removedChannelMembersDisposable?.dispose()
self.peerUpdatesSubscription?.dispose()
}
private func switchToTemporaryParticipantsContext(sourceContext: GroupCallParticipantsContext?, oldMyPeerId: PeerId) {