RocketChat/Rocket.Chat

import { Settings } from '@rocket.chat/models';
import { check } from 'meteor/check';
import { Meteor } from 'meteor/meteor';

import { hasPermissionAsync } from '../../../authorization/server/functions/hasPermission';
import { notifyOnSettingChanged } from '../../../lib/server/lib/notifyListener';
import * as Mailer from '../../../mailer/server/api';
import { settings } from '../../../settings/server';

let html = '';
Meteor.startup(() => {
    Mailer.getTemplate('Invitation_Email', (value) => {
        html = value;
    });
});

export const sendInvitationEmail = async (userId: string, emails: string[]) => {
    check(emails, [String]);
    if (!userId) {
        throw new Meteor.Error('error-invalid-user', 'Invalid user', {
            method: 'sendInvitationEmail',
        });
    }
    if (!(await hasPermissionAsync(userId, 'bulk-register-user'))) {
        throw new Meteor.Error('error-not-allowed', 'Not allowed', {
            method: 'sendInvitationEmail',
        });
    }
    const validEmails = emails.filter(Mailer.checkAddressFormat);

    if (!validEmails || validEmails.length === 0) {
        throw new Meteor.Error('error-email-send-failed', 'No valid email addresses', {
            method: 'sendInvitationEmail',
        });
    }

    const subject = settings.get<string>('Invitation_Subject');

    if (!subject) {
        throw new Meteor.Error('error-email-send-failed', 'No subject', {
            method: 'sendInvitationEmail',
        });
    }

    for await (const email of validEmails) {
        try {
            await Mailer.send({
                to: email,
                from: settings.get('From_Email'),
                subject,
                html,
                data: {
                    email,
                },
            });

            const { value } = await Settings.incrementValueById('Invitation_Email_Count', 1, { returnDocument: 'after' });
            if (value) {
                void notifyOnSettingChanged(value);
            }

            continue;
        } catch ({ message }: any) {
            throw new Meteor.Error('error-email-send-failed', `Error trying to send email: ${message}`, {
                method: 'sendInvitationEmail',
                message,
            });
        }
    }
};