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

Merge branch 'experimental-2' of gitlab.com:peter-iakovlev/telegram-ios into experimental-2

Browse Source 
# Conflicts:
#	submodules/TelegramCore/Sources/InvitationLinks.swift
This commit is contained in:
overtake 2021-02-01 17:07:20 +04:00
commit b0c24338e3
1 changed files with 58 additions and 58 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(flags: 0, peer: inputPeer, expireDate: nil, usageLimit: nil))
|> 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(flags: 0, peer: inputPeer, expireDate: nil, usageLimit: nil))
|> 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> {