ocean-subgraph/test/integration/FixedRateExchange.test.ts

import {
  DatatokenCreateParams,
  NftFactory,
  NftCreateData,
  sleep,
  FreCreationParams,
  ZERO_ADDRESS,
  FixedRateExchange,
  Datatoken
} from '@oceanprotocol/lib'
import MockERC20 from '@oceanprotocol/contracts/artifacts/contracts/utils/mock/MockERC20Decimals.sol/MockERC20Decimals.json'
import { assert } from 'chai'
import Web3 from 'web3'
import { homedir } from 'os'
import fs from 'fs'
import { fetch } from 'cross-fetch'
import { TransactionReceipt } from 'web3-core'
import { AbiItem } from 'web3-utils/types'
import BN from 'bn.js'

const sleepMs = 1700

const data = JSON.parse(
  fs.readFileSync(
    process.env.ADDRESS_FILE ||
      `${homedir}/.ocean/ocean-contracts/artifacts/address.json`,
    'utf8'
  )
)

const addresses = data.development
const web3 = new Web3('http://127.0.0.1:8545')

const subgraphUrl =
  'http://127.0.0.1:9000/subgraphs/name/oceanprotocol/ocean-subgraph'

describe('Fixed Rate Exchange tests', async () => {
  const nftName = 'test-Fixed-Price-NFT'
  const nftSymbol = 'TST-FIXED'
  const tokenURI = 'https://oceanprotocol.com/nft/fixed'
  const cap = '10000'
  const feeAmount = '0.2'
  const price = '123'
  const publishMarketSwapFee = '0.003'
  const templateIndex = 1
  const dtAmount = '10'
  const datatoken = new Datatoken(web3, 8996)
  let datatokenAddress: string
  let fixedRateAddress: string
  let baseTokenAddress: string
  let marketPlaceFeeAddress: string
  let fixedRateId: string
  let dt
  let Factory: NftFactory
  let factoryAddress: string
  let accounts: string[]
  let publisher: string
  let erc721Address: string
  let nftAddress: string
  let time: number
  let blockNumber: number
  let exchangeContract: string
  let exchangeId: string
  let transactionHash: string
  let fixedRate: FixedRateExchange
  let user1: string

  before(async () => {
    factoryAddress = addresses.ERC721Factory.toLowerCase()
    fixedRateAddress = addresses.FixedPrice.toLowerCase()
    baseTokenAddress = addresses.MockDAI.toLowerCase()
    Factory = new NftFactory(factoryAddress, web3)
    accounts = await web3.eth.getAccounts()
    publisher = accounts[0].toLowerCase()
    marketPlaceFeeAddress = accounts[1].toLowerCase()
    user1 = accounts[2].toLowerCase()
  })

  it('Deploying a Fixed Rate Exchange & Test NFT Fields', async () => {
    const date = new Date()
    time = Math.floor(date.getTime() / 1000)
    blockNumber = await web3.eth.getBlockNumber()

    const nftParams: NftCreateData = {
      name: nftName,
      symbol: nftSymbol,
      templateIndex: 1,
      tokenURI,
      transferable: true,
      owner: publisher
    }
    const erc20Params: DatatokenCreateParams = {
      templateIndex,
      cap,
      feeAmount,
      paymentCollector: ZERO_ADDRESS,
      feeToken: ZERO_ADDRESS,
      minter: publisher,
      mpFeeAddress: marketPlaceFeeAddress
    }
    const fixedRateParams: FreCreationParams = {
      fixedRateAddress,
      baseTokenAddress,
      owner: publisher,
      marketFeeCollector: marketPlaceFeeAddress,
      baseTokenDecimals: 18,
      datatokenDecimals: 18,
      fixedRate: price,
      marketFee: publishMarketSwapFee,
      allowedConsumer: ZERO_ADDRESS,
      withMint: false
    }

    const result = await Factory.createNftWithDatatokenWithFixedRate(
      publisher,
      nftParams,
      erc20Params,
      fixedRateParams
    )
    transactionHash = result.transactionHash.toLowerCase()
    erc721Address = result.events.NFTCreated.returnValues[0]
    datatokenAddress = result.events.TokenCreated.returnValues[0].toLowerCase()

    exchangeContract =
      result.events.NewFixedRate.returnValues.exchangeContract.toLowerCase()
    exchangeId =
      result.events.NewFixedRate.returnValues.exchangeId.toLowerCase()

    fixedRateId = `${exchangeContract}-${exchangeId}`

    // Check NFT values
    await sleep(sleepMs)
    nftAddress = erc721Address.toLowerCase()
    const nftQuery = {
      query: `query {
              nft(id:"${nftAddress}"){    
                id,
                symbol,
                name,
                tokenUri,
                owner{id},
                creator{id},
                address,
                providerUrl,
                assetState,
                managerRole,
                erc20DeployerRole,
                storeUpdateRole,
                metadataRole,
                template,
                transferable,
                createdTimestamp,
                tx,
                eventIndex,
                block,
                orderCount}}`
    }
    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(nftQuery)
    })
    const nft = (await initialResponse.json()).data.nft
    const nftTx: TransactionReceipt = await web3.eth.getTransactionReceipt(
      nft.tx
    )
    assert(nft.id === nftAddress, 'incorrect value for: id')
    assert(nft.symbol === nftSymbol, 'incorrect value for: symbol')
    assert(nft.name === nftName, 'incorrect value for: name')
    assert(nft.tokenUri === tokenURI, 'incorrect value for: tokenUri')
    assert(nft.owner.id === publisher, 'incorrect value for: owner')
    assert(nft.creator.id === publisher, 'incorrect value for: creator')
    assert(nft.managerRole[0] === publisher, 'incorrect value for: managerRole')
    assert(
      nft.erc20DeployerRole[0] === factoryAddress,
      'incorrect value for: erc20DeployerRole'
    )
    assert(nft.storeUpdateRole === null, 'incorrect value for: storeUpdateRole')
    assert(nft.metadataRole === null, 'incorrect value for: metadataRole')
    assert(nft.template === '', 'incorrect value for: template')
    assert(nft.transferable === true, 'incorrect value for: transferable')
    assert(
      nft.createdTimestamp >= time,
      'incorrect value for: createdTimestamp'
    )
    assert(
      nft.createdTimestamp < time + 5,
      'incorrect value for: createdTimestamp'
    )
    assert(nftTx.from === publisher, 'incorrect value for: tx')
    assert(nftTx.to === factoryAddress, 'incorrect value for: tx')
    assert(nftTx.blockNumber >= blockNumber, 'incorrect value for: tx')
    assert(nft.block >= blockNumber, 'incorrect value for: block')
    assert(nft.block < blockNumber + 50, 'incorrect value for: block')
    assert(nft.orderCount === '0', 'incorrect value for: orderCount')
    assert(
      nft.eventIndex !== null && nft.eventIndex > 0,
      'incorrect value for: eventIndex'
    )
  })

  it('Deploying a Fixed Rate Exchange with USDC as feeToken', async () => {
    const usdcSwapFee = '1'

    const nftParams: NftCreateData = {
      name: nftName,
      symbol: nftSymbol,
      templateIndex: 1,
      tokenURI,
      transferable: true,
      owner: publisher
    }
    const erc20Params: DatatokenCreateParams = {
      templateIndex,
      cap,
      feeAmount,
      paymentCollector: ZERO_ADDRESS,
      feeToken: addresses.MockUSDC, // Testing if the decimals are correct when using USDC as the feeToken
      minter: publisher,
      mpFeeAddress: marketPlaceFeeAddress
    }
    const fixedRateParams: FreCreationParams = {
      fixedRateAddress,
      baseTokenAddress,
      owner: publisher,
      marketFeeCollector: marketPlaceFeeAddress,
      baseTokenDecimals: 18,
      datatokenDecimals: 18,
      fixedRate: price,
      marketFee: usdcSwapFee,
      allowedConsumer: ZERO_ADDRESS,
      withMint: false
    }

    const result = await Factory.createNftWithDatatokenWithFixedRate(
      publisher,
      nftParams,
      erc20Params,
      fixedRateParams
    )

    const secondDatatokenAddress =
      result.events.TokenCreated.returnValues[0].toLowerCase()

    const dtQuery = {
      query: `query {
        token(id: "${secondDatatokenAddress}"){
          publishMarketFeeAddress,
          publishMarketFeeAmount
        }}`
    }
    const dtResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(dtQuery)
    })
    const secondDt = (await dtResponse.json()).data.token

    assert(secondDt, 'No datatoken')
    console.log('publishMarketFeeAmount', dt.publishMarketFeeAmount)
    console.log('usdcSwapFee', usdcSwapFee)

    assert(
      dt.publishMarketFeeAmount === usdcSwapFee,
      'incorrect value for: publishMarketFeeAmount'
    )
  })

  it('Test DT Fields after deploying Fixed rate exchange', async () => {
    // Check Datatoken Values
    const dtQuery = {
      query: `query {
        token(id: "${datatokenAddress}"){    
          id,
          symbol,
          name,
          decimals,
          address,
          cap,
          supply,
          isDatatoken,
          nft {id},
          minter,
          paymentManager,
          paymentCollector,
          publishMarketFeeAddress,
          publishMarketFeeAmount,
          templateId,
          holderCount,
          orderCount,
          orders {id},
          fixedRateExchanges {id},
          dispensers {id},
          createdTimestamp,
          tx,
          eventIndex,
          block,
          lastPriceToken,
          lastPriceValue
        }}`
    }
    const dtResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(dtQuery)
    })
    dt = (await dtResponse.json()).data.token

    const dtTx: TransactionReceipt = await web3.eth.getTransactionReceipt(dt.tx)

    assert(dt.id === datatokenAddress, 'incorrect value for: id')
    assert(dt.symbol, 'incorrect value for: symbol')
    assert(dt.name, 'incorrect value for: name')
    assert(dt.decimals === 18, 'incorrect value for: decimals')
    assert(dt.address === datatokenAddress, 'incorrect value for: address')
    assert(dt.cap === cap, 'incorrect value for: cap')
    assert(dt.supply === '0', 'incorrect value for: supply')
    assert(dt.isDatatoken === true, 'incorrect value for: isDatatoken')
    assert(dt.nft.id === nftAddress, 'incorrect value for: nft.id')
    assert(dt.minter[0] === publisher, 'incorrect value for: minter')
    assert(dt.paymentManager === null, 'incorrect value for: paymentManager')
    assert(
      dt.paymentCollector === null,
      'incorrect value for: paymentCollector'
    )
    assert(
      dt.publishMarketFeeAddress === marketPlaceFeeAddress,
      'incorrect value for: publishMarketFeeAddress'
    )
    assert(
      dt.publishMarketFeeAmount === feeAmount,
      'incorrect value for: publishMarketFeeAmount'
    )

    assert(dt.templateId === templateIndex, 'incorrect value for: templateId')
    assert(dt.holderCount === '0', 'incorrect value for: holderCount')
    assert(dt.orderCount === '0', 'incorrect value for: orderCount')
    assert(dt.orders, 'incorrect value for: orders')
    assert(dt.fixedRateExchanges, 'incorrect value for: fixedRateExchanges')
    assert(dt.dispensers, 'incorrect value for: dispensers')
    assert(dt.createdTimestamp >= time, 'incorrect value for: createdTimestamp')
    assert(
      dt.createdTimestamp < time + 5,
      'incorrect value for: createdTimestamp'
    )
    assert(dtTx.from === publisher, 'incorrect value for: tx')
    assert(dtTx.to === factoryAddress, 'incorrect value for: tx')
    assert(dtTx.blockNumber >= blockNumber, 'incorrect value for: tx')
    assert(dt.block >= blockNumber, 'incorrect value for: block')
    assert(dt.block < blockNumber + 50, 'incorrect value for: block')
    assert(dt.lastPriceValue === '0', 'incorrect value for: lastPriceValue')
    assert(
      dt.eventIndex !== null && dt.eventIndex > 0,
      'incorrect value for: eventIndex'
    )
  })

  it('Test fixedRateExchanges Fields', async () => {
    const fixedQuery = {
      query: `query {
        fixedRateExchange(id: "${fixedRateId}"){  
          id
          contract
          exchangeId
          owner {
            id
          }
          datatoken {
            id
          }
          baseToken {
            id
          }
          datatokenSupply
          baseTokenSupply
          datatokenBalance
          baseTokenBalance
          price
          active
          totalSwapValue
          allowedSwapper
          withMint
          isMinter
          updates {
            id
          }
          swaps {
            id
          }
          createdTimestamp
          tx
          eventIndex
          block
          publishMarketFeeAddress
          publishMarketSwapFee
        }
      }`
    }
    const fixedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(fixedQuery)
    })
    const fixed = (await fixedResponse.json()).data.fixedRateExchange
    const fixedTx: TransactionReceipt = await web3.eth.getTransactionReceipt(
      fixed.tx
    )
    // Test Fixed Rate Exchange Values
    assert(fixed.id === fixedRateId, 'incorrect value for: id')
    assert(fixed.contract === exchangeContract, 'incorrect value for: contract')
    assert(fixed.exchangeId === exchangeId, 'incorrect value for: exchangeId')
    assert(fixed.owner.id === publisher, 'incorrect value for: owner.id')
    assert(
      fixed.datatoken.id === datatokenAddress,
      'incorrect value for: datatoken.id'
    )
    assert(
      fixed.baseToken.id === baseTokenAddress,
      'incorrect value for: baseToken.id'
    )
    assert(
      fixed.datatokenSupply === '0',
      'incorrect value for: datatokenSupply'
    )
    assert(
      fixed.baseTokenSupply === '0',
      'incorrect value for: baseTokenSupply'
    )
    assert(
      fixed.datatokenBalance === '0',
      'incorrect value for: datatokenBalance'
    )
    assert(
      fixed.baseTokenBalance === '0',
      'incorrect value for: baseTokenBalance'
    )
    assert(fixed.price === price, 'incorrect value for: price')
    assert(fixed.active === true, 'incorrect value for: active')
    assert(fixed.totalSwapValue === '0', 'incorrect value for: totalSwapValue')
    assert(
      fixed.allowedSwapper === ZERO_ADDRESS,
      'incorrect value for: allowedSwapper'
    )
    assert(fixed.withMint === null, 'incorrect value for: withMint')
    assert(fixed.isMinter === null, 'incorrect value for: isMinter')
    assert(fixed.updates, 'incorrect value for: updates.id')
    assert(fixed.swaps, 'incorrect value for: swaps')
    assert(
      fixed.createdTimestamp >= time,
      'incorrect value for: createdTimestamp'
    )
    assert(
      fixed.createdTimestamp < time + 5,
      'incorrect value for: createdTimestamp'
    )
    assert(fixed.tx === transactionHash, 'incorrect value for: tx')
    assert(fixed.block >= blockNumber, 'incorrect value for: block')
    assert(fixed.block < blockNumber + 50, 'incorrect value for: block')
    assert(
      fixed.publishMarketFeeAddress === marketPlaceFeeAddress,
      'incorrect value for: publishMarketFeeAddress'
    )
    assert(
      fixed.publishMarketSwapFee === publishMarketSwapFee,
      'incorrect value for: publishMarketSwapFee'
    )
    assert(fixedTx.from === publisher, 'incorrect value for: tx')
    assert(fixedTx.to === factoryAddress, 'incorrect value for: tx')
    assert(
      fixed.eventIndex !== null && fixed.eventIndex > 0,
      'incorrect value for: eventIndex'
    )
  })

  it('Updates Fixed Rate Price', async () => {
    fixedRate = new FixedRateExchange(fixedRateAddress, web3, 8996)
    const priceQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){
        price
        updates(orderBy: createdTimestamp, orderDirection: desc){
          exchangeId {
            id
          }
          oldPrice
          newPrice
          eventIndex
        }
      }}`
    }

    // Check initial price
    const priceResponse1 = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(priceQuery)
    })
    const fixedResponse1 = (await priceResponse1.json()).data.fixedRateExchange

    const price1 = fixedResponse1.price
    const updates1 = fixedResponse1.updates[0]

    assert(price1 === price, 'incorrect value for: price 1')
    assert(
      updates1.exchangeId.id === fixedRateId,
      'incorrect value: initial fixedRateId'
    )
    assert(updates1.oldPrice === null, 'incorrect value: initial oldPrice')
    assert(updates1.newPrice === null, 'incorrect value: initial oldPrice')

    // Update price
    const newPrice = '999'
    const tx = await fixedRate.setRate(publisher, exchangeId, newPrice)
    await sleep(sleepMs)

    // Check price after first update
    const priceResponse2 = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(priceQuery)
    })
    const fixedResponse2 = (await priceResponse2.json()).data.fixedRateExchange
    const price2 = fixedResponse2.price
    const updates2 = fixedResponse2.updates[0]

    assert(price2 === newPrice, 'incorrect value for: price 2')
    assert(
      updates2.exchangeId.id === fixedRateId,
      'incorrect value: 2nd fixedRateId'
    )
    assert(updates2.oldPrice === price1, 'incorrect value: 2nd oldPrice')
    assert(updates2.newPrice === newPrice, 'incorrect value: 2nd newPrice')
    assert(
      updates2.eventIndex === tx.events.ExchangeRateChanged.logIndex,
      'incorrect value: 2nd eventIndex'
    )

    // Update price a 2nd time
    const newPrice2 = '1' // '5.123'
    const tx2 = await fixedRate.setRate(publisher, exchangeId, newPrice2)
    await sleep(sleepMs)

    // Check price after 2nd update
    const priceResponse3 = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(priceQuery)
    })

    const fixedResponse3 = (await priceResponse3.json()).data.fixedRateExchange
    const price3 = fixedResponse3.price
    const updates3 = fixedResponse3.updates[0]

    assert(price3 === newPrice2, 'incorrect value for: price 3')
    assert(
      updates3.exchangeId.id === fixedRateId,
      'incorrect value: 3rd fixedRateId'
    )
    assert(updates3.oldPrice === newPrice, 'incorrect value: 3rd oldPrice')
    assert(updates3.newPrice === newPrice2, 'incorrect value: 3rd newPrice')
    assert(
      updates3.eventIndex === tx2.events.ExchangeRateChanged.logIndex,
      'incorrect value: 3nd eventIndex'
    )
  })
  it('Deactivates exchange', async () => {
    const deactiveQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){active, eventIndex}}`
    }

    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(deactiveQuery)
    })
    const initialActive = (await initialResponse.json()).data.fixedRateExchange
      .active
    assert(initialActive === true, 'incorrect value for: initialActive')

    // Deactivate exchange
    await fixedRate.deactivate(publisher, exchangeId)
    await sleep(sleepMs)

    // Check the updated value for active
    const updatedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(deactiveQuery)
    })
    const updatedActive = (await updatedResponse.json()).data.fixedRateExchange

    assert(updatedActive.active === false, 'incorrect value for: updatedActive')
    assert(
      updatedActive.eventIndex !== null && updatedActive.eventIndex > 0,
      'incorrect value: eventIndex'
    )
  })

  it('Activates exchange', async () => {
    const activeQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){active, eventIndex}}`
    }
    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(activeQuery)
    })
    const initialActive = (await initialResponse.json()).data.fixedRateExchange
      .active
    assert(initialActive === false, 'incorrect value for: initialActive')

    // Activate exchange
    await fixedRate.activate(publisher, exchangeId)
    await sleep(sleepMs)

    // Check the updated value for active
    const updatedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(activeQuery)
    })
    const updatedActive = (await updatedResponse.json()).data.fixedRateExchange
    assert(updatedActive.active === true, 'incorrect value for: updatedActive')
    assert(
      updatedActive.eventIndex !== null && updatedActive.eventIndex > 0,
      'incorrect value: eventIndex'
    )
  })

  it('Activate Minting', async () => {
    const mintingQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){withMint, eventIndex}}`
    }
    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(mintingQuery)
    })
    const initialMint = (await initialResponse.json()).data.fixedRateExchange
      .withMint
    assert(initialMint === null, 'incorrect value for: initialMint')

    // Activate minting
    const tx = await fixedRate.activateMint(publisher, exchangeId)
    await sleep(sleepMs)

    // Check the updated value for active
    const updatedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(mintingQuery)
    })

    const updatedMint = (await updatedResponse.json()).data.fixedRateExchange
    assert(updatedMint.withMint === true, 'incorrect value for: updatedMint')
    assert(
      updatedMint.eventIndex === tx.events.ExchangeMintStateChanged.logIndex,
      'incorrect value for: eventIndex'
    )
  })

  it('Deactivate Minting', async () => {
    const mintingQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){withMint, eventIndex}}`
    }
    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(mintingQuery)
    })
    const initialMint = (await initialResponse.json()).data.fixedRateExchange
      .withMint
    assert(initialMint === true, 'incorrect value for: initialMint')

    // Activate minting
    const tx = await fixedRate.deactivateMint(publisher, exchangeId)
    await sleep(sleepMs)

    // Check the updated value for active
    const updatedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(mintingQuery)
    })

    const updatedMint = (await updatedResponse.json()).data.fixedRateExchange
    assert(updatedMint.withMint === false, 'incorrect value for: updatedMint')
    assert(
      updatedMint.eventIndex === tx.events.ExchangeMintStateChanged.logIndex,
      'incorrect value for: eventIndex'
    )
  })

  it('User1 buys a datatoken', async () => {
    const swapsQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){
        swaps{
          id
          exchangeId{id}
          by{id}
          baseTokenAmount
          dataTokenAmount
          block
          createdTimestamp
          tx
          eventIndex
          oceanFeeAmount
          marketFeeAmount
          consumeMarketFeeAmount
          __typename
        }  
      }}`
    }
    // Check initial swaps
    const initialResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(swapsQuery)
    })
    const initialSwaps = (await initialResponse.json()).data.fixedRateExchange
      .swaps
    assert(initialSwaps.length === 0, 'incorrect value for: initialSwaps')

    const datatoken = new Datatoken(web3, 8996)
    // Mint datatokens as initial supply is 0
    await datatoken.mint(datatokenAddress, publisher, '100')
    await datatoken.approve(
      datatokenAddress,
      fixedRateAddress,
      '100',
      publisher
    )

    const daiContract = new web3.eth.Contract(
      MockERC20.abi as AbiItem[],
      addresses.MockDAI
    )
    // user1 need DAI so that they can buy the datatoken
    await daiContract.methods
      .transfer(user1, web3.utils.toWei('100'))
      .send({ from: publisher })
    await daiContract.methods
      .approve(fixedRateAddress, web3.utils.toWei('10000000'))
      .send({ from: user1 })

    // user1 has no DTs before buying one
    let user1Balance = await datatoken.balance(datatokenAddress, user1)
    assert(user1Balance === '0', 'incorrect value for: user1Balance')

    const tx = (
      await fixedRate.buyDatatokens(user1, exchangeId, dtAmount, '100')
    ).events?.Swapped

    const oceanFeeAmount = web3.utils.fromWei(
      new BN(tx.returnValues.oceanFeeAmount)
    )
    const marketFeeAmount = web3.utils.fromWei(
      new BN(tx.returnValues.marketFeeAmount)
    )
    const consumeMarketFeeAmount = web3.utils.fromWei(
      new BN(tx.returnValues.consumeMarketFeeAmount)
    )

    await sleep(sleepMs)
    user1Balance = await datatoken.balance(datatokenAddress, user1)
    // user1 has 1 datatoken
    assert(user1Balance === dtAmount, 'incorrect value for: user1Balance')

    // Check updated swaps
    const updatedResponse = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(swapsQuery)
    })
    const swaps = (await updatedResponse.json()).data.fixedRateExchange.swaps[0]
    const swappedAmount = web3.utils.fromWei(
      new BN(tx.returnValues.baseTokenSwappedAmount)
    )
    assert(
      swaps.id ===
        `${tx.transactionHash}-${fixedRateId}-${tx.logIndex.toFixed(1)}`,
      'incorrect: id'
    )
    assert(swaps.exchangeId.id === fixedRateId, 'incorrect: exchangeId')
    assert(swaps.by.id === user1, 'incorrect value for: id')
    assert(swaps.baseTokenAmount === swappedAmount, 'incorrect baseTokenAmount')
    assert(swaps.dataTokenAmount === dtAmount, 'incorrect: dataTokenAmount')
    assert(swaps.block === tx.blockNumber, 'incorrect value for: block')
    assert(swaps.createdTimestamp >= time, 'incorrect: createdTimestamp')
    assert(swaps.createdTimestamp < time + 25, 'incorrect: createdTimestamp 2')
    assert(swaps.oceanFeeAmount === oceanFeeAmount, 'incorrect: oceanFeeAmount')
    assert(swaps.marketFeeAmount === marketFeeAmount, 'wrong marketFeeAmount')
    assert(
      swaps.consumeMarketFeeAmount === consumeMarketFeeAmount,
      'wrong consumeMarketFeeAmount'
    )
    assert(swaps.tx === tx.transactionHash, 'incorrect value for: tx')
    assert(swaps.eventIndex === tx.logIndex, 'incorrect value for: eventIndex')
    assert(swaps.__typename === 'FixedRateExchangeSwap', 'incorrect __typename')
  })
  it('User1 sells a datatoken', async () => {
    await datatoken.approve(datatokenAddress, fixedRateAddress, dtAmount, user1)
    const tx = (await fixedRate.sellDatatokens(user1, exchangeId, '10', '9'))
      .events?.Swapped
    const oceanFeeAmount = web3.utils.fromWei(
      new BN(tx.returnValues.oceanFeeAmount)
    )
    assert(tx != null)
    await sleep(sleepMs)
    const swapsQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){
        swaps(orderBy: createdTimestamp, orderDirection: desc){
          id
          exchangeId{id}
          by{id}
          baseTokenAmount
          dataTokenAmount
          block
          createdTimestamp
          tx
          eventIndex
          oceanFeeAmount
          __typename
        }  
      }}`
    }
    // Check initial swaps
    const response = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(swapsQuery)
    })
    const swaps = (await response.json()).data.fixedRateExchange.swaps[0]
    const swappedAmount = web3.utils.fromWei(
      new BN(tx.returnValues.baseTokenSwappedAmount)
    )
    assert(
      swaps.id ===
        `${tx.transactionHash}-${fixedRateId}-${tx.logIndex.toFixed(1)}`,
      'incorrect: id'
    )
    assert(swaps.exchangeId.id === fixedRateId, 'incorrect: exchangeId')
    assert(swaps.by.id === user1, 'incorrect value for: id')
    assert(swaps.baseTokenAmount === swappedAmount, 'incorrect baseTokenAmount')
    assert(swaps.dataTokenAmount === dtAmount, 'incorrect: dataTokenAmount')
    assert(swaps.block === tx.blockNumber, 'incorrect value for: block')
    assert(swaps.createdTimestamp >= time, 'incorrect: createdTimestamp')
    assert(swaps.createdTimestamp < time + 25, 'incorrect: createdTimestamp 2')
    assert(swaps.oceanFeeAmount === oceanFeeAmount, 'incorrect: oceanFeeAmount')
    assert(swaps.tx === tx.transactionHash, 'incorrect value for: tx')
    assert(swaps.eventIndex === tx.logIndex, 'incorrect value for: eventIndex')
    assert(swaps.__typename === 'FixedRateExchangeSwap', 'incorrect __typename')
  })

  it('Updates allowed swapper', async () => {
    const swapperQuery = {
      query: `query {fixedRateExchange(id: "${fixedRateId}"){allowedSwapper, eventIndex}}`
    }
    // Check initial allowedSwapper
    const swapperResponse1 = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(swapperQuery)
    })
    const allowedSwapper1 = (await swapperResponse1.json()).data
      .fixedRateExchange.allowedSwapper
    assert(
      allowedSwapper1 === ZERO_ADDRESS,
      'incorrect value for: allowedSwapper'
    )

    const tx = await fixedRate.setAllowedSwapper(publisher, exchangeId, user1)
    await sleep(sleepMs)

    const swapperResponse2 = await fetch(subgraphUrl, {
      method: 'POST',
      body: JSON.stringify(swapperQuery)
    })
    const allowedSwapper2 = (await swapperResponse2.json()).data
      .fixedRateExchange

    assert(
      allowedSwapper2.allowedSwapper === user1,
      'incorrect value for: allowedSwapper 2'
    )
    assert(
      allowedSwapper2.eventIndex ===
        tx.events.ExchangeAllowedSwapperChanged.logIndex,
      'incorrect value for: eventIndex'
    )
  })
})