fix: store transaction source and target, skip ripple block if already processed

Author: kuco23

packages/fasset-indexer-core/src/orm/utils.ts

@@ -54,8 +54,8 @@ export async function findOrCreateUnderlyingTransaction(
 ): Promise<UnderlyingTransaction> {
   let underlyingTransaction = await em.findOne(UnderlyingTransaction, { hash })
   if (!underlyingTransaction) {
-    underlyingTransaction = new UnderlyingTransaction(block, hash, value)
+    underlyingTransaction = new UnderlyingTransaction(block, hash, value, source, target)
     em.persist(underlyingTransaction)
   }
   return underlyingTransaction
-}
+}

packages/fasset-indexer-xrp/src/indexer/indexer.ts

@@ -51,7 +51,9 @@ export class XrpIndexer {
 
   protected async processBlock(block: IXrpBlock): Promise<void> {
     await this.context.orm.em.transactional(async em => {
-      const blockEnt = await this.storeXrpBlock(em, block)
+      let blockEnt = await em.findOne(UnderlyingBlock, { hash: block.ledger_hash })
+      if (blockEnt != null) return
+      blockEnt = await this.storeXrpBlock(em, block)
       for (const tx of block.transactions) {
         await this.processTx(em, tx, blockEnt)
       }