Update ParseLiveQueryServer.js

Author: dblythy

src/LiveQuery/ParseLiveQueryServer.js

@@ -171,7 +171,9 @@ class ParseLiveQueryServer {
             const trigger = getTrigger(className, 'afterEvent', Parse.applicationId);
             if (trigger) {
               const auth = await this.getAuthFromClient(client, requestId);
-              res.user = auth.user;
+              if (auth && auth.user) {
+                res.user = auth.user;
+              }
               if (res.object) {
                 res.object = Parse.Object.fromJSON(res.object);
               }
@@ -318,7 +320,9 @@ class ParseLiveQueryServer {
                 res.original = Parse.Object.fromJSON(res.original);
               }
               const auth = await this.getAuthFromClient(client, requestId);
-              res.user = auth.user;
+              if (auth && auth.user) {
+                res.user = auth.user;
+              }
               await runTrigger(trigger, `afterEvent.${className}`, res, auth);
             }
             if (!res.sendEvent) {
@@ -590,8 +594,11 @@ class ParseLiveQueryServer {
     if (!sessionToken) {
       sessionToken = getSessionFromClient();
     }
+    if (!sessionToken) {
+      return;
+    }
     const { auth } = await this.getAuthForSessionToken(sessionToken);
-    return auth || {};
+    return auth;
   }
 
   async _matchesACL(acl: any, client: any, requestId: number): Promise<boolean> {
@@ -647,7 +654,9 @@ class ParseLiveQueryServer {
       const trigger = getTrigger('@Connect', 'beforeConnect', Parse.applicationId);
       if (trigger) {
         const auth = await this.getAuthFromClient(client, request.requestId, req.sessionToken);
-        req.user = auth.user;
+        if (auth && auth.user) {
+          req.user = auth.user;
+        }
         await runTrigger(trigger, `beforeConnect.@Connect`, req, auth);
       }
       parseWebsocket.clientId = clientId;
@@ -706,7 +715,9 @@ class ParseLiveQueryServer {
       const trigger = getTrigger(className, 'beforeSubscribe', Parse.applicationId);
       if (trigger) {
         const auth = await this.getAuthFromClient(client, request.requestId, request.sessionToken);
-        request.user = auth.user;
+        if (auth && auth.user) {
+          request.user = auth.user;
+        }
 
         const parseQuery = new Parse.Query(className);
         parseQuery.withJSON(request.query);