diff --git a/libraries/nestjs-libraries/src/services/email.service.ts b/libraries/nestjs-libraries/src/services/email.service.ts index 618c2b9e..c78326b5 100644 --- a/libraries/nestjs-libraries/src/services/email.service.ts +++ b/libraries/nestjs-libraries/src/services/email.service.ts @@ -3,6 +3,7 @@ import { EmailInterface } from '@gitroom/nestjs-libraries/emails/email.interface import { ResendProvider } from '@gitroom/nestjs-libraries/emails/resend.provider'; import { EmptyProvider } from '@gitroom/nestjs-libraries/emails/empty.provider'; import { NodeMailerProvider } from '@gitroom/nestjs-libraries/emails/node.mailer.provider'; +import { concurrencyService } from '@gitroom/helpers/utils/concurrency.service'; @Injectable() export class EmailService { @@ -95,13 +96,15 @@ export class EmailService { `; - const sends = await this.emailService.sendEmail( - to, - subject, - modifiedHtml, - process.env.EMAIL_FROM_NAME, - process.env.EMAIL_FROM_ADDRESS, - replyTo + const sends = await concurrencyService('send-email', () => + this.emailService.sendEmail( + to, + subject, + modifiedHtml, + process.env.EMAIL_FROM_NAME, + process.env.EMAIL_FROM_ADDRESS, + replyTo + ) ); console.log(sends); }