diff --git a/src/modules/payments/processor/payment-default.processor.ts b/src/modules/payments/processor/payment-default.processor.ts index ebf9383..9a6de21 100644 --- a/src/modules/payments/processor/payment-default.processor.ts +++ b/src/modules/payments/processor/payment-default.processor.ts @@ -1,46 +1,31 @@ import { Injectable, Logger } from '@nestjs/common'; -import { HttpService } from '@nestjs/axios'; import { ConfigService } from '@nestjs/config'; import { Payment } from '../entities/payment.entity'; -import { firstValueFrom } from 'rxjs'; import { InjectRepository } from '@nestjs/typeorm'; import { Repository } from 'typeorm'; import { ProcessorTypeEnum } from '../enumns/processor-type.enum'; import { PaymentStatusEnum } from '../enumns/payment-status.enum'; +import { MakePaymentToProcessorService } from '../services/make-payment-to-processor.service'; @Injectable() export class PaymentDefaultProcessor { private readonly logger = new Logger(PaymentDefaultProcessor.name); constructor( - private readonly httpService: HttpService, private readonly configService: ConfigService, @InjectRepository(Payment) private readonly repository: Repository, + private makePaymentToProcessorService: MakePaymentToProcessorService, ) {} async execute(payment: Payment): Promise { const url = this.configService.get('paymentProcessors.defaultUrl'); - this.logger.log( - `Processando Pagamento ${payment.id} com default processor`, + const responseExists = await this.makePaymentToProcessorService.execute( + payment, + url, ); - const paymentData = { - amount: payment.amount, - correlationId: payment.correlationId, - }; - - const response = await firstValueFrom( - this.httpService.post(`${url}/payments`, paymentData, { - timeout: 2000, // 30 segundos - }), - ); - this.logger.log(response.status === 200); - if (response.status === 200) { - this.logger.log( - `Payment ${payment.id} processed successfully via default processor`, - ); - + if (responseExists) { await this.repository.update(payment.id, { ...payment, paymentProcessor: ProcessorTypeEnum.DEFAULT, @@ -48,9 +33,7 @@ export class PaymentDefaultProcessor { }); return true; } - this.logger.log( - `Payment ${payment.id} not processed successfully via default processor: ${response.data.message || 'Unknown error'}`, - ); + return false; } }