jos3duardo/rinha-backend-node-2025
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Handle duplicate payment and log processor errors

Browse Source
This commit is contained in:
Jose Eduardo 2025-08-17 04:30:30 -04:00
parent 7d1d01310a
commit 8ab96b8292
1 changed files with 38 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/modules/payments/services/process-payment.service.ts
View File

@ -2,18 +2,54 @@ import { Injectable, Logger } from '@nestjs/common';
import { PaymentDefaultProcessor } from '../processor/payment-default.processor'; import { PaymentDefaultProcessor } from '../processor/payment-default.processor';
import { PaymentFallbackProcessor } from '../processor/payment-fallback.processor'; import { PaymentFallbackProcessor } from '../processor/payment-fallback.processor';
import { CreatePaymentDto } from '../dto/create-payment.dto'; import { CreatePaymentDto } from '../dto/create-payment.dto';
import { Payment } from '../entities/payment.entity';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { ProcessorTypeEnum } from '../enumns/processor-type.enum';
@Injectable() @Injectable()
export class ProcessPaymentService { export class ProcessPaymentService {
private readonly logger = new Logger(ProcessPaymentService.name); private readonly logger = new Logger(ProcessPaymentService.name);
constructor( constructor(
@InjectRepository(Payment) private readonly repository: Repository<Payment>,
private paymentDefaultProcessor: PaymentDefaultProcessor, private paymentDefaultProcessor: PaymentDefaultProcessor,
private paymentFallbackProcessor: PaymentFallbackProcessor, private paymentFallbackProcessor: PaymentFallbackProcessor,
) {} ) {}
async execute(job: CreatePaymentDto): Promise<void> { async execute(job: CreatePaymentDto): Promise<void> {
const result = await this.paymentDefaultProcessor.execute(job); let result = false;
if (!result) await this.paymentFallbackProcessor.execute(job); try {
result = await this.paymentDefaultProcessor.execute(job);
} catch (error) {
if (error.response?.status === 422) {
await this.repository.query(
`
INSERT INTO payments (correlation_id, amount, payment_processor)
VALUES ($1, $2, $3)
ON CONFLICT (correlation_id) DO NOTHING
`,
[job.correlationId, job.amount, ProcessorTypeEnum.DEFAULT],
);
this.logger.warn(
`Pagamento já realizado para correlationId: ${job.correlationId}`,
);
return; // Não lança exceção, job é considerado processado
}
this.logger.warn(`Default processor failed: ${error.message}`);
}
if (!result) {
await this.paymentFallbackProcessor.execute(job);
await this.repository.query(
`
INSERT INTO payments (correlation_id, amount, payment_processor)
VALUES ($1, $2, $3)
ON CONFLICT (correlation_id) DO NOTHING
`,
[job.correlationId, job.amount, ProcessorTypeEnum.FALLBACK],
);
}
throw new Error('Payment processing failed');
} }
} }