improve email service

back/api/src/Repository/UserRepository.php

@@ -40,6 +40,21 @@ public function upgradePassword(PasswordAuthenticatedUserInterface $user, string
         $this->getEntityManager()->flush();
     }
 
+    public function save(User $entity): void
+    {
+        $this->getEntityManager()->persist($entity);
+        $this->getEntityManager()->flush();
+    }
+
+    public function findByRole($value): array
+    {
+        return $this->createQueryBuilder('u')
+            ->andWhere('u.roles LIKE :role')
+            ->setParameter('role', "%$value%")
+            ->getQuery()
+            ->getResult();
+    }
+
 //    /**
 //     * @return User[] Returns an array of User objects
 //     */

back/api/src/Service/Email.php

@@ -7,10 +7,12 @@
 use Brevo\Client\Model\SendSmtpEmail;
 use Exception;
 use GuzzleHttp\Client;
+use App\Entity\User;
 
 class Email {
     private BrevoConfiguration $config;
     private TransactionalEmailsApi $apiInstance;
+    private static string $emailFrom = '[email protected]';
 
     public function __construct()
     {
@@ -24,17 +26,17 @@ public function __construct()
     /**
      * @throws Exception
      */
-    public function sendEmail($email, $emailReceiver, $subject, $body): void
+    public function sendEmail($emailFrom, $emailTo, $subject, $body): void
     {
         $sendSMPTEmail = new SendSmtpEmail(
             [
                 'sender' => [
-                    'name' => $email,
-                    'email' => $email,
+                    'name' => $emailFrom,
+                    'email' => $emailFrom,
                 ],
                 'to' => [
                     [
-                        'email' => $emailReceiver,
+                        'email' => $emailTo,
                     ],
                 ],
                 'subject' => $subject,
@@ -47,4 +49,56 @@ public function sendEmail($email, $emailReceiver, $subject, $body): void
             throw new ApiException($e->getMessage());
         }
     }
+
+    public function sendWelcomeEmail(string $emailTo, string $name)
+    {
+        $subject = 'Bienvenue';
+        $body = 'Bonjour '.$name.',<br><br> Bienvenue chez NOM';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
+
+    public function sendResetPasswordEmail(string $emailTo, string $name, string $token)
+    {
+        $subject = 'Réinitialisation de mot de passe';
+        $body = 'Bonjour '.$name.',<br><br> Pour réinitialiser votre mot de passe, veuillez cliquer sur le lien ci-dessous : <br><br> <a href="https://localhost/auth/reset-password/validate/'.$token.'">Réinitialiser le mot de passe</a>';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
+
+    public function sendRequestProviderEmail(array $adminEmails, string $name, string $requestId)
+    {
+        $subject = 'Nouvelle demande prestataire';
+        $body = 'Bonjour,<br><br> Une nouvelle demande prestataire a été effectuée par '.$name.'.<br><br> Pour la consulter, veuillez cliquer sur le lien ci-dessous : <br><br> <a href="https://localhost:8080/admin/requests/'.$requestId.'">Consulter la demande</a>';
+
+        foreach($adminEmails as $emailTo) {
+            $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+        }
+    }
+
+    public function sendProviderConfimationEmail(string $emailTo, string $name)
+    {
+        $subject = 'Demande prestataire';
+        $body = 'Bonjour '.$name.',<br><br> Votre demande prestataire a bien été prise en compte.';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
+
+    public function sendProviderAcceptedEmail(string $emailTo, string $name)
+    {
+        $subject = 'Demande prestataire';
+        $body = 'Bonjour '.$name.',<br><br> Votre demande prestataire a été acceptée.';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
+
+    public function sendProviderRefusedEmail(string $emailTo, string $name)
+    {
+        $subject = 'Demande prestataire';
+        $body = 'Bonjour '.$name.',<br><br> Votre demande prestataire a été refusée.';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
+
+    public function sendReservationEmail(string $emailTo, string $name)
+    {
+        $subject = 'Réservation';
+        $body = 'Bonjour '.$name.',<br><br> Votre réservation a bien été prise en compte.';
+        $this->sendEmail(Email::$emailFrom, $emailTo, $subject, $body);
+    }
 }

back/api/src/Subscriber/ProviderRequestSubscriber.php

@@ -8,11 +8,24 @@
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 use Symfony\Component\HttpKernel\Event\ResponseEvent;
 use Symfony\Component\HttpKernel\KernelEvents;
+use App\Service\Email;
+use App\Entity\User;
+use App\Repository\UserRepository;
+use Symfony\Bundle\SecurityBundle\Security;
 
 final class ProviderRequestSubscriber implements EventSubscriberInterface
 {
-    public function __construct(private EntityManagerInterface $entityManager)
-    {
+    private Email $email;
+    private EntityManagerInterface $entityManager;
+    private UserRepository $userRepository;
+
+    public function __construct(
+        EntityManagerInterface $entityManager,
+        UserRepository $userRepository,
+    ) {
+        $this->entityManager = $entityManager;
+        $this->userRepository = $userRepository;
+        $this->email = new Email();
     }
 
     public static function getSubscribedEvents()
@@ -29,31 +42,35 @@ public function onRequestEvent(ResponseEvent $event)
         $response = $event->getResponse();
         $statusCode = $response->getStatusCode();
         $resourceClass = $request->attributes->get("_api_resource_class");
+        $currentData = $request->attributes->get("data");
+
         if ($resourceClass !== ProviderRequest::class) return;
-        if ($statusCode === 200 && $method === "PATCH"){
-            /**
-             * @var $currentData ProviderRequest
-             */
-            $currentData = $request->attributes->get("data");
-            /**
-             * @var $previousData ProviderRequest
-             */
+
+        if ($statusCode === 200 && $method === "PATCH") {
             $previousData = $request->attributes->get("previous_data");
             $previousStatus = $previousData->getStatus();
             $currentStatus = $currentData->getStatus();
-            if ($previousStatus === "pending" && $currentStatus != $previousStatus){
-                // TODO: Faire l'envoie de mail pour informer le client que ça demande a été refusé ou accepté
+
+            if ($previousStatus === "pending" && $currentStatus != $previousStatus) {
+                $user = $currentData->getCreatedBy();
                 if ($currentStatus === "approved") {
-                    $user = $currentData->getCreatedBy();
                     $user->setRoles(["ROLE_PROVIDER"]);
-                    $this->entityManager->persist($user);
-                    $this->entityManager->flush();
+                    $this->userRepository->save($user);
+                    $this->email->sendProviderAcceptedEmail($user->getEmail(), $user->getFirstname());
+                } else if ($currentStatus === "rejected") {
+                    $this->email->sendProviderRejectedEmail($user->getEmail(), $user->getFirstname());
                 }
             }
         }
-        if ($statusCode === 201 && $method === "POST"){
-            // TODO: Faire l'envoie de mail vers l'admin pour lui informer que une demande est dispo
+
+        if ($statusCode === 201 && $method === "POST") {
+            $content = json_decode($response->getContent(), false);
+            $user = $content->createdBy;
+            /* $requestId = $content->id; */
+            /* $admins = $this->userRepository->findByRole("ROLE_ADMIN"); */
+
+            /* $this->email->sendRequestProviderEmail($admins, $user->name, $requestId); */
+            $this->email->sendProviderConfimationEmail($user->email, $user->firstname);
         }
     }
-
 }

back/api/src/Subscriber/UserSubscriber.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace App\Subscriber;
+
+use ApiPlatform\Symfony\EventListener\EventPriorities;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpKernel\Event\ResponseEvent;
+use Symfony\Component\HttpKernel\KernelEvents;
+use App\Service\Email;
+use App\Entity\User;
+use App\Repository\UserRepository;
+use Symfony\Bundle\SecurityBundle\Security;
+
+final class UserSubscriber implements EventSubscriberInterface
+{
+    private Email $email;
+    private EntityManagerInterface $entityManager;
+    private UserRepository $userRepository;
+
+    public function __construct(
+        EntityManagerInterface $entityManager,
+        UserRepository $userRepository,
+    ) {
+        $this->entityManager = $entityManager;
+        $this->userRepository = $userRepository;
+        $this->email = new Email();
+    }
+
+    public static function getSubscribedEvents()
+    {
+        return [
+            KernelEvents::RESPONSE => ['onRequestEvent', EventPriorities::POST_WRITE],
+        ];
+    }
+
+    public function onRequestEvent(ResponseEvent $event)
+    {
+        $request = $event->getRequest();
+        $method = $request->getMethod();
+        $response = $event->getResponse();
+        $statusCode = $response->getStatusCode();
+        $resourceClass = $request->attributes->get("_api_resource_class");
+
+        if ($resourceClass !== User::class) return;
+
+        if ($statusCode === 201 && $method === "POST") {
+            $user = json_decode($response->getContent(), false);
+            $this->email->sendWelcomeEmail($user->email, $user->firstname);
+        }
+    }
+}