vendor/lnb/shopware6-lnb-subscription/src/Subscriber/Subscription/SubscriptionHistorySubscriber.php line 26

Open in your IDE?
  1. <?php
  3. namespace Lnb\Shopware6\LnbSubscription\Subscriber\Subscription;
  5. use Lnb\Shopware6\LnbSubscription\Entity\SubscriptionOrder\SubscriptionOrderDefinition;
  6. use Lnb\Shopware6\LnbSubscription\Service\History\SubscriptionOrderHistoryService;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class SubscriptionHistorySubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(
  14.         private readonly SubscriptionOrderHistoryService $subscriptionOrderHistoryService,
  15.         private readonly LoggerInterface $logger
  16.     ) {
  17.     }
  19.     public static function getSubscribedEvents(): array
  20.     {
  21.         return [
  22.             SubscriptionOrderDefinition::ENTITY_NAME . '.written' => 'onSubscriptionWritten'
  23.         ];
  24.     }
  26.     public function onSubscriptionWritten(EntityWrittenEvent $event): void
  27.     {
  28.         $results = $event->getWriteResults();
  30.         try {
  31.             $this->subscriptionOrderHistoryService->setUserId($event->getContext()->getSource());
  33.             foreach ($results as $result) {
  34.                 if ($result->getExistence()->exists()) {
  35.                     $this->subscriptionOrderHistoryService->logUpdate($result);
  36.                 } else {
  37.                     $this->subscriptionOrderHistoryService->logInitial($result);
  38.                 }
  39.             }
  41.             $this->subscriptionOrderHistoryService->save();
  42.         } catch (\Throwable $exception) {
  43.             $this->logger->error(
  44.                 sprintf('Could not create history entry for subscription. Error: %s', $exception->getMessage()),
  45.                 [
  46.                     'trace' => $exception->getTraceAsString(),
  47.                     'eventIds' => $event->getIds()
  48.                 ]
  49.             );
  50.         }
  51.     }
  52. }