Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 296ec5b63e | |||
| 94fa120c73 | |||
| 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 {
|
||||||
|
|||||||
@@ -7,8 +7,32 @@ import Foundation
|
|||||||
import WireGuardKitC
|
import WireGuardKitC
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/// The class describing a private key used by WireGuard.
|
/// Umbrella protocol for all kinds of keys.
|
||||||
public class PrivateKey: BaseKey {
|
public protocol WireGuardKey: RawRepresentable, Hashable, Codable where RawValue == Data {}
|
||||||
|
|
||||||
|
/// Class describing a private key used by WireGuard.
|
||||||
|
public final class PrivateKey: WireGuardKey {
|
||||||
|
public let rawValue: Data
|
||||||
|
|
||||||
|
/// Initialize the key with existing raw representation
|
||||||
|
public init?(rawValue: Data) {
|
||||||
|
if rawValue.count == WG_KEY_LEN {
|
||||||
|
self.rawValue = rawValue
|
||||||
|
} else {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Initialize new private key
|
||||||
|
convenience public init() {
|
||||||
|
var privateKeyData = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
||||||
|
privateKeyData.withUnsafeMutableBytes { (rawBufferPointer: UnsafeMutableRawBufferPointer) in
|
||||||
|
let privateKeyBytes = rawBufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self)
|
||||||
|
curve25519_generate_private_key(privateKeyBytes)
|
||||||
|
}
|
||||||
|
self.init(rawValue: privateKeyData)!
|
||||||
|
}
|
||||||
|
|
||||||
/// Derived public key
|
/// Derived public key
|
||||||
public var publicKey: PublicKey {
|
public var publicKey: PublicKey {
|
||||||
return rawValue.withUnsafeBytes { (privateKeyBufferPointer: UnsafeRawBufferPointer) -> PublicKey in
|
return rawValue.withUnsafeBytes { (privateKeyBufferPointer: UnsafeRawBufferPointer) -> PublicKey in
|
||||||
@@ -23,29 +47,38 @@ public class PrivateKey: BaseKey {
|
|||||||
return PublicKey(rawValue: publicKeyData)!
|
return PublicKey(rawValue: publicKeyData)!
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Initialize new private key
|
/// Class describing a public key used by WireGuard.
|
||||||
convenience public init() {
|
public final class PublicKey: WireGuardKey {
|
||||||
var privateKeyData = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
public let rawValue: Data
|
||||||
privateKeyData.withUnsafeMutableBytes { (rawBufferPointer: UnsafeMutableRawBufferPointer) in
|
|
||||||
let privateKeyBytes = rawBufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self)
|
/// Initialize the key with existing raw representation
|
||||||
curve25519_generate_private_key(privateKeyBytes)
|
public init?(rawValue: Data) {
|
||||||
|
if rawValue.count == WG_KEY_LEN {
|
||||||
|
self.rawValue = rawValue
|
||||||
|
} else {
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
self.init(rawValue: privateKeyData)!
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// The class describing a public key used by WireGuard.
|
/// Class describing a pre-shared key used by WireGuard.
|
||||||
public class PublicKey: BaseKey {}
|
public final class PreSharedKey: WireGuardKey {
|
||||||
|
|
||||||
/// The class describing a pre-shared key used by WireGuard.
|
|
||||||
public class PreSharedKey: BaseKey {}
|
|
||||||
|
|
||||||
/// The base key implementation. Should not be used directly.
|
|
||||||
public class BaseKey: RawRepresentable, Equatable, Hashable {
|
|
||||||
/// Raw key representation
|
|
||||||
public let rawValue: Data
|
public let rawValue: Data
|
||||||
|
|
||||||
|
/// Initialize the key with existing raw representation
|
||||||
|
public init?(rawValue: Data) {
|
||||||
|
if rawValue.count == WG_KEY_LEN {
|
||||||
|
self.rawValue = rawValue
|
||||||
|
} else {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Default implementation
|
||||||
|
extension WireGuardKey {
|
||||||
/// Hex encoded representation
|
/// Hex encoded representation
|
||||||
public var hexKey: String {
|
public var hexKey: String {
|
||||||
return rawValue.withUnsafeBytes { (rawBufferPointer: UnsafeRawBufferPointer) -> String in
|
return rawValue.withUnsafeBytes { (rawBufferPointer: UnsafeRawBufferPointer) -> String in
|
||||||
@@ -66,17 +99,8 @@ public class BaseKey: RawRepresentable, Equatable, Hashable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Initialize the key with existing raw representation
|
|
||||||
required public init?(rawValue: Data) {
|
|
||||||
if rawValue.count == WG_KEY_LEN {
|
|
||||||
self.rawValue = rawValue
|
|
||||||
} else {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Initialize the key with hex representation
|
/// Initialize the key with hex representation
|
||||||
public convenience init?(hexKey: String) {
|
public init?(hexKey: String) {
|
||||||
var bytes = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
var bytes = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
||||||
let success = bytes.withUnsafeMutableBytes { (bufferPointer: UnsafeMutableRawBufferPointer) -> Bool in
|
let success = bytes.withUnsafeMutableBytes { (bufferPointer: UnsafeMutableRawBufferPointer) -> Bool in
|
||||||
return key_from_hex(bufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self), hexKey)
|
return key_from_hex(bufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self), hexKey)
|
||||||
@@ -89,7 +113,7 @@ public class BaseKey: RawRepresentable, Equatable, Hashable {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/// Initialize the key with base64 representation
|
/// Initialize the key with base64 representation
|
||||||
public convenience init?(base64Key: String) {
|
public init?(base64Key: String) {
|
||||||
var bytes = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
var bytes = Data(repeating: 0, count: Int(WG_KEY_LEN))
|
||||||
let success = bytes.withUnsafeMutableBytes { (bufferPointer: UnsafeMutableRawBufferPointer) -> Bool in
|
let success = bytes.withUnsafeMutableBytes { (bufferPointer: UnsafeMutableRawBufferPointer) -> Bool in
|
||||||
return key_from_base64(bufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self), base64Key)
|
return key_from_base64(bufferPointer.baseAddress!.assumingMemoryBound(to: UInt8.self), base64Key)
|
||||||
@@ -101,7 +125,31 @@ public class BaseKey: RawRepresentable, Equatable, Hashable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static func == (lhs: BaseKey, rhs: BaseKey) -> Bool {
|
// MARK: - Codable
|
||||||
|
|
||||||
|
public init(from decoder: Decoder) throws {
|
||||||
|
let container = try decoder.singleValueContainer()
|
||||||
|
let data = try container.decode(Data.self)
|
||||||
|
|
||||||
|
if let instance = Self.init(rawValue: data) {
|
||||||
|
self = instance
|
||||||
|
} else {
|
||||||
|
throw DecodingError.dataCorruptedError(
|
||||||
|
in: container,
|
||||||
|
debugDescription: "Corrupt key data."
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public func encode(to encoder: Encoder) throws {
|
||||||
|
var container = encoder.singleValueContainer()
|
||||||
|
|
||||||
|
try container.encode(rawValue)
|
||||||
|
}
|
||||||
|
|
||||||
|
// MARK: - Equatable
|
||||||
|
|
||||||
|
public static func == (lhs: Self, rhs: Self) -> Bool {
|
||||||
return lhs.rawValue.withUnsafeBytes { (lhsBytes: UnsafeRawBufferPointer) -> Bool in
|
return lhs.rawValue.withUnsafeBytes { (lhsBytes: UnsafeRawBufferPointer) -> Bool in
|
||||||
return rhs.rawValue.withUnsafeBytes { (rhsBytes: UnsafeRawBufferPointer) -> Bool in
|
return rhs.rawValue.withUnsafeBytes { (rhsBytes: UnsafeRawBufferPointer) -> Bool in
|
||||||
return key_eq(
|
return key_eq(
|
||||||
|
|||||||
Reference in New Issue
Block a user