test: validation message

Author: DIY0R

test/mocks/dto/myClass.dto.ts

@@ -0,0 +1,10 @@
+import { IsInt, IsString, MaxLength } from 'class-validator';
+
+export class MyClass {
+  @IsString()
+  @MaxLength(5, { message: 'The name must be less than 5' })
+  name: string;
+
+  @IsInt()
+  age: number;
+}

test/mocks/rmq.event.ts

@@ -7,6 +7,7 @@ import {
   MessageRoute,
   RmqInterceptor,
   SerDes,
+  RMQValidate,
 } from '../../lib';
 import {
   EventInterceptorClass,
@@ -18,6 +19,8 @@ import {
   EventMiddlewareEndpointReturn,
 } from './event.middleware';
 import { RMQError } from '../../lib';
+import { MyClass } from './dto/myClass.dto';
+
 @Injectable()
 @SerDes({
   deserialize: (message: Buffer): any => JSON.parse(message.toString()),
@@ -104,6 +107,13 @@ export class RmqEvents {
     return { number: obj.number };
   }
 
+  @MessageRoute('message.valid')
+  @RMQValidate()
+  getValidMessage(obj: MyClass, consumeMessage: ConsumeMessage) {
+    this.rmqServie.ack(consumeMessage);
+    return { message: obj };
+  }
+
   @MessageNonRoute()
   recivedNonRoute(obj: any, consumeMessage: ConsumeMessage) {
     this.rmqServie.ack(consumeMessage);

test/rmq-nestjs.spec.ts

@@ -5,6 +5,7 @@ import { RmqModule, RmqService, TypeChannel, RMQError } from '../lib';
 import { ConnectionMockModule } from './mocks/rmq-nestjs.module';
 import { hostname } from 'node:os';
 import { MyGlobalRMQErrorHandler } from './mocks/error.handlers';
+import { MyClass } from './mocks/dto/myClass.dto';
 
 describe('RMQe2e', () => {
   let api: INestApplication;
@@ -195,6 +196,36 @@ describe('RMQe2e', () => {
     });
   });
 
+  describe('validation messages', () => {
+    it('send valid message', async () => {
+      const topic = 'message.valid';
+      const objMessage: MyClass = {
+        age: 20,
+        name: 'Diy0r',
+      };
+      const { message } = await rmqServieController.sendMessage(
+        objMessage,
+        topic,
+      );
+      expect(message).toEqual(message);
+    });
+
+    it('send invalid message', async () => {
+      try {
+        const topic = 'message.valid';
+        const objMessage = {
+          age: '20',
+          name: 'FooLii1p',
+        };
+        await rmqServieController.sendMessage(objMessage, topic);
+      } catch (error) {
+        expect(error.message).toEqual(
+          'The name must be less than 5; age must be an integer number',
+        );
+      }
+    });
+  });
+
   afterAll(async () => {
     await delay(500);
     await api.close();