rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Add AuditableEntity interface. #330

Browse source
This commit is contained in:
Korina Cordero 2020-03-09 07:21:45 +00:00
parent b743d202fb
commit d7806a2664
4 changed files with 53 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Entity/AuditableEntity.php Normal file
View file

@ -0,0 +1,8 @@
<?php
namespace App\Entity;
interface AuditableEntity
{
public function fieldDump();
}

2
src/Entity/Role.php
View file

@ -14,7 +14,7 @@ use Symfony\Bridge\Doctrine\Validator\Constraints\UniqueEntity;
* @UniqueEntity("id") * @UniqueEntity("id")
* @UniqueEntity("name") * @UniqueEntity("name")
*/ */
class Role extends BaseRole class Role extends BaseRole implements AuditableEntity
{ {
/** /**
* @ORM\ManyToMany(targetEntity="User", mappedBy="roles", fetch="EXTRA_LAZY") * @ORM\ManyToMany(targetEntity="User", mappedBy="roles", fetch="EXTRA_LAZY")

2
src/Entity/User.php
View file

@ -16,7 +16,7 @@ use Serializable;
* @UniqueEntity("username") * @UniqueEntity("username")
* @UniqueEntity("email") * @UniqueEntity("email")
*/ */
class User extends BaseUser implements Serializable class User extends BaseUser implements Serializable, AuditableEntity
{ {
/** /**
* @ORM\Id * @ORM\Id

75
src/EventListener/EntityListener.php
View file

@ -9,6 +9,8 @@ use Doctrine\ORM\Event\OnFlushEventArgs;
use InfluxDB\Point; use InfluxDB\Point;
use App\Entity\AuditableEntity;
class EntityListener class EntityListener
{ {
protected $token_storage; protected $token_storage;
@ -37,17 +39,20 @@ class EntityListener
if (isset($this->entities[$object_class])) if (isset($this->entities[$object_class]))
{ {
// get user id for logging if ($object instanceof AuditableEntity)
$user = $this->token_storage->getToken()->getUser(); {
$user_id = $user->getID(); // get user id for logging
$user = $this->token_storage->getToken()->getUser();
$user_id = $user->getID();
// get entity name // get entity name
//$obj_class = preg_replace('/.*\\\\/', '', $object_class); //$obj_class = preg_replace('/.*\\\\/', '', $object_class);
// get fields of object // get fields of object
$fields = $object->fieldDump(); $fields = $object->fieldDump();
$this->writeToLogDB($object_class, $object->getID(), 'create', $fields, $user_id); $this->writeToLogDB($object_class, $object->getID(), 'create', $fields, $user_id);
}
} }
} }
@ -78,28 +83,31 @@ class EntityListener
$entity_class = get_class($updated_entity); $entity_class = get_class($updated_entity);
if (isset($this->entities[$entity_class])) if (isset($this->entities[$entity_class]))
{ {
// get entity name if ($updated_entity instanceof AuditableEntity)
//$obj_class = preg_replace('/.*\\\\/', '', $entity_class);
$changeset = $unit_of_work->getEntityChangeSet($updated_entity);
$entity_fields = array_keys($changeset);
foreach ($entity_fields as $field)
{ {
$values = $changeset[$field]; // get entity name
//$obj_class = preg_replace('/.*\\\\/', '', $entity_class);
$old_value = $values[0]; $changeset = $unit_of_work->getEntityChangeSet($updated_entity);
$new_value = $values[1];
$field_changes[$field] = [ $entity_fields = array_keys($changeset);
'old_value' => $values[0], foreach ($entity_fields as $field)
'new_value' => $values[1], {
]; $values = $changeset[$field];
$old_value = $values[0];
$new_value = $values[1];
$field_changes[$field] = [
'old_value' => $values[0],
'new_value' => $values[1],
];
}
$fields = json_encode($field_changes);
$this->writeToLogDB($entity_class, $updated_entity->getID(), 'update', $fields, $user_id);
} }
$fields = json_encode($field_changes);
$this->writeToLogDB($entity_class, $updated_entity->getID(), 'update', $fields, $user_id);
} }
} }
@ -110,15 +118,18 @@ class EntityListener
$entity_class = get_class($deleted_entity); $entity_class = get_class($deleted_entity);
if (isset($this->entities[$entity_class])) if (isset($this->entities[$entity_class]))
{ {
// get entity name if ($deleted_entity instanceof AuditableEntity)
//$obj_class = preg_replace('/.*\\\\/', '', get_class($deleted_entity)); {
// get entity name
//$obj_class = preg_replace('/.*\\\\/', '', get_class($deleted_entity));
$deleted_id = $deleted_entity->getID(); $deleted_id = $deleted_entity->getID();
// get fields of deleted entity // get fields of deleted entity
$fields = $deleted_entity->fieldDump(); $fields = $deleted_entity->fieldDump();
$this->writeToLogDB($entity_class, $deleted_id, 'delete', $fields, $user_id); $this->writeToLogDB($entity_class, $deleted_id, 'delete', $fields, $user_id);
}
} }
} }