react-native-firebase/packages/app/e2e/events.e2e.js

/*
 * Copyright (c) 2016-present Invertase Limited & Contributors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this library except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

const eventName = 'pong';
const eventName2 = 'ping';
const eventBody = {
  foo: 'bar',
};

describe('Core -> EventEmitter', () => {
  describe('ReactNativeFirebaseEventEmitter', () => {
    it('queues events before app is ready', async () => {
      const { eventsPing, eventsNotifyReady, eventsGetListeners } = NativeModules.RNFBAppModule;
      await eventsNotifyReady(false);

      let readyToResolve = false;
      const { resolve, reject, promise } = Promise.defer();
      const emitter = NativeEventEmitter;

      emitter.addListener(eventName, event => {
        event.foo.should.equal(eventBody.foo);
        if (!readyToResolve) {
          return reject(new Error('Event was received before being ready!'));
        }

        return resolve();
      });

      await eventsNotifyReady(false);
      await eventsPing(eventName, eventBody);
      await Utils.sleep(100);
      const nativeListenersBefore = await eventsGetListeners();
      nativeListenersBefore.events.pong.should.equal(1);

      readyToResolve = true;
      await eventsNotifyReady(true);

      await promise;
      emitter.removeAllListeners(eventName);

      const nativeListenersAfter = await eventsGetListeners();

      should.equal(nativeListenersAfter.events.pong, undefined);
    });

    it('queues events before a js listener is registered', async () => {
      const {
        eventsPing,
        eventsNotifyReady,
        eventsGetListeners,
        eventsRemoveListener,
      } = NativeModules.RNFBAppModule;
      await eventsNotifyReady(true);
      const { resolve, promise } = Promise.defer();
      const emitter = NativeEventEmitter;

      await eventsPing(eventName2, eventBody);
      await Utils.sleep(500);
      const nativeListenersBefore = await eventsGetListeners();
      should.equal(nativeListenersBefore.events.ping, undefined);

      const subscription = emitter.addListener(eventName2, event => {
        event.foo.should.equal(eventBody.foo);
        return resolve();
      });

      await promise;
      emitter.removeSubscription(subscription);

      await eventsRemoveListener(eventName2, true);
      const nativeListenersAfter = await eventsGetListeners();

      should.equal(nativeListenersAfter.events.ping, undefined);
    });
  });
});