IBX-8137: Moved from swift mailer to symfony mailer

ibexa · Jul 3, 2024 · d86357d · d86357d
1 parent 8d5b5cd
commit d86357d
Show file tree

Hide file tree

Showing 8 changed files with 142 additions and 88 deletions.
diff --git a/composer.json b/composer.json
@@ -37,7 +37,6 @@
         "symfony/routing": "^5.0",
         "symfony/security-core": "^5.0",
         "symfony/security-http": "^5.0",
-        "symfony/swiftmailer-bundle": "^3.4",
         "symfony/translation": "^5.0",
         "symfony/validator": "^5.0",
         "twig/twig": "^3.0"

diff --git a/phpstan-baseline.neon b/phpstan-baseline.neon
@@ -40,11 +40,6 @@ parameters:
 			count: 1
 			path: src/bundle/Controller/PasswordChangeController.php
 
-		-
-			message: "#^Method Ibexa\\\\Bundle\\\\User\\\\Controller\\\\PasswordResetController\\:\\:sendNotification\\(\\) has parameter \\$user with no type specified\\.$#"
-			count: 1
-			path: src/bundle/Controller/PasswordResetController.php
-
 		-
 			message: "#^Parameter \\#1 \\$user of method Ibexa\\\\Bundle\\\\User\\\\Controller\\\\PasswordResetController\\:\\:sendResetPasswordMessage\\(\\) expects Ibexa\\\\Contracts\\\\Core\\\\Repository\\\\Values\\\\User\\\\User, Ibexa\\\\Contracts\\\\Core\\\\Repository\\\\Values\\\\User\\\\User\\|false given\\.$#"
 			count: 1
@@ -985,16 +980,6 @@ parameters:
 			count: 1
 			path: tests/lib/Form/Type/ChoiceList/Loader/AvailableLocaleChoiceLoaderTest.php
 
-		-
-			message: "#^Access to an undefined property Ibexa\\\\Tests\\\\User\\\\Invitation\\\\InvitationServiceTest\\:\\:\\$configResolver\\.$#"
-			count: 2
-			path: tests/lib/Invitation/InvitationServiceTest.php
-
-		-
-			message: "#^Access to an undefined property Ibexa\\\\Tests\\\\User\\\\Invitation\\\\InvitationServiceTest\\:\\:\\$siteAccessService\\.$#"
-			count: 2
-			path: tests/lib/Invitation/InvitationServiceTest.php
-
 		-
 			message: "#^Method Ibexa\\\\Tests\\\\User\\\\Invitation\\\\InvitationServiceTest\\:\\:invitationProvider\\(\\) return type has no value type specified in iterable type array\\.$#"
 			count: 1

diff --git a/src/bundle/Controller/PasswordResetController.php b/src/bundle/Controller/PasswordResetController.php
@@ -31,8 +31,6 @@
 use Ibexa\User\View\ResetPassword\FormView as UserResetPasswordFormView;
 use Ibexa\User\View\ResetPassword\InvalidLinkView;
 use Ibexa\User\View\ResetPassword\SuccessView as UserResetPasswordSuccessView;
-use Swift_Mailer;
-use Swift_Message;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
 use Twig\Environment;
@@ -43,8 +41,6 @@ class PasswordResetController extends Controller
 
     private UserService $userService;
 
-    private Swift_Mailer $mailer;
-
     private Environment $twig;
 
     private ActionResultHandler $actionResultHandler;
