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. }