use redis to store rates

1 files changed, 12 insertions, 11 deletions

diff --git a/lib/rates.js b/lib/rates.js
index 1172d202..fe942453 100644
--- a/lib/rates.js
+++ b/lib/rates.js
@@ -17,12 +17,16 @@ let connect = async () => {
   ws.onmessage = async function (event) {
     try {
       let msg = JSON.parse(event.data);
+      let rates = await g("rates");
+      let fx = await g("fx");
+      if (fx) ({ fx } = fx);
 
-      Object.keys(store.fx).map((symbol) => {
-        store.rates[symbol] = msg.c * store.fx[symbol];
+      Object.keys(fx).map((symbol) => {
+        rates[symbol] = msg.c * fx[symbol];
       });
 
-      store.last = msg.c;
+      s("rate", msg.c);
+      s("rates", rates);
       last = Date.now();
     } catch (e) {
       console.log(e);
@@ -37,13 +41,12 @@ let connect = async () => {
   return ws;
 };
 
-export let getRates = async () => {
+export let getFx = async () => {
   connect();
 
   let date = 0,
-    fx = {};
-  let rates = await g("rates");
-  if (rates) ({ date, fx } = rates);
+    fx = await g("fx");
+  if (fx) ({ date, fx } = fx);
 
   if (Date.now() - date > 24 * 60 * 60 * 1000) {
     date = Date.now();
@@ -58,13 +61,11 @@ export let getRates = async () => {
         fx[k] = fx[k] / USD;
       });
 
-      await s("rates", { date, fx });
+      await s("fx", { date, fx });
     } catch (e) {
       err("error fetching rates", e.message);
     }
   }
 
-  store.fx = fx;
-
-  setTimeout(getRates, 30000);
+  setTimeout(getFx, 30000);
 };