bigbluebutton-Github/bigbluebutton-tests/puppeteer/events/trigger.js

const Page = require('../core/page');
const { exec } = require("child_process");
const { CLIENT_RECONNECTION_TIMEOUT } = require('../core/constants'); // core constants (Timeouts vars imported)
const { sleep } = require('../core/helper');
const e = require('../core/elements');
const { checkElementLengthDifferentTo } = require('../core/util');

class Trigger extends Page {
  constructor() {
    super();
  }

  async triggerMeteorDisconnect(testName) {
    try {
      await this.screenshot(`${testName}`, `01-before-audio-modal-close-[${this.meetingId}]`);

      await this.closeAudioModal();
      await this.screenshot(`${testName}`, `02-after-audio-modal-close-[${this.meetingId}]`);

      await sleep(5000);
      await this.page.evaluate(() => Meteor.disconnect());
      await this.screenshot(`${testName}`, `03-after-meteor-disconnection-[${this.meetingId}]`);

      await sleep(CLIENT_RECONNECTION_TIMEOUT);
      const meteorStatus = await this.page.evaluate(() => Meteor.status());
      const meteorStatusConfirm = await meteorStatus.status === "offline";
      await this.logger('Check if Meteor is Offline => ', meteorStatusConfirm);
      const getAudioButton = await this.page.evaluate((joinAudioSelector) => {
        return document.querySelectorAll(joinAudioSelector)[0].getAttribute('aria-disabled') === "true";
      }, e.joinAudio);
      await this.logger('Check if Connections Buttons are disabled => ', getAudioButton);
      await this.page.evaluate(() => Meteor.reconnect());
      await sleep(3000);
      await this.screenshot(`${testName}`, `04-after-meteor-reconnection-[${this.meetingId}]`);

      const findUnauthorized = await this.page.evaluate(checkElementLengthDifferentTo, e.unauthorized, 0) === true;
      await this.logger('Check if Unauthorized message appears => ', findUnauthorized);
      return meteorStatusConfirm && getAudioButton && findUnauthorized;
    } catch (err) {
      await this.logger(err);
      return false;
    }
  }

  async triggerNetworkServiceDisconnection(testName) {
    try {
      await this.screenshot(`${testName}`, `01-before-audio-modal-close-[${this.meetingId}]`);

      await this.closeAudioModal();
      await this.screenshot(`${testName}`, `02-after-audio-modal-close-[${this.meetingId}]`);

      await sleep(5000);
      await this.logger('Stopping Network Service...');
      await exec('sh events/stop-network.sh', async (error, data, getter) => {
        if (error) {
          await this.logger("error", error.message);
          return;
        }
        if (getter) {
          await this.logger("data", data);
          return;
        }
        await this.logger("data", data);
      });
      const meteorStatus = await this.page.evaluate(() => Meteor.status());
      const meteorStatusConfirm = await meteorStatus.status === "offline";
      await this.logger('Check if Meteor is Offline => ', meteorStatusConfirm);
      await this.screenshot(`${testName}`, `03-after-network-service-shutdown-[${this.meetingId}]`);

      await this.logger('Counting ', CLIENT_RECONNECTION_TIMEOUT / 6000, ' seconds...');
      await sleep(CLIENT_RECONNECTION_TIMEOUT);
      await this.logger('Restarting Network Service...');
      await exec('sh events/restart-network.sh', async (error, data, getter) => {
        if (error) {
          await this.logger("error", error.message);
          return;
        }
        if (getter) {
          await this.logger("data", data);
          return;
        }
        await this.logger("data", data);
      });
      await this.screenshot(`${testName}`, `04-after-network-service-restart-[${this.meetingId}]`);

      await this.page.reload();
      await this.closeAudioModal();
      const getAudioButton = await this.page.evaluate((joinAudioSelector) => {
        return document.querySelectorAll(joinAudioSelector)[0].getAttribute('aria-disabled') === "true";
      }, e.joinAudio)
      await this.logger('Check if Connections Buttons are disabled => ', getAudioButton);
      await sleep(3000);
      const findUnauthorized = await this.page.evaluate(checkElementLengthDifferentTo, e.unauthorized, 0) === true;
      await this.logger('Check if Unauthorized message appears => ', findUnauthorized);
      return meteorStatusConfirm && getAudioButton && findUnauthorized;
    } catch (err) {
      await this.logger(err);
      return false;
    }
  }
}

module.exports = exports = Trigger;