Add support for sessionToken in "connect" and "subscribe" operations

Author: Joe Hansche

ParseLiveQuery/src/main/java/com/parse/ParseLiveQueryClientImpl.java

@@ -224,7 +224,8 @@ private Subscription<T> subscriptionForRequestId(int requestId) {
     }
 
     private void sendSubscription(Subscription<T> subscription) {
-        sendOperationAsync(new SubscribeClientOperation<>(subscription.getRequestId(), subscription.getQueryState()));
+        String sessionToken = ParseUser.getCurrentSessionToken();
+        sendOperationAsync(new SubscribeClientOperation<>(subscription.getRequestId(), subscription.getQueryState(), sessionToken));
     }
 
     private void sendUnsubscription(Subscription subscription) {
@@ -236,7 +237,8 @@ private WebSocketClient.WebSocketClientCallback getWebSocketClientCallback() {
             @Override
             public void onOpen() {
                 Log.v(LOG_TAG, "Socket opened");
-                sendOperationAsync(new ConnectClientOperation(applicationId, "")).continueWith(new Continuation<Void, Void>() {
+                String sessionToken = ParseUser.getCurrentSessionToken();
+                sendOperationAsync(new ConnectClientOperation(applicationId, sessionToken)).continueWith(new Continuation<Void, Void>() {
                     public Void then(Task<Void> task) {
                         Exception error = task.getError();
                         if (error != null) {

ParseLiveQuery/src/main/java/com/parse/SubscribeClientOperation.java

@@ -7,17 +7,20 @@
 
     private final int requestId;
     private final ParseQuery.State<T> state;
+    private final String sessionToken;
 
-    /* package */ SubscribeClientOperation(int requestId, final ParseQuery.State<T> state) {
+    /* package */ SubscribeClientOperation(int requestId, ParseQuery.State<T> state, String sessionToken) {
         this.requestId = requestId;
         this.state = state;
+        this.sessionToken = sessionToken;
     }
 
     @Override
     /* package */ JSONObject getJSONObjectRepresentation() throws JSONException {
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("op", "subscribe");
         jsonObject.put("requestId", requestId);
+        if (sessionToken != null) jsonObject.put("sessionToken", sessionToken);
 
         JSONObject queryJsonObject = state.toJSON(NoObjectsEncoder.get());