clean-hook.php

<?php

use WinTenDev\Utils\Arrays;
use WinTenDev\Utils\Inputs;

include_once './vendor/autoload.php';
//include_once './Resources/Config/bot.php';
//include_once './Resources/Config/config.php';

$bots = include __DIR__ . '/Resources/Config/bots.php';
$input = Inputs::get('id');
$filtered = Arrays::arrayFilter($bots, ['id' => $input]);
$bot_token = $filtered[0]['bot_token'];
$bot_name = $filtered[0]['bot_name'];

Arrays::toJson([
	'bot_name' => $filtered[0],
]);

define('API_URL', 'https://api.telegram.org/bot' . $bot_token . '/');

function apiRequestWebhook($method, $parameters)
{
    if (!is_string($method)) {
        error_log("Method name must be a string\n");
        return false;
    }

    if (!$parameters) {
        $parameters = array();
    } else if (!is_array($parameters)) {
        error_log("Parameters must be an array\n");
        return false;
    }

    $parameters['method'] = $method;

    header('Content-Type: application/json');
    echo json_encode($parameters);
    return true;
}

function exec_curl_request($handle)
{
    $response = curl_exec($handle);

    if ($response === false) {
        $errno = curl_errno($handle);
        $error = curl_error($handle);
        error_log("Curl returned error $errno: $error\n");
        curl_close($handle);
        return false;
    }

    $http_code = intval(curl_getinfo($handle, CURLINFO_HTTP_CODE));
    curl_close($handle);

    if ($http_code >= 500) {
        // do not wat to DDOS server if something goes wrong
        sleep(10);
        return false;
    } else if ($http_code != 200) {
        $response = json_decode($response, true);
        error_log("Proses has failed with error {$response['error_code']}: {$response['description']}\n");
        if ($http_code == 401) {
            throw new Exception('Invalid access token provided');
        }
        return false;
    } else {
        $response = json_decode($response, true);
        if (isset($response['description'])) {
            error_log("Proses was successful: {$response['description']}\n");
        }
        $response = $response['result'];
    }

    return $response;
}

function apiRequest($method, $parameters)
{
    if (!is_string($method)) {
        error_log("Method name must be a string\n");
        return false;
    }

    if (!$parameters) {
        $parameters = array();
    } else if (!is_array($parameters)) {
        error_log("Parameters must be an array\n");
        return false;
    }

    foreach ($parameters as $key => &$val) {
        // encoding to JSON array parameters, for example reply_markup
        if (!is_numeric($val) && !is_string($val)) {
            $val = json_encode($val);
        }
    }
    $url = API_URL . $method . '?' . http_build_query($parameters);

    $handle = curl_init($url);
    curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
    curl_setopt($handle, CURLOPT_TIMEOUT, 60);

    return exec_curl_request($handle);
}

function apiRequestJson($method, $parameters)
{
    if (!is_string($method)) {
        error_log("Method name must be a string\n");
        return false;
    }

    if (!$parameters) {
        $parameters = array();
    } else if (!is_array($parameters)) {
        error_log("Parameters must be an array\n");
        return false;
    }

    $parameters['method'] = $method;

    $handle = curl_init(API_URL);
    curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
    curl_setopt($handle, CURLOPT_TIMEOUT, 60);
    curl_setopt($handle, CURLOPT_POST, true);
    curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($parameters));
    curl_setopt($handle, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));

    return exec_curl_request($handle);
}

function processMessage($message)
{
    // process incoming message
    $message_id = $message['message_id'];
    $chat_id = $message['chat']['id'];
    if (isset($message['text'])) {
        // incoming text message
        $text = $message['text'];

        if (strpos($text, '/ping') === 0) {
	        apiRequestJson('sendMessage',
		        array('chat_id' => $chat_id, 'text' => 'Hello', 'reply_markup' =>
			        array(
                'keyboard' => array(array('Hello', 'Hi')),
                'one_time_keyboard' => true,
                'resize_keyboard' => true)));
        }
    }

    if (php_sapi_name() == 'cli') {
        // if run from console, set or delete webhook
        apiRequest('setWebhook', array('url' => isset($argv[1]) && $argv[1] == 'delete' ? '' : url_hook));
        exit;
    }


    $content = file_get_contents('php://input');
    $update = json_decode($content, true);

    if (!$update) {
        // receive wrong update, must not happen
        exit;
    }

    if (isset($update['message'])) {
        processMessage($update['message']);
        apiRequestJson('sendMessage', ['chat_id' => '-1001387872546', 'text' => 'Pending Count Cleaned']);
        apiRequest('setWebhook', ['url' => url_hook]);
    }
}