chore: update dependencies and clean up code

kastov · kastov · commit db6ff3b48f37 · 2025-07-20T20:18:22.000+03:00
diff --git a/libs/contract/constants/errors/errors.ts b/libs/contract/constants/errors/errors.ts
@@ -724,4 +724,9 @@ export const ERRORS = {
         message: 'This name is reserved by Remnawave. Please use a different name.',
         httpCode: 400,
     },
+    UPDATE_CONFIG_PROFILE_ERROR: {
+        code: 'A146',
+        message: 'Update config profile error',
+        httpCode: 500,
+    },
 } as const;
diff --git a/libs/contract/constants/headers/headers.constants.ts b/libs/contract/constants/headers/headers.constants.ts
diff --git a/libs/contract/constants/headers/index.ts b/libs/contract/constants/headers/index.ts
@@ -1 +1 @@
-export * from './headers.contants';
+export * from './headers.constants';
diff --git a/libs/contract/models/infra-provider.schema.ts b/libs/contract/models/infra-provider.schema.ts
@@ -21,7 +21,7 @@ export const InfraProviderSchema = z.object({
     }),
     billingNodes: z.array(
         z.object({
-            nodeUuid: z.string(),
+            nodeUuid: z.string().uuid(),
             name: z.string(),
             countryCode: z.string(),
         }),
diff --git a/libs/contract/package.json b/libs/contract/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@remnawave/backend-contract",
-  "version": "2.0.0-alpha.35",
+  "version": "2.0.0-alpha.36",
   "public": true,
   "license": "AGPL-3.0-only",
   "description": "A contract library for Remnawave Backend. It can be used in backend and frontend.",
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -59,14 +59,14 @@
     "@nestjs/axios": "4.0.1",
     "@nestjs/bullmq": "11.0.2",
     "@nestjs/cache-manager": "^3.0.1",
-    "@nestjs/common": "11.1.4",
+    "@nestjs/common": "11.1.5",
     "@nestjs/config": "4.0.2",
-    "@nestjs/core": "11.1.4",
+    "@nestjs/core": "11.1.5",
     "@nestjs/cqrs": "11.0.3",
     "@nestjs/event-emitter": "3.0.1",
     "@nestjs/jwt": "11.0.0",
     "@nestjs/passport": "11.0.5",
-    "@nestjs/platform-express": "11.1.4",
+    "@nestjs/platform-express": "11.1.5",
     "@nestjs/schedule": "6.0.0",
     "@nestjs/serve-static": "5.0.3",
     "@nestjs/swagger": "11.2.0",
diff --git a/src/modules/config-profiles/config-profile.service.ts b/src/modules/config-profiles/config-profile.service.ts
@@ -252,7 +252,7 @@ export class ConfigProfileService {
             this.logger.error(error);
             return {
                 isOk: false,
-                ...ERRORS.CREATE_CONFIG_PROFILE_ERROR,
+                ...ERRORS.UPDATE_CONFIG_PROFILE_ERROR,
             };
         }
     }
diff --git a/src/modules/hosts/repositories/hosts.repository.ts b/src/modules/hosts/repositories/hosts.repository.ts
@@ -127,34 +127,6 @@ export class HostsRepository implements ICrud<HostsEntity> {
     }
 
     public async findActiveHostsByUserUuid(userUuid: string): Promise<HostWithRawInbound[]> {
-        // const hosts = await this.qb.kysely
-        //     .selectFrom('hosts')
-        //     .innerJoin(
-        //         'internalSquadInbounds',
-        //         'internalSquadInbounds.inboundUuid',
-        //         'hosts.configProfileInboundUuid',
-        //     )
-        //     .innerJoin(
-        //         'internalSquadMembers',
-        //         'internalSquadMembers.internalSquadUuid',
-        //         'internalSquadInbounds.internalSquadUuid',
-        //     )
-
-        //     .innerJoin(
-        //         'configProfileInbounds',
-        //         'configProfileInbounds.uuid',
-        //         'hosts.configProfileInboundUuid',
-        //     )
-
-        //     .where('hosts.isDisabled', '=', false)
-        //     .where('internalSquadMembers.userUuid', '=', getKyselyUuid(userUuid))
-        //     .selectAll('hosts')
-        //     .select(['configProfileInbounds.rawInbound', 'configProfileInbounds.tag'])
-        //     .orderBy('hosts.viewPosition', 'asc')
-        //     .execute();
-
-        // TODO: remove later
-
         const hosts = await this.qb.kysely
             .selectFrom('hosts')
             .distinct()
diff --git a/src/modules/infra-billing/repositories/infra-billing-node.repository.ts b/src/modules/infra-billing/repositories/infra-billing-node.repository.ts
@@ -205,12 +205,6 @@ export class InfraBillingNodeRepository implements ICrud<InfraBillingNodeEntity>
             }),
         );
 
