Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7dea71898d | ||
|
|
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 {
|
||||||
|
|||||||
@@ -253,12 +253,27 @@ public class WireGuardAdapter {
|
|||||||
self.packetTunnelProvider?.reasserting = false
|
self.packetTunnelProvider?.reasserting = false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
let settingsGenerator: PacketTunnelSettingsGenerator
|
||||||
do {
|
do {
|
||||||
let settingsGenerator = try self.makeSettingsGenerator(with: tunnelConfiguration)
|
settingsGenerator = try self.makeSettingsGenerator(with: tunnelConfiguration)
|
||||||
try self.setNetworkSettings(settingsGenerator.generateNetworkSettings())
|
} catch let error as WireGuardAdapterError {
|
||||||
|
completionHandler(error)
|
||||||
|
return
|
||||||
|
} catch {
|
||||||
|
fatalError()
|
||||||
|
}
|
||||||
|
|
||||||
switch self.state {
|
switch self.state {
|
||||||
case .started(let handle, _):
|
case .started(let handle, _):
|
||||||
|
do {
|
||||||
|
try self.setNetworkSettings(settingsGenerator.generateNetworkSettings())
|
||||||
|
} catch let error as WireGuardAdapterError {
|
||||||
|
completionHandler(error)
|
||||||
|
return
|
||||||
|
} catch {
|
||||||
|
fatalError()
|
||||||
|
}
|
||||||
|
|
||||||
let (wgConfig, resolutionResults) = settingsGenerator.uapiConfiguration()
|
let (wgConfig, resolutionResults) = settingsGenerator.uapiConfiguration()
|
||||||
self.logEndpointResolutionResults(resolutionResults)
|
self.logEndpointResolutionResults(resolutionResults)
|
||||||
|
|
||||||
@@ -270,6 +285,19 @@ public class WireGuardAdapter {
|
|||||||
self.state = .started(handle, settingsGenerator)
|
self.state = .started(handle, settingsGenerator)
|
||||||
|
|
||||||
case .temporaryShutdown:
|
case .temporaryShutdown:
|
||||||
|
// On iOS 15.1 or newer, updating network settings may fail when in airplane mode.
|
||||||
|
// Network path monitor will retry updating settings later when connectivity is
|
||||||
|
// back online.
|
||||||
|
do {
|
||||||
|
try self.setNetworkSettings(settingsGenerator.generateNetworkSettings())
|
||||||
|
} catch let error as WireGuardAdapterError {
|
||||||
|
if case .setNetworkSettings(let systemError) = error {
|
||||||
|
self.logHandler(.verbose, "Failed to set network settings while offline. Will retry when connectivity is back online. Error: \(systemError.localizedDescription)")
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
fatalError()
|
||||||
|
}
|
||||||
|
|
||||||
self.state = .temporaryShutdown(settingsGenerator)
|
self.state = .temporaryShutdown(settingsGenerator)
|
||||||
|
|
||||||
case .stopped:
|
case .stopped:
|
||||||
@@ -277,11 +305,6 @@ public class WireGuardAdapter {
|
|||||||
}
|
}
|
||||||
|
|
||||||
completionHandler(nil)
|
completionHandler(nil)
|
||||||
} catch let error as WireGuardAdapterError {
|
|
||||||
completionHandler(error)
|
|
||||||
} catch {
|
|
||||||
fatalError()
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user