scalecube · idanilt · Feb 13, 2021 · Feb 13, 2021
diff --git a/packages/scalecube-microservice/src/Microservices/endpointsUtil.ts b/packages/scalecube-microservice/src/Microservices/endpointsUtil.ts
@@ -23,9 +23,10 @@ export interface Endpoints {
 export function minimized(endpoints: MicroserviceApi.Endpoint[]): Endpoints {
   const res: Endpoints = {};
   endpoints.forEach((e) => {
-    res[getFullAddress(e.address)] = res[getFullAddress(e.address)] || {};
-    res[getFullAddress(e.address)][e.serviceName] = res[getFullAddress(e.address)][e.serviceName] || {};
-    res[getFullAddress(e.address)][e.serviceName][e.methodName] = sAsyncModel[e.asyncModel];
+    const addr = getFullAddress(e.address);
+    res[addr] = res[addr] || {};
+    res[addr][e.serviceName] = res[getFullAddress(e.address)][e.serviceName] || {};
+    res[addr][e.serviceName][e.methodName] = sAsyncModel[e.asyncModel];
   });
   return res;
 }

diff --git a/packages/scalecube-microservice/tests/unit/Microservices/endpointsUtil.spec.ts b/packages/scalecube-microservice/tests/unit/Microservices/endpointsUtil.spec.ts
@@ -28,6 +28,18 @@ describe('endpointsUtil', () => {
           path: 'B',
         },
       },
+      {
+        qualifier: 'GreetingService/greet$',
+        serviceName: 'GreetingService',
+        methodName: 'greet$',
+        asyncModel: 'requestStream' as AsyncModel,
+        address: {
+          protocol: 'pm',
+          host: 'defaultHost',
+          port: 1234,
+          path: '',
+        },
+      },
     ];
 
     expect(endpoints).toEqual(restore(minimized(endpoints)));

diff --git a/packages/utils/src/address.ts b/packages/utils/src/address.ts
@@ -55,7 +55,7 @@ const buildAddress = ({
   key: string;
 }) => {
   let [v1, rest]: any = str.split(delimiter);
-  if (!rest) {
+  if (rest === undefined) {
     rest = v1;
     v1 = optionalValue;
   }

diff --git a/packages/utils/tests/address.spec.ts b/packages/utils/tests/address.spec.ts
@@ -178,4 +178,19 @@ describe('Test address', () => {
       })
     );
   });
+  test(`
+  Given a string 'ws://localhost:1234'
+  When calling getAddress with the given string
+  Then result will matching address object
+  `, () => {
+    const address = getAddress('ws://localhost:1234/');
+    expect(address).toMatchObject(
+      expect.objectContaining({
+        protocol: 'ws',
+        path: '',
+        host: 'localhost',
+        port: 1234,
+      })
+    );
+  });
 });