import Foundation import AsyncDisplayKit import Postbox import SwiftSignalKit import Display import TelegramCore private struct FetchControls { let fetch: () -> Void let cancel: () -> Void } private let secretMediaIcon = generateTintedImage(image: UIImage(bundleImageName: "Chat/Message/SecretMediaIcon"), color: .white) final class ChatMessageInteractiveMediaNode: ASTransformNode { private let imageNode: TransformImageNode private var progressNode: RadialProgressNode? private var timeoutNode: RadialTimeoutNode? private var tapRecognizer: UITapGestureRecognizer? private var account: Account? private var messageIdAndFlags: (MessageId, MessageFlags)? private var media: Media? private var message: Message? private let statusDisposable = MetaDisposable() private let fetchControls = Atomic(value: nil) private var fetchStatus: MediaResourceStatus? private let fetchDisposable = MetaDisposable() var activateLocalContent: () -> Void = { } init() { self.imageNode = TransformImageNode() super.init(layerBacked: false) self.imageNode.displaysAsynchronously = false self.addSubnode(self.imageNode) } deinit { self.statusDisposable.dispose() self.fetchDisposable.dispose() } override func didLoad() { let tapRecognizer = UITapGestureRecognizer(target: self, action: #selector(self.imageTap(_:))) self.imageNode.view.addGestureRecognizer(tapRecognizer) self.tapRecognizer = tapRecognizer } @objc func progressPressed() { if let fetchStatus = self.fetchStatus { switch fetchStatus { case .Fetching: if let account = self.account, let (messageId, flags) = self.messageIdAndFlags, flags.isSending { account.postbox.modify({ modifier -> Void in modifier.deleteMessages([messageId]) }).start() } if let cancel = self.fetchControls.with({ return $0?.cancel }) { cancel() } case .Remote: if let fetch = self.fetchControls.with({ return $0?.fetch }) { fetch() } case .Local: break } } } @objc func imageTap(_ recognizer: UITapGestureRecognizer) { if case .ended = recognizer.state { /*if let file = self.media as? TelegramMediaFile, let message = self.message, (file.isVideo || file.isAnimated || file.mimeType.hasPrefix("video/")) && !message.containsSecretMedia { self.activateLocalContent() } else {*/ if let fetchStatus = self.fetchStatus, case .Local = fetchStatus { self.activateLocalContent() } else { self.progressPressed() } //} } } func asyncLayout() -> (_ account: Account, _ message: Message, _ media: Media, _ corners: ImageCorners, _ automaticDownload: Bool, _ constrainedSize: CGSize, _ layoutConstants: ChatMessageItemLayoutConstants) -> (CGFloat, (CGSize) -> (CGFloat, (CGFloat) -> (CGSize, () -> Void))) { let currentMessageIdAndFlags = self.messageIdAndFlags let currentMedia = self.media let imageLayout = self.imageNode.asyncLayout() return { account, message, media, corners, automaticDownload, constrainedSize, layoutConstants in var nativeSize: CGSize var isSecretMedia = message.containsSecretMedia var secretBeginTimeAndTimeout: (Double, Double)? if isSecretMedia { for attribute in message.attributes { if let attribute = attribute as? AutoremoveTimeoutMessageAttribute { if let countdownBeginTime = attribute.countdownBeginTime { secretBeginTimeAndTimeout = (Double(countdownBeginTime), Double(attribute.timeout)) } break } } } if let image = media as? TelegramMediaImage, let dimensions = largestImageRepresentation(image.representations)?.dimensions { nativeSize = CGSize(width: floor(dimensions.width * 0.5), height: floor(dimensions.height * 0.5)).fitted(constrainedSize) } else if let file = media as? TelegramMediaFile, let dimensions = file.dimensions { nativeSize = CGSize(width: floor(dimensions.width * 0.5), height: floor(dimensions.height * 0.5)).fitted(constrainedSize) if file.isAnimated { nativeSize = nativeSize.fitted(CGSize(width: 480.0, height: 480.0)) } } else { nativeSize = CGSize(width: 54.0, height: 54.0) } let maxWidth: CGFloat if isSecretMedia { maxWidth = 180.0 } else { maxWidth = layoutConstants.image.maxDimensions.width } var secretProgressIcon: UIImage? if isSecretMedia { secretProgressIcon = secretMediaIcon } return (maxWidth, { constrainedSize in return (min(maxWidth, nativeSize.width), { boundingWidth in let drawingSize: CGSize let boundingSize: CGSize if isSecretMedia { boundingSize = CGSize(width: maxWidth, height: maxWidth) drawingSize = nativeSize.aspectFilled(boundingSize) } else { drawingSize = nativeSize.fittedToWidthOrSmaller(boundingWidth) boundingSize = CGSize(width: max(boundingWidth, drawingSize.width), height: drawingSize.height).cropped(CGSize(width: CGFloat.greatestFiniteMagnitude, height: layoutConstants.image.maxDimensions.height)) } var updateImageSignal: Signal<(TransformImageArguments) -> DrawingContext?, NoError>? var updatedStatusSignal: Signal? var updatedFetchControls: FetchControls? var mediaUpdated = false if let currentMedia = currentMedia { mediaUpdated = !media.isEqual(currentMedia) } else { mediaUpdated = true } var statusUpdated = mediaUpdated if currentMessageIdAndFlags?.0 != message.id || currentMessageIdAndFlags?.1 != message.flags { statusUpdated = true } if mediaUpdated { if let image = media as? TelegramMediaImage { if isSecretMedia { updateImageSignal = chatSecretPhoto(account: account, photo: image) } else { updateImageSignal = chatMessagePhoto(account: account, photo: image) } updatedFetchControls = FetchControls(fetch: { [weak self] in if let strongSelf = self { strongSelf.fetchDisposable.set(chatMessagePhotoInteractiveFetched(account: account, photo: image).start()) } }, cancel: { chatMessagePhotoCancelInteractiveFetch(account: account, photo: image) }) } else if let file = media as? TelegramMediaFile { if isSecretMedia { updateImageSignal = chatSecretMessageVideo(account: account, video: file) } else { updateImageSignal = chatMessageVideo(account: account, video: file) } updatedFetchControls = FetchControls(fetch: { [weak self] in if let strongSelf = self { strongSelf.fetchDisposable.set(chatMessageFileInteractiveFetched(account: account, file: file).start()) } }, cancel: { chatMessageFileCancelInteractiveFetch(account: account, file: file) }) } } if statusUpdated { if let image = media as? TelegramMediaImage { if message.flags.isSending { updatedStatusSignal = combineLatest(chatMessagePhotoStatus(account: account, photo: image), account.pendingMessageManager.pendingMessageStatus(message.id)) |> map { resourceStatus, pendingStatus -> MediaResourceStatus in if let pendingStatus = pendingStatus { return .Fetching(progress: pendingStatus.progress) } else { return resourceStatus } } } else { updatedStatusSignal = chatMessagePhotoStatus(account: account, photo: image) } } else if let file = media as? TelegramMediaFile { updatedStatusSignal = combineLatest(chatMessageFileStatus(account: account, file: file), account.pendingMessageManager.pendingMessageStatus(message.id)) |> map { resourceStatus, pendingStatus -> MediaResourceStatus in if let pendingStatus = pendingStatus { return .Fetching(progress: pendingStatus.progress) } else { return resourceStatus } } } } let arguments = TransformImageArguments(corners: corners, imageSize: drawingSize, boundingSize: boundingSize, intrinsicInsets: UIEdgeInsets()) let imageFrame = CGRect(origin: CGPoint(x: -arguments.insets.left, y: -arguments.insets.top), size: arguments.drawingSize) let imageApply = imageLayout(arguments) return (boundingSize, { [weak self] in if let strongSelf = self { strongSelf.account = account strongSelf.messageIdAndFlags = (message.id, message.flags) strongSelf.media = media strongSelf.message = message strongSelf.imageNode.frame = imageFrame strongSelf.progressNode?.position = CGPoint(x: imageFrame.midX, y: imageFrame.midY) strongSelf.timeoutNode?.position = CGPoint(x: imageFrame.midX, y: imageFrame.midY) if let updateImageSignal = updateImageSignal { strongSelf.imageNode.setSignal(account: account, signal: updateImageSignal) } if let secretBeginTimeAndTimeout = secretBeginTimeAndTimeout { if strongSelf.timeoutNode == nil { let timeoutNode = RadialTimeoutNode(backgroundColor: UIColor(white: 0.0, alpha: 0.6), foregroundColor: UIColor(white: 1.0, alpha: 0.6)) timeoutNode.frame = CGRect(origin: CGPoint(), size: CGSize(width: 50.0, height: 50.0)) timeoutNode.position = strongSelf.imageNode.position strongSelf.timeoutNode = timeoutNode strongSelf.addSubnode(timeoutNode) timeoutNode.setTimeout(beginTimestamp: secretBeginTimeAndTimeout.0, timeout: secretBeginTimeAndTimeout.1) } if let progressNode = strongSelf.progressNode { progressNode.removeFromSupernode() strongSelf.progressNode = nil } } else if let timeoutNode = strongSelf.timeoutNode { timeoutNode.removeFromSupernode() strongSelf.timeoutNode = nil } if let updatedStatusSignal = updatedStatusSignal { strongSelf.statusDisposable.set((updatedStatusSignal |> deliverOnMainQueue).start(next: { [weak strongSelf] status in displayLinkDispatcher.dispatch { if let strongSelf = strongSelf { strongSelf.fetchStatus = status var progressRequired = false if secretBeginTimeAndTimeout == nil { if case .Local = status { if let file = media as? TelegramMediaFile, file.isVideo { progressRequired = true } else if isSecretMedia { progressRequired = true } } else { progressRequired = true } } if progressRequired { if strongSelf.progressNode == nil { let progressNode = RadialProgressNode() progressNode.frame = CGRect(origin: CGPoint(), size: CGSize(width: 50.0, height: 50.0)) progressNode.position = strongSelf.imageNode.position strongSelf.progressNode = progressNode strongSelf.addSubnode(progressNode) } } else { if let progressNode = strongSelf.progressNode { progressNode.removeFromSupernode() strongSelf.progressNode = nil } } switch status { case let .Fetching(progress): strongSelf.progressNode?.state = .Fetching(progress: progress) case .Local: var state: RadialProgressState = .None if isSecretMedia && secretProgressIcon != nil { state = .Image(secretProgressIcon!) } else if let file = media as? TelegramMediaFile { if file.isVideo { state = .Play } } strongSelf.progressNode?.state = state case .Remote: strongSelf.progressNode?.state = .Remote } } } })) } if let updatedFetchControls = updatedFetchControls { let _ = strongSelf.fetchControls.swap(updatedFetchControls) if automaticDownload { if let image = media as? TelegramMediaImage { strongSelf.fetchDisposable.set(chatMessagePhotoInteractiveFetched(account: account, photo: image).start()) } } } imageApply() } }) }) }) } } static func asyncLayout(_ node: ChatMessageInteractiveMediaNode?) -> (_ account: Account, _ message: Message, _ media: Media, _ corners: ImageCorners, _ automaticDownload: Bool, _ constrainedSize: CGSize, _ layoutConstants: ChatMessageItemLayoutConstants) -> (CGFloat, (CGSize) -> (CGFloat, (CGFloat) -> (CGSize, () -> ChatMessageInteractiveMediaNode))) { let currentAsyncLayout = node?.asyncLayout() return { account, message, media, corners, automaticDownload, constrainedSize, layoutConstants in var imageNode: ChatMessageInteractiveMediaNode var imageLayout: (_ account: Account, _ message: Message, _ media: Media, _ corners: ImageCorners, _ automaticDownload: Bool, _ constrainedSize: CGSize, _ layoutConstants: ChatMessageItemLayoutConstants) -> (CGFloat, (CGSize) -> (CGFloat, (CGFloat) -> (CGSize, () -> Void))) if let node = node, let currentAsyncLayout = currentAsyncLayout { imageNode = node imageLayout = currentAsyncLayout } else { imageNode = ChatMessageInteractiveMediaNode() imageLayout = imageNode.asyncLayout() } let (initialWidth, continueLayout) = imageLayout(account, message, media, corners, automaticDownload, constrainedSize, layoutConstants) return (initialWidth, { constrainedSize in let (finalWidth, finalLayout) = continueLayout(constrainedSize) return (finalWidth, { boundingWidth in let (finalSize, apply) = finalLayout(boundingWidth) return (finalSize, { apply() return imageNode }) }) }) } } }