@@ -58,7 +54,6 @@ class PasswordResetController extends Controller
     public function __construct(
         FormFactory $formFactory,
         UserService $userService,
-        Swift_Mailer $mailer,
         Environment $twig,
         ActionResultHandler $actionResultHandler,
         PermissionResolver $permissionResolver,
@@ -67,7 +62,6 @@ public function __construct(
     ) {
         $this->formFactory = $formFactory;
         $this->userService = $userService;
-        $this->mailer = $mailer;
         $this->twig = $twig;
         $this->actionResultHandler = $actionResultHandler;
         $this->permissionResolver = $permissionResolver;
@@ -89,7 +83,7 @@ public function userForgotPasswordAction(Request $request, ?string $reason = nul
             $data = $form->getData();
             $users = $this->userService->loadUsersByEmail($data->getEmail());
 
-            /** Because is is possible to have multiple user accounts with same email address we must gain a user login. */
+            /** Because it is possible to have multiple user accounts with same email address we must gain a user login. */
             if (\count($users) > 1) {
                 return $this->redirectToRoute('ibexa.user.forgot_password.login');
             }
@@ -234,40 +228,13 @@ private function updateUserToken(User $user): string
 
     private function sendResetPasswordMessage(User $user, string $hashKey): void
     {
-        if ($this->isNotifierConfigured()) {
-            $this->sendNotification($user, $hashKey);
-
+        if (!$this->isNotifierConfigured()) {
             return;
         }
 
-        // Swiftmailer delivery has to be kept to maintain backwards compatibility
-        $template = $this->twig->load($this->configResolver->getParameter('user_forgot_password.templates.mail'));
-
-        $senderAddress = $this->configResolver->hasParameter('sender_address', 'swiftmailer.mailer')
-            ? $this->configResolver->getParameter('sender_address', 'swiftmailer.mailer')
-            : '';
-
-        $subject = $template->renderBlock('subject', []);
-        $from = $template->renderBlock('from', []) ?: $senderAddress;
-        $body = $template->renderBlock('body', ['hash_key' => $hashKey]);
-
-        $message = (new Swift_Message())
-            ->setSubject($subject)
-            ->setTo($user->email)
-            ->setBody($body, 'text/html');
-
-        if (empty($from) === false) {
-            $message->setFrom($from);
-        }
-
-        $this->mailer->send($message);
-    }
-
-    private function sendNotification($user, string $token): void
-    {
         $this->notificationService->send(
             new SymfonyNotificationAdapter(
-                new UserPasswordReset($user, $token),
+                new UserPasswordReset($user, $hashKey, $this->configResolver, $this->twig),
             ),
             [new SymfonyRecipientAdapter(new UserRecipient($user))],
         );

diff --git a/src/contracts/Notification/UserInvitation.php b/src/contracts/Notification/UserInvitation.php
@@ -0,0 +1,80 @@
+<?php
+
+/**
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
+ * @license For full copyright and license information view LICENSE file distributed with this source code.
+ */
+declare(strict_types=1);
+
+namespace Ibexa\Contracts\User\Notification;
+
+use Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface;
+use Ibexa\Contracts\User\Invitation\Invitation;
+use Symfony\Bridge\Twig\Mime\NotificationEmail;
+use Symfony\Component\Notifier\Message\EmailMessage;
+use Symfony\Component\Notifier\Message\SmsMessage;
+use Symfony\Component\Notifier\Notification\EmailNotificationInterface;
+use Symfony\Component\Notifier\Notification\Notification;
+use Symfony\Component\Notifier\Notification\SmsNotificationInterface;
+use Symfony\Component\Notifier\Recipient\EmailRecipientInterface;
+use Symfony\Component\Notifier\Recipient\SmsRecipientInterface;
+use Twig\Environment;
+
+final class UserInvitation extends Notification implements EmailNotificationInterface, SmsNotificationInterface
+{
+    private Invitation $invitation;
+
+    private ConfigResolverInterface $configResolver;
+
+    private Environment $twig;
+
+    public function __construct(
+        Invitation $invitation,
+        ConfigResolverInterface $configResolver,
+        Environment $twig
+    ) {
+        parent::__construct();
+
+        $this->configResolver = $configResolver;
+        $this->twig = $twig;
+        $this->invitation = $invitation;
+    }
+
+    public function asEmailMessage(EmailRecipientInterface $recipient, string $transport = null): ?EmailMessage
+    {
+        $templatePath = $this->twig->load(
+            $this->configResolver->getParameter(
+                'user_invitation.templates.mail',
+                null,
+                $this->invitation->getSiteAccessIdentifier()
+            )
+        );
+
+        $template = $this->twig->load($templatePath);
+
+        $subject = $template->renderBlock('subject');
+        $from = $template->renderBlock('from') ?: null;
+        $body = $template->renderBlock('body', [
+            'invite_hash' => $this->invitation->getHash(),
+            'siteaccess' => $this->invitation->getSiteAccessIdentifier(),
+            'invitation' => $this->invitation,
+        ]);
+
+        $email = NotificationEmail::asPublicEmail()
+            ->html($body)
+            ->to($recipient->getEmail())
+            ->subject($subject)
+        ;
+
+        if ($from !== null) {
+            $email->from($from);
+        }
+
+        return new EmailMessage($email);
+    }
+
+    public function asSmsMessage(SmsRecipientInterface $recipient, string $transport = null): ?SmsMessage
+    {
+        return null;
+    }
+}
diff --git a/src/contracts/Notification/UserPasswordReset.php b/src/contracts/Notification/UserPasswordReset.php
@@ -9,33 +9,61 @@
 namespace Ibexa\Contracts\User\Notification;
 
 use Ibexa\Contracts\Core\Repository\Values\User\User;
+use Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface;
+use Symfony\Bridge\Twig\Mime\NotificationEmail;
 use Symfony\Component\Notifier\Message\EmailMessage;
 use Symfony\Component\Notifier\Message\SmsMessage;
 use Symfony\Component\Notifier\Notification\EmailNotificationInterface;
 use Symfony\Component\Notifier\Notification\Notification;
 use Symfony\Component\Notifier\Notification\SmsNotificationInterface;
 use Symfony\Component\Notifier\Recipient\EmailRecipientInterface;
 use Symfony\Component\Notifier\Recipient\SmsRecipientInterface;
+use Twig\Environment;
 
 final class UserPasswordReset extends Notification implements EmailNotificationInterface, SmsNotificationInterface, UserAwareNotificationInterface
 {
     private User $user;
 
     private string $token;
 
+    private ConfigResolverInterface $configResolver;
+
+    private Environment $twig;
+
     public function __construct(
         User $user,
-        string $token
+        string $token,
+        ConfigResolverInterface $configResolver,
+        Environment $twig
     ) {
         parent::__construct();
 
         $this->user = $user;
         $this->token = $token;
+        $this->configResolver = $configResolver;
+        $this->twig = $twig;
     }
 
     public function asEmailMessage(EmailRecipientInterface $recipient, string $transport = null): ?EmailMessage
     {
-        return null;
+        $templatePath = $this->configResolver->getParameter('user_forgot_password.templates.mail');
+        $template = $this->twig->load($templatePath);
+
+        $subject = $template->renderBlock('subject');
+        $from = $template->renderBlock('from') ?: null;
+        $body = $template->renderBlock('body', ['hash_key' => $this->token]);
+
+        $email = NotificationEmail::asPublicEmail()
+            ->html($body)
+            ->to($recipient->getEmail())
+            ->subject($subject)
+        ;
+
+        if ($from !== null) {
+            $email->from($from);
+        }
+
+        return new EmailMessage($email);
     }
 
     public function asSmsMessage(SmsRecipientInterface $recipient, string $transport = null): ?SmsMessage

diff --git a/src/lib/Invitation/MailSender.php b/src/lib/Invitation/MailSender.php
@@ -9,10 +9,13 @@
 namespace Ibexa\User\Invitation;
 
 use Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface;
+use Ibexa\Contracts\Notifications\Service\NotificationServiceInterface;
+use Ibexa\Contracts\Notifications\Value\Notification\SymfonyNotificationAdapter;
+use Ibexa\Contracts\Notifications\Value\Recipent\SymfonyRecipientAdapter;
 use Ibexa\Contracts\User\Invitation\Invitation;
 use Ibexa\Contracts\User\Invitation\InvitationSender;
-use Swift_Mailer;
-use Swift_Message;
+use Ibexa\Contracts\User\Notification\UserInvitation;
+use Symfony\Component\Notifier\Recipient\Recipient;
 use Twig\Environment;
 
 final class MailSender implements InvitationSender
@@ -21,49 +24,37 @@ final class MailSender implements InvitationSender
 
     private ConfigResolverInterface $configResolver;
 
-    private Swift_Mailer $mailer;
+    private NotificationServiceInterface $notificationService;
 
     public function __construct(
         Environment $twig,
         ConfigResolverInterface $configResolver,
-        Swift_Mailer $mailer
+        NotificationServiceInterface $notificationService
     ) {
         $this->twig = $twig;
         $this->configResolver = $configResolver;
-        $this->mailer = $mailer;
+        $this->notificationService = $notificationService;
     }
 
     public function sendInvitation(Invitation $invitation): void
     {
-        $template = $this->twig->load(
-            $this->configResolver->getParameter(
-                'user_invitation.templates.mail',
-                null,
-                $invitation->getSiteAccessIdentifier()
-            )
-        );
-
-        $senderAddress = $this->configResolver->hasParameter('sender_address', 'swiftmailer.mailer')
-            ? $this->configResolver->getParameter('sender_address', 'swiftmailer.mailer')
-            : '';
-
-        $subject = $template->renderBlock('subject', []);
-        $from = $template->renderBlock('from', []) ?: $senderAddress;
-        $body = $template->renderBlock('body', [
-            'invite_hash' => $invitation->getHash(),
-            'siteaccess' => $invitation->getSiteAccessIdentifier(),
-            'invitation' => $invitation,
-        ]);
+        if (!$this->isNotifierConfigured()) {
+            return;
+        }
 
-        $message = (new Swift_Message())
-            ->setSubject($subject)
-            ->setTo($invitation->getEmail())
-            ->setBody($body, 'text/html');
+        $this->notificationService->send(
+            new SymfonyNotificationAdapter(
+                new UserInvitation($invitation, $this->configResolver, $this->twig),
+            ),
+            [new SymfonyRecipientAdapter(new Recipient($invitation->getEmail()))],
+        );
+    }
 
-        if (empty($from) === false) {
-            $message->setFrom($from);
-        }
+    private function isNotifierConfigured(): bool
+    {
+        $subscriptions = $this->configResolver->getParameter('notifications.subscriptions');
 
-        $this->mailer->send($message);
+        return array_key_exists(UserInvitation::class, $subscriptions)
+            && !empty($subscriptions[UserInvitation::class]['channels']);
     }
 }
diff --git a/tests/integration/IbexaTestKernel.php b/tests/integration/IbexaTestKernel.php
@@ -14,7 +14,6 @@
 use Ibexa\Contracts\Core\Test\IbexaTestKernel as BaseIbexaTestKernel;
 use Ibexa\Contracts\User\Invitation\InvitationService;
 use LogicException;
-use Swift_Mailer;
 use Symfony\Component\Config\Loader\LoaderInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\Definition;
@@ -55,7 +54,6 @@ public function registerContainerConfiguration(LoaderInterface $loader): void
             $container->setParameter('locale_fallback', 'en');
 
             self::createSyntheticService($container, UserDispatcher::class);
-            self::createSyntheticService($container, Swift_Mailer::class);
 
             $container->loadFromExtension('framework', [
                 'router' => [

diff --git a/tests/lib/Invitation/InvitationServiceTest.php b/tests/lib/Invitation/InvitationServiceTest.php
@@ -26,6 +26,12 @@ class InvitationServiceTest extends TestCase
 {
     private InvitationService $invitationService;
 
+    /** @var \Ibexa\Core\MVC\Symfony\SiteAccess\SiteAccessServiceInterface&\PHPUnit\Framework\MockObject\MockObject */
+    private SiteAccessServiceInterface $siteAccessService;
+
+    /** @var \Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface&\PHPUnit\Framework\MockObject\MockObject */
+    private ConfigResolverInterface $configResolver;
+
     protected function setUp(): void
     {
         $this->siteAccessService = $this->createMock(SiteAccessServiceInterface::class);