feat: add activate all inbounds functionality

- Updated the contract library to include a new route and controller method for activating all inbounds for a user.
- Introduced error handling for activation failures and added relevant error codes.
- Enhanced the UsersService to manage the activation process and publish events accordingly.
- Added DTOs for request and response handling in the controller.
- Updated package version to 0.3.63.

Author: kastov

libs/contract/api/controllers/users.ts

@@ -13,6 +13,7 @@ export const USERS_ROUTES = {
     DELETE_USER: 'delete',
     UPDATE: 'update',
     RESET_USER_TRAFFIC: 'reset-traffic',
+    ACTIVATE_ALL_INBOUNDS: 'activate-all-inbounds',
     BULK: {
         DELETE_BY_STATUS: 'bulk/delete-by-status',
         UPDATE: 'bulk/update',

libs/contract/api/routes.ts

@@ -74,6 +74,8 @@ export const REST_API = {
         DELETE_USER: (uuid: string) =>
             `${ROOT}/${CONTROLLERS.USERS_CONTROLLER}/${CONTROLLERS.USERS_ROUTES.DELETE_USER}/${uuid}`,
         UPDATE: `${ROOT}/${CONTROLLERS.USERS_CONTROLLER}/${CONTROLLERS.USERS_ROUTES.UPDATE}`,
+        ACTIVATE_ALL_INBOUNDS: (uuid: string) =>
+            `${ROOT}/${CONTROLLERS.USERS_CONTROLLER}/${CONTROLLERS.USERS_ROUTES.ACTIVATE_ALL_INBOUNDS}/${uuid}`,
         GET_ALL_V2: `${ROOT}/${CONTROLLERS.USERS_CONTROLLER}/${CONTROLLERS.USERS_ROUTES.GET_ALL_V2}`,
         RESET_USER_TRAFFIC: (uuid: string) =>
             `${ROOT}/${CONTROLLERS.USERS_CONTROLLER}/${CONTROLLERS.USERS_ROUTES.RESET_USER_TRAFFIC}/${uuid}`,

libs/contract/commands/users/activate-all-inbounds.command.ts

@@ -0,0 +1,24 @@
+import { z } from 'zod';
+
+import { LastConnectedNodeSchema, UsersSchema } from '../../models';
+import { REST_API } from '../../api';
+
+export namespace ActivateAllInboundsCommand {
+    export const url = REST_API.USERS.ACTIVATE_ALL_INBOUNDS;
+    export const TSQ_url = url(':uuid');
+
+    export const RequestSchema = z.object({
+        uuid: z.string().uuid(),
+    });
+
+    export type Request = z.infer<typeof RequestSchema>;
+
+    export const ResponseSchema = z.object({
+        response: UsersSchema.extend({
+            subscriptionUrl: z.string(),
+            lastConnectedNode: LastConnectedNodeSchema,
+        }),
+    });
+
+    export type Response = z.infer<typeof ResponseSchema>;
+}

libs/contract/commands/users/index.ts

@@ -1,3 +1,4 @@
+export * from './activate-all-inbounds.command';
 export * from './bulk';
 export * from './bulk-all';
 export * from './create-user.command';

libs/contract/constants/errors/errors.ts

@@ -458,4 +458,9 @@ export const ERRORS = {
         message: 'Keypair not found. Restart app.',
         httpCode: 500,
     },
+    ACTIVATE_ALL_INBOUNDS_ERROR: {
+        code: 'A093',
+        message: 'Activate all inbounds error',
+        httpCode: 500,
+    },
 } as const;

libs/contract/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@remnawave/backend-contract",
-  "version": "0.3.62",
+  "version": "0.3.63",
   "public": true,
   "license": "AGPL-3.0-only",
   "description": "A contract library for Remnawave Backend. It can be used in backend and frontend.",

src/modules/inbounds/commands/create-many-user-active-inbounds/create-many-user-active-inbounds.handler.ts

@@ -1,7 +1,6 @@
 import { ERRORS } from '@contract/constants';
 
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { Transactional } from '@nestjs-cls/transactional';
 import { Logger } from '@nestjs/common';
 
 import { ICommandResponse } from '@common/types/command-response.type';
@@ -17,7 +16,6 @@ export class CreateManyUserActiveInboundsHandler
 
     constructor(private readonly activeUserInboundsRepository: ActiveUserInboundsRepository) {}
 
-    @Transactional()
     async execute(command: CreateManyUserActiveInboundsCommand): Promise<ICommandResponse<number>> {
         try {
             const response = await this.activeUserInboundsRepository.createMany(

src/modules/inbounds/commands/delete-many-active-inbounds-by-user-uuid/delete-many-active-inbounds-by-user-uuid.handler.ts

@@ -1,9 +1,7 @@
 import { ActiveUserInboundsRepository } from 'src/modules/inbounds/repositories/active-user-inbounds.repository';
 import { ERRORS } from '@contract/constants';
 
-import { TransactionalAdapterPrisma } from '@nestjs-cls/transactional-adapter-prisma';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { Transactional } from '@nestjs-cls/transactional';
 import { Logger } from '@nestjs/common';
 
 import { ICommandResponse } from '@common/types/command-response.type';
@@ -18,10 +16,6 @@ export class DeleteManyActiveInboundsByUserUuidHandler
 
     constructor(private readonly activeUserInboundsRepository: ActiveUserInboundsRepository) {}
 
-    @Transactional<TransactionalAdapterPrisma>({
-        maxWait: 20_000,
-        timeout: 120_000,
-    })
     async execute(
         command: DeleteManyActiveInboundsByUserUuidCommand,
     ): Promise<ICommandResponse<number>> {

src/modules/inbounds/repositories/active-user-inbounds.repository.ts

@@ -46,6 +46,7 @@ export class ActiveUserInboundsRepository implements ICrud<ActiveUserInboundEnti
     public async createMany(userUuid: string, inboundUuids: string[]): Promise<number> {
         const result = await this.prisma.tx.activeUserInbounds.createMany({
             data: inboundUuids.map((inboundUuid) => ({ userUuid, inboundUuid })),
+            skipDuplicates: true,
         });
         return result.count;
     }

src/modules/users/controllers/users.controller.ts

@@ -34,6 +34,8 @@ import { USERS_CONTROLLER, USERS_ROUTES } from '@libs/contracts/api';
 import { ROLE } from '@libs/contracts/constants';
 
 import {
+    ActivateAllInboundsRequestDto,
+    ActivateAllInboundsResponseDto,
     CreateUserRequestDto,
     CreateUserResponseDto,
     DeleteUserRequestDto,
@@ -482,4 +484,33 @@ export class UsersController {
             response: data.map((item) => new GetFullUserResponseModel(item, this.subPublicDomain)),
         };
     }
+
+    @ApiNotFoundResponse({
+        description: 'User not found',
+    })
+    @ApiOkResponse({
+        type: ActivateAllInboundsResponseDto,
+        description: 'All inbounds activated successfully',
+    })
+    @ApiOperation({
+        summary: 'Activate All Inbounds',
+        description: 'Activate all inbounds',
+    })
+    @ApiParam({ name: 'uuid', type: String, description: 'UUID of the user', required: true })
+    @HttpCode(HttpStatus.OK)
+    @Patch(USERS_ROUTES.ACTIVATE_ALL_INBOUNDS + '/:uuid')
+    async activateAllInbounds(
+        @Param() paramData: ActivateAllInboundsRequestDto,
+    ): Promise<ActivateAllInboundsResponseDto> {
+        const result = await this.usersService.activateAllInbounds(paramData.uuid);
+
+        const data = errorHandler(result);
+        return {
+            response: new GetUserResponseModel(
+                data.user,
+                data.lastConnectedNode,
+                this.subPublicDomain,
+            ),
+        };
+    }
 }