vendor/ibexa/connect/src/bundle/EventSubscriber/FormBuilderSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Bundle\Connect\EventSubscriber;
  11. use Ibexa\Bundle\Connect\Message\WebhookRequest;
  12. use Ibexa\Bundle\Connect\MessageHandler\WebhookRequestHandler;
  13. use Ibexa\FormBuilder\Definition\FieldAttributeDefinitionBuilder;
  14. use Ibexa\FormBuilder\Event\FieldDefinitionEvent;
  15. use Ibexa\FormBuilder\Event\FormEvents;
  16. use Ibexa\FormBuilder\Event\FormSubmitEvent;
  17. use Ibexa\FormBuilder\Exception\FormFieldNotFoundException;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. final class FormBuilderSubscriber implements EventSubscriberInterface
  21. {
  22.     private const ATTRIBUTE_IDENTIFIER = 'ibexa_connect_webhook_url';
  24.     private WebhookRequestHandler $notificationHandler;
  26.     public function __construct(WebhookRequestHandler $notificationHandler)
  27.     {
  28.         $this->notificationHandler = $notificationHandler;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             FormEvents::FORM_SUBMIT => 'onFormSubmit',
  35.             FormEvents::getFieldDefinitionEventName('button') => 'onButtonField',
  36.         ];
  37.     }
  39.     public function onFormSubmit(FormSubmitEvent $event): void
  40.     {
  41.         try {
  42.             $button = $event->getForm()->getFieldByIdentifier('button');
  43.         } catch (FormFieldNotFoundException $e) {
  44.             return;
  45.         }
  47.         if (!$button->hasAttribute(self::ATTRIBUTE_IDENTIFIER)) {
  48.             return;
  49.         }
  51.         $url = $button->getAttributeValue(self::ATTRIBUTE_IDENTIFIER);
  52.         if (!is_string($url) || empty($url)) {
  53.             return;
  54.         }
  56.         $fields = $event->getForm()->getFields();
  57.         $data = $event->getData();
  59.         $requestData = [
  60.             'languageCode' => $data['languageCode'],
  61.             'contentId' => $data['contentId'],
  62.             'contentFieldId' => $data['contentFieldId'],
  63.             'fields' => [],
  64.         ];
  66.         foreach ($fields as $field) {
  67.             $requestData['fields'][] = [
  68.                 'field_type_identifier' => $field->getIdentifier(),
  69.                 'field_name' => $field->getName(),
  70.                 'value' => $data['fields'][$field->getId()] ?? null,
  71.             ];
  72.         }
  74.         $notification = new WebhookRequest($url, $requestData);
  76.         $this->notificationHandler->handle($notification);
  77.     }
  79.     public function onButtonField(FieldDefinitionEvent $event): void
  80.     {
  81.         $webhookAttribute = new FieldAttributeDefinitionBuilder();
  82.         $webhookAttribute->setIdentifier(self::ATTRIBUTE_IDENTIFIER);
  83.         $webhookAttribute->setName('Ibexa Connect Webhook URL');
  84.         $webhookAttribute->setType('string');
  86.         $definitionBuilder = $event->getDefinitionBuilder();
  87.         $definitionBuilder->addAttribute($webhookAttribute->buildDefinition());
  88.     }
  89. }