allerta-vvf/backend/telegramBotRouter.php

<?php
use skrtdev\NovaGram\Bot;
use skrtdev\Telegram\Message;
use skrtdev\Telegram\CallbackQuery;

require_once 'utils.php';

define('NONE', 0);
define('WEBHOOK', 1);
$Bot = null;

function initializeBot($mode = WEBHOOK) {
    global $Bot;
    if (is_null($Bot)) {
        if(defined("BASE_PATH")){
            $base_path = "/".BASE_PATH."api/bot/telegram";
        } else {
            $base_path = "/api/bot/telegram";
        }
        $_SERVER['SCRIPT_URL'] = $base_path;
    
        $NovagramConfig = [
            "disable_ip_check" => true, //TODO: fix NovaGram ip check and enable it again
            "parse_mode" => "HTML",
            "mode" => $mode
        ];
    
        if(defined("BOT_TELEGRAM_DEBUG_USER")){
            $NovagramConfig["debug"] = BOT_TELEGRAM_DEBUG_USER;
        }
    
        $Bot = new Bot(BOT_TELEGRAM_API_KEY, $NovagramConfig);
    }
}

function getUserIdByFrom($from_id)
{
    global $db;
    return $db->selectValue("SELECT user FROM `".DB_PREFIX."_bot_telegram` WHERE `chat_id` = ?", [$from_id]);
}

function getUserIdByMessage(Message $message)
{
    return getUserIdByFrom($message->from->id);
}

function requireBotLogin(Message $message)
{
    global $users;

    $userId = getUserIdByMessage($message);
    if ($userId === null) {
        $message->reply(
            "Non hai ancora collegato il tuo account Allerta al bot.".
            "\nPer farlo, premere su <strong>\"Collega l'account al bot Telegram\"</strong>."
        );
        exit();
    } else {
        if($users->auth->hasRole(\Delight\Auth\Role::CONSULTANT)) {
            //Migrate to new user roles
            $users->auth->admin()->removeRoleForUserById($users->auth->getUserId(), \Delight\Auth\Role::CONSULTANT);
            $users->auth->admin()->addRoleForUserById($users->auth->getUserId(), Role::SUPER_EDITOR);
        }
    }
}

function sendTelegramNotification($message, $do_not_send_if_same=true)
{
    global $Bot, $db;

    if(is_null($Bot)) initializeBot(NONE);

    $sentMessages = [];

    //TODO: implement different types of notifications
    //TODO: add command for subscribing to notifications
    $chats = $db->select("SELECT * FROM `".DB_PREFIX."_bot_telegram_notifications`");
    if(!is_null($chats)) {
        foreach ($chats as $chat) {
            if($do_not_send_if_same && urldecode($chat['last_notification']) === $message) continue;
            $chat = $chat['chat_id'];
            $sendMessage = $Bot->sendMessage([
                "chat_id" => $chat,
                "text" => $message
            ]);
            $db->update(
                DB_PREFIX."_bot_telegram_notifications",
                ["last_notification" => urlencode($message)],
                ["chat_id" => $chat]
            );
            $sentMessages[$chat] = $sendMessage->message_id;
        }
    }
    return $sentMessages;
}

function sendTelegramNotificationToUser($message, $userId, $options = [])
{
    global $Bot, $db;

    if(is_null($Bot)) initializeBot(NONE);

    $chat = $db->selectValue("SELECT `chat_id` FROM `".DB_PREFIX."_bot_telegram` WHERE `user` = ?", [$userId]);
    if(!is_null($chat)) {
        $message_response = $Bot->sendMessage(array_merge([
            "chat_id" => $chat,
            "text" => $message
        ], $options));
        return [$message_response->message_id, $chat];
    }
}

