vendor/ibexa/activity-log/src/bundle/EventSubscriber/PostActivityListLoad/ContentActivity.php line 42

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Bundle\ActivityLog\EventSubscriber\PostActivityListLoad;
  11. use Ibexa\Contracts\ActivityLog\Event\PostActivityGroupListLoadEvent;
  12. use Ibexa\Contracts\Core\Repository\ContentService;
  13. use Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException;
  14. use Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException;
  15. use Ibexa\Contracts\Core\Repository\Values\Content\Content;
  16. use Psr\Log\LoggerAwareInterface;
  17. use Psr\Log\LoggerAwareTrait;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. final class ContentActivity implements EventSubscriberInterface, LoggerAwareInterface
  21. {
  22.     use LoggerAwareTrait;
  24.     private ContentService $contentService;
  26.     public function __construct(
  27.         ContentService $contentService
  28.     ) {
  29.         $this->contentService = $contentService;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             PostActivityGroupListLoadEvent::class => ['loadContent'],
  36.         ];
  37.     }
  39.     /**
  40.      * TODO: Handle lists in a more performant way.
  41.      */
  42.     public function loadContent(PostActivityGroupListLoadEvent $event): void
  43.     {
  44.         // We will store Content IDs that we have attempted to load to prevent loading the same object more than once.
  45.         $visitedIds = [];
  46.         $list = $event->getList();
  47.         foreach ($list as $group) {
  48.             foreach ($group->getActivityLogs() as $log) {
  49.                 if ($log->getObjectClass() !== Content::class) {
  50.                     continue;
  51.                 }
  53.                 $contentId = $log->getObjectId();
  54.                 try {
  55.                     if (!array_key_exists($contentId, $visitedIds)) {
  56.                         $visitedIds[$contentId] = $this->loadContentById($contentId);
  57.                     }
  59.                     if ($visitedIds[$contentId] === null) {
  60.                         continue;
  61.                     }
  63.                     $log->setRelatedObject($visitedIds[$contentId]);
  64.                 } catch (NotFoundException|UnauthorizedException $e) {
  65.                     // Log entry contains relationship to an object that has been deleted, current user does not have
  66.                     // access to it, or is otherwise not reachable.
  67.                     $visitedIds[$contentId] = null;
  68.                 }
  69.             }
  70.         }
  71.     }
  73.     /**
  74.      * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  75.      * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  76.      */
  77.     private function loadContentById(string $contentId): ?Content
  78.     {
  79.         if (is_numeric($contentId) && $contentId == (int)$contentId) {
  80.             return $this->contentService->loadContent((int)$contentId);
  81.         }
  83.         if (isset($this->logger)) {
  84.             $this->logger->warning(sprintf(
  85.                 'Failed to load Content using ID: "%s". Content ID has to be an integerish value.',
  86.                 $contentId,
  87.             ));
  88.         }
  90.         return null;
  91.     }
  92. }