File Browser - /AgentAIv3

📄 Source: chat_handler.php

<?php
session_name('INBOXZERO');
session_start();

header('Content-Type: application/json');

if (!isset($_SESSION['access_token'])) {
    echo json_encode(['reply' => 'Please login first']);
    exit();
}

require_once 'vendor/autoload.php';

$input = json_decode(file_get_contents('php://input'), true);
$query = trim($input['query'] ?? '');
$lang = $input['lang'] ?? 'en';
$requestedChatId = $input['conversation_id'] ?? null;
$maxEmails = intval($input['max_emails'] ?? 50);

if (empty($query)) {
    echo json_encode(['reply' => 'What would you like to know about your emails?']);
    exit();
}

function getEmailBodyContent($service, $messageId) {
    try {
        $message = $service->users_messages->get('me', $messageId, ['format' => 'full']);
        $payload = $message->getPayload();
        
        $decode = function($data) {
            return base64_decode(strtr($data, '-_', '+/'));
        };
        
        $body = "";
        
        if ($payload->getParts()) {
            foreach ($payload->getParts() as $part) {
                if ($part->getMimeType() == 'text/plain' && $part->getBody() && $part->getBody()->getData()) {
                    $body = $decode($part->getBody()->getData());
                    break;
                }
            }
        }
        
        if (empty($body) && $payload->getBody() && $payload->getBody()->getData()) {
            $body = $decode($payload->getBody()->getData());
        }
        
        if (empty($body) && $payload->getParts()) {
            foreach ($payload->getParts() as $part) {
                if ($part->getMimeType() == 'text/html' && $part->getBody() && $part->getBody()->getData()) {
                    $body = $decode($part->getBody()->getData());
                    break;
                }
            }
        }
        
        if (empty($body)) return "";
        
        $body = preg_replace('/<style[^>]*>.*?<\/style>/is', '', $body);
        $body = preg_replace('/<script[^>]*>.*?<\/script>/is', '', $body);
        $body = strip_tags($body);
        $body = html_entity_decode($body, ENT_QUOTES | ENT_HTML5, 'UTF-8');
        $body = preg_replace('/\s+/', ' ', $body);
        $body = trim($body);
        $body = preg_replace('/https?:\/\/[^\s]+/i', '', $body);
        $body = preg_replace('/unsubscribe.*$/i', '', $body);
        
        if (strlen($body) < 20) return "";
        return substr($body, 0, 1000);
    } catch (Exception $e) {
        return "";
    }
}

function saveToHistory($chatId, $userMsg, $assistantMsg) {
    if (!isset($_SESSION['chat_histories'])) {
        $_SESSION['chat_histories'] = [];
    }
    if (!isset($_SESSION['chat_histories'][$chatId])) {
        $_SESSION['chat_histories'][$chatId] = [];
    }
    $_SESSION['chat_histories'][$chatId][] = "User: $userMsg";
    $_SESSION['chat_histories'][$chatId][] = "Assistant: $assistantMsg";
    if (count($_SESSION['chat_histories'][$chatId]) > 30) {
        $_SESSION['chat_histories'][$chatId] = array_slice($_SESSION['chat_histories'][$chatId], -30);
    }
}

// Inițializare chat ID
if (!$requestedChatId) {
    if (isset($_SESSION['current_conversation_id'])) {
        $requestedChatId = $_SESSION['current_conversation_id'];
    } else {
        $requestedChatId = time() . '_' . rand(1000, 9999);
        $_SESSION['current_conversation_id'] = $requestedChatId;
    }
}
$currentChatId = $requestedChatId;

// Fetch emails
$emailListForDisplay = [];
$totalEmails = 0;
$allEmails = [];

