Setup Redis

.env.example

@@ -6,3 +6,8 @@ PASSWORD = <MYSQL_SERVER_PASSWORD>
 # jwt
 JWT_SECRET = 'stack_overflow_api'
 JWT_EXPIRES_IN = 1
+
+# redis
+REDIS_HOST='redis-19923.c302.asia-northeast1-1.gce.cloud.redislabs.com'
+REDIS_PORT=19923
+REDIS_PASSWORD='Ov9lLYsVxts6alqucdMFjMdtnqnYjWhA'

.gitignore

@@ -4,3 +4,4 @@
 .env
 package-lock.json
 .vercel
+yarn.lock

package.json

@@ -24,10 +24,13 @@
     "express-session": "^1.17.0",
     "express-validator": "^6.4.0",
     "helmet": "^3.23.3",
+    "ioredis": "^5.2.3",
     "jsonwebtoken": "^8.5.1",
     "morgan": "^1.10.0",
     "mysql2": "^2.3.2",
     "nodemon": "^2.0.15",
+    "redis": "^4.3.1",
+    "redis-om": "^0.3.6",
     "sequelize": "^6.6.4",
     "xss-clean": "^0.1.1"
   },

src/config/index.js

@@ -25,6 +25,11 @@ const config = {
     SECRET: getEnvVariable('JWT_SECRET'),
     EXPIRES_IN: +getEnvVariable('JWT_EXPIRES_IN'),
   },
+  REDIS: {
+    HOST: getEnvVariable('REDIS_HOST'),
+    PORT: getEnvVariable('REDIS_PORT'),
+    PASSWORD: getEnvVariable('REDIS_PASSWORD'),
+  },
 };
 
 module.exports = config;

src/config/redis.js

@@ -0,0 +1,21 @@
+const redis = require('redis');
+
+const config = require('./index');
+
+let client;
+
+(async () => {
+  client = redis.createClient({
+    socket: {
+      host: config.REDIS.HOST,
+      port: config.REDIS.PORT,
+    },
+    password: config.REDIS.PASSWORD,
+  });
+
+  client.on('error', (err) => console.log('Redis Client Error', err));
+
+  await client.connect();
+})();
+
+module.exports = client;

src/services/posts.service.js

@@ -1,4 +1,5 @@
 const db = require('../config/db.config');
+const client = require('../config/redis');
 const { responseHandler, investApi } = require('../helpers');
 const utils = require('../utils');
 const {
@@ -117,7 +118,18 @@ exports.retrieveOne = async (postId, result) => {
 };
 
 exports.retrieveAll = async (result) => {
-  const postsMap = await PostsRepository.retrieveAll();
+  await client.set('key', 'testing');
+  const value = await client.get('key');
+
+  console.log('value: ', value);
+
+  await client.rpush(['frameworks_list', 'ReactJS', 'Angular']);
+
+  const frameworksList = await client.get('frameworks_list');
+
+  console.log('frameworksList: ', frameworksList);
+
+  postsMap = await PostsRepository.retrieveAll();
 
   const postCounts = await PostsRepository.countForAll();