diff options
author | Fabio Berger <me@fabioberger.com> | 2018-07-14 01:44:21 +0800 |
---|---|---|
committer | Fabio Berger <me@fabioberger.com> | 2018-07-14 01:44:21 +0800 |
commit | ced68e4e022eb1020a4d15ab9a64552b4f92744a (patch) | |
tree | 0e8daaea34e7aa7339ea2961bf7de664d60f434d /packages/order-watcher/src/order_watcher/event_watcher.ts | |
parent | 9b387b8ec3c543b5c96d1887550797a2bb90fe94 (diff) | |
download | dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar.gz dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar.bz2 dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar.lz dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar.xz dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.tar.zst dexon-sol-tools-ced68e4e022eb1020a4d15ab9a64552b4f92744a.zip |
Expose Blockstreams blockRetention config as an OrderWatcher config
Diffstat (limited to 'packages/order-watcher/src/order_watcher/event_watcher.ts')
-rw-r--r-- | packages/order-watcher/src/order_watcher/event_watcher.ts | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/packages/order-watcher/src/order_watcher/event_watcher.ts b/packages/order-watcher/src/order_watcher/event_watcher.ts index 08ecf81cb..38ba8101e 100644 --- a/packages/order-watcher/src/order_watcher/event_watcher.ts +++ b/packages/order-watcher/src/order_watcher/event_watcher.ts @@ -27,13 +27,16 @@ export class EventWatcher { private _pollingIntervalMs: number; private _stateLayer: BlockParamLiteral; private _isVerbose: boolean; + private _blockRetention: number; constructor( web3Wrapper: Web3Wrapper, pollingIntervalIfExistsMs: undefined | number, stateLayer: BlockParamLiteral = BlockParamLiteral.Latest, + blockRetention: number, isVerbose: boolean, ) { this._isVerbose = isVerbose; + this._blockRetention = blockRetention; this._web3Wrapper = web3Wrapper; this._stateLayer = stateLayer; this._pollingIntervalMs = _.isUndefined(pollingIntervalIfExistsMs) @@ -69,6 +72,9 @@ export class EventWatcher { this._web3Wrapper.getBlockAsync.bind(this._web3Wrapper, this._stateLayer), this._web3Wrapper.getLogsAsync.bind(this._web3Wrapper, eventFilter), this._onBlockAndLogStreamerError.bind(this), + { + blockRetention: this._blockRetention, + }, ); const catchAllLogFilter = {}; this._blockAndLogStreamerIfExists.addLogFilter(catchAllLogFilter); |