Adds redis cache adapter for distributed systems

Author: flovilmart

.travis.yml

@@ -16,6 +16,7 @@ env:
   - COVERAGE_OPTION='./node_modules/.bin/istanbul cover'
   matrix:
   - PARSE_SERVER_TEST_DB=postgres
+  - PARSE_SERVER_TEST_CACHE=redis
   - MONGODB_VERSION=3.0.8
   - MONGODB_VERSION=3.2.6
 matrix:

spec/helper.js

@@ -24,6 +24,7 @@ var MongoStorageAdapter = require('../src/Adapters/Storage/Mongo/MongoStorageAda
 const GridStoreAdapter = require('../src/Adapters/Files/GridStoreAdapter').GridStoreAdapter;
 const FSAdapter = require('parse-server-fs-adapter');
 const PostgresStorageAdapter = require('../src/Adapters/Storage/Postgres/PostgresStorageAdapter');
+const RedisCacheAdapter = require('../src/Adapters/Cache/RedisCacheAdapter').default;
 
 const mongoURI = 'mongodb://localhost:27017/parseServerMongoAdapterTestDatabase';
 const postgresURI = 'postgres://localhost:5432/parse_server_postgres_adapter_test_database';
@@ -101,6 +102,10 @@ var defaultConfiguration = {
   }
 };
 
+if (process.env.PARSE_SERVER_TEST_CACHE === 'redis') {
+  defaultConfiguration.cacheAdapter = new RedisCacheAdapter();
+}
+
 let openConnections = {};
 
 // Set up a default API server for testing with default configuration.

src/Adapters/Cache/RedisCacheAdapter.js

@@ -0,0 +1,69 @@
+import redis from 'redis';
+import logger from '../../logger';
+
+function debug() {
+  logger.debug.apply(logger, ['RedisCacheAdapter', ...arguments]);
+}
+
+export class RedisCacheAdapter {
+
+  constructor(ctx) {
+    this.client = redis.createClient(ctx);
+    this.p = Promise.resolve();
+  }
+
+  get(key) {
+    debug('get', key);
+    this.p = this.p.then(() => {
+      return new Promise((resolve, _) => {
+        this.client.get(key, function(err, res) {
+          debug('-> get', key, res);
+          if(!res) {
+            return resolve(null);
+          }
+          resolve(JSON.parse(res));
+        });
+      });
+    });
+    return this.p;
+  }
+
+  put(key, value, ttl) {
+    value = JSON.stringify(value);
+    debug('put', key, value, ttl);
+    this.p = this.p.then(() => {
+      return new Promise((resolve, _) => {
+        this.client.set(key, value, function(err, res) {
+          resolve();
+        });
+      });
+    });
+    return this.p;
+  }
+
+  del(key) {
+    debug('del', key);
+    this.p = this.p.then(() => {
+      return new Promise((resolve, _) => {
+        this.client.del(key, function(err, res) {
+          resolve();
+        });
+      });
+    });
+    return this.p;
+  }
+
+  clear() {
+    debug('clear');
+    this.p = this.p.then(() => {
+      return new Promise((resolve, _) => {
+        this.client.flushall(function(err, res) {
+          resolve();
+        });
+      });
+    });
+    return this.p;
+  }
+}
+
+export default RedisCacheAdapter;

src/index.js

@@ -3,6 +3,7 @@ import S3Adapter            from 'parse-server-s3-adapter'
 import FileSystemAdapter    from 'parse-server-fs-adapter'
 import InMemoryCacheAdapter from './Adapters/Cache/InMemoryCacheAdapter'
 import NullCacheAdapter     from './Adapters/Cache/NullCacheAdapter'
+import RedisCacheAdapter    from './Adapters/Cache/RedisCacheAdapter'
 import TestUtils            from './TestUtils';
 import { useExternal }      from './deprecated';
 import { getLogger }        from './logger';
@@ -22,4 +23,4 @@ Object.defineProperty(module.exports, 'logger', {
 });
 
 export default ParseServer;
-export { S3Adapter, GCSAdapter, FileSystemAdapter, InMemoryCacheAdapter, NullCacheAdapter, TestUtils, _ParseServer as ParseServer };
+export { S3Adapter, GCSAdapter, FileSystemAdapter, InMemoryCacheAdapter, NullCacheAdapter, RedisCacheAdapter, TestUtils, _ParseServer as ParseServer };