added cache for oracle contract state

aeternity · Mar 25, 2020 · ca9bed4 · ca9bed4
1 parent 9956ad0
commit ca9bed4
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 1 deletion.
diff --git a/logic/cacheLogic.js b/logic/cacheLogic.js
@@ -24,6 +24,7 @@ module.exports = class CacheLogic {
     const keepHotFunction = async () => {
       await CacheLogic.getTipsCheckPreviews();
       await CacheLogic.fetchChainNames();
+      await aeternity.getOracleState();
     };
 
     await cache.init(aeternity, keepHotFunction);
@@ -134,7 +135,13 @@ module.exports = class CacheLogic {
     await cache.del(["getTips"]);
     res.send({status: "OK"});
   }
+
   static async deliverAllItems(req, res) {
     res.send(await CacheLogic.getAllTips());
   }
+
+  static async deliverOracleState(req, res) {
+    res.send(await aeternity.getOracleState());
+  }
+
 };
diff --git a/routes/cacheRoutes.js b/routes/cacheRoutes.js
@@ -9,6 +9,8 @@ const cache = new CacheLogic();
 // Open api routes
 router.get('/', CacheLogic.deliverAllItems);
 
+router.get('/oracle', CacheLogic.deliverOracleState);
+
 router.get('/invalidate/tips', CacheLogic.invalidateTips);
 
 // View routes

diff --git a/utils/aeternity.js b/utils/aeternity.js
@@ -38,14 +38,26 @@ class Aeternity {
     return (await this.client.getNodeInfo()).nodeNetworkId
   };
 
+  getOracleState = async () => {
+    if (!this.client) throw new Error('Init sdk first');
+
+    const fetchOracleState = () => this.oracleContract.methods.get_state().then(res => res.decodedResult);
+
+    return this.cache
+      ? this.cache.getOrSet(["oracleState"], () => fetchOracleState(), this.cache.shortCacheTime)
+      : fetchOracleState();
+  };
+
   getTips = async () => {
     if (!this.client) throw new Error('Init sdk first');
     const fetchTips = async () => {
       const state = await this.contract.methods.get_state();
       return this.getTipsRetips(state.decodedResult);
     };
 
-    return this.cache ? this.cache.getOrSet(["getTips"], () => fetchTips(), this.cache.shortCacheTime) : fetchTips();
+    return this.cache
+      ? this.cache.getOrSet(["getTips"], () => fetchTips(), this.cache.shortCacheTime)
+      : fetchTips();
   };
 
   getContractSource = () => {