class.ilForumMailNotification.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilForumMailNotification extends ilMailNotification
{
    private const PERMANENT_LINK_POST = 'PL_Post';
    private const PERMANENT_LINK_FORUM = 'PL_Forum';
    public const TYPE_THREAD_DELETED = 54;
    public const TYPE_POST_NEW = 60;
    public const TYPE_POST_ACTIVATION = 61;
    public const TYPE_POST_UPDATED = 62;
    public const TYPE_POST_CENSORED = 63;
    public const TYPE_POST_DELETED = 64;
    public const TYPE_POST_ANSWERED = 65;
    public const TYPE_POST_UNCENSORED = 66;

    private bool $is_cronjob = false;
    private ilForumNotificationMailData $provider;
    private ilLogger $logger;

    public function __construct(ilForumNotificationMailData $provider, ilLogger $logger)
    {
        parent::__construct(false);
        $this->provider = $provider;
        $this->logger = $logger;
    }

    protected function initMail(): ilMail
    {
        $mail = parent::initMail();
        $this->logger->debug('Initialized mail service');
        return $mail;
    }

    public function sendMail(array $a_rcp, bool $a_parse_recipients = true): void
    {
        $this->logger->debug(sprintf(
            'Delegating notification transport to mail service for recipients: %s',
            print_r($a_rcp, true)
        ));
        parent::sendMail($a_rcp, $a_parse_recipients);
        $this->logger->debug('Notification transport delegated');
    }

    protected function setSubject(string $a_subject): string
    {
        $value = parent::setSubject($a_subject);
        $this->logger->debug(sprintf('Setting subject to: %s', $a_subject));
        return $value;
    }

    protected function appendAttachments(): void
    {
        if (count($this->provider->getAttachments()) > 0) {
            $this->logger->debug('Adding attachments ...');
            foreach ($this->provider->getAttachments() as $attachment) {
                $this->appendBody($this->getLanguageText('attachment') . ": " . $attachment . "\n");
            }
            $this->appendBody("\n------------------------------------------------------------\n");
            $this->setAttachments($this->provider->getAttachments());
        }
    }

    public function send(): bool
    {
        global $DIC;
        $ilSetting = $DIC->settings();
        $lng = $DIC->language();

        if (!$ilSetting->get('forum_notification', '0')) {
            $this->logger->debug('Forum notifications are globally disabled');
            return false;
        }

        if (!$this->getRecipients()) {
            $this->logger->debug('No notification recipients, nothing to do');
            return false;
        }

        $lng->loadLanguageModule('forum');

        $date_type = ilDatePresentation::useRelativeDates();
        ilDatePresentation::setUseRelativeDates(false);

        switch ($this->getType()) {
            case self::TYPE_THREAD_DELETED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('thread_deleted_by'),
                        $this->provider->getDeletedBy(),
                        $this->provider->getForumTitle()
                    );
                    $this->sendMailWithoutAttachments(
                        'frm_noti_subject_del_thread',
                        (int) $rcp,
                        $customText,
                        'content_deleted_thread'
                    );
                }
                break;

