vendor/shopware/core/Framework/Webhook/Subscriber/RetryWebhookMessageFailedSubscriber.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Webhook\Subscriber;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\Webhook\Event\RetryWebhookMessageFailedEvent;
  9. use Shopware\Core\Framework\Webhook\EventLog\WebhookEventLogDefinition;
  10. use Shopware\Core\Framework\Webhook\Message\WebhookEventMessage;
  11. use Shopware\Core\Framework\Webhook\WebhookEntity;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16.  */
  17. class RetryWebhookMessageFailedSubscriber implements EventSubscriberInterface
  18. {
  19.     private const MAX_WEBHOOK_ERROR_COUNT = 10;
  20.     private const MAX_DEAD_MESSAGE_ERROR_COUNT = 2;
  22.     private EntityRepositoryInterface $deadMessageRepository;
  24.     private EntityRepositoryInterface $webhookRepository;
  26.     private EntityRepositoryInterface $webhookEventLogRepository;
  28.     /**
  29.      * @internal
  30.      */
  31.     public function __construct(
  32.         EntityRepositoryInterface $deadMessageRepository,
  33.         EntityRepositoryInterface $webhookRepository,
  34.         EntityRepositoryInterface $webhookEventLogRepository
  35.     ) {
  36.         $this->deadMessageRepository = $deadMessageRepository;
  37.         $this->webhookRepository = $webhookRepository;
  38.         $this->webhookEventLogRepository = $webhookEventLogRepository;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [RetryWebhookMessageFailedEvent::class => ['handleWebhookMessageFail']];
  44.     }
  46.     public function handleWebhookMessageFail(RetryWebhookMessageFailedEvent $event): void
  47.     {
  48.         $deadMessage = $event->getDeadMessage();
  49.         $context = $event->getContext();
  51.         if ($deadMessage->getErrorCount() < self::MAX_DEAD_MESSAGE_ERROR_COUNT) {
  52.             return;
  53.         }
  55.         /** @var WebhookEventMessage $webhookEventMessage */
  56.         $webhookEventMessage = $deadMessage->getOriginalMessage();
  58.         $webhookId = $webhookEventMessage->getWebhookId();
  59.         $webhookEventLogId = $webhookEventMessage->getWebhookEventId();
  61.         $this->deleteDeadMessage($deadMessage->getId(), $context);
  62.         $this->markWebhookEventFailed($webhookEventLogId, $context);
  64.         /** @var WebhookEntity|null $webhook */
  65.         $webhook = $this->webhookRepository
  66.             ->search(new Criteria([$webhookId]), $context)
  67.             ->get($webhookId);
  69.         if ($webhook === null || !$webhook->isActive()) {
  70.             return;
  71.         }
  73.         $webhookErrorCount = $webhook->getErrorCount() + 1;
  74.         $params = [
  75.             'id' => $webhook->getId(),
  76.             'errorCount' => $webhookErrorCount,
  77.         ];
  79.         if ($webhookErrorCount >= self::MAX_WEBHOOK_ERROR_COUNT) {
  80.             $params = array_merge($params, [
  81.                 'errorCount' => 0,
  82.                 'active' => false,
  83.             ]);
  84.         }
  86.         $this->webhookRepository->update([$params], $context);
  87.     }
  89.     private function deleteDeadMessage(string $deadMessageId, Context $context): void
  90.     {
  91.         $this->deadMessageRepository->delete([
  92.             [
  93.                 'id' => $deadMessageId,
  94.             ],
  95.         ], $context);
  96.     }
  98.     private function markWebhookEventFailed(string $webhookEventLogId, Context $context): void
  99.     {
  100.         $this->webhookEventLogRepository->update([
  101.             [
  102.                 'id' => $webhookEventLogId,
  103.                 'deliveryStatus' => WebhookEventLogDefinition::STATUS_FAILED,
  104.             ],
  105.         ], $context);
  106.     }
  107. }