Add sign in mutation

Author: adzamkomladev

apps/main-service/src/app/@common/modules/global.module.ts

@@ -9,7 +9,10 @@ import { ApolloDriver, ApolloDriverConfig } from '@nestjs/apollo';
 import { join } from 'path';
 import type { ClientOpts } from 'redis';
 import * as redisStore from 'cache-manager-redis-store';
-import { ApolloServerPluginLandingPageLocalDefault } from 'apollo-server-core';
+import {
+  ApolloServerPluginSchemaReporting,
+  ApolloServerPluginLandingPageLocalDefault,
+} from 'apollo-server-core';
 import { MailerModule } from '@nestjs-modules/mailer';
 import { HandlebarsAdapter } from '@nestjs-modules/mailer/dist/adapters/handlebars.adapter';
 
@@ -64,7 +67,10 @@ import { Match } from '../validators/match.validator';
       driver: ApolloDriver,
       autoSchemaFile: true,
       playground: false,
-      plugins: [ApolloServerPluginLandingPageLocalDefault()],
+      plugins: [
+        ApolloServerPluginSchemaReporting(),
+        ApolloServerPluginLandingPageLocalDefault(),
+      ],
     }),
     MailerModule.forRoot({
       // transport: 'smtps://user@example.com:topsecret@smtp.example.com',

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

@@ -1,6 +1,7 @@
 import {
   BadRequestException,
   Injectable,
+  Logger,
   NotFoundException,
   UnauthorizedException,
 } from '@nestjs/common';
@@ -15,7 +16,9 @@ import { Profile } from '../profile/entities/profile.entity';
 import { UserVerification } from '../verification/entities/user-verification.entity';
 
 import { SignUpViaEmailInput } from './dto/sign-up-via-email.input';
+import { SignInViaEmailInput } from './dto/sign-in-via-email.input';
 import { SignedUpViaEmailOutput } from './dto/signed-up-via-email.output';
+import { SignedInViaEmailOutput } from './dto/signed-in-via-email.output';
 
 import { JwtPayload } from './interfaces/jwt-payload.interface';
 
@@ -25,6 +28,8 @@ import { UserSignedUpEvent } from './events/user-signed-up.event';
 
 @Injectable()
 export class AuthService {
+  private readonly logger: Logger;
+
   constructor(
     private readonly eventEmitter: EventEmitter2,
     private readonly jwtService: JwtService,
@@ -34,7 +39,9 @@ export class AuthService {
     private readonly profileRepository: Repository<Profile>,
     @InjectRepository(UserVerification)
     private readonly userVerificationRepository: Repository<UserVerification>
-  ) {}
+  ) {
+    this.logger = new Logger(AuthService.name);
+  }
 
   async signUpViaEmail(signUpViaEmailInput: SignUpViaEmailInput) {
     const queryRunner = this.dataSource.createQueryRunner();
@@ -77,20 +84,55 @@ export class AuthService {
     } catch (e) {
       await queryRunner.rollbackTransaction();
 
+      this.logger.error(e.message, e);
+
       throw new BadRequestException('Failed to sign up via email');
     } finally {
       await queryRunner.release();
     }
   }
 
+  async signInViaEmail(signInViaEmailInput: SignInViaEmailInput) {
+    try {
+      const { email, password } = signInViaEmailInput;
+
+      const user = await this.userRepository.findOne({
+        where: {
+          email,
+        },
+      });
+
+      if (!user || !(await user?.validatePassword(password))) {
+        throw new UnauthorizedException('Invalid user credentials');
+      }
+
+      const accessToken = await this.generateJwtToken(user);
+
+      return {
+        user,
+        auth: {
+          accessToken,
+        },
+      } as SignedInViaEmailOutput;
+    } catch (e) {
+      this.logger.error(e.message, e);
+
+      throw e instanceof UnauthorizedException
+        ? e
+        : new BadRequestException('Failed to sign in via email');
+    }
+  }
+
   async findUserById(id: string) {
     try {
       return await this.userRepository.findOneOrFail({
         where: {
           id,
         },
       });
-    } catch (error) {
+    } catch (e) {
+      this.logger.error(e.message, e);
+
       throw new NotFoundException('User not found!');
     }
   }
@@ -102,7 +144,9 @@ export class AuthService {
           id: payload.id,
         },
       });
-    } catch (error) {
+    } catch (e) {
+      this.logger.error(e.message, e);
+
       throw new NotFoundException('User not found!');
     }
   }
@@ -112,7 +156,9 @@ export class AuthService {
       const payload = this.jwtService.decode(jwt) as JwtPayload;
 
       return await this.findUserById(payload.id);
-    } catch (error) {
+    } catch (e) {
+      this.logger.error(e.message, e);
+
       throw new UnauthorizedException();
     }
   }

apps/main-service/src/app/auth/dto/sign-in-via-email.input.ts

@@ -0,0 +1,28 @@
+import { InputType, Field } from '@nestjs/graphql';
+
+import {
+  IsEmail,
+  IsNotEmpty,
+  IsString,
+  Matches,
+  MaxLength,
+  MinLength,
+} from 'class-validator';
+
+@InputType()
+export class SignInViaEmailInput {
+  @Field({ description: 'Email address to sign into account with' })
+  @IsNotEmpty()
+  @MaxLength(100)
+  @IsEmail()
+  readonly email: string;
+
+  @Field({ description: 'Password to sign into account with' })
+  @IsNotEmpty()
+  @IsString()
+  @MinLength(8)
+  @Matches(/((?=.*\d)|(?=.*\W+))(?![.\n])(?=.*[A-Z])(?=.*[a-z]).*$/, {
+    message: 'Password too weak',
+  })
+  readonly password: string;
+}

apps/main-service/src/app/auth/dto/signed-in-via-email.output.ts

