From ae5e489e8a21293ae3f4d9a3e1940a62ddd01011 Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Tue, 5 Nov 2019 22:09:50 -0800
Subject: cache fx rates and periodically re-establish websocket

---
 rates.js | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

(limited to 'rates.js')

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);
 };
-- 
cgit v1.2.3