kami-parse-server/spec/Subscription.spec.js

const Subscription = require('../lib/LiveQuery/Subscription').Subscription;
let logger;
describe('Subscription', function() {
  beforeEach(function() {
    logger = require('../lib/logger').logger;
    spyOn(logger, 'error').and.callThrough();
  });

  it('can be initialized', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );

    expect(subscription.className).toBe('className');
    expect(subscription.query).toEqual({ key: 'value' });
    expect(subscription.hash).toBe('hash');
    expect(subscription.clientRequestIds.size).toBe(0);
  });

  it('can check it has subscribing clients', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );

    expect(subscription.hasSubscribingClient()).toBe(false);
  });

  it('can check it does not have subscribing clients', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);

    expect(subscription.hasSubscribingClient()).toBe(true);
  });

  it('can add one request for one client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);

    expect(subscription.clientRequestIds.size).toBe(1);
    expect(subscription.clientRequestIds.get(1)).toEqual([1]);
  });

  it('can add requests for one client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.addClientSubscription(1, 2);

    expect(subscription.clientRequestIds.size).toBe(1);
    expect(subscription.clientRequestIds.get(1)).toEqual([1, 2]);
  });

  it('can add requests for clients', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.addClientSubscription(1, 2);
    subscription.addClientSubscription(2, 2);
    subscription.addClientSubscription(2, 3);

    expect(subscription.clientRequestIds.size).toBe(2);
    expect(subscription.clientRequestIds.get(1)).toEqual([1, 2]);
    expect(subscription.clientRequestIds.get(2)).toEqual([2, 3]);
  });

  it('can delete requests for nonexistent client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.deleteClientSubscription(1, 1);

    expect(logger.error).toHaveBeenCalled();
  });

  it('can delete nonexistent request for one client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.deleteClientSubscription(1, 2);

    expect(logger.error).toHaveBeenCalled();
    expect(subscription.clientRequestIds.size).toBe(1);
    expect(subscription.clientRequestIds.get(1)).toEqual([1]);
  });

  it('can delete some requests for one client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.addClientSubscription(1, 2);
    subscription.deleteClientSubscription(1, 2);

    expect(logger.error).not.toHaveBeenCalled();
    expect(subscription.clientRequestIds.size).toBe(1);
    expect(subscription.clientRequestIds.get(1)).toEqual([1]);
  });

  it('can delete all requests for one client', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.addClientSubscription(1, 2);
    subscription.deleteClientSubscription(1, 1);
    subscription.deleteClientSubscription(1, 2);

    expect(logger.error).not.toHaveBeenCalled();
    expect(subscription.clientRequestIds.size).toBe(0);
  });

  it('can delete requests for multiple clients', function() {
    const subscription = new Subscription(
      'className',
      { key: 'value' },
      'hash'
    );
    subscription.addClientSubscription(1, 1);
    subscription.addClientSubscription(1, 2);
    subscription.addClientSubscription(2, 1);
    subscription.addClientSubscription(2, 2);
    subscription.deleteClientSubscription(1, 2);
    subscription.deleteClientSubscription(2, 1);
    subscription.deleteClientSubscription(2, 2);

    expect(logger.error).not.toHaveBeenCalled();
    expect(subscription.clientRequestIds.size).toBe(1);
    expect(subscription.clientRequestIds.get(1)).toEqual([1]);
  });
});