36 lines
1.2 KiB
Swift
36 lines
1.2 KiB
Swift
//
|
|
// Copyright 2022 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
//
|
|
|
|
import SignalServiceKit
|
|
|
|
enum ProxyConnectionChecker: Dependencies {
|
|
static func checkConnectionAndNotify(completion: @escaping (Bool) -> Void) {
|
|
var observer: NSObjectProtocol?
|
|
func unregisterObserver() {
|
|
observer.map { NotificationCenter.default.removeObserver($0) }
|
|
observer = nil
|
|
}
|
|
|
|
var hasTransitionedToConnecting = false
|
|
|
|
// Wait to see if we can establish a websocket connection via the new proxy.
|
|
observer = NotificationCenter.default.addObserver(forName: OWSWebSocket.webSocketStateDidChange, object: nil, queue: nil) { _ in
|
|
switch DependenciesBridge.shared.socketManager.socketState(forType: .identified) {
|
|
case .closed:
|
|
// Ignore closed state until we start connecting, it's expected that old sockets will close
|
|
guard hasTransitionedToConnecting else { break }
|
|
|
|
unregisterObserver()
|
|
completion(false)
|
|
case .connecting:
|
|
hasTransitionedToConnecting = true
|
|
case .open:
|
|
unregisterObserver()
|
|
completion(true)
|
|
}
|
|
}
|
|
}
|
|
}
|