function generateAlertMessage($alertType, $alertEnabled, $alertNotes, $alertCreatedBy, $alertDeleted=false) {
    global $users;

    $message = 
      "<b><i><u>".($alertEnabled ? "Allertamento in corso" : ($alertDeleted ? "Allertamento completato" : "Allerta rimossa")).":</u></i></b> ".
      ($alertType === "full" ? "Richiesta <b>squadra completa 🚒</b>" : "<b>Supporto 🧯</b>\n");
    
    if(!is_null($alertNotes) && $alertNotes !== "") {
        $message .= "Note:\n<b>".$alertNotes."</b>\n";
    }
    if(!is_null($alertCreatedBy)) {
        $message .= "Lanciata da: <b>".$users->getName($alertCreatedBy)."</b>\n";
    }
    
    return $message;
}

function generateAlertReportMessage($alertType, $crew, $alertEnabled, $alertNotes, $alertCreatedBy, $alertDeleted=false) {
    global $users;

    $message = generateAlertMessage($alertType, $alertEnabled, $alertNotes, $alertCreatedBy);
    $message .= "\nSquadra:\n";

    foreach($crew as $member) {
        if((!$alertEnabled || $alertDeleted) && $member["response"] === "waiting") continue;
        $user = $users->getUserById($member['id']);
        $message .= "<i>".$user["name"]."</i> ";
        if($user["chief"]) $message .= "CS";
        if($user["driver"]) $message .= "🚒";
        $message .= "- ";
        if($member["response"] === "waiting") {
            $message .= "In attesa 🟡";
        } else if($member["response"] === true) {
            $message .= "Presente 🟢";
        } else if($member["response"] === false) {
            $message .= "Assente 🔴";
        }
        $message .= "\n";
    }

    return $message;
}

function sendAlertReportMessage($alertType, $crew, $alertEnabled, $alertNotes, $alertCreatedBy, $alertDeleted = false) {
    $message = generateAlertReportMessage($alertType, $crew, $alertEnabled, $alertNotes, $alertCreatedBy, $alertDeleted);

    return sendTelegramNotification($message, false);
}

function sendAlertRequestMessage($alertType, $userId, $alertId, $alertNotes, $alertCreatedBy, $alertDeleted = false) {
    return sendTelegramNotificationToUser(generateAlertMessage($alertType, true, $alertNotes, $alertCreatedBy, $alertDeleted), $userId, [
        'reply_markup' => [
            'inline_keyboard' => [
                [
                    [
                        'text' => '✅ Partecipo',
                        'callback_data' => "alert_yes_".$alertId
                    ],
                    [
                        'text' => 'Non partecipo ❌',
                        'callback_data' => "alert_no_".$alertId
                    ]
                ]
            ]
        ]
    ]);
}

function yesOrNo($value)
{
    return ($value === 1 || $value) ? '<b>SI</b>' : '<b>NO</b>';
}

