diff options
author | Leonid Logvinov <logvinov.leon@gmail.com> | 2017-10-26 19:29:57 +0800 |
---|---|---|
committer | Leonid Logvinov <logvinov.leon@gmail.com> | 2017-11-10 03:11:45 +0800 |
commit | cea2fb0fe6014959def51b20ae574e3b6f547e49 (patch) | |
tree | 57daacc1854cf2fe4b49cec65ab7daa1b5646ea4 /test | |
parent | 23d7d7d1400706488d50af2c648cbe9a73530562 (diff) | |
download | dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar.gz dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar.bz2 dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar.lz dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar.xz dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.tar.zst dexon-sol-tools-cea2fb0fe6014959def51b20ae574e3b6f547e49.zip |
Add mempool tests
Diffstat (limited to 'test')
-rw-r--r-- | test/mempool_test.ts | 125 |
1 files changed, 125 insertions, 0 deletions
diff --git a/test/mempool_test.ts b/test/mempool_test.ts new file mode 100644 index 000000000..0c8fb921a --- /dev/null +++ b/test/mempool_test.ts @@ -0,0 +1,125 @@ +import 'mocha'; +import * as chai from 'chai'; +import * as _ from 'lodash'; +import * as Sinon from 'sinon'; +import * as Web3 from 'web3'; +import BigNumber from 'bignumber.js'; +import {chaiSetup} from './utils/chai_setup'; +import {web3Factory} from './utils/web3_factory'; +import { + ZeroEx, + LogEvent, + DecodedLogEvent, +} from '../src'; +import {DoneCallback} from '../src/types'; + +chaiSetup.configure(); +const expect = chai.expect; + +describe('MempoolWatcher', () => { + let web3: Web3; + let zeroEx: ZeroEx; + let stubs: Sinon.SinonStub[] = []; + const logA = { + address: '0x71d271f8b14adef568f8f28f1587ce7271ac4ca5', + blockHash: null, + blockNumber: null, + data: '', + logIndex: null, + topics: [], + transactionHash: '0x004881d38cd4a8f72f1a0d68c8b9b8124504706041ff37019c1d1ed6bfda8e17', + transactionIndex: null, + }; + const logB = { + address: '0x8d12a197cb00d4747a1fe03395095ce2a5cc6819', + blockHash: null, + blockNumber: null, + data: '', + logIndex: null, + topics: [ '0xf341246adaac6f497bc2a656f546ab9e182111d630394f0c57c710a59a2cb567' ], + transactionHash: '0x01ef3c048b18d9b09ea195b4ed94cf8dd5f3d857a1905ff886b152cfb1166f25', + transactionIndex: null, + }; + const logC = { + address: '0x1d271f8b174adef58f1587ce68f8f27271ac4ca5', + blockHash: null, + blockNumber: null, + data: '', + logIndex: null, + topics: [ '0xf341246adaac6f497bc2a656f546ab9e182111d630394f0c57c710a59a2cb567' ], + transactionHash: '0x01ef3c048b18d9b09ea195b4ed94cf8dd5f3d857a1905ff886b152cfb1166f25', + transactionIndex: null, + }; + before(async () => { + web3 = web3Factory.create(); + const config = { + mempoolPollingIntervalMs: 10, + }; + zeroEx = new ZeroEx(web3.currentProvider, config); + }); + afterEach(() => { + // clean up any stubs after the test has completed + _.each(stubs, s => s.restore()); + stubs = []; + zeroEx.mempool.unsubscribe(); + }); + it('correctly emits initial log events', (done: DoneCallback) => { + const logs: Web3.LogEntry[] = [logA, logB]; + const expectedLogEvents = [ + { + removed: false, + ...logA, + }, + { + removed: false, + ...logB, + }, + ]; + const getLogsStub = Sinon.stub((zeroEx.mempool as any)._web3Wrapper, 'getLogsAsync'); + getLogsStub.onCall(0).returns(logs); + stubs.push(getLogsStub); + const callback = (event: LogEvent) => { + const expectedLogEvent = expectedLogEvents.shift(); + expect(event).to.be.deep.equal(expectedLogEvent); + if (_.isEmpty(expectedLogEvents)) { + done(); + } + }; + zeroEx.mempool.subscribe(callback); + }); + it('correctly computes the difference and emits only changes', (done: DoneCallback) => { + const initialLogs: Web3.LogEntry[] = [logA, logB]; + const changedLogs: Web3.LogEntry[] = [logA, logC]; + const expectedLogEvents = [ + { + removed: false, + ...logA, + }, + { + removed: false, + ...logB, + }, + { + removed: true, + ...logB, + }, + { + removed: false, + ...logC, + }, + ]; + const getLogsStub = Sinon.stub((zeroEx.mempool as any)._web3Wrapper, 'getLogsAsync'); + getLogsStub.onCall(0).returns(initialLogs); + getLogsStub.onCall(1).returns(changedLogs); + stubs.push(getLogsStub); + const callback = (event: LogEvent) => { + // console.log(event); + const expectedLogEvent = expectedLogEvents.shift(); + expect(event).to.be.deep.equal(expectedLogEvent); + if (_.isEmpty(expectedLogEvents)) { + done(); + } + }; + zeroEx.mempool.subscribe(callback); + }); +}); |