try {
    $client = new Google\Client();
    $client->setAccessToken($_SESSION['access_token']);
    $service = new Google\Service\Gmail($client);
    
    $optParams = ['maxResults' => $maxEmails, 'labelIds' => ['INBOX']];
    $messages = $service->users_messages->listUsersMessages('me', $optParams);
    
    if ($messages->getMessages()) {
        foreach ($messages->getMessages() as $msg) {
            $message = $service->users_messages->get('me', $msg->getId(), [
                'format' => 'metadata', 
                'metadataHeaders' => ['From', 'Subject', 'Date']
            ]);
            
            $headers = $message->getPayload()->getHeaders();
            $from = 'Unknown';
            $subject = '(no subject)';
            $date = '';
            $threadId = $message->getThreadId();
            
            foreach ($headers as $header) {
                if ($header->getName() == 'From') $from = $header->getValue();
                if ($header->getName() == 'Subject') $subject = $header->getValue();
                if ($header->getName() == 'Date') $date = $header->getValue();
            }
            
            try {
                $dateObj = new DateTime($date);
                $dateObj->setTimezone(new DateTimeZone('Europe/Bucharest'));
                $dateFormatted = $dateObj->format('d M Y, H:i');
                $timestamp = $dateObj->getTimestamp();
            } catch (Exception $e) {
                $dateFormatted = 'unknown date';
                $timestamp = 0;
            }
            
            $allEmails[] = [
                'from' => $from,
                'subject' => $subject,
                'date' => $dateFormatted,
                'timestamp' => $timestamp,
                'threadId' => $threadId,
                'id' => $msg->getId()
            ];
        }
    }
    
    usort($allEmails, function($a, $b) {
        return $b['timestamp'] - $a['timestamp'];
    });
    
    $totalEmails = count($allEmails);
    
    foreach ($allEmails as $email) {
        $emailListForDisplay[] = [
            'from' => htmlspecialchars($email['from']),
            'subject' => htmlspecialchars($email['subject']),
            'date' => $email['date'],
            'id' => $email['id'],
            'threadId' => $email['threadId']
        ];
    }
    
    // ============================================
    // ANALIZĂ INTELIGENTĂ
    // ============================================
    $q = strtolower($query);
    $reply = "";
    $isRomanian = ($lang == 'ro' || strpos($q, 'ș') !== false || strpos($q, 'ț') !== false || strpos($q, 'ă') !== false);
    
    // ============================================
    // 1. REMINDER (prioritate maximă)
    // ============================================
    if (preg_match('/(remind me|set a reminder|set a timer|amintește-mi|setează un reminder|reminder)/i', $query, $matches)) {
        // Extrage minutele
        if (preg_match('/(\d+)\s*(minute|minutes|min|m)/i', $query, $timeMatches)) {
            $minutes = intval($timeMatches[1]);
            $reminderText = "Check your email";
            
            // Extrage textul reminder-ului
            if (preg_match('/(?:to|about|for|pentru|să)\s+(.+)$/i', $query, $textMatches)) {
                $reminderText = trim($textMatches[1]);
            }
            
            $reply = $isRomanian 
                ? "🔔 Voi trimite o notificare în $minutes minut(e): \"$reminderText\""
                : "🔔 I'll send a notification in $minutes minute(s): \"$reminderText\"";
            
            // Trimite reminder-ul către frontend
            echo json_encode([
                'reply' => $reply,
                'reminder' => ['text' => $reminderText, 'minutes' => $minutes],
                'emails' => $emailListForDisplay,
                'total_emails' => $totalEmails,
                'conversation_id' => $currentChatId
            ]);
            exit();
        } else {
            $reply = $isRomanian 
                ? "⏰ Spune-mi câte minute: 'amintește-mi în 5 minute să verific emailul'"
                : "⏰ Tell me how many minutes: 'remind me in 5 minutes to check my email'";
        }
    }
    // ============================================
    // 2. SCRIERE EMAIL (nu e implementat încă, dar dă un răspuns util)
    // ============================================
    elseif (preg_match('/(write an email|send an email|scrie un email|trimite un email)/i', $query)) {
        $reply = $isRomanian
            ? "📧 Funcția de trimis emailuri va fi disponibilă în versiunea viitoare. Momentan, îți pot doar citi emailurile."
            : "📧 The email sending feature will be available in a future version. For now, I can only read your emails.";
    }
    // ============================================
    // 3. CONȚINUT EMAIL
    // ============================================
    elseif (strpos($q, 'conține') !== false || strpos($q, 'spune') !== false || 
            strpos($q, 'conținut') !== false || strpos($q, 'ce scrie') !== false ||
            strpos($q, 'what does') !== false || strpos($q, 'what is in') !== false) {
        
        $targetEmail = null;
        
        // Caută "de la X"
        if (preg_match('/de la (\w+)/i', $query, $matches)) {
            $senderName = strtolower($matches[1]);
            foreach ($allEmails as $email) {
                if (stripos($email['from'], $senderName) !== false) {
                    $targetEmail = $email;
                    break;
                }
            }
        }
        
        // Caută "ultimul"
        if (!$targetEmail && (strpos($q, 'ultimul') !== false || strpos($q, 'latest') !== false)) {
            $targetEmail = $allEmails[0];
        }
        
        if (!$targetEmail) {
            $targetEmail = $allEmails[0];
        }
        
        $content = getEmailBodyContent($service, $targetEmail['id']);
        if (!empty($content)) {
            if ($isRomanian) {
                $reply = "📧 Email de la {$targetEmail['from']}:\nSubiect: {$targetEmail['subject']}\nData: {$targetEmail['date']}\n\n---\n" . $content . "\n---";
            } else {
                $reply = "📧 Email from {$targetEmail['from']}:\nSubject: {$targetEmail['subject']}\nDate: {$targetEmail['date']}\n\n---\n" . $content . "\n---";
            }
        } else {
            $reply = $isRomanian ? "Nu am putut extrage conținutul acestui email." : "Could not extract content from this email.";
        }
    }
    // ============================================
    // 4. OFERTE
    // ============================================
    elseif (strpos($q, 'oferte') !== false || strpos($q, 'offers') !== false || strpos($q, 'reduceri') !== false) {
        $offerWords = ['sale', 'discount', 'reducere', 'promo', 'offer', 'voucher', '%', 'gratis', 'free'];
        $offers = [];
        
        // Verifică expeditor specific
        $targetOfferSender = null;
        if (preg_match('/de la (\w+)/i', $query, $matches)) {
            $targetOfferSender = strtolower($matches[1]);
        }
        
        foreach ($allEmails as $email) {
            $subject = strtolower($email['subject']);
            $isOffer = false;
            foreach ($offerWords as $kw) {
                if (strpos($subject, $kw) !== false) {
                    $isOffer = true;
                    break;
                }
            }
            if ($isOffer) {
                if ($targetOfferSender === null || stripos($email['from'], $targetOfferSender) !== false) {
                    $offers[] = $email;
                }
            }
        }
        
        if (count($offers) > 0) {
            if ($isRomanian) {
                $reply = "🎁 Ai " . count($offers) . " email(uri) cu oferte:\n";
            } else {
                $reply = "🎁 You have " . count($offers) . " emails with offers:\n";
            }
            for ($i = 0; $i < min(10, count($offers)); $i++) {
                $reply .= "• {$offers[$i]['from']} - {$offers[$i]['subject']}\n";
            }
        } else {
            $reply = $isRomanian ? "Nu am găsit oferte." : "No offers found.";
        }
    }
    // ============================================
    // 5. LISTARE EMAILURI
    // ============================================
    elseif (strpos($q, 'list') !== false || strpos($q, 'lista') !== false || strpos($q, 'arată') !== false) {
        $numEmails = 10;
        if (preg_match('/\b(\d+)\b/', $q, $matches)) {
            $numEmails = min(intval($matches[1]), $totalEmails);
        }
        if (strpos($q, 'all') !== false || strpos($q, 'toate') !== false) {
            $numEmails = min(30, $totalEmails);
        }
        
        if ($isRomanian) {
            $reply = "Ultimele $numEmails emailuri:\n";
        } else {
            $reply = "Latest $numEmails emails:\n";
        }
        for ($i = 0; $i < $numEmails; $i++) {
            $reply .= ($i+1) . ". {$allEmails[$i]['from']} - {$allEmails[$i]['subject']}\n";
        }
    }
    // ============================================
    // 6. EXPEDITOR SPECIFIC
    // ============================================
    elseif (preg_match('/(de la|from)\s+(\w+)/i', $query, $matches)) {
        $senderName = strtolower($matches[2]);
        $filtered = array_filter($allEmails, function($email) use ($senderName) {
            return stripos($email['from'], $senderName) !== false;
        });
        $filtered = array_values($filtered);
        $count = count($filtered);
        
        if ($count > 0) {
            if ($isRomanian) {
                $reply = "Ai $count email(uri) de la " . ucfirst($senderName) . ":\n";
            } else {
                $reply = "You have $count email(s) from " . ucfirst($senderName) . ":\n";
            }
            for ($i = 0; $i < min(5, $count); $i++) {
                $reply .= "• {$filtered[$i]['subject']} [{$filtered[$i]['date']}]\n";
            }
            if ($count > 5) $reply .= ($isRomanian ? "...și " : "...and ") . ($count - 5) . " more.";
        } else {
            $reply = $isRomanian ? "Nu am găsit emailuri de la " . ucfirst($senderName) : "No emails from " . ucfirst($senderName) . " found";
        }
    }
    // ============================================
    // 7. NUMĂRARE
    // ============================================
    elseif (strpos($q, 'how many') !== false || strpos($q, 'câte') !== false || strpos($q, 'cati') !== false) {
        $reply = $isRomanian ? "Ai $totalEmails emailuri în inbox." : "You have $totalEmails emails in your inbox.";
    }
    // ============================================
    // 8. CEL MAI RECENT
    // ============================================
    elseif (strpos($q, 'ultimul') !== false || strpos($q, 'latest') !== false) {
        if ($isRomanian) {
            $reply = "📧 Ultimul email:\nDe la: {$allEmails[0]['from']}\nSubiect: {$allEmails[0]['subject']}\nData: {$allEmails[0]['date']}";
        } else {
            $reply = "📧 Latest email:\nFrom: {$allEmails[0]['from']}\nSubject: {$allEmails[0]['subject']}\nDate: {$allEmails[0]['date']}";
        }
    }
    // ============================================
    // 9. SALUT / HELP
    // ============================================
    elseif (strpos($q, 'salut') !== false || strpos($q, 'hello') !== false || strpos($q, 'hi') !== false || strpos($q, 'help') !== false) {
        if ($isRomanian) {
            $reply = "👋 Salut! Sunt InboxZero AI. Te pot ajuta:\n\n• Găsesc emailuri ('emailuri de la Steam')\n• Citesc conținut ('ce spune ultimul email')\n• Listează emailuri ('list 20 emailuri')\n• Găsesc oferte ('ce oferte am')\n• Setez reminder ('amintește-mi în 5 minute')\n• Numără emailuri ('câte emailuri am')\n\nCu ce te pot ajuta?";
        } else {
            $reply = "👋 Hello! I'm InboxZero AI. I can:\n\n• Find emails ('emails from Steam')\n• Read content ('what does the latest email say')\n• List emails ('list 20 emails')\n• Find offers ('what offers do I have')\n• Set reminders ('remind me in 5 minutes')\n• Count emails ('how many emails')\n\nWhat would you like to know?";
        }
    }
    // ============================================
    // 10. DEFAULT
    // ============================================
    else {
        if ($isRomanian) {
            $reply = "📬 Văd $totalEmails emailuri. Încearcă:\n• 'list emailuri'\n• 'ultimul email'\n• 'emailuri de la Steam'\n• 'ce oferte am'\n• 'amintește-mi în 5 minute'";
        } else {
            $reply = "📬 I see $totalEmails emails. Try:\n• 'list emails'\n• 'latest email'\n• 'emails from Steam'\n• 'what offers do I have'\n• 'remind me in 5 minutes'";
        }
    }
    
} catch (Exception $e) {
    $reply = "Error: " . $e->getMessage();
}

saveToHistory($currentChatId, $query, $reply);

echo json_encode([
    'reply' => $reply,
    'emails' => $emailListForDisplay,
    'total_emails' => $totalEmails,
    'conversation_id' => $currentChatId
]);
?>
← Back
📂 File Browser

📁 Directories

📄 Files

📄 Source: chat_handler.php
