fix: check amount to update clientPayment

Author: lissavxo

services/chronikService.ts

@@ -12,7 +12,8 @@ import {
   getSimplifiedTransactions,
   getSimplifiedTrasaction,
   connectAllTransactionsToPrices,
-  updatePaymentStatus
+  updatePaymentStatus,
+  getClientPayment
 } from './transactionService'
 import { Address, Prisma, ClientPaymentStatus } from '@prisma/client'
 import xecaddr from 'xecaddrjs'
@@ -470,8 +471,14 @@ export class ChronikBlockchainClient {
             const parsedOpReturn = parseOpReturnData(tx.opReturn)
             const paymentId = parsedOpReturn.paymentId
             const newClientPaymentStatus = 'ADDED_TO_MEMPOOL' as ClientPaymentStatus
-
-            await updatePaymentStatus(paymentId, newClientPaymentStatus)
+            const clientPayment = await getClientPayment(paymentId)
+            if (clientPayment.amount !== null) {
+              if (clientPayment.amount === tx.amount) {
+                await updatePaymentStatus(paymentId, newClientPaymentStatus)
+              }
+            } else {
+              await updatePaymentStatus(paymentId, newClientPaymentStatus)
+            }
           }
         }
         this.mempoolTxsBeingProcessed -= 1

services/transactionService.ts

@@ -1007,3 +1007,10 @@ export const updatePaymentStatus = async (paymentId: string, status: ClientPayme
     data: { status }
   })
 }
+
+export const getClientPayment = async (paymentId: string): Promise<Prisma.ClientPaymentGetPayload<{ include: { address: true } }>> => {
+  return await prisma.clientPayment.findUniqueOrThrow({
+    where: { paymentId },
+    include: { address: true }
+  })
+}