proxy/nodejs/utils/redis_model.js

'use strict';

const {createClient} = require('redis');
const objValidate = require('../utils/object_validate');
const conf = require('../conf');

const client = createClient({});
client.connect()

function redisPrefix(key){
	return `${conf.redis.prefix}${key}`;
}

class Table{
	static redisClient = client;
	
	constructor(data){
		for(let key in data){
			this[key] = data[key];
		}
	}

	static async get(index){
		try{
			if(typeof index === 'object'){
				index = index[this._key];
			}

			let result = await client.HGETALL(
				redisPrefix(`${this.prototype.constructor.name}_${index}`)
			);

			if(!Object.keys(result).length){
				let error = new Error('EntryNotFound');
				error.name = 'EntryNotFound';
				error.message = `${this.prototype.constructor.name}:${index} does not exists`;
				error.status = 404;
				throw error;
			}

			// Redis always returns strings, use the keyMap schema to turn them
			// back to native values.
			result = objValidate.parseFromString(this._keyMap, result);

			return new this(result);

		}catch(error){
			throw error;
		}

	}

	static async exists(index){
		try{
			await this.get(data);

			return true;
		}catch(error){
			return false;
		}
	}

	static async list(){
		// return a list of all the index keys for this table.
		try{
			return await client.SMEMBERS(
				redisPrefix(this.prototype.constructor.name)
			);

		}catch(error){
			throw error;
		}
	}

	static async listDetail(){
		// Return a list of the entries as instances.
		let out = [];

		for(let entry of await this.list()){
			out.push(await this.get(entry));
		}

		return out;
	}

	static async create(data){
		// Add a entry to this redis table.
		try{
			// Validate the passed data by the keyMap schema.
			data = objValidate.processKeys(this._keyMap, data);

			// Do not allow the caller to overwrite an existing index key,
			if(data[this._key] && await this.exists(data)){
				let error = new Error('EntryNameUsed');
				error.name = 'EntryNameUsed';
				error.message = `${this.prototype.constructor.name}:${data[this._key]} already exists`;
				error.status = 409;

				throw error;
			}

			// Add the key to the members for this redis table
			await client.SADD(
				redisPrefix(this.prototype.constructor.name),
				data[this._key]
			);

			// Add the values for this entry.
			for(let key of Object.keys(data)){
				if(!data[key]) continue;
				await client.HSET(
					redisPrefix(`${this.prototype.constructor.name}_${data[this._key]}`), 
					key,
					objValidate.parseToString(data[key])
				);
			}

			// return the created redis entry as entry instance.
			return await this.get(data[this._key]);
		} catch(error){
			throw error;
		}
	}

	async update(data, key){
		// Update an existing entry.
		try{
			// Check to see if entry name changed.
			if(data[this.constructor._key] && data[this.constructor._key] !== this[this.constructor._key]){
				// Remove the index key from the tables members list.
				await client.SREM(
					redisPrefix(this.constructor.name),
					this[this.constructor._key]
				);

				// Add the key to the members for this redis table
				await client.SADD(
					redisPrefix(this.constructor.name),
					data[this.constructor._key]
				);

			}
			// Update what ever fields that where passed.

			// Validate the passed data, ignoring required fields.
			data = objValidate.processKeys(this.constructor._keyMap, data, true);
			
			// Loop over the data fields and apply them to redis
			for(let key of Object.keys(data)){
				this[key] = data[key];
				await client.HSET(
					redisPrefix(`${this.constructor.name}_${this[this.constructor._key]}`),
					key, String(data[key])
				);
			}
			

			return this;
		
		} catch(error){
			// Pass any error to the calling function
			throw error;
		}
	}

	async remove(data){
		// Remove an entry from this table.

		try{
			// Remove the index key from the tables members list.
			await client.SREM(
				redisPrefix(this.constructor.name),
				this[this.constructor._key]
			);

			// Remove the entries hash values.
			let count = await client.DEL(
				redisPrefix(`${this.constructor.name}_${this[this.constructor._key]}`)
			);

			// Return the number of removed values to the caller.
			return this;

		} catch(error) {
			throw error;
		}
	};

}


module.exports = Table;