Welcome to my Documentation

INIT
Constants

const sys = require('util');
//const keyboard = require('node-key-sender');
const exec = require('child_process').exec;
const cluster = require('cluster');
const os = require('os');
const systemOS = os.platform();
const prettySize = require('prettysize');
const prettyMs = require('pretty-ms');
const ffmpeg = require('fluent-ffmpeg');
const colors = require('colors');
const fs = require('fs');
const path = require('path');
const express = require('express');
const request = require('request');
const http = require('http');
const conf = require('./lib/config.js');
const blessed = require('blessed');
var node_dropbox = require('node-dropbox-v2');
const { Client } = require('discord.js');

Events and Signals

//var eventEmitter = require('events').EventEmitter;
//var ee = new eventEmitter;
//ee.on('botConsole', botConsole);
//ee.on('botConsolePrompt', botConsolePrompt);
//Doesn't Work on Win32 (No Signals)
process.on("SIGINT", function() { 
	console.log('' ); 
	console.log('Received SIGINT, killing current command...'); 
});

FUNCTIONS
Timestamp Log

function timeStampLog() {
	var dateTime = require('node-datetime');
	var dt = dateTime.create();
	return dt.format('Y-m-d H:M:S').bold.green+'| ';
}

Timestamp Normal

function timeStamp() {
	var dateTime = require('node-datetime');
	var dt = dateTime.create();
	return dt.format('Y-m-d H:M:S');
}

Ping

function ping(host) {
	var sys = require('util');
	var exec = require('child_process').exec;
	function puts(error, stdout, stderr) { 
		console.log(stdout);
		botConsole();		
	}
	if (systemOS === "win32") {
		exec("ping -n 5 "+host, puts);
	} else {		
		exec("ping -c 5 "+host, puts);
	}
}

Git Operations

function git(argument) {
	var sys = require('util');
	var exec = require('child_process').exec;
	function puts(error, stdout, stderr) { 
		console.log(stdout);
		botConsole();		
	} 
	if(argument == 'HISTORY') {
		if (systemOS === "win32") {
			exec('git log --pretty=format:"%h - %an (%ae): %s" --shortstat  -n 3', puts);
		} else {		
			exec('git log --pretty=format:"%h - %an (%ae): %s" --shortstat  -n 3', puts);
		}
	} else if(argument == 'PULL') {
		if (systemOS === "win32") {
			exec('git stash && git pull', puts);
		} else {		
			exec('git stash && git pull', puts);
		}
	} else {
				console.log(timeStampLog()+'Usage: git history/pull'.bold.green);
				botConsole();		
	}	
}

Config Operations

function config(argument) {
	var sys = require('util');
	var exec = require('child_process').exec;
	var config = __dirname+'/config/config.json';
	var configBackup = __dirname+'/config/config.json.backup';
	function puts(error, stdout, stderr) { 
		console.log(stdout);
		botConsole();		
	}
	if(argument == 'SHOW') {
		fs.readFile(__dirname+'/config/config.json', 'utf8', function (err,data) {
			if (err) {
				console.log(timeStampLog()+err);
			}
			console.log(data);
			botConsole();		
		});
	} else if(argument == 'BACKUP') {
		fs.readFile(config, 'utf8', function (err,data) {
			if (err) {
				return console.log(timeStampLog()+err);
			}
			fs.writeFile(configBackup, data, 'utf8', function (err) {
				if (err) return console.log(timeStampLog()+err);
				console.log(timeStampLog()+
					'Backup saved to config/config.json.backup!'.bold.green);
				botConsole();		
			});
		});
	} else if(argument == 'WIPE') {
		fs.unlinkSync(__dirname+'/config/config.json', 'utf8', function (err,data) {
			if (err) {
				console.log(timeStampLog()+err);
			}
		});
		console.log(timeStampLog()+'Sucessfully wiped the config, exiting the program!'.bold.red);
		process.exit();
	} else {
				console.log(timeStampLog()+'Usage: config show/backup/wipe'.bold.green);
				botConsole();		
	}
}

Blessed Example

