Added support for session token and user authentication. (#60)

* 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.

* Made userDisconnected public, as it needs to be accessible outside of the framework.

* Swift 3 conformance.

Author: agordeev

Sources/ParseLiveQuery/Client.swift

@@ -23,7 +23,7 @@ open class Client: NSObject {
     let clientKey: String?
 
     var socket: SRWebSocket?
-    var userDisconnected = false
+    public var userDisconnected = false
 
     // This allows us to easily plug in another request ID generation scheme, or more easily change the request id type
     // if needed (technically this could be a string).
@@ -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.current()?.sessionToken))
         } else if socket == nil || socket?.readyState != .CONNECTING {
             if !userDisconnected {
                 reconnect()

Sources/ParseLiveQuery/Internal/ClientPrivate.swift

@@ -138,8 +138,8 @@ extension Client: SRWebSocketDelegate {
     }
 
     public func webSocketDidOpen(_ webSocket: SRWebSocket!) {
-        // TODO: Add support for session token and user authetication.
-        _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: ""))
+        let sessionToken = PFUser.current()?.sessionToken ?? ""
+        _ = self.sendOperationAsync(.connect(applicationId: applicationId, sessionToken: sessionToken))
     }
 
     public func webSocket(_ webSocket: SRWebSocket!, didFailWithError error: Error!) {
@@ -227,8 +227,9 @@ extension Client {
 
             switch response {
             case .connected:
+                let sessionToken = PFUser.current()?.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,20 @@ 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):
             return [ "op": "connect", "applicationId": applicationId, "sessionToken": sessionToken ]
 
-        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: Any] =  [ "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 ]