vendor/setono/sylius-mailchimp-plugin/src/Controller/Action/SubscribeToNewsletterAction.php line 21

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Setono\SyliusMailchimpPlugin\Controller\Action;
  7. use Setono\SyliusMailchimpPlugin\Client\ClientInterface;
  8. use Setono\SyliusMailchimpPlugin\Form\Type\SubscribeToNewsletterType;
  9. use Setono\SyliusMailchimpPlugin\Model\AudienceInterface;
  10. use Setono\SyliusMailchimpPlugin\Repository\AudienceRepositoryInterface;
  11. use Sylius\Component\Channel\Context\ChannelContextInterface;
  12. use Symfony\Component\Form\FormError;
  13. use Symfony\Component\Form\FormFactoryInterface;
  14. use Symfony\Component\Form\FormInterface;
  15. use Symfony\Component\HttpFoundation\JsonResponse;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Contracts\Translation\TranslatorInterface;
  19. use Twig\Environment;
  21. final class SubscribeToNewsletterAction
  22. {
  23.     /** @var FormFactoryInterface */
  24.     private $formFactory;
  26.     /** @var Environment */
  27.     private $twig;
  29.     /** @var TranslatorInterface */
  30.     private $translator;
  32.     /** @var ChannelContextInterface */
  33.     private $channelContext;
  35.     /** @var AudienceRepositoryInterface */
  36.     private $audienceRepository;
  38.     /** @var ClientInterface */
  39.     private $client;
  41.     public function __construct(
  42.         FormFactoryInterface $formFactory,
  43.         Environment $twig,
  44.         TranslatorInterface $translator,
  45.         ChannelContextInterface $channelContext,
  46.         AudienceRepositoryInterface $audienceRepository,
  47.         ClientInterface $client
  48.     ) {
  49.         $this->formFactory = $formFactory;
  50.         $this->twig = $twig;
  51.         $this->translator = $translator;
  52.         $this->channelContext = $channelContext;
  53.         $this->audienceRepository = $audienceRepository;
  54.         $this->client = $client;
  55.     }
  57.     public function __invoke(Request $request): Response
  58.     {
  59.         $form = $this->formFactory->create(SubscribeToNewsletterType::class);
  61.         $form->handleRequest($request);
  62.         if ($form->isSubmitted()) {
  63.             $audience = $this->getAudience();
  64.             if (null === $audience) {
  65.                 return $this->json(
  66.                     $this->translator->trans('setono_sylius_mailchimp.ui.no_audience_associated_with_channel'),
  67.                     400
  68.                 );
  69.             }
  71.             if (!$form->isValid()) {
  72.                 $errors = $this->getErrorsFromForm($form);
  73.                 if (is_string($errors)) {
  74.                     $errors = [$errors];
  75.                 }
  77.                 return $this->json(
  78.                     $this->translator->trans('setono_sylius_mailchimp.ui.an_error_occurred'), 400, $errors
  79.                 );
  80.             }
  82.             $this->client->subscribeEmail($audience, $form->get('email')->getData());
  84.             return $this->json($this->translator->trans('setono_sylius_mailchimp.ui.subscribed_successfully'));
  85.         }
  87.         $template = $request->query->get('template', '@SetonoSyliusMailchimpPlugin/Shop/Subscribe/content.html.twig');
  88.         $content = $this->twig->render($template, [
  89.             'form' => $form->createView(),
  90.         ]);
  92.         return new Response($content);
  93.     }
  95.     private function json(string $message, int $status = 200, array $errors = []): JsonResponse
  96.     {
  97.         return new JsonResponse([
  98.             'message' => $message,
  99.             'errors' => $errors,
  100.         ], $status);
  101.     }
  103.     /**
  104.      * Taken from https://symfonycasts.com/screencast/javascript/post-proper-api-endpoint#codeblock-99cf6afd45
  105.      *
  106.      * @return array|string
  107.      */
  108.     private function getErrorsFromForm(FormInterface $form)
  109.     {
  110.         /** @var FormError $error */
  111.         foreach ($form->getErrors() as $error) {
  112.             // only supporting 1 error per field
  113.             // and not supporting a "field" with errors, that has more
  114.             // fields with errors below it
  115.             return $error->getMessage();
  116.         }
  118.         $errors = [];
  119.         foreach ($form->all() as $childForm) {
  120.             $childError = $this->getErrorsFromForm($childForm);
  121.             if (is_string($childError)) {
  122.                 $errors[$childForm->getName()] = $childError;
  123.             }
  124.         }
  126.         return $errors;
  127.     }
  129.     private function getAudience(): ?AudienceInterface
  130.     {
  131.         $channel = $this->channelContext->getChannel();
  133.         return $this->audienceRepository->findOneByChannel($channel);
  134.     }
  135. }