48 lines
1.2 KiB
JavaScript
48 lines
1.2 KiB
JavaScript
import flat from 'flat';
|
|
import { Match, check } from 'meteor/check';
|
|
import Logger from '/imports/startup/server/logger';
|
|
import GroupChat from '/imports/api/group-chat';
|
|
|
|
export default async function addGroupChat(meetingId, chat) {
|
|
check(meetingId, String);
|
|
check(chat, {
|
|
id: Match.Maybe(String),
|
|
chatId: Match.Maybe(String),
|
|
correlationId: Match.Maybe(String),
|
|
access: String,
|
|
createdBy: Object,
|
|
users: Array,
|
|
msg: Match.Maybe(Array),
|
|
});
|
|
|
|
const chatDocument = {
|
|
meetingId,
|
|
chatId: chat.chatId || chat.id,
|
|
access: chat.access,
|
|
users: chat.users.map((u) => u.id),
|
|
participants: chat.users,
|
|
createdBy: chat.createdBy.id,
|
|
};
|
|
|
|
const selector = {
|
|
chatId: chatDocument.chatId,
|
|
meetingId,
|
|
};
|
|
|
|
const modifier = {
|
|
$set: flat(chatDocument, { safe: true }),
|
|
};
|
|
|
|
try {
|
|
const { insertedId } = await GroupChat.upsertAsync(selector, modifier);
|
|
|
|
if (insertedId) {
|
|
Logger.info(`Added group-chat chatId=${chatDocument.chatId} meetingId=${meetingId}`);
|
|
} else {
|
|
Logger.info(`Upserted group-chat chatId=${chatDocument.chatId} meetingId=${meetingId}`);
|
|
}
|
|
} catch (err) {
|
|
Logger.error(`Adding group-chat to collection: ${err}`);
|
|
}
|
|
}
|