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

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\WebhookStatusReceived\WebhookReceivedAuthorizedEvent;
  31. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedCancelledEvent;
  32. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedChargebackEvent;
  33. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedCompletedEvent;
  34. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedExpiredEvent;
  35. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedFailedEvent;
  36. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPaidEvent;
  37. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPartialRefundedEvent;
  38. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedPendingEvent;
  39. use Kiener\MolliePayments\Compatibility\Bundles\FlowBuilder\Events\WebhookStatusReceived\WebhookReceivedRefundedEvent;
  40. use Kiener\MolliePayments\Compatibility\VersionCompare;
  41. use Shopware\Core\Framework\Event\BusinessEventCollector;
  42. use Shopware\Core\Framework\Event\BusinessEventCollectorEvent;
  43. use Shopware\Core\Framework\Event\BusinessEventDefinition;
  44. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  46. class BusinessEventCollectorSubscriber implements EventSubscriberInterface
  47. {
  48.     /**
  49.      * @var VersionCompare
  50.      */
  51.     private $versionCompare;
  53.     /**
  54.      * @var BusinessEventCollector
  55.      */
  56.     private $businessEventCollector;
  59.     /**
  60.      * @param string $shopwareVersion
  61.      * @param BusinessEventCollector $businessEventCollector
  62.      */
  63.     public function __construct(string $shopwareVersion, BusinessEventCollector $businessEventCollector)
  64.     {
  65.         $this->versionCompare = new VersionCompare($shopwareVersion);
  67.         $this->businessEventCollector = $businessEventCollector;
  68.     }
  70.     /**
  71.      * @return array<mixed>
  72.      */
  73.     public static function getSubscribedEvents()
  74.     {
  75.         return [
  76.             BusinessEventCollectorEvent::NAME => ['onAddEvent', 1000],
  77.         ];
  78.     }
  80.     /**
  81.      * @param BusinessEventCollectorEvent $event
  82.      * @return void
  83.      */
  84.     public function onAddEvent(BusinessEventCollectorEvent $event): void
  85.     {
  86.         $collection = $event->getCollection();
  88.         $events = [
  89.             # --------------------------------------------
  90.             WebhookReceivedEvent::class,
  91.             # --------------------------------------------
  92.             WebhookReceivedPaidEvent::class,
  93.             WebhookReceivedFailedEvent::class,
  94.             WebhookReceivedExpiredEvent::class,
  95.             WebhookReceivedCancelledEvent::class,
  96.             WebhookReceivedPendingEvent::class,
  97.             WebhookReceivedCompletedEvent::class,
  98.             WebhookReceivedAuthorizedEvent::class,
  99.             WebhookReceivedChargebackEvent::class,
  100.             WebhookReceivedRefundedEvent::class,
  101.             WebhookReceivedPartialRefundedEvent::class,
  102.         ];
  104.         if ($this->versionCompare->gte('6.5.1.0')) {
  105.             $events[] = OrderSuccessEvent651::class;
  106.             $events[] = OrderFailedEvent651::class;
  107.             $events[] = OrderCanceledEvent651::class;
  108.             # --------------------------------------------
  109.             $events[] = RefundStartedEvent651::class;
  110.             # --------------------------------------------
  111.             $events[] = SubscriptionRemindedEvent651::class;
  112.             $events[] = SubscriptionStartedEvent651::class;
  113.             $events[] = SubscriptionPausedEvent651::class;
  114.             $events[] = SubscriptionEndedEvent651::class;
  115.             $events[] = SubscriptionResumedEvent651::class;
  116.             $events[] = SubscriptionSkippedEvent651::class;
  117.             $events[] = SubscriptionCancelledEvent651::class;
  118.             $events[] = SubscriptionRenewedEvent651::class;
  119.         } else {
  120.             $events[] = OrderSuccessEvent::class;
  121.             $events[] = OrderFailedEvent::class;
  122.             $events[] = OrderCanceledEvent::class;
  123.             # --------------------------------------------
  124.             $events[] = RefundStartedEvent::class;
  125.             # --------------------------------------------
  126.             $events[] = SubscriptionRemindedEvent::class;
  127.             $events[] = SubscriptionStartedEvent::class;
  128.             $events[] = SubscriptionPausedEvent::class;
  129.             $events[] = SubscriptionEndedEvent::class;
  130.             $events[] = SubscriptionResumedEvent::class;
  131.             $events[] = SubscriptionSkippedEvent::class;
  132.             $events[] = SubscriptionCancelledEvent::class;
  133.             $events[] = SubscriptionRenewedEvent::class;
  134.         }
  136.         foreach ($events as $tmpEvent) {
  137.             /** @var BusinessEventDefinition $definition */
  138.             $definition = $this->businessEventCollector->define($tmpEvent);
  139.             $collection->set($definition->getName(), $definition);
  140.         }
  141.     }
  142. }