This commit is contained in:
Dragon Fire
2024-05-01 23:33:09 -04:00
parent 5c959244a7
commit 447557622c
2 changed files with 14 additions and 17 deletions
+1 -2
View File
@@ -23,8 +23,7 @@ module.exports = class XiaoClient extends CommandClient {
)
});
this.fonts = new FontManager(this);
this.redis = Redis.db;
Redis.start();
this.redis = new Redis(this);
this.timers = new TimerManager(this);
this.pokemon = new PokemonStore();
this.dispatchers = new Map();
+13 -15
View File
@@ -1,22 +1,20 @@
const Redis = require('ioredis');
const { REDIS_HOST, REDIS_PASS } = process.env;
const redis = new Redis({
port: 6379,
host: REDIS_HOST,
enableReadyCheck: true,
password: REDIS_PASS,
db: 0
});
module.exports = class RedisClient {
static get db() {
return redis;
}
constructor(client, host = REDIS_HOST, pass = REDIS_PASS) {
Object.defineProperty(this, 'client', { value: client });
static start() {
redis.on('connect', () => console.info('[REDIS][CONNECT]: Connecting...'));
redis.on('ready', () => console.info('[REDIS][READY]: Ready!'));
redis.on('error', error => console.error(`[REDIS][ERROR]: Encountered error:\n${error}`));
redis.on('reconnecting', () => console.warn('[REDIS][RECONNECT]: Reconnecting...'));
this.db = new Redis({
port: 6379,
host,
enableReadyCheck: true,
password: pass,
db: 0
});
this.db.on('connect', () => this.client.logger.info('[REDIS] Connecting...'));
this.db.on('ready', () => this.client.logger.info('[REDIS] Ready!'));
this.db.on('error', error => this.client.logger.error(`[REDIS] Encountered error:\n${error}`));
this.db.on('reconnecting', () => this.client.logger.warn('[REDIS] Reconnecting...'));
}
};