Notifier.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Mail\Cron\ExpiredOrOrphanedMails;

use ILIAS\Data\Clock\ClockInterface;
use ILIAS\Data\Factory;
use ReportDto;
use ilDBStatement;
use ilDBConstants;
use ilMailCronOrphanedMails;
use ilDBInterface;

class Notifier
{
    private const NOTIFICATION_MARKER_PING_THRESHOLD = 250;
    private const MAIL_DELIVERY_PING_THRESHOLD = 25;

    private ilMailCronOrphanedMails $job;
    private NotificationsCollector $collector;
    private ilDBInterface $db;
    private ClockInterface $clock;
    private int $mail_expiration_days;
    private int $mail_expiration_warning_days;
    private ilDBStatement $mark_as_notified_stmt;

    public function __construct(
        ilMailCronOrphanedMails $job,
        NotificationsCollector $collector,
        int $mail_expiration_days,
        int $mail_expiration_warning_days,
        ?ilDBInterface $db = null,
        ?ClockInterface $clock = null
    ) {
        global $DIC;

        $this->db = $db ?? $DIC->database();
        $this->clock = $clock ?? (new Factory())->clock()->system();

        $this->job = $job;
        $this->collector = $collector;
        $this->mail_expiration_days = $mail_expiration_days;
        $this->mail_expiration_warning_days = $mail_expiration_warning_days;

        $this->mark_as_notified_stmt = $this->db->prepareManip(
            'INSERT INTO mail_cron_orphaned (mail_id, folder_id, ts_do_delete) VALUES (?, ?, ?)',
            [ilDBConstants::T_INTEGER, ilDBConstants::T_INTEGER, ilDBConstants::T_INTEGER]
        );
    }

    private function markAsNotified(ReportDto $collection_obj): void
    {
        $notify_days_before = 1;
        if ($this->mail_expiration_days > $this->mail_expiration_warning_days) {
            $notify_days_before = $this->mail_expiration_days - $this->mail_expiration_warning_days;
        }

        $deletion_datetime = $this->clock->now()
                                         ->modify('+ ' . $notify_days_before . ' days')
                                         ->setTime(0, 0);

        $i = 0;
        foreach ($collection_obj->getFolderObjects() as $folder_obj) {
            $folder_id = $folder_obj->getFolderId();

            foreach ($folder_obj->getOrphanedMailObjects() as $mail_obj) {
                $mail_id = $mail_obj->getMailId();

                if ($i > 0 && $i % self::NOTIFICATION_MARKER_PING_THRESHOLD === 0) {
                    $this->job->ping();
                }

                $this->db->execute(
                    $this->mark_as_notified_stmt,
                    [$mail_id, $folder_id, $deletion_datetime->getTimestamp()]
                );
                $i++;
            }
        }
    }

    private function sendMail(ReportDto $collection_obj): void
    {
        $mail = new MailNotification();
        $mail->setRecipients([$collection_obj->getUserId()]);
        $mail->setAdditionalInformation(['mail_folders' => $collection_obj->getFolderObjects()]);
        $mail->send();
    }

    public function send(): void
    {
        $i = 0;
        foreach ($this->collector->getCollection() as $collection_obj) {
            if ($i > 0 && $i % self::MAIL_DELIVERY_PING_THRESHOLD === 0) {
                $this->job->ping();
            }

            $this->sendMail($collection_obj);
            $this->markAsNotified($collection_obj);
            ++$i;
        }
    }
}