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

@@ -149,7 +149,8 @@ extension Client {
         subscriptions.append(subscriptionRecord)
 
         if socket?.readyState == .OPEN {
-            sendOperationAsync(.Subscribe(requestId: subscriptionRecord.requestId, query: query))
+            sendOperationAsync(.Subscribe(requestId: subscriptionRecord.requestId, query: query,
+                sessionToken: PFUser.currentUser()?.sessionToken))
         } else if socket == nil || socket?.readyState != .CONNECTING {
             if !userDisconnected {
                 reconnect()

Sources/ParseLiveQuery/Internal/ClientPrivate.swift

@@ -127,8 +127,7 @@ func == (first: Client.RequestId, second: Client.RequestId) -> Bool {
 
 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: NSError!) {
@@ -228,7 +227,7 @@ extension Client {
             switch response {
             case .Connected:
                 self.subscriptions.forEach {
-                    self.sendOperationAsync(.Subscribe(requestId: $0.requestId, query: $0.query))
+                    self.sendOperationAsync(.Subscribe(requestId: $0.requestId, query: $0.query, sessionToken: PFUser.currentUser()?.sessionToken))
                 }
 
             case .Redirect:

Sources/ParseLiveQuery/Internal/Operation.swift

@@ -11,17 +11,25 @@ import Foundation
 import Parse
 
 enum ClientOperation {
-    case Connect(applicationId: String, sessionToken: String)
-    case Subscribe(requestId: Client.RequestId, query: PFQuery)
+    case Connect(applicationId: String, sessionToken: String?)
+    case Subscribe(requestId: Client.RequestId, query: PFQuery, sessionToken: String?)
     case Unsubscribe(requestId: Client.RequestId)
 
     var JSONObjectRepresentation: [String : AnyObject] {
         switch self {
         case .Connect(let applicationId, let sessionToken):
-            return [ "op": "connect", "applicationId": applicationId, "sessionToken": sessionToken ]
+            var result: [String: AnyObject] = [ "op": "connect", "applicationId": applicationId ]
+            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):
+            var result: [String: AnyObject] = [ "op": "subscribe", "requestId": requestId.value, "query": Dictionary<String, AnyObject>(query: query) ]
+            if let sessionToken = sessionToken {
+                result["sessionToken"] = sessionToken
+            }
+            return result
 
         case .Unsubscribe(let requestId):
             return [ "op": "unsubscribe", "requestId": requestId.value ]