@@ -0,0 +1,14 @@
+import { Field, ObjectType } from '@nestjs/graphql';
+
+import { User } from '../../users/entities/user.entity';
+
+import { AuthOutput } from './auth.output';
+
+@ObjectType()
+export class SignedInViaEmailOutput {
+  @Field(() => User, { description: 'User signed in' })
+  public user: User;
+
+  @Field(() => AuthOutput, { description: 'Auth options' })
+  public auth: AuthOutput;
+}

apps/main-service/src/app/auth/resolvers/auth.resolver.ts

@@ -1,7 +1,9 @@
 import { Resolver, Mutation, Args } from '@nestjs/graphql';
 
 import { SignUpViaEmailInput } from '../dto/sign-up-via-email.input';
+import { SignInViaEmailInput } from '../dto/sign-in-via-email.input';
 import { SignedUpViaEmailOutput } from '../dto/signed-up-via-email.output';
+import { SignedInViaEmailOutput } from '../dto/signed-in-via-email.output';
 
 import { AuthService } from '../auth.service';
 
@@ -16,4 +18,10 @@ export class AuthResolver {
     return this.authService.signUpViaEmail(signUpViaEmailInput);
   }
 
+  @Mutation(() => SignedInViaEmailOutput, { name: 'signInViaEmail' })
+  signInViaEmail(
+    @Args('signInViaEmailInput') signInViaEmailInput: SignInViaEmailInput
+  ) {
+    return this.authService.signInViaEmail(signInViaEmailInput);
+  }
 }

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

@@ -5,13 +5,13 @@ import { User } from '../users/entities/user.entity';
 
 import { VerifyEmailViaOtpInput } from './dto/verify-email-via-otp.input';
 import { VerifyPhoneViaOtpInput } from './dto/verify-phone-via-otp.input';
+import { SendOtpInput } from './dto/send-otp.input';
 
 import { CurrentUser } from '../@common/decorators/current-user.decorator';
 
 import { GqlAuthGuard } from '../@common/guards/gql-auth.guard';
 
 import { VerificationService } from './verification.service';
-import { SendOtpInput } from './dto/send-otp.input';
 
 @Resolver()
 @UseGuards(GqlAuthGuard)

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

@@ -87,19 +87,19 @@ export class VerificationService {
     verifyPhoneViaOtpInput: VerifyPhoneViaOtpInput,
     user: User
   ) {
-    const { code } = verifyPhoneViaOtpInput;
+    try {
+      const { code } = verifyPhoneViaOtpInput;
 
-    const res = await this.phoneVerificationService.verifyCode({
-      code,
-      number: user.phone,
-    });
+      const res = await this.phoneVerificationService.verifyCode({
+        code,
+        number: user.phone,
+      });
 
-    if (!res.success) {
-      this.logger.error(res);
-      throw new BadRequestException('OTP Code is not valid!');
-    }
+      if (!res.success) {
+        this.logger.error(res);
+        throw new BadRequestException('OTP Code is not valid!');
+      }
 
-    try {
       const fullUser = await this.userRepository.findOneOrFail({
         where: {
           id: user.id,
@@ -118,32 +118,44 @@ export class VerificationService {
     } catch (e) {
       this.logger.error(e.message, e);
 
-      throw new BadRequestException('Failed to verify phone via otp!');
+      throw e instanceof BadRequestException
+        ? e
+        : new BadRequestException('Failed to verify phone via otp!');
     }
   }
 
   async sendOtpForPhoneVerification(sendOtpInput: SendOtpInput, user: User) {
-    const { type } = sendOtpInput;
+    try {
+      const { type } = sendOtpInput;
 
-    const res = await this.phoneVerificationService.sendCode({
-      number: user.phone,
-      medium: type === OtpType.SMS ? 'sms' : 'voice',
-      message: `Your ${environment.app.name} phone number verification code is %otp_code%. Do not share this code with anyone. Visit your ${environment.app.name} account now to verify.`,
-    });
+      const res = await this.phoneVerificationService.sendCode({
+        number: user.phone,
+        medium: type === OtpType.SMS ? 'sms' : 'voice',
+        message: `Your ${environment.app.name} phone number verification code is %otp_code%. Do not share this code with anyone. Visit your ${environment.app.name} account now to verify.`,
+      });
 
-    if (!res.success) {
-      this.logger.error(res);
-      throw new BadRequestException(
-        'Failed to send OTP code. Please try again later!'
-      );
-    }
+      if (!res.success) {
+        this.logger.error(res);
+        throw new BadRequestException(
+          'Failed to send OTP code. Please try again later!'
+        );
+      }
 
-    return await this.userRepository.findOneOrFail({
-      where: {
-        id: user.id,
-      },
-      relations: ['profile', 'verification'],
-    });
+      return await this.userRepository.findOneOrFail({
+        where: {
+          id: user.id,
+        },
+        relations: ['profile', 'verification'],
+      });
+    } catch (e) {
+      this.logger.error(e.message, e);
+
+      throw e instanceof BadRequestException
+        ? e
+        : new BadRequestException(
+            'Failed to send OTP code. Please try again later!'
+          );
+    }
   }
 
   async sendOtpForEmailVerification(sendOtpInput: SendOtpInput, user: User) {
@@ -176,7 +188,8 @@ export class VerificationService {
 
       return fullUser;
     } catch (e) {
-      this.logger.error(e);
+      this.logger.error(e.message, e);
+
       throw new BadRequestException(
         'Failed to send OTP code. Please try again later!'
       );
@@ -191,6 +204,8 @@ export class VerificationService {
         },
       });
     } catch (e) {
+      this.logger.error(e.message, e);
+
       throw new NotFoundException('User Verification not found!');
     }
   }