aboutsummaryrefslogtreecommitdiffstats
path: root/packages/connect/src/orderbook_channel_factory.ts
diff options
context:
space:
mode:
authorBrandon Millman <brandon.millman@gmail.com>2018-05-26 07:08:15 +0800
committerBrandon Millman <brandon.millman@gmail.com>2018-07-12 01:18:15 +0800
commita4b6112a311332df2c00799857463a646df78e25 (patch)
tree8fcc053b7fae56f7a69801e3c4091cda30a393ac /packages/connect/src/orderbook_channel_factory.ts
parent47debf0134b5864046831321b8eeeeb9aaaaf0a8 (diff)
downloaddexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar.gz
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar.bz2
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar.lz
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar.xz
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.tar.zst
dexon-sol-tools-a4b6112a311332df2c00799857463a646df78e25.zip
Consolidate back to one channel and expose only the factory
Diffstat (limited to 'packages/connect/src/orderbook_channel_factory.ts')
-rw-r--r--packages/connect/src/orderbook_channel_factory.ts35
1 files changed, 14 insertions, 21 deletions
diff --git a/packages/connect/src/orderbook_channel_factory.ts b/packages/connect/src/orderbook_channel_factory.ts
index cb00212e7..4b363365f 100644
--- a/packages/connect/src/orderbook_channel_factory.ts
+++ b/packages/connect/src/orderbook_channel_factory.ts
@@ -1,16 +1,21 @@
-// import * as WebSocket from 'websocket';
+import * as WebSocket from 'websocket';
-import { BrowserWebSocketOrderbookChannel } from './browser_ws_orderbook_channel';
-import { NodeWebSocketOrderbookChannel } from './node_ws_orderbook_channel';
+import { OrderbookChannel, WebsocketClientEventType } from './types';
+import { assert } from './utils/assert';
+import { WebSocketOrderbookChannel } from './ws_orderbook_channel';
export const orderbookChannelFactory = {
- async createBrowserOrderbookChannelAsync(url: string): Promise<BrowserWebSocketOrderbookChannel> {
- return new Promise<BrowserWebSocketOrderbookChannel>((resolve, reject) => {
- const client = new WebSocket(url);
- console.log(client);
+ /**
+ * Instantiates a new WebSocketOrderbookChannel instance
+ * @param url The relayer API base WS url you would like to interact with
+ * @return An OrderbookChannel Promise
+ */
+ async createWebSocketOrderbookChannelAsync(url: string): Promise<OrderbookChannel> {
+ assert.isUri('url', url);
+ return new Promise<OrderbookChannel>((resolve, reject) => {
+ const client = new WebSocket.w3cwebsocket(url);
client.onopen = () => {
- const orderbookChannel = new BrowserWebSocketOrderbookChannel(client);
- console.log(orderbookChannel);
+ const orderbookChannel = new WebSocketOrderbookChannel(client);
resolve(orderbookChannel);
};
client.onerror = err => {
@@ -18,16 +23,4 @@ export const orderbookChannelFactory = {
};
});
},
- // async createNodeOrderbookChannelAsync(url: string): Promise<NodeWebSocketOrderbookChannel> {
- // return new Promise<BrowserWebSocketOrderbookChannel>((resolve, reject) => {
- // const client = new WebSocket.w3cwebsocket(url);
- // client.onopen = () => {
- // const orderbookChannel = new BrowserWebSocketOrderbookChannel(client);
- // resolve(orderbookChannel);
- // };
- // client.onerror = err => {
- // reject(err);
- // };
- // });
- // },
};