-        // const x = results
-        //     .flat()
-        //     .sort(
-        //         (a, b) => new Date(a.nextBillingAt).getTime() - new Date(b.nextBillingAt).getTime(),
-        //     );
-
         return results.flat().map((node) => new InfraBillingNodeNotificationEntity(node));
     }
 }
diff --git a/src/modules/internal-squads/internal-squad.controller.ts b/src/modules/internal-squads/internal-squad.controller.ts
@@ -128,7 +128,6 @@ export class InternalSquadController {
     ): Promise<UpdateInternalSquadResponseDto> {
         const result = await this.internalSquadService.updateInternalSquad(
             updateInternalSquadDto.uuid,
-
             updateInternalSquadDto.inbounds,
         );
 
diff --git a/src/modules/nodes/repositories/nodes.repository.ts b/src/modules/nodes/repositories/nodes.repository.ts
@@ -106,21 +106,6 @@ export class NodesRepository implements ICrud<NodesEntity> {
         return new NodesEntity(result);
     }
 
-    // public async update({ uuid, ...data }: Partial<NodesEntity>): Promise<NodesEntity> {
-
-    //     const result = await this.prisma.tx.nodes.update({
-    //         where: {
-    //             uuid,
-    //         },
-    //         data: {
-    //             ...data,
-    //         },
-    //         include: INCLUDE_RESOLVED_INBOUNDS,
-    //     });
-
-    //     return new NodesEntity(result);
-    // }
-
     public async findByCriteria(dto: Partial<NodesEntity>): Promise<NodesEntity[]> {
         const nodesList = await this.prisma.tx.nodes.findMany({
             where: dto,
diff --git a/src/queue/start-all-nodes/start-all-nodes.processor.ts b/src/queue/start-all-nodes/start-all-nodes.processor.ts
@@ -21,14 +21,12 @@ import { QueueNames } from '../queue.enum';
 )
 export class StartAllNodesQueueProcessor extends WorkerHost {
     private readonly logger = new Logger(StartAllNodesQueueProcessor.name);
-    private readonly CONCURRENCY: number;
 
     constructor(
         private readonly nodesRepository: NodesRepository,
         private readonly startAllNodesByProfileQueueService: StartAllNodesByProfileQueueService,
     ) {
         super();
-        this.CONCURRENCY = 20;
     }
 
     async process(job: Job) {
diff --git a/src/scheduler/tasks/export-metrics/node-metrics-message.handler.ts b/src/scheduler/tasks/export-metrics/node-metrics-message.handler.ts
@@ -98,7 +98,7 @@ export class NodeMetricsMessageHandler implements IMessageHandler<NodeMetricsMes
 
             return new MessageResponse([{ result: 'OK' }]);
         } catch (error) {
-            this.logger.error(`Error in reportShortUserStats: ${error}`);
+            this.logger.error(`Error in handle: ${error}`);
 
             return new MessageResponse([{ result: 'ERROR' }]);
         }

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-export * from './headers.contants';`
	`1`	`+export * from './headers.constants';`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@remnawave/backend-contract",`
`3`		`- "version": "2.0.0-alpha.35",`
	`3`	`+ "version": "2.0.0-alpha.36",`
`4`	`4`	`"public": true,`
`5`	`5`	`"license": "AGPL-3.0-only",`
`6`	`6`	`"description": "A contract library for Remnawave Backend. It can be used in backend and frontend.",`
Original file line number	Diff line number	Diff line change
`@@ -252,7 +252,7 @@ export class ConfigProfileService {`
`252`	`252`	`this.logger.error(error);`
`253`	`253`	`return {`
`254`	`254`	`isOk: false,`
`255`		`- ...ERRORS.CREATE_CONFIG_PROFILE_ERROR,`
	`255`	`+ ...ERRORS.UPDATE_CONFIG_PROFILE_ERROR,`
`256`	`256`	`};`
`257`	`257`	`}`
`258`	`258`	`}`
Original file line number	Diff line number	Diff line change
`@@ -205,12 +205,6 @@ export class InfraBillingNodeRepository implements ICrud<InfraBillingNodeEntity>`
`205`	`205`	`}),`
`206`	`206`	`);`
`207`	`207`
`208`		`- // const x = results`
`209`		`- // .flat()`
`210`		`- // .sort(`
`211`		`- // (a, b) => new Date(a.nextBillingAt).getTime() - new Date(b.nextBillingAt).getTime(),`
`212`		`- // );`
`213`		`-`
`214`	`208`	`return results.flat().map((node) => new InfraBillingNodeNotificationEntity(node));`
`215`	`209`	`}`
`216`	`210`	`}`