cache fx rates and periodically re-establish websocket

3 files changed, 19 insertions, 8 deletions

diff --git a/binance.js b/binance.js
index 007f7848..52d06ad9 100644
--- a/binance.js
+++ b/binance.js
@@ -1,5 +1,4 @@
 const WebSocket = require("ws");
-
 module.exports = (app, socket) => {
   const binance = new WebSocket(
     "wss://stream.binance.com:9443/ws/btcusdt@ticker"
@@ -11,7 +10,7 @@ module.exports = (app, socket) => {
     app.set("ask", msg.a);
     app.set("last", msg.l);
 
-    let fx = app.get("rates");
+    let fx = app.get("fxrates");
     if (!fx) return;
     let rates = {};
 
@@ -19,6 +18,8 @@ module.exports = (app, socket) => {
       rates[symbol] = msg.a * fx[symbol];
     });
 
-    socket.emit("rates", rates);
+    app.set("rates", rates);
   };
+
+  return binance;
 };
diff --git a/index.js b/index.js
index 2e452404..5a0c1df6 100644
--- a/index.js
+++ b/index.js
@@ -39,8 +39,7 @@ const l = console.log;
     })
   );
 
-  require("./binance")(app, socket);
-  require("./rates")(app);
+  require("./rates")(app, socket);
 
   const seen = [];
   const addresses = {};
diff --git a/rates.js b/rates.js
index 608f5d4a..7c4643d3 100644
--- a/rates.js
+++ b/rates.js
@@ -2,7 +2,9 @@ const axios = require("axios");
 const config = require("./config");
 const l = console.log;
 
-module.exports = app => {
+module.exports = (app, socket) => {
+  let binance = require("./binance")(app, socket);
+
   let fetchRates;
   (fetchRates = async () => {
     try {
@@ -26,11 +28,20 @@ module.exports = app => {
       rates.VES = res.data["exchange_rates"].VEF_USD / 100000;
       rates.KVES = res.data["exchange_rates"].VEF_USD / 100000000;
 
-      app.set("rates", rates);
+      app.set("fxrates", rates);
     } catch (e) {
       l(e);
     }
 
-    setTimeout(fetchRates, 3600000);
+    setTimeout(fetchRates, 7200000);
   })();
+
+  setInterval(() => {
+    socket.emit("rates", app.get("rates"));
+  }, 1000);
+
+  setInterval(() => {
+    binance.terminate();
+    binance = require("./binance")(app, socket);
+  }, 360000);
 };