diff options
author | Brandon Millman <brandon.millman@gmail.com> | 2018-05-26 07:08:15 +0800 |
---|---|---|
committer | Brandon Millman <brandon.millman@gmail.com> | 2018-07-12 01:18:15 +0800 |
commit | a4b6112a311332df2c00799857463a646df78e25 (patch) | |
tree | 8fcc053b7fae56f7a69801e3c4091cda30a393ac /packages/connect/src/orderbook_channel_factory.ts | |
parent | 47debf0134b5864046831321b8eeeeb9aaaaf0a8 (diff) | |
download | dexon-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.ts | 35 |
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); - // }; - // }); - // }, }; |