diff --git a/src/clients/pipelines/client.service.ts b/src/clients/pipelines/client.service.ts index 8ae6369..c197ca7 100644 --- a/src/clients/pipelines/client.service.ts +++ b/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'); }, }); }) diff --git a/src/main.ts b/src/main.ts index cee2b3d..a0accc9 100644 --- a/src/main.ts +++ b/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, diff --git a/src/modules/pipelines/pipelines.controller.ts b/src/modules/pipelines/pipelines.controller.ts index d34a23e..1c40836 100644 --- a/src/modules/pipelines/pipelines.controller.ts +++ b/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); diff --git a/src/modules/pipelines/pipelines.service.ts b/src/modules/pipelines/pipelines.service.ts index 3073831..2ed3c3a 100644 --- a/src/modules/pipelines/pipelines.service.ts +++ b/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) {