feature(microservices): add logic to transform patterns to routes

Author: Geass1000

packages/microservices/client/client-proxy.ts

@@ -18,6 +18,8 @@ import {
   WritePacket,
 } from '../interfaces';
 
+import * as Utils from '../utils';
+
 export abstract class ClientProxy {
   public abstract connect(): Promise<any>;
   public abstract close(): any;
@@ -101,6 +103,6 @@ export abstract class ClientProxy {
   }
 
   protected normalizePattern<T = any>(pattern: T): string {
-    return (isString(pattern) ? pattern : JSON.stringify(pattern)) as string;
+    return Utils.MsvcUtil.transformPatternToRoute(pattern);
   }
 }

packages/microservices/server/server.ts

@@ -18,6 +18,8 @@ import {
 } from '../interfaces';
 import { NO_EVENT_HANDLER } from './../constants';
 
+import * as Utils from '../utils';
+
 export abstract class Server {
   protected readonly messageHandlers = new Map<string, MessageHandler>();
   protected readonly logger = new Logger(Server.name);
@@ -28,17 +30,19 @@ export abstract class Server {
     isEventHandler = false,
   ) {
     const key = isString(pattern) ? pattern : JSON.stringify(pattern);
+    const route = this.getRouteFromPattern(key);
     callback.isEventHandler = isEventHandler;
-    this.messageHandlers.set(key, callback);
+    this.messageHandlers.set(route, callback);
   }
 
   public getHandlers(): Map<string, MessageHandler> {
     return this.messageHandlers;
   }
 
   public getHandlerByPattern(pattern: string): MessageHandler | null {
-    return this.messageHandlers.has(pattern)
-      ? this.messageHandlers.get(pattern)
+    const route = this.getRouteFromPattern(pattern);
+    return this.messageHandlers.has(route)
+      ? this.messageHandlers.get(route)
       : null;
   }
 
@@ -99,4 +103,25 @@ export abstract class Server {
   private isObservable(input: unknown): input is Observable<any> {
     return input && isFunction((input as Observable<any>).subscribe);
   }
+
+  /**
+   * Transforms the server Pattern to valid type and returns a route for him.
+   *
+   * @param  {string} pattern - server pattern
+   * @returns string
+   */
+  private getRouteFromPattern(pattern: string): string {
+    let validPattern: any;
+
+    try {
+      // Gets the pattern in JSON format
+      validPattern = JSON.parse(pattern);
+    } catch (error) {
+      // Uses a fundamental object (`pattern` variable without any conversion)
+      validPattern = pattern;
+    }
+
+    // Transform the Pattern to Route
+    return Utils.MsvcUtil.transformPatternToRoute(validPattern);
+  }
 }