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,
			});
		}
	}
};