feat: enhance logging by using masked TmqConfig in WsConsumer constructor

Author: qevolg

nodejs/src/common/utils.ts

@@ -219,19 +219,19 @@ export function maskUrlForLog(url: URL | null): string {
     return masked.toString().replace(/%5BREDACTED%5D/g, "[REDACTED]");
 }
 
-export function maskTmqConfigForLog(config: Map<string, any>): TmqConfig {
-    const maskedConfig = new TmqConfig(config);
-    if (maskedConfig.url) {
-        maskedConfig.url = new URL(maskUrlForLog(maskedConfig.url));
+export function maskTmqConfigForLog(config: TmqConfig): object {
+    const masked = { ...config, otherConfigs: Object.fromEntries(config.otherConfigs) };
+    if (masked.url) {
+        masked.url = new URL(maskUrlForLog(masked.url));
     }
-    if (maskedConfig.sql_url) {
-        maskedConfig.sql_url = new URL(maskUrlForLog(maskedConfig.sql_url));
+    if (masked.sql_url) {
+        masked.sql_url = new URL(maskUrlForLog(masked.sql_url));
     }
-    if (maskedConfig.token) {
-        maskedConfig.token = "[REDACTED]";
+    if (masked.token) {
+        masked.token = "[REDACTED]";
     }
-    if (maskedConfig.password) {
-        maskedConfig.password = "[REDACTED]";
+    if (masked.password) {
+        masked.password = "[REDACTED]";
     }
-    return maskedConfig;
+    return masked;
 }

nodejs/src/tmq/wsTmq.ts

@@ -34,7 +34,7 @@ export class WsConsumer {
     private constructor(wsConfig: Map<string, any>) {
         this._wsConfig = new TmqConfig(wsConfig);
         if (logger.isDebugEnabled()) {
-            logger.debug(maskTmqConfigForLog(wsConfig));
+            logger.debug(maskTmqConfigForLog(this._wsConfig));
         }
         if (wsConfig.size == 0 || !this._wsConfig.url) {
             throw new WebSocketInterfaceError(