aboutsummaryrefslogtreecommitdiffstats
path: root/src/mempool/order_watcher.ts
diff options
context:
space:
mode:
authorLeonid Logvinov <logvinov.leon@gmail.com>2017-10-30 16:54:28 +0800
committerFabio Berger <me@fabioberger.com>2017-10-31 00:49:16 +0800
commitf21f42f11ed11ef7b4e8ec7de1281150bf8b695c (patch)
tree01d439bcfe30ebd3d536d5b76454b0561756e233 /src/mempool/order_watcher.ts
parent68a8556cd20e45731343053ece9fb92944799a4c (diff)
downloaddexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar.gz
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar.bz2
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar.lz
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar.xz
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.tar.zst
dexon-sol-tools-f21f42f11ed11ef7b4e8ec7de1281150bf8b695c.zip
Add initial interface of an OrderWatcher
Diffstat (limited to 'src/mempool/order_watcher.ts')
-rw-r--r--src/mempool/order_watcher.ts27
1 files changed, 27 insertions, 0 deletions
diff --git a/src/mempool/order_watcher.ts b/src/mempool/order_watcher.ts
new file mode 100644
index 000000000..90c15cd34
--- /dev/null
+++ b/src/mempool/order_watcher.ts
@@ -0,0 +1,27 @@
+import * as Web3 from 'web3';
+import * as _ from 'lodash';
+import {Web3Provider, SignedOrder} from '../types';
+import {Web3Wrapper} from '../web3_wrapper';
+
+export class OrderWatcher {
+ constructor(provider: Web3Provider) {
+ if (_.isUndefined((provider as any).sendAsync)) {
+ // Web3@1.0 provider doesn't support synchronous http requests,
+ // so it only has an async `send` method, instead of a `send` and `sendAsync` in web3@0.x.x`
+ // We re-assign the send method so that Web3@1.0 providers work with 0x.js
+ (provider as any).sendAsync = (provider as any).send;
+ }
+ }
+ public addOrder(signedOrder: SignedOrder): void {
+ //
+ }
+ public removeOrder(signedOrder: SignedOrder): void {
+ //
+ }
+ public subscribe(callback: OnOrderFillabilityStateChangeCallback): void {
+ //
+ }
+ public unsubscribe(): void {
+ //
+ }
+}