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;
};
