feat(apps/whale-api): add updatemasternode indexer (#1869)

#### What this PR does / why we need it:

Add `UpdateMasternodeIndexer extends DfTxIndexer<UpdateMasternode>` to
update the masternode index when the DfTx UpdaterMasternode transaction
is created.

#### Which issue(s) does this PR fixes?:

Fixes part of #1842

Signed-off-by: Isaac Yong <[email protected]>
Signed-off-by: Kven Ho <[email protected]>
Signed-off-by: Fuxing Loh <[email protected]>
Co-authored-by: Mark Tan <[email protected]>
Co-authored-by: Mark Tan <[email protected]>
Co-authored-by: Shoham Chakraborty <[email protected]>
Co-authored-by: Dilshan Madushanka <[email protected]>
Co-authored-by: Isaac Yong <[email protected]>
Co-authored-by: Fuxing Loh <[email protected]>

Author: 6 people

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

@@ -9,6 +9,7 @@ import { SetOracleDataIndexer } from './dftx/set.oracle.data'
 import { SetOracleDataIntervalIndexer } from './dftx/set.oracle.data.interval'
 import { CreateMasternodeIndexer } from './dftx/create.masternode'
 import { ResignMasternodeIndexer } from './dftx/resign.masternode'
+import { UpdateMasternodeIndexer } from './dftx/update.masternode'
 import { Injectable, Logger } from '@nestjs/common'
 import { DfTxIndexer, DfTxTransaction } from './dftx/_abstract'
 import { PoolSwapIndexer } from './dftx/pool.swap'
@@ -30,6 +31,7 @@ export class MainDfTxIndexer extends Indexer {
     setOracleDataInterval: SetOracleDataIntervalIndexer,
     createMasternode: CreateMasternodeIndexer,
     resignMasternode: ResignMasternodeIndexer,
+    updateMasternode: UpdateMasternodeIndexer,
     poolSwapIndexer: PoolSwapIndexer,
     compositeSwapIndexer: CompositeSwapIndexer,
     poolSwapIntervalIndexer: PoolSwapAggregatedIndexer,
@@ -45,6 +47,7 @@ export class MainDfTxIndexer extends Indexer {
       setOracleDataInterval,
       createMasternode,
       resignMasternode,
+      updateMasternode,
       poolSwapIndexer,
       compositeSwapIndexer,
       poolSwapIntervalIndexer,

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

@@ -6,6 +6,7 @@ import { SetOracleDataIndexer } from './set.oracle.data'
 import { SetOracleDataIntervalIndexer } from './set.oracle.data.interval'
 import { CreateMasternodeIndexer } from './create.masternode'
 import { ResignMasternodeIndexer } from './resign.masternode'
+import { UpdateMasternodeIndexer } from './update.masternode'
 import { NetworkName } from '@defichain/jellyfish-network'
 import { ConfigService } from '@nestjs/config'
 import { PoolSwapIndexer } from './pool.swap'
@@ -23,6 +24,7 @@ const indexers = [
   UpdateOracleIndexer,
   CreateMasternodeIndexer,
   ResignMasternodeIndexer,
+  UpdateMasternodeIndexer,
   PoolSwapIndexer,
   PoolSwapAggregatedIndexer,
   CompositeSwapIndexer,

apps/whale-api/src/module.indexer/model/dftx/create.masternode.spec.ts

@@ -114,6 +114,7 @@ describe('create masternode (pre eunos paya)', () => {
     expect(masternode?.creationHeight).toStrictEqual(masternodeRPCInfo.creationHeight)
     expect(masternode?.resignHeight).toStrictEqual(masternodeRPCInfo.resignHeight)
     expect(masternode?.mintedBlocks).toStrictEqual(masternodeRPCInfo.mintedBlocks)
+    expect(masternode?.history).toStrictEqual(undefined)
   })
 })
 

apps/whale-api/src/module.indexer/model/dftx/create.masternode.ts

@@ -30,11 +30,7 @@ export class CreateMasternodeIndexer extends DfTxIndexer<CreateMasternode> {
 
     // This is actually the operatorPubKeyHash but jellyfish deserializes like so
     if (data.operatorPubKeyHash !== undefined) {
-      if (data.operatorType === MasternodeKeyType.PKHashType) {
-        operatorAddress = P2PKH.to(this.network, data.operatorPubKeyHash).utf8String
-      } else { // WitV0KeyHashType
-        operatorAddress = P2WPKH.to(this.network, data.operatorPubKeyHash).utf8String
-      }
+      operatorAddress = CreateMasternodeIndexer.getAddress(this.network, data.operatorType, data.operatorPubKeyHash) ?? ''
     }
 
     await this.masternodeMapper.put({
@@ -92,6 +88,17 @@ export class CreateMasternodeIndexer extends DfTxIndexer<CreateMasternode> {
   async invalidateBlockStart (block: RawBlock): Promise<void> {
     await this.masternodeStatsMapper.delete(block.height)
   }
+
+  public static getAddress (network: NetworkName, type: MasternodeKeyType, addressPubKeyHash: string): string | undefined {
+    if (type === MasternodeKeyType.PKHashType) {
+      return P2PKH.to(network, addressPubKeyHash).utf8String
+    }
+
+    if (type === MasternodeKeyType.WitV0KeyHashType) {
+      return P2WPKH.to(network, addressPubKeyHash).utf8String
+    }
+    return undefined
+  }
 }
 
 enum MasternodeKeyType {