@dynacom/blaze/lib/blaze.js

const chokidar = require('chokidar');
const mime = require('mime-types');
const path = require('path');
const fs = require('fs-extra');
const { spawn } = require('child_process');
const { promisify } = require('util');
const pidusage = require('pidusage');
const selfupdate = require('selfupdate');
const package = require('../package.json');
const server = require('./server.js');
const Domain = require('./domain.js');
const Plugin = require('./plugins.js');
const Parse = require('./parse.js');

const default_modules = [
	{
		"vars": [
			"fs",
			"filesystem"
		],
		"context": true,
		"path": "fs"
	},
	{
		"context": true,
		"vars": [
			"path"
		],
		"path": "path"
	},
	{
		"context": true,
		"vars": [
			"include",
			"require"
		],
		"path": "blaze/include.js"
	}
];

const default_config = {
	"http": {
		"ports": [
			80
		]
	},
	"https": {
		"ports": [
			443
		]
	},
	"orders": [],
	"plugins": [],
	"logger": {
		"maxLogSize": 2000000,
		"logInterval": 86400000
	},
	"form": {
		"maxFileSize": 2147483648
	},
	"label": "Blaze Web Server",
	"contact": "",
	"root": "./www",
	"logs": "./logs"
}

let WATCHES = [];

let processPath = path.join(__dirname, '/instances.json');

let instancesFile = fs.existsSync(processPath) ? require('./instances.json') : [];

module.exports.reload = () => {
	Object.keys(require.cache).forEach(key => { delete require.cache[key] });
}

module.exports.start = async installDir => {
	process.env.BLAZE_LIBRARY = __dirname;
	process.env.BLAZE_INSTANCE = installDir;

	let config = await fs.readJson(path.join(installDir, 'config.json'));

	Domain.compile(installDir);
	Plugin.compile(installDir);

	WATCHES.push(chokidar.watch(path.join(installDir, 'domains'), {
		persistent: true
	})
		.on('all', (event, path) => {
			Domain.compile(installDir);
		}));

	// WATCHES.push(chokidar.watch(path.join(installDir, 'plugins'), {
	// 	persistent: true
	// })
	// 	.on('all', (event, path) => {
	// 		Plugin.compile(installDir);
	// 	}));

	let instance = new server(config);
	instance.listen();
}

module.exports.version = async () => {
	console.log('v' + package.version);
}

module.exports.uninstall = async installDir => {
	WATCHES.forEach(WATCH => {
		WATCH.close();
	});

	await fs.remove(installDir);
}

module.exports.install = async installDir => {
	let validDir = true;
	if (fs.existsSync(installDir)) {
		let files = fs.readdirSync(installDir);
		if (files.length) {
			console.log('Install directory must be empty');
			validDir = false;
		}
	}

	if (validDir) {
		await fs.ensureDir(installDir)
			.then(() => {
				let configPath = path.join(installDir, 'config.json');
				let domainsPath = path.join(installDir, 'domains');
				let certsPath = path.join(installDir, 'certs');
				let wwwPath = path.join(installDir, 'www');
				let logsPath = path.join(installDir, 'logs');
				let pluginsPath = path.join(installDir, 'plugins');
				let modulesPath = path.join(installDir, 'modules');
				let modulesConfigPath = path.join(modulesPath, 'modules.json');

				return Promise.all([
					fs.writeJSON(configPath, default_config),
					fs.mkdir(domainsPath),
					fs.mkdir(wwwPath),
					fs.mkdir(logsPath),
					fs.mkdir(pluginsPath),
					fs.mkdir(modulesPath).then(() => {
						return fs.writeJSON(modulesConfigPath, default_modules)
					}),
					fs.mkdir(certsPath)
				]);
			});
	} else {
		return null;
	}
}

module.exports.help = (...commands) => {
	console.log('blaze web server v' + package.version + '\n');
	console.log('Commands:');
	let strLength = 4 + commands.reduce(function (longestCommand, schema) {
		return Math.max(longestCommand, schema.command.length);
	}, 0);

	commands.forEach(
		schema => {
			console.log('  blaze ' + (schema.command.padEnd(strLength)) + schema.help);
		}
	);
}

module.exports.parse = async (installDir, parser, context) => {
	if (parser) {
		Parse[parser](context);
	} else {
		Parse(context);
	}
}