From c0888fab024cc9f7c99812bfabf9d7774312dbf7 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Wed, 11 Mar 2020 15:10:40 -0700 Subject: refactor --- lib/binance.js | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 lib/binance.js (limited to 'lib/binance.js') diff --git a/lib/binance.js b/lib/binance.js new file mode 100644 index 00000000..2f4f7ef7 --- /dev/null +++ b/lib/binance.js @@ -0,0 +1,30 @@ +const WebSocket = require("ws"); + +module.exports = () => { + 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; +}; -- cgit v1.2.3