Initial commit

Author: dabroek

.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+.idea/

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2017 Matthijs Dabroek
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,85 @@
+'use strict';
+
+function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'default' in ex) ? ex['default'] : ex; }
+
+var Redis = _interopDefault(require('redis'));
+
+const redisStore = (...args) => {
+  const redisCache = Redis.createClient(...args);
+  const storeArgs = redisCache.options;
+
+  return {
+    name: 'redis',
+    getClient: () => redisCache,
+    set: (key, value, options, cb) => (
+      new Promise((resolve, reject) => {
+        if (typeof options === 'function') {
+          cb = options;
+          options = {};
+        }
+        options = options || {};
+
+        if (!cb) {
+          cb = (err, result) => (err ? reject(err) : resolve(result));
+        }
+
+        const ttl = (options.ttl || options.ttl === 0) ? options.ttl : storeArgs.ttl;
+        const val = JSON.stringify(value) || '"undefined"';
+
+        if (ttl) {
+          redisCache.setex(key, ttl, val, handleResponse(cb));
+        } else {
+          redisCache.set(key, val, handleResponse(cb));
+        }
+      })
+    ),
+    get: (key, options, cb) => (
+      new Promise((resolve, reject) => {
+        if (typeof options === 'function') {
+          cb = options;
+        }
+
+        if (!cb) {
+          cb = (err, result) => (err ? reject(err) : resolve(result));
+        }
+
+        redisCache.get(key, handleResponse(cb, { parse: true }));
+      })
+    ),
+    del: (key, options, cb) => {
+      if (typeof options === 'function') {
+        cb = options;
+      }
+
+      redisCache.del(key, handleResponse(cb));
+    },
+    reset: cb => redisCache.flushdb(handleResponse(cb)),
+    keys: cb => redisCache.keys(handleResponse(cb)),
+    ttl: (key, cb) => redisCache.ttl(key, handleResponse(cb)),
+    isCacheableValue: args.isCacheableValue || (value => value !== undefined && value !== null),
+  };
+};
+
+function handleResponse(cb, opts = {}) {
+  return (err, result) => {
+    if (err) {
+      return cb && cb(err);
+    }
+
+    if (opts.parse) {
+      try {
+        result = JSON.parse(result);
+      } catch (e) {
+        return cb && cb(e);
+      }
+    }
+
+    return cb && cb(null, result);
+  };
+}
+
+const methods = {
+  create: (...args) => redisStore(...args),
+};
+
+module.exports = methods;

dist/index.js

@@ -0,0 +1,81 @@
+import Redis from 'redis';
+
+const redisStore = (...args) => {
+  const redisCache = Redis.createClient(...args);
+  const storeArgs = redisCache.options;
+
+  return {
+    name: 'redis',
+    getClient: () => redisCache,
+    set: (key, value, options, cb) => (
+      new Promise((resolve, reject) => {
+        if (typeof options === 'function') {
+          cb = options;
+          options = {};
+        }
+        options = options || {};
+
+        if (!cb) {
+          cb = (err, result) => (err ? reject(err) : resolve(result));
+        }
+
+        const ttl = (options.ttl || options.ttl === 0) ? options.ttl : storeArgs.ttl;
+        const val = JSON.stringify(value) || '"undefined"';
+
+        if (ttl) {
+          redisCache.setex(key, ttl, val, handleResponse(cb));
+        } else {
+          redisCache.set(key, val, handleResponse(cb));
+        }
+      })
+    ),
+    get: (key, options, cb) => (
+      new Promise((resolve, reject) => {
+        if (typeof options === 'function') {
+          cb = options;
+        }
+
+        if (!cb) {
+          cb = (err, result) => (err ? reject(err) : resolve(result));
+        }
+
+        redisCache.get(key, handleResponse(cb, { parse: true }));
+      })
+    ),
+    del: (key, options, cb) => {
+      if (typeof options === 'function') {
+        cb = options;
+      }
+
+      redisCache.del(key, handleResponse(cb));
+    },
+    reset: cb => redisCache.flushdb(handleResponse(cb)),
+    keys: cb => redisCache.keys(handleResponse(cb)),
+    ttl: (key, cb) => redisCache.ttl(key, handleResponse(cb)),
+    isCacheableValue: args.isCacheableValue || (value => value !== undefined && value !== null),
+  };
+};
+
+function handleResponse(cb, opts = {}) {
+  return (err, result) => {
+    if (err) {
+      return cb && cb(err);
+    }
+
+    if (opts.parse) {
+      try {
+        result = JSON.parse(result);
+      } catch (e) {
+        return cb && cb(e);
+      }
+    }
+
+    return cb && cb(null, result);
+  };
+}
+
+const methods = {
+  create: (...args) => redisStore(...args),
+};
+
+export default methods;

index.js

@@ -0,0 +1,22 @@
+{
+  "name": "cache-manager-redis-store",
+  "author": "Matthijs Dabroek <[email protected]>",
+  "description": "Redis store for node-cache-manager module",
+  "version": "1.0.0",
+  "license": "MIT",
+  "main": "dist/index.js",
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/dabroek/node-cache-manager-redis-store.git"
+  },
+  "scripts": {
+    "test": "node test.js",
+    "build": "rollup -c"
+  },
+  "dependencies": {
+    "redis": "^2.7.1"
+  },
+  "devDependencies": {
+    "rollup": "^0.41.6"
+  }
+}

package.json

@@ -0,0 +1,5 @@
+export default {
+  entry: 'index.js',
+  format: 'cjs',
+  dest: 'dist/index.js',
+};

rollup.config.js

@@ -0,0 +1,14 @@
+var redisStore = require('./dist/index');
+
+var store = redisStore.create({
+  host: '127.0.0.1',
+  port: 6379,
+  ttl: 712,
+});
+
+console.log(store.getClient().options);
+
+store.set('lala', 'baba').then(() => store.get('lala').then((output) => {
+  console.log(output);
+  process.exit();
+}));