@dynacom/blaze/lib/plugins.js

const fs = require('fs-extra');
const path = require('path');

let plugins = [];

function mapOrder(array, order, key) {
	array.sort((a, b) => {
		let A = a[key], B = b[key];

		if (!order.includes(A)) return 1;
		if (!order.includes(B)) return -1;

		return order.indexOf(A) > order.indexOf(B);
	});

	return array;
}

module.exports = class plugin {
	static async compile(installDir) {
		let config = await fs.readJson(path.join(process.env.BLAZE_INSTANCE, 'config.json'));
		let files = (await fs.readdir(path.join(installDir, 'plugins'))).filter(fileName => fileName.endsWith('.js'));

		let compiledPlugins = [];

		for (let fileIndex = 0; fileIndex < files.length; fileIndex++) {
			const fileName = files[fileIndex];
			try {
				compiledPlugins.push({
					"id": fileName.replace('.js', ''),
					"name": fileName,
					"module": require(path.join(installDir, 'plugins', fileName))
				});
			} catch (error) {
				throw ('Failed to load plugin ' + fileName);
			}
		}
		plugins = mapOrder(compiledPlugins, config.plugins, 'id');
	}

	static async fire($_CONTEXT, event) {
		for (let pluginIndex = 0; pluginIndex < plugins.length; pluginIndex++) {
			const plugin = plugins[pluginIndex];
			if (plugin.module.hasOwnProperty(event)) {
				if ('function' === typeof plugin.module[event]) {
					await plugin.module[event]($_CONTEXT);
				}
			}
		}
	}

	static get BEFORE_REQUEST() {
		return 'beforeRequest';
	}

	static get AFTER_REQUEST() {
		return 'afterRequest';
	}

	static get BEFORE_TIMEOUT() {
		return 'beforeTimeout';
	}

	static get AFTER_TIMEOUT() {
		return 'afterTimeout';
	}

	static get BEFORE_ERROR() {
		return 'beforeError';
	}

	static get AFTER_ERROR() {
		return 'afterError';
	}
}