refactor

1 files changed, 30 insertions, 0 deletions

diff --git a/lib/binance.js b/lib/binance.js
new file mode 100644
index 00000000..2f4f7ef7
--- /dev/null
+++ b/lib/binance.js
@@ -0,0 +1,30 @@
+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;
+};