bigbluebutton-Github/bigbluebutton-html5/imports/api/breakouts/server/handlers/breakoutJoinURL.js

import Breakouts from '/imports/api/breakouts';
import Logger from '/imports/startup/server/logger';
import { check } from 'meteor/check';
import RedisPubSub from '/imports/startup/server/redis';
import { XMLHttpRequest } from 'xmlhttprequest';
import xml2js from 'xml2js';
const xmlParser = new xml2js.Parser();

const getUrlParams = url => {
  let urlParams = {};
  url.split('?')[1].split('&').map(s => {
    const p = s.split('=');
    urlParams[p[0]] = p[1];
  });

  return urlParams;
};

export default function breakoutJoinURL({ payload }) {
  const REDIS_CONFIG = Meteor.settings.redis;

  const {
    joinURL,
  } = payload;

  check(joinURL, String);

  const urlParams = getUrlParams(joinURL);

  const selector = {
    externalMeetingId: urlParams.meetingID,
  };

  let breakout = Breakouts.findOne(selector);

  if (urlParams.redirect !== 'false') {
    const MessageContent = {
      breakoutMeetingId: breakout.externalMeetingId,
      meetingId: breakout.parentMeetingId,
      redirect: false,
      userId: payload.userId,
    };

    const CHANNEL = REDIS_CONFIG.channels.toBBBApps.users;
    const eventName = 'RequestBreakoutJoinURL';

    return RedisPubSub.publish(CHANNEL, eventName, MessageContent);
  } else {
    const res = Meteor.http.call('get', joinURL);
    xmlParser.parseString(res.content, (err, parsedXML) => {
      breakout = Breakouts.findOne(selector);

      const { response } = parsedXML;
      let users = breakout.users;

      let user = {
        userId: payload.userId,
        urlParams: {
          meetingId: response.meeting_id[0],
          userId: response.user_id[0],
          authToken: response.auth_token[0],
        },
      };

      const userExists = users.find(u => user.userId === u.userId);

      if (userExists) {
        return;
      }

      const modifier = {
        $push: {
          users: user,
        },
      };

      const cb = (err, numChanged) => {
        if (err) {
          return Logger.error(`Adding breakout to collection: ${err}`);
        }

        const {
          insertedId,
        } = numChanged;
        if (insertedId) {
          return Logger.info(`Added breakout id=${urlParams.meetingID}`);
        }

        return Logger.info(`Upserted breakout id=${urlParams.meetingID}`);
      };

      return Breakouts.upsert(selector, modifier, cb);
    });
  }
}