woomy-v2/bot/util/redis.js

/* 
 * - All get/set functions will return nothing if the key is not found in the database.
 * - If you want to delete a key, use hdelAsync. Writing extended functions for deleting keys is pointless.
 * - Member key names are formatted as "guildID-userID". Use this.member.del(guildId + '-' + id) to delete member data.
 */

const { promisifyAll } = require('bluebird');
const redis = promisifyAll(require('redis'));
const generators = require('redis-async-gen');

class Redis {
	constructor(client) {
		this.client = client;

		// Create redis client
		this.global = redis.createClient(this.client.config.redis)
		this.guild = this.global.duplicate({ db: 1 })
		this.member = this.global.duplicate({ db: 2 })
		this.user = this.global.duplicate({ db: 3 })

		// Monitor for events emitted by Redis client
		this.global.on('ready', () => {
			this.client.logger.info('Connected to Redis DB.');
		});

		this.global.on('reconnecting', () => {
		this.client.logger.info('Attempting to reconnect to Redis DB...');
		});

		this.global.on('error', (err) => {
			this.client.logger.error('Redis error: ' + err);
		});

		this.global.on('warning', (warn) => {
			this.client.logger.warn('Redis warning: ' + warn);
		});
	}

	async getGuild (id) {
		let result = await this.guild.hgetallAsync(id);
		let defaults = this.client.config.defaultGuildData;

		if (result === null) return defaults;
		
		for (const defaultValue in defaults) {
			if (!result[defaultValue]) {
				result[defaultValue] = defaults[defaultValue];
			};
		};

		return result;
	};

	async getMember (id) {
		let result = await this.member.hgetallAsync(id);
		let defaults = this.client.config.defaultMemberData;

		if (result === null) return defaults;
		
		for (const defaultValue in defaults) {
			if (!result[defaultValue]) {
				result[defaultValue] = defaults[defaultValue];
			};
		};

		return result;
	};

	async getUser (id) {
		let result = await this.user.hgetallAsync(id);
		let defaults = this.client.config.defaultUserData;

		if (result === null) return defaults;
		
		for (const defaultValue in defaults) {
			if (!result[defaultValue]) {
				result[defaultValue] = defaults[defaultValue];
			};
		};

		return result;
	};

	async getGuildKey (id, key) {
		let result = await this.guild.hgetAsync(id, key);

		// Return value in config if no override is found in the database
		if(result === null) result = this.client.config.defaultGuildData[key];

		return result;
	};

	async getMemberKey (id, key) {
		let result = await this.member.hgetAsync(id, key);

		if(result === null) result = this.client.config.defaultMemberData[key];

		return result;
	};

	async getUserKey (id, key) {
		let result = await this.user.hgetAsync(id, key);

		if(result === null) result = this.client.config.defaultUserData[key];

		return result;
	};

	async setGuildKey (id, key, newValue) {
		const def = this.client.config.defaultGuildData[key];

		if (!def) return;
		
		if(def === newValue) {
			await this.guild.hdel(id, key); // If new value matches the default, delete the override.
		} else {
			await this.guild.hsetAsync(id, key, newValue);
		};

		return true;
	};

	async setMemberKey (id, key, newValue) {
		const def = this.client.config.defaultMemberData[key];

		if (!def) return;
		
		if(def === newValue) {
			await this.member.hdel(id, key);
		} else {
			await this.member.hsetAsync(id, key, newValue);
		};

		return true;
	};

	async setUserKey (id, key, newValue) {
		const def = this.client.config.defaultUserData[key];

		if (!def) return;
		
		if(def === newValue) {
			await this.user.hdel(id, key);
		} else {
			await this.user.hsetAsync(id, key, newValue);
		};

		return true;
	};

  // Deletes all data associated with a guild, INCLUDING MEMBER DATA
  async purgeGuild (id) {
    this.guild.del(id)
    var { keysMatching } = await generators.using(this.member)
    // eslint-disable-next-line no-unused-vars
    for await (const key of keysMatching(id + '-*')) {
      this.member.del(key)
    }
	}

  // Deletes all data associated with a user, INCLUDING MEMBER DATA
  async purgeUser (id) {
		this.user.del(id)
		var { keysMatching } = await generators.using(this.member)
		// eslint-disable-next-line no-unused-vars
		for await (const key of keysMatching('*-' + id)) {
			this.member.del(key)
		}
	}
}

module.exports = Redis;