115 lines
2.8 KiB
JavaScript
115 lines
2.8 KiB
JavaScript
import flat from 'flat';
|
|
import { check } from 'meteor/check';
|
|
import Meetings from '/imports/api/meetings';
|
|
import Logger from '/imports/startup/server/logger';
|
|
|
|
import addGroupChatMsg from '/imports/api/group-chat-msg/server/modifiers/addGroupChatMsg';
|
|
|
|
export default function addMeeting(meeting) {
|
|
const meetingId = meeting.meetingProp.intId;
|
|
const CHAT_CONFIG = Meteor.settings.public.chat;
|
|
const PUBLIC_CHAT_SYSTEM_ID = CHAT_CONFIG.system_userid;
|
|
const PUBLIC_GROUP_CHAT_ID = CHAT_CONFIG.public_group_id;
|
|
|
|
check(meetingId, String);
|
|
check(meeting, {
|
|
breakoutProps: {
|
|
sequence: Number,
|
|
freeJoin: Boolean,
|
|
breakoutRooms: Array,
|
|
parentId: String,
|
|
},
|
|
meetingProp: {
|
|
intId: String,
|
|
extId: String,
|
|
isBreakout: Boolean,
|
|
name: String,
|
|
},
|
|
usersProp: {
|
|
webcamsOnlyForModerator: Boolean,
|
|
guestPolicy: String,
|
|
maxUsers: Number,
|
|
},
|
|
durationProps: {
|
|
createdTime: Number,
|
|
duration: Number,
|
|
createdDate: String,
|
|
maxInactivityTimeoutMinutes: Number,
|
|
warnMinutesBeforeMax: Number,
|
|
meetingExpireIfNoUserJoinedInMinutes: Number,
|
|
meetingExpireWhenLastUserLeftInMinutes: Number,
|
|
userInactivityInspectTimerInMinutes: Number,
|
|
userInactivityThresholdInMinutes: Number,
|
|
userActivitySignResponseDelayInMinutes: Number,
|
|
},
|
|
welcomeProp: {
|
|
welcomeMsg: String,
|
|
modOnlyMessage: String,
|
|
welcomeMsgTemplate: String,
|
|
},
|
|
recordProp: {
|
|
allowStartStopRecording: Boolean,
|
|
autoStartRecording: Boolean,
|
|
record: Boolean,
|
|
},
|
|
password: {
|
|
viewerPass: String,
|
|
moderatorPass: String,
|
|
},
|
|
voiceProp: {
|
|
voiceConf: String,
|
|
dialNumber: String,
|
|
telVoice: String,
|
|
muteOnStart: Boolean,
|
|
},
|
|
screenshareProps: {
|
|
red5ScreenshareIp: String,
|
|
red5ScreenshareApp: String,
|
|
screenshareConf: String,
|
|
},
|
|
metadataProp: Object,
|
|
});
|
|
|
|
const selector = {
|
|
meetingId,
|
|
};
|
|
|
|
const modifier = {
|
|
$set: Object.assign(
|
|
{ meetingId },
|
|
flat(meeting, { safe: true }),
|
|
),
|
|
};
|
|
|
|
const welcomeMsg = {
|
|
color: '0',
|
|
timestamp: Date.now(),
|
|
correlationId: `${PUBLIC_CHAT_SYSTEM_ID}-${Date.now()}`,
|
|
sender: {
|
|
id: PUBLIC_CHAT_SYSTEM_ID,
|
|
name: '',
|
|
},
|
|
message: meeting.welcomeProp.welcomeMsg,
|
|
};
|
|
|
|
addGroupChatMsg(meetingId, PUBLIC_GROUP_CHAT_ID, welcomeMsg);
|
|
|
|
const cb = (err, numChanged) => {
|
|
if (err) {
|
|
Logger.error(`Adding meeting to collection: ${err}`);
|
|
return;
|
|
}
|
|
|
|
const { insertedId } = numChanged;
|
|
if (insertedId) {
|
|
Logger.info(`Added meeting id=${meetingId}`);
|
|
}
|
|
|
|
if (numChanged) {
|
|
Logger.info(`Upserted meeting id=${meetingId}`);
|
|
}
|
|
};
|
|
|
|
return Meetings.upsert(selector, modifier, cb);
|
|
}
|