Update sockets

Cartfile

@@ -1,3 +1,3 @@
 github "BoltsFramework/Bolts-Swift" >= 1.5.0
 github "ParsePlatform/Parse-SDK-iOS-OSX" >= 1.19.0
-github "daltoniam/Starscream" == 3.1.1
+github "daltoniam/Starscream" >= 4.0.4

Cartfile.resolved

@@ -1,5 +1,5 @@
 github "BoltsFramework/Bolts-ObjC" "1.9.1"
 github "BoltsFramework/Bolts-Swift" "1.5.0"
-github "ParsePlatform/Parse-SDK-iOS-OSX" "1.19.0"
-github "daltoniam/Starscream" "3.1.1"
+github "ParsePlatform/Parse-SDK-iOS-OSX" "1.19.1"
+github "daltoniam/Starscream" "4.0.4"
 github "facebook/facebook-objc-sdk" "v6.5.2"

ParseLiveQuery.podspec

@@ -15,7 +15,7 @@ Pod::Spec.new do |s|
   s.swift_version = '5.0'
   s.cocoapods_version = '>= 1.4'
 
-  s.ios.deployment_target = '8.0'
+  s.ios.deployment_target = '9.0'
   s.tvos.deployment_target = '10.0'
   s.osx.deployment_target = '10.12'
 
@@ -24,6 +24,6 @@ Pod::Spec.new do |s|
 
   s.dependency 'Parse', '~> 1.19.0'
   s.dependency 'Bolts-Swift', '~> 1.5.0'
-  s.dependency 'Starscream', '3.1.0'
+  s.dependency 'Starscream', '~> 4.0.4'
 
 end

Sources/ParseLiveQuery.xcodeproj/project.pbxproj

@@ -891,7 +891,7 @@
 				GCC_WARN_UNINITIALIZED_AUTOS = YES;
 				GCC_WARN_UNUSED_FUNCTION = YES;
 				GCC_WARN_UNUSED_VARIABLE = YES;
-				IPHONEOS_DEPLOYMENT_TARGET = 8.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 9.0;
 				MACOSX_DEPLOYMENT_TARGET = 10.12;
 				ONLY_ACTIVE_ARCH = YES;
 				SWIFT_OBJC_BRIDGING_HEADER = "";
@@ -928,7 +928,7 @@
 				GCC_WARN_UNINITIALIZED_AUTOS = YES;
 				GCC_WARN_UNUSED_FUNCTION = YES;
 				GCC_WARN_UNUSED_VARIABLE = YES;
-				IPHONEOS_DEPLOYMENT_TARGET = 8.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 9.0;
 				MACOSX_DEPLOYMENT_TARGET = 10.12;
 				SWIFT_OBJC_BRIDGING_HEADER = "";
 				SWIFT_OPTIMIZATION_LEVEL = "-Owholemodule";
@@ -1003,7 +1003,7 @@
 				FRAMEWORK_VERSION = A;
 				INFOPLIST_FILE = ParseLiveQuery/Info.plist;
 				INSTALL_PATH = "$(LOCAL_LIBRARY_DIR)/Frameworks";
-				IPHONEOS_DEPLOYMENT_TARGET = 8.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 9.0;
 				LD_RUNPATH_SEARCH_PATHS = "$(inherited) @executable_path/Frameworks @loader_path/Frameworks";
 				LIBRARY_SEARCH_PATHS = "$(inherited)";
 				MARKETING_VERSION = 2.7.2;
@@ -1032,7 +1032,7 @@
 				FRAMEWORK_VERSION = A;
 				INFOPLIST_FILE = ParseLiveQuery/Info.plist;
 				INSTALL_PATH = "$(LOCAL_LIBRARY_DIR)/Frameworks";
-				IPHONEOS_DEPLOYMENT_TARGET = 8.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 9.0;
 				LD_RUNPATH_SEARCH_PATHS = "$(inherited) @executable_path/Frameworks @loader_path/Frameworks";
 				LIBRARY_SEARCH_PATHS = "$(inherited)";
 				MARKETING_VERSION = 2.7.2;

Sources/ParseLiveQuery/Client.swift

