123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267 |
- #if !(os(watchOS) || os(Linux))
- import Foundation
- import SystemConfiguration
- open class NetworkReachabilityManager {
-
- public enum NetworkReachabilityStatus {
-
- case unknown
-
- case notReachable
-
- case reachable(ConnectionType)
- init(_ flags: SCNetworkReachabilityFlags) {
- guard flags.isActuallyReachable else { self = .notReachable; return }
- var networkStatus: NetworkReachabilityStatus = .reachable(.ethernetOrWiFi)
- if flags.isCellular { networkStatus = .reachable(.cellular) }
- self = networkStatus
- }
-
- public enum ConnectionType {
-
- case ethernetOrWiFi
-
- case cellular
- }
- }
-
-
- public typealias Listener = (NetworkReachabilityStatus) -> Void
-
- public static let `default` = NetworkReachabilityManager()
-
-
- open var isReachable: Bool { isReachableOnCellular || isReachableOnEthernetOrWiFi }
-
-
-
-
-
- open var isReachableOnCellular: Bool { status == .reachable(.cellular) }
-
- open var isReachableOnEthernetOrWiFi: Bool { status == .reachable(.ethernetOrWiFi) }
-
- public let reachabilityQueue = DispatchQueue(label: "org.alamofire.reachabilityQueue")
-
- open var flags: SCNetworkReachabilityFlags? {
- var flags = SCNetworkReachabilityFlags()
- return (SCNetworkReachabilityGetFlags(reachability, &flags)) ? flags : nil
- }
-
- open var status: NetworkReachabilityStatus {
- flags.map(NetworkReachabilityStatus.init) ?? .unknown
- }
-
- struct MutableState {
-
- var listener: Listener?
-
- var listenerQueue: DispatchQueue?
-
- var previousStatus: NetworkReachabilityStatus?
- }
-
- private let reachability: SCNetworkReachability
-
- @Protected
- private var mutableState = MutableState()
-
-
-
-
-
-
-
- public convenience init?(host: String) {
- guard let reachability = SCNetworkReachabilityCreateWithName(nil, host) else { return nil }
- self.init(reachability: reachability)
- }
-
-
-
-
- public convenience init?() {
- var zero = sockaddr()
- zero.sa_len = UInt8(MemoryLayout<sockaddr>.size)
- zero.sa_family = sa_family_t(AF_INET)
- guard let reachability = SCNetworkReachabilityCreateWithAddress(nil, &zero) else { return nil }
- self.init(reachability: reachability)
- }
- private init(reachability: SCNetworkReachability) {
- self.reachability = reachability
- }
- deinit {
- stopListening()
- }
-
-
-
-
-
-
-
-
-
-
- @discardableResult
- open func startListening(onQueue queue: DispatchQueue = .main,
- onUpdatePerforming listener: @escaping Listener) -> Bool {
- stopListening()
- $mutableState.write { state in
- state.listenerQueue = queue
- state.listener = listener
- }
- var context = SCNetworkReachabilityContext(version: 0,
- info: Unmanaged.passUnretained(self).toOpaque(),
- retain: nil,
- release: nil,
- copyDescription: nil)
- let callback: SCNetworkReachabilityCallBack = { _, flags, info in
- guard let info = info else { return }
- let instance = Unmanaged<NetworkReachabilityManager>.fromOpaque(info).takeUnretainedValue()
- instance.notifyListener(flags)
- }
- let queueAdded = SCNetworkReachabilitySetDispatchQueue(reachability, reachabilityQueue)
- let callbackAdded = SCNetworkReachabilitySetCallback(reachability, callback, &context)
-
- if let currentFlags = flags {
- reachabilityQueue.async {
- self.notifyListener(currentFlags)
- }
- }
- return callbackAdded && queueAdded
- }
-
- open func stopListening() {
- SCNetworkReachabilitySetCallback(reachability, nil, nil)
- SCNetworkReachabilitySetDispatchQueue(reachability, nil)
- $mutableState.write { state in
- state.listener = nil
- state.listenerQueue = nil
- state.previousStatus = nil
- }
- }
-
-
-
-
-
-
- func notifyListener(_ flags: SCNetworkReachabilityFlags) {
- let newStatus = NetworkReachabilityStatus(flags)
- $mutableState.write { state in
- guard state.previousStatus != newStatus else { return }
- state.previousStatus = newStatus
- let listener = state.listener
- state.listenerQueue?.async { listener?(newStatus) }
- }
- }
- }
- extension NetworkReachabilityManager.NetworkReachabilityStatus: Equatable {}
- extension SCNetworkReachabilityFlags {
- var isReachable: Bool { contains(.reachable) }
- var isConnectionRequired: Bool { contains(.connectionRequired) }
- var canConnectAutomatically: Bool { contains(.connectionOnDemand) || contains(.connectionOnTraffic) }
- var canConnectWithoutUserInteraction: Bool { canConnectAutomatically && !contains(.interventionRequired) }
- var isActuallyReachable: Bool { isReachable && (!isConnectionRequired || canConnectWithoutUserInteraction) }
- var isCellular: Bool {
- #if os(iOS) || os(tvOS)
- return contains(.isWWAN)
- #else
- return false
- #endif
- }
-
- var readableDescription: String {
- let W = isCellular ? "W" : "-"
- let R = isReachable ? "R" : "-"
- let c = isConnectionRequired ? "c" : "-"
- let t = contains(.transientConnection) ? "t" : "-"
- let i = contains(.interventionRequired) ? "i" : "-"
- let C = contains(.connectionOnTraffic) ? "C" : "-"
- let D = contains(.connectionOnDemand) ? "D" : "-"
- let l = contains(.isLocalAddress) ? "l" : "-"
- let d = contains(.isDirect) ? "d" : "-"
- let a = contains(.connectionAutomatic) ? "a" : "-"
- return "\(W)\(R) \(c)\(t)\(i)\(C)\(D)\(l)\(d)\(a)"
- }
- }
- #endif
|