UPDATE: Prepared Maestro for APM

src/clients/pipelines/client.service.ts

@@ -152,11 +152,10 @@ export class PipelinesClientService implements OnModuleInit {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          this.logger.error('Observable Error');
           reject(err);
         },
         complete() {
-          this.logger.info('Done');
+          // this.logger.info('Done');
         },
       });
     })
@@ -181,11 +180,10 @@ export class PipelinesClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          this.logger.error('Observable Error');
           reject(err);
         },
         complete() {
-          this.logger.info('Done');
+          // this.logger.info('Done');
         },
       });
     })
@@ -219,11 +217,10 @@ export class PipelinesClientService implements OnModuleInit {
             resolve({ status: statusArray });
           },
           error(err) {
-            this.logger.error('Observable Error');
             reject(err);
           },
           complete() {
-            this.logger.info('Done');
+            // this.logger.info('Done');
           },
         });
     })

src/main.ts

@@ -30,11 +30,9 @@ async function bootstrap() {
 
   Object.assign(apm, { logger });
 
-  apm.start({
-    serviceName: 'maestro',
-    disableSend: true, // This disables sending payloads to APM Server
-    centralConfig: false, // This disables periodic requests to the APM Server to fetch updated configuration
-  });
+  if (process.env.ENV != 'local') {
+    apm.start({});
+  }
 
   const app = await NestFactory.create(AppModule, {
     logger: logger,

src/modules/pipelines/pipelines.controller.ts

@@ -109,7 +109,10 @@ export class PipelinesController {
 
   @Get()
   async findAll(@Body() data) {
-    this.logger.info(process.env.DEV_URL + `/pipeline ON Find All ROUTE`);
+    this.logger.info(process.env.DEV_URL + `/pipeline ON Find All ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.findAll(data);

src/modules/pipelines/pipelines.service.ts

@@ -6,7 +6,7 @@ import { objectCamelToSnake } from 'src/utils/CaseConverter';
 
 @Injectable()
 export class PipelinesService {
-  constructor(private pipelineClient: PipelinesClientService) { }
+  constructor(private pipelineClient: PipelinesClientService) {}
 
   adjustPayload(payload) {
     if (payload.input?.input_generic) {