use redis to store rates

3 files changed, 16 insertions, 12 deletions

diff --git a/routes/ecash.js b/routes/ecash.js
index d7a9fe7b..8c2684b1 100644
--- a/routes/ecash.js
+++ b/routes/ecash.js
@@ -16,7 +16,7 @@ export default {
       await s(`cash:${id}`, token);
       res.send({ id });
     } catch (e) {
-      console.log(e)
+      err(e.message);
       bail(res, e.message);
     }
   },
@@ -27,6 +27,7 @@ export default {
       let status = await check(token);
       res.send({ token, status });
     } catch (e) {
+      err(e.message);
       bail(res, e.message);
     }
   },
@@ -38,11 +39,12 @@ export default {
       let memo;
       let hash = v4();
       let { currency, id: uid } = user;
+      let rates = await g("rates");
       await s(`invoice:${hash}`, {
         currency,
         id: hash,
         hash,
-        rate: store.rates[currency],
+        rate: rates[currency],
         uid,
         received: 0,
       });
@@ -51,7 +53,7 @@ export default {
 
       res.send({ ok: true });
     } catch (e) {
-      console.log(e);
+      err(e.message);
       bail(res, e.message);
     }
   },
@@ -69,6 +71,7 @@ export default {
 
       res.send({ id });
     } catch (e) {
+      err(e.message);
       bail(res, e.message);
     }
   },
@@ -89,7 +92,8 @@ export default {
         0,
       );
 
-      let rate = store.rates[currency];
+      let rates = await g("rates");
+      let rate = rates[currency];
 
       if (ourfee.err) fail(ourfee.err);
 
diff --git a/routes/payments.js b/routes/payments.js
index 0a40317c..df479d19 100644
--- a/routes/payments.js
+++ b/routes/payments.js
@@ -1,5 +1,4 @@
 import config from "$config";
-import store from "$lib/store";
 import { emit } from "$lib/sockets";
 import { v4 } from "uuid";
 import { db, g, s, t } from "$lib/db";
@@ -139,11 +138,11 @@ export default {
   async parse({ body: { payreq }, user }, res) {
     try {
       let hour = 1000 * 60 * 60;
-      let { last } = store.nodes;
-      let { nodes } = store;
+      let nodes = await g("nodes");
+      let { last } = nodes;
 
       if (!last || last > Date.now() - hour) ({ nodes } = await ln.listnodes());
-      store.nodes = nodes;
+      await s("nodes", nodes);
 
       let twoWeeksAgo = new Date(new Date().setDate(new Date().getDate() - 14));
       let decoded = await ln.decodepay(payreq);
@@ -202,12 +201,13 @@ export default {
 
       if (!iid) {
         iid = v4();
+        let rates = await g("rates");
         let { currency } = user;
         await s(`invoice:${iid}`, {
           currency,
           id: iid,
           hash: iid,
-          rate: store.rates[currency],
+          rate: rates[currency],
           uid: user.id,
           received: 0,
         });
diff --git a/routes/rates.js b/routes/rates.js
index 08b604bb..828e5b2c 100644
--- a/routes/rates.js
+++ b/routes/rates.js
@@ -1,11 +1,11 @@
-import store from "$lib/store";
+import { g } from "$lib/db";
 
 export default {
   async last(req, res) {
-    res.send(store.last);
+    res.send(await g('rate'));
   },
 
   async index(req, res) {
-    res.send(store.rates);
+    res.send(await g('rates'));
   },
 };