Use query to insert payment and handle conflicts

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

@@ -26,12 +26,14 @@ export class PaymentDefaultProcessor {
     );
 
     if (!responseExists) return false;
-
+    await this.repository.query(
-    await this.repository.save({
+      `
-      ...payment,
+      INSERT INTO payments (correlation_id, amount, payment_processor)
-      paymentProcessor: ProcessorTypeEnum.DEFAULT,
+      VALUES ($1, $2, $3)
-    });
+      ON CONFLICT (correlation_id) DO NOTHING
-
+      `,
+      [payment.correlationId, payment.amount, ProcessorTypeEnum.DEFAULT],
+    );
     return true;
   }
 }