Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 977ec25e79 | |||
| 23618f994f | |||
| ba644415c7 |
@@ -42,7 +42,7 @@ extension ActivateOnDemandOption {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
tunnelProviderManager.onDemandRules = rules
|
tunnelProviderManager.onDemandRules = rules
|
||||||
tunnelProviderManager.isOnDemandEnabled = false
|
tunnelProviderManager.isOnDemandEnabled = (rules != nil) && tunnelProviderManager.isOnDemandEnabled
|
||||||
}
|
}
|
||||||
|
|
||||||
init(from tunnelProviderManager: NETunnelProviderManager) {
|
init(from tunnelProviderManager: NETunnelProviderManager) {
|
||||||
|
|||||||
@@ -206,7 +206,10 @@ class TunnelsManager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func modify(tunnel: TunnelContainer, tunnelConfiguration: TunnelConfiguration, onDemandOption: ActivateOnDemandOption, completionHandler: @escaping (TunnelsManagerError?) -> Void) {
|
func modify(tunnel: TunnelContainer, tunnelConfiguration: TunnelConfiguration,
|
||||||
|
onDemandOption: ActivateOnDemandOption,
|
||||||
|
shouldEnsureOnDemandEnabled: Bool = false,
|
||||||
|
completionHandler: @escaping (TunnelsManagerError?) -> Void) {
|
||||||
let tunnelName = tunnelConfiguration.name ?? ""
|
let tunnelName = tunnelConfiguration.name ?? ""
|
||||||
if tunnelName.isEmpty {
|
if tunnelName.isEmpty {
|
||||||
completionHandler(TunnelsManagerError.tunnelNameEmpty)
|
completionHandler(TunnelsManagerError.tunnelNameEmpty)
|
||||||
@@ -214,6 +217,20 @@ class TunnelsManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
let tunnelProviderManager = tunnel.tunnelProvider
|
let tunnelProviderManager = tunnel.tunnelProvider
|
||||||
|
|
||||||
|
let isIntroducingOnDemandRules = (tunnelProviderManager.onDemandRules ?? []).isEmpty && onDemandOption != .off
|
||||||
|
if isIntroducingOnDemandRules && tunnel.status != .inactive && tunnel.status != .deactivating {
|
||||||
|
tunnel.onDeactivated = { [weak self] in
|
||||||
|
self?.modify(tunnel: tunnel, tunnelConfiguration: tunnelConfiguration,
|
||||||
|
onDemandOption: onDemandOption, shouldEnsureOnDemandEnabled: true,
|
||||||
|
completionHandler: completionHandler)
|
||||||
|
}
|
||||||
|
self.startDeactivation(of: tunnel)
|
||||||
|
return
|
||||||
|
} else {
|
||||||
|
tunnel.onDeactivated = nil
|
||||||
|
}
|
||||||
|
|
||||||
let oldName = tunnelProviderManager.localizedDescription ?? ""
|
let oldName = tunnelProviderManager.localizedDescription ?? ""
|
||||||
let isNameChanged = tunnelName != oldName
|
let isNameChanged = tunnelName != oldName
|
||||||
if isNameChanged {
|
if isNameChanged {
|
||||||
@@ -231,8 +248,11 @@ class TunnelsManager {
|
|||||||
}
|
}
|
||||||
tunnelProviderManager.isEnabled = true
|
tunnelProviderManager.isEnabled = true
|
||||||
|
|
||||||
let isActivatingOnDemand = !tunnelProviderManager.isOnDemandEnabled && onDemandOption != .off
|
let isActivatingOnDemand = !tunnelProviderManager.isOnDemandEnabled && shouldEnsureOnDemandEnabled
|
||||||
onDemandOption.apply(on: tunnelProviderManager)
|
onDemandOption.apply(on: tunnelProviderManager)
|
||||||
|
if shouldEnsureOnDemandEnabled {
|
||||||
|
tunnelProviderManager.isOnDemandEnabled = true
|
||||||
|
}
|
||||||
|
|
||||||
tunnelProviderManager.saveToPreferences { [weak self] error in
|
tunnelProviderManager.saveToPreferences { [weak self] error in
|
||||||
if let error = error {
|
if let error = error {
|
||||||
@@ -499,6 +519,11 @@ class TunnelsManager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if session.status == .disconnected {
|
||||||
|
tunnel.onDeactivated?()
|
||||||
|
tunnel.onDeactivated = nil
|
||||||
|
}
|
||||||
|
|
||||||
if tunnel.status == .restarting && session.status == .disconnected {
|
if tunnel.status == .restarting && session.status == .disconnected {
|
||||||
tunnel.startActivation(activationDelegate: self.activationDelegate)
|
tunnel.startActivation(activationDelegate: self.activationDelegate)
|
||||||
return
|
return
|
||||||
@@ -569,6 +594,7 @@ class TunnelContainer: NSObject {
|
|||||||
var activationAttemptId: String?
|
var activationAttemptId: String?
|
||||||
var activationTimer: Timer?
|
var activationTimer: Timer?
|
||||||
var deactivationTimer: Timer?
|
var deactivationTimer: Timer?
|
||||||
|
var onDeactivated: (() -> Void)?
|
||||||
|
|
||||||
fileprivate var tunnelProvider: NETunnelProviderManager {
|
fileprivate var tunnelProvider: NETunnelProviderManager {
|
||||||
didSet {
|
didSet {
|
||||||
|
|||||||
@@ -27,6 +27,29 @@ extension IPAddressRange: Hashable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
extension IPAddressRange: Codable {
|
||||||
|
public func encode(to encoder: Encoder) throws {
|
||||||
|
var container = encoder.singleValueContainer()
|
||||||
|
|
||||||
|
try container.encode(self.stringRepresentation)
|
||||||
|
}
|
||||||
|
|
||||||
|
public init(from decoder: Decoder) throws {
|
||||||
|
let container = try decoder.singleValueContainer()
|
||||||
|
let value = try container.decode(String.self)
|
||||||
|
|
||||||
|
if let ipAddressRange = IPAddressRange(from: value) {
|
||||||
|
self = ipAddressRange
|
||||||
|
} else {
|
||||||
|
let context = DecodingError.Context(
|
||||||
|
codingPath: container.codingPath,
|
||||||
|
debugDescription: "Invalid IPAddressRange representation"
|
||||||
|
)
|
||||||
|
throw DecodingError.dataCorrupted(context)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
extension IPAddressRange {
|
extension IPAddressRange {
|
||||||
public var stringRepresentation: String {
|
public var stringRepresentation: String {
|
||||||
return "\(address)/\(networkPrefixLength)"
|
return "\(address)/\(networkPrefixLength)"
|
||||||
|
|||||||
Reference in New Issue
Block a user