fix: config registry list

Author: zulfikar4568

src/frameworks/data-services/config/config-collector.module.ts

@@ -0,0 +1,8 @@
+import { Module } from '@nestjs/common';
+import { ConfigCollectorService } from './config-collector.service';
+
+@Module({
+  providers: [ConfigCollectorService],
+  exports: [ConfigCollectorService],
+})
+export class ConfigCollectorModule {}

src/frameworks/data-services/config/config-collector.service.ts

@@ -0,0 +1,90 @@
+import { Injectable } from '@nestjs/common';
+import { ConfigRegistry } from './config-registry.service';
+
+@Injectable()
+export class ConfigCollectorService {
+  private extendedConfigs: Record<string, any> = {};
+  private sensitiveKeys = ['secret', 'password', 'key', 'cert', 'ca'];
+
+  constructor() {}
+
+  /**
+   * Register a configuration
+   */
+  registerConfig(name: string, config: any): void {
+    this.extendedConfigs[name] = config;
+    this.collectConfig(name, config);
+  }
+
+  /**
+   * Check if a key is sensitive
+   */
+  private isSensitiveKey(key: string): boolean {
+    return this.sensitiveKeys.some((sensitiveKey) =>
+      key.toLowerCase().includes(sensitiveKey.toLowerCase()),
+    );
+  }
+
+  /**
+   * Mask sensitive value
+   */
+  private maskValue(value: any): any {
+    if (typeof value === 'string') {
+      return '******';
+    }
+    return value;
+  }
+
+  /**
+   * Collect configuration keys from a specific config object
+   */
+  private collectConfig(configName: string, config: any): void {
+    if (!config) return;
+
+    const processConfig = (obj: any): any => {
+      if (!obj) return obj;
+
+      if (typeof obj === 'object') {
+        const result = Array.isArray(obj) ? [] : {};
+
+        Object.entries(obj).forEach(([key, value]) => {
+          if (typeof value === 'object' && value !== null) {
+            result[key] = processConfig(value);
+          } else {
+            result[key] = this.isSensitiveKey(key)
+              ? this.maskValue(value)
+              : value;
+          }
+        });
+
+        return result;
+      }
+
+      return obj;
+    };
+
+    const processedConfig = processConfig(config);
+    ConfigRegistry.addConfigKey(configName, null, processedConfig);
+  }
+
+  /**
+   * Get all collected configuration keys
+   */
+  getAllConfigKeys(): Record<string, any> {
+    return ConfigRegistry.getAllConfigKeys();
+  }
+
+  /**
+   * Get configuration keys for a specific category
+   */
+  getConfigKeysForCategory(category: string): any {
+    return ConfigRegistry.getConfigKeysForCategory(category);
+  }
+
+  /**
+   * Get a configuration by name
+   */
+  getConfig(name: string): any {
+    return this.extendedConfigs[name];
+  }
+}

src/frameworks/data-services/config/config-registry.service.ts

@@ -0,0 +1,60 @@
+/**
+ * Global Configuration Registry Service
+ *
+ * Stores and organizes all configuration keys by category.
+ * This provides a centralized way to access configuration metadata.
+ */
+export class ConfigRegistry {
+  private static configKeys: Record<string, any> = {};
+
+  /**
+   * Get all configuration keys organized by category
+   */
+  static getAllConfigKeys(): Record<string, any> {
+    return { ...this.configKeys };
+  }
+
+  /**
+   * Get configuration keys for a specific category
+   */
+  static getConfigKeysForCategory(category: string): any {
+    return this.configKeys[category] || {};
+  }
+
+  /**
+   * Add or update a configuration key to the registry
+   */
+  static addConfigKey(
+    category: string,
+    subcategory: string | null,
+    value: any,
+  ): void {
+    if (!this.configKeys[category]) {
+      this.configKeys[category] = subcategory ? {} : [];
+    }
+
+    if (subcategory) {
+      if (!this.configKeys[category][subcategory]) {
+        this.configKeys[category][subcategory] = [];
+      }
+
+      if (!this.configKeys[category][subcategory].includes(value)) {
+        this.configKeys[category][subcategory].push(value);
+      }
+    } else {
+      if (
+        Array.isArray(this.configKeys[category]) &&
+        !this.configKeys[category].includes(value)
+      ) {
+        this.configKeys[category].push(value);
+      }
+    }
+  }
+
+  /**
+   * Clear all registered configuration keys
+   */
+  static clear(): void {
+    this.configKeys = {};
+  }
+}

src/frameworks/data-services/config/index.ts

@@ -0,0 +1,3 @@
+export * from './config-collector.service';
+export * from './config-registry.service';
+export * from './config-collector.module';

src/frameworks/data-services/index.ts

@@ -1,3 +1,4 @@
 export * from './nats';
 export * from './prisma';
 export * from './method-collector';
+export * from './config';

src/modules/messaging/domain/usecases/handlers/system-control.handler.ts

@@ -1,4 +1,9 @@
-import { ErrorResponse, log, SuccessResponse } from '@/frameworks';
+import {
+  ConfigCollectorService,
+  ErrorResponse,
+  log,
+  SuccessResponse,
+} from '@/frameworks';
 import fs from 'fs';
 import path from 'path';
 import {
@@ -7,7 +12,6 @@ import {
 } from '@/modules/messaging/domain/entities/messaging-adapter.interface';
 import { Inject, Injectable } from '@nestjs/common';
 import * as os from 'os';
-import { ConfigRegistryService } from '@/modules/messaging/domain/usecases/services/config-registry.service';
 import { SubjectFactory } from '../factories/subject.factory';
 import { SYSTEM_CONTROL_MESSAGE_TYPE } from './constant.handler';
 import {
@@ -22,7 +26,7 @@ export class SystemControlHandler {
   constructor(
     @Inject(MESSAGING_ADAPTER)
     private readonly messagingAdapter: IMessagingAdapter,
-    private readonly configRegistry: ConfigRegistryService,
+    private readonly configCollector: ConfigCollectorService,
     private readonly methodCollectorService: MethodCollectorService,
   ) {}
 
@@ -150,7 +154,7 @@ export class SystemControlHandler {
 
   public async getConfigurationNames() {
     try {
-      const configNames = this.configRegistry.getAllConfigKeys();
+      const configNames = this.configCollector.getAllConfigKeys();
       const response = new SuccessResponse(
         'Configuration names retrieved successfully',
         {

src/modules/messaging/domain/usecases/index.ts

@@ -2,5 +2,4 @@ export * from './adapter/nats-messaging.adapter';
 export * from './handlers/system-control.handler';
 export * from './handlers/system-monitor.handler';
 export * from './handlers/constant.handler';
-export * from './services/config-registry.service';
 export * from './factories/subject.factory';