2017-06-19 21:13:35 +08:00
|
|
|
import RedisPubSub from '/imports/startup/server/redis2x';
|
|
|
|
// import handleGetUsers from './handlers/getUsers';
|
|
|
|
import handleRemoveUser from './handlers/removeUser';
|
|
|
|
// import handleKickUser from './handlers/kickUser';
|
|
|
|
// import handlePresenterAssigned from './handlers/presenterAssigned';
|
|
|
|
// import handleEmojiStatus from './handlers/emojiStatus';
|
|
|
|
// import handleLockedStatusChange from './handlers/lockedStatusChange';
|
|
|
|
import handleUserJoined from './handlers/userJoined';
|
|
|
|
import handleValidateAuthToken from './handlers/validateAuthToken';
|
2017-06-21 01:17:37 +08:00
|
|
|
import handleVoiceUpdate from './handlers/voiceUpdate';
|
|
|
|
//import handleListeningOnly from './handlers/listeningOnly';
|
2017-06-19 21:13:35 +08:00
|
|
|
|
|
|
|
// RedisPubSub.on('validate_auth_token_reply', handleValidateAuthToken);
|
|
|
|
// RedisPubSub.on('get_users_reply', handleGetUsers);
|
|
|
|
RedisPubSub.on('UserJoinRespMsg', handleUserJoined);
|
|
|
|
// RedisPubSub.on('user_eject_from_meeting', handleKickUser);
|
|
|
|
// RedisPubSub.on('disconnect_user_message', handleRemoveUser);
|
|
|
|
RedisPubSub.on('UserLeaveRespMsg', handleRemoveUser);
|
|
|
|
// RedisPubSub.on('presenter_assigned_message', handlePresenterAssigned);
|
|
|
|
// RedisPubSub.on('user_emoji_status_message', handleEmojiStatus);
|
|
|
|
// RedisPubSub.on('user_locked_message', handleLockedStatusChange);
|
|
|
|
// RedisPubSub.on('user_unlocked_message', handleLockedStatusChange);
|
2017-06-21 01:17:37 +08:00
|
|
|
RedisPubSub.on('UserLeftVoiceConfToClientEvtMsg', handleVoiceUpdate);
|
|
|
|
RedisPubSub.on('UserJoinedVoiceConfToClientEvtMsg', handleVoiceUpdate);
|
|
|
|
//RedisPubSub.on('user_voice_talking_message', handleVoiceUpdate);
|
|
|
|
//RedisPubSub.on('user_voice_muted_message', handleVoiceUpdate);
|
|
|
|
//RedisPubSub.on('user_listening_only', handleListeningOnly);
|
2017-06-19 21:13:35 +08:00
|
|
|
RedisPubSub.on('ValidateAuthTokenRespMsg', handleValidateAuthToken);
|