diff options
author | Leonid Logvinov <logvinov.leon@gmail.com> | 2018-02-06 02:10:17 +0800 |
---|---|---|
committer | Leonid Logvinov <logvinov.leon@gmail.com> | 2018-02-06 02:10:17 +0800 |
commit | 881d32e73324b226bdc97f96fb583edb7a5311c1 (patch) | |
tree | 78e3b30e47d5fd03ee169afc9e33d8e6a45f8d43 /packages/long-lived-subscriptions-test/src/index.ts | |
parent | c7ad6ebad6ab65a4b1e4a2084e744c6ca2bc09b8 (diff) | |
download | dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar.gz dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar.bz2 dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar.lz dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar.xz dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.tar.zst dexon-sol-tools-881d32e73324b226bdc97f96fb583edb7a5311c1.zip |
Temp
Diffstat (limited to 'packages/long-lived-subscriptions-test/src/index.ts')
-rw-r--r-- | packages/long-lived-subscriptions-test/src/index.ts | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/packages/long-lived-subscriptions-test/src/index.ts b/packages/long-lived-subscriptions-test/src/index.ts new file mode 100644 index 000000000..2d79dcc89 --- /dev/null +++ b/packages/long-lived-subscriptions-test/src/index.ts @@ -0,0 +1,32 @@ +import { DecodedLogEvent, ExchangeEvents, LogFillContractEventArgs, ZeroEx } from '0x.js'; +import * as _ from 'lodash'; +import * as Web3 from 'web3'; + +const zeroExConfig = { + networkId: 1, +}; + +const RPC_URL = 'https://mainnet.infura.io/T5WSC8cautR4KXyYgsRs'; +// const RPC_URL = 'https://mainnet.0xproject.com'; + +const web3 = new Web3(new Web3.providers.HttpProvider(RPC_URL)); +const zeroEx = new ZeroEx(web3.currentProvider, zeroExConfig); + +const subscribe = () => { + console.log('subscribing...'); + zeroEx.exchange.subscribe<LogFillContractEventArgs>( + ExchangeEvents.LogFill, + {}, + (err: Error | null, event?: DecodedLogEvent<LogFillContractEventArgs>) => { + if (_.isNull(err)) { + console.log('EVENT'); + console.log(event); + } else { + console.log('ERROR'); + console.log(err); + subscribe(); + } + }, + ); +}; +subscribe(); |