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

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\Log\Package;
  9. use Shopware\Core\Framework\Webhook\Event\RetryWebhookMessageFailedEvent;
  10. use Shopware\Core\Framework\Webhook\EventLog\WebhookEventLogDefinition;
  11. use Shopware\Core\Framework\Webhook\Message\WebhookEventMessage;
  12. use Shopware\Core\Framework\Webhook\WebhookEntity;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. /**
  16.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  17.  */
  18. #[Package('core')]
  19. class RetryWebhookMessageFailedSubscriber implements EventSubscriberInterface
  20. {
  21.     private const MAX_WEBHOOK_ERROR_COUNT = 10;
  22.     private const MAX_DEAD_MESSAGE_ERROR_COUNT = 2;
  24.     private EntityRepositoryInterface $deadMessageRepository;
  26.     private EntityRepositoryInterface $webhookRepository;
  28.     private EntityRepositoryInterface $webhookEventLogRepository;
  30.     /**
  31.      * @internal
  32.      */
  33.     public function __construct(
  34.         EntityRepositoryInterface $deadMessageRepository,
  35.         EntityRepositoryInterface $webhookRepository,
  36.         EntityRepositoryInterface $webhookEventLogRepository
  37.     ) {
  38.         $this->deadMessageRepository = $deadMessageRepository;
  39.         $this->webhookRepository = $webhookRepository;
  40.         $this->webhookEventLogRepository = $webhookEventLogRepository;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [RetryWebhookMessageFailedEvent::class => ['handleWebhookMessageFail']];
  46.     }
  48.     public function handleWebhookMessageFail(RetryWebhookMessageFailedEvent $event): void
  49.     {
  50.         $deadMessage = $event->getDeadMessage();
  51.         $context = $event->getContext();
  53.         if ($deadMessage->getErrorCount() < self::MAX_DEAD_MESSAGE_ERROR_COUNT) {
  54.             return;
  55.         }
  57.         /** @var WebhookEventMessage $webhookEventMessage */
  58.         $webhookEventMessage = $deadMessage->getOriginalMessage();
  60.         $webhookId = $webhookEventMessage->getWebhookId();
  61.         $webhookEventLogId = $webhookEventMessage->getWebhookEventId();
  63.         $this->deleteDeadMessage($deadMessage->getId(), $context);
  64.         $this->markWebhookEventFailed($webhookEventLogId, $context);
  66.         /** @var WebhookEntity|null $webhook */
  67.         $webhook = $this->webhookRepository
  68.             ->search(new Criteria([$webhookId]), $context)
  69.             ->get($webhookId);
  71.         if ($webhook === null || !$webhook->isActive()) {
  72.             return;
  73.         }
  75.         $webhookErrorCount = $webhook->getErrorCount() + 1;
  76.         $params = [
  77.             'id' => $webhook->getId(),
  78.             'errorCount' => $webhookErrorCount,
  79.         ];
  81.         if ($webhookErrorCount >= self::MAX_WEBHOOK_ERROR_COUNT) {
  82.             $params = array_merge($params, [
  83.                 'errorCount' => 0,
  84.                 'active' => false,
  85.             ]);
  86.         }
  88.         $this->webhookRepository->update([$params], $context);
  89.     }
  91.     private function deleteDeadMessage(string $deadMessageId, Context $context): void
  92.     {
  93.         $this->deadMessageRepository->delete([
  94.             [
  95.                 'id' => $deadMessageId,
  96.             ],
  97.         ], $context);
  98.     }
  100.     private function markWebhookEventFailed(string $webhookEventLogId, Context $context): void
  101.     {
  102.         $this->webhookEventLogRepository->update([
  103.             [
  104.                 'id' => $webhookEventLogId,
  105.                 'deliveryStatus' => WebhookEventLogDefinition::STATUS_FAILED,
  106.             ],
  107.         ], $context);
  108.     }
  109. }