Quick Inquiry

Want to use Nestjs with other Redis command in node js?

Yogesh Kumar
02-May-2022
0

It seem cache-manager-redis-store allow only normal redis operation and if you want to use more, you have to access cacheManager.store.getClient() as Micael suggest.

Cache interface got no getClient but RedisCache had! The problem is RedisCache interface inside cache-manager-redis-store package don't export those interface for outsider.

The easiest way to fix this is to create redis.interface.ts or whatever name for your own.

 import { Cache, Store } from 'cache-manager';
import { RedisClient } from 'redis';

export interface RedisCache extends Cache {
  store: RedisStore;
}

export interface RedisStore extends Store {
  name: 'redis';
  getClient: () => RedisClient;
  isCacheableValue: (value: any) => boolean;
}

Now you can replace Cache with RedisCache interface.

The usage will be as follows.

 import {
  CACHE_MANAGER,
  Inject,
  Injectable,
} from '@nestjs/common';
import { RedisClient } from 'redis';
import { RedisCache } from './interface/redis.interface';

@Injectable()
export class RedisService {
  private redisClient: RedisClient;
  constructor(@Inject(CACHE_MANAGER) private cacheManager: RedisCache) {
    this.redisClient = this.cacheManager.store.getClient();
  }

  hgetall() {
    this.redisClient.hgetall('mykey', (err, reply) => {
      console.log(reply);
    })
  }
}

Note that these redisClient commands do not return value so you have to use callback to get the value.

As you can see that the answer is in callback structure, I prefer await and async more so I did a little more work.

 import {
  BadRequestException,
  CACHE_MANAGER,
  Inject,
  Injectable,
} from '@nestjs/common';
import { RedisClient } from 'redis';
import { RedisCache } from './interface/redis.interface';

@Injectable()
export class RedisService {
  private redisClient: RedisClient;
  constructor(@Inject(CACHE_MANAGER) private cacheManager: RedisCache) {
    this.redisClient = this.cacheManager.store.getClient();
  }

  async hgetall(key: string): Promise<{ [key: string]: string }> {
    return new Promise<{ [key: string]: string }>((resolve, reject) => {
      this.redisClient.hgetall(key, (err, reply) => {
        if (err) {
          console.error(err);
          throw new BadRequestException();
        }
        resolve(reply);
      });
    });
  }
}

By using promise, I can get the answer as if the function return. The usage is as follows.

 import { Injectable } from '@nestjs/common';
import { RedisService } from './redis.service';

@Injectable()
export class UserService {
  constructor(private readonly redisService: RedisService) {}

  async getUserInfo(): Promise<{ [key: string]: string }> {
    const userInfo = await this.redisService.hgetall('mykey');
    return userInfo;
  }
}