aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--lib/binance.js17
1 files changed, 6 insertions, 11 deletions
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;