refactor: Enhance logging data structure in publish function

Author: Dobrunia

src/metrics/graphql.ts

@@ -81,7 +81,11 @@ export const graphqlMetricsPlugin: ApolloServerPlugin = {
 
         const hasErrors = ctx.errors && ctx.errors.length > 0;
 
-        const breadcrumbData: Record<string, string | number> = { operationName, operationType, durationMs };
+        const breadcrumbData: Record<string, string | number> = {
+          operationName,
+          operationType,
+          durationMs,
+        };
 
         if (hasErrors) {
           breadcrumbData.errors = ctx.errors!.map((e: GraphQLError) => e.message).join('; ');

src/metrics/mongodb.ts

@@ -312,7 +312,12 @@ export function setupMongoMetrics(client: MongoClient): void {
         category: 'db.query',
         message: `${metadata.db}.${metadata.collectionFamily}.${metadata.commandName} ${event.duration}ms`,
         level: 'debug',
-        data: { db: metadata.db, collection: metadata.collectionFamily, command: metadata.commandName, durationMs: event.duration },
+        data: {
+          db: metadata.db,
+          collection: metadata.collectionFamily,
+          command: metadata.commandName,
+          durationMs: { value: event.duration },
+        },
       });
 
       // Clean up metadata
@@ -353,7 +358,13 @@ export function setupMongoMetrics(client: MongoClient): void {
         category: 'db.query',
         message: `${metadata.db}.${metadata.collectionFamily}.${metadata.commandName} FAILED: ${errorMsg} ${event.duration}ms`,
         level: 'error',
-        data: { db: metadata.db, collection: metadata.collectionFamily, command: metadata.commandName, durationMs: event.duration, errorCode },
+        data: {
+          db: metadata.db,
+          collection: metadata.collectionFamily,
+          command: metadata.commandName,
+          durationMs: { value: event.duration },
+          errorCode,
+        },
       });
 
       // Clean up metadata

src/models/usersFactory.ts

@@ -4,7 +4,6 @@ import { Collection, Db, OptionalId } from 'mongodb';
 import DataLoaders from '../dataLoaders';
 import { UserDBScheme } from '@hawk.so/types';
 
-
 /**
  * Users factory to work with User Model
  */

src/rabbitmq.ts

@@ -138,7 +138,10 @@ export async function publish(exchange: string, route: string, message: string,
       category: 'amqp.publish',
       message: `AMQP publish ${exchange || '(default)'}/${route}`,
       level: 'debug',
-      data: { exchange, route },
+      data: {
+        exchange: { value: exchange },
+        route: { value: route },
+      },
     });
     debug(`Message sent: ${message}`);
   } catch (err) {
@@ -147,7 +150,10 @@ export async function publish(exchange: string, route: string, message: string,
       category: 'amqp.publish',
       message: `AMQP publish FAILED ${exchange || '(default)'}/${route}: ${(err as Error).message}`,
       level: 'error',
-      data: { exchange, route },
+      data: {
+        exchange: { value: exchange },
+        route: { value: route },
+      },
     });
     HawkCatcher.send(err as Error);
     console.log('Message was rejected:', (err as Error).stack);