diff options
author | Brandon Millman <brandon.millman@gmail.com> | 2018-05-25 08:19:27 +0800 |
---|---|---|
committer | Brandon Millman <brandon.millman@gmail.com> | 2018-07-12 01:17:45 +0800 |
commit | 47debf0134b5864046831321b8eeeeb9aaaaf0a8 (patch) | |
tree | d371b018939c7dad121edd0eae324cc560c95d74 /packages/connect/src/orderbook_channel_factory.ts | |
parent | 16ddd1edfccdd7768447bfff9afec1f4a1ce014e (diff) | |
download | dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar.gz dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar.bz2 dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar.lz dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar.xz dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.tar.zst dexon-sol-tools-47debf0134b5864046831321b8eeeeb9aaaaf0a8.zip |
Initial implementation of OrderbookChannelFactory
Diffstat (limited to 'packages/connect/src/orderbook_channel_factory.ts')
-rw-r--r-- | packages/connect/src/orderbook_channel_factory.ts | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/packages/connect/src/orderbook_channel_factory.ts b/packages/connect/src/orderbook_channel_factory.ts new file mode 100644 index 000000000..cb00212e7 --- /dev/null +++ b/packages/connect/src/orderbook_channel_factory.ts @@ -0,0 +1,33 @@ +// import * as WebSocket from 'websocket'; + +import { BrowserWebSocketOrderbookChannel } from './browser_ws_orderbook_channel'; +import { NodeWebSocketOrderbookChannel } from './node_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); + client.onopen = () => { + const orderbookChannel = new BrowserWebSocketOrderbookChannel(client); + console.log(orderbookChannel); + resolve(orderbookChannel); + }; + client.onerror = err => { + reject(err); + }; + }); + }, + // 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); + // }; + // }); + // }, +}; |