fix: config handler workflow

package.json

@@ -64,7 +64,7 @@
   "dependencies": {
     "@nestjs/common": "^8.4.7",
     "@vodyani/class-decorator": "^8.2.3",
-    "@vodyani/core": "^8.9.7",
+    "@vodyani/core": "^8.9.8",
     "@vodyani/utils": "^8.7.1",
     "js-yaml": "^4.1.0",
     "lodash": "4.17.21"

src/provider/ark-manager.ts

@@ -2,7 +2,7 @@ import { FactoryProvider } from '@nestjs/common';
 import { This } from '@vodyani/class-decorator';
 import { AsyncInjectable, AsyncProviderFactory } from '@vodyani/core';
 
-import { ConfigHandlerOptions } from '../common';
+import { ConfigHandlerOptions, IConfigHandler } from '../common';
 import { ConfigClientSubscriber } from '../struct';
 import { ConfigArgumentHandler, ConfigClientHandler, DynamicDataSourceConfigObserverHandler } from '../struct/config-handler';
 
@@ -36,27 +36,27 @@ export class ArkManager extends AsyncProviderFactory {
     config: ConfigProvider,
     observer?: DynamicDataSourceConfigObserver,
   ) {
-    const handlers = [];
-    const handler = new ConfigArgumentHandler(config);
+    const flow: IConfigHandler[] = [];
+    const concreteHandler = new ConfigArgumentHandler(config);
+
+    flow.push(concreteHandler);
 
     if (this.options.clients) {
+      const handler = flow.pop();
       const subscriber = new ConfigClientSubscriber(config);
       const clientHandler = new ConfigClientHandler(config, subscriber);
 
-      handlers.push(clientHandler);
+      flow.push(handler.setNext(clientHandler));
     }
 
     if (this.options.enableDynamicDataSource) {
+      const handler = flow.pop();
       const observerHandler = new DynamicDataSourceConfigObserverHandler(observer);
 
-      handlers.push(observerHandler);
-    }
-
-    while (handlers.length > 0) {
-      handler.setNext(handlers.shift());
+      flow.push(handler.setNext(observerHandler));
     }
 
-    await handler.execute(this.options);
+    await concreteHandler.execute(this.options);
 
     return config;
   }

src/struct/config-client.ts

@@ -19,4 +19,12 @@ export class LocalConfigClient implements IConfigClient {
   public unSubscribe() {
     this.subscriber = null;
   }
+
+  public polling() {
+    // do something ...
+  }
+
+  public unPolling() {
+    // do something ...
+  }
 }

src/struct/config-handler.ts

@@ -7,7 +7,6 @@ abstract class AbstractConfigHandler<T = any> implements IConfigHandler<T> {
 
   public setNext(handler: IConfigHandler) {
     this.next = handler;
-
     return handler;
   }
 

test/struct/config-client.spec.ts

@@ -32,6 +32,8 @@ describe('LocalConfigClient', () => {
 
       public polling(): void {
         this.contrast({ poller: 'DemoConfigClient' });
+        super.polling();
+        super.unPolling();
       }
 
       public contrast(value: any) {

test/struct/config-handler.spec.ts

@@ -28,6 +28,8 @@ class DemoConfigClient extends LocalConfigClient {
 
   public polling(): void {
     this.contrast({ poller: 'DemoConfigClient' });
+    super.polling();
+    super.unPolling();
   }
 
   public contrast(value: any) {