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

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