bigbluebutton-Github/bigbluebutton-html5/imports/api/users/server/modifiers/eventHandlers.js

import { logger } from '/imports/startup/server/logger';
import { eventEmitter } from '/imports/startup/server';
import { userJoined } from './userJoined';
import { setUserLockedStatus } from './setUserLockedStatus';
import { markUserOffline } from './markUserOffline';
import { inReplyToHTML5Client } from '/imports/api/common/server/helpers';
import Users from '../..';

eventEmitter.on('user_eject_from_meeting', function (arg) {
  handleRemoveUserEvent(arg);
});

eventEmitter.on('disconnect_user_message', function (arg) {
  handleRemoveUserEvent(arg);
});

eventEmitter.on('user_left_message', function (arg) {
  handleRemoveUserEvent(arg);
});

eventEmitter.on('validate_auth_token_reply', function (arg) {
  const meetingId = arg.payload.meeting_id;
  const userId = arg.payload.userid;
  const user = Users.findOne({
    userId: userId,
    meetingId: meetingId,
  });
  const validStatus = arg.payload.valid;

  // if the user already exists in the db
  if (user != null && user.clientType === 'HTML5') {
    //if the html5 client user was validated successfully, add a flag
    return Users.update({
      userId: userId,
      meetingId: meetingId,
    }, {
      $set: {
        validated: validStatus,
      },
    }, (err, numChanged) => {
      if (numChanged.insertedId != null) {
        let funct = function (cbk) {
          let user = Users.findOne({
            userId: userId,
            meetingId: meetingId,
          });
          let val;
          if (user != null) {
            val = user.validated;
          }

          logger.info(`user.validated for ${userId} in meeting ${meetingId} just became ${val}`);
          return cbk();
        };

        return funct(arg.callback);
      } else {
        return arg.callback();
      }
    });
  } else {
    logger.info('a non-html5 user got validate_auth_token_reply.');
    return arg.callback();
  }
});

eventEmitter.on('user_joined_message', function (arg) {
  const meetingId = arg.payload.meeting_id;
  const payload = arg.payload;
  let userObj = payload.user;
  let dbUser = Users.findOne({
    userId: userObj.userid,
    meetingId: meetingId,
  });

  // On attempting reconnection of Flash clients (in voiceBridge) we receive
  // an extra user_joined_message. Ignore it as it will add an extra user
  // in the user list, creating discrepancy with the list in the Flash client
  if (dbUser != null && dbUser.user != null && dbUser.user.connection_status === 'offline') {
    if (payload.user != null && payload.user.phone_user) {
      logger.error('offline AND phone user');
      return arg.callback(); //return without joining the user
    }
  } else {
    if (dbUser != null && dbUser.clientType === 'HTML5') {
      // typically html5 users will be in
      // the db [as a dummy user] before the joining message
      let status = dbUser.validated;
      logger.info(`in user_joined_message the validStatus of the user was ${status}`);
      userObj.timeOfJoining = arg.header.current_time;
    }

    return userJoined(meetingId, userObj, arg.callback);
  }

  return arg.callback();
});

eventEmitter.on('get_users_reply', function (arg) {
  if (inReplyToHTML5Client(arg)) {
    let users = arg.payload.users;
    const meetingId = arg.payload.meeting_id;

    //TODO make the serialization be split per meeting. This will allow us to
    // use N threads vs 1 and we'll take advantage of Mongo's concurrency tricks

    // Processing the users recursively with a callback to notify us,
    // ensuring that we update the users collection serially
    let processUser = function () {
      let user = users.pop();
      if (user != null) {
        user.timeOfJoining = arg.header.current_time;
        if (user.emoji_status !== 'none' && typeof user.emoji_status === 'string') {
          user.set_emoji_time = new Date();
          return userJoined(meetingId, user, processUser);
        } else {
          return userJoined(meetingId, user, processUser);
        }
      } else {
        return arg.callback(); // all meeting arrays (if any) have been processed
      }
    };

    return processUser();
  } else {
    arg.callback();
  }
});

eventEmitter.on('user_emoji_status_message', function (arg) {
  const userId = arg.payload.userid;
  const meetingId = arg.payload.meeting_id;
  const emojiStatus = arg.payload.emoji_status;
  if (userId != null && meetingId != null) {
    const setEmojiTime = new Date();
    Users.update({
      'user.userid': userId,
    }, {
      $set: {
        'user.set_emoji_time': setEmojiTime,
        'user.emoji_status': emojiStatus,
      },
    }, (err, numUpdated) => logger.info(` Updating emoji numUpdated=${numUpdated}, err=${err}`));
  }

  return arg.callback();
});

eventEmitter.on('user_locked_message', function (arg) {
  handleLockEvent(arg);
});

eventEmitter.on('user_unlocked_message', function (arg) {
  handleLockEvent(arg);
});

eventEmitter.on('presenter_assigned_message', function (arg) {
  const meetingId = arg.payload.meeting_id;
  const newPresenterId = arg.payload.new_presenter_id;
  if (newPresenterId != null) {
    // reset the previous presenter
    Users.update({
      'user.presenter': true,
      meetingId: meetingId,
    }, {
      $set: {
        'user.presenter': false,
      },
    }, (err, numUpdated) => logger.info(
      ` Updating old presenter numUpdated=${numUpdated}, ` +
      ` err=${err}`
      )
    );

    // set the new presenter
    Users.update({
      'user.userid': newPresenterId,
      meetingId: meetingId,
    }, {
      $set: {
        'user.presenter': true,
      },
    }, (err, numUpdated) => logger.info(
      ` Updating new presenter numUpdated=${numUpdated}, ` +
      `err=${err}`
      )
    );
  }

  return arg.callback();
});

const handleRemoveUserEvent = function (arg) {
  const { payload, callback } = arg;
  if ((payload.userid || payload.user.userid) &&
    payload.meeting_id) {
    const meetingId = payload.meeting_id;
    const userId = payload.userid || payload.user.userid;
    return markUserOffline(meetingId, userId, callback);
  } else {
    logger.info('could not perform handleRemoveUserEvent');
    return callback();
  }
};

const handleLockEvent = function (arg) {
  const userId = arg.payload.userid;
  const isLocked = arg.payload.locked;
  const meetingId = arg.payload.meeting_id;
  setUserLockedStatus(meetingId, userId, isLocked);
  return arg.callback();
};