aboutsummaryrefslogtreecommitdiffstats
path: root/binance.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2020-03-11 15:10:40 -0700
committerAdam Soltys <[email protected]>2020-03-11 15:10:40 -0700
commitc0888fab024cc9f7c99812bfabf9d7774312dbf7 (patch)
treecad95683af97432f6092a2c2bae10fbb7a588db5 /binance.js
parentbf2b51f0c2ae9b8f0f330dde6411e45fc0da8a25 (diff)
downloadcoinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.tar.gz
coinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.zip
refactor
Diffstat (limited to 'binance.js')
-rw-r--r--binance.js31
1 files changed, 0 insertions, 31 deletions
diff --git a/binance.js b/binance.js
deleted file mode 100644
index ccb010e1..00000000
--- a/binance.js
+++ /dev/null
@@ -1,31 +0,0 @@
-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) {
- 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;
-};