function telegramBotRouter() {
    global $Bot;

    define("running_telegram_bot_webhook", true);

    initializeBot();

    $Bot->addErrorHandler(function ($e) {
        print('Caught '.get_class($e).' exception from general handler'.PHP_EOL);
        print($e.PHP_EOL);
    });
    
    $Bot->onCommand('start', function (Message $message, array $args = []) {
        global $db;
        if(isset($args[0])) {
            $registered_chats = $db->select("SELECT * FROM `".DB_PREFIX."_bot_telegram` WHERE `chat_id` = ?", [$message->from->id]);
            if(!is_null($registered_chats) && count($registered_chats) > 1) {
                $message->chat->sendMessage(
                    "⚠️ Questo account Allerta è già associato ad un'altro utente Telegram.".
                    "\nContattare un amministratore."
                );
                return;
            }
            $response = $db->update(
                DB_PREFIX.'_bot_telegram',
                ['chat_id' => $message->from->id],
                ['tmp_login_token' => $args[0]]
            );
            if($response === 1) {
                logger("Utente collegato ad account telegram (".$message->from->id.")");
                $message->chat->sendMessage(
                    "✅ Login avvenuto con successo!".
                    "\nPer ottenere informazioni sul profilo, utilizzare il comando /info".
                    "\nPer ricevere informazioni sui comandi, utilizzare il comando /help o visualizzare il menu dei comandi da Telegram"
                );
            } else {
                $message->chat->sendMessage(
                    "⚠️ Chiave di accesso non valida, impossibile eseguire il login.".
                    "\nRiprovare o contattare un amministratore."
                );
            }
        } else {
            $message->chat->sendMessage(
                "Per iniziare, è necessario collegare l'account di Allerta con Telegram.".
                "\nPer farlo, premere su <strong>\"Collega l'account al bot Telegram\"</strong>."
            );
        }
    });

    $Bot->onCommand('help', function (Message $message, array $args = []) {
        $message->chat->sendMessage(
            "ℹ️ Elenco dei comandi disponibili:".
            "\n/info - Ottieni informazioni sul profilo connesso".
            "\n/help - Ottieni informazioni sui comandi".
            "\n/attiva - Modifica la tua disponibilità in \"reperibile\"".
            "\n/disattiva - Modifica la tua disponibilità in \"non reperibile\"".
            "\n/programma - Abilita programmazione oraria".
            "\n/disponibili - Mostra un elenco dei vigili attualmente disponibili".
            "\n/stato - Mostra lo stato della disponibilità della squadra"
        );
    });
    
    $Bot->onCommand('debug_userid', function (Message $message) {
        global $Bot;

        $messageText = "🔎 ID utente Telegram: <b>".$message->from->id."</b>";
        if(isset($message->from->username)) {
            $messageText .= "\n💬 Username: <b>".$message->from->username."</b>";
        }
        if(isset($message->from->first_name)) {
            $messageText .= "\n🔎 Nome: <b>".$message->from->first_name."</b>";
        }
        if(isset($message->from->last_name)) {
            $messageText .= "\n🔎 Cognome: <b>".$message->from->last_name."</b>";
        }
        if(isset($message->from->language_code)) {
            $messageText .= "\n🌐 Lingua: <b>".$message->from->language_code."</b>";
        }
        if(isset($message->from->is_bot)) {
            $messageText .= "\n🤖 Bot: <b>".yesOrNo($message->from->is_bot)."</b>";
        }
        $message->reply($messageText);

        if(defined("BOT_TELEGRAM_DEBUG_USER")){
            $messageText .= "\n\n🔎 JSON del messaggio: <b>".json_encode($message)."</b>";
            $Bot->sendMessage(BOT_TELEGRAM_DEBUG_USER, $messageText);
        }
    });
    
    $Bot->onCommand('info', function (Message $message) {
        global $users;
        $user_id = getUserIdByMessage($message);
        if(is_null($user_id)) {
            $message->chat->sendMessage('⚠️ Questo account Telegram non è associato a nessun utente di Allerta.');
        } else {
            $user = $users->getUserById($user_id);
            $message->chat->sendMessage(
                "ℹ️ Informazioni sul profilo:".
                "\n<i>Nome:</i> <b>".$user["name"]."</b>".
                "\n<i>Disponibile:</i> ".yesOrNo($user["available"]).
                "\n<i>Caposquadra:</i> ".yesOrNo($user["chief"] === 1).
                "\n<i>Autista:</i> ".yesOrNo($user["driver"] === 1).
                "\n<i>Interventi svolti:</i> <b>".$user["services"]."</b>".
                "\n<i>Esercitazioni svolte:</i> <b>".$user["trainings"]."</b>".
                "\n<i>Minuti di disponibilità:</i> <b>".$user["availability_minutes"]."</b>"
            );
        }
    });

    //Too difficult and "spaghetti to explain it here in comments, please use https://regexr.com/
    //Jokes apart, checks if text contains something like "Attiva", "attiva", "Disponibile", "disponibile" but not "Non ", "non ", "Non_", "non_", "Dis" or "dis"
    $Bot->onText("/\/?(Sono |sono |Io sono |Io sono )?(?<!non( |_))(?<!dis)(?<!Non( |_))(?<!Dis)(Attiva|Attivami|Attivo|Disponibile|Operativo|attiva|attivami|attivo|disponibile|operativo)/", function (Message $message, $matches = []) {
        global $Bot, $availability;
        requireBotLogin($message);
        if(count(explode(" ", $message->text)) > 3) return;
        $user_id = getUserIdByMessage($message);
        $availability->change(1, $user_id, true);
        $Bot->sendMessage($message->from->id, "Disponibilità aggiornata con successo.\nOra sei <b>operativo</b>.");
    });

    $Bot->onText("/\/?(Io |Io sono )?(Disattiva|Disattivo|Disattivami|Non( |_)attivo|Non( |_)(Sono |sono )?disponibile|Non( |_)(Sono |sono )?operativo|disattiva|disattivo|sisattivami|non( |_)(Sono |sono )?attivo|non( |_)(Sono |sono )?disponibile|non( |_)(Sono |sono )?operativo)/", function (Message $message, $matches = []) {
        global $Bot, $availability;
        requireBotLogin($message);
        if(count(explode(" ", $message->text)) > 4) return;
        $user_id = getUserIdByMessage($message);
        $availability->change(0, $user_id, true);
        $Bot->sendMessage($message->from->id, "Disponibilità aggiornata con successo.\nOra sei <b>non operativo</b>.");
    });

    $Bot->onText("/\/?(Abilita( |_)|abilita( |_)|Attiva( |_)|attiva( |_))?(Programma|Programmazione|programmazione|Programmazione( |_)oraria|programma|programmazione( |_)oraria)/", function (Message $message, $matches = []) {
        global $Bot, $availability;
        requireBotLogin($message);
        if(count(explode(" ", $message->text)) > 3) return;
        $userId = getUserIdByMessage($message);
        $availability->change_manual_mode(0, $userId);
        $Bot->sendMessage($message->from->id, "Programmazione oraria <b>abilitata</b>.\nPer disabilitarla (e tornare in modalità manuale), cambiare la disponbilità usando i comandi \"/attiva\" e \"/disattiva\"");
    });

    $Bot->onText("/\/?(Stato|stato)( |_)?(Distaccamento|distaccamento)?/", function (Message $message, $matches = []) {
        global $db;
        requireBotLogin($message);
        if(count(explode(" ", $message->text)) > 2) return;
        $available_users_count = $db->selectValue("SELECT COUNT(id) FROM `".DB_PREFIX."_profiles` WHERE `available` = 1 AND `hidden` = 0");
        if($available_users_count >= 5) {
            $message->reply("🚒 Distaccamento operativo con squadra completa");
        } else if($available_users_count >= 2) {
            $message->reply("🧯 Distaccamento operativo per supporto");
        } else if($available_users_count >= 0) {
            $message->reply("⚠️ Distaccamento non operativo");
        }
    });

    $Bot->onText("/\/?(Elenco|elenco|Elenca|elenca)?(_| )?(Disponibili|disponibili)/", function (Message $message, $matches = []) {
        global $db, $users;
        requireBotLogin($message);
        if(count(explode(" ", $message->text)) > 2) return;
        $result = $db->select("SELECT `chief`, `driver`, `available`, `name` FROM `".DB_PREFIX."_profiles` WHERE available = 1 and hidden = 0 ORDER BY chief DESC, services ASC, trainings DESC, availability_minutes DESC, name ASC");
        if(!is_null($result) && count($result) > 0) {
            $msg = "ℹ️ Vigili attualmente disponibili:";
            foreach($result as $user) {
                $msg .= "\n<b>".$user["name"]."</b>";
                if($user["driver"]) $msg .= " 🚒";
                if($user["chief"]) {
                    $msg .= " CS";
                }
            }
        } else {
            $msg = "⚠️ Nessun vigile disponibile.";
        }
        $message->reply($msg);
    });

    $Bot->onCallbackQuery(function (CallbackQuery $callback_query) use ($Bot) {
        $user = $callback_query->from;
        $message = $callback_query->message;
        $chat = $message->chat;

        if(strpos($callback_query->data, 'alert_') === 0) {
            $data = explode("_", str_replace("alert_", "", $callback_query->data));
            $alert_id = $data[1];

            setAlertResponse($data[0] === "yes", getUserIdByFrom($user->id), $alert_id);
            return;
        }
    });
    
    $Bot->start();
}