aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2020-06-27 19:58:07 -0700
committerAdam Soltys <[email protected]>2020-06-27 19:58:07 -0700
commitcf4e234edd9aa01bf99019e209ddd512c8cf2607 (patch)
tree2a04692e2d5b4ef928bfc67b5d71a10dda4add83 /lib
parent7c1f6e8c79f9f8ef8923328012aa3910fdd455a6 (diff)
downloadcoinos-server-cf4e234edd9aa01bf99019e209ddd512c8cf2607.tar.gz
coinos-server-cf4e234edd9aa01bf99019e209ddd512c8cf2607.zip
change in binance api
Diffstat (limited to 'lib')
-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;