.prettierignore

@@ -0,0 +1 @@
+node_modules/

.prettierrc.json

@@ -0,0 +1,18 @@
+{
+  "arrowParens": "always",
+  "bracketSameLine": false,
+  "bracketSpacing": true,
+  "endOfLine": "lf",
+  "overrides": [
+    {
+      "files": "*.mjml",
+      "options": { "parser": "html" }
+    }
+  ],
+  "printWidth": 80,
+  "semi": true,
+  "singleQuote": true,
+  "tabWidth": 2,
+  "trailingComma": "all",
+  "useTabs": false
+}

jest.config.json

@@ -1,3 +1,5 @@
 {
-  "testEnvironment": "node"
+  "testEnvironment": "node",
+  "clearMocks": true,
+  "restoreMocks": true
 }

lib/cache.js → lib/cache/index.js

@@ -1,49 +1,48 @@
-const EventEmitter = require('events');
+'use strict';
+
 const crypto = require('crypto');
 
+const { CacheStoreFactory } = require('./storage/cache_store_factory');
+
 const DEFAULT_STORAGE = 'shared-memory';
 const DEFAULT_INDEX_LIMIT = 1000;
 
-class Cache extends EventEmitter {
+class Cache {
   constructor(clientId, options) {
-    super();
-
-    this.versions = null;
-    this.indexes = null;
-    this.storage = null;
-    this.env = null;
-
     options = options || {};
     if (typeof options === 'string') {
       options = { path: options };
     }
 
-    // Pre-emptive env setting
-    this.env = options.env;
-
     this.params = {
       clientId: clientId,
       path: options.path ? String(options.path) : '',
       storage: options.storage || DEFAULT_STORAGE,
       indexLimit: options.indexLimit || DEFAULT_INDEX_LIMIT,
     };
 
-    switch (this.params.storage) {
-      case 'memory':
-        this.storage = new MemoryStorage();
-        break;
-      case 'shared-memory':
-        this.storage = new SharedMemoryStorage();
-        break;
-      default:
-        throw new Error(this.params.storage + ' storage is not currently supported');
-    }
+    // Initialize environment setting
+    this.env = options.env;
+
+    // Initialize cache storage
+    this.cacheStore = CacheStoreFactory.getCacheStore(this.params.storage);
+
+    // Initialize cache contents
+    this.flush();
   }
 
   setEnv(env) {
     this.env = env;
   }
 
+  /**
+   * Flushes the cache.
+   */
+  flush() {
+    this.cacheStore.flush();
+    this.reset();
+  }
+
   get(url, data) {
     data = data || null;
 
@@ -272,7 +271,7 @@ class Cache extends EventEmitter {
   // Get cache content
   getCache() {
     const cachePath = this.getPath.apply(this, arguments);
-    const cacheContent = this.storage.read(cachePath);
+    const cacheContent = this.cacheStore.read(cachePath);
     if (cacheContent !== undefined) {
       return JSON.parse(cacheContent);
     }
@@ -284,14 +283,14 @@ class Cache extends EventEmitter {
     const cacheContent = JSON.stringify(content);
     const cacheSize = cacheContent.length;
 
-    this.storage.write(cachePath, cacheContent);
+    this.cacheStore.write(cachePath, cacheContent);
 
     return cacheSize;
   }
 
   // Clear a cache path
   clearCache(cachePath) {
-    this.storage.remove(cachePath);
+    this.cacheStore.remove(cachePath);
   }
 
   // Get array of collections affected by a result
@@ -309,47 +308,4 @@ class Cache extends EventEmitter {
   }
 }
 
-// Memory used by this instance only
-class MemoryStorage {
-  memory = {};
-
-  read(key) {
-    return this.memory[key];
-  }
-
-  write(key, value) {
-    this.memory[key] = value;
-  }
-
-  remove(key) {
-    delete this.memory[key];
-  }
-}
-
-// Memory used by all instances in this process
-class SharedMemoryStorage {
-  memory = {};
-
-  constructor() {
-    if (!SharedMemoryStorage.memory) {
-      SharedMemoryStorage.memory = {};
-    }
-    this.memory = SharedMemoryStorage.memory;
-  }
-
-  read(key) {
-    return this.memory[key];
-  }
-
-  write(key, value) {
-    this.memory[key] = value;
-  }
-
-  remove(key) {
-    delete this.memory[key];
-  }
-}
-
 module.exports = Cache;
-module.exports.MemoryStorage = MemoryStorage;
-module.exports.SharedMemoryStorage = SharedMemoryStorage;