aboutsummaryrefslogtreecommitdiffstats
path: root/packages/contract-wrappers/test/subscription_test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/contract-wrappers/test/subscription_test.ts')
-rw-r--r--packages/contract-wrappers/test/subscription_test.ts75
1 files changed, 0 insertions, 75 deletions
diff --git a/packages/contract-wrappers/test/subscription_test.ts b/packages/contract-wrappers/test/subscription_test.ts
deleted file mode 100644
index 0fa6af40d..000000000
--- a/packages/contract-wrappers/test/subscription_test.ts
+++ /dev/null
@@ -1,75 +0,0 @@
-import { BlockchainLifecycle } from '@0x/dev-utils';
-import { DoneCallback } from '@0x/types';
-import * as _ from 'lodash';
-import 'mocha';
-import * as Sinon from 'sinon';
-
-import {
- ContractWrappers,
- ContractWrappersConfig,
- DecodedLogEvent,
- ERC20TokenApprovalEventArgs,
- ERC20TokenEvents,
-} from '../src';
-
-import { chaiSetup } from './utils/chai_setup';
-import { constants } from './utils/constants';
-import { migrateOnceAsync } from './utils/migrate';
-import { tokenUtils } from './utils/token_utils';
-import { provider, web3Wrapper } from './utils/web3_wrapper';
-
-chaiSetup.configure();
-const blockchainLifecycle = new BlockchainLifecycle(web3Wrapper);
-
-describe('SubscriptionTest', () => {
- let contractWrappers: ContractWrappers;
- let config: ContractWrappersConfig;
-
- before(async () => {
- const contractAddresses = await migrateOnceAsync();
- config = {
- networkId: constants.TESTRPC_NETWORK_ID,
- contractAddresses,
- };
- contractWrappers = new ContractWrappers(provider, config);
- });
- beforeEach(async () => {
- await blockchainLifecycle.startAsync();
- });
- afterEach(async () => {
- await blockchainLifecycle.revertAsync();
- });
- describe('#subscribe', () => {
- const indexFilterValues = {};
- let tokenAddress: string;
- let stubs: Sinon.SinonStub[] = [];
- before(() => {
- const tokenAddresses = tokenUtils.getDummyERC20TokenAddresses();
- tokenAddress = tokenAddresses[0];
- });
- afterEach(() => {
- contractWrappers.erc20Token.unsubscribeAll();
- _.each(stubs, s => s.restore());
- stubs = [];
- });
- it('Should allow unsubscribeAll to be called successfully after an error', (done: DoneCallback) => {
- (async () => {
- const callback = (err: Error | null, _logEvent?: DecodedLogEvent<ERC20TokenApprovalEventArgs>) =>
- _.noop.bind(_);
- contractWrappers.erc20Token.subscribe(
- tokenAddress,
- ERC20TokenEvents.Approval,
- indexFilterValues,
- callback,
- );
- stubs = [
- Sinon.stub((contractWrappers as any)._web3Wrapper, 'getBlockIfExistsAsync').throws(
- new Error('JSON RPC error'),
- ),
- ];
- contractWrappers.erc20Token.unsubscribeAll();
- done();
- })().catch(done);
- });
- });
-});