Messaging

<?php
$config = [
    'db' => [
        'dsn' => 'mysql:host=localhost;dbname=schoolkit;charset=utf8mb4',
        'user' => 'your_username',
        'pass' => 'your_password'
    ],
    'storage_path' => __DIR__ . '/storage'
];

$schoolKit = SchoolKit::start($config);
$messaging = $schoolKit->messaging();

// Messaging module is now ready for bulk communication
echo "Messaging module initialized successfully";
?>

<?php
$templateId = $schoolKit->messaging()->createTemplate(
    'Field Trip Reminder',
    'Upcoming Field Trip - {{trip_date}}',
    '
Field Trip Reminder
Dear {{guardian_name}}, your child {{student_name}} has a field trip on {{trip_date}}.
',
    "Dear {{guardian_name}}, your child {{student_name}} has a field trip on {{trip_date}}.",
    123 // User ID of template creator
);

echo "Created template with ID: {$templateId}";
?>

<?php
// Get templates created by a specific user
$templates = $schoolKit->messaging()->listTemplates(['created_by' => 123]);

// Get all templates
$allTemplates = $schoolKit->messaging()->listTemplates();

foreach ($templates as $template) {
    echo "Template: {$template['name']} - Subject: {$template['subject']}\n";
}
?>

<?php
if ($schoolKit->messaging()->deleteTemplate(15)) {
    echo "Template deleted successfully";
} else {
    echo "Failed to delete template";
}
?>

<?php
$messageId = $schoolKit->messaging()->create([
    'subject' => 'School Picture Day Reminder',
    'body_html' => '
Don\'t forget, picture day is this Friday!
',
    'created_by' => 123 // Admin user ID
]);
echo "Created message draft with ID: {$messageId}";
?>

<?php
$messageId = 101;
// Target all guardians of students in grade 5
$schoolKit->messaging()->addTarget($messageId, 'grade', '5');

// Also target all guardians of students in the chess club (activity ID 22)
$schoolKit->messaging()->addTarget($messageId, 'activity', '22');
?>

<?php
$messageId = 101;
$schoolKit->messaging()->addManual($messageId, 'special.guest@example.com', 'Special Guest');
$schoolKit->messaging()->addManual($messageId, 'board.member@school.edu', 'Board Member');

echo "Added manual recipients to the message";
?>

<?php
$messageId = 101;

// Attach a PDF with custom name
$schoolKit->messaging()->attach($messageId, '/uploads/permission_slip.pdf', 'Permission Slip.pdf');

// Attach an image (MIME type auto-detected)
$schoolKit->messaging()->attach($messageId, '/uploads/school_map.png');

echo "Files attached to message";
?>

<?php
$messageId = 101;
$count = $schoolKit->messaging()->expandRecipients($messageId);
echo "Message is ready to be sent to {$count} recipients.";
?>

<?php
$messageId = 101;
$pendingCount = $schoolKit->messaging()->sendNow($messageId);
echo "Message queued for immediate delivery to {$pendingCount} recipients.";
?>

<?php
$messageId = 101;
$schoolKit->messaging()->schedule($messageId, '2025-08-30 17:00:00');
echo "Message scheduled for delivery.";
?>

<?php
$status = $schoolKit->messaging()->status(101);

echo "Message Status:\n";
echo "Total Recipients: {$status['totals']}\n";
echo "Sent: {$status['sent']}\n";
echo "Failed: {$status['failed']}\n";
echo "Pending: {$status['pending']}\n";
?>

<?php
$dryRunResults = $schoolKit->messaging()->dryRun(101);
echo "Subject: {$dryRunResults['subject']}\n";
echo "Would send to " . count($dryRunResults['to']) . " recipients:\n";

foreach ($dryRunResults['to'] as $email) {
    echo "• {$email}\n";
}

if (isset($dryRunResults['preview_html'])) {
    echo "\nHTML Preview:\n{$dryRunResults['preview_html']}\n";
}

