Add sending otp to validate user email

Author: adzamkomladev

apps/main-service/src/app/verification/verification.resolver.ts

@@ -53,4 +53,16 @@ export class VerificationResolver {
       user
     );
   }
+
+  @Mutation(() => User, { name: 'sendOtpForEmailVerification' })
+  sendOtpForEmailVerification(
+    @CurrentUser() user: User,
+    @Args('sendOtpInput')
+      sendOtpInput: SendOtpInput
+  ) {
+    return this.verificationService.sendOtpForEmailVerification(
+      sendOtpInput,
+      user
+    );
+  }
 }

apps/main-service/src/app/verification/verification.service.ts

@@ -7,19 +7,26 @@ import {
   NotFoundException,
 } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
+import { InjectQueue } from '@nestjs/bull';
 
 import { Cache } from 'cache-manager';
 import { Repository } from 'typeorm';
+import { Queue } from 'bull';
+
+import { PhoneVerificationService } from '@laze/nestjs-phone-verification';
+
+import { environment } from '../../environments/environment';
 
 import { User } from '../users/entities/user.entity';
 import { UserVerification } from './entities/user-verification.entity';
 
+import { OtpType } from './enums/otp-type.enum';
+
+import { SendOtpInput } from './dto/send-otp.input';
 import { VerifyEmailViaOtpInput } from './dto/verify-email-via-otp.input';
 import { VerifyPhoneViaOtpInput } from './dto/verify-phone-via-otp.input';
-import { PhoneVerificationService } from '@laze/nestjs-phone-verification';
-import { SendOtpInput } from './dto/send-otp.input';
-import { OtpType } from './enums/otp-type.enum';
-import { environment } from '../../environments/environment';
+import { Email } from '../@common/interfaces/jobs/email.interface';
+import { TokenGenerationService } from '../@common/services/token-generation.service';
 
 @Injectable()
 export class VerificationService {
@@ -28,10 +35,12 @@ export class VerificationService {
   constructor(
     @Inject(CACHE_MANAGER) private readonly cache: Cache,
     private readonly phoneVerificationService: PhoneVerificationService,
+    private readonly tokenGenerationService: TokenGenerationService,
     @InjectRepository(UserVerification)
     private readonly userVerificationRepository: Repository<UserVerification>,
     @InjectRepository(User)
-    private readonly userRepository: Repository<User>
+    private readonly userRepository: Repository<User>,
+    @InjectQueue('email') private readonly emailQueue: Queue
   ) {
     this.logger = new Logger(VerificationService.name);
   }
@@ -137,6 +146,43 @@ export class VerificationService {
     });
   }
 
+  async sendOtpForEmailVerification(sendOtpInput: SendOtpInput, user: User) {
+    try {
+      const { type } = sendOtpInput;
+
+      const otp = '' + this.tokenGenerationService.generateOtp(6);
+      await this.cache.set(`users.${user.id}.otp.${type}`, otp, {
+        ttl: 600,
+      });
+
+      const fullUser = await this.userRepository.findOneOrFail({
+        where: {
+          id: user.id,
+        },
+        relations: ['profile', 'verification'],
+      });
+
+      const job: Email = {
+        receiver: user.email,
+        subject: `${environment.app.name} Email Verification`,
+        template: './auth/email-otp',
+        data: {
+          name: `${fullUser.profile.name.first} ${fullUser.profile.name.last}`,
+          otp,
+        },
+      };
+
+      await this.emailQueue.add(job);
+
+      return fullUser;
+    } catch (e) {
+      this.logger.error(e);
+      throw new BadRequestException(
+        'Failed to send OTP code. Please try again later!'
+      );
+    }
+  }
+
   async findUserVerificationById(id: number) {
     try {
       return await this.userVerificationRepository.findOneOrFail({