diff options
| author | Adam Soltys <[email protected]> | 2020-03-11 15:10:40 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2020-03-11 15:10:40 -0700 |
| commit | c0888fab024cc9f7c99812bfabf9d7774312dbf7 (patch) | |
| tree | cad95683af97432f6092a2c2bae10fbb7a588db5 /binance.js | |
| parent | bf2b51f0c2ae9b8f0f330dde6411e45fc0da8a25 (diff) | |
| download | coinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.tar.gz coinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.zip | |
refactor
Diffstat (limited to 'binance.js')
| -rw-r--r-- | binance.js | 31 |
1 files changed, 0 insertions, 31 deletions
diff --git a/binance.js b/binance.js deleted file mode 100644 index ccb010e1..00000000 --- a/binance.js +++ /dev/null @@ -1,31 +0,0 @@ -const WebSocket = require("ws"); -const l = require("pino")(); - -module.exports = (app, socket) => { - const binance = new WebSocket( - "wss://stream.binance.com:9443/ws/btcusdt@ticker" - ); - - binance.onmessage = async function(event) { - try { - let msg = JSON.parse(event.data); - app.set("bid", msg.b); - app.set("ask", msg.a); - app.set("last", msg.l); - - let fx = app.get("fxrates"); - if (!fx) return; - let rates = {}; - - Object.keys(fx).map(symbol => { - rates[symbol] = msg.a * fx[symbol]; - }); - - app.set("rates", rates); - } catch(e) { - l.error("binance socket error", e); - } - }; - - return binance; -}; |
