tools.js

process.env["NTBA_FIX_319"] = 1;
process.env["NTBA_FIX_350"] = 1;

process.on('uncaughtException', function (error) {
	console.log("\x1b[31m", "Exception: ", error, "\x1b[0m");
});

process.on('unhandledRejection', function (error, p) {
	console.log("\x1b[31m","Error: ", error.message, "\x1b[0m");
});

var config = require('./config.js');
var TelegramBot = require('node-telegram-bot-api');
var mysql = require('mysql');
var mysql_sync = require('sync-mysql');

var express = require('express');
var http = require('http');
var https = require('https');
var fs = require('fs');
var bodyParser = require('body-parser');
var request = require('request');

console.log('Connecting bot...');

var token = config.toolstoken;
var bot = new TelegramBot(token);
var app = express();

var path = "/tools/bot" + token;
var port = 25011;

bot.setWebHook('https://fenixweb.net:8443' + path);
app.listen(port);

app.use(bodyParser.json());
app.post(path, function(req, res) {
	bot.processUpdate(req.body);
	res.sendStatus(200);
});

console.log('Starting bot...');

var connection = mysql.createConnection({
	host: config.dbhost,
	user: config.dbuser_pinner,
	password: config.dbpassword_pinner,
	database: config.dbdatabase_pinner
});
connection.connect();

var connection_sync = new mysql_sync({
	host: config.dbhost,
	user: config.dbuser_pinner,
	password: config.dbpassword_pinner,
	database: config.dbdatabase_pinner
});

setInterval(function () {
	connection.query('SELECT 1');
	connection_sync.query('SELECT 1');
}, 60000);

process.on('SIGINT', function() {
	console.log("Shutting down bot...");
	connection.end();
	process.exit();
});

process.on('SIGTERM', function() {
	console.log("Shutting down bot...");
	connection.end();
	process.exit();
});

var html = {
	parse_mode: "HTML"
};

bot.onText(/^\/start/i, function (message) {
	bot.sendMessage(message.chat.id, "Questo è il bot personale di @fenix45!\n\nComandi disponibili:\n/rape");
});

bot.onText(/^\/rape/i, function (message) {
	var options = {
		'method': 'POST',
		'url': 'https://api.turnip.exchange/islands/',
		'headers': {
			'Content-Type': 'application/json',
			'User-Agent': 'Fenix Tools 2'
		},
		body: JSON.stringify({
			"islander": "neither", 
			"category": "turnips", 
			"fee": 0
		})
	};
	request(options, function (error, response) { 
		if (error) throw new Error(error);
		var json = JSON.parse(response.body);
		var islands = json.islands;
		var maxValue = 0;
		var maxIsland = null;
		for (var i = 0; i < islands.length; i++) {
			if ((islands[i].turnipPrice > maxValue) && 
				(islands[i].queued.split("/")[0] < islands[i].queued.split("/")[1]) &&
			   	(islands[i].patreonOnly == 0)) {
				maxValue = islands[i].turnipPrice;
				maxIsland = islands[i];
			}
		}
		
		if (maxIsland != null) {
			bot.sendMessage(message.chat.id, "<b>Nome</b>: " + maxIsland.name + "\n" +
						   					"<b>Prezzo Rape</b>: " + maxIsland.turnipPrice + "\n" +
											"<b>Descrizione</b>: " + maxIsland.description.replace("<", "").replace(">", "") + "\n" +
											"<b>Coda</b>: " + maxIsland.queued + "\n" +
											"<a href='https://turnip.exchange/island/" + maxIsland.turnipCode + "'>Accedi all'isola</a>", html);
			console.log(maxIsland);
		}
	});
});

// Functions

function getNow(lang, obj) {
	var d = new Date();
	obj = typeof obj !== 'undefined' ? obj : false;
	var datetime;
	if (lang == "it") {
		datetime = addZero(d.getDate()) + "/" + addZero(d.getMonth() + 1) + "/" + d.getFullYear() + " " + addZero(d.getHours()) + ':' + addZero(d.getMinutes()) + ':' + addZero(d.getSeconds());
	} else if (lang == "en") {
		datetime = d.getFullYear() + "-" + addZero(d.getMonth() + 1) + "-" + addZero(d.getDate()) + " " + addZero(d.getHours()) + ':' + addZero(d.getMinutes()) + ':' + addZero(d.getSeconds());
	} else
		datetime = "Error";
	if (obj == true)
		datetime = new Date(datetime);
	return datetime;
}

function toDate(lang, date) {
	var d = new Date(date);
	if (typeof date == "object")
		d = date;
	var datetime = "";
	if (lang == "it") {
		datetime = addZero(d.getMonth() + 1) + "/" + addZero(d.getDate()) + "/" + d.getFullYear() + " " + addZero(d.getHours()) + ':' + addZero(d.getMinutes()) + ':' + addZero(d.getSeconds());
	} else if (lang == "en") {
		datetime = d.getFullYear() + "-" + addZero(d.getMonth() + 1) + "-" + addZero(d.getDate()) + " " + addZero(d.getHours()) + ':' + addZero(d.getMinutes()) + ':' + addZero(d.getSeconds());
	} else
		datetime = "Error";
	return datetime;
}

function formatNumber(num) {
	return ("" + num).replace(/(\d)(?=(\d\d\d)+(?!\d))/g, function ($1) {
		return $1 + "."
	});
}

function addZero(i) {
	if (i < 10)
		i = "0" + i;
	return i;
}