app.js

"use strict";
const tg = require('node-telegram-bot-api');
let util = require('util');
let http = require('http');
let request = require('request');
var fs = require('fs');
var process = require('process');

////////////////////////////////
//----------------------------//
// Copyright (c) 2017 NullDev //
//----------------------------//
////////////////////////////////

process.on('uncaughtException', function(err) { console.error((err && err.stack) ? err.stack : err); });
console.log(
	'\n\n\n'                          +
	'+-+-+-+-+-+-+-+-+-+-+-+-+-+-+\n' +
	'      INITIALIZING BOT...    \n' +
	'+-+-+-+-+-+-+-+-+-+-+-+-+-+-+\n'
);
var _s = "\n-----------------------------------------";
require.extensions['.json'] = function (module, filename) { module.exports = fs.readFileSync(filename, 'utf8'); };
var jsondata = require('./config.json'),
	cfg      = JSON.parse(jsondata),
	denylist = cfg.denylist,
	token    = cfg.bot.telegram_token,
	nltoken  = cfg.bot.nulldev_token,
	_n       = cfg.bot.botname,
	rooturl  = cfg.bot.root,
	typo     = cfg.bot.typo_percentage,
	typodel  = cfg.bot.typo_response_delay,
	isDev    = cfg.dev.devmode,
	devs     = String.prototype.toLowerCase.apply(cfg.dev.devs).split(",");
//var rooturl = "https://api.nulldev.org" <-- In config.json 
console.log('\nLOADED JSON DATA:\n' + jsondata);
const bot = new tg(token, { polling: true });
console.log(
	'\n#-#-#-#-#-#-#-#-#-#-#'          +
	'\n#-------------------#'          +
	'\n# AIKIN BOT STARTED #'          +
	'\n#-------------------#'          +
	'\n#-#-#-#-#-#-#-#-#-#-#\n\n'      +
	'-- Copyright (c) 2017 NullDev --' +
	'\n\nListening...'
);

function replaceRandom(str){
	var amount = 1;
    for(var i = 0; i < amount; i++)    {
        var max = str.length - 1;
        var pos = Math.round(Math.random() * max);
        str = str.slice(0, pos) + str.slice(pos + 1);
    }
    return str;
}

function aikin(_in, id, uid, debug, un){
	var uname = (isset(un) ? un : "Unknown");

	var options = {
		uri : rooturl + '/aikin?in=' + encodeURI(_in) + '&token=' +encodeURI(nltoken) + '&userid=' + encodeURI(uid) + "&username=" + encodeURI(uname),
		method : 'GET'
	};
	request(options, function(error, response, body){
		if (error) {
			bot.sendMessage(id, "err");
			console.log(error);
		}
		else {
			console.log((debug ? "" : "\n") + "AIKIN: Got callback: \n" + body);
			var typoLikely = typo / 100;
			var ansParsed = JSON.parse(body);
			var d = Math.random();
			var hasTypo = ((d < typoLikely) ? true : false);
			if (!debug){
				var _r = ansParsed.answer;
				if (!hasTypo) bot.sendMessage(id, _r);
				else {
					var words = _r.split(" ");
					var word = null;
					
					do { word  = words[Math.floor(Math.random() * words.length)]; }
					while(word != null && !isNaN(word) && /^[a-zA-Z]+$/.test(word) && words.length > 1);

					var newword = replaceRandom(word);
					var newmsg  = _r.replace(word, newword);

					bot.sendMessage(id, newmsg);

					setTimeout(function(){ bot.sendMessage(id, "*" + word); }, typodel);
				}
				console.log('\nAIKIN REPLY: ' + _r);
			}
			else {
				var _r = "Answer: \""           + ansParsed.answer + "\"" +
						 "\nConfidence: "       + ansParsed.confidence + 
						 "\nInteractions: "     + ansParsed.interaction_count + 
						 "\nHas Typo: "         + hasTypo +
						 "\nCalculation Time: " + ansParsed.calculation_time + "MS" +
						 "\nResponse Time: "    + ansParsed.response_time + "MS" +
						 "\nRandom Number: "    + ansParsed.random_integer;
				bot.sendMessage(id, _r, { reply_to_message_id: id.message_id });
				console.log('\nAIKIN REPLY: ' + _r);
			}
		}
	});
}

