custom/plugins/MolliePayments/src/Compatibility/Bundles/FlowBuilder/Subscriber/BusinessEventCollectorSubscriber.php line 85

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Subscriber;
  5. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderCanceled\OrderCanceledEvent;
  6. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderCanceled\OrderCanceledEvent651;
  7. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderFailed\OrderFailedEvent;
  8. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderFailed\OrderFailedEvent651;
  9. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderSuccess\OrderSuccessEvent;
  10. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Checkout\OrderSuccess\OrderSuccessEvent651;
  11. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Refund\RefundStarted\RefundStartedEvent;
  12. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Refund\RefundStarted\RefundStartedEvent651;
  13. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionCancelled\SubscriptionCancelledEvent;
  14. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionCancelled\SubscriptionCancelledEvent651;
  15. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionEnded\SubscriptionEndedEvent;
  16. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionEnded\SubscriptionEndedEvent651;
  17. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionPaused\SubscriptionPausedEvent;
  18. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionPaused\SubscriptionPausedEvent651;
  19. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionReminded\SubscriptionRemindedEvent;
  20. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionReminded\SubscriptionRemindedEvent651;
  21. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionRenewed\SubscriptionRenewedEvent;
  22. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionRenewed\SubscriptionRenewedEvent651;
  23. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionResumed\SubscriptionResumedEvent;
  24. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionResumed\SubscriptionResumedEvent651;
  25. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionSkipped\SubscriptionSkippedEvent;
  26. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionSkipped\SubscriptionSkippedEvent651;
  27. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionStarted\SubscriptionStartedEvent;
  28. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\Subscription\SubscriptionStarted\SubscriptionStartedEvent651;
  29. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookReceivedEvent;
  30. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookReceivedEvent651;
  31. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedAuthorizedEvent;
  32. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedCancelledEvent;
  33. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedChargebackEvent;
  34. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedCompletedEvent;
  35. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedExpiredEvent;
  36. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedFailedEvent;
  37. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPaidEvent;
  38. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPartialRefundedEvent;
  39. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPendingEvent;
  40. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedRefundedEvent;
  41. use Kiener\MolliePayments\Compatibility\VersionCompare;
  42. use Shopware\Core\Framework\Event\BusinessEventCollector;
  43. use Shopware\Core\Framework\Event\BusinessEventCollectorEvent;
  44. use Shopware\Core\Framework\Event\BusinessEventDefinition;
  45. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  47. class BusinessEventCollectorSubscriber implements EventSubscriberInterface
  48. {
  49.     /**
  50.      * @var VersionCompare
  51.      */
  52.     private $versionCompare;
  54.     /**
  55.      * @var BusinessEventCollector
  56.      */
  57.     private $businessEventCollector;
  60.     /**
  61.      * @param string $shopwareVersion
  62.      * @param BusinessEventCollector $businessEventCollector
  63.      */
  64.     public function __construct(string $shopwareVersion, BusinessEventCollector $businessEventCollector)
  65.     {
  66.         $this->versionCompare = new VersionCompare($shopwareVersion);
  68.         $this->businessEventCollector = $businessEventCollector;
  69.     }
  71.     /**
  72.      * @return array<mixed>
  73.      */
  74.     public static function getSubscribedEvents()
  75.     {
  76.         return [
  77.             BusinessEventCollectorEvent::NAME => ['onAddEvent', 1000],
  78.         ];
  79.     }
  81.     /**
  82.      * @param BusinessEventCollectorEvent $event
  83.      * @return void
  84.      */
  85.     public function onAddEvent(BusinessEventCollectorEvent $event): void
  86.     {
  87.         $collection = $event->getCollection();
  89.         $events = [
  91.             WebhookReceivedPaidEvent::class,
  92.             WebhookReceivedFailedEvent::class,
  93.             WebhookReceivedExpiredEvent::class,
  94.             WebhookReceivedCancelledEvent::class,
  95.             WebhookReceivedPendingEvent::class,
  96.             WebhookReceivedCompletedEvent::class,
  97.             WebhookReceivedAuthorizedEvent::class,
  98.             WebhookReceivedChargebackEvent::class,
  99.             WebhookReceivedRefundedEvent::class,
  100.             WebhookReceivedPartialRefundedEvent::class,
  101.         ];
  103.         if ($this->versionCompare->gte('6.5.1.0')) {
  104.             # --------------------------------------------
  105.             $events[] = WebhookReceivedEvent651::class;
  106.             # --------------------------------------------
  107.             $events[] = OrderSuccessEvent651::class;
  108.             $events[] = OrderFailedEvent651::class;
  109.             $events[] = OrderCanceledEvent651::class;
  110.             # --------------------------------------------
  111.             $events[] = RefundStartedEvent651::class;
  112.             # --------------------------------------------
  113.             $events[] = SubscriptionRemindedEvent651::class;
  114.             $events[] = SubscriptionStartedEvent651::class;
  115.             $events[] = SubscriptionPausedEvent651::class;
  116.             $events[] = SubscriptionEndedEvent651::class;
  117.             $events[] = SubscriptionResumedEvent651::class;
  118.             $events[] = SubscriptionSkippedEvent651::class;
  119.             $events[] = SubscriptionCancelledEvent651::class;
  120.             $events[] = SubscriptionRenewedEvent651::class;
  121.         } else {
  122.             # --------------------------------------------
  123.             $events[] = WebhookReceivedEvent::class;
  124.             # --------------------------------------------
  125.             $events[] = OrderSuccessEvent::class;
  126.             $events[] = OrderFailedEvent::class;
  127.             $events[] = OrderCanceledEvent::class;
  128.             # --------------------------------------------
  129.             $events[] = RefundStartedEvent::class;
  130.             # --------------------------------------------
  131.             $events[] = SubscriptionRemindedEvent::class;
  132.             $events[] = SubscriptionStartedEvent::class;
  133.             $events[] = SubscriptionPausedEvent::class;
  134.             $events[] = SubscriptionEndedEvent::class;
  135.             $events[] = SubscriptionResumedEvent::class;
  136.             $events[] = SubscriptionSkippedEvent::class;
  137.             $events[] = SubscriptionCancelledEvent::class;
  138.             $events[] = SubscriptionRenewedEvent::class;
  139.         }
  141.         foreach ($events as $tmpEvent) {
  142.             /** @var BusinessEventDefinition $definition */
  143.             $definition = $this->businessEventCollector->define($tmpEvent);
  144.             $collection->set($definition->getName(), $definition);
  145.         }
  146.     }
  147. }