feat: bulk delete users (#600)

src/partner-admin/super-admin-auth.guard.ts

@@ -57,7 +57,7 @@ export class SuperAdminAuthGuard implements CanActivate {
       );
     }
     try {
-      const user = await this.userRepository.findOneBy({ firebaseUid: userUid });
+      const user = await this.userRepository.findOneByOrFail({ firebaseUid: userUid });
       request['userEntity'] = user;
       return !!user.isSuperAdmin && user.email.indexOf('@chayn.co') !== -1;
     } catch (error) {

src/user/user.controller.ts

@@ -58,6 +58,13 @@ export class UserController {
     return await this.userService.deleteUser(req['user'].user as UserEntity);
   }
 
+  @ApiBearerAuth('access-token')
+  @Delete('/bulk-delete')
+  @UseGuards(SuperAdminAuthGuard)
+  async bulkDeleteUsers(): Promise<UserEntity[]> {
+    return await this.userService.bulkDeleteUsers();
+  }
+
   // This route must go before the Delete user route below as we want nestjs to check against this one first
   @ApiBearerAuth('access-token')
   @Delete('/cypress')

src/user/user.service.ts

@@ -9,7 +9,7 @@ import { Logger } from 'src/logger/logger';
 import { ServiceUserProfilesService } from 'src/service-user-profiles/service-user-profiles.service';
 import { SubscriptionUserService } from 'src/subscription-user/subscription-user.service';
 import { TherapySessionService } from 'src/therapy-session/therapy-session.service';
-import { SIGNUP_TYPE } from 'src/utils/constants';
+import { isProduction, SIGNUP_TYPE } from 'src/utils/constants';
 import { FIREBASE_ERRORS } from 'src/utils/errors';
 import { FIREBASE_EVENTS, USER_SERVICE_EVENTS } from 'src/utils/logs';
 import { ILike, IsNull, Not, Repository } from 'typeorm';
@@ -327,16 +327,33 @@ export class UserService {
     return deletedUsers;
   }
 
+  public async bulkDeleteUsers(): Promise<UserEntity[]> {
+    if (isProduction) {
+      throw new Error('Bulk delete cannot be performed on production database');
+    }
+
+    let deletedUsers: UserEntity[];
+
+    try {
+      const users = await this.userRepository.find();
+
+      deletedUsers = await this.batchDeleteUsers(users);
+    } catch (error) {
+      this.logger.error(`deleteFilteredUsers - Unable to delete all users`, error);
+    }
+    return deletedUsers;
+  }
+
   public async deleteCypressTestUsers(clean = false): Promise<UserEntity[]> {
     let deletedUsers: UserEntity[];
     try {
-      const queryResult = await this.userRepository.find({
+      const users = await this.userRepository.find({
         where: {
           email: ILike('%cypresstestemail+%'),
         },
       });
 
-      deletedUsers = await this.batchDeleteUsers(queryResult);
+      deletedUsers = await this.batchDeleteUsers(users);
     } catch (error) {
       // If this fails we don't want to break cypress tests but we want to be alerted
       this.logger.error(`deleteCypressTestUsers - Unable to delete all cypress users`, error);