src/Core/Framework/Webhook/Subscriber/RetryWebhookMessageFailedSubscriber.php line 37

  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(private readonly EntityRepository $webhookRepository, private readonly EntityRepository $webhookEventLogRepository)
  27.     {
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             WorkerMessageFailedEvent::class => 'failed',
  34.         ];
  35.     }
  37.     public function failed(WorkerMessageFailedEvent $event): void
  38.     {
  39.         if ($event->willRetry()) {
  40.             return;
  41.         }
  43.         $message = $event->getEnvelope()->getMessage();
  44.         if (!$message instanceof WebhookEventMessage) {
  45.             return;
  46.         }
  48.         $webhookId = $message->getWebhookId();
  49.         $webhookEventLogId = $message->getWebhookEventId();
  51.         $this->markWebhookEventFailed($webhookEventLogId);
  53.         /** @var WebhookEntity|null $webhook */
  54.         $webhook = $this->webhookRepository
  55.             ->search(new Criteria([$webhookId]), Context::createDefaultContext())
  56.             ->get($webhookId);
  58.         if ($webhook === null || !$webhook->isActive()) {
  59.             return;
  60.         }
  62.         $webhookErrorCount = $webhook->getErrorCount() + 1;
  63.         $params = [
  64.             'id' => $webhook->getId(),
  65.             'errorCount' => $webhookErrorCount,
  66.         ];
  68.         if ($webhookErrorCount >= self::MAX_WEBHOOK_ERROR_COUNT) {
  69.             $params = array_merge($params, [
  70.                 'errorCount' => 0,
  71.                 'active' => false,
  72.             ]);
  73.         }
  75.         $this->webhookRepository->update([$params], Context::createDefaultContext());
  76.     }
  78.     private function markWebhookEventFailed(string $id): void
  79.     {
  80.         $this->webhookEventLogRepository->update([
  81.             ['id' => $id, 'deliveryStatus' => WebhookEventLogDefinition::STATUS_FAILED],
  82.         ], Context::createDefaultContext());
  83.     }
  84. }