// // AppContext.swift // Passepartout // // Created by Davide De Rosa on 3/17/22. // Copyright (c) 2023 Davide De Rosa. All rights reserved. // // https://github.com/passepartoutvpn // // This file is part of Passepartout. // // Passepartout is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // Passepartout is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with Passepartout. If not, see . // import Combine import Foundation import PassepartoutLibrary @MainActor final class AppContext { private let coreContext: CoreContext let upgradeManager: UpgradeManager let productManager: ProductManager let persistenceManager: PersistenceManager private let reviewer: Reviewer private var cancellables: Set = [] init(store: KeyValueStore) { let logger = SwiftyBeaverLogger( logFile: Constants.Log.App.url, logLevel: Constants.Log.level, logFormat: Constants.Log.App.format ) Passepartout.shared.logger = logger pp_log.info("Logging to: \(logger.logFile!)") upgradeManager = UpgradeManager( store: store, strategy: DefaultUpgradeManagerStrategy() ) upgradeManager.migrate(toVersion: Constants.Global.appVersionNumber) productManager = ProductManager( overriddenAppType: Constants.InApp.overriddenAppType, buildProducts: Constants.InApp.buildProducts ) persistenceManager = PersistenceManager( store: store, ckContainerId: Constants.CloudKit.containerId, ckCoreDataZone: Constants.CloudKit.coreDataZone ) reviewer = Reviewer() reviewer.eventCountBeforeRating = Constants.Rating.eventCount coreContext = CoreContext(persistenceManager: persistenceManager) // post configureObjects() } var providerManager: ProviderManager { coreContext.providerManager } var profileManager: ProfileManager { coreContext.profileManager } var vpnManager: VPNManager { coreContext.vpnManager } } private extension AppContext { func configureObjects() { coreContext.vpnManager.isOnDemandRulesSupported = { self.isEligibleForOnDemandRules() } coreContext.vpnManager.currentState.$vpnStatus .removeDuplicates() .receive(on: DispatchQueue.main) .sink { [weak self] in if $0 == .connected { pp_log.info("VPN successful connection, report to Reviewer") self?.reviewer.reportEvent() } }.store(in: &cancellables) productManager.didRefundProducts .receive(on: DispatchQueue.main) .sink { [weak self] in Task { pp_log.info("Refunds detected, uninstalling VPN profile") await self?.coreContext.vpnManager.uninstall() } }.store(in: &cancellables) } // eligibility: ignore network settings if ineligible func isEligibleForNetworkSettings() -> Bool { guard productManager.isEligible(forFeature: .networkSettings) else { pp_log.warning("Ignore network settings, not eligible") return false } return true } // eligibility: reset on-demand rules if no trusted networks func isEligibleForOnDemandRules() -> Bool { guard productManager.isEligible(forFeature: .trustedNetworks) else { pp_log.warning("Ignore on-demand rules, not eligible for trusted networks") return false } return true } }