WIP:delete inactive sessions

Signed-off-by: shitrerohit <[email protected]>

Author: shitrerohit

apps/api-gateway/src/user/user.controller.ts

@@ -62,7 +62,7 @@ export class UserController {
     private readonly userService: UserService,
     private readonly commonService: CommonService,
     private readonly awsService: AwsService
-  ) { }
+  ) {}
 
   /**
    *
@@ -105,9 +105,9 @@ export class UserController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
-    /**
+  /**
    * Get public profile details of a user by username.
-   * 
+   *
    * @param username The username of the user.
    * @returns Public profile information.
    */
@@ -134,7 +134,6 @@ export class UserController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
-
   /**
    * Retrieves the profile details of the currently logged-in user.
    *
@@ -149,7 +148,7 @@ export class UserController {
   @ApiBearerAuth()
   async getProfile(@User() reqUser: user, @Res() res: Response): Promise<Response> {
     const userData = await this.userService.getProfile(reqUser.id);
-    
+
     const finalResponse: IResponse = {
       statusCode: HttpStatus.OK,
       message: ResponseMessages.user.success.fetchProfile,
@@ -159,9 +158,9 @@ export class UserController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
- /**
+  /**
    * Retrieves all platform settings.
-   * 
+   *
    * @returns  The platform settings.
    */
   @Get('/platform-settings')