            case self::TYPE_POST_NEW:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('frm_noti_new_post'),
                        $this->provider->getForumTitle()
                    );
                    $this->sendMailWithAttachments('frm_noti_subject_new_post', (int) $rcp, $customText, 'new_post');
                }
                break;

            case self::TYPE_POST_ACTIVATION:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = $this->getLanguageText('forums_post_activation_mail');
                    $this->sendMailWithAttachments('frm_noti_subject_act_post', (int) $rcp, $customText, 'new_post');
                }
                break;

            case self::TYPE_POST_ANSWERED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = $this->getLanguageText('forum_post_replied');
                    $this->sendMailWithAttachments('frm_noti_subject_answ_post', (int) $rcp, $customText, 'new_post');
                }
                break;

            case self::TYPE_POST_UPDATED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('post_updated_by'),
                        $this->provider->getPostUpdateUserName($this->getLanguage()),
                        $this->provider->getForumTitle()
                    );
                    $this->sendMailWithAttachments(
                        'frm_noti_subject_upt_post',
                        (int) $rcp,
                        $customText,
                        'content_post_updated',
                        $this->provider->getPostUpdate()
                    );
                }
                break;

            case self::TYPE_POST_CENSORED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('post_censored_by'),
                        $this->provider->getPostUpdateUserName($this->getLanguage()),
                        $this->provider->getForumTitle()
                    );
                    $this->sendMailWithAttachments(
                        'frm_noti_subject_cens_post',
                        (int) $rcp,
                        $customText,
                        'content_censored_post',
                        $this->provider->getPostCensoredDate()
                    );
                }
                break;

            case self::TYPE_POST_UNCENSORED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('post_uncensored_by'),
                        $this->provider->getPostUpdateUserName($this->getLanguage())
                    );
                    $this->sendMailWithAttachments(
                        'frm_noti_subject_uncens_post',
                        (int) $rcp,
                        $customText,
                        'forums_the_post',
                        $this->provider->getPostCensoredDate()
                    );
                }
                break;

            case self::TYPE_POST_DELETED:
                foreach ($this->getRecipients() as $rcp) {
                    $this->initLanguage($rcp);
                    $customText = sprintf(
                        $this->getLanguageText('post_deleted_by'),
                        $this->provider->getDeletedBy(),
                        $this->provider->getForumTitle()
                    );
                    $this->sendMailWithoutAttachments(
                        'frm_noti_subject_del_post',
                        (int) $rcp,
                        $customText,
                        'content_deleted_post'
                    );
                }
                break;
        }

        ilDatePresentation::setLanguage($lng);
        ilDatePresentation::setUseRelativeDates($date_type);

        return true;
    }

    protected function initLanguage(int $a_usr_id): void
    {
        parent::initLanguage($a_usr_id);
        $this->language->loadLanguageModule('forum');
    }

    public function isCronjob(): bool
    {
        return $this->is_cronjob;
    }

    public function setIsCronjob(bool $is_cronjob): void
    {
        $this->is_cronjob = $is_cronjob;
    }

    private function getPermanentLink(string $type = self::PERMANENT_LINK_POST): string
    {
        global $DIC;

        $ilClientIniFile = $DIC['ilClientIniFile'];

        if ($type === self::PERMANENT_LINK_FORUM) {
            $language_text = $this->getLanguageText("forums_notification_show_frm");
            $forum_parameters = $this->provider->getRefId();
        } else {
            $language_text = $this->getLanguageText("forums_notification_show_post");
            $forum_parameters = $this->provider->getRefId() . "_" . $this->provider->getThreadId() . "_" . $this->provider->getPostId();
        }

        $this->logger->debug(sprintf(
            'Building permanent with parameters %s',
            $forum_parameters
        ));

        $posting_link = sprintf(
            $language_text,
            ilUtil::_getHttpPath() . "/goto.php?target=frm_" . $forum_parameters . '&client_id=' . CLIENT_ID
        ) . "\n\n";

        $posting_link .= sprintf(
            $this->getLanguageText("forums_notification_intro"),
            $ilClientIniFile->readVariable("client", "name"),
            ilUtil::_getHttpPath() . '/?client_id=' . CLIENT_ID
        ) . "\n\n";

        $this->logger->debug(sprintf(
            'Link built: %s',
            $posting_link
        ));

        return $posting_link;
    }

    private function getPostMessage(): string
    {
        $pos_message = $this->provider->getPostMessage();
        if (strip_tags($pos_message) !== $pos_message) {
            $pos_message = preg_replace("/\n/i", "", $pos_message);
            $pos_message = preg_replace("/<li([^>]*)>/i", "\n<li$1>", $pos_message);
            $pos_message = preg_replace("/<\/ul([^>]*)>(?!\s*?(<p|<ul))/i", "</ul$1>\n", $pos_message);
            $pos_message = preg_replace("/<br(\s*)(\/?)>/i", "\n", $pos_message);
            $pos_message = preg_replace("/<p([^>]*)>/i", "\n\n", $pos_message);
            $pos_message = preg_replace("/<\/p([^>]*)>/i", '', $pos_message);

            return $pos_message;
        }

        return $pos_message;
    }

    private function sendMailWithAttachments(
        string $subjectLanguageId,
        int $userId,
        string $customText,
        string $action,
        string $date = ''
    ): void {
        $this->createMail($subjectLanguageId, $userId, $customText, $action, $date);
        $this->appendAttachments();
        $this->addLinkToMail();
        $this->sendMail([$userId]);
    }

    private function sendMailWithoutAttachments(
        string $subjectLanguageId,
        int $userId,
        string $customText,
        string $action,
        ?string $date = null
    ): void {
        $this->createMail($subjectLanguageId, $userId, $customText, $action, $date);
        $this->addLinkToMail();
        $this->sendMail([$userId]);
    }

    private function createMail(
        string $subject,
        int $userId,
        string $customText,
        string $action,
        ?string $date
    ): void {
        if (is_string($date)) {
            $date = $this->createMailDate($date);
        }

        $this->addMailSubject($subject);

        $this->setBody(ilMail::getSalutation($userId, $this->getLanguage()));
        $this->appendBody("\n\n");
        $this->appendBody($customText);
        $this->appendBody("\n\n");
        $this->appendBody($this->getLanguageText('forum') . ": " . $this->provider->getForumTitle());
        $this->appendBody("\n\n");
        if ($this->provider->providesClosestContainer()) {
            $this->appendBody(
                $this->getLanguageText('frm_noti_obj_' . $this->provider->closestContainer()->getType()) . ": " .
                $this->provider->closestContainer()->getTitle()
            );
            $this->appendBody("\n\n");
        }
        $this->appendBody($this->getLanguageText('thread') . ": " . $this->provider->getThreadTitle());
        $this->appendBody("\n\n");
        $this->appendBody($this->getLanguageText($action) . ": \n------------------------------------------------------------\n");

        $this->appendBody($this->getLanguageText('author') . ": " . $this->provider->getPostUserName($this->getLanguage()));
        $this->appendBody("\n");
        if (is_string($date) && $date !== '') {
            $this->appendBody($this->getLanguageText('date') . ": " . $date);
            $this->appendBody("\n");
        }
        $this->appendBody($this->getLanguageText('subject') . ": " . $this->provider->getPostTitle());
        $this->appendBody("\n");
        $this->appendBody($this->getLanguageText('frm_noti_message'));
        $this->appendBody("\n");

        $message = strip_tags($this->getPostMessage());

        if ($this->provider->isPostCensored()) {
            $message = $this->provider->getCensorshipComment();
        }

        $this->appendBody($message . "\n");
        $this->appendBody("------------------------------------------------------------\n");
    }

    private function addMailSubject(string $subject): void
    {
        $this->initMail();

        $container_text = '';
        if ($this->provider->providesClosestContainer()) {
            $container_text = " (" .
                $this->getLanguageText('obj_' . $this->provider->closestContainer()->getType()) .
                " \"" . $this->provider->closestContainer()->getTitle() . "\")";
        }

        $this->setSubject(sprintf(
            $this->getLanguageText($subject),
            $this->provider->getForumTitle(),
            $container_text,
            $this->provider->getThreadTitle()
        ));
    }

    private function createMailDate(string $date): string
    {
        ilDatePresentation::setLanguage($this->language);

        if ($date === '') {
            $date = $this->provider->getPostDate();
        }

        return ilDatePresentation::formatDate(new ilDateTime($date, IL_CAL_DATETIME));
    }

    private function addLinkToMail(): void
    {
        $this->appendBody($this->getPermanentLink());
        $this->appendBody(ilMail::_getInstallationSignature());
    }
}