src/Subscriber/Messenger/MailSubscriber.php line 48

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Messenger;
  5. use App\Dictionary\ConversationMessageSource;
  6. use App\Dictionary\MailPriority;
  7. use App\Entity\ConversationMessage;
  8. use App\Entity\Member;
  9. use App\Event\Messenger\NewMessageEvent;
  10. use App\Service\Mail\MailService;
  11. use App\Service\Messenger\MessengerPropertyService;
  12. use App\Service\Property\MemberPropertyService as PropertyService;
  13. use App\Service\System\BounceService;
  14. use App\Service\User\AccountService;
  15. use App\Service\User\Layer\AmateurLayer;
  16. use App\Subscriber\AbstractMailSubscriber;
  17. use Frivol\Common\Dict\AccountStatus;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Twig\Environment;
  21. class MailSubscriber extends AbstractMailSubscriber implements EventSubscriberInterface
  22. {
  23.     public function __construct(
  24.         private AmateurLayer $amateurLayer,
  25.         private PropertyService $propertyService,
  26.         private BounceService $bounceService,
  27.         AccountService $accountService,
  28.         MailService $mailService,
  29.         Environment $twig,
  30.     ) {
  31.         parent::__construct($accountService, $mailService, $twig);
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             NewMessageEvent::class => [
  38.                 ['onNewMessage', 0],
  39.             ],
  40.         ];
  41.     }
  43.     /**
  44.      * @throws \Twig\Error\LoaderError
  45.      * @throws \Twig\Error\RuntimeError
  46.      * @throws \Twig\Error\SyntaxError
  47.      */
  48.     public function onNewMessage(NewMessageEvent $event)
  49.     {
  50.         $message = $event->getEntity();
  51.         $sender = $event->getSender();
  52.         $recipient = $message->getConversation()?->getPartner($sender);
  54.         if (null === $recipient
  55.             || $recipient->isMemberOnline()
  56.             || $this->isEmailNotificationDisabled($recipient)
  57.             || false === $recipient->getIsActive()
  58.             || false === in_array($recipient->getAccount()->getStatus(), [AccountStatus::ACTIVE, AccountStatus::NEW], true)
  59.             || $this->bounceService->hasBounce($recipient->getAccount()->getEmail())
  60.         ) {
  61.             return;
  62.         }
  64.         $mail = $this->createSwiftInstance($message, $recipient, $sender);
  66.         if (ConversationMessageSource::MASSMAILER === $message->getSource()) {
  67.             $priority = MailPriority::MESSENGER_NEW_MESSAGE_MASSMAILER;
  68.             // gitlab #507: only send each third message as an email to reduce mail volume
  69.             if (2 === random_int(1, 6)) {
  70.                 $this->getMailService()->queueMessage($mail, $priority);
  71.             }
  72.         } else {
  73.             $priority = MailPriority::MESSENGER_NEW_MESSAGE;
  74.             $this->getMailService()->queueMessage($mail, $priority);
  75.         }
  76.     }
  78.     /**
  79.      * Returns TRUE, if the user does NOT want email notifications when he or she is offline.
  80.      */
  81.     protected function isEmailNotificationDisabled(Member $recipient): bool
  82.     {
  83.         $prop = MessengerPropertyService::PROPERTY_MESSENGER_EMAIL_NOTIFICATION_DISABLED;
  85.         return true === $this->propertyService->getValueForMember($recipient, $prop);
  86.     }
  88.     protected function getSwiftMailSubject(Member $sender): string
  89.     {
  90.         return sprintf('Neue Nachricht von %s', $sender->getUsername());
  91.     }
  93.     /**
  94.      * @throws \Twig\Error\LoaderError
  95.      * @throws \Twig\Error\RuntimeError
  96.      * @throws \Twig\Error\SyntaxError
  97.      */
  98.     protected function createSwiftInstance(ConversationMessage $message, Member $recipient, Member $sender): \Swift_Message
  99.     {
  100.         $account = $recipient->getAccount();
  102.         $topAmateursPaginator = $this->amateurLayer->getTopAmateurs(1, 30, true, false);
  103.         $topAmateurs = $topAmateursPaginator->getIterator()->getArrayCopy();
  104.         shuffle($topAmateurs);
  106.         $subject = $this->getSwiftMailSubject($sender);
  107.         $mail = new \Swift_Message($subject);
  108.         $mail->addTo($account->getEmail());
  109.         $mail->setFrom('server@frivol.com', 'Frivol.com');
  110.         $mail->setBody($this->getTwigEnvironment()->render('emails/new-message-notification.html.twig', [
  111.             'message' => $message,
  112.             'subject' => $subject,
  113.             'sender' => $sender,
  114.             'amateurs' => array_slice($topAmateurs, 0, 4),
  115.             'recipient' => $recipient,
  116.             'login' => $this->getAccountService()->getAutologinParameter($account),
  117.         ]), 'text/html');
  119.         return $mail;
  120.     }
  121. }