Added support for session token and user authentication.

Added using of sessionToken for both Connect and Subscribe messages. sessionToken is taken from PFUser.currentUser() directly and passes only if it's not nil.

Author: agordeev

Sources/ParseLiveQuery/Client.swift

@@ -151,7 +151,8 @@ extension Client {
         subscriptions.append(subscriptionRecord)
 
         if socket?.readyState == .OPEN {
-            _ = sendOperationAsync(.subscribe(requestId: subscriptionRecord.requestId, query: query as! PFQuery<PFObject>))
+            _ = sendOperationAsync(.subscribe(requestId: subscriptionRecord.requestId, query: query as! PFQuery<PFObject>,
+            sessionToken: PFUser.currentUser()?.sessionToken))
         } else if socket == nil || socket?.readyState != .CONNECTING {
             if !userDisconnected {
                 reconnect()

Sources/ParseLiveQuery/Internal/ClientPrivate.swift

@@ -139,7 +139,7 @@ extension Client: SRWebSocketDelegate {
 
     public func webSocketDidOpen(_ webSocket: SRWebSocket!) {
         // TODO: Add support for session token and user authetication.
-        _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: ""))
+        _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: PFUser.currentUser()?.sessionToken))
     }
 
     public func webSocket(_ webSocket: SRWebSocket!, didFailWithError error: Error!) {
@@ -227,8 +227,9 @@ extension Client {
 
             switch response {
             case .connected:
+                let sessionToken = PFUser.currentUser()?.sessionToken
                 self.subscriptions.forEach {
-                    _ = self.sendOperationAsync(.subscribe(requestId: $0.requestId, query: $0.query))
+                    _ = self.sendOperationAsync(.subscribe(requestId: $0.requestId, query: $0.query, sessionToken: sessionToken))
                 }
 
             case .redirect:

Sources/ParseLiveQuery/Internal/Operation.swift

@@ -12,16 +12,21 @@ import Parse
 
 enum ClientOperation {
     case connect(applicationId: String, sessionToken: String)
-    case subscribe(requestId: Client.RequestId, query: PFQuery<PFObject>)
+    case subscribe(requestId: Client.RequestId, query: PFQuery<PFObject>, sessionToken: String?)
     case unsubscribe(requestId: Client.RequestId)
 
     var JSONObjectRepresentation: [String : Any] {
         switch self {
         case .connect(let applicationId, let sessionToken):
+            var result: [String: Any] = [ "op": "connect", "applicationId": applicationId ]
             return [ "op": "connect", "applicationId": applicationId, "sessionToken": sessionToken ]
+            if let sessionToken = sessionToken {
+                result["sessionToken"] = sessionToken
+            }
+            return result
 
-        case .subscribe(let requestId, let query):
-            return [ "op": "subscribe", "requestId": requestId.value, "query": Dictionary<String, AnyObject>(query: query) ]
+        case .subscribe(let requestId, let query, let sessionToken):
+            return [ "op": "subscribe", "requestId": requestId.value, "query": Dictionary<String, AnyObject>(query: query), "sessionToken": sessionToken ]
 
         case .unsubscribe(let requestId):
             return [ "op": "unsubscribe", "requestId": requestId.value ]