feat: add reset traffic functionality for nodes

Author: kastov

libs/contract/api/controllers/nodes.ts

@@ -13,6 +13,7 @@ export const NODES_ROUTES = {
         ENABLE: (uuid: string) => `${uuid}/${NODE_ACTIONS_ROUTE}/enable`,
         DISABLE: (uuid: string) => `${uuid}/${NODE_ACTIONS_ROUTE}/disable`,
         RESTART: (uuid: string) => `${uuid}/${NODE_ACTIONS_ROUTE}/restart`,
+        RESET_TRAFFIC: (uuid: string) => `${uuid}/${NODE_ACTIONS_ROUTE}/reset-traffic`,
 
         RESTART_ALL: `${NODE_ACTIONS_ROUTE}/restart-all`,
         REORDER: `${NODE_ACTIONS_ROUTE}/reorder`,

libs/contract/api/routes.ts

@@ -61,6 +61,10 @@ export const REST_API = {
                     uuid,
                 )}`,
             RESTART_ALL: `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.ACTIONS.RESTART_ALL}`,
+            RESET_TRAFFIC: (uuid: string) =>
+                `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.ACTIONS.RESET_TRAFFIC(
+                    uuid,
+                )}`,
             REORDER: `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.ACTIONS.REORDER}`,
         },
 

libs/contract/commands/nodes/actions/index.ts

@@ -1,5 +1,6 @@
 export * from './disable.command';
 export * from './enable.command';
 export * from './reorder.command';
+export * from './reset-traffic.command';
 export * from './restart-all.command';
 export * from './restart.command';

libs/contract/commands/nodes/actions/reset-traffic.command.ts

@@ -0,0 +1,29 @@
+import { z } from 'zod';
+
+import { getEndpointDetails } from '../../../constants';
+import { NODES_ROUTES, REST_API } from '../../../api';
+
+export namespace ResetNodeTrafficCommand {
+    export const url = REST_API.NODES.ACTIONS.RESET_TRAFFIC;
+    export const TSQ_url = url(':uuid');
+
+    export const endpointDetails = getEndpointDetails(
+        NODES_ROUTES.ACTIONS.RESET_TRAFFIC(':uuid'),
+        'post',
+        'Reset Node Traffic',
+    );
+
+    export const RequestSchema = z.object({
+        uuid: z.string().uuid(),
+    });
+
+    export type Request = z.infer<typeof RequestSchema>;
+
+    export const ResponseSchema = z.object({
+        response: z.object({
+            eventSent: z.boolean(),
+        }),
+    });
+
+    export type Response = z.infer<typeof ResponseSchema>;
+}

libs/contract/constants/errors/errors.ts

@@ -1009,4 +1009,9 @@ export const ERRORS = {
         message: 'Get computed config profile by UUID error',
         httpCode: 500,
     },
+    RESET_NODE_TRAFFIC_ERROR: {
+        code: 'A201',
+        message: 'Reset node traffic error',
+        httpCode: 500,
+    },
 } as const;

libs/contract/package.json

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

src/modules/nodes/dtos/index.ts

@@ -5,6 +5,7 @@ export * from './enable-node.request.dto';
 export * from './get-all-nodes.dto';
 export * from './get-one-node.dto';
 export * from './reorder.dto';
+export * from './reset-traffic.request.dto';
 export * from './restart-all.dto';
 export * from './restart-node.request.dto';
 export * from './update-node.dto';

src/modules/nodes/dtos/reset-traffic.request.dto.ts

@@ -0,0 +1,10 @@
+import { createZodDto } from 'nestjs-zod';
+
+import { ResetNodeTrafficCommand } from '@contract/commands';
+
+export class ResetNodeTrafficRequestDto extends createZodDto(
+    ResetNodeTrafficCommand.RequestSchema,
+) {}
+export class ResetNodeTrafficResponseDto extends createZodDto(
+    ResetNodeTrafficCommand.ResponseSchema,
+) {}

src/modules/nodes/models/base-event.response.model.ts

@@ -0,0 +1,7 @@
+export class BaseEventResponseModel {
+    public eventSent: boolean;
+
+    constructor(eventSent: boolean) {
+        this.eventSent = eventSent;
+    }
+}

src/modules/nodes/models/index.ts

@@ -1,3 +1,4 @@
+export * from './base-event.response.model';
 export * from './create-node.response.model';
 export * from './delete-node.response.model';
 export * from './get-all-nodes.response.model';