describe('Stomp Subscription', function () {
  let client;

  beforeEach(function () {
    client = stompClient();
  });

  afterEach(async function () {
    await disconnectStomp(client);
  });

  it('Should receive messages sent to destination after subscribing', function (done) {
    const msg = 'Is anybody out there?';

    client.onConnect = function () {
      client.subscribe(TEST.destination, function (frame) {
        expect(frame.body).toEqual(msg);

        done();
      });

      client.publish({ destination: TEST.destination, body: msg });
    };
    client.activate();
  });

  it('Should tolerate exceptions thrown in a message handler', function (done) {
    const msg = 'Message';
    let numMessages = 0;

    client.onConnect = function () {
      client.subscribe(TEST.destination, function (frame) {
        numMessages++;
        // cause an unhandled exception
        throw new Error('Special Error');
      });

      client.publish({ destination: TEST.destination, body: msg });
      client.publish({ destination: TEST.destination, body: msg });

      setTimeout(() => {
        expect(numMessages).toBe(2);
        done();
      }, 1000);
    };
    client.activate();
  });

  it('Should receive messages with special chars in headers', function (done) {
    const msg = 'Is anybody out there?';
    const cust = 'f:o:o\nbar\rbaz\\foo\nbar\rbaz\\';

    client.onConnect = function () {
      // This is a test intended for version 1.2 of STOMP client
      if (client.connectedVersion !== StompJs.Versions.V1_2) {
        client.debug(
          `Skipping 1.2 specific test, current STOMP version: ${client.version}`
        );
        done();
        return;
      }

      client.subscribe(TEST.destination, function (frame) {
        expect(frame.body).toEqual(msg);
        expect(frame.headers.cust).toEqual(cust);

        done();
      });

      client.publish({
        destination: TEST.destination,
        headers: { cust: cust },
        body: msg,
      });
    };
    client.activate();
  });

  it('Should no longer receive messages after unsubscribing to destination', function (done) {
    const msg1 = 'Calling all cars!';
    let subscription1 = null,
      subscription2 = null;

    client.onConnect = function () {
      subscription1 = client.subscribe(TEST.destination, function (frame) {
        // Should not have received message
        expect(false).toBe(true);
      });

      subscription2 = client.subscribe(TEST.destination, function (frame) {
        expect(frame.body).toEqual(msg1);

        done();
      });

      subscription1.unsubscribe();
      client.publish({ destination: TEST.destination, body: msg1 });
    };
    client.activate();
  });
});