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

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. }