feat: added tx orphaning

prisma-local/migrations/20260104000000_transaction_orphaned_column/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `Transaction` ADD COLUMN `orphaned` BOOLEAN NOT NULL DEFAULT false;

prisma-local/schema.prisma

@@ -71,6 +71,7 @@ model Transaction {
   hash      String                 @db.VarChar(255)
   amount    Decimal                @db.Decimal(24, 8)
   confirmed Boolean                @default(false)
+  orphaned  Boolean                @default(false)
   timestamp Int
   addressId String
   opReturn String                @db.LongText @default("")

services/chronikService.ts

@@ -8,6 +8,7 @@ import {
   createManyTransactions,
   deleteTransactions,
   fetchUnconfirmedTransactions,
+  markTransactionsOrphaned,
   upsertTransaction,
   getSimplifiedTransactions,
   getSimplifiedTrasaction
@@ -632,8 +633,15 @@ export class ChronikBlockchainClient {
             const { amount, opReturn } = addressWithTransaction.transaction
             await this.handleUpdateClientPaymentStatus(amount, opReturn, 'CONFIRMED' as ClientPaymentStatus, addressWithTransaction.address.address)
           }
-        } catch (e) {
-          console.error(`${this.CHRONIK_MSG_PREFIX}: confirmed tx handler failed for ${msg.txid}`, e)
+        } catch (e: any) {
+          const msg404 = String(e?.message ?? e)
+          const is404 = /not found in the index|404/.test(msg404)
+          if (is404) {
+            console.log(`${this.CHRONIK_MSG_PREFIX}: [${msg.msgType}] tx ${msg.txid} not found in chronik, marking as orphaned`)
+            await markTransactionsOrphaned(msg.txid)
+          } else {
+            console.error(`${this.CHRONIK_MSG_PREFIX}: confirmed tx handler failed for ${msg.txid}`, e)
+          }
         }
       } else if (msg.msgType === 'TX_ADDED_TO_MEMPOOL') {
         if (this.isAlreadyBeingProcessed(msg.txid, false)) return

services/transactionService.ts

@@ -629,6 +629,17 @@ export async function deleteTransactions (transactions: TransactionWithAddressAn
   ))
 }
 
+export async function markTransactionsOrphaned (hash: string): Promise<void> {
+  await prisma.transaction.updateMany({
+    where: {
+      hash
+    },
+    data: {
+      orphaned: true
+    }
+  })
+}
+
 async function fetchAllTransactionsWithNoPrices (): Promise<TransactionWithNetwork[]> {
   const x = await prisma.transaction.findMany({
     where: {