index.php

<?php

require 'config.php';
define('CREATOR', $config['creator']);

require 'libs/Telegram-PHP/src/Autoloader.php';
require 'core/Core.php';
require 'core/Module.php';
require 'core/Functions.php';
require 'core/User.php';
require 'core/Chat.php';

if($config['telegram']['id'] == 0){
	die("Please edit config.php before running.");
}

$core = new TelegramApp\Core();
// $core->addTimelog("Startup");

// Block unknown hosts
// ------------
if($config['safe_connect'] != FALSE){
	$addr = array();
	$pass = FALSE;

	if(is_array($config['safe_connect'])){ $addr = $config['safe_connect']; }
	// Add Default Telegram IP
	// Updated in https://core.telegram.org/bots/webhooks
	for($ip = 160; $ip <= 175; $ip++){
        $addr[] = "149.154.${ip}.";
	}
	$addr[] = "91.108.4.";
	$addr[] = "91.108.5.";
	$addr[] = "91.108.6.";
	$addr[] = "91.108.7.";

	foreach($addr as $a){
		if(strpos($_SERVER['REMOTE_ADDR'], $a) !== FALSE){
			$pass = TRUE; break;
		}
	}

	$headers = apache_request_headers();
	// Need this headers
	$check = [
		"Content-Type" => "application/json",
		"Connection" => "keep-alive"
	];

	if($pass){
		foreach($check as $h => $v){
			$get = FALSE;
			$h = strtolower($h);
			// $v = strtolower($v);
			foreach($headers as $ah => $av){
				if($h == trim(strtolower($ah)) and $v == $av){
					$get = TRUE;
					break;
				}
			}
			if(!$get){
				$pass = FALSE;
				break;
			}
		}
	}

	if(!$pass){
		error_log("Access denied from " .$_SERVER['REMOTE_ADDR'] ." to bot " .$config['telegram']['username']);
		http_response_code(401);
		die();
	}
}

$bot = new Telegram\Bot($config['telegram']);
$tg = new Telegram\Receiver($bot);
$core->setTelegram($tg);

if($config['ignore_older_than'] > 5 and $tg->date(TRUE) >= $config['ignore_older_than']){
	die();
}

if(!$config['convert_emoji']){ $tg->send->convert_emoji = FALSE; }

// Log received data
// ------------
if($config['log']){
	$log = __DIR__ ."/log.txt";
	$set = (!file_exists($log));
	$fp = fopen($log, "a");
	fwrite($fp, $tg->dump(TRUE) ."\n");
	fclose($fp);
	if($set){
		chmod($log, 0220);
		exec("chattr +a $log");
	}
	unset($log, $set, $fp);
}

// Detect and remove Telegram lock
// ------------
if($config['repeat_updateid'] > 0){
	$updates = array();
	if(file_exists("updateid.txt")){
		$updates = file_get_contents("updateid.txt");
		$updates = explode("\n", $updates);
	}
	array_unshift($updates, $tg->id); // Add element to beginning
	if(count($updates) > $config['repeat_updateid']){
		array_pop($updates); // Remove last element
	}
	file_put_contents("updateid.txt", implode("\n", $updates));
	$c = 0;
	foreach($updates as $u){
		if($u == $updates[0]){ $c++; }
	}
	// Skip message - 200 OK
	if($c >= $config['repeat_updateid']){ die(); }
	unset($updates, $c);
}

// Blacklist user
// ------------
if(file_exists("blacklist.txt") && is_readable("blacklist.txt")){
	$users = file_get_contents("blacklist.txt");
	$users = explode("\n", $users);
	foreach($users as $u){
		if(empty($u) or substr($u, 0, 1) == "#"){ continue; }
		if(
			(is_numeric($u) && $tg->chat->id == $u) or
			(is_string($u) && isset($tg->chat->username) && $tg->chat->username == $u)
		){
			die(); // Exit bot.
		}
	}
}

// Load DB class
// ------------
if($config['mysql']['enable']){
	require 'libs/PHP-MySQLi-Database-Class/MysqliDb.php';
	// require 'libs/PHP-MySQLi-Database-Class/dbObject.php';

	$mysql = new MysqliDb($config['mysql']);
	$core->setDB($mysql);
}

// Load User model
// ------------
if(file_exists('app/User.php')){
	$core->load('User');
	$User = new User($tg->user);
	$User->setVar('telegram', $tg);
	$core->addInherit('user', $User);
}

// Load Chat model
// ------------
if(file_exists('app/Chat.php')){
	$core->load('Chat');
	$Chat = new Chat($tg->chat);
	$Chat->setVar('telegram', $tg);
	$core->addInherit('chat', $Chat);
}

// Force add MySQL
// ------------
if($config['mysql']['enable']){
	if($core->is_loaded('User')){ $User->setDB($mysql); }
	if($core->is_loaded('Chat')){ $Chat->setDB($mysql); }
}

// Add tracking functions
// ------------
if($config['tracking'] !== FALSE){
	require 'core/Tracking.php';
	$track = ['name' => key($config['tracking']), 'token' => current($config['tracking'])];
	if(!file_exists('core/Tracking/' .$track['name'] .'.php')){
		die('Tracking core does not exist.');
	}
	require 'core/Tracking/' .$track['name'] .'.php';

	$class = 'TelegramApp\\Tracking\\' .$track['name'];
	$Tracking = new $class($track['token']);
	$Tracking->setTelegram($tg);
	$core->addInherit('tracking', $Tracking);
	unset($track, $class);
}

// Add cache (currently Memcached)
// ------------
if($config['cache_memcached'] !== FALSE){
	$Cache = new Memcached("TGAPP" .$config['telegram']['id']);
	if(!count($Cache->getServerList())){
		$Cache->addServers($config['cache_memcached']);
	}
	$core->addInherit('cache', $Cache);
}

// Add locale / string Functions
// -----------
if(is_dir("locale")){
	require 'core/Strings.php';
	$lang = $tg->language;
	if(empty($lang)){ $lang = $config['language']; }

	$Strings = new TelegramApp\Strings($lang);
	$Strings->load();
	$core->addInherit('strings', $Strings);
}

// Load modules
foreach(scandir("app") as $file){
	if(is_readable("app/$file") && substr($file, -4) == ".php"){
		$name = substr($file, 0, -4);
		if(in_array($name, ["Main", "User", "Chat"])){ continue; }
		$core->load($name);
	}
}

$core->addTimelog("Running");
// Run bot
$core->load('Main', TRUE);

$core->addTimelog("Finished");

if(isset($config['log_time']) and $config['log_time']){
	$log = __DIR__ ."/logtime.txt";
	$set = (!file_exists($log));

	$times = $core->getTimelogs();
	$start = array_shift($times);
	$end = array_pop($times);
	$time = floor(($end[0] - $start[0]) * 1000);
	$str = floor($start[0]) ." " .$tg->id ." $time\n";

	$fp = fopen($log, "a");
	fwrite($fp, $str);
	fclose($fp);
}

?>