Merge pull request #164 from apurvaubade/DeleteUser

Task:PS-372 User: Delete user API- delete user from keycloak,user & related tables

src/adapters/hasura/user.adapter.ts

@@ -706,4 +706,7 @@ export class HasuraUserService implements IServicelocator {
       return e;
     }
   }
+
+  public async deleteUserById(userId){}
+
 }

src/adapters/postgres/user-adapter.ts

@@ -776,6 +776,66 @@ export class PostgresUserService {
     };
   }
 
+  public async deleteUserById(userId){
+    const { KEYCLOAK, KEYCLOAK_ADMIN } = process.env;
+     // Validate userId format
+     if (!isUUID(userId)) {
+      return new ErrorResponseTypeOrm({
+          statusCode: HttpStatus.BAD_REQUEST,
+          errorMessage: "Please enter a valid UUID for userId",
+      });
+  }
+
+      try {
+    // Check if user exists in usersRepository
+    const user = await this.usersRepository.findOne({ where :{userId:userId}});
+    if (!user) {
+        return new ErrorResponseTypeOrm({
+            statusCode: HttpStatus.NOT_FOUND,
+            errorMessage: "User not found in user table.",
+        });
+    }  
+
+
+       // Delete from User table
+        const userResult = await this.usersRepository.delete(userId);
+
+        // Delete from CohortMembers table
+        const cohortMembersResult = await this.cohortMemberRepository.delete({ userId: userId });
+
+        // Delete from UserTenantMapping table
+        const userTenantMappingResult = await this.userTenantMappingRepository.delete({ userId: userId });
+
+        // Delete from UserRoleMapping table
+        const userRoleMappingResult = await this.userRoleMappingRepository.delete({ userId: userId });
+
+      // Delete from FieldValues table where ItemId matches userId
+        const fieldValuesResult = await this.fieldsValueRepository.delete({ itemId: userId });
+
+      const keycloakResponse = await getKeycloakAdminToken();
+      const token = keycloakResponse.data.access_token;
+
+        await this.axios.delete(`${KEYCLOAK}${KEYCLOAK_ADMIN}/${userId}`, {
+        headers: {
+            'Authorization': `Bearer ${token}`
+        }});
+
+
+        return new SuccessResponse({
+          statusCode: HttpStatus.OK,
+          message: "User and related entries deleted Successfully.",
+          data: {
+            user: userResult
+          },
+        });
+      } catch (e) {
+          return new ErrorResponseTypeOrm({
+          statusCode: HttpStatus.INTERNAL_SERVER_ERROR,
+          errorMessage: e,
+        });
+      }
+    }
+
 }
 
 

src/adapters/userservicelocator.ts

@@ -23,4 +23,6 @@ export interface IServicelocator {
     userSearchDto: UserSearchDto
   );
   resetUserPassword(request: any, username: string, newPassword: string);
+  deleteUserById(userId: string): Promise<any>;
+
 }

src/user/user.controller.ts

@@ -14,6 +14,7 @@ import {
   UsePipes,
   ValidationPipe,
   HttpStatus,
+  Delete,
 } from "@nestjs/common";
 
 import { Request } from "@nestjs/common";
@@ -161,4 +162,27 @@ export class UserController {
       .buildUserAdapter()
       .resetUserPassword(request, reqBody.username, reqBody.newPassword);
   }
+
+   //delete
+   @Delete("/:userId")
+
+   @ApiBasicAuth("access-token")
+   @ApiOkResponse({ description: "User deleted successfully" })
+   @ApiNotFoundResponse({ description: "Data not found" })
+   @SerializeOptions({
+     strategy: "excludeAll",
+   })
+
+   public async deleteUserById(
+     @Headers() headers,
+     @Param("userId") userId: string,
+     @Req() request: Request,
+     @Res() response: Response
+   ) {
+
+     const result = await this.userAdapter
+       .buildUserAdapter()
+       .deleteUserById(userId);
+     return response.status(result.statusCode).json(result);
+   }
 }