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. }