function resetAikin(hardreset, uid, callback){
	var getInteractions = {
		uri : rooturl + '/aikin?in=null&token=' + nltoken + '&userid=' + uid,
		method : 'GET'
	};
	var options = {
		uri : rooturl + '/aikin?in=null&reset=1&token=' + nltoken + '&userid=' + uid,
		method : 'GET'
	};
	if (hardreset) {
		request(getInteractions, function(error, response, body){
			var resetParsed = JSON.parse(body);
			var interactions = resetParsed.interaction_count - 1;
			request(options, function(error, response, body){
				console.log("AIKIN: Got callback: \n" + body);
				console.log('\nAIKIN: -- Cache Clear --');
				callback(interactions);
			});
		});
	}
}

function desc(_in, id){
	var options = {
		uri : rooturl + '/aikin?pic=' + encodeURI(_in) + '&token=' + nltoken,
		method : 'GET'
	};
	request(options, function(error, response, body){
		if (error) {
			bot.sendMessage(id, "err");
			console.log(error);
		}
		else {
			console.log("\nAIKIN: Got callback: \n" + body);
			var evalParsed = JSON.parse(body);
			if (evalParsed.error == 1){
				var _r = "Error: This image appears to be invalid!";
				bot.sendMessage(id, _r);
				console.log('\nAIKIN REPLY: ' + _r);
			}
			else {
				var _r = "I am " + evalParsed.confidence_percent + " sure that it\'s " + evalParsed.eval;
				bot.sendMessage(id, _r);
				console.log('\nAIKIN REPLY: ' + _r);
			}
		}
	});
}

function isURL(str) {
	var pattern = new RegExp(
		'^(https?:\\/\\/)?((([a-z\\d]([a-z\\d-]*[a-z\\d])*)\\.)+[a-z]{2,}|' + 
		'((\\d{1,3}\\.){3}\\d{1,3}))(\\:\\d+)?(\\/[-a-z\\d%_.~+&:]*)*' + 
		'(\\?[;&a-z\\d%_.,~+&:=-]*)?(\\#[-a-z\\d_]*)?$','i'
	);
	return pattern.test(str);
}

function evalEmo(_in, id){
	var options = {
		uri : rooturl + '/emo?text=' + encodeURI(_in),
		method : 'GET'
	};
	request(options, function(error, response, body){
		if (error) {
			bot.sendMessage(id, "err");
			console.log(error);
		}
		else {
			console.log("AIKIN: Got callback: " + body);
			var emoParsed = JSON.parse(body);
			var _r = "Emotion Tone: " + emoParsed.emotion_tone + 
					 "\nProbability (Value): " + emoParsed.probability_value + 
					 "\nProbability (in %): " + emoParsed.probability_percent;
			bot.sendMessage(id, _r);
			console.log('\nAIKIN REPLY: ' + _r);
		}
	});
}

function isset(_var) { return ((_var && _var != null && _var != "" ) ? true : false); }
function isaDev(_from, _id) { return ((devs.indexOf(_from.toString().toLowerCase()) > -1 || devs.indexOf(_id.toString()) > -1) ? true : false); }
function isDenied(_from, _id) { return ((denylist.indexOf(_from.toString().toLowerCase()) > -1 || denylist.indexOf(_id.toString().toLowerCase()) > -1) ? true : false); }

function replStr(s, words, replacement){ 
	var re = new RegExp( '\\b' + words.join('|') + '\\b','gi');
	return s.replace(re, replacement);
}

