import Foundation import UIKit import Display import SwiftSignalKit import TelegramCore import AVFoundation import TelegramPresentationData import ItemListUI import PresentationDataUtils import AccountContext import TelegramStringFormatting import AppBundle import LegacyMediaPickerUI import AVFoundation import UndoUI private struct NotificationSoundSelectionArguments { let account: Account let selectSound: (PeerMessageSound) -> Void let complete: () -> Void let cancel: () -> Void let upload: () -> Void let deleteSound: (PeerMessageSound, String) -> Void } private enum NotificationSoundSelectionSection: Int32 { case cloud case modern case classic } private struct NotificationSoundSelectionState: Equatable { var selectedSound: PeerMessageSound var removedSounds: [PeerMessageSound] } private enum NotificationSoundSelectionEntry: ItemListNodeEntry { enum StableId: Hashable { case index(Int32) case sound(PeerMessageSound.Id) } case cloudHeader(String) case uploadSound(String) case cloudInfo(String) case modernHeader(PresentationTheme, String) case classicHeader(PresentationTheme, String) case none(section: NotificationSoundSelectionSection, theme: PresentationTheme, text: String, selected: Bool) case `default`(section: NotificationSoundSelectionSection, theme: PresentationTheme, text: String, selected: Bool) case sound(section: NotificationSoundSelectionSection, index: Int32, theme: PresentationTheme, text: String, sound: PeerMessageSound, selected: Bool, canBeDeleted: Bool) var section: ItemListSectionId { switch self { case .cloudHeader, .uploadSound, .cloudInfo: return NotificationSoundSelectionSection.cloud.rawValue case .modernHeader: return NotificationSoundSelectionSection.modern.rawValue case .classicHeader: return NotificationSoundSelectionSection.classic.rawValue case let .none(section, _, _, _): return section.rawValue case let .default(section, _, _, _): return section.rawValue case let .sound(section, _, _, _, _, _, _): return section.rawValue } } var sortId: Int32 { switch self { case .cloudHeader: return 0 case .uploadSound: return 998 case .cloudInfo: return 999 case .modernHeader: return 1000 case .classicHeader: return 2000 case let .none(section, _, _, _): switch section { case .cloud: return 1 case .modern: return 1001 case .classic: return 2001 } case let .default(section, _, _, _): switch section { case .cloud: return 2 case .modern: return 1002 case .classic: return 2002 } case let .sound(section, index, _, _, _, _, _): switch section { case .cloud: return 3 + index case .modern: return 1003 + index case .classic: return 2003 + index } } } var stableId: StableId { switch self { case let .sound(_ , _, _, _, sound, _, _): return .sound(sound.id) default: return .index(self.sortId) } } static func ==(lhs: NotificationSoundSelectionEntry, rhs: NotificationSoundSelectionEntry) -> Bool { switch lhs { case let .cloudHeader(text): if case .cloudHeader(text) = rhs { return true } else { return false } case let .cloudInfo(text): if case .cloudInfo(text) = rhs { return true } else { return false } case let .uploadSound(text): if case .uploadSound(text) = rhs { return true } else { return false } case let .modernHeader(lhsTheme, lhsText): if case let .modernHeader(rhsTheme, rhsText) = rhs, lhsTheme === rhsTheme, lhsText == rhsText { return true } else { return false } case let .classicHeader(lhsTheme, lhsText): if case let .classicHeader(rhsTheme, rhsText) = rhs, lhsTheme === rhsTheme, lhsText == rhsText { return true } else { return false } case let .none(lhsSection, lhsTheme, lhsText, lhsSelected): if case let .none(rhsSection, rhsTheme, rhsText, rhsSelected) = rhs, lhsSection == rhsSection, lhsTheme === rhsTheme, lhsText == rhsText, lhsSelected == rhsSelected { return true } else { return false } case let .default(lhsSection, lhsTheme, lhsText, lhsSelected): if case let .default(rhsSection, rhsTheme, rhsText, rhsSelected) = rhs, lhsSection == rhsSection, lhsTheme === rhsTheme, lhsText == rhsText, lhsSelected == rhsSelected { return true } else { return false } case let .sound(lhsSection, lhsIndex, lhsTheme, lhsText, lhsSound, lhsSelected, lhsCanBeDeleted): if case let .sound(rhsSection, rhsIndex, rhsTheme, rhsText, rhsSound, rhsSelected, rhsCanBeDeleted) = rhs, lhsSection == rhsSection, lhsIndex == rhsIndex, lhsTheme === rhsTheme, lhsText == rhsText, lhsSound == rhsSound, lhsSelected == rhsSelected, lhsCanBeDeleted == rhsCanBeDeleted { return true } else { return false } } } static func <(lhs: NotificationSoundSelectionEntry, rhs: NotificationSoundSelectionEntry) -> Bool { return lhs.sortId < rhs.sortId } func item(presentationData: ItemListPresentationData, arguments: Any) -> ListViewItem { let arguments = arguments as! NotificationSoundSelectionArguments switch self { case let .cloudHeader(text): return ItemListSectionHeaderItem(presentationData: presentationData, text: text, sectionId: self.section) case let .uploadSound(text): let icon = PresentationResourcesItemList.uploadToneIcon(presentationData.theme) return ItemListCheckboxItem(presentationData: presentationData, icon: icon, iconSize: nil, iconPlacement: .check, title: text, style: .left, textColor: .accent, checked: false, zeroSeparatorInsets: false, sectionId: self.section, action: { arguments.upload() }) case let .cloudInfo(text): return ItemListTextItem(presentationData: presentationData, text: .plain(text), sectionId: self.section) case let .modernHeader(_, text): return ItemListSectionHeaderItem(presentationData: presentationData, text: text, sectionId: self.section) case let .classicHeader(_, text): return ItemListSectionHeaderItem(presentationData: presentationData, text: text, sectionId: self.section) case let .none(_, _, text, selected): return ItemListCheckboxItem(presentationData: presentationData, title: text, style: .left, checked: selected, zeroSeparatorInsets: true, sectionId: self.section, action: { arguments.selectSound(.none) }) case let .default(_, _, text, selected): return ItemListCheckboxItem(presentationData: presentationData, title: text, style: .left, checked: selected, zeroSeparatorInsets: false, sectionId: self.section, action: { arguments.selectSound(.default) }) case let .sound(_, _, _, text, sound, selected, canBeDeleted): return ItemListCheckboxItem(presentationData: presentationData, title: text, style: .left, checked: selected, zeroSeparatorInsets: false, sectionId: self.section, action: { arguments.selectSound(sound) }, deleteAction: canBeDeleted ? { arguments.deleteSound(sound, text) } : nil) } } } private func notificationsAndSoundsEntries(presentationData: PresentationData, defaultSound: PeerMessageSound?, state: NotificationSoundSelectionState, notificationSoundList: NotificationSoundList?) -> [NotificationSoundSelectionEntry] { let selectedSound = resolvedNotificationSound(sound: state.selectedSound, notificationSoundList: notificationSoundList) var entries: [NotificationSoundSelectionEntry] = [] entries.append(.cloudHeader(presentationData.strings.Notifications_TelegramTones)) if let notificationSoundList = notificationSoundList { let cloudSounds = notificationSoundList.sounds.filter({ CloudSoundBuiltinCategory(id: $0.file.fileId.id) == nil }) let modernSounds = notificationSoundList.sounds.filter({ CloudSoundBuiltinCategory(id: $0.file.fileId.id) == .modern }) let classicSounds = notificationSoundList.sounds.filter({ CloudSoundBuiltinCategory(id: $0.file.fileId.id) == .classic }) for listSound in cloudSounds { let sound: PeerMessageSound = .cloud(fileId: listSound.file.fileId.id) if state.removedSounds.contains(where: { $0.id == sound.id }) { continue } entries.append(.sound(section: .cloud, index: Int32(entries.count), theme: presentationData.theme, text: localizedPeerNotificationSoundString(strings: presentationData.strings, notificationSoundList: notificationSoundList, sound: sound), sound: sound, selected: selectedSound.id == sound.id, canBeDeleted: true)) } entries.append(.uploadSound(presentationData.strings.Notifications_UploadSound)) entries.append(.cloudInfo(presentationData.strings.Notifications_MessageSoundInfo)) entries.append(.modernHeader(presentationData.theme, presentationData.strings.Notifications_AlertTones)) if let defaultSound = defaultSound { entries.append(.default(section: .modern, theme: presentationData.theme, text: localizedPeerNotificationSoundString(strings: presentationData.strings, notificationSoundList: notificationSoundList, sound: .default, default: defaultSound), selected: selectedSound.id == .default)) } entries.append(.none(section: .modern, theme: presentationData.theme, text: localizedPeerNotificationSoundString(strings: presentationData.strings, notificationSoundList: notificationSoundList, sound: .none), selected: selectedSound.id == .none)) for i in 0 ..< modernSounds.count { let sound: PeerMessageSound = .cloud(fileId: modernSounds[i].file.fileId.id) entries.append(.sound(section: .modern, index: Int32(100 + i), theme: presentationData.theme, text: localizedPeerNotificationSoundString(strings: presentationData.strings, notificationSoundList: notificationSoundList, sound: sound), sound: sound, selected: sound.id == selectedSound.id, canBeDeleted: false)) } entries.append(.classicHeader(presentationData.theme, presentationData.strings.Notifications_ClassicTones)) for i in 0 ..< classicSounds.count { let sound: PeerMessageSound = .cloud(fileId: classicSounds[i].file.fileId.id) entries.append(.sound(section: .classic, index: Int32(200 + i), theme: presentationData.theme, text: localizedPeerNotificationSoundString(strings: presentationData.strings, notificationSoundList: notificationSoundList, sound: sound), sound: sound, selected: sound.id == selectedSound.id, canBeDeleted: false)) } } return entries } private final class AudioPlayerWrapper: NSObject, AVAudioPlayerDelegate { private let completed: () -> Void private var player: AVAudioPlayer? init(url: URL, completed: @escaping () -> Void) { self.completed = completed super.init() self.player = try? AVAudioPlayer(contentsOf: url, fileTypeHint: "mp3") self.player?.delegate = self } func play() { self.player?.play() } func stop() { self.player?.stop() self.player = nil } func audioPlayerDidFinishPlaying(_ player: AVAudioPlayer, successfully flag: Bool) { self.completed() } } public func fileNameForNotificationSound(account: Account, notificationSoundList: NotificationSoundList?, sound: PeerMessageSound, defaultSound: PeerMessageSound?) -> String { switch sound { case .none: return "" case .default: if let defaultSound = defaultSound { if case .default = defaultSound { return "\(100)" } else { return fileNameForNotificationSound(account: account, notificationSoundList: notificationSoundList, sound: defaultSound, defaultSound: nil) } } else { return "\(100)" } case let .bundledModern(id): return "\(id + 100)" case let .bundledClassic(id): return "\(id + 2)" case let .cloud(fileId): guard let notificationSoundList = notificationSoundList else { return "" } for sound in notificationSoundList.sounds { if sound.file.fileId.id == fileId { if let path = account.postbox.mediaBox.completedResourcePath(sound.file.resource, pathExtension: nil) { return path } } } return "" } } public func playSound(context: AccountContext, notificationSoundList: NotificationSoundList?, sound: PeerMessageSound, defaultSound: PeerMessageSound?) -> Signal { if case .none = sound { return .complete() } else { return Signal { subscriber in var currentPlayer: AudioPlayerWrapper? var deactivateImpl: (() -> Void)? let session = context.sharedContext.mediaManager.audioSession.push(audioSessionType: .play(mixWithOthers: true), activate: { _ in Queue.mainQueue().async { let filePath = fileNameForNotificationSound(account: context.account, notificationSoundList: notificationSoundList, sound: sound, defaultSound: defaultSound) if filePath.contains("/") { currentPlayer = AudioPlayerWrapper(url: URL(fileURLWithPath: filePath), completed: { deactivateImpl?() }) currentPlayer?.play() } else if !filePath.isEmpty { if let url = getAppBundle().url(forResource: filePath, withExtension: "m4a") { currentPlayer = AudioPlayerWrapper(url: url, completed: { deactivateImpl?() }) currentPlayer?.play() } } } }, deactivate: { _ in return Signal { subscriber in Queue.mainQueue().async { currentPlayer?.stop() currentPlayer = nil subscriber.putCompletion() } return EmptyDisposable } }) deactivateImpl = { session.dispose() } return ActionDisposable { session.dispose() Queue.mainQueue().async { currentPlayer?.stop() currentPlayer = nil } } } |> runOn(Queue.mainQueue()) } } public func notificationSoundSelectionController(context: AccountContext, updatedPresentationData: (initial: PresentationData, signal: Signal)? = nil, isModal: Bool, currentSound: PeerMessageSound, defaultSound: PeerMessageSound?, completion: @escaping (PeerMessageSound) -> Void) -> ViewController { let statePromise = ValuePromise(NotificationSoundSelectionState(selectedSound: currentSound, removedSounds: []), ignoreRepeated: true) let stateValue = Atomic(value: NotificationSoundSelectionState(selectedSound: currentSound, removedSounds: [])) let updateState: ((NotificationSoundSelectionState) -> NotificationSoundSelectionState) -> Void = { f in statePromise.set(stateValue.modify { f($0) }) } var completeImpl: (() -> Void)? var cancelImpl: (() -> Void)? var presentFilePicker: (() -> Void)? var deleteSoundImpl: ((PeerMessageSound, String) -> Void)? let playSoundDisposable = MetaDisposable() let soundActionDisposable = MetaDisposable() let fetchedSoundsDisposable = ensureDownloadedNotificationSoundList(postbox: context.account.postbox).start() let arguments = NotificationSoundSelectionArguments(account: context.account, selectSound: { sound in updateState { state in var state = state state.selectedSound = sound return state } let _ = (context.engine.peers.notificationSoundList() |> take(1) |> deliverOnMainQueue).start(next: { notificationSoundList in playSoundDisposable.set(playSound(context: context, notificationSoundList: notificationSoundList, sound: sound, defaultSound: defaultSound).start()) }) }, complete: { completeImpl?() }, cancel: { cancelImpl?() }, upload: { presentFilePicker?() }, deleteSound: { sound, title in deleteSoundImpl?(sound, title) }) let presentationData = updatedPresentationData?.signal ?? context.sharedContext.presentationData let signal = combineLatest(presentationData, statePromise.get(), context.engine.peers.notificationSoundList()) |> map { presentationData, state, notificationSoundList -> (ItemListControllerState, (ItemListNodeState, Any)) in let leftNavigationButton = ItemListNavigationButton(content: .text(presentationData.strings.Common_Cancel), style: .regular, enabled: true, action: { arguments.cancel() }) let rightNavigationButton = ItemListNavigationButton(content: .text(presentationData.strings.Common_Done), style: .bold, enabled: true, action: { arguments.complete() }) let controllerState = ItemListControllerState(presentationData: ItemListPresentationData(presentationData), title: .text(presentationData.strings.Notifications_TextTone), leftNavigationButton: leftNavigationButton, rightNavigationButton: rightNavigationButton, backNavigationButton: ItemListBackButton(title: presentationData.strings.Common_Back)) let listState = ItemListNodeState(presentationData: ItemListPresentationData(presentationData), entries: notificationsAndSoundsEntries(presentationData: presentationData, defaultSound: defaultSound, state: state, notificationSoundList: notificationSoundList), style: .blocks) return (controllerState, (listState, arguments)) } let controller = ItemListController(context: context, state: signal |> afterDisposed { playSoundDisposable.dispose() soundActionDisposable.dispose() fetchedSoundsDisposable.dispose() }) controller.enableInteractiveDismiss = true if isModal { controller.navigationPresentation = .modal } completeImpl = { [weak controller] in let sound = stateValue.with { state in return state.selectedSound } completion(sound) controller?.dismiss() } cancelImpl = { [weak controller] in controller?.dismiss() } presentFilePicker = { [weak controller] in guard let controller = controller else { return } presentCustomNotificationSoundFilePicker(context: context, controller: controller, disposable: soundActionDisposable) } deleteSoundImpl = { [weak controller] sound, title in guard let controller = controller else { return } let presentationData = context.sharedContext.currentPresentationData.with { $0 } controller.present(standardTextAlertController(theme: AlertControllerTheme(presentationData: presentationData), title: presentationData.strings.PeerInfo_DeleteToneTitle, text: presentationData.strings.PeerInfo_DeleteToneText(title).string, actions: [ TextAlertAction(type: .destructiveAction, title: presentationData.strings.Common_Delete, action: { updateState { state in var state = state state.removedSounds.append(sound) if state.selectedSound.id == sound.id { state.selectedSound = defaultCloudPeerNotificationSound } return state } switch sound { case let .cloud(id): soundActionDisposable.set((context.engine.peers.deleteNotificationSound(fileId: id) |> deliverOnMainQueue).start(completed: { })) default: break } }), TextAlertAction(type: .defaultAction, title: presentationData.strings.Common_Cancel, action: { }) ], parseMarkdown: true), in: .window(.root)) } return controller } public func presentCustomNotificationSoundFilePicker(context: AccountContext, controller: ViewController, disposable: MetaDisposable) { let presentUndo: (UndoOverlayContent) -> Void = { [weak controller] content in guard let controller = controller else { return } let presentationData = context.sharedContext.currentPresentationData.with { $0 } controller.present(UndoOverlayController(presentationData: presentationData, content: content, elevatedLayout: false, animateInAsReplacement: true, action: { _ in return false }), in: .current) } let settings = NotificationSoundSettings.extract(from: context.currentAppConfiguration.with({ $0 })) let presentationData = context.sharedContext.currentPresentationData.with { $0 } controller.present(legacyICloudFilePicker(theme: presentationData.theme, documentTypes: ["public.mp3"], completion: { urls in guard !urls.isEmpty, let url = urls.first else { Logger.shared.log("NotificationSoundSelection", "url is nil") return } if !url.startAccessingSecurityScopedResource() { Logger.shared.log("NotificationSoundSelection", "startAccessingSecurityScopedResource failed") return } let coordinator = NSFileCoordinator(filePresenter: nil) var error: NSError? coordinator.coordinate(readingItemAt: url, options: .forUploading, error: &error, byAccessor: { souceUrl in let fileName = url.lastPathComponent var maybeUrl: URL? let tempFile = EngineTempBox.shared.tempFile(fileName: "file.mp3") do { try FileManager.default.copyItem(at: url, to: URL(fileURLWithPath: tempFile.path)) maybeUrl = URL(fileURLWithPath: tempFile.path) } catch let e { Logger.shared.log("NotificationSoundSelection", "copy file error \(e)") EngineTempBox.shared.dispose(tempFile) souceUrl.stopAccessingSecurityScopedResource() return } guard let url = maybeUrl else { Logger.shared.log("NotificationSoundSelection", "temp url is nil") EngineTempBox.shared.dispose(tempFile) souceUrl.stopAccessingSecurityScopedResource() return } Queue.mainQueue().async { do { let asset = AVAsset(url: url) let data = try Data(contentsOf: url) if data.count > settings.maxSize { presentUndo(.info(title: presentationData.strings.Notifications_UploadError_TooLarge_Title, text: presentationData.strings.Notifications_UploadError_TooLarge_Text(dataSizeString(Int64(settings.maxSize), formatting: DataSizeStringFormatting(presentationData: presentationData))).string, timeout: nil, customUndoText: nil)) souceUrl.stopAccessingSecurityScopedResource() EngineTempBox.shared.dispose(tempFile) return } func loadValues(asset: AVAsset, retryCount: Int, completion: @escaping () -> Void) { asset.loadValuesAsynchronously(forKeys: ["tracks", "duration"], completionHandler: { if asset.statusOfValue(forKey: "tracks", error: nil) == .loading { if retryCount < 2 { Queue.mainQueue().after(0.1, { loadValues(asset: asset, retryCount: retryCount + 1, completion: completion) }) } else { completion() } } else { completion() } }) } loadValues(asset: asset, retryCount: 0, completion: { var duration = 0.0 guard let track = asset.tracks(withMediaType: .audio).first else { Logger.shared.log("NotificationSoundSelection", "track is nil") url.stopAccessingSecurityScopedResource() EngineTempBox.shared.dispose(tempFile) return } duration = track.timeRange.duration.seconds if duration.isZero { Logger.shared.log("NotificationSoundSelection", "duration is zero") souceUrl.stopAccessingSecurityScopedResource() EngineTempBox.shared.dispose(tempFile) return } EngineTempBox.shared.dispose(tempFile) Queue.mainQueue().async { if duration > Double(settings.maxDuration) { souceUrl.stopAccessingSecurityScopedResource() presentUndo(.info(title: presentationData.strings.Notifications_UploadError_TooLong_Title(fileName).string, text: presentationData.strings.Notifications_UploadError_TooLong_Text(stringForDuration(Int32(settings.maxDuration))).string, timeout: nil, customUndoText: nil)) } else { Logger.shared.log("NotificationSoundSelection", "Uploading sound") disposable.set((context.engine.peers.uploadNotificationSound(title: fileName, data: data) |> deliverOnMainQueue).start(next: { _ in Logger.shared.log("NotificationSoundSelection", "Upload done") presentUndo(.notificationSoundAdded(title: presentationData.strings.Notifications_UploadSuccess_Title, text: presentationData.strings.Notifications_UploadSuccess_Text(fileName).string, action: nil)) }, error: { _ in Logger.shared.log("NotificationSoundSelection", "Upload error") souceUrl.stopAccessingSecurityScopedResource() }, completed: { souceUrl.stopAccessingSecurityScopedResource() })) } } }) } catch let e { Logger.shared.log("NotificationSoundSelection", "Error: \(e)") } } }) if let error = error { url.stopAccessingSecurityScopedResource() Logger.shared.log("NotificationSoundSelection", "Error: \(error)") } }), in: .window(.root)) }