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

  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\EntityRepository;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\Log\Package;
  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;
  13. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  15. /**
  16.  * @internal
  17.  */
  18. #[Package('core')]
  19. class RetryWebhookMessageFailedSubscriber implements EventSubscriberInterface
  20. {
  21.     private const MAX_WEBHOOK_ERROR_COUNT = 10;
  23.     /**
  24.      * @internal
  25.      */
  26.     public function __construct(
  27.         private readonly EntityRepository $webhookRepository,
  28.         private readonly EntityRepository $webhookEventLogRepository
  29.     ) {
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             WorkerMessageFailedEvent::class => 'failed',
  36.         ];
  37.     }
  39.     public function failed(WorkerMessageFailedEvent $event): void
  40.     {
  41.         if ($event->willRetry()) {
  42.             return;
  43.         }
  45.         $message = $event->getEnvelope()->getMessage();
  46.         if (!$message instanceof WebhookEventMessage) {
  47.             return;
  48.         }
  50.         $webhookId = $message->getWebhookId();
  51.         $webhookEventLogId = $message->getWebhookEventId();
  53.         $this->markWebhookEventFailed($webhookEventLogId);
  55.         /** @var WebhookEntity|null $webhook */
  56.         $webhook = $this->webhookRepository
  57.             ->search(new Criteria([$webhookId]), Context::createDefaultContext())
  58.             ->get($webhookId);
  60.         if ($webhook === null || !$webhook->isActive()) {
  61.             return;
  62.         }
  64.         $webhookErrorCount = $webhook->getErrorCount() + 1;
  65.         $params = [
  66.             'id' => $webhook->getId(),
  67.             'errorCount' => $webhookErrorCount,
  68.         ];
  70.         if ($webhookErrorCount >= self::MAX_WEBHOOK_ERROR_COUNT) {
  71.             $params = array_merge($params, [
  72.                 'errorCount' => 0,
  73.                 'active' => false,
  74.             ]);
  75.         }
  77.         $this->webhookRepository->update([$params], Context::createDefaultContext());
  78.     }
  80.     private function markWebhookEventFailed(string $id): void
  81.     {
  82.         $this->webhookEventLogRepository->update([
  83.             ['id' => $id, 'deliveryStatus' => WebhookEventLogDefinition::STATUS_FAILED],
  84.         ], Context::createDefaultContext());
  85.     }
  86. }