bot.on('message', (msg) => {
	var txt   = msg.text;
	var from  = msg.from.username;
	var frID  = msg.from.id;

	//Username could be non-existant
	if (typeof from === 'undefined' || !from || from == null) from = frID;
	var name  = msg.from.first_name;
	//Just to be save
	if (typeof name === 'undefined' || !name || name == null) name = msg.from.first_name;
	//If picture
	var _pic  = msg.photo;
	if (typeof _pic !== 'undefined' && _pic != null) _pic = msg.photo[0].file_id;
	const _id = msg.chat.id;

	console.log(_s);
	if (typeof txt !== 'undefined' && txt != null) console.log('\nUSER ' +  from + ' MADE CHAT MESSAGE: ' + txt + "\n");
	if (typeof txt === 'undefined' || txt == null) console.log('\nUSER ' +  from + ' MADE CHAT PICTURE: ' + _pic + "\n");
	console.log(JSON.stringify(msg));
	if (isDev == 1 && !isaDev(from, frID) && txt.toLowerCase() != "!-- whoami"){
		//bot.sendMessage(_id, "ID: " + frID + "\nName: " + name + "\nUser: " + from + "\nChatID: " + _id);
		bot.sendMessage(_id, 
			"Sorry, " + name + 
			"... I am currently in maintenance mode! That normally means that my developer Chris is fixing bugs or programming features. " +
			"So please check back later :)\n\nYou can contact the developer for more information:\n\n@NullPing"
		);
		console.log(_s);
		console.log('\nUSER ' + from + ' GOT DENIED. RESON: Maintenance Mode\n');
		console.log(from.toString().toLowerCase() + " != " + devs.toString());
	}
	else if (isDenied(from, frID)){
		bot.sendMessage(_id, 
			"Sorry, " + name + 
			"... You got denied from using this bot. \n\nIf you think this is a mistake, please" +
			" contact the developer:\n\n@NullPing"
		);
		console.log(_s);
		console.log('\nUSER ' + from + ' GOT DENIED. RESON: Banned\n');
	}
	else if (txt.toLowerCase() == "/start"){
		var disUser = (isset(msg.from.username) ? msg.from.username : msg.from.first_name);
		console.log('\nUSER ' + disUser + ' STARTED FIRST TIME\n');
		var craftedMsg = "Hii " + disUser + "!";
		bot.sendMessage(_id, craftedMsg + "\n\n");
		console.log('AIKIN REPLY: ' + craftedMsg);
	}
	else if (typeof _pic !== 'undefined' && _pic != null){
		console.log('\nUSER ' + from + ' SENT PICTURE');
		var options = {
			uri: "https:\/\/api.telegram.org\/bot" + token + "\/getFile?file_id=" + _pic,
			method: 'POST',
			headers: { 'Content-Type': 'application/json' }
		};
		try{
			request(options, function(error, response, body){
				var jsonraw = JSON.parse(body), _p = jsonraw.result.file_path;
				console.log('\nGOT PATH: ' + _p);
				var uri = "https:\/\/api.telegram.org\/file\/bot" + token + "\/" + _p;
				console.log('GOT URI: ' + uri);
				desc(uri, _id);
			});
		}
		catch(err){ return; }
	}
	else if (txt.indexOf('!-- ') === 0){
		var cmd = txt.slice('!-- '.length);
		console.log('\nUSER ' + from + ' PERFORMED COMMAND: ' + cmd + '\n');
		if (cmd.toLowerCase() == "status") {
			bot.sendMessage(_id, 
				"AIKIN Health Status: " +
				"\n--- Telegram API: Online" +
				"\n--- In Devmode: " + ((isDev == 1) ? "Yes" : "No") +
				"\n--- Main Developer: @NullPing" +
				"\n--- Users marked as Devs: " + devs.toString()
				);
		}
		else if (cmd.toLowerCase() == "help") {
			var _r = "AIKIN: Commands:\n\n !-- status\n !-- git\n !-- debug\n !-- ping\n !-- clearcache\n !-- emo\n !-- banner\n !-- whoami\n !-- pic\n !-- help";
			bot.sendMessage(_id, _r);
			console.log('AIKIN REPLY: ' + _r + "\n");
		}
		else if (cmd.toLowerCase() == "clearcache") { 
			if (isaDev(from, frID)){ resetAikin(true, frID, function(x){ bot.sendMessage(_id, "AIKIN: Cache Cleared.\nTotal Interactions before clear: " + x); }); }
			else bot.sendMessage(_id, "AIKIN: Insufficient permissions...");
		}
		else if (cmd.toLowerCase() == "git") {
			var _r = "The bot (client) is open source! :)\nGrab the code here:\n\nhttps://github.com/NullDev/Telegram-AI";
			bot.sendMessage(_id, _r);
			console.log('AIKIN REPLY: ' + _r + "\n");
		}
		else if (cmd.toLowerCase() == "ping") {
			var startTime = new Date();
			var _r = "Pong!";
			bot.sendMessage(_id, _r);
			console.log('\nAIKIN REPLY: ' + _r);
			var diff = new Date() - startTime;
			var _r2 = "(Took " + diff + "MS)";
			bot.sendMessage(_id, _r2);
			console.log('AIKIN REPLY: ' + _r2 + "\n");
		}
		else if (cmd.toLowerCase().indexOf("emo") === 0) {
			var _txt = cmd.slice('emo '.length);
			if (_txt.replace(/\s/gi, "") == ""){
				var _r = "AIKIN: Usage: !-- emo your text";
				bot.sendMessage(_id, _r);
				console.log('\nAIKIN REPLY: ' + _r + "\n");
			}
			else evalEmo(_txt, _id);
		}
		else if (cmd.toLowerCase().indexOf("debug") === 0) {
			var _txt = cmd.slice('debug '.length);
			if (_txt.replace(/\s/gi, "") == ""){
				var _r = "AIKIN: Usage: !-- debug your text";
				bot.sendMessage(_id, _r);
				console.log('\nAIKIN REPLY: ' + _r + "\n");
			}
			else aikin(_txt, _id, frID, true, (isset(msg.from.username) ? msg.from.username : msg.from.first_name));
		}
		else if (cmd.toLowerCase() == "whoami") {
			bot.sendMessage(_id, 
				"First Name: "      + msg.chat.first_name    + 
				"\nUser name: "     + from                   +
				"\nLanguage-Code: " + msg.from.language_code +
				"\nID: "            + msg.from.id            +
				"\nIs Dev: "        + (isaDev(from, frID) ? "Yes" : "No")
			);
		}
		else if (cmd.toLowerCase().indexOf("pic") === 0) {
			var _url = cmd.slice('pic '.length);
			if (_url.replace(/\s/gi, "") == ""){
				var _r = "AIKIN: Usage: !-- pic link";
				bot.sendMessage(_id, _r);
				console.log('\nAIKIN REPLY: ' + _r + "\n");
			}
			else if (isURL(_url)) desc(_url, _id);
			else {
				var _r = "AIKIN: This URL seems to be invalid";
				bot.sendMessage(_id, _r);
				console.log('\nAIKIN REPLY: ' + _r + "\n");
			}
		}
		else if (cmd.toLowerCase() == "banner") { bot.sendPhoto(_id, "https://nulldev.org/img/banner.jpg"); }
		else {
			var _r = "AIKIN: Unknown command. Please use !-- help for a list of commands.";
			bot.sendMessage(_id, _r);
			console.log('AIKIN REPLY: ' + _r + "\n");
		}
	}

	//Developer Info (Without Database in case offline)
	else if (/^((who is|whos|who's) (ur|your) (dev|developer|coder|programmer|owner|creator|maker))+(.*)$/i.test(txt) ||
		 /^((who|who did|whod|who'd|who is) (made|created|programmed|coded|programed|developed|) (u|you|aikin))+(.*)$/i.test(txt)){
		var d1_f = [
			"His username is @NullPing",
			"@NullPing is his username",
			"@NullPing would be his username!",
			"You can contact him here: @NullPing",
			"If you wanna contact him, his username is @NullPing",
			"If you wanna message him, his username is @NullPing",
			"If you want to contact him, his username is @NullPing",
			"If you wanna contact him, his username is @NullPing",
			"His username would be @NullPing"
		],  
		d1 = d1_f[Math.floor(Math.random() * d1_f.length)],
		ansmsg = [
			"Chris. " + d1,
			"Chris (@NullPing)",
			"Chris! " + d1,
			"Chris! (@NullPing)",
			"Chris is my dev! " + d1,
			"Chris is my dev! (@NullPing)",
			"Chris-Sensai, " + d1,
			"Chris-Sensai (@NullPing)",
			"My developer is chris and " + d1,
			"My developer is chris. " + d1,
			"My developer is chris. (@NullPing)",
			"Chris is my developer! " + d1,
			"Chris is my developer! (@NullPing)",
			"It's chris! " + d1,
			"It's chris! (@NullPing)",
			"Chris is my creator. " + d1,
			"Chris is my creator. (@NullPing)",
			"My creator is chris! " + d1,
			"My creator is chris! (@NullPing)"
		],
		ans = ansmsg[Math.floor(Math.random() * ansmsg.length)];
		bot.sendMessage(_id, ans);
		console.log(_s);
		console.log('\nAIKIN REPLY: ' + ans + "\n");
	}
	else aikin(txt, _id, frID, false, (isset(msg.from.username) ? msg.from.username : msg.from.first_name));
});