Null safety and small changes

Author: theSlyest

Parse/Platform/LiveQueries/ParseLiveQueryController.cs

@@ -196,10 +196,10 @@ void ProcessDeleteEventMessage(IDictionary<string, object> message)
         if (!ValidateClientMessage(message, out int requestId))
             return;
 
-        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
+        if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
             return;
 
-        if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
+        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
             return;
 
         subscription.OnDelete(ParseObjectCoder.Instance.Decode(objectDict, Decoder, ParseClient.Instance.Services));
@@ -210,15 +210,15 @@ void ProcessLeaveEventMessage(IDictionary<string, object> message)
         if (!ValidateClientMessage(message, out int requestId))
             return;
 
-        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
-            return;
-
         if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
             return;
 
         if (!GetDictEntry(message, "original", out IDictionary<string, object> originalDict))
             return;
 
+        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
+            return;
+
         subscription.OnLeave(
             ParseObjectCoder.Instance.Decode(objectDict, Decoder, ParseClient.Instance.Services),
             ParseObjectCoder.Instance.Decode(originalDict, Decoder, ParseClient.Instance.Services));
@@ -229,15 +229,15 @@ void ProcessUpdateEventMessage(IDictionary<string, object> message)
         if (!ValidateClientMessage(message, out int requestId))
             return;
 
-        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
-            return;
-
         if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
             return;
 
         if (!GetDictEntry(message, "original", out IDictionary<string, object> originalDict))
             return;
 
+        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
+            return;
+
         subscription.OnUpdate(
             ParseObjectCoder.Instance.Decode(objectDict, Decoder, ParseClient.Instance.Services),
             ParseObjectCoder.Instance.Decode(originalDict, Decoder, ParseClient.Instance.Services));
@@ -248,15 +248,15 @@ void ProcessEnterEventMessage(IDictionary<string, object> message)
         if (!ValidateClientMessage(message, out int requestId))
             return;
 
-        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
-            return;
-
         if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
             return;
 
         if (!GetDictEntry(message, "original", out IDictionary<string, object> originalDict))
             return;
 
+        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
+            return;
+
         subscription.OnEnter(
             ParseObjectCoder.Instance.Decode(objectDict, Decoder, ParseClient.Instance.Services),
             ParseObjectCoder.Instance.Decode(originalDict, Decoder, ParseClient.Instance.Services));
@@ -267,10 +267,10 @@ void ProcessCreateEventMessage(IDictionary<string, object> message)
         if (!ValidateClientMessage(message, out int requestId))
             return;
 
-        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
+        if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
             return;
 
-        if (!GetDictEntry(message, "object", out IDictionary<string, object> objectDict))
+        if (!Subscriptions.TryGetValue(requestId, out IParseLiveQuerySubscription subscription))
             return;
 
         subscription.OnCreate(ParseObjectCoder.Instance.Decode(objectDict, Decoder, ParseClient.Instance.Services));
@@ -323,7 +323,7 @@ void ProcessConnectionMessage(IDictionary<string, object> message)
 
         ClientId = clientId;
         _state = ParseLiveQueryState.Connected;
-        ConnectionSignal.TrySetResult();
+        ConnectionSignal?.TrySetResult();
     }
 
     private async Task<IDictionary<string, object>> AppendSessionToken(IDictionary<string, object> message)