create.masternode.spec.ts

import {
  createTestingApp,
  DelayedEunosPayaTestContainer,
  invalidateFromHeight,
  stopTestingApp,
  waitForIndexedHeight
} from '../../../e2e.module'
import { NestFastifyApplication } from '@nestjs/platform-fastify'
import { JsonRpcClient } from '@defichain/jellyfish-api-jsonrpc'
import { MasternodeMapper } from '../../../module.model/masternode'
import { MasternodeInfo } from '@defichain/jellyfish-api-core/dist/category/masternode'
import { MasterNodeRegTestContainer } from '@defichain/testcontainers'
import { MasternodeStatsMapper } from '../../../module.model/masternode.stats'

describe('genesis masternodes', () => {
  const container = new MasterNodeRegTestContainer()
  let app: NestFastifyApplication
  let client: JsonRpcClient

  beforeAll(async () => {
    await container.start()
    await container.waitForWalletCoinbaseMaturity()

    app = await createTestingApp(container)
    client = new JsonRpcClient(await container.getCachedRpcUrl())
  })

  afterAll(async () => {
    await stopTestingApp(container, app)
  })

  it('should index genesis masternodes', async () => {
    await container.generate(1)
    const height = await client.blockchain.getBlockCount()
    await container.generate(1)
    await waitForIndexedHeight(app, height)

    const genesisNodeId = 'e86c027861cc0af423313f4152a44a83296a388eb51bf1a6dde9bd75bed55fb4'
    const masternodeRPCInfo: MasternodeInfo =
      (await client.masternode.getMasternode(genesisNodeId))[genesisNodeId]

    const masternodeMapper = app.get(MasternodeMapper)
    const masternodeList = await masternodeMapper.query(30)
    expect(masternodeList.length).toStrictEqual(8)

    const genesisNode = await masternodeMapper.get(genesisNodeId)
    expect(masternodeRPCInfo).not.toStrictEqual(undefined)
    expect(genesisNode?.operatorAddress).toStrictEqual(masternodeRPCInfo.operatorAuthAddress)
    expect(genesisNode?.ownerAddress).toStrictEqual(masternodeRPCInfo.ownerAuthAddress)
    expect(genesisNode?.creationHeight).toStrictEqual(masternodeRPCInfo.creationHeight)
    expect(genesisNode?.resignHeight).toStrictEqual(masternodeRPCInfo.resignHeight)
    expect(genesisNode?.mintedBlocks).toStrictEqual(masternodeRPCInfo.mintedBlocks)
  })

  it('should index genesis masternodes stats', async () => {
    await container.generate(1)
    const height = await client.blockchain.getBlockCount()
    await container.generate(1)
    await waitForIndexedHeight(app, height)

    const masternodeStatsMapper = app.get(MasternodeStatsMapper)
    const masternodeStats = await masternodeStatsMapper.getLatest()
    expect(masternodeStats?.stats).toStrictEqual({
      count: 8,
      tvl: '80.00000000',
      locked: [
        {
          weeks: 0,
          count: 8,
          tvl: '80.00000000'
        }
      ]
    })
  })
})

describe('create masternode (pre eunos paya)', () => {
  const container = new DelayedEunosPayaTestContainer()
  let app: NestFastifyApplication
  let client: JsonRpcClient

  beforeAll(async () => {
    await container.start()
    await container.waitForWalletCoinbaseMaturity()

    app = await createTestingApp(container)
    client = new JsonRpcClient(await container.getCachedRpcUrl())
  })

  afterAll(async () => {
    await stopTestingApp(container, app)
  })

  it('should index create masternode', async () => {
    await container.generate(1)

    const ownerAddress = await client.wallet.getNewAddress()
    const masternodeId = await client.masternode.createMasternode(ownerAddress)
    await container.generate(1)

    const height = await client.blockchain.getBlockCount()
    await container.generate(1)
    await waitForIndexedHeight(app, height)

    const masternodeMapper = app.get(MasternodeMapper)

    const masternodeRPCInfo: MasternodeInfo =
      (await client.masternode.getMasternode(masternodeId))[masternodeId]
    const masternode = await masternodeMapper.get(masternodeId)

    expect(masternode).not.toStrictEqual(undefined)
    expect(masternode?.operatorAddress).toStrictEqual(masternodeRPCInfo.operatorAuthAddress)
    expect(masternode?.ownerAddress).toStrictEqual(masternodeRPCInfo.ownerAuthAddress)
    expect(masternode?.creationHeight).toStrictEqual(masternodeRPCInfo.creationHeight)
    expect(masternode?.resignHeight).toStrictEqual(masternodeRPCInfo.resignHeight)
    expect(masternode?.mintedBlocks).toStrictEqual(masternodeRPCInfo.mintedBlocks)
    expect(masternode?.history).toStrictEqual(undefined)
  })
})

