From 95af8deae8a964ffd28377706ee1872a6d280959 Mon Sep 17 00:00:00 2001 From: jos3duardo Date: Sun, 17 Aug 2025 04:30:39 -0400 Subject: [PATCH] Use query to insert payment and handle conflicts --- .../processor/payment-default.processor.ts | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/src/modules/payments/processor/payment-default.processor.ts b/src/modules/payments/processor/payment-default.processor.ts index 763b7ff..5de9c23 100644 --- a/src/modules/payments/processor/payment-default.processor.ts +++ b/src/modules/payments/processor/payment-default.processor.ts @@ -26,12 +26,14 @@ export class PaymentDefaultProcessor { ); if (!responseExists) return false; - - await this.repository.save({ - ...payment, - paymentProcessor: ProcessorTypeEnum.DEFAULT, - }); - + await this.repository.query( + ` + INSERT INTO payments (correlation_id, amount, payment_processor) + VALUES ($1, $2, $3) + ON CONFLICT (correlation_id) DO NOTHING + `, + [payment.correlationId, payment.amount, ProcessorTypeEnum.DEFAULT], + ); return true; } }