src/Core/Framework/Webhook/Service/WebhookCleanup.php line 41

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Webhook\Service;
  5. use Doctrine\DBAL\Connection;
  6. use Psr\Clock\ClockInterface;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\Log\Package;
  9. use Shopware\Core\System\SystemConfig\SystemConfigService;
  10. use Symfony\Component\Clock\NativeClock;
  12. /**
  13.  * @internal
  14.  */
  15. #[Package('core')]
  16. class WebhookCleanup
  17. {
  18.     /**
  19.      * @internal
  20.      */
  21.     public function __construct(
  22.         private readonly SystemConfigService $systemConfigService,
  23.         private readonly Connection $connection,
  24.         private readonly ClockInterface $clock = new NativeClock(),
  25.     ) {
  26.     }
  28.     public function removeOldLogs(): void
  29.     {
  30.         $entryLifetimeSeconds = $this->systemConfigService->getInt('core.webhook.entryLifetimeSeconds');
  32.         if ($entryLifetimeSeconds === -1) {
  33.             return;
  34.         }
  36.         $deleteBefore = $this->clock
  37.             ->now()
  38.             ->modify("- $entryLifetimeSeconds seconds")
  39.             ->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  41.         $this->connection->executeStatement(
  42.             'DELETE FROM `webhook_event_log` WHERE `created_at` < :before',
  43.             ['before' => $deleteBefore]
  44.         );
  45.     }
  46. }