allerta-vvf/backend/app/Telegram/WebhookController.php

<?php

namespace App\Telegram;

use App\Models\TelegramBotLogins;
use App\Models\User;

use App\Utils\Alerts;
use App\Utils\Availability;

use App\Exceptions\AlertClosed;
use App\Exceptions\AlertResponseAlreadySet;

use DefStudio\Telegraph\Facades\Telegraph;

use Sentry\State\Scope;

class WebhookController extends
    \DefStudio\Telegraph\Handlers\WebhookHandler
{
    private $publicCommandsDict = [
        "disponibili" => "Mostra un elenco dei vigili attualmente disponibili",
        "stato" => "Mostra lo stato della disponibilità della squadra",
        "attiva" => "Modifica la tua disponibilità in \"reperibile\"",
        "disattiva" => "Modifica la tua disponibilità in \"non reperibile\"",
        "programma" => "Abilita programmazione oraria",
        "info" => "Ottieni informazioni sul profilo connesso",
        "help" => "Ottieni informazioni sui comandi",
    ];

    private $user = null;

    private function user(): User|null {
        if($this->user) return $this->user;
        try {
            $this->user = $this->message->from()->storage()->get('user', null);
        } catch (\Exception|\Throwable|\Error $e) {
            $this->user = null;
        }

        if($this->user && app()->bound('sentry')) {
            \Sentry\configureScope(function (Scope $scope): void {
                $scope->setUser([
                    'id' => $this->user->id,
                    'name' => $this->user->name,
                ]);
            });
        }

        return $this->user;
    }

    private function replyToUserChat($text) {
        $chat = Telegraph::chat($this->message->from()->id());
        $chat->message($text)->send();
    }

    /**
     * Helper and core commands
     */

    public function help(): void
    {
        $text = "ℹ️ Elenco dei comandi disponibili:";
        foreach ($this->publicCommandsDict as $command => $description) {
            $text .= "\n/$command - $description";
        }
        $this->reply($text);
    }

    public function registerCommands()
    {
        $response = $this->bot->registerCommands($this->publicCommandsDict)->send();
        if($response->ok()) {
            $this->reply("✅ Fatto\nElenco comandi aggiornato con successo.");
        } else {
            $this->reply(
                "⚠️ Errore durante l'aggiornamento dell'elenco comandi.".
                "\nProcedere manualmente, utilizzando @botfather e inviando il seguente elenco:"
            );
            $text = "";
            foreach ($this->publicCommandsDict as $command => $description) {
                $text .= "$command - $description\n";
            }
            $this->reply($text);
        }
    }

    public function start(string $loginCode)
    {
        if($this->user()) {
            $username = $this->user()->username;
            $this->chat->html(
                "⚠️ Il tuo account è già collegato con Telegram (username: <i>$username</i>).\n".
                "Per scollegarlo, eseguire il comando <strong><i>/logout</i></strong>"
            )->send();
            return;
        }

        if(!$loginCode || $loginCode == "/start") {
            $this->chat->html(
                "Questo Bot Telegram permette di interfacciarsi con il sistema di gestione delle disponibilità <b>AllertaVVF</b>\n".
                "Per iniziare, è necessario collegare l'account di Allerta con Telegram.\n".
                "Per farlo, accedere alla WebApp e premere su <strong>\"Collega l'account al bot Telegram\"</strong>."
            )->send();
            return;
        }

        $row = TelegramBotLogins::where('tmp_login_code', $loginCode)->first();
        if(!$row) {
            $this->chat->html(
                "⚠️ Il codice di login non è valido.\n".
                "Per favore, riprovare."
            )->send();
            return;
        }

        $row->chat_id = $this->message->chat()->id();
        $row->tmp_login_code = null;
        $row->save();

        $this->reply("✅ Il tuo account è stato collegato con successo.");
        $user = User::find($row->user);
        $this->message->from()->storage()->set("user", $user);
    }

    public function logout()
    {
        $this->message->from()->storage()->forget('user');
        TelegramBotLogins::where('chat_id', $this->message->chat()->id())->delete();
        $this->replyToUserChat("✅ Il tuo account è stato scollegato con successo.");
    }

    /**
     * Generic commands
     */
    public function info()
    {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        $this->replyToUserChat(
            "ℹ️ Informazioni sul profilo:".
            "\n<i>Nome:</i> <b>".$user["name"]."</b>".
            (!empty($user["surname"])&& !is_null($user["surname"]) ? "\n<i>Cognome:</i> <b>".$user["surname"]."</b>" : "").
            "\n<i>Disponibile:</i> ".($user["available"] ? "<b>SI</b>" : "<b>NO</b>").
            "\n<i>Caposquadra:</i> ".($user["chief"] === 1 ? "<b>SI</b>" : "<b>NO</b>").
            "\n<i>Autista:</i> ".($user["driver"] === 1 ? "<b>SI</b>" : "<b>NO</b>").
            "\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>"
        );
    }

    public function attiva() {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        
        Availability::updateAvailability($user, true, true);
        $this->replyToUserChat("Disponibilità aggiornata con successo.\nOra sei <b>operativo</b>.");
    }

    public function disattiva() {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        
        Availability::updateAvailability($user, false, true);
        $this->replyToUserChat("Disponibilità aggiornata con successo.\nOra sei <b>non operativo</b>.");
    }

    public function programma() {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        
        Availability::updateAvailabilityManualMode($user, false, true);
        $this->replyToUserChat("Programmazione oraria <b>abilitata</b>.\nPer disabilitarla (e tornare in modalità manuale), cambiare la disponbilità usando i comandi \"/attiva\" e \"/disattiva\"");
    }

    public function disponibili()
    {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        //Get all users with availability true
        $users = User::where('available', true)
          ->where('hidden', false)
          ->orderBy('chief', 'desc')
          ->orderBy('driver', 'desc')
          ->orderBy('services', 'asc')
          ->orderBy('trainings', 'desc')
          ->orderBy('availability_minutes', 'desc')
          ->orderBy('name', 'asc')
          ->orderBy('surname', 'asc')
          ->get();
        if(count($users) == 0) {
            $text = "⚠️ Nessun vigile attualmente disponibile.";
        } else {
            $text = "👨‍🚒 Elenco dei vigili attualmente disponibili:";
            foreach ($users as $user) {
                $text .= "\n- <i>".(!empty($user->surname)&&!is_null($user->surname) ? $user->surname : "")." ".$user->name."</i>";
                if($user->chief) $text .= " CS";
                if($user->driver) $text .= " 🚒";
            }
        }
        $this->reply($text);
    }

    public function stato()
    {
        $user = $this->user();
        if(is_null($user)) {
            $this->replyToUserChat("⚠️ Il tuo account Allerta non è collegato con Telegram.\nPer favore, eseguire il comando <strong><i>/start</i></strong>.");
            return;
        }
        //Get all users with availability true
        $available_users_count = User::where('available', true)->where('hidden', false)->count();
        if($available_users_count >= 5) {
            $text = "🚒 Distaccamento operativo con squadra completa";
        } else if($available_users_count >= 2) {
            $text = "🧯 Distaccamento operativo per supporto";
        } else {
            $text = "⚠️ Distaccamento non operativo";
        }
        $this->reply($text);
    }

    /**
     * Callbacks
     */
    public function manual_mode_off()
    {
        $user = User::find($this->data->get('user_id', null));
        if(is_null($user)) {
            $this->reply("⚠️ Il tuo account Allerta non è collegato con Telegram.", true);
            return;
        }
        Availability::updateAvailabilityManualMode($user, false, true);
        $this->reply("✅ Programmazione oraria abilitata", true);
        
        //Delete the message that triggered the callback
        $this->chat->deleteMessage($this->messageId)->send();
    }

    public function delete_notification()
    {
        //Delete the message that triggered the callback
        $this->chat->deleteMessage($this->messageId)->send();
    }

    public function alert_set_response()
    {
        $user_id = $this->data->get('user_id', null);
        $user = User::find($user_id);
        if(is_null($user)) {
            $this->reply("⚠️ Il tuo account Allerta non è collegato con Telegram.", true);
            return;
        }

        $response = $this->data->get('response', null);
        if(!in_array($response, [true, false, 1, 0])) {
            $this->reply("⚠️ Risposta non valida.", true);
            return;
        }
        $alert_id = $this->data->get('alert_id', null);
        if(is_null($alert_id)) {
            $this->reply("⚠️ ID allertamento non valido.", true);
            return;
        }
        
        try {
            Alerts::updateAlertResponse($alert_id, $response, $user_id, true);
        } catch(AlertClosed $e) {
            $this->reply("⚠️ La chiamata è stata chiusa.", true);
        } catch(AlertResponseAlreadySet $e) {
            $this->reply("⚠️ La tua risposta è già stata registrata.", true);
        }
    }
}