add redis for store user data

Author: daniwebdev

.env.example

@@ -1,15 +1,27 @@
 APP_ENV=development
+APP_API_KEY=intervest-sandbox
 
-DB_HOST="db-host"
+DB_HOST="pgsql"
 DB_PORT="5432"
-DB_USER="user"
-DB_PASS="password"
+DB_USER="user_intervest_dev"
+DB_PASS="pass_intervest_dev"
 DB_NAME="core"
 
+DB_COMMUNITY_HOST="pgsql-community"
+DB_COMMUNITY_PORT="5432"
+DB_COMMUNITY_USER="user_intervest_dev"
+DB_COMMUNITY_PASS="pass_intervest_dev"
+DB_COMMUNITY_NAME="community"
+
 MAIL_HOST=host.docker.internal
 MAIL_PORT=1025
 MAIL_USER=
 MAIL_PASS=
 MAIL_FROM_DEFAULT='"No Reply" <[email protected]>'
 
-REDIS_URL='redis://crypto-app-redis:6379/1'
+REDIS_URL='redis://redis:6379/0'
+
+JWT_SECRET=123k34j3k423jk231jk231j2k31j2k3jj33j
+JWT_SECRET_REFRESH=123234234234235234234443
+JWT_EXP_AT=60*60*24*7
+JWT_REFRESH_EXP_AT=60*60*24*30

package.json

@@ -36,6 +36,7 @@
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
     "ejs": "^3.1.8",
+    "ioredis": "^5.3.2",
     "jsonwebtoken": "^9.0.1",
     "passport": "^0.6.0",
     "passport-jwt": "^4.0.1",

src/apps/auth/auth.module.ts

@@ -5,10 +5,12 @@ import { TypeOrmModule } from '@nestjs/typeorm';
 import { User } from 'src/entities/user.entity';
 import { UserDevice } from 'src/entities/user-device.entity';
 import { AccessTokenStrategy, RefreshTokenStrategy } from './strategies';