function doSomething() {
	var screen = blessed.screen({
		tput: true,
		smartCSR: true,
		dump: __dirname + '/logs/prompt.log',
		autoPadding: true,
		warnings: true
	});
	var prompt = blessed.prompt({
		parent: screen,
		border: 'line',
		height: 'shrink',
		width: 'half',
		top: 'center',
		left: 'center',
		label: ' {blue-fg}Prompt{/blue-fg} ',
		tags: true,
		keys: true,
		vi: true
	});
	var question = blessed.question({
		parent: screen,
		border: 'line',
		height: 'shrink',
		width: 'half',
		top: 'center',
		left: 'center',
		label: ' {blue-fg}Question{/blue-fg} ',
		tags: true,
		keys: true,
		vi: true
	});
	var msg = blessed.message({
		parent: screen,
		border: 'line',
		height: 'shrink',
		width: 'half',
		top: 'center',
		left: 'center',
		label: ' {blue-fg}Message{/blue-fg} ',
		tags: true,
		keys: true,
		hidden: true,
		vi: true
	});
	var loader = blessed.loading({
		parent: screen,
		border: 'line',
		height: 'shrink',
		width: 'half',
		top: 'center',
		left: 'center',
		label: ' {blue-fg}Loader{/blue-fg} ',
		tags: true,
		keys: true,
		hidden: true,
		vi: true
	});
	prompt.input('Question?', '', function(err, value) {
		question.ask('Question?', function(err, value) {
			msg.display('Hello world!', 3, function(err) {
				msg.display('Hello world again!', -1, function(err) {
					loader.load('Loading...');
					setTimeout(function() {
						loader.stop();
						screen.destroy();
						botConsole();		
					}, 3000);
				});
			});
		});
	});
	screen.key('q', function() {
		screen.destroy();
		botConsole();		
	});
	screen.render();
}

Prompt

function prompt(question, callback) {
	var stdin = process.stdin,
	stdout = process.stdout;
	stdin.resume();
	stdout.write(question);
	stdin.once('data', function (data) {
		callback(data.toString().trim());
	});
}

Console Prompt

function botConsolePrompt() {
	return conf.bot_nickname.toLowerCase().yellow+'@localhost'.yellow+' >>\ '.trap.bold.cyan;
}

Discord Bot Controller

function botDiscord(type,operation) {
	if(operation == "START") {
		if(type == "SELF") { 
			token = conf.discord_token_self; 
		} else if(type == "BOT") { 
			token = conf.discord_token_bot; 
		}
		client = new Client();
		client.on('ready', () => {
			//console.log(timeStampLog()+"Discord "+type+" is ready for you!");
			//ee.emit('botConsole');
		});
		client.on('message', msg => {
			fs.appendFile('logs/discord.log', msg.content+'\n', 'utf8', function(err) {
			});
		});
		client.login(token);
		var msg = "Discord "+type.toLowerCase()+" started successfully!";
		console.log(timeStampLog()+msg.green);
		botConsole();	
	} else if(operation == "STOP") {
		var msg = "Discord "+type.toLowerCase()+" stopped successfully!";
		client.destroy();
		console.log(timeStampLog()+msg.red);
		botConsole();		
	}
}

Console

function botConsole() {
	if (fs.existsSync(__dirname+'/config/config.json')) {
	prompt(timeStampLog()+botConsolePrompt(), function(botCommand) {
		var arguments = botCommand.toUpperCase().split(/(\s+)/);
		if(arguments[0] == "EXIT") {
				console.log(timeStampLog()+'Exiting back to console...');
				process.exit();
		} else if(arguments[0] == "WEB") {
			webServer(arguments[2]);
		} else if(arguments[0] == "DISCORD") {
			botDiscord(arguments[2],arguments[4]);
		} else if(arguments[0] == "DROPBOX") {
			dropboxAPI(arguments[2]);
		} else if(arguments[0] == "CONFIG") {
			config(arguments[2]);
		} else if(arguments[0] == "PING") {
			console.log(timeStampLog()+'Pinging host, please wait...');
			let host = arguments[2];
			ping(host);
		} else if(arguments[0] == "GIT") {
			console.log(timeStampLog()+'Working with repository, please wait...');
			let argument = arguments[2];
			git(argument);
		} else if (arguments[0] == "DOCS") {
			generateDocumentation(arguments[2]);
		} else if (arguments[0] == "DO") {
			doSomething();
		} else if (arguments == "" || !arguments) {
			console.log(timeStampLog()+'Need to enter a command...'.yellow);
			botConsole();		
		} else {
			var sys = require('util');
			var exec = require('child_process').exec;
			function puts(error, stdout, stderr) { 
				console.log(stdout);
				botConsole();		
			}
			if(conf.bot_shell_whitelist.indexOf(arguments[0].toLowerCase())!=-1) {
				exec(botCommand, puts);
			} else {		
				console.log(timeStampLog()+'This command is blacklisted!');	
				botConsole();		
			}
		}
	});
	}
}

Web Server

