提交 f3863e8a authored 作者: Oleg Repin's avatar Oleg Repin

lint project sources

上级 a92484ca
export * from './redis.service' export * from './redis.service';
export * from './redis.module' export * from './redis.module';
export * from './redis.interface' export * from './redis.interface';
\ No newline at end of file
export const REDIS_MODULE_OPTIONS = Symbol('REDIS_MODULE_OPTIONS') export const REDIS_MODULE_OPTIONS = Symbol('REDIS_MODULE_OPTIONS');
export const REDIS_CLIENT = Symbol('REDIS_CLIENT') export const REDIS_CLIENT = Symbol('REDIS_CLIENT');
\ No newline at end of file
...@@ -2,13 +2,15 @@ import { ModuleMetadata } from '@nestjs/common/interfaces'; ...@@ -2,13 +2,15 @@ import { ModuleMetadata } from '@nestjs/common/interfaces';
import { RedisOptions } from 'ioredis'; import { RedisOptions } from 'ioredis';
export interface RedisModuleOptions extends RedisOptions { export interface RedisModuleOptions extends RedisOptions {
name?: string name?: string;
url?: string url?: string;
} }
export interface RedisModuleAsyncOptions export interface RedisModuleAsyncOptions
extends Pick<ModuleMetadata, 'imports'> { extends Pick<ModuleMetadata, 'imports'> {
useFactory?: (...args: any[]) => useFactory?: (
...args: any[]
) =>
| RedisModuleOptions | RedisModuleOptions
| RedisModuleOptions[] | RedisModuleOptions[]
| Promise<RedisModuleOptions> | Promise<RedisModuleOptions>
......
import { Injectable, Inject } from "@nestjs/common"; import { Injectable, Inject } from '@nestjs/common';
import { REDIS_CLIENT } from './redis.constants'; import { REDIS_CLIENT } from './redis.constants';
import * as Redis from "ioredis"; import * as Redis from 'ioredis';
import { RedisClient, RedisClientError } from "./redis-client.provider"; import { RedisClient, RedisClientError } from './redis-client.provider';
@Injectable() @Injectable()
export class RedisService { export class RedisService {
constructor( constructor(
@Inject(REDIS_CLIENT) private readonly redisClient: RedisClient @Inject(REDIS_CLIENT) private readonly redisClient: RedisClient,
) { } ) {}
getClient(name?: string): Redis.Redis { getClient(name?: string): Redis.Redis {
if (!name) { if (!name) {
name = this.redisClient.defaultKey name = this.redisClient.defaultKey;
} }
if (!this.redisClient.clients.has(name)) { if (!this.redisClient.clients.has(name)) {
throw new RedisClientError(`client ${name} is not exists`) throw new RedisClientError(`client ${name} is not exists`);
} }
return this.redisClient.clients.get(name) return this.redisClient.clients.get(name);
} }
getClients(): Map<string, Redis.Redis> { getClients(): Map<string, Redis.Redis> {
return this.redisClient.clients; return this.redisClient.clients;
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论