<?php
// Database connection (use YOUR hosting's external MySQL hostname)
$host = 'sql123.infinityfree.com';  // NOT localhost!
$db   = 'if0_12345678_myapp';
$user = 'if0_12345678';
$pass = 'your_db_password';

// Mailjet API credentials
$MJ_API_KEY = 'your_mailjet_api_key';
$MJ_SECRET  = 'your_mailjet_secret';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$db;charset=utf8mb4", $user, $pass);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "Connected to database\n";

    // Query for pending emails (adjust to your table structure)
    $stmt = $pdo->query("
        SELECT id, recipient_email, subject, body
        FROM email_queue
        WHERE sent_at IS NULL
        LIMIT 10
    ");

    $emails = $stmt->fetchAll(PDO::FETCH_ASSOC);
    echo "Found " . count($emails) . " pending emails\n";

    foreach ($emails as $email) {
        // Send via Mailjet API
        $data = [
            'Messages' => [[
                'From' => ['Email' => 'noreply@yourdomain.com', 'Name' => 'Your App'],
                'To' => [['Email' => $email['recipient_email']]],
                'Subject' => $email['subject'],
                'HTMLPart' => $email['body']
            ]]
        ];

        $ch = curl_init('https://api.mailjet.com/v3.1/send');
        curl_setopt($ch, CURLOPT_USERPWD, "$MJ_API_KEY:$MJ_SECRET");
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpCode === 200) {
            // Mark as sent
            $update = $pdo->prepare("UPDATE email_queue SET sent_at = NOW() WHERE id = ?");
            $update->execute([$email['id']]);
            echo "Sent email to {$email['recipient_email']}\n";
        } else {
            echo "Failed to send to {$email['recipient_email']}: $response\n";
        }
    }

    echo "Done!\n";

} catch (PDOException $e) {
    echo "Database error: " . $e->getMessage() . "\n";
}