feat: add tags support to nodes

- Updated Nodes model and related schemas to include tags as an array.
- Enhanced create and update node commands to validate and handle tags.
- Introduced new API routes for fetching node tags.
- Updated service and repository methods to support tag retrieval and filtering.
- Modified response models to include tags in node data.
- Adjusted metrics providers to incorporate tags in metrics reporting.

Author: kastov

libs/contract/api/controllers/nodes.ts

@@ -24,4 +24,8 @@ export const NODES_ROUTES = {
         USAGE_BY_RANGE_USER: (uuid: string) => `usage/${uuid}/users/range`,
         USAGE_REALTIME: 'usage/realtime',
     },
+
+    TAGS: {
+        GET: 'tags',
+    },
 } as const;

libs/contract/api/routes.ts

@@ -47,6 +47,9 @@ export const REST_API = {
         UPDATE: `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.UPDATE}`,
         DELETE: (uuid: string) =>
             `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.DELETE(uuid)}`,
+        TAGS: {
+            GET: `${ROOT}/${CONTROLLERS.NODES_CONTROLLER}/${CONTROLLERS.NODES_ROUTES.TAGS.GET}`,
+        },
 
         ACTIONS: {
             ENABLE: (uuid: string) =>

libs/contract/commands/nodes/create.command.ts

@@ -60,6 +60,19 @@ export namespace CreateNodeCommand {
         }),
 
         providerUuid: z.optional(z.nullable(z.string().uuid())),
+        tags: z.optional(
+            z
+                .array(
+                    z
+                        .string()
+                        .regex(
+                            /^[A-Z0-9_:]+$/,
+                            'Tag can only contain uppercase letters, numbers, underscores and colons',
+                        )
+                        .max(36, 'Each tag must be less than 36 characters'),
+                )
+                .max(10, 'Maximum 10 tags'),
+        ),
     });
 
     export type Request = z.infer<typeof RequestSchema>;

libs/contract/commands/nodes/index.ts

@@ -4,4 +4,5 @@ export * from './delete.command';
 export * from './get-all.command';
 export * from './get-one.command';
 export * from './stats';
+export * from './tags';
 export * from './update.command';

libs/contract/commands/nodes/tags/get-all-nodes-tags.command.ts

@@ -0,0 +1,23 @@
+import { z } from 'zod';
+
+import { getEndpointDetails } from '../../../constants';
+import { REST_API, NODES_ROUTES } from '../../../api';
+
+export namespace GetAllNodesTagsCommand {
+    export const url = REST_API.NODES.TAGS.GET;
+    export const TSQ_url = url;
+
+    export const endpointDetails = getEndpointDetails(
+        NODES_ROUTES.TAGS.GET,
+        'get',
+        'Get all existing nodes tags',
+    );
+
+    export const ResponseSchema = z.object({
+        response: z.object({
+            tags: z.array(z.string()),
+        }),
+    });
+
+    export type Response = z.infer<typeof ResponseSchema>;
+}

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

@@ -0,0 +1 @@
+export * from './get-all-nodes-tags.command';

libs/contract/commands/nodes/update.command.ts

@@ -54,6 +54,19 @@ export namespace UpdateNodeCommand {
             .optional(),
 
         providerUuid: z.optional(z.nullable(z.string().uuid())),
+        tags: z.optional(
+            z
+                .array(
+                    z
+                        .string()
+                        .regex(
+                            /^[A-Z0-9_:]+$/,
+                            'Tag can only contain uppercase letters, numbers, underscores and colons',
+                        )
+                        .max(36, 'Each tag must be less than 36 characters'),
+                )
+                .max(10, 'Maximum 10 tags'),
+        ),
     });
 
     export type Request = z.infer<typeof RequestSchema>;

libs/contract/models/nodes.schema.ts

@@ -33,6 +33,7 @@ export const NodesSchema = z.object({
     viewPosition: z.number().int(),
     countryCode: z.string(),
     consumptionMultiplier: z.number(),
+    tags: z.array(z.string()),
 
     cpuCount: z.nullable(z.number().int()),
     cpuModel: z.nullable(z.string()),

libs/contract/package.json

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

prisma/migrations/20251118004805_node_tags/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "public"."nodes" ADD COLUMN     "tags" TEXT[] DEFAULT ARRAY[]::TEXT[];