Improve notifications

src/Bundle/ChillPersonBundle/AccompanyingPeriod/Events/UserRefEventSubscriber.php

@@ -0,0 +1,101 @@
+<?php
+
+/**
+ * Chill is a software for social workers
+ *
+ * For the full copyright and license information, please view
+ * the LICENSE file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Chill\PersonBundle\AccompanyingPeriod\Events;
+
+use Chill\MainBundle\Entity\Notification;
+use Chill\MainBundle\Entity\User;
+use Chill\PersonBundle\Entity\AccompanyingPeriod;
+use Doctrine\ORM\EntityManagerInterface;
+use Doctrine\Persistence\Event\LifecycleEventArgs;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\Security\Core\Security;
+use Symfony\Component\Templating\EngineInterface;
+use Symfony\Component\Workflow\Event\EnteredEvent;
+use Symfony\Contracts\Translation\TranslatorInterface;
+
+class UserRefEventSubscriber implements EventSubscriberInterface
+{
+    private EntityManagerInterface $em;
+
+    private EngineInterface $engine;
+
+    private Security $security;
+
+    private TranslatorInterface $translator;
+
+    public function __construct(Security $security, TranslatorInterface $translator, EngineInterface $engine, EntityManagerInterface $em)
+    {
+        $this->security = $security;
+        $this->translator = $translator;
+        $this->engine = $engine;
+        $this->em = $em;
+    }
+
+    public static function getSubscribedEvents()
+    {
+        return [
+            'workflow.accompanying_period_lifecycle.entered' => [
+                'onStateEntered',
+            ],
+        ];
+    }
+
+    public function onStateEntered(EnteredEvent $enteredEvent): void
+    {
+        if ($enteredEvent->getMarking()->has(AccompanyingPeriod::STEP_CONFIRMED)) {
+            $this->onPeriodConfirmed($enteredEvent->getSubject());
+        }
+    }
+
+    public function postUpdate(AccompanyingPeriod $period, LifecycleEventArgs $args): void
+    {
+        if ($period->hasPreviousUser()
+            && $period->getUser() !== $this->security->getUser()
+            && $period->getStep() !== AccompanyingPeriod::STEP_DRAFT
+        ) {
+            $this->generateNotificationToUser($period);
+        }
+
+        // we are just out of a flush operation. Launch a new one
+        $this->em->flush();
+    }
+
+    private function generateNotificationToUser(AccompanyingPeriod $period)
+    {
+        $notification = new Notification();
+
+        $urgentStatement =
+            $period->isEmergency() ? strtoupper($this->translator->trans('accompanying_period.emergency')) . ' ' : '';
+
+        $notification
+            ->setRelatedEntityId($period->getId())
+            ->setRelatedEntityClass(AccompanyingPeriod::class)
+            ->setTitle($urgentStatement . $this->translator->trans('period_notification.period_designated_subject'))
+            ->setMessage($this->engine->render(
+                '@ChillPerson/Notification/accompanying_course_designation.md.twig',
+                [
+                    'accompanyingCourse' => $period,
+                ]
+            ))
+            ->addAddressee($period->getUser());
+
+        $this->em->persist($notification);
+    }
+
+    private function onPeriodConfirmed(AccompanyingPeriod $period)
+    {
+        if ($period->getUser() instanceof User
+            && $period->getUser() !== $this->security->getUser()) {
+            $this->generateNotificationToUser($period);
+        }
+    }
+}