PiedWeb / CMS

src/Extension/UpdateNotification/PageUpdateMailNotifier.php

<?php

namespace PiedWeb\CMSBundle\Extension\UpdateNotification;

use DateInterval;
use Doctrine\ORM\EntityManagerInterface;
use PiedWeb\CMSBundle\Utils\LastTime;
use Symfony\Bridge\Twig\Mime\TemplatedEmail;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Contracts\Translation\TranslatorInterface;

/**
 * Move it to a plugin (todo).
 */
class PageUpdateMailNotifier
{
    private $mailer;
    private $emailTo;
    private $emailFrom;
    private $appName;
    private $rootDir;
    private $interval;
    private $em;
    private $translator;
    private $pageClass;

    public function __construct(
        string $pageClass,
        MailerInterface $mailer,
        string $emailFrom,
        ?string $emailTo,
        string $appName,
        string $rootDir,
        string $interval, //minIntervalBetweenTwoNotification
        EntityManagerInterface $entityManager,
        TranslatorInterface $translator
    ) {
        $this->mailer = $mailer;
        $this->emailTo = $emailTo;
        $this->emailFrom = $emailFrom;
        $this->interval = $interval;
        $this->appName = $appName;
        $this->rootDir = $rootDir;
        $this->em = $entityManager;
        $this->translator = $translator;
        $this->pageClass = $pageClass;
    }

    protected function getPageUpdatedSince($datetime)
    {
        $query = $this->em->createQuery(
            'SELECT p FROM '.$this->pageClass.' p WHERE p.createdAt > :lastTime OR p.updatedAt > :lastTime'
        )->setParameter('lastTime', $datetime);

        return $query->getResult();
    }

    public function postUpdate($page)

The parameter $page is not used and could be removed.

    {
        $this->send();
    }

    public function postPersist($page)

The parameter $page is not used and could be removed.

    {
        $this->send();
    }

    public function send()
    {
        if (! $this->emailTo) {
            return;
        }

        $lastTime = new LastTime($this->rootDir.'/../var/lastPageUpdateNotification');
        if (false === $lastTime->wasRunSince(new DateInterval($this->interval))) {
            return;
        }

        $pages = $this->getPageUpdatedSince($lastTime->get('15 minutes ago'));
        if (empty($pages)) {
            return;
        }

        $message = (new TemplatedEmail())
            ->subject(
                $this->translator->trans('admin.page.update_notification.title', ['%appName%' => $this->appName])
            )
            ->from($this->emailFrom)
            ->to($this->emailTo)
            ->htmlTemplate('@pwcUpdateNotification/pageUpdateMailNotification.html.twig')
            ->context([
                'appName' => $this->appName,
                'pages' => $pages,
            ]);

        $lastTime->set();
        $this->mailer->send($message);
    }
}