2017-02-06 23:56:09 +08:00
|
|
|
import RedisPubSub from '/imports/startup/server/redis';
|
2017-02-24 01:45:51 +08:00
|
|
|
import handleGetUsers from './handlers/getUsers';
|
2017-02-23 01:49:44 +08:00
|
|
|
import handleRemoveUser from './handlers/removeUser';
|
2017-04-26 01:04:17 +08:00
|
|
|
import handleKickUser from './handlers/kickUser';
|
2017-02-23 01:49:44 +08:00
|
|
|
import handlePresenterAssigned from './handlers/presenterAssigned';
|
2017-02-23 02:59:47 +08:00
|
|
|
import handleEmojiStatus from './handlers/emojiStatus';
|
2017-02-24 01:45:51 +08:00
|
|
|
import handleLockedStatusChange from './handlers/lockedStatusChange';
|
2017-02-24 02:05:18 +08:00
|
|
|
import handleUserJoined from './handlers/userJoined';
|
2017-02-24 02:15:08 +08:00
|
|
|
import handleValidateAuthToken from './handlers/validateAuthToken';
|
2017-02-24 02:52:44 +08:00
|
|
|
import handleVoiceUpdate from './handlers/voiceUpdate';
|
|
|
|
import handleListeningOnly from './handlers/listeningOnly';
|
2017-02-06 23:56:09 +08:00
|
|
|
|
2017-02-24 02:15:08 +08:00
|
|
|
RedisPubSub.on('validate_auth_token_reply', handleValidateAuthToken);
|
2017-02-24 01:45:51 +08:00
|
|
|
RedisPubSub.on('get_users_reply', handleGetUsers);
|
2017-02-24 02:05:18 +08:00
|
|
|
RedisPubSub.on('user_joined_message', handleUserJoined);
|
2017-04-26 01:04:17 +08:00
|
|
|
RedisPubSub.on('user_eject_from_meeting', handleKickUser);
|
2017-02-23 01:49:44 +08:00
|
|
|
RedisPubSub.on('disconnect_user_message', handleRemoveUser);
|
|
|
|
RedisPubSub.on('user_left_message', handleRemoveUser);
|
|
|
|
RedisPubSub.on('presenter_assigned_message', handlePresenterAssigned);
|
2017-02-23 02:59:47 +08:00
|
|
|
RedisPubSub.on('user_emoji_status_message', handleEmojiStatus);
|
2017-02-24 01:45:51 +08:00
|
|
|
RedisPubSub.on('user_locked_message', handleLockedStatusChange);
|
|
|
|
RedisPubSub.on('user_unlocked_message', handleLockedStatusChange);
|
2017-02-24 02:52:44 +08:00
|
|
|
RedisPubSub.on('user_left_voice_message', handleVoiceUpdate);
|
|
|
|
RedisPubSub.on('user_joined_voice_message', handleVoiceUpdate);
|
|
|
|
RedisPubSub.on('user_voice_talking_message', handleVoiceUpdate);
|
|
|
|
RedisPubSub.on('user_voice_muted_message', handleVoiceUpdate);
|
|
|
|
RedisPubSub.on('user_listening_only', handleListeningOnly);
|