function webServer(action) {
	const web = express();
	if (action == "START") {
		const server = web.listen(conf.bot_port_web);
		web.use(express.static(path.join(__dirname, 'assets/web/public')));
		web.set('views', path.join(__dirname, 'assets/web/views'));
		web.set('view engine', 'ejs');
		web.get('/', (req, res) => res.render('pages/index', { 
			'web_title': conf.web_title,
			'web_favicon': conf.web_favicon,
			'bot_nickname': conf.bot_nickname,
			'bot_logo_long': conf.bot_logo_long,
			'bot_logo_square': conf.bot_logo_square,
			'bot_info_website': conf.bot_info_website,
			'bot_info_copyright': conf.bot_info_copyright,
			'discord_invite_link': conf.discord_invite_link,
			'theme': 'default'
		}));
		web.get('/api/'+conf.bot_api_key+'/close', (req,res) => {
			res.send('Stopping the web server...');
			server.close();
		});
		web.get('/api/'+conf.bot_api_key+'/status', (req,res) => {
			res.send('Web server IS online...');
		});
		console.log(timeStampLog()+'Web server started successfully!'.green);
		botConsole();		
	} else if(action == "STOP") {
		var webBackendClose = 
			'http:\/\/localhost:'+conf.bot_port_web+'/api/'+conf.bot_api_key+'/close';
		var webBackendStatus = 
			'http:\/\/localhost:'+conf.bot_port_web+'/api/'+conf.bot_api_key+'/status';
		request({
			url: webBackendClose
			//timeout: 500
		}, function (error,response,body) {
			console.log(timeStampLog()+'Web server stopped successfully!'.red);
			botConsole();		
		})
	} else if(action == "STATUS") {
                var webBackendStatus = 
			'http:\/\/localhost:'+conf.bot_port_web+'/api/'+conf.bot_api_key+'/status';
                request({
                        url: webBackendStatus,
                        timeout: 1000
                }, function (error,response,body) {
			if (error) { 
				console.log(timeStampLog()+'Web Server IS NOT online...'.red);
			} else {
				console.log(timeStampLog()+'Web Server IS online...'.green);
			}
			botConsole();		
                })
        }
}

Dropbox API

function dropboxAPI(operation) {
	if(operation == "ACCOUNT") {
		console.log(timeStampLog()+'Querying DropBox account information, please wait...');
		api = node_dropbox.api(conf.dropbox_token);
		api.account(function(err, res, body) {
			if(!err) {
				console.log(body);
				botConsole();
			} else {
				console.log(timeStampLog()+err);
				botConsole();
			}
		});
	}
}

Documentation Generator

function generateDocumentation(type) {
	if(type == "MARKUP") {
	console.log(timeStampLog()+'Documentation generation beginning, please wait...'.yellow);
		fs.readFile(__dirname+'/init.js', 'utf8', function (err,data) {
			if (err) {
				return console.log(timeStampLog()+err);
			}
			var result = data
				.replace(/#!\/usr\/bin\/env node/g,
					'Welcome to my Documentation')
				.replace(/\/\/ START SECTION: /g,
					'

  ')
				.replace(/\/\/ END SECTION: (.+)/g,
					'')
				.replace(/\/\/ START SUB: /g,
					'
 ')
				.replace(/\/\/ END SUB: (.+)/g,
					'')
				.replace(/\/\/ COMMENT: /g,
					'')
				.replace(/\/\* START \*\//g,
					'')
				.replace(/\/\* END \*\//g,
					'');
			fs.writeFile(__dirname+'/docs/DOCS.md', result, 'utf8', function (err) {
				if (err) { 
					return console.log(timeStampLog()+err); 
				}
			});
		});
		console.log(timeStampLog()+'Documentation (markup) generation done!'.bold.green);
	} else if(type == "HTML") {
	console.log(timeStampLog()+'Documentation generation beginning, please wait...'.yellow);
		if (fs.existsSync(__dirname+'/docs/DOCS.md')) {
			fs.readFile(__dirname+'/docs/DOCS.md', 'utf8', function (err,data) {
				if (err) {
					return console.log(timeStampLog()+err);
				}
				var result = data
					.replace(/Welcome to my Documentation/g,
						'Welcome to my Documentation')
					.replace(/
 /g,
						'
 ')
					.replace(/

 /g,
						'

 ')
					.replace(/

 /g,
						'

 ')
					.replace(/\/\/ END SUB: (.+)/g,
						'')
					.replace(/\/\/ COMMENT: /g,
						'')
					.replace(//g,
						'')
					.replace(//g,
						'');
				fs.writeFile(__dirname+'/docs/DOCS.html', result, 'utf8', function (err) {
					if (err) return console.log(timeStampLog()+err);
				});
			});	
			console.log(timeStampLog()+'Documentation (html) generation done!'.bold.green);			
		} else {
			console.log(timeStampLog()+'Must do'+' '+'docs markup'.inverse+' '+'first, then'+' '+'docs html'.inverse+'!');
		}
	}
	botConsole();		
}

RUNTIME
Initial Prompt and Console Calls the console, which everything else calls back too... kinda.

if (fs.existsSync(__dirname+'/config/config.json')) {
	botConsole();		
}