Added Cache

Author: imdkbj

.gitignore

@@ -6,6 +6,7 @@ yarn-debug.log*
 yarn-error.log*
 lerna-debug.log*
 db.js
+cache
 
 
 # Diagnostic reports (https://nodejs.org/api/report.html)

example/test2.js

@@ -1,12 +1,13 @@
 const _udf = require('../index.js');
-const conn = require('./db.js');
+// const conn = require('./db.js');
 
 let nodeUDF = new _udf();
 
 let {
     convertToTradingSymbol,
     validateOrderInput,
-    download
+    download,
+    setgetCache
 } = nodeUDF;
 
 
@@ -51,9 +52,10 @@ const test2 = async () => {
 // const myCache = new NodeCache()
 
 async function test3() {
-    let x = await nodeUDF.getsetData(['k'], 100);
+    let cb = new Date()
+    let x = await setgetCache('k', 10, cb);
 
     console.log(x);
 }
 
-test2()
+test3()

misc/cache.js

@@ -1,50 +1,36 @@
-const NodeCache = require("node-cache");
-
-class Cache extends NodeCache {
-    constructor(params) {
-        super(params);
-        this.params = params;
-    }
-
-    getData = (keys) => {
-        let _this = this;
-        let cache = Array.isArray(keys) ? _this.mget(keys) : _this.get(keys);
+const cacheManager = require("cache-manager");
+var fsStore = require('cache-manager-fs');
+
+const initCache = () =>
+    new Promise((resolve, reject) => {
+        memoryCache = cacheManager.caching({
+            store: fsStore,
+            path: 'cache',
+            ttl: 30,
+            preventfill: false,
+            reviveBuffers: false,
+            fillcallback: data => {
+                resolve()
+            }
+        })
+    })
 
-        // let cache = 
 
-        //     Object.assign(cache, {
-        //         _key: val
-        //     });
-        // }
 
-        return [cache];
+class Cache {
+    constructor(params) {
+        this.params = params;
     }
 
-
-    getsetData = async (arr, ttl, cb, arg) => {
-        let _this = this;
-        let all_data = [await _this.mget(arr)];
-        console.log(_this.keys());
-
-        let _ttl = (i) => Array.isArray(ttl) ? ttl[i] : ttl;
-        let process_data = all_data.map((data, i) => {
-            if (Object.keys(data).length == 0) {
-                //get the data
-                let _data = new Date();
-                //cb(arg);
-
-                //store this
-                _this.set(arr[i], _data, _ttl(i));
-
-                //return data
-                return _data;
-            } else {
-                return data;
-            }
-        })
-        console.log(_this.keys());
-
-        return process_data;
+    setgetCache = async (key, ttl, cb) => {
+        try {
+            await initCache();
+            return memoryCache.wrap(key, async () => await eval(cb), {
+                ttl: ttl
+            });
+        } catch (err) {
+            return Promise.reject(err);
+        }
     }
 }