ap2i/src/Message/Handler/OrganizationDeletionHandler.php

<?php

declare(strict_types=1);

namespace App\Message\Handler;

use App\Message\Message\OrganizationCreation;
use App\Message\Message\OrganizationDeletion;
use App\Service\Organization\OrganizationFactory;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
use Symfony\Component\Mime\Address;
use Symfony\Component\Mime\Email as SymfonyEmail;
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
use Throwable;

#[AsMessageHandler(priority: 1)]
class OrganizationDeletionHandler
{
    public function __construct(
        private readonly OrganizationFactory $organizationFactory,
        private readonly MailerInterface $symfonyMailer,
        private readonly string $opentalentMailReport
    ) {}

    /**
     * @throws Throwable
     * @throws TransportExceptionInterface
     * @throws \Symfony\Component\Mailer\Exception\TransportExceptionInterface
     */
    public function __invoke(OrganizationDeletion $organizationDeletionCommand): void
    {
        $organizationCreationRequest = $organizationDeletionCommand->getOrganizationDeletionRequest();
        $mail = ['subject' => '', 'content' => ''];

        try {
            $this->organizationFactory->delete($organizationCreationRequest);

            $mail['subject'] = 'Organization deleted';
            $mail['content'] = 'The organization n° ' . $organizationCreationRequest->getOrganizationId() . ' has been deleted successfully.';

        } catch (\Exception $e) {
            $mail['subject'] = 'Organization deletion : an error occured';
            $mail['content'] = 'An error occured while deleting the new organization : \n' . $e->getMessage();
            throw $e;

        } finally {
            if ($organizationCreationRequest->getSendConfirmationEmailAt() !== null) {
                $symfonyMail = (new SymfonyEmail())
                    ->from($this->opentalentMailReport)
                    ->replyTo($this->opentalentMailReport)
                    ->returnPath(Address::create($this->opentalentMailReport))
                    ->to($organizationCreationRequest->getSendConfirmationEmailAt())
                    ->subject($mail['subject'])
                    ->text($mail['content']);
                $this->symfonyMailer->send($symfonyMail);
            }
        }
    }
}