vendor/wns/security-compliance-suite/src/Logging/Subscriber/CacheInvalidationSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace WnsSecurityComplianceSuite\Logging\Subscriber;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use WnsSecurityComplianceSuite\Logging\Provider\SourceInfoProvider;
  11. final class CacheInvalidationSubscriber implements EventSubscriberInterface
  12. {
  13. private SourceInfoProvider $sourceInfoProvider;
  15. public function __construct(
  16. SourceInfoProvider $sourceInfoProvider
  17. ) {
  18. $this->sourceInfoProvider = $sourceInfoProvider;
  19. }
  21. public static function getSubscribedEvents()
  22. {
  23. return [
  24. 'user.written' => 'invalidateUserCache',
  25. 'user.deleted' => 'invalidateUserCache',
  26. 'integration.written' => 'invalidateIntegrationCache',
  27. 'integration.deleted' => 'invalidateIntegrationCache',
  28. ];
  29. }
  31. public function invalidateUserCache(EntityWrittenEvent $event): void
  32. {
  33. foreach ($event->getWriteResults() as $userWriteResult) {
  34. /** @var string $userId */
  35. $userId = $userWriteResult->getPrimaryKey();
  36. $this->sourceInfoProvider->clearUserCache($userId);
  37. }
  38. }
  40. public function invalidateIntegrationCache(EntityWrittenEvent $event): void
  41. {
  42. foreach ($event->getWriteResults() as $integrationWriteResult) {
  43. /** @var string $integrationId */
  44. $integrationId = $integrationWriteResult->getPrimaryKey();
  45. $this->sourceInfoProvider->clearIntegrationCache($integrationId);
  46. }
  47. }
  48. }