feat: improve the execution efficiency of initialization and operation

src/common/interface/client.ts

@@ -1,6 +1,6 @@
 import { IConfigSubscriber } from './config';
 
-export interface IClient<T = any, C = any> {
+export interface IClientAdapter<T = any, C = any> {
   /**
    * Close the client.
    *
@@ -20,15 +20,15 @@ export interface IClient<T = any, C = any> {
    *
    * @publicApi
    */
-  create: (config: C) => T | Promise<T>;
+  create: (config: C) => void | Promise<void>;
   /**
    * Redeploy the client instance.
    *
    * @param config C The configuration of client instance
    *
    * @publicApi
    */
-  redeploy: (config: C) => T | Promise<T>;
+  redeploy: (config: C) => void | Promise<void>;
 }
 
 export interface IClientMediator<T = any, C = any> extends IConfigSubscriber {
@@ -44,11 +44,11 @@ export interface IClientMediator<T = any, C = any> extends IConfigSubscriber {
    * Deploy the client inside to mediator.
    *
    * @param key string The key of client.
-   * @param client IClient<T, C> The client.
+   * @param client IClientAdapter<T, C> The client.
    *
    * @publicApi
    */
-  deploy: (key: string, client: IClient<T, C>) => void | Promise<void>;
+  deploy: (key: string, client: IClientAdapter<T, C>) => void | Promise<void>;
   /**
    * Redeploy the client inside to mediator.
    *
@@ -64,5 +64,5 @@ export interface IClientMediator<T = any, C = any> extends IConfigSubscriber {
    *
    * @publicApi
    */
-  getClient: (key: string) => IClient<T, C>;
+  getClient: (key: string) => IClientAdapter<T, C>;
 }

src/common/interface/config.ts

@@ -27,14 +27,14 @@ export interface IConfig<T = any> {
    */
   search: <K extends keyof T>(key: K) => T[K]
   /**
-   * Set the configuration with property key.
+   * Replace the configuration with property key.
    *
    * @param key string The property of configuration.
    * @param value any The configuration value.
    *
    * @publicApi
    */
-  set: (key: string, value: any) => void;
+  replace: (key: string, value: any) => void;
   /**
    * Merge the configuration.
    *
@@ -110,7 +110,7 @@ export interface IConfigObserver extends Observer {
   *
   * @publicApi
   */
-  subscribe: (key: string, subscriber: IConfigSubscriber) => void | Promise<void>;
+  subscribe: (key: string, subscriber: IConfigSubscriber) => void;
   /**
   * Notify subscribers of configuration updates.
   *
@@ -125,13 +125,13 @@ export interface IConfigObserver extends Observer {
   *
   * @publicApi
   */
-  polling: () => void | Promise<void>;
+  polling: () => void;
   /**
   * Close the polling.
   *
   * @publicApi
   */
-  unPolling: () => void | Promise<void>;
+  unPolling: () => void;
   /**
   * Remove the subscriber from client by the key of configuration..
   *
@@ -150,7 +150,7 @@ export interface IConfigClient extends Observer {
    *
    * @publicApi
    */
-  load: <T = any>(loader: IConfigLoader) => T | Promise<T>;
+  init: <T = any>(loader: IConfigLoader) => T | Promise<T>;
   /**
    * Contrasting configuration.
    *
@@ -166,7 +166,7 @@ export interface IConfigClient extends Observer {
   *
   * @publicApi
   */
-  subscribe: (subscriber: IConfigClientSubscriber) => void | Promise<void>;
+  subscribe: (subscriber: IConfigClientSubscriber) => void;
   /**
   * Notify subscribers of configuration updates.
   *
@@ -180,13 +180,13 @@ export interface IConfigClient extends Observer {
   *
   * @publicApi
   */
-  polling: () => void | Promise<void>;
+  polling: () => void;
   /**
   * Close the polling.
   *
   * @publicApi
   */
-  unPolling: () => void | Promise<void>;
+  unPolling: () => void;
   /**
   * Remove the subscriber from client by the key of configuration..
   *

src/common/interface/options.ts

@@ -11,12 +11,11 @@ export interface ConfigClientOptions {
 
 export interface ConfigHandlerOptions<T = any> {
   args: T;
-  clients: ConfigClientOptions[];
-  enableDynamicDataSource: boolean;
-  enableDynamicDataSourcePolling: boolean;
+  clients?: ConfigClientOptions[];
+  enableDynamicDataSource?: boolean;
 }
 
 export interface ArkOptions<T = any> extends ConfigHandlerOptions<T> {
-  imports: ModuleMetadata['imports'];
-  global: boolean;
+  imports?: ModuleMetadata['imports'];
+  global?: boolean;
 }

src/provider/config-manager.ts → src/provider/ark-manager.ts

@@ -2,7 +2,7 @@ import { FactoryProvider } from '@nestjs/common';
 import { This } from '@vodyani/class-decorator';
 import { AsyncInjectable, AsyncProvider, AsyncProviderFactory } from '@vodyani/core';
 
-import { ArkOptions } from '../common';
+import { ConfigHandlerOptions } from '../common';
 import { ConfigClientSubscriber } from '../struct';
 import { ConfigArgumentHandler, ConfigClientHandler, DynamicDataSourceConfigObserverHandler } from '../struct/config-handler';
 
@@ -11,10 +11,10 @@ import { DynamicDataSourceConfigObserver } from './dynamic-data-source';
 
 @AsyncInjectable
 export class ArkManager extends AsyncProvider implements AsyncProviderFactory {
-  private options: ArkOptions;
+  private options: ConfigHandlerOptions;
 
   @This
-  public create(options: ArkOptions): FactoryProvider {
+  public create(options: ConfigHandlerOptions): FactoryProvider {
     const inject: any[] = [ConfigProvider];
     const { enableDynamicDataSource } = options;
 
@@ -41,12 +41,12 @@ export class ArkManager extends AsyncProvider implements AsyncProviderFactory {
 
     if (this.options.clients) {
       const subscriber = new ConfigClientSubscriber(config);
-      const clientHandler = new ConfigClientHandler(subscriber);
+      const clientHandler = new ConfigClientHandler(config, subscriber);
 
       handlers.push(clientHandler);
     }
 
-    if (this.options.enableDynamicDataSourcePolling) {
+    if (this.options.enableDynamicDataSource) {
       const observerHandler = new DynamicDataSourceConfigObserverHandler(observer);
 
       handlers.push(observerHandler);

src/provider/config.ts

@@ -1,5 +1,7 @@
 import { Injectable } from '@nestjs/common';
-import { isValidDict, toDeepMatch, toDeepMerge, toDeepRestore } from '@vodyani/utils';
+import { This } from '@vodyani/class-decorator';
+import { isValidDict, toDeepMatch, toDeepMerge, toDeepSave } from '@vodyani/utils';
+import { cloneDeep } from 'lodash';
 
 import { IConfig } from '../common';
 
@@ -9,25 +11,33 @@ export class ConfigProvider<T = any> implements IConfig<T> {
 
   private readonlyConfig: T;
 
+  @This
   public get<V = any>(key: string) {
     return toDeepMatch<V>(this.readonlyConfig, key);
   }
 
+  @This
   public search<K extends keyof T>(key: K) {
     return this.readonlyConfig[key];
   }
 
-  public set(key: string, value: any) {
-    this.merge(toDeepRestore<T>(value, key));
+  @This
+  public replace(key: string, value: any) {
+    toDeepSave(this.writeConfig, value, key);
+    this.updateReadonlyConfig();
   }
 
+  @This
   public merge(config: T) {
     if (isValidDict(config)) {
       this.writeConfig = toDeepMerge(this.writeConfig, config);
-
-      this.readonlyConfig = this.writeConfig;
-
-      Object.freeze(this.readonlyConfig);
+      this.updateReadonlyConfig();
     }
   }
+
+  @This
+  private updateReadonlyConfig() {
+    this.readonlyConfig = cloneDeep(this.writeConfig);
+    Object.freeze(this.readonlyConfig);
+  }
 }

src/provider/dynamic-data-source.ts

@@ -1,14 +1,14 @@
 import { Injectable } from '@nestjs/common';
 import { This } from '@vodyani/class-decorator';
-import { CircularHandler, isValid, circular } from '@vodyani/utils';
+import { CircularHandler, circular } from '@vodyani/utils';
 
-import { IClient, IClientMediator, IConfigObserver, IConfigSubscriber, toHash } from '../common';
+import { IClientAdapter, IClientMediator, IConfigObserver, IConfigSubscriber, toHash } from '../common';
 
 import { ConfigProvider } from './config';
 
 @Injectable()
 export class AsyncDynamicDataSourceProvider<T = any, C = any> implements IClientMediator<T, C> {
-  private readonly clients = new Map<string, IClient<T, C>>();
+  private readonly clients = new Map<string, IClientAdapter<T, C>>();
 
   private readonly keys = new Set<string>();
 
@@ -27,7 +27,7 @@ export class AsyncDynamicDataSourceProvider<T = any, C = any> implements IClient
   }
 
   @This
-  public async deploy(key: string, client: IClient<T, C>) {
+  public async deploy(key: string, client: IClientAdapter<T, C>) {
     const config = this.config.get<C>(key);
 
     await client.create(config);
@@ -52,14 +52,14 @@ export class AsyncDynamicDataSourceProvider<T = any, C = any> implements IClient
   }
 
   @This
-  public update(key: string, value: any) {
-    this.redeploy(key, value);
+  public async update(key: string, value: any) {
+    await this.redeploy(key, value);
   }
 }
 
 @Injectable()
 export class DynamicDataSourceProvider<T = any, C = any> implements IClientMediator<T, C> {
-  private readonly clients = new Map<string, IClient<T, C>>();
+  private readonly clients = new Map<string, IClientAdapter<T, C>>();
 
   private readonly keys = new Set<string>();
 
@@ -78,7 +78,7 @@ export class DynamicDataSourceProvider<T = any, C = any> implements IClientMedia
   }
 
   @This
-  public deploy(key: string, client: IClient<T, C>) {
+  public deploy(key: string, client: IClientAdapter<T, C>) {
     const config = this.config.get<C>(key);
 
     client.create(config);
@@ -152,10 +152,6 @@ export class DynamicDataSourceConfigObserver<T = any> implements IConfigObserver
 
   @This
   public polling() {
-    if (isValid(this.poller)) {
-      this.unPolling();
-    }
-
     this.poller = circular(this.circularContrast, 1000);
   }
 
@@ -176,6 +172,8 @@ export class DynamicDataSourceConfigObserver<T = any> implements IConfigObserver
     this.keys.forEach((key) => {
       const value = this.config.get(key);
 
+      console.log(value);
+
       this.contrast(key, value);
     });
   }

src/provider/index.ts

@@ -1,3 +1,3 @@
-export * from './config-manager';
+export * from './ark-manager';
 export * from './config';
 export * from './dynamic-data-source';

src/struct/config-client.ts

@@ -1,22 +1,28 @@
+import { isValidString } from '@vodyani/utils';
+
 import { IConfigClient, IConfigLoader, IConfigClientSubscriber, toHash } from '../common';
 
-export abstract class ConfigClient implements IConfigClient {
+export abstract class AbstractConfigClient implements IConfigClient {
   private subscriber: IConfigClientSubscriber;
 
   private hash: string;
 
   public contrast(value: any) {
-    const afterHash = toHash(value);
-    const beforeHash = this.hash;
-
-    if (afterHash !== beforeHash) {
-      this.notify(value);
-      this.hash = afterHash;
+    if (isValidString(this.hash)) {
+      const afterHash = toHash(value);
+      const beforeHash = this.hash;
+
+      if (afterHash !== beforeHash) {
+        this.notify(value);
+        this.hash = afterHash;
+      }
     }
   }
 
-  public load<T = any>(loader: IConfigLoader) {
-    return loader.execute<T>();
+  public init<T = any>(loader: IConfigLoader) {
+    const result = loader.execute<T>();
+    this.hash = toHash(result);
+    return result;
   }
 
   public subscribe(subscriber: IConfigClientSubscriber) {
@@ -40,4 +46,4 @@ export abstract class ConfigClient implements IConfigClient {
   }
 }
 
-export class LocalConfigClient extends ConfigClient {}
+export class LocalConfigClient extends AbstractConfigClient {}