due to hard fork upgrades on PoolPairHistory Data this is not represe…

…ntative of actual DfTx (#798)
JellyfishSDK · Feb 21, 2022 · d8e3caf · d8e3caf
1 parent 6418fc9
commit d8e3caf
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/src/module.indexer/model/dftx/composite.swap.ts b/src/module.indexer/model/dftx/composite.swap.ts
@@ -9,8 +9,6 @@ import { NetworkName } from '@defichain/jellyfish-network'
 import { IndexerError } from '@src/module.indexer/error'
 import BigNumber from 'bignumber.js'
 
-const ONE = new BigNumber(1.0)
-
 @Injectable()
 export class CompositeSwapIndexer extends DfTxIndexer<CompositeSwap> {
   OP_CODE: number = CCompositeSwap.OP_CODE
@@ -29,12 +27,12 @@ export class CompositeSwapIndexer extends DfTxIndexer<CompositeSwap> {
     const poolSwap = data.poolSwap
     const poolIds = await this.getPoolIdsForTokens(data)
 
-    let fromAmount: BigNumber = poolSwap.fromAmount
+    const fromAmount: BigNumber = poolSwap.fromAmount
 
     for (const pool of poolIds) {
       const poolPair = await this.getPoolPair(pool.id)
       await this.poolSwapIndexer.indexSwap(block, transaction, poolPair.poolPairId, poolSwap.fromTokenId, fromAmount)
-      fromAmount = ONE.minus(poolPair.commission).times(fromAmount)
+      // fromAmount = ONE.minus(poolPair.commission).times(fromAmount)
     }
   }
 
@@ -43,12 +41,12 @@ export class CompositeSwapIndexer extends DfTxIndexer<CompositeSwap> {
     const poolSwap = data.poolSwap
     const poolIds = await this.getPoolIdsForTokens(data)
 
-    let fromAmount: BigNumber = poolSwap.fromAmount
+    const fromAmount: BigNumber = poolSwap.fromAmount
 
     for (const pool of poolIds) {
       const poolPair = await this.getPoolPair(pool.id)
       await this.poolSwapIndexer.invalidateSwap(transaction, poolPair.poolPairId, poolSwap.fromTokenId, fromAmount)
-      fromAmount = ONE.minus(poolPair.commission).times(fromAmount)
+      // fromAmount = ONE.minus(poolPair.commission).times(fromAmount)
     }
   }
 

diff --git a/src/module.indexer/model/dftx/create.pool.pair.ts b/src/module.indexer/model/dftx/create.pool.pair.ts
@@ -51,6 +51,7 @@ export class CreatePoolPairIndexer extends DfTxIndexer<PoolCreatePair> {
 
     const pairSymbol = this.getPairSymbol(tokenA, tokenB, block, transaction)
 
+    // due to hard fork upgrades on PoolPair Data this is not representative of actual DfTx
     await this.poolPairHistoryMapper.put({
       id: txid,
       sort: HexEncoder.encodeHeight(block.height) + HexEncoder.encodeHeight(transaction.txnNo),