Merge pull request #15598 from ghyghoo8/patch-1

feat(errors): add InvalidTcpDataReceptionException for handling TCP receive errors​

Author: kamilmysliwiec

packages/microservices/errors/invalid-tcp-data-reception.exception.ts

@@ -0,0 +1,19 @@
+import { RuntimeException } from '@nestjs/core/errors/exceptions/runtime.exception';
+
+export class InvalidTcpDataReceptionException extends RuntimeException {
+  constructor(err: string | Error) {
+    const errMsgStr =
+      typeof err === 'string'
+        ? err
+        : err &&
+            typeof err === 'object' &&
+            'message' in err &&
+            typeof (err as any).message === 'string'
+          ? (err as any).message
+          : String(err);
+    const _errMsg = errMsgStr.includes('Corrupted length value')
+      ? `Corrupted length value of the received data supplied in a packet`
+      : `The invalid received message from tcp server`;
+    super(_errMsg);
+  }
+}

packages/microservices/server/server-tcp.ts

@@ -14,6 +14,7 @@ import { TcpContext } from '../ctx-host/tcp.context';
 import { Transport } from '../enums';
 import { TcpEvents, TcpEventsMap, TcpStatus } from '../events/tcp.events';
 import { JsonSocket, TcpSocket } from '../helpers';
+import { InvalidTcpDataReceptionException } from '../errors/invalid-tcp-data-reception.exception';
 import {
   IncomingRequest,
   PacketId,
@@ -81,7 +82,10 @@ export class ServerTCP extends Server<TcpEvents, TcpStatus> {
     readSocket.on('message', async (msg: ReadPacket & PacketId) =>
       this.handleMessage(readSocket, msg),
     );
-    readSocket.on(TcpEventsMap.ERROR, this.handleError.bind(this));
+    readSocket.on(TcpEventsMap.ERROR, err => {
+      const invalidError = new InvalidTcpDataReceptionException(err);
+      this.handleError(invalidError as any);
+    });
   }
 
   public async handleMessage(socket: TcpSocket, rawMessage: unknown) {