fix: allow Parse.Cloud.beforeSubscribe rejections to be caught by q…

…uery.subscribe

integration/test/ParseLiveQueryTest.js

@@ -256,4 +256,31 @@ describe('Parse LiveQuery', () => {
     object.set({ foo: 'bar' });
     await object.save();
   });
+
+  it('live query can handle beforeConnect and beforeSubscribe errors', async () => {
+    const client = new Parse.LiveQueryClient({
+      applicationId: 'integration',
+      serverURL: 'ws://localhost:1337',
+      javascriptKey: null,
+      masterKey: null,
+      sessionToken: null,
+      installationId: null,
+    });
+    client.open();
+    const query = new Parse.Query('TestError');
+    let subscription = client.subscribe(query);
+    await expectAsync(subscription.subscribePromise).toBeRejectedWith(
+      new Parse.Error(141, 'not allowed to subscribe')
+    );
+    client.close();
+    await reconfigureServer({
+      cloud: `${__dirname}/cloud/before_connect.js`,
+    });
+    client.open();
+    subscription = client.subscribe(query);
+    await expectAsync(subscription.subscribePromise).toBeRejectedWith(
+      new Parse.Error(141, 'not allowed to connect')
+    );
+    client.close();
+  });
 });

integration/test/cloud/before_connect.js

@@ -0,0 +1,3 @@
+Parse.Cloud.beforeConnect(() => {
+  throw 'not allowed to connect';
+});

integration/test/cloud/main.js

@@ -48,3 +48,7 @@ Parse.Cloud.job('CloudJob2', function () {
 Parse.Cloud.job('CloudJobFailing', function () {
   throw 'cloud job failed';
 });
+
+Parse.Cloud.beforeSubscribe('TestError', () => {
+  throw 'not allowed to subscribe';
+});

src/LiveQueryClient.js

@@ -14,6 +14,7 @@ import EventEmitter from './EventEmitter';
 import ParseObject from './ParseObject';
 import LiveQuerySubscription from './LiveQuerySubscription';
 import { resolvingPromise } from './promiseUtils';
+import ParseError from './ParseError';
 
 // The LiveQuery client inner state
 const CLIENT_STATE = {
@@ -218,6 +219,10 @@ class LiveQueryClient extends EventEmitter {
     this.subscriptions.set(this.requestId, subscription);
     this.requestId += 1;
     this.connectPromise.then(() => {
+      if (this.connectError) {
+        subscription.subscribePromise.reject(this.connectError);
+        return;
+      }
       this.socket.send(JSON.stringify(subscribeRequest));
     });
 
@@ -382,10 +387,16 @@ class LiveQueryClient extends EventEmitter {
         setTimeout(() => subscription.emit(SUBSCRIPTION_EMMITER_TYPES.OPEN, response), 200);
       }
       break;
-    case OP_EVENTS.ERROR:
+    case OP_EVENTS.ERROR: {
+      const parseError = new ParseError(data.code, data.error);
+      if (!this.id) {
+        this.connectError = parseError;
+        this.connectPromise.resolve();
+        this.state = CLIENT_STATE.DISCONNECTED;
+      }
       if (data.requestId) {
         if (subscription) {
-          subscription.subscribePromise.resolve();
+          subscription.subscribePromise.reject(parseError);
           setTimeout(() => subscription.emit(SUBSCRIPTION_EMMITER_TYPES.ERROR, data.error), 200);
         }
       } else {
@@ -398,6 +409,7 @@ class LiveQueryClient extends EventEmitter {
         this._handleReconnect();
       }
       break;
+    }
     case OP_EVENTS.UNSUBSCRIBED:
       // We have already deleted subscription in unsubscribe(), do nothing here
       break;