describe('create masternode (post eunos paya)', () => {
  const container = new MasterNodeRegTestContainer()
  let app: NestFastifyApplication
  let client: JsonRpcClient

  beforeAll(async () => {
    await container.start()
    await container.waitForWalletCoinbaseMaturity()

    app = await createTestingApp(container)
    client = new JsonRpcClient(await container.getCachedRpcUrl())
  })

  afterAll(async () => {
    await stopTestingApp(container, app)
  })

  it('should index create masternode', async () => {
    await container.generate(1)

    const ownerAddress = await client.wallet.getNewAddress()
    const masternodeId = await client.masternode.createMasternode(ownerAddress)
    await container.generate(1)

    const height = await client.blockchain.getBlockCount()
    await container.generate(1)
    await waitForIndexedHeight(app, height)

    const masternodeMapper = app.get(MasternodeMapper)

    const masternodeRPCInfo: MasternodeInfo =
      (await client.masternode.getMasternode(masternodeId))[masternodeId]
    const masternode = await masternodeMapper.get(masternodeId)

    expect(masternode).not.toStrictEqual(undefined)
    expect(masternode?.operatorAddress).toStrictEqual(masternodeRPCInfo.operatorAuthAddress)
    expect(masternode?.ownerAddress).toStrictEqual(masternodeRPCInfo.ownerAuthAddress)
    expect(masternode?.creationHeight).toStrictEqual(masternodeRPCInfo.creationHeight)
    expect(masternode?.resignHeight).toStrictEqual(masternodeRPCInfo.resignHeight)
    expect(masternode?.mintedBlocks).toStrictEqual(masternodeRPCInfo.mintedBlocks)

    // Test stats here too
    const masternodeStatsMapper = app.get(MasternodeStatsMapper)
    const masternodeStats = await masternodeStatsMapper.getLatest()
    expect(masternodeStats?.stats).toStrictEqual({
      count: 9,
      tvl: '82.00000000',
      locked: [
        {
          weeks: 0,
          count: 9,
          tvl: '82.00000000'
        }
      ]
    })
  })
})

describe('invalidate', () => {
  const container = new MasterNodeRegTestContainer()
  let app: NestFastifyApplication
  let client: JsonRpcClient

  beforeAll(async () => {
    await container.start()
    await container.waitForWalletCoinbaseMaturity()

    app = await createTestingApp(container)
    client = new JsonRpcClient(await container.getCachedRpcUrl())
  })

  afterAll(async () => {
    await stopTestingApp(container, app)
  })

  it('should create masternode and invalidate', async () => {
    await container.generate(1)

    const ownerAddress = await client.wallet.getNewAddress()
    const masternodeId = await client.masternode.createMasternode(ownerAddress)
    await container.generate(1)

    const height = await client.blockchain.getBlockCount()
    await container.generate(1)
    await waitForIndexedHeight(app, height)

    const masternodeMapper = app.get(MasternodeMapper)

    const masternodeRPCInfo: MasternodeInfo =
      (await client.masternode.getMasternode(masternodeId))[masternodeId]
    const masternode = await masternodeMapper.get(masternodeId)

    expect(masternode).not.toStrictEqual(undefined)
    expect(masternode?.operatorAddress).toStrictEqual(masternodeRPCInfo.operatorAuthAddress)
    expect(masternode?.ownerAddress).toStrictEqual(masternodeRPCInfo.ownerAuthAddress)
    expect(masternode?.creationHeight).toStrictEqual(masternodeRPCInfo.creationHeight)
    expect(masternode?.resignHeight).toStrictEqual(masternodeRPCInfo.resignHeight)
    expect(masternode?.mintedBlocks).toStrictEqual(masternodeRPCInfo.mintedBlocks)

    await invalidateFromHeight(app, container, height)
    await container.generate(2)
    await waitForIndexedHeight(app, height)

    {
      const invalidatedMasternode = await masternodeMapper.get(masternodeId)
      expect(invalidatedMasternode).toStrictEqual(undefined)
    }
  })
})