vendor/damienharper/doctrine-audit-bundle/src/DoctrineAuditBundle/Event/AuditSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. namespace DH\DoctrineAuditBundle\Event;
  5. use DH\DoctrineAuditBundle\Manager\AuditManager;
  6. use Doctrine\DBAL\Exception\TableNotFoundException;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. class AuditSubscriber implements EventSubscriberInterface
  10. {
  11.     /**
  12.      * @var AuditManager
  13.      */
  14.     private $manager;
  16.     public function __construct(AuditManager $manager)
  17.     {
  18.         $this->manager = $manager;
  19.     }
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             LifecycleEvent::class => 'onAuditEvent',
  25.         ];
  26.     }
  28.     /**
  29.      * @param LifecycleEvent $event
  30.      *
  31.      * @throws \Doctrine\DBAL\DBALException
  32.      *
  33.      * @return LifecycleEvent
  34.      */
  35.     public function onAuditEvent(LifecycleEvent $event): LifecycleEvent
  36.     {
  37.         $payload = $event->getPayload();
  38.         $auditTable = $payload['table'];
  39.         unset($payload['table'], $payload['entity']);
  41.         $fields = [
  42.             'type' => ':type',
  43.             'object_id' => ':object_id',
  44.             'discriminator' => ':discriminator',
  45.             'transaction_hash' => ':transaction_hash',
  46.             'diffs' => ':diffs',
  47.             'blame_id' => ':blame_id',
  48.             'blame_user' => ':blame_user',
  49.             'blame_user_fqdn' => ':blame_user_fqdn',
  50.             'blame_user_firewall' => ':blame_user_firewall',
  51.             'ip' => ':ip',
  52.             'created_at' => ':created_at',
  53.         ];
  55.         $query = sprintf(
  56.             'INSERT INTO %s (%s) VALUES (%s)',
  57.             $auditTable,
  58.             implode(', ', array_keys($fields)),
  59.             implode(', ', array_values($fields))
  60.         );
  62.         $storage = $this->manager->selectStorageSpace($this->manager->getConfiguration()->getEntityManager());
  63.         $statement = $storage->getConnection()->prepare($query);
  65.         foreach ($payload as $key => $value)
  66.         {
  67.             $statement->bindValue($key, $value);
  68.         }
  70.         try
  71.         {
  72.             $statement->execute();
  73.         }
  74.         catch (TableNotFoundException $e)
  75.         {
  76.         }
  78.         return $event;
  79.     }
  80. }