Add payment processors for handling payment processing logic

src/modules/payments/processor/payment-default.processor.ts

@@ -0,0 +1,56 @@
+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';
+
+@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<Payment>,
+  ) {}
+
+  async execute(payment: Payment): Promise<boolean> {
+    const url = this.configService.get('paymentProcessors.defaultUrl');
+
+    this.logger.log(
+      `Processando Pagamento ${payment.id} com default processor`,
+    );
+
+    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`,
+      );
+
+      await this.repository.update(payment.id, {
+        ...payment,
+        paymentProcessor: ProcessorTypeEnum.DEFAULT,
+        status: PaymentStatusEnum.SUCCESS,
+      });
+      return true;
+    }
+    this.logger.log(
+      `Payment ${payment.id} not processed successfully via default processor: ${response.data.message || 'Unknown error'}`,
+    );
+    return false;
+  }
+}

src/modules/payments/processor/payment-fallback.processor.ts

@@ -0,0 +1,51 @@
+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';
+
+@Injectable()
+export class PaymentFallbackProcessor {
+  private readonly logger = new Logger(PaymentFallbackProcessor.name);
+
+  constructor(
+    private readonly httpService: HttpService,
+    private readonly configService: ConfigService,
+    @InjectRepository(Payment) private readonly repository: Repository<Payment>,
+  ) {}
+
+  async execute(payment: Payment): Promise<boolean> {
+    const url = this.configService.get('paymentProcessors.fallbackUrl');
+
+    this.logger.log(`Processing payment ${payment.id} via fallback processor`);
+
+    const paymentData = {
+      amount: payment.amount,
+      correlationId: payment.correlationId,
+    };
+
+    const response = await firstValueFrom(
+      this.httpService.post(`${url}/payments`, paymentData, {
+        timeout: 2000, // 30 segundos
+      }),
+    );
+
+    if (response.status === 200 && response.data.success) {
+      this.logger.log(
+        `Payment ${payment.id} processed successfully via fallback processor`,
+      );
+
+      await this.repository.update(payment.id, {
+        ...payment,
+        paymentProcessor: ProcessorTypeEnum.FALLBACK,
+        status: PaymentStatusEnum.SUCCESS,
+      });
+      return true;
+    }
+    return false;
+  }
+}

src/modules/payments/processor/payment.processor.ts

@@ -0,0 +1,37 @@
+import { Job } from 'bullmq';
+import { PaymentJobData } from '../../queue/queue.service';
+import { Processor, WorkerHost } from '@nestjs/bullmq';
+import { Injectable, Logger } from '@nestjs/common';
+import { ProcessPaymentService } from '../services/process-payment.service';
+import { PAYMENT_QUEUE } from '../../queue/constants/queue.constants';
+
+@Processor(PAYMENT_QUEUE)
+@Injectable()
+export class PaymentProcessor extends WorkerHost {
+  private readonly logger = new Logger(PaymentProcessor.name);
+
+  constructor(private processPaymentService: ProcessPaymentService) {
+    super();
+  }
+
+  async process(job: Job<PaymentJobData>) {
+    const { paymentId, retryCount = 0 } = job.data;
+
+    this.logger.log(
+      `Processing payment ${paymentId}, attempt ${retryCount + 1}`,
+    );
+
+    try {
+      await this.processPaymentService.execute(paymentId);
+      this.logger.log(`Pagamento ${paymentId} processado com sucesso`);
+
+      return { success: true, paymentId };
+    } catch (error) {
+      this.logger.error(
+        `Failed to process payment ${paymentId}:`,
+        error.message,
+      );
+      throw error;
+    }
+  }
+}