From cf4e234edd9aa01bf99019e209ddd512c8cf2607 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Sat, 27 Jun 2020 19:58:07 -0700 Subject: change in binance api --- lib/binance.js | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) (limited to 'lib/binance.js') diff --git a/lib/binance.js b/lib/binance.js index 2f4f7ef7..a93c7c38 100644 --- a/lib/binance.js +++ b/lib/binance.js @@ -1,29 +1,24 @@ const WebSocket = require("ws"); module.exports = () => { - binance = new WebSocket( - "wss://stream.binance.com:9443/ws/btcusdt@ticker" - ); + binance = new WebSocket("wss://fstream.binance.com/ws/btcusdt@ticker"); - binance.onmessage = async function(event) { + 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]; + Object.keys(fx).map((symbol) => { + rates[symbol] = msg.c * fx[symbol]; }); app.set("rates", rates); - } catch(e) { + } catch (e) { l.error("binance socket error", e); - } + } }; return binance; -- cgit v1.2.3