feat: update client payment comfirmed

Author: lissavxo

services/chronikService.ts

@@ -414,6 +414,9 @@ export class ChronikBlockchainClient {
       await new Promise(resolve => setTimeout(resolve, CHRONIK_INITIALIZATION_DELAY))
     }
     if (msg.type === 'Tx') {
+      const transaction = await this.chronik.tx(msg.txid)
+      const addressesWithTransactions = await this.getAddressesForTransaction(transaction)
+      const inputAddresses = this.getSortedInputAddresses(transaction)
       if (msg.msgType === 'TX_REMOVED_FROM_MEMPOOL') {
         console.log(`${this.CHRONIK_MSG_PREFIX}: [${msg.msgType}] ${msg.txid}`)
         const transactionsToDelete = await fetchUnconfirmedTransactions(msg.txid)
@@ -428,6 +431,13 @@ export class ChronikBlockchainClient {
       } else if (msg.msgType === 'TX_CONFIRMED') {
         console.log(`${this.CHRONIK_MSG_PREFIX}: [${msg.msgType}] ${msg.txid}`)
         this.confirmedTxsHashesFromLastBlock = [...this.confirmedTxsHashesFromLastBlock, msg.txid]
+        for (const addressWithTransaction of addressesWithTransactions) {
+          const parsedOpReturn = parseOpReturnData(addressWithTransaction.transaction.opReturn ?? '')
+          const paymentId = parsedOpReturn.paymentId
+          const newClientPaymentStatus = 'COMFIRMED' as ClientPaymentStatus
+
+          await updatePaymentStatus(paymentId, newClientPaymentStatus)
+        }
       } else if (msg.msgType === 'TX_ADDED_TO_MEMPOOL') {
         if (this.isAlreadyBeingProcessed(msg.txid, false)) {
           return
@@ -437,9 +447,7 @@ export class ChronikBlockchainClient {
         }
         this.mempoolTxsBeingProcessed += 1
         console.log(`${this.CHRONIK_MSG_PREFIX}: [${msg.msgType}] ${msg.txid}`)
-        const transaction = await this.chronik.tx(msg.txid)
-        const addressesWithTransactions = await this.getAddressesForTransaction(transaction)
-        const inputAddresses = this.getSortedInputAddresses(transaction)
+
         for (const addressWithTransaction of addressesWithTransactions) {
           const { created, tx } = await upsertTransaction(addressWithTransaction.transaction)
           if (tx !== undefined) {