upstream-rocketchat/apps/meteor/server/api/v1/mailer.ts

import {
	ajv,
	isMailerProps,
	isMailerUnsubscribeProps,
	validateUnauthorizedErrorResponse,
	validateForbiddenErrorResponse,
	validateBadRequestErrorResponse,
} from '@rocket.chat/rest-typings';

import { sendMail } from '../../lib/notifications/mail-messages/functions/sendMail';
import { Mailer } from '../../lib/notifications/mail-messages/lib/Mailer';
import { API } from '../api';

const mailerResponseSchema = ajv.compile<void>({
	type: 'object',
	properties: {
		success: { type: 'boolean', enum: [true] },
	},
	required: ['success'],
	additionalProperties: true,
});

const mailerUnsubscribeResponseSchema = ajv.compile<void>({
	type: 'object',
	properties: {
		success: { type: 'boolean', enum: [true] },
	},
	required: ['success'],
	additionalProperties: false,
});

API.v1.post(
	'mailer',
	{
		authRequired: true,
		body: isMailerProps,
		permissionsRequired: ['send-mail'],
		response: {
			200: mailerResponseSchema,
			400: validateBadRequestErrorResponse,
			401: validateUnauthorizedErrorResponse,
			403: validateForbiddenErrorResponse,
		},
	},
	async function action() {
		const { from, subject, body, dryrun, query } = this.bodyParams;

		const result = await sendMail({ from, subject, body, dryrun: Boolean(dryrun), query });

		return API.v1.success(result);
	},
);

API.v1.post(
	'mailer.unsubscribe',
	{
		authRequired: true,
		body: isMailerUnsubscribeProps,
		rateLimiterOptions: { intervalTimeInMS: 60000, numRequestsAllowed: 1 },
		response: {
			200: mailerUnsubscribeResponseSchema,
			401: validateUnauthorizedErrorResponse,
		},
	},
	async function action() {
		const { _id, createdAt } = this.bodyParams;

		await Mailer.unsubscribe(_id, createdAt);

		return API.v1.success();
	},
);