Support redis/memcached in cache

api/src/cache.ts

@@ -1,12 +1,50 @@
 import env from './env';
-import Keyv from 'keyv';
+import Keyv, { Options } from 'keyv';
 import { validateEnv } from './utils/validate-env';
+import { getConfigFromEnv } from './utils/get-config-from-env';
+import ms from 'ms';
+import logger from './logger';
 
 let cache: Keyv | null = null;
 
 if (env.CACHE_ENABLED === true) {
 	validateEnv(['CACHE_NAMESPACE', 'CACHE_TTL', 'CACHE_STORE']);
-	cache = new Keyv({ namespace: env.CACHE_NAMESPACE, ttl: env.CACHE_TTL });
+	cache = getKevyInstance();
+	cache.on('error', logger.error);
 }
 
 export default cache;
+
+function getKevyInstance() {
+	switch (env.CACHE_STORE) {
+		case 'redis':
+			return new Keyv(getConfig('redis'));
+		case 'memcache':
+			return new Keyv(getConfig('memcache'));
+		case 'memory':
+		default:
+			return new Keyv(getConfig());
+	}
+}
+
+function getConfig(
+	store: 'memory' | 'redis' | 'memcache' = 'memory'
+): Options<any> {
+	const config: Options<any> = { namespace: env.CACHE_NAMESPACE, ttl: ms(env.CACHE_TTL as string) };
+
+	if (store === 'redis') {
+		const Redis = require('ioredis');
+		const KeyvRedis = require('@keyv/redis');
+
+		config.store = new KeyvRedis(new Redis(
+			env.CACHE_REDIS || getConfigFromEnv('CACHE_REDIS_')
+		));
+	}
+
+	if (store === 'memcache') {
+		const KeyvMemcache = require('keyv-memcache');
+		config.store = new KeyvMemcache(env.CACHE_MEMCACHE);
+	}
+
+	return config;
+}

api/src/middleware/rate-limiter.ts

@@ -6,7 +6,6 @@ import {
 	RateLimiterMemcache,
 	IRateLimiterOptions,
 	IRateLimiterStoreOptions,
-	RateLimiterStoreAbstract,
 } from 'rate-limiter-flexible';
 import env from '../env';
 import { getConfigFromEnv } from '../utils/get-config-from-env';