Skip to content

Commit

Permalink
Data Parity tests for Transactions (#146)
Browse files Browse the repository at this point in the history 
* Added parity tests around transactions 

* Extend test timeout

Co-authored-by: Rhys Bartels-Waller <rhys.bartelswaller@iohk.io>
  • Loading branch information
@oneEdoubleD @rhyslbw
oneEdoubleD and rhyslbw authored May 11, 2020
1 parent 7ef646e commit 26cbed9
Show file tree
Hide file tree
Showing 3 changed files with 371 additions and 1 deletion.
2 changes: 1 addition & 1 deletion jest.config.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,5 +3,5 @@ module.exports = {
"^.+\\.test.ts?$": "ts-jest"
},
preset: 'ts-jest',
testTimeout: 10000
testTimeout: 30000
}
1 change: 1 addition & 0 deletions src/__test__/dataparitytests/index.ts
View file
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
export * from './blocks.parity.test'
export * from './transactions.parity.test'
369 changes: 369 additions & 0 deletions src/__test__/dataparitytests/transactions.parity.test.ts
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,369 @@
import gql from 'graphql-tag'
import { TestClient } from '../TestClient'
import fetch from 'node-fetch'

async function getDataFromAPI (path: string) {
const response = await fetch(`https://explorer.cardano.org/api/${path}`)
return response.json()
}

function timestampToIsoStringWithoutTimezone (timestamp: number): string {
return new Date(timestamp * 1000).toISOString().substr(0, 19)
}

export function transactionTests (createClient: () => Promise<TestClient>) {
describe('transactions', () => {
let client: TestClient

beforeEach(async () => {
client = await createClient()
}, 60000)

it('return the correct ID', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
}
}`
})

const restResultId = restResult['Right']['ctsId']
const graphQLId = graphQLResult['data']['transactions'][0]['id']

expect(graphQLId).toEqual(restResultId)
})

it('return the correct Result Fee', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
fee
}
}`
})

const restResultFee = restResult['Right']['ctsFees']['getCoin']
const graphQLFee = graphQLResult['data']['transactions'][0]['fee']

expect(graphQLFee).toEqual(parseInt(restResultFee))
})

it('return the correct Total Output', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
totalOutput
}
}`
})

const restResultTotalOutput = restResult['Right']['ctsTotalOutput']['getCoin']
const graphQLTotalOutput = graphQLResult['data']['transactions'][0]['totalOutput']

expect(graphQLTotalOutput).toEqual(restResultTotalOutput)
})

it('return the correct Block Height', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs {
address
value
sourceTxId
sourceTxIndex
}
outputs{
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultTotalOutput = restResult['Right']['ctsBlockHeight']
const graphQLTotalOutput = graphQLResult['data']['transactions'][0]['block']['number']

expect(graphQLTotalOutput).toEqual(restResultTotalOutput)
})

it('return the correct Input Addresses', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs(order_by: { index: asc }) {
address
value
sourceTxId
sourceTxIndex
}
outputs(order_by: { index: asc }){
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultInputs = restResult['Right']['ctsInputs']
const restResultAddresses = []

for (const input of restResultInputs) {
restResultAddresses.push(input[0])
}

const graphQLInputs = graphQLResult['data']['transactions'][0]['inputs']
const graphQLAddresses = []

for (const input of graphQLInputs) {
graphQLAddresses.push(input['address'])
}

expect(graphQLAddresses).toEqual(restResultAddresses)
})

it('return the correct Input Values', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs {
address
value
sourceTxId
sourceTxIndex
}
outputs{
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultInputs = restResult['Right']['ctsInputs']
let restResultValues = 0

for (const input of restResultInputs) {
restResultValues += Number(input[1]['getCoin'])
}

const graphQLInputs = graphQLResult['data']['transactions'][0]['inputs']
let graphQLValues = 0

for (const input of graphQLInputs) {
graphQLValues += Number(input['value'])
}

expect(graphQLValues).toEqual(restResultValues)
})

it('return the correct Output Addresses', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs(order_by: { index: asc }) {
address
value
sourceTxId
sourceTxIndex
}
outputs(order_by: { index: asc }){
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultOutputs = restResult['Right']['ctsOutputs']
const restResultAddresses = []

for (const output of restResultOutputs) {
restResultAddresses.push(output[0])
}

const graphQLOutputs = graphQLResult['data']['transactions'][0]['outputs']
const graphQLAddresses = []

for (const output of graphQLOutputs) {
graphQLAddresses.push(output['address'])
}

expect(graphQLAddresses).toEqual(restResultAddresses)
})

it('return the correct Output Values', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs {
address
value
sourceTxId
sourceTxIndex
}
outputs{
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultOutputs = restResult['Right']['ctsOutputs']
let restResultValues = 0

for (const output of restResultOutputs) {
restResultValues += Number(output[1]['getCoin'])
}

const graphQLOutputs = graphQLResult['data']['transactions'][0]['outputs']
let graphQLValues = 0

for (const output of graphQLOutputs) {
graphQLValues += Number(output['value'])
}

expect(graphQLValues).toEqual(restResultValues)
})

it('have the same block creation time', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs {
address
value
sourceTxId
sourceTxIndex
}
outputs{
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultBlockTime = restResult['Right']['ctsBlockTimeIssued']
const graphQLBlockTime = graphQLResult['data']['transactions'][0]['block']['createdAt']

expect(graphQLBlockTime).toEqual(timestampToIsoStringWithoutTimezone(restResultBlockTime))
})

it('have the same transaction inclusion time', async () => {
const restResult = await getDataFromAPI('txs/summary/1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762')
const graphQLResult = await client.query({
query: gql`query TxById{
transactions (where: {id: {_eq:"1ac36644733c367ee4c551413d799d2e395d6ddfe14bebf1c281e6e826901762"}})
{
id
fee
block{
number
createdAt
}
inputs {
address
value
sourceTxId
sourceTxIndex
}
outputs{
address
index
value
}
totalOutput
includedAt
}
}`
})

const restResultTransactionTime = restResult['Right']['ctsTxTimeIssued']
const graphQLTransactionTime = graphQLResult['data']['transactions'][0]['includedAt']

expect(graphQLTransactionTime).toEqual(timestampToIsoStringWithoutTimezone(restResultTransactionTime))
})
})
}

0 comments on commit 26cbed9

Please sign in to comment.