import PromiseKit import WebRTC extension AppDelegate { @objc func setUpCallHandling() { // Offer messages MessageReceiver.handleOfferCallMessage = { message in DispatchQueue.main.async { let sdp = RTCSessionDescription(type: .offer, sdp: message.sdps![0]) guard let presentingVC = CurrentAppContext().frontmostViewController() else { preconditionFailure() } // TODO: Handle more gracefully let alert = UIAlertController(title: "Incoming Call", message: nil, preferredStyle: .alert) alert.addAction(UIAlertAction(title: "Accept", style: .default, handler: { _ in let callVC = CallVC(for: message.sender!, mode: .answer(sdp: sdp)) presentingVC.dismiss(animated: true) { callVC.modalPresentationStyle = .overFullScreen callVC.modalTransitionStyle = .crossDissolve presentingVC.present(callVC, animated: true, completion: nil) } })) alert.addAction(UIAlertAction(title: "Decline", style: .default, handler: { _ in // Do nothing })) presentingVC.present(alert, animated: true, completion: nil) } } // Answer messages MessageReceiver.handleAnswerCallMessage = { message in DispatchQueue.main.async { guard let callVC = CurrentAppContext().frontmostViewController() as? CallVC else { return } callVC.handleAnswerMessage(message) } } // End call messages MessageReceiver.handleEndCallMessage = { message in DispatchQueue.main.async { guard let callVC = CurrentAppContext().frontmostViewController() as? CallVC else { return } callVC.handleEndCallMessage(message) } } } @objc(syncConfigurationIfNeeded) func syncConfigurationIfNeeded() { guard Storage.shared.getUser()?.name != nil else { return } let userDefaults = UserDefaults.standard let lastSync = userDefaults[.lastConfigurationSync] ?? .distantPast guard Date().timeIntervalSince(lastSync) > 7 * 24 * 60 * 60, let configurationMessage = ConfigurationMessage.getCurrent() else { return } // Sync every 2 days let destination = Message.Destination.contact(publicKey: getUserHexEncodedPublicKey()) Storage.shared.write { transaction in let job = MessageSendJob(message: configurationMessage, destination: destination) JobQueue.shared.add(job, using: transaction) } userDefaults[.lastConfigurationSync] = Date() } func forceSyncConfigurationNowIfNeeded() -> Promise { guard Storage.shared.getUser()?.name != nil, let configurationMessage = ConfigurationMessage.getCurrent() else { return Promise.value(()) } let destination = Message.Destination.contact(publicKey: getUserHexEncodedPublicKey()) let (promise, seal) = Promise.pending() Storage.writeSync { transaction in MessageSender.send(configurationMessage, to: destination, using: transaction).done { seal.fulfill(()) }.catch { _ in seal.fulfill(()) // Fulfill even if this failed; the configuration in the swarm should be at most 2 days old }.retainUntilComplete() } return promise } @objc func startClosedGroupPoller() { guard OWSIdentityManager.shared().identityKeyPair() != nil else { return } ClosedGroupPoller.shared.start() } @objc func stopClosedGroupPoller() { ClosedGroupPoller.shared.stop() } @objc func getAppModeOrSystemDefault() -> AppMode { let userDefaults = UserDefaults.standard if userDefaults.dictionaryRepresentation().keys.contains("appMode") { let mode = userDefaults.integer(forKey: "appMode") return AppMode(rawValue: mode) ?? .light } else { if #available(iOS 13.0, *) { return UITraitCollection.current.userInterfaceStyle == .dark ? .dark : .light } else { return .light } } } }