@@ -185,11 +184,11 @@ export class UserController {
   }
 
   /**
- * Fetch user activities.
- * 
- * @param limit - Number of activities to fetch.
- * @returns A response containing user activity data.
- */
+   * Fetch user activities.
+   *
+   * @param limit - Number of activities to fetch.
+   * @returns A response containing user activity data.
+   */
   @Get('/activity')
   @ApiOperation({
     summary: 'Fetch users activity',
@@ -214,12 +213,11 @@ export class UserController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
-
- /**
- * Fetch organization invitations.
- *
- * @returns A paginated list of organization invitations.
- */
+  /**
+   * Fetch organization invitations.
+   *
+   * @returns A paginated list of organization invitations.
+   */
   @Get('/org-invitations')
   @ApiOperation({
     summary: 'organization invitations',
@@ -248,7 +246,7 @@ export class UserController {
     required: false
   })
   async invitations(
-  @Query() getAllInvitationsDto: GetAllInvitationsDto,
+    @Query() getAllInvitationsDto: GetAllInvitationsDto,
     @User() reqUser: user,
     @Res() res: Response
   ): Promise<Response> {
@@ -271,14 +269,17 @@ export class UserController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
- /**
- * Checks if a user is registered and verifies email existence.
- *
- * @param email The email address to check.
- * @returns Returns user registration and email verification status.
- */
+  /**
+   * Checks if a user is registered and verifies email existence.
+   *
+   * @param email The email address to check.
+   * @returns Returns user registration and email verification status.
+   */
   @Get('/:email')
-  @ApiOperation({ summary: 'Check user registration and email verification status', description: 'Check if a user is already registered and if their email already exists.' })
+  @ApiOperation({
+    summary: 'Check user registration and email verification status',
+    description: 'Check if a user is already registered and if their email already exists.'
+  })
   async checkUserExist(@Param() emailParam: EmailValidator, @Res() res: Response): Promise<Response> {
     const userDetails = await this.userService.checkUserExist(emailParam.email);
 
@@ -292,12 +293,12 @@ export class UserController {
   }
 
   /**
- * Accept or reject an organization invitation.
- *
- * @param invitationId The ID of the organization invitation.
- * @body AcceptRejectInvitationDto
- * @returns The status of the organization invitation response.
- */
+   * Accept or reject an organization invitation.
+   *
+   * @param invitationId The ID of the organization invitation.
+   * @body AcceptRejectInvitationDto
+   * @returns The status of the organization invitation response.
+   */
   @Post('/org-invitations/:invitationId')
   @ApiOperation({
     summary: 'accept/reject organization invitation',
@@ -306,8 +307,17 @@ export class UserController {
   @UseGuards(AuthGuard('jwt'), UserAccessGuard)
   @ApiBearerAuth()
   async acceptRejectInvitaion(
-      @Body() acceptRejectInvitation: AcceptRejectInvitationDto,
-      @Param('invitationId', TrimStringParamPipe, new ParseUUIDPipe({exceptionFactory: (): Error => { throw new BadRequestException(`Invalid format for InvitationId`); }})) invitationId: string,
+    @Body() acceptRejectInvitation: AcceptRejectInvitationDto,
+    @Param(
+      'invitationId',
+      TrimStringParamPipe,
+      new ParseUUIDPipe({
+        exceptionFactory: (): Error => {
+          throw new BadRequestException(`Invalid format for InvitationId`);
+        }
+      })
+    )
+    invitationId: string,
     @User() reqUser: user,
     @Res() res: Response
   ): Promise<Response> {
@@ -320,13 +330,13 @@ export class UserController {
     };
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
-  
+
   /**
- * Updates the user profile.
- *
- * @body UpdateUserProfileDto
- * @returns A response indicating the success of the update operation.
- */
+   * Updates the user profile.
+   *
+   * @body UpdateUserProfileDto
+   * @returns A response indicating the success of the update operation.
+   */
   @Put('/')
   @ApiOperation({
     summary: 'Update user profile',
@@ -343,48 +353,48 @@ export class UserController {
     const userId = reqUser.id;
     updateUserProfileDto.id = userId;
     await this.userService.updateUserProfile(updateUserProfileDto);
-     
+
     const finalResponse: IResponse = {
       statusCode: HttpStatus.OK,
       message: ResponseMessages.user.success.update
     };
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
- /**
+  /**
    * @body AddPasskeyDetailsDto
    * @returns User's profile update status
    */
-  
-
- @Put('/password/:email')
- @ApiOperation({ summary: 'Store user password details', description: 'Securely store and update the user’s password details.' })
- @ApiExcludeEndpoint()
- @ApiBearerAuth()
- @UseGuards(AuthGuard('jwt'), UserAccessGuard)
- 
- async addPasskey(
-   @Body() userInfo: AddPasskeyDetailsDto,
-   @User() reqUser: user,
-   @Res() res: Response
- ): Promise<Response> {
-
-   const userDetails = await this.userService.addPasskey(reqUser.email, userInfo);
-   const finalResponse = {
-     statusCode: HttpStatus.OK,
-     message: ResponseMessages.user.success.update,
-     data: userDetails
-   };
-
-   return res.status(HttpStatus.OK).json(finalResponse);
- }
+
+  @Put('/password/:email')
+  @ApiOperation({
+    summary: 'Store user password details',
+    description: 'Securely store and update the user’s password details.'
+  })
+  @ApiExcludeEndpoint()
+  @ApiBearerAuth()
+  @UseGuards(AuthGuard('jwt'), UserAccessGuard)
+  async addPasskey(
+    @Body() userInfo: AddPasskeyDetailsDto,
+    @User() reqUser: user,
+    @Res() res: Response
+  ): Promise<Response> {
+    const userDetails = await this.userService.addPasskey(reqUser.email, userInfo);
+    const finalResponse = {
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.user.success.update,
+      data: userDetails
+    };
+
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
 
   /**
- * Updates platform settings.
- * @body UpdatePlatformSettingsDto
- * 
- * @returns Status of the update operation.
- */
+   * Updates platform settings.
+   * @body UpdatePlatformSettingsDto
+   *
+   * @returns Status of the update operation.
+   */
   @Put('/platform-settings')
   @ApiOperation({
     summary: 'Update platform settings',
@@ -406,4 +416,19 @@ export class UserController {
 
     return res.status(HttpStatus.OK).json(finalResponse);
   }
-}
+
+  @Post('/delete-inactive-sessions')
+  @ApiOperation({
+    summary: 'Update platform settings',
+    description: 'Modify platform settings. Only accessible by platform admins.'
+  })
+  async deleteInactiveSessions(@Res() res: Response): Promise<Response> {
+    await this.userService.deleteInactiveSessions();
+    const finalResponse = {
+      statusCode: HttpStatus.OK,
+      message: ''
+    };
+
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
+}

apps/api-gateway/src/user/user.service.ts

@@ -15,7 +15,10 @@ import { NATSClient } from '@credebl/common/NATSClient';
 
 @Injectable()
 export class UserService extends BaseService {
-  constructor(@Inject('NATS_CLIENT') private readonly serviceProxy: ClientProxy, private readonly natsClient : NATSClient) {
+  constructor(
+    @Inject('NATS_CLIENT') private readonly serviceProxy: ClientProxy,
+    private readonly natsClient: NATSClient
+  ) {
     super('User Service');
   }
 
@@ -25,8 +28,8 @@ export class UserService extends BaseService {
   }
 
   async getPublicProfile(username: string): Promise<object> {
-  const payload = { username };
-  return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-user-public-profile', payload);
+    const payload = { username };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-user-public-profile', payload);
   }
 
   async updateUserProfile(updateUserProfileDto: UpdateUserProfileDto): Promise<user> {
@@ -43,24 +46,19 @@ export class UserService extends BaseService {
     const payload = { id };
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-user-by-keycloak', payload);
   }
-  
+
   async invitations(id: string, status: string, getAllInvitationsDto: GetAllInvitationsDto): Promise<IUserInvitations> {
     const { pageNumber, pageSize, search } = getAllInvitationsDto;
     const payload = { id, status, pageNumber, pageSize, search };
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-org-invitations', payload);
   }
 
-  async acceptRejectInvitaion(
-    acceptRejectInvitation: AcceptRejectInvitationDto,
-    userId: string
-  ): Promise<string> {
+  async acceptRejectInvitaion(acceptRejectInvitation: AcceptRejectInvitationDto, userId: string): Promise<string> {
     const payload = { acceptRejectInvitation, userId };
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'accept-reject-invitations', payload);
   }
 
-  async get(
-    paginationDto:PaginationDto
-  ): Promise<object> {
+  async get(paginationDto: PaginationDto): Promise<object> {
     const { pageNumber, pageSize, search } = paginationDto;
     const payload = { pageNumber, pageSize, search };
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'fetch-users', payload);
@@ -94,4 +92,8 @@ export class UserService extends BaseService {
     const payload = { email };
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-user-info-by-user-email-keycloak', payload);
   }
+
+  async deleteInactiveSessions(): Promise<void> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'delete-inactive-sessions', '');
+  }
 }

apps/user/repositories/user.repository.ts

@@ -987,4 +987,30 @@ export class UserRepository {
       throw error;
     }
   }
+
+  async deleteInactiveSessions(): Promise<number> {
+    try {
+      //       await this.prisma.session.deleteMany({
+      //   where: {
+      //     AND: [
+      //       {
+      //         createdAt: {
+      //           lt: new Date(Date.now() - expires), // Current time minus expire interval
+      //         },
+      //       },
+      //       // You can add more conditions here
+      //     ],
+      //   },
+      // });
+      const response = await this.prisma.$executeRaw`
+        DELETE FROM "session"
+        WHERE ("createdAt" + make_interval(secs => "expires")) < NOW()
+      `;
+      this.logger.debug('Response::', response);
+      return response;
+    } catch (error) {
+      this.logger.error(`Error in deleting the in active sessions::${error.message}`);
+      throw error;
+    }
+  }
 }

apps/user/src/user.controller.ts

@@ -269,4 +269,9 @@ export class UserController {
   async logout(logoutUserDto: ISessions): Promise<string> {
     return this.userService.logout(logoutUserDto);
   }
+
+  @MessagePattern({ cmd: 'delete-inactive-sessions' })
+  async deleteInActiveSessions(): Promise<string> {
+    return this.userService.deleteInActiveSessions();
+  }
 }

apps/user/src/user.service.ts

@@ -1335,4 +1335,13 @@ export class UserService {
       throw new RpcException(error.response ? error.response : error);
     }
   }
+
+  async deleteInActiveSessions(): Promise<number> {
+    try {
+      return await this.userRepository.deleteInactiveSessions();
+    } catch (error) {
+      this.logger.error(`Error in deleting in-active sessions`);
+      throw new RpcException(error.response ? error.response : error);
+    }
+  }
 }