if (isset($dryRunResults['preview_text'])) {
    echo "\nText Preview:\n{$dryRunResults['preview_text']}\n";
}
?>

<?php
$email = $_GET['email'] ?? '';
$token = $_GET['token'] ?? '';

// Verify unsubscribe token first for security
if (hash_equals($expected_token, $token)) {
    if ($schoolKit->messaging()->unsubscribe($email)) {
        echo "You have been successfully unsubscribed from bulk messages";
    } else {
        echo "Unable to process unsubscribe request";
    }
} else {
    echo "Invalid unsubscribe link";
}
?>

<?php
// Background worker script
$pendingMessages = $schoolKit->messaging()->getPendingMessages();

foreach ($pendingMessages as $message) {
    echo "Processing message ID: {$message['id']} - '{$message['subject']}'\n";
    
    // Process recipients for this message
    $recipients = $schoolKit->messaging()->getPendingRecipients($message['id'], 25);
    // ... send emails to recipients
}
?>

<?php
$recipients = $schoolKit->messaging()->getPendingRecipients(101, 25);

foreach ($recipients as $recipient) {
    // Attempt to send email
    try {
        $schoolKit->mail()->send([
            'to' => $recipient['email'],
            'subject' => $recipient['subject'],
            'html' => $recipient['body_html']
        ]);
        $schoolKit->messaging()->markSent($recipient['id']);
    } catch (Exception $e) {
        $schoolKit->messaging()->markFailed($recipient['id'], $e->getMessage());
    }
}
?>

<?php
// After successfully sending an email
if ($schoolKit->messaging()->markSent($recipientId)) {
    echo "Recipient marked as sent";
} else {
    echo "Failed to update recipient status";
}
?>

<?php
// After a failed email send attempt
if ($schoolKit->messaging()->markFailed($recipientId, "SMTP connection timeout")) {
    echo "Recipient marked as failed with error logged";
} else {
    echo "Failed to update recipient status";
}
?>

<?php
$attachments = $schoolKit->messaging()->getMessageAttachments(101);

foreach ($attachments as $attachment) {
    echo "File: {$attachment['name']} ({$attachment['mime']})\n";
    echo "Path: {$attachment['file_path']}\n";
    echo "Size: " . number_format($attachment['size'] / 1024, 2) . " KB\n";
}
?>

<?php
// Background worker logic
$recipients = $schoolKit->messaging()->getPendingRecipients(101, 25);

foreach ($recipients as $recipient) {
    try {
        // Attempt to send email
        $sent = $schoolKit->mail()->send([
            'to' => $recipient['email'],
            'subject' => $recipient['subject'],
            'html' => $recipient['body_html']
        ]);
        
        if ($sent) {
            $schoolKit->messaging()->markSent($recipient['id']);
        } else {
            throw new Exception("SMTP failed");
        }
    } catch (Exception $e) {
        // Check if we should retry this recipient
        if ($schoolKit->messaging()->shouldRetry($recipient)) {
            // Will be retried in next worker cycle
            continue;
        } else {
            // Mark as permanently failed
            $schoolKit->messaging()->markFailed($recipient['id'], $e->getMessage());
        }
    }
}
?>

<?php
// After successfully sending multiple emails
$sentIds = [123, 124, 125, 126];
$success = $schoolKit->messaging()->markSentBatch($sentIds);
if ($success) {
    echo "All recipients marked as sent successfully";
} else {
    echo "Some recipients could not be marked as sent";
}
?>

<?php
// After multiple failed email attempts
$failures = [
    ['id' => 127, 'error' => 'Invalid email address'],
    ['id' => 128, 'error' => 'SMTP timeout'],
    ['id' => 129, 'error' => 'Recipient blocked']
];

$success = $schoolKit->messaging()->markFailedBatch($failures);
if ($success) {
    echo "All recipients marked as failed successfully";
} else {
    echo "Some recipients could not be marked as failed";
}
?>