Changeset View
Changeset View
Standalone View
Standalone View
apps/alias-server/test/eventsTests.js
| Show All 9 Lines | |||||
| const { handleAppStartup, handleBlockConnected } = require('../src/events'); | const { handleAppStartup, handleBlockConnected } = require('../src/events'); | ||||
| const { MockChronikClient } = require('./mocks/chronikMock'); | const { MockChronikClient } = require('./mocks/chronikMock'); | ||||
| const MockAdapter = require('axios-mock-adapter'); | const MockAdapter = require('axios-mock-adapter'); | ||||
| const axios = require('axios'); | const axios = require('axios'); | ||||
| // Mock mongodb | // Mock mongodb | ||||
| const { initializeDb, updateServerState } = require('../src/db'); | const { initializeDb, updateServerState } = require('../src/db'); | ||||
| const { MongoClient } = require('mongodb'); | const { MongoClient } = require('mongodb'); | ||||
| const { MongoMemoryServer } = require('mongodb-memory-server'); | const { MongoMemoryServer } = require('mongodb-memory-server'); | ||||
| const { testAddressAliases } = require('./mocks/aliasMocks'); | const { generated } = require('./mocks/aliasMocks'); | ||||
| describe('alias-server events.js', async function () { | describe('alias-server events.js', async function () { | ||||
| let mongoServer, testMongoClient; | let mongoServer, testMongoClient; | ||||
| before(async () => { | before(async () => { | ||||
| // Start mongo memory server before running this suite of unit tests | // Start mongo memory server before running this suite of unit tests | ||||
| mongoServer = await MongoMemoryServer.create(); | mongoServer = await MongoMemoryServer.create(); | ||||
| const mongoUri = mongoServer.getUri(); | const mongoUri = mongoServer.getUri(); | ||||
| testMongoClient = new MongoClient(mongoUri); | testMongoClient = new MongoClient(mongoUri); | ||||
| Show All 33 Lines | it('handleAppStartup calls handleBlockConnected with tipHeight and completes function if block is avalanche finalized', async function () { | ||||
| // Add tx history to mockedChronik | // Add tx history to mockedChronik | ||||
| // Set the script | // Set the script | ||||
| const { type, hash } = cashaddr.decode( | const { type, hash } = cashaddr.decode( | ||||
| config.aliasConstants.registrationAddress, | config.aliasConstants.registrationAddress, | ||||
| true, | true, | ||||
| ); | ); | ||||
| mockedChronik.setScript(type, hash); | mockedChronik.setScript(type, hash); | ||||
| // Set the mock tx history | // Set the mock tx history | ||||
| mockedChronik.setTxHistory(testAddressAliases.txHistory); | mockedChronik.setTxHistory(generated.txHistory); | ||||
| // Mock avalanche RPC call | // Mock avalanche RPC call | ||||
| // onNoMatch: 'throwException' helps to debug if mock is not being used | // onNoMatch: 'throwException' helps to debug if mock is not being used | ||||
| const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | ||||
| // Mock response for rpc return of true for isfinalblock method | // Mock response for rpc return of true for isfinalblock method | ||||
| mock.onPost().reply(200, { | mock.onPost().reply(200, { | ||||
| result: true, | result: true, | ||||
| error: null, | error: null, | ||||
| ▲ Show 20 Lines • Show All 116 Lines • ▼ Show 20 Lines | it('handleBlockConnected returns false if the function fails to obtain serverState', async function () { | ||||
| // Add tx history to mockedChronik | // Add tx history to mockedChronik | ||||
| // Set the script | // Set the script | ||||
| const { type, hash } = cashaddr.decode( | const { type, hash } = cashaddr.decode( | ||||
| config.aliasConstants.registrationAddress, | config.aliasConstants.registrationAddress, | ||||
| true, | true, | ||||
| ); | ); | ||||
| mockedChronik.setScript(type, hash); | mockedChronik.setScript(type, hash); | ||||
| // Set the mock tx history | // Set the mock tx history | ||||
| mockedChronik.setTxHistory(testAddressAliases.txHistory); | mockedChronik.setTxHistory(generated.txHistory); | ||||
| // Mock avalanche RPC call | // Mock avalanche RPC call | ||||
| // onNoMatch: 'throwException' helps to debug if mock is not being used | // onNoMatch: 'throwException' helps to debug if mock is not being used | ||||
| const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | ||||
| // Mock response for rpc return of true for isfinalblock method | // Mock response for rpc return of true for isfinalblock method | ||||
| mock.onPost().reply(200, { | mock.onPost().reply(200, { | ||||
| result: true, | result: true, | ||||
| error: null, | error: null, | ||||
| ▲ Show 20 Lines • Show All 43 Lines • ▼ Show 20 Lines | it('handleBlockConnected returns false if called with a block of height lower than serverState', async function () { | ||||
| // Add tx history to mockedChronik | // Add tx history to mockedChronik | ||||
| // Set the script | // Set the script | ||||
| const { type, hash } = cashaddr.decode( | const { type, hash } = cashaddr.decode( | ||||
| config.aliasConstants.registrationAddress, | config.aliasConstants.registrationAddress, | ||||
| true, | true, | ||||
| ); | ); | ||||
| mockedChronik.setScript(type, hash); | mockedChronik.setScript(type, hash); | ||||
| // Set the mock tx history | // Set the mock tx history | ||||
| mockedChronik.setTxHistory(testAddressAliases.txHistory); | mockedChronik.setTxHistory(generated.txHistory); | ||||
| // Mock avalanche RPC call | // Mock avalanche RPC call | ||||
| // onNoMatch: 'throwException' helps to debug if mock is not being used | // onNoMatch: 'throwException' helps to debug if mock is not being used | ||||
| const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | ||||
| // Mock response for rpc return of true for isfinalblock method | // Mock response for rpc return of true for isfinalblock method | ||||
| mock.onPost().reply(200, { | mock.onPost().reply(200, { | ||||
| result: true, | result: true, | ||||
| error: null, | error: null, | ||||
| ▲ Show 20 Lines • Show All 45 Lines • ▼ Show 20 Lines | it('handleBlockConnected returns false if called with a block of height equal to serverState', async function () { | ||||
| // Add tx history to mockedChronik | // Add tx history to mockedChronik | ||||
| // Set the script | // Set the script | ||||
| const { type, hash } = cashaddr.decode( | const { type, hash } = cashaddr.decode( | ||||
| config.aliasConstants.registrationAddress, | config.aliasConstants.registrationAddress, | ||||
| true, | true, | ||||
| ); | ); | ||||
| mockedChronik.setScript(type, hash); | mockedChronik.setScript(type, hash); | ||||
| // Set the mock tx history | // Set the mock tx history | ||||
| mockedChronik.setTxHistory(testAddressAliases.txHistory); | mockedChronik.setTxHistory(generated.txHistory); | ||||
| // Mock avalanche RPC call | // Mock avalanche RPC call | ||||
| // onNoMatch: 'throwException' helps to debug if mock is not being used | // onNoMatch: 'throwException' helps to debug if mock is not being used | ||||
| const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | const mock = new MockAdapter(axios, { onNoMatch: 'throwException' }); | ||||
| // Mock response for rpc return of true for isfinalblock method | // Mock response for rpc return of true for isfinalblock method | ||||
| mock.onPost().reply(200, { | mock.onPost().reply(200, { | ||||
| result: true, | result: true, | ||||
| error: null, | error: null, | ||||
| Show All 26 Lines | |||||