@@ -152,17 +152,18 @@ extension Client {
             requestId: requestIdGenerator(),
             handler: handler
         )
-        subscriptions.append(subscriptionRecord)
+
+        self.subscriptions.append(subscriptionRecord)
 
-        if let socket = socket, socket.isConnected == true {
-            _ = sendOperationAsync(.subscribe(requestId: subscriptionRecord.requestId, query: query as! PFQuery<PFObject>,
+        if socket != nil {
+            _ = self.sendOperationAsync(.subscribe(requestId: subscriptionRecord.requestId, query: query as! PFQuery<PFObject>,
             sessionToken: PFUser.current()?.sessionToken))
+        } else if !self.userDisconnected {
+            self.reconnect()
+            self.subscriptions.removeLast()
+            return self.subscribe(query, handler: handler)
         } else {
-            if !userDisconnected {
-                reconnect()
-            } else {
-                NSLog("ParseLiveQuery: Warning: The client was explicitly disconnected! You must explicitly call .reconnect() in order to process your subscriptions.")
-            }
+            NSLog("ParseLiveQuery: Warning: The client was explicitly disconnected! You must explicitly call .reconnect() in order to process your subscriptions.")
         }
 
         return handler
@@ -233,7 +234,7 @@ extension Client {
         guard socket == nil || !isConnecting else { return }
         socket?.disconnect()
         socket = {
-            let socket = WebSocket(url: host)
+            let socket = WebSocket(request: .init(url: host))
             socket.delegate = self
             socket.callbackQueue = queue
             socket.connect()

Sources/ParseLiveQuery/Internal/ClientPrivate.swift

@@ -115,32 +115,33 @@ func == (first: Client.RequestId, second: Client.RequestId) -> Bool {
 // ---------------
 
 extension Client: WebSocketDelegate {
-
-    public func websocketDidReceiveData(socket: WebSocketClient, data: Data) {
-        if shouldPrintWebSocketLog { NSLog("ParseLiveQuery: Received binary data but we don't handle it...") }
-    }
-
-    public func websocketDidReceiveMessage(socket: WebSocketClient, text: String) {
-        handleOperationAsync(text).continueWith { [weak self] task in
-            if let error = task.error, self?.shouldPrintWebSocketLog == true {
-                NSLog("ParseLiveQuery: Error processing message: \(error)")
+    public func didReceive(event: WebSocketEvent, client: WebSocket) {
+        switch event {
+
+        case .connected(_):
+            isConnecting = false
+            let sessionToken = PFUser.current()?.sessionToken ?? ""
+            _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: sessionToken, clientKey: clientKey))
+        case .disconnected(let reason, let code):
+            isConnecting = false
+            if shouldPrintWebSocketLog { NSLog("ParseLiveQuery: WebSocket did disconnect with error: \(reason) code:\(code)") }
+
+            // TODO: Better retry logic, unless `disconnect()` was explicitly called
+            if !userDisconnected {
+                reconnect()
             }
-        }
-    }
-
-    public func websocketDidConnect(socket: WebSocketClient) {
-        isConnecting = false
-        let sessionToken = PFUser.current()?.sessionToken ?? ""
-        _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: sessionToken, clientKey: clientKey))
-    }
-
-    public func websocketDidDisconnect(socket: WebSocketClient, error: Error?) {
-        isConnecting = false
-        if shouldPrintWebSocketLog { NSLog("ParseLiveQuery: WebSocket did disconnect with error: \(String(describing: error))") }
-
-        // TODO: Better retry logic, unless `disconnect()` was explicitly called
-        if !userDisconnected {
-            reconnect()
+        case .text(let text):
+            handleOperationAsync(text).continueWith { [weak self] task in
+                if let error = task.error, self?.shouldPrintWebSocketLog == true {
+                    NSLog("ParseLiveQuery: Error processing message: \(error)")
+                }
+            }
+        case .binary(_):
+            if shouldPrintWebSocketLog { NSLog("ParseLiveQuery: Received binary data but we don't handle it...") }
+        case .error(let error):
+            NSLog("ParseLiveQuery: Error processing message: \(String(describing: error))")
+        default:
+            break
         }
     }
 }