ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-06-16 05:55:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

[skip ci]

Browse Source
This commit is contained in:
overtake 2021-02-01 17:06:39 +04:00
parent 1ffa585fa4
commit 079bdb3f76
2 changed files with 59 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

116
submodules/TelegramCore/Sources/InvitationLinks.swift
View File

@ -6,64 +6,64 @@ import MtProtoKit
import SyncCore
public func ensuredExistingPeerExportedInvitation(account: Account, peerId: PeerId, revokeExisted: Bool = false) -> Signal<ExportedInvitation?, NoError> {
return account.postbox.transaction { transaction -> Signal<ExportedInvitation?, NoError> in
if let peer = transaction.getPeer(peerId), let inputPeer = apiInputPeer(peer) {
if let _ = peer as? TelegramChannel {
if let cachedData = transaction.getPeerCachedData(peerId: peerId) as? CachedChannelData, cachedData.exportedInvitation != nil && !revokeExisted {
return .single(cachedData.exportedInvitation)
} else {
return account.network.request(Api.functions.messages.exportChatInvite(peer: inputPeer))
|> retryRequest
|> mapToSignal { result -> Signal<ExportedInvitation?, NoError> in
return account.postbox.transaction { transaction -> ExportedInvitation? in
if let invitation = ExportedInvitation(apiExportedInvite: result) {
transaction.updatePeerCachedData(peerIds: Set([peerId]), update: { _, current in
if let current = current as? CachedChannelData {
return current.withUpdatedExportedInvitation(invitation)
} else {
return CachedChannelData().withUpdatedExportedInvitation(invitation)
}
})
return invitation
} else {
return nil
}
}
}
}
} else if let _ = peer as? TelegramGroup {
if let cachedData = transaction.getPeerCachedData(peerId: peerId) as? CachedGroupData, cachedData.exportedInvitation != nil && !revokeExisted {
return .single(cachedData.exportedInvitation)
} else {
return account.network.request(Api.functions.messages.exportChatInvite(peer: inputPeer))
|> retryRequest
|> mapToSignal { result -> Signal<ExportedInvitation?, NoError> in
return account.postbox.transaction { transaction -> ExportedInvitation? in
if let invitation = ExportedInvitation(apiExportedInvite: result) {
transaction.updatePeerCachedData(peerIds: Set([peerId]), update: { _, current in
if let current = current as? CachedGroupData {
return current.withUpdatedExportedInvitation(invitation)
} else {
return current
}
})
return invitation
} else {
return nil
}
}
}
}
} else {
return .complete()
}
} else {
return .complete()
}
} |> switchToLatest
}
//
//public func ensuredExistingPeerExportedInvitation(account: Account, peerId: PeerId, revokeExisted: Bool = false) -> Signal<ExportedInvitation?, NoError> {
// return account.postbox.transaction { transaction -> Signal<ExportedInvitation?, NoError> in
// if let peer = transaction.getPeer(peerId), let inputPeer = apiInputPeer(peer) {
// if let _ = peer as? TelegramChannel {
// if let cachedData = transaction.getPeerCachedData(peerId: peerId) as? CachedChannelData, cachedData.exportedInvitation != nil && !revokeExisted {
// return .single(cachedData.exportedInvitation)
// } else {
// return account.network.request(Api.functions.messages.exportChatInvite(peer: inputPeer))
// |> retryRequest
// |> mapToSignal { result -> Signal<ExportedInvitation?, NoError> in
// return account.postbox.transaction { transaction -> ExportedInvitation? in
// if let invitation = ExportedInvitation(apiExportedInvite: result) {
// transaction.updatePeerCachedData(peerIds: Set([peerId]), update: { _, current in
// if let current = current as? CachedChannelData {
// return current.withUpdatedExportedInvitation(invitation)
// } else {
// return CachedChannelData().withUpdatedExportedInvitation(invitation)
// }
// })
// return invitation
// } else {
// return nil
// }
// }
// }
// }
// } else if let _ = peer as? TelegramGroup {
// if let cachedData = transaction.getPeerCachedData(peerId: peerId) as? CachedGroupData, cachedData.exportedInvitation != nil && !revokeExisted {
// return .single(cachedData.exportedInvitation)
// } else {
// return account.network.request(Api.functions.messages.exportChatInvite(peer: inputPeer))
// |> retryRequest
// |> mapToSignal { result -> Signal<ExportedInvitation?, NoError> in
// return account.postbox.transaction { transaction -> ExportedInvitation? in
// if let invitation = ExportedInvitation(apiExportedInvite: result) {
// transaction.updatePeerCachedData(peerIds: Set([peerId]), update: { _, current in
// if let current = current as? CachedGroupData {
// return current.withUpdatedExportedInvitation(invitation)
// } else {
// return current
// }
// })
// return invitation
// } else {
// return nil
// }
// }
// }
// }
// } else {
// return .complete()
// }
// } else {
// return .complete()
// }
// } |> switchToLatest
//}
public func revokePersistentPeerExportedInvitation(account: Account, peerId: PeerId) -> Signal<ExportedInvitation?, NoError> {

2
submodules/TgVoipWebrtc/tgcalls

@ -1 +1 @@
Subproject commit 1c6747b73fd19043d7bd382ea208ba78314fed00
Subproject commit ff6c6f97a6546049f0543bb5322789348e119b9d