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

no message

Browse Source
This commit is contained in:
Peter
2018-09-15 00:39:19 +03:00
parent 6aeaf3699c
commit 11629a068a
7 changed files with 66 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
TelegramCore/CollectCacheUsageStats.swift
View File

@@ -173,8 +173,6 @@ public func collectCacheUsageStats(account: Account) -> Signal<CacheUsageStatsRe
#endif #endif
return account.postbox.transaction { transaction -> CacheUsageStats in return account.postbox.transaction { transaction -> CacheUsageStats in
var peers: [PeerId: Peer] = [:] var peers: [PeerId: Peer] = [:]
for peerId in finalMedia.keys { for peerId in finalMedia.keys {
if let peer = transaction.getPeer(peerId) { if let peer = transaction.getPeer(peerId) {

7
TelegramCore/Download.swift
View File

@@ -232,7 +232,6 @@ class Download: NSObject, MTRequestMessageServiceDelegate {
} }
func request<T>(_ data: (FunctionDescription, Buffer, DeserializeFunctionResponse<T>)) -> Signal<T, MTRpcError> { func request<T>(_ data: (FunctionDescription, Buffer, DeserializeFunctionResponse<T>)) -> Signal<T, MTRpcError> {
let requestService = self.requestService
return Signal { subscriber in return Signal { subscriber in
let request = MTRequest() let request = MTRequest()
@@ -261,10 +260,10 @@ class Download: NSObject, MTRequestMessageServiceDelegate {
let internalId: Any! = request.internalId let internalId: Any! = request.internalId
requestService.add(request) self.requestService.add(request)
return ActionDisposable { [weak requestService] in return ActionDisposable {
requestService?.removeRequest(byInternalId: internalId) self.requestService.removeRequest(byInternalId: internalId)
} }
} }
} }

94
TelegramCore/FetchedMediaResource.swift
View File

@@ -423,18 +423,20 @@ extension MediaResourceReference {
final class TelegramCloudMediaResourceFetchInfo: MediaResourceFetchInfo { final class TelegramCloudMediaResourceFetchInfo: MediaResourceFetchInfo {
let reference: MediaResourceReference let reference: MediaResourceReference
let preferBackgroundReferenceRevalidation: Bool
init(reference: MediaResourceReference) { init(reference: MediaResourceReference, preferBackgroundReferenceRevalidation: Bool) {
self.reference = reference self.reference = reference
self.preferBackgroundReferenceRevalidation = preferBackgroundReferenceRevalidation
} }
} }
public func fetchedMediaResource(postbox: Postbox, reference: MediaResourceReference, range: Range<Int>? = nil, statsCategory: MediaResourceStatsCategory = .generic, reportResultStatus: Bool = false) -> Signal<FetchResourceSourceType, NoError> { public func fetchedMediaResource(postbox: Postbox, reference: MediaResourceReference, range: Range<Int>? = nil, statsCategory: MediaResourceStatsCategory = .generic, reportResultStatus: Bool = false, preferBackgroundReferenceRevalidation: Bool = false) -> Signal<FetchResourceSourceType, NoError> {
if let range = range { if let range = range {
return postbox.mediaBox.fetchedResourceData(reference.resource, in: range, parameters: MediaResourceFetchParameters(tag: TelegramMediaResourceFetchTag(statsCategory: statsCategory), info: TelegramCloudMediaResourceFetchInfo(reference: reference))) return postbox.mediaBox.fetchedResourceData(reference.resource, in: range, parameters: MediaResourceFetchParameters(tag: TelegramMediaResourceFetchTag(statsCategory: statsCategory), info: TelegramCloudMediaResourceFetchInfo(reference: reference, preferBackgroundReferenceRevalidation: preferBackgroundReferenceRevalidation)))
|> map { _ in .local } |> map { _ in .local }
} else { } else {
return postbox.mediaBox.fetchedResource(reference.resource, parameters: MediaResourceFetchParameters(tag: TelegramMediaResourceFetchTag(statsCategory: statsCategory), info: TelegramCloudMediaResourceFetchInfo(reference: reference)), implNext: reportResultStatus) return postbox.mediaBox.fetchedResource(reference.resource, parameters: MediaResourceFetchParameters(tag: TelegramMediaResourceFetchTag(statsCategory: statsCategory), info: TelegramCloudMediaResourceFetchInfo(reference: reference, preferBackgroundReferenceRevalidation: preferBackgroundReferenceRevalidation)), implNext: reportResultStatus)
} }
} }
@@ -550,43 +552,50 @@ private final class MediaReferenceRevalidationItemContext {
} }
} }
private struct MediaReferenceRevalidationKeyAndPlacement: Hashable {
let key: MediaReferenceRevalidationKey
let background: Bool
}
private final class MediaReferenceRevalidationContextImpl { private final class MediaReferenceRevalidationContextImpl {
let queue: Queue let queue: Queue
var itemContexts: [MediaReferenceRevalidationKey: MediaReferenceRevalidationItemContext] = [:] var itemContexts: [MediaReferenceRevalidationKeyAndPlacement: MediaReferenceRevalidationItemContext] = [:]
init(queue: Queue) { init(queue: Queue) {
self.queue = queue self.queue = queue
} }
func genericItem(key: MediaReferenceRevalidationKey, request: @escaping (@escaping (Any) -> Void, @escaping (RevalidateMediaReferenceError) -> Void) -> Disposable, _ f: @escaping (Any) -> Void) -> Disposable { func genericItem(key: MediaReferenceRevalidationKey, background: Bool, request: @escaping (@escaping (Any) -> Void, @escaping (RevalidateMediaReferenceError) -> Void) -> Disposable, _ f: @escaping (Any) -> Void) -> Disposable {
let queue = self.queue let queue = self.queue
let itemKey = MediaReferenceRevalidationKeyAndPlacement(key: key, background: background)
let context: MediaReferenceRevalidationItemContext let context: MediaReferenceRevalidationItemContext
if let current = self.itemContexts[key] { if let current = self.itemContexts[itemKey] {
context = current context = current
} else { } else {
let disposable = MetaDisposable() let disposable = MetaDisposable()
context = MediaReferenceRevalidationItemContext(disposable: disposable) context = MediaReferenceRevalidationItemContext(disposable: disposable)
self.itemContexts[key] = context self.itemContexts[itemKey] = context
disposable.set(request({ [weak self] result in disposable.set(request({ [weak self] result in
queue.async { queue.async {
guard let strongSelf = self else { guard let strongSelf = self else {
return return
} }
if let current = strongSelf.itemContexts[key], current === context { if let current = strongSelf.itemContexts[itemKey], current === context {
strongSelf.itemContexts.removeValue(forKey: key) strongSelf.itemContexts.removeValue(forKey: itemKey)
for subscriber in current.subscribers.copyItems() { for subscriber in current.subscribers.copyItems() {
subscriber(result) subscriber(result)
} }
} }
} }
}, { [weak self] _ in }, { [weak self] _ in
queue.async { /*queue.async {
guard let strongSelf = self else { guard let strongSelf = self else {
return return
} }
} }*/
})) }))
} }
@@ -597,11 +606,11 @@ private final class MediaReferenceRevalidationContextImpl {
guard let strongSelf = self else { guard let strongSelf = self else {
return return
} }
if let current = strongSelf.itemContexts[key], current === context { if let current = strongSelf.itemContexts[itemKey], current === context {
current.removeSubscriber(index) current.removeSubscriber(index)
if current.isEmpty { if current.isEmpty {
current.disposable.dispose() current.disposable.dispose()
strongSelf.itemContexts.removeValue(forKey: key) strongSelf.itemContexts.removeValue(forKey: itemKey)
} }
} }
} }
@@ -621,11 +630,11 @@ final class MediaReferenceRevalidationContext {
}) })
} }
private func genericItem(key: MediaReferenceRevalidationKey, request: @escaping (@escaping (Any) -> Void, @escaping (RevalidateMediaReferenceError) -> Void) -> Disposable) -> Signal<Any, RevalidateMediaReferenceError> { private func genericItem(key: MediaReferenceRevalidationKey, background: Bool, request: @escaping (@escaping (Any) -> Void, @escaping (RevalidateMediaReferenceError) -> Void) -> Disposable) -> Signal<Any, RevalidateMediaReferenceError> {
return Signal { subscriber in return Signal { subscriber in
let disposable = MetaDisposable() let disposable = MetaDisposable()
self.impl.with { impl in self.impl.with { impl in
disposable.set(impl.genericItem(key: key, request: request, { result in disposable.set(impl.genericItem(key: key, background: background, request: request, { result in
subscriber.putNext(result) subscriber.putNext(result)
subscriber.putCompletion() subscriber.putCompletion()
})) }))
@@ -634,9 +643,20 @@ final class MediaReferenceRevalidationContext {
} }
} }
func message(postbox: Postbox, network: Network, message: MessageReference) -> Signal<Message, RevalidateMediaReferenceError> { func message(postbox: Postbox, network: Network, background: Bool, message: MessageReference) -> Signal<Message, RevalidateMediaReferenceError> {
return self.genericItem(key: .message(message: message), request: { next, error in return self.genericItem(key: .message(message: message), background: background, request: { next, error in
return fetchRemoteMessage(postbox: postbox, network: network, message: message).start(next: { value in let source: Signal<FetchMessageHistoryHoleSource, NoError>
if background {
source = network.background()
|> map(FetchMessageHistoryHoleSource.download)
} else {
source = .single(.network(network))
}
let signal = source
|> mapToSignal { source -> Signal<Message?, NoError> in
return fetchRemoteMessage(postbox: postbox, source: source, message: message)
}
return signal.start(next: { value in
if let value = value { if let value = value {
next(value) next(value)
} else { } else {
@@ -654,8 +674,8 @@ final class MediaReferenceRevalidationContext {
} }
} }
func stickerPack(postbox: Postbox, network: Network, stickerPack: StickerPackReference) -> Signal<(StickerPackCollectionInfo, [ItemCollectionItem]), RevalidateMediaReferenceError> { func stickerPack(postbox: Postbox, network: Network, background: Bool, stickerPack: StickerPackReference) -> Signal<(StickerPackCollectionInfo, [ItemCollectionItem]), RevalidateMediaReferenceError> {
return self.genericItem(key: .stickerPack(stickerPack: stickerPack), request: { next, error in return self.genericItem(key: .stickerPack(stickerPack: stickerPack), background: background, request: { next, error in
return (updatedRemoteStickerPack(postbox: postbox, network: network, reference: stickerPack) return (updatedRemoteStickerPack(postbox: postbox, network: network, reference: stickerPack)
|> mapError { _ -> RevalidateMediaReferenceError in |> mapError { _ -> RevalidateMediaReferenceError in
return .generic return .generic
@@ -677,8 +697,8 @@ final class MediaReferenceRevalidationContext {
} }
} }
func webPage(postbox: Postbox, network: Network, webPage: WebpageReference) -> Signal<TelegramMediaWebpage, RevalidateMediaReferenceError> { func webPage(postbox: Postbox, network: Network, background: Bool, webPage: WebpageReference) -> Signal<TelegramMediaWebpage, RevalidateMediaReferenceError> {
return self.genericItem(key: .webPage(webPage: webPage), request: { next, error in return self.genericItem(key: .webPage(webPage: webPage), background: background, request: { next, error in
return (updatedRemoteWebpage(postbox: postbox, network: network, webPage: webPage) return (updatedRemoteWebpage(postbox: postbox, network: network, webPage: webPage)
|> mapError { _ -> RevalidateMediaReferenceError in |> mapError { _ -> RevalidateMediaReferenceError in
return .generic return .generic
@@ -700,8 +720,8 @@ final class MediaReferenceRevalidationContext {
} }
} }
func savedGifs(postbox: Postbox, network: Network) -> Signal<[TelegramMediaFile], RevalidateMediaReferenceError> { func savedGifs(postbox: Postbox, network: Network, background: Bool) -> Signal<[TelegramMediaFile], RevalidateMediaReferenceError> {
return self.genericItem(key: .savedGifs, request: { next, error in return self.genericItem(key: .savedGifs, background: background, request: { next, error in
let loadRecentGifs: Signal<[TelegramMediaFile], NoError> = postbox.transaction { transaction -> [TelegramMediaFile] in let loadRecentGifs: Signal<[TelegramMediaFile], NoError> = postbox.transaction { transaction -> [TelegramMediaFile] in
return transaction.getOrderedListItems(collectionId: Namespaces.OrderedItemList.CloudRecentGifs).compactMap({ item -> TelegramMediaFile? in return transaction.getOrderedListItems(collectionId: Namespaces.OrderedItemList.CloudRecentGifs).compactMap({ item -> TelegramMediaFile? in
if let contents = item.contents as? RecentMediaItem, let file = contents.media as? TelegramMediaFile { if let contents = item.contents as? RecentMediaItem, let file = contents.media as? TelegramMediaFile {
@@ -729,8 +749,8 @@ final class MediaReferenceRevalidationContext {
} }
} }
func peer(postbox: Postbox, network: Network, peer: PeerReference) -> Signal<Peer, RevalidateMediaReferenceError> { func peer(postbox: Postbox, network: Network, background: Bool, peer: PeerReference) -> Signal<Peer, RevalidateMediaReferenceError> {
return self.genericItem(key: .peer(peer: peer), request: { next, error in return self.genericItem(key: .peer(peer: peer), background: background, request: { next, error in
return (updatedRemotePeer(postbox: postbox, network: network, peer: peer) return (updatedRemotePeer(postbox: postbox, network: network, peer: peer)
|> mapError { _ -> RevalidateMediaReferenceError in |> mapError { _ -> RevalidateMediaReferenceError in
return .generic return .generic
@@ -748,8 +768,8 @@ final class MediaReferenceRevalidationContext {
} }
} }
func wallpapers(postbox: Postbox, network: Network) -> Signal<[TelegramWallpaper], RevalidateMediaReferenceError> { func wallpapers(postbox: Postbox, network: Network, background: Bool) -> Signal<[TelegramWallpaper], RevalidateMediaReferenceError> {
return self.genericItem(key: .wallpapers, request: { next, error in return self.genericItem(key: .wallpapers, background: background, request: { next, error in
return (telegramWallpapers(postbox: postbox, network: network) return (telegramWallpapers(postbox: postbox, network: network)
|> last |> last
|> mapError { _ -> RevalidateMediaReferenceError in |> mapError { _ -> RevalidateMediaReferenceError in
@@ -778,7 +798,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
case let .media(media, _): case let .media(media, _):
switch media { switch media {
case let .message(message, _): case let .message(message, _):
return revalidationContext.message(postbox: postbox, network: network, message: message) return revalidationContext.message(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, message: message)
|> mapToSignal { message -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { message -> Signal<Data, RevalidateMediaReferenceError> in
for media in message.media { for media in message.media {
if let fileReference = findMediaResourceReference(media: media, resource: resource) { if let fileReference = findMediaResourceReference(media: media, resource: resource) {
@@ -788,7 +808,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case let .stickerPack(stickerPack, media): case let .stickerPack(stickerPack, media):
return revalidationContext.stickerPack(postbox: postbox, network: network, stickerPack: stickerPack) return revalidationContext.stickerPack(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, stickerPack: stickerPack)
|> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in
for item in result.1 { for item in result.1 {
if let item = item as? StickerPackItem { if let item = item as? StickerPackItem {
@@ -802,7 +822,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case let .webPage(webPage, _): case let .webPage(webPage, _):
return revalidationContext.webPage(postbox: postbox, network: network, webPage: webPage) return revalidationContext.webPage(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, webPage: webPage)
|> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in
if let fileReference = findMediaResourceReference(media: result, resource: resource) { if let fileReference = findMediaResourceReference(media: result, resource: resource) {
return .single(fileReference) return .single(fileReference)
@@ -810,7 +830,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case let .savedGif(media): case let .savedGif(media):
return revalidationContext.savedGifs(postbox: postbox, network: network) return revalidationContext.savedGifs(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation)
|> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in
for file in result { for file in result {
if media.id != nil && file.id == media.id { if media.id != nil && file.id == media.id {
@@ -825,7 +845,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
if let file = media as? TelegramMediaFile { if let file = media as? TelegramMediaFile {
for attribute in file.attributes { for attribute in file.attributes {
if case let .Sticker(sticker) = attribute, let stickerPack = sticker.packReference { if case let .Sticker(sticker) = attribute, let stickerPack = sticker.packReference {
return revalidationContext.stickerPack(postbox: postbox, network: network, stickerPack: stickerPack) return revalidationContext.stickerPack(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, stickerPack: stickerPack)
|> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { result -> Signal<Data, RevalidateMediaReferenceError> in
for item in result.1 { for item in result.1 {
if let item = item as? StickerPackItem { if let item = item as? StickerPackItem {
@@ -844,7 +864,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case let .avatar(peer, _): case let .avatar(peer, _):
return revalidationContext.peer(postbox: postbox, network: network, peer: peer) return revalidationContext.peer(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, peer: peer)
|> mapToSignal { updatedPeer -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { updatedPeer -> Signal<Data, RevalidateMediaReferenceError> in
for representation in updatedPeer.profileImageRepresentations { for representation in updatedPeer.profileImageRepresentations {
if representation.resource.id.isEqual(to: resource.id), let representationResource = representation.resource as? CloudFileMediaResource, let fileReference = representationResource.fileReference { if representation.resource.id.isEqual(to: resource.id), let representationResource = representation.resource as? CloudFileMediaResource, let fileReference = representationResource.fileReference {
@@ -854,7 +874,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case let .messageAuthorAvatar(message, _): case let .messageAuthorAvatar(message, _):
return revalidationContext.message(postbox: postbox, network: network, message: message) return revalidationContext.message(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation, message: message)
|> mapToSignal { updatedMessage -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { updatedMessage -> Signal<Data, RevalidateMediaReferenceError> in
if let author = updatedMessage.author { if let author = updatedMessage.author {
for representation in author.profileImageRepresentations { for representation in author.profileImageRepresentations {
@@ -866,7 +886,7 @@ func revalidateMediaResourceReference(postbox: Postbox, network: Network, revali
return .fail(.generic) return .fail(.generic)
} }
case .wallpaper: case .wallpaper:
return revalidationContext.wallpapers(postbox: postbox, network: network) return revalidationContext.wallpapers(postbox: postbox, network: network, background: info.preferBackgroundReferenceRevalidation)
|> mapToSignal { wallpapers -> Signal<Data, RevalidateMediaReferenceError> in |> mapToSignal { wallpapers -> Signal<Data, RevalidateMediaReferenceError> in
for wallpaper in wallpapers { for wallpaper in wallpapers {
if case let .image(representations) = wallpaper { if case let .image(representations) = wallpaper {

2
TelegramCore/ManagedSynchronizeSavedGifsOperations.swift
View File

@@ -150,7 +150,7 @@ private func synchronizeSavedGifs(transaction: Transaction, postbox: Postbox, ne
case .generic: case .generic:
return .fail(.generic) return .fail(.generic)
case .invalidReference: case .invalidReference:
return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: fileReference.resourceReference(fileReference.media.resource)), resource: fileReference.media.resource) return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: fileReference.resourceReference(fileReference.media.resource), preferBackgroundReferenceRevalidation: false), resource: fileReference.media.resource)
|> mapError { _ -> SaveGifError in |> mapError { _ -> SaveGifError in
return .generic return .generic
} }

2
TelegramCore/ManagedSynchronizeSavedStickersOperations.swift
View File

@@ -150,7 +150,7 @@ private func synchronizeSavedStickers(transaction: Transaction, postbox: Postbox
case .generic: case .generic:
return .fail(.generic) return .fail(.generic)
case .invalidReference: case .invalidReference:
return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: fileReference.resourceReference(fileReference.media.resource)), resource: fileReference.media.resource) return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: fileReference.resourceReference(fileReference.media.resource), preferBackgroundReferenceRevalidation: false), resource: fileReference.media.resource)
|> mapError { _ -> SaveStickerError in |> mapError { _ -> SaveStickerError in
return .generic return .generic
} }

2
TelegramCore/PendingMessageUploadedContent.swift
View File

@@ -96,7 +96,7 @@ func mediaContentToUpload(network: Network, postbox: Postbox, auxiliaryMethods:
} else { } else {
mediaReference = .savedGif(media: file) mediaReference = .savedGif(media: file)
} }
return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: mediaReference.resourceReference(file.resource)), resource: resource) return revalidateMediaResourceReference(postbox: postbox, network: network, revalidationContext: revalidationContext, info: TelegramCloudMediaResourceFetchInfo(reference: mediaReference.resourceReference(file.resource), preferBackgroundReferenceRevalidation: false), resource: resource)
|> mapError { _ -> PendingMessageUploadError in |> mapError { _ -> PendingMessageUploadError in
return .generic return .generic
} }

6
TelegramCore/SearchMessages.swift
View File

@@ -272,19 +272,19 @@ public func downloadMessage(postbox: Postbox, network: Network, messageId: Messa
} }
} }
func fetchRemoteMessage(postbox: Postbox, network: Network, message: MessageReference) -> Signal<Message?, NoError> { func fetchRemoteMessage(postbox: Postbox, source: FetchMessageHistoryHoleSource, message: MessageReference) -> Signal<Message?, NoError> {
guard case let .message(peer, id) = message.content else { guard case let .message(peer, id) = message.content else {
return .single(nil) return .single(nil)
} }
let signal: Signal<Api.messages.Messages, MTRpcError> let signal: Signal<Api.messages.Messages, MTRpcError>
if id.peerId.namespace == Namespaces.Peer.CloudChannel { if id.peerId.namespace == Namespaces.Peer.CloudChannel {
if let channel = peer.inputChannel { if let channel = peer.inputChannel {
signal = network.request(Api.functions.channels.getMessages(channel: channel, id: [Api.InputMessage.inputMessageID(id: id.id)])) signal = source.request(Api.functions.channels.getMessages(channel: channel, id: [Api.InputMessage.inputMessageID(id: id.id)]))
} else { } else {
signal = .fail(MTRpcError(errorCode: 400, errorDescription: "Peer Not Found")) signal = .fail(MTRpcError(errorCode: 400, errorDescription: "Peer Not Found"))
} }
} else if id.peerId.namespace == Namespaces.Peer.CloudUser || id.peerId.namespace == Namespaces.Peer.CloudGroup { } else if id.peerId.namespace == Namespaces.Peer.CloudUser || id.peerId.namespace == Namespaces.Peer.CloudGroup {
signal = network.request(Api.functions.messages.getMessages(id: [Api.InputMessage.inputMessageID(id: id.id)])) signal = source.request(Api.functions.messages.getMessages(id: [Api.InputMessage.inputMessageID(id: id.id)]))
} else { } else {
signal = .fail(MTRpcError(errorCode: 400, errorDescription: "Invalid Peer")) signal = .fail(MTRpcError(errorCode: 400, errorDescription: "Invalid Peer"))
} }