fix: register/unregister microservice & remote middleware on all workers

Author: MatthewPattell

__tests__/services/microservice-test.ts

@@ -60,16 +60,13 @@ describe('services/microservice', () => {
     const stubbed = sinon.stub(ms, 'sendRequest').resolves();
 
     await ms.gatewayRegisterCancel('gateway');
-    await ms.gatewayRegisterCancel('gateway', false);
 
     stubbed.restore();
 
     const args = stubbed.firstCall.lastArg;
-    const args2 = stubbed.secondCall.lastArg;
 
-    expect(stubbed).to.callCount(2);
-    expect(args.reqParams.headers).to.include({ type: 'async' });
-    expect(args2.reqParams.headers).to.not.include({ type: 'async' });
+    expect(stubbed).to.callCount(1);
+    expect(args.reqParams.headers).to.include({ type: 'pub' });
   });
 
   it('should throw register remote middleware - before/after', () => {

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lomray/microservice-nodejs-lib",
-	"version": "1.0.0",
+	"version": "1.0.1",
 	"description": "Package for create microservice architecture based on NodeJS & inverted json.",
 	"main": "lib/index.js",
 	"types": "lib/index.d.ts",

src/services/microservice.ts

@@ -149,8 +149,8 @@ class Microservice extends AbstractMicroservice {
       `${gatewayName}.${this.autoRegistrationEndpoint}`,
       { action: AutoRegistrationAction.ADD },
       {
-        // timeout 10 min - wait until gateway becomes available
-        reqParams: { timeout },
+        // timeout 10 min - wait until gateway becomes available, type: pub - message will be received by all gateways
+        reqParams: { timeout, headers: { type: 'pub' } },
       },
     );
 
@@ -164,13 +164,18 @@ class Microservice extends AbstractMicroservice {
   /**
    * Cancel microservice registration at gateway
    */
-  public gatewayRegisterCancel(gatewayName: string, isAsync = true): Promise<MicroserviceResponse> {
+  public gatewayRegisterCancel(gatewayName: string): Promise<MicroserviceResponse> {
     return this.sendRequest(
       `${gatewayName}.${this.autoRegistrationEndpoint}`,
       {
         action: AutoRegistrationAction.REMOVE,
       },
-      { reqParams: { headers: isAsync ? { type: 'async' } : {} } },
+      {
+        reqParams: {
+          // type: pub - message will be received by all gateways
+          headers: { type: 'pub' },
+        },
+      },
     );
   }
 

src/services/remote-middleware.ts

@@ -175,8 +175,8 @@ class RemoteMiddleware {
     const { timeout = 1000 * 60 * 5, shouldCancelRegister = true } = params;
 
     const result = await this.microservice.sendRequest(`${microservice}.${this.endpoint}`, data, {
-      // timeout 5 min - wait until microservice becomes available
-      reqParams: { timeout },
+      // timeout 5 min - wait until gateway becomes available, type: pub - message will be received by all gateways
+      reqParams: { timeout, headers: { type: 'pub' } },
     });
 
     if (shouldCancelRegister) {
@@ -207,7 +207,8 @@ class RemoteMiddleware {
             action: RemoteMiddlewareActionType.REMOVE,
             method,
           },
-          { reqParams: { headers: { type: 'async' } } },
+          // type: pub - message will be received by all gateways
+          { reqParams: { headers: { type: 'pub' } } },
         );
       });