custom/plugins/CioCustomerDeletionCleanup/src/Subscriber/CustomerDeletionCleanupSubscriber.php line 24

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace CioCustomerDeletionCleanup\Subscriber;
  7. use CioDataRetention\Event\BeforeCustomerDeletionEvent;
  8. use Doctrine\DBAL\Connection;
  9. use Doctrine\DBAL\Exception;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. // CIO-AI-Driven
  13. final class CustomerDeletionCleanupSubscriber implements EventSubscriberInterface
  14. {
  15.     private const AVAILABILITY_NOTIFICATION_TABLE = 'cio_availability_notification';
  17.     public static function getSubscribedEvents(): array
  18.     {
  19.         return [
  20.             BeforeCustomerDeletionEvent::class => 'onBeforeCustomerDeletion',
  21.         ];
  22.     }
  24.     public function onBeforeCustomerDeletion(BeforeCustomerDeletionEvent $event): void
  25.     {
  26.         $connection = $event->getConnection();
  28.         // T55792: email-based cleanup
  29.         if ($this->tableExists($connection, self::AVAILABILITY_NOTIFICATION_TABLE)) {
  30.             try {
  31.                 $connection->executeStatement(
  32.                     'DELETE FROM `cio_availability_notification` WHERE `email` = :email',
  33.                     ['email' => $event->getCustomerEmail()]
  34.                 );
  35.             } catch (Exception $exception) {
  36.                 // Cleanup must never block customer deletion.
  37.             }
  38.         }
  39.     }
  41.     // CIO-AI-Driven
  42.     private function tableExists(Connection $connection, string $tableName): bool
  43.     {
  44.         try {
  45.             // Doctrine DBAL 3: createSchemaManager(); DBAL 2: getSchemaManager();
  46.             try {
  47.                 $schemaManager = $connection->createSchemaManager();
  48.             } catch (\Throwable $throwable) {
  49.                 $schemaManager = $connection->getSchemaManager();
  50.             }
  52.             return $schemaManager->tablesExist([$tableName]);
  53.         } catch (\Throwable $throwable) {
  54.             return false;
  55.         }
  56.     }
  57. }