cache fx rates and periodically re-establish websocket

1 files changed, 14 insertions, 3 deletions

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);
 };