+import { RedisModule } from 'src/modules/redis/redis.module';
 
 @Module({
   imports: [
     TypeOrmModule.forFeature([User, UserDevice]),
+    RedisModule,
   ],
   providers: [AuthService, AccessTokenStrategy, RefreshTokenStrategy],
   controllers: [AuthController]

src/apps/auth/auth.service.ts

@@ -10,13 +10,15 @@ import { compare, hash } from 'bcrypt';
 import { Request } from 'express';
 import { UserDevice } from 'src/entities/user-device.entity';
 import { DeviceDTO } from './dto/device.dto';
+import { RedisService } from 'src/modules/redis/redis.service';
 
 @Injectable()
 export class AuthService {
 
     constructor(
         @InjectRepository(User) private usersRepository: Repository<User>,
         @InjectRepository(UserDevice) private userDevicesRepository: Repository<UserDevice>,
+        private readonly redisService: RedisService,
         private readonly jwtService: JwtService,
         private readonly configService: ConfigService,
     ) {}
@@ -116,22 +118,26 @@ export class AuthService {
       }
 
     async getTokens(user: User, device: DeviceDTO) {
+        
+        await this.redisService.set(`user-data:${user.id}`, user);
+
         return {
             access_token: await this.jwtService.signAsync({
                 username: user.name,
                 deviceId: device.id,
                 id: user.id,
             }, {
                 secret: this.configService.get("JWT_SECRET"),
-                expiresIn: 15,
+                expiresIn: eval(this.configService.get('JWT_EXP_AT')),
             }),
             refresh_token: await this.jwtService.signAsync({
                 username: user.name,
                 id: user.id,
                 deviceId: device.id
             }, {
                 secret: this.configService.get("JWT_SECRET_REFRESH"),
-                expiresIn: 60 * 60 * 24 * 7,
+                // expiresIn: 60 * 60 * 24 * 7,
+                expiresIn: eval(this.configService.get('JWT_REFRESH_EXP_AT')),
             }),
         }
     }

src/apps/auth/strategies/access-token.strategy.ts

@@ -1,24 +1,26 @@
-import { HttpException, Injectable } from '@nestjs/common';
+import { Injectable } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config'
 import { PassportStrategy } from '@nestjs/passport'
 import { ExtractJwt, Strategy } from 'passport-jwt'
+import { RedisService } from 'src/modules/redis/redis.service';
 
 @Injectable()
 export class AccessTokenStrategy extends PassportStrategy(Strategy, 'jwt') {
 
     constructor(
         configService: ConfigService,
+        private redisService: RedisService,
     ) {
         super({
             jwtFromRequest: ExtractJwt.fromAuthHeaderAsBearerToken(),
             secretOrKey: configService.get('JWT_SECRET'),
         })
     }
 
-
-    validate(payload: any) {
-
-        return payload;
+    async validate(payload: any) {
+        const data = await this.redisService.get(`user-data:${payload.id}`) ?? payload;
+        console.log(data);
+        return data;
     }
 
 }

src/modules/redis/redis.module.ts

@@ -1,35 +1,17 @@
-// import { CacheModule } from '@nestjs/cache-manager';
 import { Module } from '@nestjs/common';
 import { RedisModule as IoRedisModule } from '@svtslv/nestjs-ioredis';
-// import { redisStore } from 'cache-manager-redis-store';
 import { RedisService } from './redis.service';
 @Module({
   imports: [
-    // CacheModule.registerAsync({
-    //   isGlobal: true,
-
-    //   useFactory: async () => ({
-    //     store: <> <unknown> redisStore,
-    //     url: process.env.REDIS_URL,
-    //   }),
-
-    // }),
 
     IoRedisModule.forRootAsync({
       useFactory: async () => ({
           config: {
             url: process.env.REDIS_URL,
           }
       })
-    }, 'real-connection'),
+    }, 'default'),
 
-    IoRedisModule.forRootAsync({
-      useFactory: async  () => ({
-          config: {
-            url: process.env.REDIS_DEMO_URL,
-          }
-      })
-    }, 'demo-connection')
   ],
   providers: [RedisService],
   exports: [RedisService],

src/modules/redis/redis.service.ts

@@ -5,46 +5,28 @@ import { InjectRedis, Redis } from '@svtslv/nestjs-ioredis';
 export class RedisService {
 
     constructor(
-        // @Inject(CACHE_MANAGER) private cacheManager: Cache,
-        @InjectRedis('real-connection') private readonly redisRealConnection: Redis,
-        @InjectRedis('demo-connection') private readonly redisDemoConnection: Redis,
+        @InjectRedis('default') private readonly redis: Redis,
     ) {}
 
     async get(key: string) {
-        if(key.indexOf('demo-') > -1) {
-            return await this.redisDemoConnection.get(key);
-        }
-        return await this.redisRealConnection.get(key);
-        // return this.cacheManager.get(key);
+        return JSON.parse(await this.redis.get(key));
     }
 
     async set(key: string, value: any, ttl?: number) {
-        console.log('🔥 🔥 🔥 🔥',key, key.indexOf('demo-'));
-        if(key.indexOf('demo-') != -1) {
-            return await this.redisDemoConnection.set(key, value);
-        }
-        return await this.redisRealConnection.set(key, value);
-        // await this.cacheManager.set(key, value, ttl)
+
+        return await this.redis.set(key, JSON.stringify(value));
     }
 
     // get store() {
-    //     return this.redisRealConnection;
+    //     return this.redis;
     //     // return this.cacheManager.store
     // }
 
     async del(key: string) {
-        if(key.indexOf('demo-') > -1) {
-            return await this.redisDemoConnection.del(key);
-        }
-        return await this.redisRealConnection.del(key);
-        // await this.cacheManager.store.del(key);
+        return await this.redis.del(key);
     }
 
     async keys(pattern?: any) {
-        if(pattern.indexOf('demo') > -1) {
-            return await this.redisDemoConnection.keys(pattern);
-        }
-        return  await this.redisRealConnection.keys(pattern);
-        // return this.store.keys(pattern);
+        return  await this.redis.keys(pattern);
     }
 }

yarn.lock

@@ -427,6 +427,11 @@
   resolved "https://registry.npmjs.org/@humanwhocodes/object-schema/-/object-schema-1.2.1.tgz"
   integrity sha512-ZnQMnLV4e7hDlUvw8H+U8ASL02SS2Gn6+9Ac3wGGLIe7+je2AeAOxPY+izIPJDfFDb7eDjev0Us8MO1iFRN8hA==
 
+"@ioredis/commands@^1.1.1":
+  version "1.2.0"
+  resolved "https://registry.yarnpkg.com/@ioredis/commands/-/commands-1.2.0.tgz#6d61b3097470af1fdbbe622795b8921d42018e11"
+  integrity sha512-Sx1pU8EM64o2BrqNpEO1CNLtKQwyhuXuqyfH7oGKCk+1a33d2r5saW8zNwm3j6BTExtjrv2BxTgzzkMwts6vGg==
+
 "@isaacs/cliui@^8.0.2":
   version "8.0.2"
   resolved "https://registry.yarnpkg.com/@isaacs/cliui/-/cliui-8.0.2.tgz#b37667b7bc181c168782259bab42474fbf52b550"
@@ -2153,7 +2158,7 @@ clone@^1.0.2:
   resolved "https://registry.npmjs.org/clone/-/clone-1.0.4.tgz"
   integrity sha512-JQHZ2QMW6l3aH/j6xCqQThY/9OH4D/9ls34cgkUBiEeocRTU04tHfKPBsUK1PqZCUQM7GiA0IIXJSuXHI64Kbg==
 
-[email protected]:
+[email protected], cluster-key-slot@^1.1.0:
   version "1.1.2"
   resolved "https://registry.npmjs.org/cluster-key-slot/-/cluster-key-slot-1.1.2.tgz"
   integrity sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA==
@@ -2468,6 +2473,11 @@ delegates@^1.0.0:
   resolved "https://registry.yarnpkg.com/delegates/-/delegates-1.0.0.tgz#84c6e159b81904fdca59a0ef44cd870d31250f9a"
   integrity sha512-bd2L678uiWATM6m5Z1VzNCErI3jiGzt6HGY8OVICs40JQq/HALfbyNJmp0UDakEY4pMMaN0Ly5om/B1VI/+xfQ==
 
+denque@^2.1.0:
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/denque/-/denque-2.1.0.tgz#e93e1a6569fb5e66f16a3c2a2964617d349d6ab1"
+  integrity sha512-HVQE3AAb/pxF8fQAoiqpvg9i3evqug3hoiwakOyZAwJm+6vZehbkYXZ0l4JxS+I3QxM97v5aaRNhj8v5oBhekw==
+
 [email protected]:
   version "2.0.0"
   resolved "https://registry.npmjs.org/depd/-/depd-2.0.0.tgz"
@@ -3747,6 +3757,21 @@ interpret@^1.0.0:
   resolved "https://registry.npmjs.org/interpret/-/interpret-1.4.0.tgz"
   integrity sha512-agE4QfB2Lkp9uICn7BAqoscw4SZP9kTE2hxiFI3jBPmXJfdqiahTbUuKGsMoN2GtqL9AxhYioAcVvgsb1HvRbA==
 
+ioredis@^5.3.2:
+  version "5.3.2"
+  resolved "https://registry.yarnpkg.com/ioredis/-/ioredis-5.3.2.tgz#9139f596f62fc9c72d873353ac5395bcf05709f7"
+  integrity sha512-1DKMMzlIHM02eBBVOFQ1+AolGjs6+xEcM4PDL7NqOS6szq7H9jSaEkIUH6/a5Hl241LzW6JLSiAbNvTQjUupUA==
+  dependencies:
+    "@ioredis/commands" "^1.1.1"
+    cluster-key-slot "^1.1.0"
+    debug "^4.3.4"
+    denque "^2.1.0"
+    lodash.defaults "^4.2.0"
+    lodash.isarguments "^3.1.0"
+    redis-errors "^1.2.0"
+    redis-parser "^3.0.0"
+    standard-as-callback "^2.1.0"
+
 ip@^1.1.5:
   version "1.1.8"
   resolved "https://registry.yarnpkg.com/ip/-/ip-1.1.8.tgz#ae05948f6b075435ed3307acce04629da8cdbf48"
@@ -4562,6 +4587,16 @@ locate-path@^6.0.0:
   dependencies:
     p-locate "^5.0.0"
 
+lodash.defaults@^4.2.0:
+  version "4.2.0"
+  resolved "https://registry.yarnpkg.com/lodash.defaults/-/lodash.defaults-4.2.0.tgz#d09178716ffea4dde9e5fb7b37f6f0802274580c"
+  integrity sha512-qjxPLHd3r5DnsdGacqOMU6pb/avJzdh9tFX2ymgoZE27BmjXrNy/y4LoaiTeAb+O3gL8AfpJGtqfX/ae2leYYQ==
+
+lodash.isarguments@^3.1.0:
+  version "3.1.0"
+  resolved "https://registry.yarnpkg.com/lodash.isarguments/-/lodash.isarguments-3.1.0.tgz#2f573d85c6a24289ff00663b491c1d338ff3458a"
+  integrity sha512-chi4NHZlZqZD18a0imDHnZPrDeBbTtVN7GXMwuGdRH9qotxAjYs3aVLKc7zNOG9eddR5Ksd8rvFEBc9SsggPpg==
+
 [email protected]:
   version "4.1.2"
   resolved "https://registry.npmjs.org/lodash.memoize/-/lodash.memoize-4.1.2.tgz"
@@ -6103,6 +6138,18 @@ rechoir@^0.6.2:
   dependencies:
     resolve "^1.1.6"
 
+redis-errors@^1.0.0, redis-errors@^1.2.0:
+  version "1.2.0"
+  resolved "https://registry.yarnpkg.com/redis-errors/-/redis-errors-1.2.0.tgz#eb62d2adb15e4eaf4610c04afe1529384250abad"
+  integrity sha512-1qny3OExCf0UvUV/5wpYKf2YwPcOqXzkwKKSmKHiE6ZMQs5heeE/c8eXK+PNllPvmjgAbfnsbpkGZWy8cBpn9w==
+
+redis-parser@^3.0.0:
+  version "3.0.0"
+  resolved "https://registry.yarnpkg.com/redis-parser/-/redis-parser-3.0.0.tgz#b66d828cdcafe6b4b8a428a7def4c6bcac31c8b4"
+  integrity sha512-DJnGAeenTdpMEH6uAJRK/uiyEIH9WVsUmoLwzudwGJUwZPp80PDBWPHXSAGNPwNvIXAbe7MSUB1zQFugFml66A==
+  dependencies:
+    redis-errors "^1.0.0"
+
 redis@^4.3.1:
   version "4.6.7"
   resolved "https://registry.npmjs.org/redis/-/redis-4.6.7.tgz"
@@ -6477,6 +6524,11 @@ stack-utils@^2.0.3:
   dependencies:
     escape-string-regexp "^2.0.0"
 
+standard-as-callback@^2.1.0:
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/standard-as-callback/-/standard-as-callback-2.1.0.tgz#8953fc05359868a77b5b9739a665c5977bb7df45"
+  integrity sha512-qoRRSyROncaz1z0mvYqIE4lCd9p2R90i6GxW3uZv5ucSu8tU7B5HXUP1gG8pVZsYNVaXjk8ClXHPttLyxAL48A==
+
 [email protected]:
   version "2.0.1"
   resolved "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz"