chore: enrich metadata, update error msg in logger

src/controllers/source.ts

@@ -4,13 +4,27 @@ import { MiscService } from '../services/misc';
 import { SourcePostTransformationService } from '../services/source/postTransformation';
 import { ControllerUtility } from './util';
 import logger from '../logger';
+import { FixMe } from '../util/types';
 
 export class SourceController {
+  private static enrichMetadata(
+    metadata: { namespace: string; cluster: string; features: FixMe },
+    source: string,
+    version: string,
+  ) {
+    return {
+      ...metadata,
+      source,
+      version,
+    };
+  }
+
   public static async sourceTransform(ctx: Context) {
     logger.debug('Native(Source-Transform):: Request to transformer::', ctx.request.body);
     const requestMetadata = MiscService.getRequestMetadata(ctx);
     const events = ctx.request.body as object[];
     const { version, source }: { version: string; source: string } = ctx.params;
+    const enrichedMetadata = this.enrichMetadata(requestMetadata, source, version);
     const integrationService = ServiceSelector.getNativeSourceService();
 
     try {
@@ -28,10 +42,7 @@ export class SourceController {
       );
       ctx.body = resplist;
     } catch (err: any) {
-      logger.error(`[source transformation] ${err?.message || 'error in source transformation'}`, {
-        source,
-        version,
-      });
+      logger.error(err?.message || 'error in source transformation', enrichedMetadata);
       const metaTO = integrationService.getTags();
       const resp = SourcePostTransformationService.handleFailureEventsSource(err, metaTO);
       ctx.body = [resp];