OutboxDatabaseRepository.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\Mail\Folder;
 
use Generator;
use DateTimeZone;
use ilDBConstants;
use ilDBInterface;
use MailDeliveryData;
use DateTimeImmutable;
use ILIAS\Data\Clock\ClockFactory;
use ilMail;
 
readonly class OutboxDatabaseRepository implements OutboxRepository
{
    public function __construct(
        private ilDBInterface $db,
        private ClockFactory $clock,
        private ilMail $mail,
    ) {
    }
 
    public function getOutboxMails(): Generator
    {
        $res = $this->db->queryF(
            <<<'SQL'
            SELECT 
                mail_id, 
                rcp_to, 
                rcp_cc, 
                rcp_bcc, 
                m_subject,
                m_message, 
                attachments, 
                use_placeholders, 
                schedule_datetime, 
                schedule_timezone
            FROM mail 
            INNER JOIN mail_obj_data ON mail.folder_id = mail_obj_data.obj_id AND mail.user_id = mail_obj_data.user_id
                 WHERE mail_obj_data.m_type = %s 
                   AND schedule_datetime IS NOT NULL
            SQL,
            [ilDBConstants::T_TEXT],
            [MailFolderType::OUTBOX->value]
        );
        $current_time = $this->clock->utc()->now();
 
        while ($row = $this->mail->fetchMailData($this->db->fetchAssoc($res))) {
            $schedule_datetime = new DateTimeImmutable(
                $row['schedule_datetime'],
                new DateTimeZone($row['schedule_timezone'])
            );
            if ($schedule_datetime <= $current_time) {
                yield new MailDeliveryData(
                    $row['rcp_to'],
                    $row['rcp_cc'],
                    $row['rcp_bcc'],
                    $row['m_subject'],
                    $row['m_message'],
                    $row['attachments'],
                    (bool) ($row['use_placeholders'] ?? false),
                    isset($row['mail_id']) ? (int) $row['mail_id'] : null
                );
            }
        }
    }
}