mirror of
https://github.com/DefinedNet/mobile_nebula.git
synced 2025-02-23 11:35:26 +00:00
Annotate existentials with any
prefix keyword
<https://github.com/swiftlang/swift-evolution/blob/main/proposals/0335-existential-any.md>
This commit is contained in:
parent
fb843f1982
commit
29c3b7e569
6 changed files with 22 additions and 20 deletions
|
@ -219,7 +219,7 @@ class PacketTunnelProvider: NEPacketTunnelProvider {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
var error: Error?
|
var error: (any Error)?
|
||||||
var data: JSON?
|
var data: JSON?
|
||||||
|
|
||||||
// start command has special treatment due to needing to call two completers
|
// start command has special treatment due to needing to call two completers
|
||||||
|
@ -264,27 +264,27 @@ class PacketTunnelProvider: NEPacketTunnelProvider {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private func listHostmap(pending: Bool) -> (JSON?, Error?) {
|
private func listHostmap(pending: Bool) -> (JSON?, (any Error)?) {
|
||||||
var err: NSError?
|
var err: NSError?
|
||||||
let res = nebula!.listHostmap(pending, error: &err)
|
let res = nebula!.listHostmap(pending, error: &err)
|
||||||
return (JSON(res), err)
|
return (JSON(res), err)
|
||||||
}
|
}
|
||||||
|
|
||||||
private func getHostInfo(args: JSON) -> (JSON?, Error?) {
|
private func getHostInfo(args: JSON) -> (JSON?, (any Error)?) {
|
||||||
var err: NSError?
|
var err: NSError?
|
||||||
let res = nebula!.getHostInfo(
|
let res = nebula!.getHostInfo(
|
||||||
byVpnIp: args["vpnIp"].string, pending: args["pending"].boolValue, error: &err)
|
byVpnIp: args["vpnIp"].string, pending: args["pending"].boolValue, error: &err)
|
||||||
return (JSON(res), err)
|
return (JSON(res), err)
|
||||||
}
|
}
|
||||||
|
|
||||||
private func setRemoteForTunnel(args: JSON) -> (JSON?, Error?) {
|
private func setRemoteForTunnel(args: JSON) -> (JSON?, (any Error)?) {
|
||||||
var err: NSError?
|
var err: NSError?
|
||||||
let res = nebula!.setRemoteForTunnel(
|
let res = nebula!.setRemoteForTunnel(
|
||||||
args["vpnIp"].string, addr: args["addr"].string, error: &err)
|
args["vpnIp"].string, addr: args["addr"].string, error: &err)
|
||||||
return (JSON(res), err)
|
return (JSON(res), err)
|
||||||
}
|
}
|
||||||
|
|
||||||
private func closeTunnel(args: JSON) -> (JSON?, Error?) {
|
private func closeTunnel(args: JSON) -> (JSON?, (any Error)?) {
|
||||||
let res = nebula!.closeTunnel(args["vpnIp"].string)
|
let res = nebula!.closeTunnel(args["vpnIp"].string)
|
||||||
return (JSON(res), nil)
|
return (JSON(res), nil)
|
||||||
}
|
}
|
||||||
|
|
|
@ -458,7 +458,7 @@ struct IncomingSite: Codable {
|
||||||
|
|
||||||
func save(
|
func save(
|
||||||
manager: NETunnelProviderManager?, saveToManager: Bool = true,
|
manager: NETunnelProviderManager?, saveToManager: Bool = true,
|
||||||
callback: @escaping (Error?) -> Void
|
callback: @escaping ((any Error)?) -> Void
|
||||||
) {
|
) {
|
||||||
let configPath: URL
|
let configPath: URL
|
||||||
|
|
||||||
|
@ -506,7 +506,7 @@ struct IncomingSite: Codable {
|
||||||
}
|
}
|
||||||
|
|
||||||
private func saveToManager(
|
private func saveToManager(
|
||||||
manager: NETunnelProviderManager?, callback: @escaping (Error?) -> Void
|
manager: NETunnelProviderManager?, callback: @escaping ((any Error)?) -> Void
|
||||||
) {
|
) {
|
||||||
if manager != nil {
|
if manager != nil {
|
||||||
// We need to refresh our settings to properly update config
|
// We need to refresh our settings to properly update config
|
||||||
|
@ -524,7 +524,7 @@ struct IncomingSite: Codable {
|
||||||
}
|
}
|
||||||
|
|
||||||
private func finishSaveToManager(
|
private func finishSaveToManager(
|
||||||
manager: NETunnelProviderManager, callback: @escaping (Error?) -> Void
|
manager: NETunnelProviderManager, callback: @escaping ((any Error)?) -> Void
|
||||||
) {
|
) {
|
||||||
// Stuff our details in the protocol
|
// Stuff our details in the protocol
|
||||||
let proto =
|
let proto =
|
||||||
|
|
|
@ -49,7 +49,7 @@ class SiteList {
|
||||||
"logs", isDirectory: false)
|
"logs", isDirectory: false)
|
||||||
}
|
}
|
||||||
|
|
||||||
init(completion: @escaping ([String: Site]?, Error?) -> Void) {
|
init(completion: @escaping ([String: Site]?, (any Error)?) -> Void) {
|
||||||
#if targetEnvironment(simulator)
|
#if targetEnvironment(simulator)
|
||||||
SiteList.loadAllFromFS { sites, err in
|
SiteList.loadAllFromFS { sites, err in
|
||||||
if sites != nil {
|
if sites != nil {
|
||||||
|
@ -67,7 +67,7 @@ class SiteList {
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
private static func loadAllFromFS(completion: @escaping ([String: Site]?, Error?) -> Void) {
|
private static func loadAllFromFS(completion: @escaping ([String: Site]?, (any Error)?) -> Void) {
|
||||||
let fileManager = FileManager.default
|
let fileManager = FileManager.default
|
||||||
var siteDirs: [URL]
|
var siteDirs: [URL]
|
||||||
var sites = [String: Site]()
|
var sites = [String: Site]()
|
||||||
|
@ -97,7 +97,9 @@ class SiteList {
|
||||||
completion(sites, nil)
|
completion(sites, nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
private static func loadAllFromNETPM(completion: @escaping ([String: Site]?, Error?) -> Void) {
|
private static func loadAllFromNETPM(
|
||||||
|
completion: @escaping ([String: Site]?, (any Error)?) -> Void
|
||||||
|
) {
|
||||||
var sites = [String: Site]()
|
var sites = [String: Site]()
|
||||||
|
|
||||||
// dispatchGroup is used to ensure we have migrated all sites before returning them
|
// dispatchGroup is used to ensure we have migrated all sites before returning them
|
||||||
|
|
|
@ -318,13 +318,13 @@ func MissingArgumentError(message: String, details: Any?) -> FlutterError {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func MissingArgumentError(message: String, details: Error? = nil) -> FlutterError {
|
func MissingArgumentError(message: String, details: (any Error)? = nil) -> FlutterError {
|
||||||
return FlutterError(code: "missingArgument", message: message, details: details)
|
return FlutterError(code: "missingArgument", message: message, details: details)
|
||||||
}
|
}
|
||||||
|
|
||||||
func NoArgumentsError(
|
func NoArgumentsError(
|
||||||
message: String? = "no arguments were provided or could not be deserialized",
|
message: String? = "no arguments were provided or could not be deserialized",
|
||||||
details: Error? = nil
|
details: (any Error)? = nil
|
||||||
) -> FlutterError {
|
) -> FlutterError {
|
||||||
return FlutterError(code: "noArguments", message: message, details: details)
|
return FlutterError(code: "noArguments", message: message, details: details)
|
||||||
}
|
}
|
||||||
|
|
|
@ -100,7 +100,7 @@ class RepeatingTimer {
|
||||||
self.timeInterval = timeInterval
|
self.timeInterval = timeInterval
|
||||||
}
|
}
|
||||||
|
|
||||||
private lazy var timer: DispatchSourceTimer = {
|
private lazy var timer: any DispatchSourceTimer = {
|
||||||
let t = DispatchSource.makeTimerSource()
|
let t = DispatchSource.makeTimerSource()
|
||||||
t.schedule(deadline: .now(), repeating: self.timeInterval)
|
t.schedule(deadline: .now(), repeating: self.timeInterval)
|
||||||
t.setEventHandler(handler: { [weak self] in
|
t.setEventHandler(handler: { [weak self] in
|
||||||
|
|
|
@ -13,13 +13,13 @@ class SiteContainer {
|
||||||
|
|
||||||
class Sites {
|
class Sites {
|
||||||
private var containers = [String: SiteContainer]()
|
private var containers = [String: SiteContainer]()
|
||||||
private var messenger: FlutterBinaryMessenger?
|
private var messenger: (any FlutterBinaryMessenger)?
|
||||||
|
|
||||||
init(messenger: FlutterBinaryMessenger?) {
|
init(messenger: (any FlutterBinaryMessenger)?) {
|
||||||
self.messenger = messenger
|
self.messenger = messenger
|
||||||
}
|
}
|
||||||
|
|
||||||
func loadSites(completion: @escaping ([String: Site]?, Error?) -> Void) {
|
func loadSites(completion: @escaping ([String: Site]?, (any Error)?) -> Void) {
|
||||||
_ = SiteList { (sites, err) in
|
_ = SiteList { (sites, err) in
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return completion(nil, err)
|
return completion(nil, err)
|
||||||
|
@ -42,7 +42,7 @@ class Sites {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteSite(id: String, callback: @escaping (Error?) -> Void) {
|
func deleteSite(id: String, callback: @escaping ((any Error)?) -> Void) {
|
||||||
if let site = self.containers.removeValue(forKey: id) {
|
if let site = self.containers.removeValue(forKey: id) {
|
||||||
_ = KeyChain.delete(key: "\(site.site.id).dnCredentials")
|
_ = KeyChain.delete(key: "\(site.site.id).dnCredentials")
|
||||||
_ = KeyChain.delete(key: "\(site.site.id).key")
|
_ = KeyChain.delete(key: "\(site.site.id).key")
|
||||||
|
@ -85,9 +85,9 @@ class SiteUpdater: NSObject, FlutterStreamHandler {
|
||||||
private var notification: Any?
|
private var notification: Any?
|
||||||
public var startFunc: (() -> Void)?
|
public var startFunc: (() -> Void)?
|
||||||
private var configFd: Int32? = nil
|
private var configFd: Int32? = nil
|
||||||
private var configObserver: DispatchSourceFileSystemObject? = nil
|
private var configObserver: (any DispatchSourceFileSystemObject)? = nil
|
||||||
|
|
||||||
init(messenger: FlutterBinaryMessenger, site: Site) {
|
init(messenger: any FlutterBinaryMessenger, site: Site) {
|
||||||
do {
|
do {
|
||||||
let configPath = try SiteList.getSiteConfigFile(id: site.id, createDir: false)
|
let configPath = try SiteList.getSiteConfigFile(id: site.id, createDir: false)
|
||||||
self.configFd = open(configPath.path, O_EVTONLY)
|
self.configFd = open(configPath.path, O_EVTONLY)
|
||||||
|
|
Loading…
Reference in a new issue