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; }; v id='cgit'>
aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/express/node_modules/mkdirp/.travis.yml
blob: f1d0f13c8a54d0f8d78f86a1f9348f3c59750694 (plain) (blame) 
1
2
3
4