bot.php

<?php
include "config.php";
include "include/database.php";
include "include/api.php";
include "include/logger.php";
include "include/telegram.php";
include "include/image.php";
include "include/help.php";
include "include/ai.php";
include "include/moderation.php";
include "include/orders.php";
include "include/events.php";
include "include/dispatcher.php";
include "include/message.php";

$db = new SQLite3(DB_FILE);

initDatabase();

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

file_put_contents(logPath('debug'), print_r($update, true) . "\n\n", FILE_APPEND);

// Rispondi subito 200 a Telegram per evitare timeout e retry
http_response_code(200);
header('Connection: close');
header('Content-Length: 0');
ob_end_flush();
flush();

// Se disponibile, chiudi la connessione FastCGI e continua in background
if (function_exists('fastcgi_finish_request')) {
    fastcgi_finish_request();
}










////////////////////////////////////////////////////////////////////////
//////////////////////   Aggiornamento della chat   ///////////////////
////////////////////////////////////////////////////////////////////////


if (isset($update['message'])) {
    $message = $update['message'];
    $groupId = $message['chat']['id'];
    $userName = $message['from']['first_name'] ?? 'Utente';
    $userId = $message['from']['id'] ?? null;
    $chatType = $message['chat']['type'];

    // Gestisci testo
    $messageText = $message['text'] ?? '';
    $messageText = str_replace('@rootbotbot', '', $messageText);
    $messageText = str_replace('@rootbot', '', $messageText);
    $messageText = str_replace('@bot', '', $messageText);
    $messageText = str_replace('@root', '', $messageText);

    // Skip vision quando qualcuno in chat sta caricando immagini menu pappatoia:
    // in quel flusso l'analisi è lavoro amministrativo e la vision (3-10s via QBert)
    // ritardava inutilmente il feedback "immagine salvata".
    // Gli stati pappatoia in orders.php sono chat-wide (senza user_id), quindi
    // filtro solo per chat_id — diversamente da getUserState() che vuole user_id.
    $skipVision = false;
    $stateStmt = $db->prepare("SELECT 1 FROM user_states WHERE chat_id = :chat_id AND state IN ('waiting_images', 'waiting_menu_images') LIMIT 1");
    $stateStmt->bindValue(':chat_id', $groupId, SQLITE3_INTEGER);
    if ($stateStmt->execute()->fetchArray(SQLITE3_ASSOC)) {
        $skipVision = true;
    }

    // PRIMA: Gestisci immagini - analizza e salva nel contesto PRIMA di processMessage
    // Così l'AI avrà il contesto dell'immagine quando risponde
    $botImageAnalysis = null; // Analisi del bot da salvare separatamente
    if (isset($message['photo'])) {
        $photos = $message['photo'];
        $fileId = $photos[count($photos) - 1]['file_id']; // Prendi la versione più grande
        $caption = $message['caption'] ?? '';

        // Analizza l'immagine con AI vision (passa anche la caption per contesto)
        $imageDescription = $skipVision ? null : analyzeImage($fileId, $caption, $groupId);

        // Messaggio utente: ha condiviso un'immagine (+ eventuale caption)
        if ($caption) {
            $messageText = "[ha condiviso un'immagine] $caption";
        } else {
            $messageText = "[ha condiviso un'immagine]";
        }

        if ($imageDescription) {
            // Salva l'analisi come messaggio separato del bot
            $botImageAnalysis = "[analisi immagine: $imageDescription]";
            // Salva file_id per ri-analisi futura
            saveImageLog($groupId, $userId, $userName, $fileId, $imageDescription);

            // Controlla se la caption menziona il bot
            $captionMentionsBot = !empty($caption) && (
                preg_match('/@rootbotbot\b/', $caption) ||
                preg_match('/@rootbot\b/', $caption) ||
                preg_match('/@root\b/', $caption) ||
                preg_match('/@bot\b/', $caption) ||
                preg_match('/\brootbotbot\b/i', $caption) ||
                preg_match('/\brootbot\b/i', $caption)
            );

            // Rispondi con l'analisi in chat privata o quando menzionato nel gruppo
            if ($chatType == 'private' || $captionMentionsBot) {
                sendTelegramMessage($groupId, $imageDescription, [
                    'reply_to_message_id' => $message['message_id'],
                ]);
            }
        }
    }

    // Gestisci documenti immagine (inviati senza compressione)
    if (isset($message['document'])) {
        file_put_contents(logPath('debug'), "=== DOCUMENT DETECTED ===\n", FILE_APPEND);
        file_put_contents(logPath('debug'), "mime=" . ($message['document']['mime_type'] ?? 'none') . "\n", FILE_APPEND);
        file_put_contents(logPath('debug'), "isImageDocument=" . (isImageDocument($message['document']) ? 'YES' : 'NO') . "\n", FILE_APPEND);
    }
    if (isset($message['document']) && isImageDocument($message['document'])) {
        $fileId = $message['document']['file_id'];
        $caption = $message['caption'] ?? '';
        file_put_contents(logPath('debug'), "Processing document image, caption=" . substr($caption, 0, 50) . "\n", FILE_APPEND);

        $imageDescription = $skipVision ? null : analyzeImage($fileId, $caption, $groupId);
        file_put_contents(logPath('debug'), "analyzeImage returned: " . ($imageDescription ? "OK (" . strlen($imageDescription) . " chars)" : ($skipVision ? "SKIPPED (menu upload state)" : "NULL")) . "\n", FILE_APPEND);

        // Messaggio utente: ha condiviso un'immagine (+ eventuale caption)
        if ($caption) {
            $messageText = "[ha condiviso un'immagine] $caption";
        } else {
            $messageText = "[ha condiviso un'immagine]";
        }

        if ($imageDescription) {
            // Salva l'analisi come messaggio separato del bot
            $botImageAnalysis = "[analisi immagine: $imageDescription]";
            // Salva file_id per ri-analisi futura
            saveImageLog($groupId, $userId, $userName, $fileId, $imageDescription);

            $captionMentionsBot = !empty($caption) && (
                preg_match('/@rootbotbot\b/', $caption) ||
                preg_match('/@rootbot\b/', $caption) ||
                preg_match('/@root\b/', $caption) ||
                preg_match('/@bot\b/', $caption) ||
                preg_match('/\brootbotbot\b/i', $caption) ||
                preg_match('/\brootbot\b/i', $caption)
            );

            if ($chatType == 'private' || $captionMentionsBot) {
                sendTelegramMessage($groupId, $imageDescription, [
                    'reply_to_message_id' => $message['message_id'],
                ]);
            }
        }
    }

    // Estrai reply_to_user_id se il messaggio è una risposta a un altro utente
    $replyToUserId = null;
    if (isset($message['reply_to_message']['from']['id'])) {
        $replyToUserId = (int)$message['reply_to_message']['from']['id'];
    }

    // Salva nel contesto PRIMA di processMessage (così l'AI ha il contesto aggiornato)
    if (!empty(trim($messageText))) {
        saveMessageToContext($groupId, $userName, $messageText, $userId, $replyToUserId);
    }
    // Salva l'analisi immagine come messaggio separato del bot
    if (!empty($botImageAnalysis)) {
        saveMessageToContext($groupId, 'rootbot', $botImageAnalysis);
    }

    // Prima di processare, marca come "in elaborazione" se il messaggio invoca il bot
    // (per evitare doppie risposte se il messaggio viene editato durante l'elaborazione)
    $textToCheck = $message['text'] ?? $message['caption'] ?? '';
    $mentionsBot = preg_match('/@rootbotbot\b/', $textToCheck) ||
                   preg_match('/@rootbot\b/', $textToCheck) ||
                   preg_match('/@root\b/', $textToCheck) ||
                   preg_match('/@bot\b/', $textToCheck) ||
                   preg_match('/\brootbotbot\b/i', $textToCheck) ||
                   preg_match('/\brootbot\b/i', $textToCheck) ||
                   $chatType == 'private';

    if ($mentionsBot) {
        markAsReplied($groupId, $message['message_id']);
    }

    // POI: Processa il messaggio (comandi, AI, ecc.)
    // Le reply a un'immagine col bot menzionato sono instradate dal dispatcher
    // come qualsiasi altro messaggio: gli agenti che accettano foto in input
    // (image_query, 3d_gen, ...) leggono il file_id da ctx['raw']['reply_to_message'].
    processMessage($message);
} elseif (isset($update['edited_message'])) {
    // Gestisce i messaggi editati solo se menzionano il bot (o chat privata) e non abbiamo già risposto
    $editedMessage = $update['edited_message'];
    $chatId = $editedMessage['chat']['id'];
    $messageId = $editedMessage['message_id'];
    $chatType = $editedMessage['chat']['type'];
    $text = $editedMessage['text'] ?? $editedMessage['caption'] ?? '';

    // Controlla se il messaggio menziona il bot
    $mentionsBot = preg_match('/@rootbotbot\b/', $text) ||
                   preg_match('/@rootbot\b/', $text) ||
                   preg_match('/@root\b/', $text) ||
                   preg_match('/@bot\b/', $text) ||
                   preg_match('/\brootbotbot\b/i', $text) ||
                   preg_match('/\brootbot\b/i', $text);

    // Processa solo se: (menziona il bot O è chat privata) E non abbiamo già risposto
    if (($mentionsBot || $chatType == 'private') && !hasAlreadyReplied($chatId, $messageId)) {
        // Marca subito come "in elaborazione" per evitare race condition
        if (markAsReplied($chatId, $messageId)) {
            // Salva nel contesto e processa come un messaggio normale
            $userName = $editedMessage['from']['first_name'] ?? 'Utente';
            $userId = $editedMessage['from']['id'] ?? null;
            $messageText = str_replace('@rootbotbot', '', $text);
            $messageText = str_replace('@rootbot', '', $messageText);
            $messageText = str_replace('@bot', '', $messageText);
            $messageText = str_replace('@root', '', $messageText);

            $editReplyToUserId = isset($editedMessage['reply_to_message']['from']['id'])
                ? (int)$editedMessage['reply_to_message']['from']['id'] : null;

            if (!empty(trim($messageText))) {
                saveMessageToContext($chatId, $userName, $messageText, $userId, $editReplyToUserId);
            }

            processMessage($editedMessage);
        }
    }
} elseif (isset($update['callback_query'])) {
    $callbackQuery = $update['callback_query'];
    $data = $callbackQuery['data'];

    // Callback ordini/pappatoie
    if (strpos($data, 'seleziona_pappatoia:') === 0) {
        gestisci_selezione_pappatoia($callbackQuery);
    } elseif (strpos($data, 'delete_pappatoia:') === 0) {
        handle_delete_pappatoia($callbackQuery);
    } elseif (strpos($data, 'confirm_delete_pappatoia:') === 0) {
        confirm_delete_pappatoia($callbackQuery);
    } elseif ($data === 'cancel_delete_pappatoia') {
        cancel_delete_pappatoia($callbackQuery);
    } elseif (strpos($data, 'show_pappatoia_images:') === 0) {
        handle_show_pappatoia_images($callbackQuery);
    } elseif (strpos($data, 'select_pappatoia_for_menu:') === 0) {
        handle_select_pappatoia_for_menu($callbackQuery);
    } elseif (strpos($data, 'menu_action:') === 0) {
        handle_menu_action($callbackQuery);
    }
    // Callback eventi
    elseif (strpos($data, 'partecipo_evento:') === 0) {
        handlePartecipoEvento($callbackQuery);
    } elseif (strpos($data, 'lista_partecipanti:') === 0) {
        handleListaPartecipanti($callbackQuery);
    } elseif (strpos($data, 'annullo_tipo:') === 0) {
        handleAnnulloTipo($callbackQuery);
    } elseif (strpos($data, 'modifica_evento_select:') === 0) {
        handleModificaEventoSelect($callbackQuery);
    } elseif (strpos($data, 'modifica_campo:') === 0) {
        handleModificaCampo($callbackQuery);
    } elseif (strpos($data, 'chiudi_evento_select:') === 0) {
        handleChiudiEventoSelect($callbackQuery);
    } elseif (strpos($data, 'conferma_chiudi_evento:') === 0) {
        handleConfermaChiudiEvento($callbackQuery);
    } elseif ($data === 'annulla_chiudi_evento') {
        handleAnnullaChiudiEvento($callbackQuery);
    } elseif (strpos($data, 'ospite_evento:') === 0) {
        handleOspiteEvento($callbackQuery);
    } elseif (strpos($data, 'annullo_ospite:') === 0) {
        handleAnnulloOspiteCallback($callbackQuery);
    }
    // Callback TTS
    elseif ($data === 'tts') {
        handleTTSCallback($callbackQuery);
    } elseif ($data === 'tts_generating') {
        makeAPIRequest('answerCallbackQuery', [
            'callback_query_id' => $callbackQuery['id'],
            'text' => 'Generazione già in corso, attendi...',
            'show_alert' => false
        ]);
    }
} elseif (isset($update['poll_answer'])) {
    // Gestione risposte ai quiz
    handlePollAnswer($update['poll_answer']);
}

?>