fix(whale-api): Fix swap tx not found index

apps/whale-api/src/module.indexer/model/dftx/composite.swap.ts

@@ -4,7 +4,6 @@ import { RawBlock } from '../_abstract'
 import { Inject, Injectable } from '@nestjs/common'
 import { NetworkName } from '@defichain/jellyfish-network'
 import BigNumber from 'bignumber.js'
-import { IndexerError } from '../../error'
 import { PoolPairPathMapping } from './pool.pair.path.mapping'
 import { PoolSwapIndexer } from './pool.swap'
 
@@ -51,10 +50,6 @@ export class CompositeSwapIndexer extends DfTxIndexer<CompositeSwap> {
 
     const poolSwap = compositeSwap.poolSwap
     const pair = await this.poolPairPathMapping.findPair(poolSwap.fromTokenId, poolSwap.toTokenId)
-    if (pair !== undefined) {
-      return [{ id: Number(pair.id) }]
-    }
-
-    throw new IndexerError(`Pool for pair ${poolSwap.fromTokenId}, ${poolSwap.toTokenId} not found in PoolPairPathMapping`)
+    return [{ id: Number(pair.id) }]
   }
 }

apps/whale-api/src/module.indexer/model/dftx/pool.pair.path.mapping.ts

@@ -1,22 +1,27 @@
-import { Injectable } from '@nestjs/common'
+import { Injectable, Logger } from '@nestjs/common'
 import { DeFiDCache, PoolPairInfoWithId } from '../../../module.api/cache/defid.cache'
 
 @Injectable()
 export class PoolPairPathMapping {
+  private readonly logger = new Logger(PoolPairPathMapping.name)
   private readonly paths: Record<string, PoolPairInfoWithId> = {}
 
   constructor (
     protected readonly deFiDCache: DeFiDCache
   ) {
   }
 
-  async findPair (tokenA: number, tokenB: number): Promise<PoolPairInfoWithId | undefined> {
+  async findPair (tokenA: number, tokenB: number): Promise<PoolPairInfoWithId> {
     const pair = this.paths[`${tokenA}-${tokenB}`]
     if (pair !== undefined) {
       return pair
     }
 
     await this.updateMapping()
+    if (this.paths[`${tokenA}-${tokenB}`] === undefined) {
+      this.logger.error(`Pool for pair ${tokenA}, ${tokenB} not found in PoolPairPathMapping`)
+      await this.findPair(tokenA, tokenB)
+    }
     return this.paths[`${tokenA}-${tokenB}`]
   }
 

apps/whale-api/src/module.indexer/model/dftx/pool.swap.ts

@@ -9,7 +9,6 @@ import { HexEncoder } from '../../../module.model/_hex.encoder'
 import { PoolSwapAggregatedMapper } from '../../../module.model/pool.swap.aggregated'
 import { AggregatedIntervals } from './pool.swap.aggregated'
 import { PoolPairInfoWithId } from '../../../module.api/cache/defid.cache'
-import { IndexerError } from '../../error'
 import { PoolPairPathMapping } from './pool.pair.path.mapping'
 
 @Injectable()
@@ -89,11 +88,6 @@ export class PoolSwapIndexer extends DfTxIndexer<PoolSwap> {
   }
 
   async getPair (tokenA: number, tokenB: number): Promise<PoolPairInfoWithId> {
-    const pair = await this.poolPairPathMapping.findPair(tokenA, tokenB)
-    if (pair !== undefined) {
-      return pair
-    }
-
-    throw new IndexerError(`Pool for pair ${tokenA}, ${tokenB} not found in PoolPairPathMapping`)
+    return await this.poolPairPathMapping.findPair(tokenA, tokenB)
   }
 }