mirror of
https://github.com/oceanprotocol/ocean-subgraph.git
synced 2024-12-02 05:57:29 +01:00
Fixed rate exchange tests (#513)
* Creating an inital Fixed rate exchange test * Testing additional fields * Testing all fields on fixed rate exchange * Splitting up tests * Splitting up fixed rate exachange tests * Creating test for fixed rate price updates * Adding test for updating allowed swapper * Fixing templateId test * Testing fixed rate excahnge updates * Testing deactivate exchange * Testing activate and deactive exchange * Updating activate and deactivate minting * Testing all fields of swaps after buying a DT * Creating testing for selling a fixed rate DT * Creating a constant for sleep ms
This commit is contained in:
parent
6199c34c69
commit
82ce88c026
@ -24,6 +24,7 @@
|
||||
"deploy:local-barge": "graph deploy oceanprotocol/ocean-subgraph subgraph.yaml -l $npm_package_version --debug --ipfs http://172.15.0.16:5001 --node http://172.15.0.15:8020",
|
||||
"test": "npm run codegen && npm run lint && npm run type-check",
|
||||
"test-integration": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/**/*.test.ts'",
|
||||
"test-fixed": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/FixedRateExchange.test.ts'",
|
||||
"lint": "eslint --ignore-path .gitignore --ext .js --ext .ts --ext .tsx .",
|
||||
"lint:fix": "eslint --ignore-path .gitignore --ext .js,.ts,.tsx . --fix",
|
||||
"format": "prettier --ignore-path .gitignore './**/*.{css,yml,js,ts,tsx,json,yaml}' --write",
|
||||
|
727
test/integration/FixedRateExchange.test.ts
Normal file
727
test/integration/FixedRateExchange.test.ts
Normal file
@ -0,0 +1,727 @@
|
||||
import {
|
||||
Erc20CreateParams,
|
||||
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: Erc20CreateParams = {
|
||||
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.createNftErc20WithFixedRate(
|
||||
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,
|
||||
creator,
|
||||
address,
|
||||
providerUrl,
|
||||
assetState,
|
||||
managerRole,
|
||||
erc20DeployerRole,
|
||||
storeUpdateRole,
|
||||
metadataRole,
|
||||
template,
|
||||
transferable,
|
||||
createdTimestamp,
|
||||
tx,
|
||||
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 === publisher, 'incorrect value for: owner')
|
||||
assert(nft.creator === 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')
|
||||
})
|
||||
|
||||
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,
|
||||
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.lastPriceToken === '0x0000000000000000000000000000000000000000',
|
||||
'incorrect value for: lastPriceToken'
|
||||
)
|
||||
assert(dt.lastPriceValue === '0', 'incorrect value for: lastPriceValue')
|
||||
})
|
||||
|
||||
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
|
||||
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')
|
||||
})
|
||||
|
||||
it('Updates Fixed Rate Price', async () => {
|
||||
fixedRate = new FixedRateExchange(web3, fixedRateAddress, 8996)
|
||||
const priceQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){
|
||||
price
|
||||
updates(orderBy: createdTimestamp, orderDirection: desc){
|
||||
exchangeId {
|
||||
id
|
||||
}
|
||||
oldPrice
|
||||
newPrice
|
||||
}
|
||||
}}`
|
||||
}
|
||||
|
||||
// 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'
|
||||
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')
|
||||
|
||||
// Update price a 2nd time
|
||||
const newPrice2 = '1' // '5.123'
|
||||
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')
|
||||
})
|
||||
it('Deactivates exchange', async () => {
|
||||
const deactiveQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){active}}`
|
||||
}
|
||||
|
||||
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
|
||||
.active
|
||||
assert(updatedActive === false, 'incorrect value for: updatedActive')
|
||||
})
|
||||
|
||||
it('Activates exchange', async () => {
|
||||
const activeQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){active}}`
|
||||
}
|
||||
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
|
||||
.active
|
||||
assert(updatedActive === true, 'incorrect value for: updatedActive')
|
||||
})
|
||||
|
||||
it('Activate Minting', async () => {
|
||||
const mintingQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){withMint}}`
|
||||
}
|
||||
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
|
||||
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
|
||||
.withMint
|
||||
assert(updatedMint === true, 'incorrect value for: updatedMint')
|
||||
})
|
||||
|
||||
it('Deactivate Minting', async () => {
|
||||
const mintingQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){withMint}}`
|
||||
}
|
||||
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
|
||||
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
|
||||
.withMint
|
||||
assert(updatedMint === false, 'incorrect value for: updatedMint')
|
||||
})
|
||||
|
||||
it('User1 buys a datatoken', async () => {
|
||||
const swapsQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){
|
||||
swaps{
|
||||
id
|
||||
exchangeId{id}
|
||||
by{id}
|
||||
baseTokenAmount
|
||||
dataTokenAmount
|
||||
block
|
||||
createdTimestamp
|
||||
tx
|
||||
__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.buyDT(user1, exchangeId, dtAmount, '100'))
|
||||
.events?.Swapped
|
||||
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}`, '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.tx === tx.transactionHash, 'incorrect value for: tx')
|
||||
assert(swaps.__typename === 'FixedRateExchangeSwap', 'incorrect __typename')
|
||||
})
|
||||
it('User1 sells a datatoken', async () => {
|
||||
await datatoken.approve(datatokenAddress, fixedRateAddress, dtAmount, user1)
|
||||
const tx = (await fixedRate.sellDT(user1, exchangeId, '10', '9')).events
|
||||
?.Swapped
|
||||
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
|
||||
__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}`, '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.tx === tx.transactionHash, 'incorrect value for: tx')
|
||||
assert(swaps.__typename === 'FixedRateExchangeSwap', 'incorrect __typename')
|
||||
})
|
||||
|
||||
it('Updates allowed swapper', async () => {
|
||||
const swapperQuery = {
|
||||
query: `query {fixedRateExchange(id: "${fixedRateId}"){allowedSwapper}}`
|
||||
}
|
||||
// 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'
|
||||
)
|
||||
|
||||
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.allowedSwapper
|
||||
|
||||
assert(allowedSwapper2 === user1, 'incorrect value for: allowedSwapper 2')
|
||||
})
|
||||
})
|
Loading…
Reference in New Issue
Block a user