src/Cms/LogBundle/Service/FeedingService.php line 128

Open in your IDE?
  1. <?php
  3. namespace Cms\LogBundle\Service;
  5. use Cms\CoreBundle\Service\ContextManager;
  6. use Cms\CoreBundle\Util\DateTimeUtils;
  7. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  8. use Cms\LogBundle\Entity\RecentFeed;
  9. use Cms\ModuleBundle\Entity\Draft;
  10. use Cms\ModuleBundle\Entity\ModuleEntity;
  11. use Cms\ModuleBundle\Entity\Proxy;
  12. use DateTime;
  13. use Platform\SecurityBundle\Entity\Identity\Account;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. final class FeedingService implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var array|RecentFeed[]
  21.      */
  22.     protected $entries = [];
  24.     /**
  25.      * @var EntityManager
  26.      */
  27.     protected $em;
  29.     /**
  30.      * @var ContextManager
  31.      */
  32.     protected $cm;
  34.     /**
  35.      * @param EntityManager $em
  36.      * @param ContextManager $cm
  37.      */
  38.     public function __construct(EntityManager $em, ContextManager $cm)
  39.     {
  40.         $this->em = $em;
  41.         $this->cm = $cm;
  42.     }
  44.     /**
  45.      * {@inheritdoc}
  46.      */
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         return [
  50.             KernelEvents::TERMINATE => ['onKernelTerminate'],
  51.         ];
  52.     }
  54.     /**
  55.      * @param ModuleEntity $entity
  56.      * @param DateTime|null $timestamp
  57.      * @param Account|null $account
  58.      * @return $this
  59.      */
  60.     public function log(ModuleEntity $entity, ?DateTime $timestamp = null, ?Account $account = null): self
  61.     {
  62.         // get the proxy for the entity that we have
  63.         $proxy = null;
  64.         switch (true) {
  65.             case $entity instanceof Proxy:
  66.                 $proxy = $entity;
  67.                 break;
  68.             case $entity instanceof Draft:
  69.                 $proxy = $entity->getProxy();
  70.                 break;
  71.         }
  72.         if ( ! $proxy instanceof Proxy) {
  73.             throw new \Exception();
  74.         }
  76.         // get the currently logged in, effective, user if no account was given specifically
  77.         if (empty($account)) {
  78.             $account = $this->cm->getGlobalContext()->getEffectiveAccount();
  79.         }
  81.         // if the user is not set, we want to skip this
  82.         if ( ! empty($account)) {
  83.             // try to find the existing log, create a new one if not
  84.             $entry = $this->em->getRepository(RecentFeed::class)->findOneByAccountAndProxy($account, $proxy);
  85.             if (empty($entry)) {
  86.                 $entry = (new RecentFeed())
  87.                     ->setAccount($account)
  88.                     ->setProxy($proxy);
  89.             }
  91.             // save the name
  92.             $entry->setName($proxy->getData()->ui());
  94.             // need to force things when given
  95.             if ( ! $entry->isCreated()) {
  96.                 $entry
  97.                     ->autoCreatedBy(false)
  98.                     ->setCreatedBy($account, false);
  99.                 if ( ! empty($timestamp)) {
  100.                     $entry
  101.                         ->autoCreatedAt(false)
  102.                         ->setCreatedAt($timestamp, false);
  103.                 }
  104.             } else {
  105.                 $entry
  106.                     ->autoUpdatedBy(false)
  107.                     ->setUpdatedBy($account, false);
  108.                 if ( ! empty($timestamp)) {
  109.                     $entry
  110.                         ->autoUpdatedAt(false)
  111.                         ->setUpdatedAt($timestamp, false);
  112.                 }
  113.             }
  115.             // need to touch the entity in some way to force it to update in case all other data is the same
  116.             $entry->setChecksum(DateTimeUtils::now()->getTimestamp());
  118.             // spool the entry
  119.             $this->entries[] = $entry;
  120.         }
  122.         return $this;
  123.     }
  125.     /**
  126.      *
  127.      */
  128.     public function onKernelTerminate(): void
  129.     {
  130.         if ( ! empty($this->entries)) {
  131.             $this->em->saveAll($this->entries);
  132.             $this->entries = [];
  133.         }
  134.     }
  135. }