feat: Otp email bridge

apps/meteor/app/apps/server/bridges/bridges.js

@@ -5,6 +5,7 @@ import { AppApisBridge } from './api';
 import { AppCloudBridge } from './cloud';
 import { AppCommandsBridge } from './commands';
 import { AppDetailChangesBridge } from './details';
+import { AppEmailBridge } from './email';
 import { AppEnvironmentalVariableBridge } from './environmental';
 import { AppHttpBridge } from './http';
 import { AppInternalBridge } from './internal';
@@ -42,6 +43,7 @@ export class RealAppBridges extends AppBridges {
 		this._internalBridge = new AppInternalBridge(orch);
 		this._setsBridge = new AppSettingBridge(orch);
 		this._userBridge = new AppUserBridge(orch);
+		this._emailBridge = new AppEmailBridge(orch);
 		this._livechatBridge = new AppLivechatBridge(orch);
 		this._uploadBridge = new AppUploadBridge(orch);
 		this._uiInteractionBridge = new UiInteractionBridge(orch);
@@ -119,6 +121,10 @@ export class RealAppBridges extends AppBridges {
 		return this._uploadBridge;
 	}
 
+	getEmailBridge() {
+		return this._emailBridge;
+	}
+
 	getUiInteractionBridge() {
 		return this._uiInteractionBridge;
 	}

apps/meteor/app/apps/server/bridges/email.ts

@@ -0,0 +1,16 @@
+import type { IAppServerOrchestrator } from '@rocket.chat/apps';
+import { EmailBridge } from '@rocket.chat/apps-engine/server/bridges/EmailBridge';
+import type { IEmail } from '@rocket.chat/apps-engine/server/definitions/email';
+
+import * as Mailer from '../../../mailer/server/api';
+
+export class AppEmailBridge extends EmailBridge {
+	constructor(private readonly orch: IAppServerOrchestrator) {
+		super();
+	}
+
+	protected async sendEmail(email: IEmail, appId: string): Promise<void> {
+		this.orch.debugLog(`The app: ${appId} is requesting an OTP code to be sent to: ${email}`);
+		await Mailer.send(email);
+	}
+}

apps/meteor/app/livechat/server/lib/Contacts.ts

@@ -58,6 +58,12 @@ type UpdateContactParams = {
 	channels?: ILivechatContactChannel[];
 };
 
+type ContactOTPCodeInfo = {
+	code: string;
+	expiresAt: Date;
+	attempts: number;
+};
+
 export const Contacts = {
 	async registerContact({
 		token,
@@ -278,3 +284,15 @@ export async function validateContactManager(user: Pick<IUser, 'roles'> | null)
 		throw new Error('error-contact-manager-not-found');
 	}
 }
+
+export async function addEmailCodeByContactEmail(email: string, channel: string, code: string, expiresAt: Date): Promise<any> {
+	throw new Error('addEmailCodeByContactEmail: implement');
+}
+
+export async function findContactCodeFromChannelAndEmail(email: string, channel: string): Promise<ContactOTPCodeInfo> {
+	throw new Error('findContactCodeFromChannelAndEmail: implement');
+}
+
+export async function incrementInvalidEmailCodeAttemptByVerifyingMethod(email: string, channel: string): Promise<any> {
+	throw new Error('incrementInvalidEmailCodeAttemptByVerifyingMethod: implement');
+}