passepartout-apple/Passepartout/App/Managers/PersistenceManager.swift

199 lines
6.1 KiB
Swift
Raw Normal View History

2018-10-11 07:13:19 +00:00
//
2022-04-12 13:09:14 +00:00
// PersistenceManager.swift
// Passepartout
2018-10-11 07:13:19 +00:00
//
2022-04-12 13:09:14 +00:00
// Created by Davide De Rosa on 4/6/22.
2024-01-14 13:34:21 +00:00
// Copyright (c) 2024 Davide De Rosa. All rights reserved.
2018-10-11 07:13:19 +00:00
//
2018-11-03 21:33:30 +00:00
// https://github.com/passepartoutvpn
2018-10-11 07:13:19 +00:00
//
// 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 <http://www.gnu.org/licenses/>.
//
import CloudKit
import Combine
2022-04-12 13:09:14 +00:00
import CoreData
import Foundation
2023-05-24 16:19:47 +00:00
import PassepartoutLibrary
2018-10-11 07:13:19 +00:00
@MainActor
final class PersistenceManager: ObservableObject {
let store: KeyValueStore
private let ckContainerId: String
2023-12-16 19:58:54 +00:00
private let ckSharedContainerId: String
private let ckCoreDataZone: String
private var vpnPersistence: VPNPersistence?
2023-12-16 19:58:54 +00:00
private var sharedVPNPersistence: VPNPersistence?
private var providersPersistence: ProvidersPersistence?
private(set) var isCloudSyncingEnabled: Bool {
didSet {
pp_log.info("CloudKit enabled: \(isCloudSyncingEnabled)")
didChangePersistence.send()
}
}
@Published private(set) var isErasingCloudKitStore = false
let didChangePersistence = PassthroughSubject<Void, Never>()
2023-03-17 20:55:47 +00:00
2023-12-16 19:58:54 +00:00
init(store: KeyValueStore,
ckContainerId: String,
ckSharedContainerId: String,
ckCoreDataZone: String) {
self.store = store
self.ckContainerId = ckContainerId
2023-12-16 19:58:54 +00:00
self.ckSharedContainerId = ckSharedContainerId
self.ckCoreDataZone = ckCoreDataZone
isCloudSyncingEnabled = store.canEnableCloudSyncing
2023-03-17 20:55:47 +00:00
// set once
if persistenceAuthor == nil {
persistenceAuthor = UUID().uuidString
}
2022-04-12 13:09:14 +00:00
}
func loadVPNPersistence(withName containerName: String) -> VPNPersistence {
2023-12-16 19:58:54 +00:00
let persistence = VPNPersistence(withName: containerName,
cloudKit: isCloudSyncingEnabled,
cloudKitIdentifier: nil,
author: persistenceAuthor)
vpnPersistence = persistence
return persistence
}
2023-03-17 20:55:47 +00:00
2023-12-16 19:58:54 +00:00
func loadSharedVPNPersistence(withName containerName: String) -> VPNPersistence {
let persistence = VPNPersistence(withName: containerName,
cloudKit: true,
cloudKitIdentifier: ckSharedContainerId,
author: persistenceAuthor)
sharedVPNPersistence = persistence
return persistence
}
func loadProvidersPersistence(withName containerName: String) -> ProvidersPersistence {
let persistence = ProvidersPersistence(withName: containerName, cloudKit: false, author: persistenceAuthor)
providersPersistence = persistence
return persistence
}
}
// MARK: CloudKit
extension PersistenceManager {
func eraseCloudKitStore() async {
isErasingCloudKitStore = true
await Self.eraseCloudKitStore(
fromContainerWithId: ckContainerId,
zoneId: .init(zoneName: ckCoreDataZone)
)
2023-12-16 19:58:54 +00:00
await Self.eraseCloudKitStore(
fromContainerWithId: ckSharedContainerId,
zoneId: .init(zoneName: ckCoreDataZone)
)
isErasingCloudKitStore = false
}
// WARNING: this is not running on main actor
private static func eraseCloudKitStore(fromContainerWithId containerId: String, zoneId: CKRecordZone.ID) async {
do {
let container = CKContainer(identifier: containerId)
let db = container.privateCloudDatabase
try await db.deleteRecordZone(withID: zoneId)
} catch {
pp_log.error("Unable to erase CloudKit store: \(error)")
}
}
}
// MARK: KeyValueStore
private extension KeyValueStore {
private var cloudKitToken: Any? {
FileManager.default.ubiquityIdentityToken
}
private var isCloudKitSupported: Bool {
2023-12-16 19:58:54 +00:00
#if !os(tvOS)
cloudKitToken != nil
2023-12-16 19:58:54 +00:00
#else
true
#endif
}
var canEnableCloudSyncing: Bool {
isCloudKitSupported && shouldEnableCloudSyncing
}
var shouldEnableCloudSyncing: Bool {
get {
value(forLocation: PersistenceManager.StoreKey.shouldEnableCloudSyncing) ?? false
}
set {
setValue(newValue, forLocation: PersistenceManager.StoreKey.shouldEnableCloudSyncing)
}
}
}
extension PersistenceManager {
2023-05-24 16:19:47 +00:00
private(set) var persistenceAuthor: String? {
get {
store.value(forLocation: StoreKey.persistenceAuthor)
}
set {
store.setValue(newValue, forLocation: StoreKey.persistenceAuthor)
}
}
var shouldEnableCloudSyncing: Bool {
get {
store.shouldEnableCloudSyncing
}
set {
objectWillChange.send()
store.shouldEnableCloudSyncing = newValue
// iCloud may be externally disabled from the device settings
let newIsCloudSyncingEnabled = store.canEnableCloudSyncing
guard newIsCloudSyncingEnabled != isCloudSyncingEnabled else {
pp_log.debug("CloudKit state did not change")
return
}
isCloudSyncingEnabled = newIsCloudSyncingEnabled
}
}
}
// TODO: iCloud, restore private after dropping migration from 2.2.0
// private extension PersistenceManager {
extension PersistenceManager {
2023-09-08 20:18:41 +00:00
enum StoreKey: String, KeyStoreDomainLocation {
case persistenceAuthor
case shouldEnableCloudSyncing
var domain: String {
"Passepartout.PersistenceManager"
}
}
2018-10-11 07:13:19 +00:00
}