From 629701a87138e2fedb69e260bc3951cb567b322c Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Mon, 9 Mar 2020 22:30:48 -0700 Subject: log binance error --- binance.js | 28 +++++++++++++++++----------- 1 file changed, 17 insertions(+), 11 deletions(-) (limited to 'binance.js') diff --git a/binance.js b/binance.js index 52d06ad9..ccb010e1 100644 --- a/binance.js +++ b/binance.js @@ -1,24 +1,30 @@ 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) { - let msg = JSON.parse(event.data); - app.set("bid", msg.b); - app.set("ask", msg.a); - app.set("last", msg.l); + 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 = {}; + 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.a * fx[symbol]; + }); - app.set("rates", rates); + app.set("rates", rates); + } catch(e) { + l.error("binance socket error", e); + } }; return binance; -- cgit v1.2.3