import { model as User } from '../models/user'; import { getUserInfo } from './email'; import {sendNotification as sendPushNotification} from './pushNotifications'; export async function getAuthorEmailFromMessage (message) { let authorId = message.uuid; if (authorId === 'system') { return 'system'; } let author = await User.findOne({_id: authorId}, {auth: 1}).exec(); if (author) { return getUserInfo(author, ['email']).email; } else { return 'Author Account Deleted'; } } export async function sendChatPushNotifications (user, group, message, mentions, translate) { let members = await User.find({ 'party._id': group._id, _id: {$ne: user._id}, }) .select('preferences.pushNotifications preferences.language profile.name pushDevices auth.local.username') .exec(); members.forEach(member => { if (member.preferences.pushNotifications.partyActivity !== false) { if (mentions && mentions.includes(`@${member.auth.local.username}`) && member.preferences.pushNotifications.mentionParty !== false) { return; } sendPushNotification( member, { title: translate('groupActivityNotificationTitle', {user: message.user, group: group.name}, member.preferences.language), message: message.text, identifier: 'groupActivity', category: 'groupActivity', payload: {groupID: group._id, type: group.type, groupName: group.name, message: message.text, timestamp: message.timestamp, senderName: message.user}, } ); } }); }