44 lines
1.5 KiB
JavaScript
44 lines
1.5 KiB
JavaScript
import { publish } from '/server/redispubsub';
|
|
import { isAllowedTo } from '/server/user_permissions';
|
|
import { appendMessageHeader } from '/server/helpers';
|
|
|
|
Meteor.methods({
|
|
// meetingId: the id of the meeting
|
|
// chatObject: the object including info on the chat message, including the text
|
|
// requesterUserId: the userId of the user sending chat
|
|
// requesterToken: the authToken of the requester
|
|
sendChatMessagetoServer(meetingId, chatObject, requesterUserId, requesterToken) {
|
|
let action, chatType, eventName, message, recipient;
|
|
chatType = chatObject.chat_type;
|
|
recipient = chatObject.to_userid;
|
|
eventName = null;
|
|
action = function () {
|
|
if (chatType === 'PUBLIC_CHAT') {
|
|
eventName = 'send_public_chat_message';
|
|
return 'chatPublic';
|
|
} else {
|
|
eventName = 'send_private_chat_message';
|
|
if (recipient === requesterUserId) {
|
|
return 'chatSelf'; //not allowed
|
|
} else {
|
|
return 'chatPrivate';
|
|
}
|
|
}
|
|
};
|
|
|
|
if (isAllowedTo(action(), meetingId, requesterUserId, requesterToken) && chatObject.from_userid === requesterUserId) {
|
|
chatObject.message = translateHTML5ToFlash(chatObject.message);
|
|
message = {
|
|
payload: {
|
|
message: chatObject,
|
|
meeting_id: meetingId,
|
|
requester_id: chatObject.from_userid,
|
|
},
|
|
};
|
|
message = appendMessageHeader(eventName, message);
|
|
Meteor.log.info('publishing chat to redis');
|
|
publish(Meteor.config.redis.channels.toBBBApps.chat, message);
|
|
}
|
|
}
|
|
});
|