IBX-2823: Added loadRelation method

src/contracts/Persistence/Content/Handler.php

@@ -261,18 +261,24 @@ public function copy($contentId, $versionNo = null, $newOwnerId = null);
      */
     public function addRelation(RelationCreateStruct $createStruct);
 
+    /**
+     * Load a relation by $relationId.
+     */
+    public function loadRelation(int $relationId): Relation;
+
     /**
      * Removes a relation by relation Id.
      *
      * @todo Should the existence verifications happen here or is this supposed to be handled at a higher level?
      *
-     * @param mixed $relationId
+     * @param int $relationId
      * @param int $type {@see \Ibexa\Contracts\Core\Repository\Values\Content\Relation::COMMON,
      *                 \Ibexa\Contracts\Core\Repository\Values\Content\Relation::EMBED,
      *                 \Ibexa\Contracts\Core\Repository\Values\Content\Relation::LINK,
      *                 \Ibexa\Contracts\Core\Repository\Values\Content\Relation::FIELD}
+     * @param ?int $destinationContentId Content id to invalidate cache tag related to content reverse relations count
      */
-    public function removeRelation($relationId, $type);
+    public function removeRelation($relationId, $type, ?int $destinationContentId = null);
 
     /**
      * Loads relations from $sourceContentId. Optionally, loads only those with $type and $sourceContentVersionNo.

src/lib/Persistence/Cache/ContentHandler.php

@@ -11,6 +11,7 @@
 use Ibexa\Contracts\Core\Persistence\Content\CreateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\Handler as ContentHandlerInterface;
 use Ibexa\Contracts\Core\Persistence\Content\MetadataUpdateStruct;
+use Ibexa\Contracts\Core\Persistence\Content\Relation;
 use Ibexa\Contracts\Core\Persistence\Content\Relation\CreateStruct as RelationCreateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\UpdateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\VersionInfo;
@@ -30,6 +31,8 @@ class ContentHandler extends AbstractInMemoryPersistenceHandler implements Conte
     private const CONTENT_VERSION_LIST_IDENTIFIER = 'content_version_list';
     private const CONTENT_VERSION_INFO_IDENTIFIER = 'content_version_info';
     private const CONTENT_VERSION_IDENTIFIER = 'content_version';
+    private const CONTENT_REVERSE_RELATIONS_COUNT_IDENTIFIER = 'content_reverse_relations_count';
+    private const RELATION_IDENTIFIER = 'relation';
 
     public const ALL_TRANSLATIONS_KEY = '0';
 
@@ -433,16 +436,68 @@ public function addRelation(RelationCreateStruct $relation)
     {
         $this->logger->logCall(__METHOD__, ['struct' => $relation]);
 
+        $this->cache->invalidateTags([
+            $this->cacheIdentifierGenerator->generateTag(
+                self::CONTENT_IDENTIFIER,
+                [$relation->destinationContentId]
+            ),
+        ]);
+
         return $this->persistenceHandler->contentHandler()->addRelation($relation);
     }
 
     /**
      * {@inheritdoc}
      */
-    public function removeRelation($relationId, $type)
+    public function removeRelation($relationId, $type, ?int $destinationContentId = null): void
     {
+        if (null === $destinationContentId) {
+            @trigger_error('Expecting to pass $destinationContentId argument since version 4.1.5', E_USER_DEPRECATED);
+        }
+
         $this->logger->logCall(__METHOD__, ['relation' => $relationId, 'type' => $type]);
-        $this->persistenceHandler->contentHandler()->removeRelation($relationId, $type);
+
+        $this->cache->invalidateTags([
+            $this->cacheIdentifierGenerator->generateTag(
+                self::CONTENT_IDENTIFIER,
+                [$destinationContentId ?? $this->loadRelation($relationId)->destinationContentId]
+            ),
+            $this->cacheIdentifierGenerator->generateTag(
+                self::RELATION_IDENTIFIER,
+                [$relationId]
+            ),
+        ]);
+
+        $this->persistenceHandler->contentHandler()->removeRelation($relationId, $type, $destinationContentId);
+    }
+
+    public function loadRelation(int $relationId): Relation
+    {
+        $cacheItem = $this->cache->getItem(
+            $this->cacheIdentifierGenerator->generateKey(
+                self::RELATION_IDENTIFIER,
+                [$relationId],
+                true
+            )
+        );
+
+        if ($cacheItem->isHit()) {
+            $this->logger->logCacheHit(['relationId' => $relationId]);
+
+            return $cacheItem->get();
+        }
+
+        $this->logger->logCacheMiss(['relationId' => $relationId]);
+        $relation = $this->persistenceHandler->contentHandler()->loadRelation($relationId);
+        $cacheItem->set($relation);
+        $tags = [
+            $this->cacheIdentifierGenerator->generateTag(self::RELATION_IDENTIFIER, [$relationId]),
+        ];
+
+        $cacheItem->tag($tags);
+        $this->cache->save($cacheItem);
+
+        return $relation;
     }
 
     /**
@@ -467,9 +522,31 @@ public function loadRelations($sourceContentId, $sourceContentVersionNo = null,
      */
     public function countReverseRelations(int $destinationContentId, ?int $type = null): int
     {
-        $this->logger->logCall(__METHOD__, ['content' => $destinationContentId, 'type' => $type]);
+        $cacheItem = $this->cache->getItem(
+            $this->cacheIdentifierGenerator->generateKey(
+                self::CONTENT_REVERSE_RELATIONS_COUNT_IDENTIFIER,
+                [$destinationContentId],
+                true
+            )
+        );
+
+        if ($cacheItem->isHit()) {
+            $this->logger->logCacheHit(['content' => $destinationContentId]);
+
+            return $cacheItem->get();
+        }
+
+        $this->logger->logCacheMiss(['content' => $destinationContentId]);
+        $reverseRelationsCount = $this->persistenceHandler->contentHandler()->countReverseRelations($destinationContentId, $type);
+        $cacheItem->set($reverseRelationsCount);
+        $tags = [
+            $this->cacheIdentifierGenerator->generateTag(self::CONTENT_IDENTIFIER, [$destinationContentId]),
+        ];
+
+        $cacheItem->tag($tags);
+        $this->cache->save($cacheItem);
 
-        return $this->persistenceHandler->contentHandler()->countReverseRelations($destinationContentId, $type);
+        return $reverseRelationsCount;
     }
 
     /**

src/lib/Persistence/Legacy/Content/Gateway.php

@@ -13,6 +13,7 @@
 use Ibexa\Contracts\Core\Persistence\Content\Relation\CreateStruct as RelationCreateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\UpdateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\VersionInfo;
+use Ibexa\Contracts\Core\Repository\Values\Content\Relation;
 
 /**
  * Base class for content gateways.
@@ -395,6 +396,13 @@ abstract public function deleteRelation(int $relationId, int $type): void;
      */
     abstract public function insertRelation(RelationCreateStruct $createStruct): int;
 
+    /**
+     * Load Relation object.
+     *
+     * @see \Ibexa\Contracts\Core\Persistence\Content\Relation
+     */
+    abstract public function loadRelation(int $relationId): array;
+
     /**
      * Return all Content IDs for the given $contentTypeId.
      *

src/lib/Persistence/Legacy/Content/Gateway/DoctrineDatabase.php

@@ -25,12 +25,14 @@
 use Ibexa\Contracts\Core\Repository\Values\Content\Relation;
 use Ibexa\Contracts\Core\Repository\Values\Content\VersionInfo as APIVersionInfo;
 use Ibexa\Core\Base\Exceptions\BadStateException;
+use Ibexa\Core\Base\Exceptions\NotFoundException;
 use Ibexa\Core\Base\Exceptions\NotFoundException as NotFound;
 use Ibexa\Core\Persistence\Legacy\Content\Gateway;
 use Ibexa\Core\Persistence\Legacy\Content\Gateway\DoctrineDatabase\QueryBuilder;
 use Ibexa\Core\Persistence\Legacy\Content\Language\MaskGenerator as LanguageMaskGenerator;
 use Ibexa\Core\Persistence\Legacy\Content\StorageFieldValue;
 use Ibexa\Core\Persistence\Legacy\SharedGateway\Gateway as SharedGateway;
+use LogicException;
 
 /**
  * Doctrine database based content gateway.
@@ -1609,6 +1611,35 @@ public function insertRelation(RelationCreateStruct $createStruct): int
         return (int)$this->connection->lastInsertId(self::CONTENT_RELATION_SEQ);
     }
 
+    /**
+     * @throws \Doctrine\DBAL\Driver\Exception
+     * @throws \Doctrine\DBAL\Exception
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
+     */
+    public function loadRelation(int $relationId): array
+    {
+        $query = $this->queryBuilder->createRelationFindQueryBuilder();
+        $expr = $query->expr();
+
+        $query
+            ->andWhere(
+                $expr->eq('id', ':relationId')
+            )
+            ->setParameter('relationId', $relationId, ParameterType::INTEGER);
+
+        $result = $query->execute()->fetchAllAssociative();
+        $resultCount = count($result);
+        if ($resultCount === 0) {
+            throw new NotFoundException('Relation', $relationId);
+        }
+
+        if ($resultCount > 1) {
+            throw new LogicException('More then one row found for the relation id: ' . $relationId);
+        }
+
+        return current($result);
+    }
+
     public function deleteRelation(int $relationId, int $type): void
     {
         // Legacy Storage stores COMMON, LINK and EMBED types using bitmask, therefore first load

src/lib/Persistence/Legacy/Content/Gateway/ExceptionConversion.php

@@ -446,6 +446,15 @@ public function insertRelation(RelationCreateStruct $struct): int
         }
     }
 
+    public function loadRelation(int $relationId): array
+    {
+        try {
+            return $this->innerGateway->loadRelation($relationId);
+        } catch (DBALException | PDOException $e) {
+            throw DatabaseException::wrap($e);
+        }
+    }
+
     public function getContentIdsByContentTypeId($contentTypeId): array
     {
         try {

src/lib/Persistence/Legacy/Content/Handler.php

@@ -12,6 +12,7 @@
 use Ibexa\Contracts\Core\Persistence\Content\Field;
 use Ibexa\Contracts\Core\Persistence\Content\Handler as BaseContentHandler;
 use Ibexa\Contracts\Core\Persistence\Content\MetadataUpdateStruct;
+use Ibexa\Contracts\Core\Persistence\Content\Relation;
 use Ibexa\Contracts\Core\Persistence\Content\Relation\CreateStruct as RelationCreateStruct;
 use Ibexa\Contracts\Core\Persistence\Content\Type\Handler as ContentTypeHandler;
 use Ibexa\Contracts\Core\Persistence\Content\UpdateStruct;
@@ -776,6 +777,16 @@ public function addRelation(RelationCreateStruct $createStruct)
         return $relation;
     }
 
+    /**
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
+     */
+    public function loadRelation(int $relationId): Relation
+    {
+        return $this->mapper->extractRelationFromRow(
+            $this->contentGateway->loadRelation($relationId)
+        );
+    }
+
     /**
      * Removes a relation by relation Id.
      *
@@ -787,7 +798,7 @@ public function addRelation(RelationCreateStruct $createStruct)
      *                 \Ibexa\Contracts\Core\Repository\Values\Content\Relation::LINK,
      *                 \Ibexa\Contracts\Core\Repository\Values\Content\Relation::FIELD}
      */
-    public function removeRelation($relationId, $type)
+    public function removeRelation($relationId, $type, ?int $destinationContentId = null): void
     {
         $this->contentGateway->deleteRelation($relationId, $type);
     }

src/lib/Persistence/Legacy/Content/Mapper.php

@@ -542,7 +542,7 @@ public function extractRelationsFromRows(array $rows)
      *
      * @return \Ibexa\Contracts\Core\Persistence\Content\Relation
      */
-    protected function extractRelationFromRow(array $row)
+    public function extractRelationFromRow(array $row)
     {
         $relation = new Relation();
         $relation->id = (int)$row['ezcontentobject_link_id'];

src/lib/Repository/ContentService.php

@@ -2128,7 +2128,8 @@ public function deleteRelation(APIVersionInfo $sourceVersion, ContentInfo $desti
                 if ($spiRelation->destinationContentId == $destinationContent->id) {
                     $this->persistenceHandler->contentHandler()->removeRelation(
                         $spiRelation->id,
-                        APIRelation::COMMON
+                        APIRelation::COMMON,
+                        $spiRelation->destinationContentId
                     );
                 }
             }

src/lib/Repository/Helper/RelationProcessor.php

@@ -192,15 +192,17 @@ public function processFieldRelations(
                         foreach ($relationEntry as $relation) {
                             $this->persistenceHandler->contentHandler()->removeRelation(
                                 $relation->id,
-                                $relationType
+                                $relationType,
+                                $relation->destinationContentInfo->id
                             );
                         }
                         break;
                     case Relation::LINK:
                     case Relation::EMBED:
                         $this->persistenceHandler->contentHandler()->removeRelation(
                             $relationEntry->id,
-                            $relationType
+                            $relationType,
+                            $relationEntry->destinationContentInfo->id
                         );
                 }
             }

src/lib/Resources/settings/storage_engines/cache.yml

@@ -47,6 +47,7 @@ parameters:
         notification_count: 'nc-%s'
         notification_pending_count: 'npc-%s'
         policy: 'p-%s'
+        relation: 're-%s'
         role: 'r-%s'
         role_assignment: 'ra-%s'
         role_assignment_group_list: 'ragl-%s'
@@ -114,6 +115,7 @@ parameters:
         content_info: 'ci-%s'
         content_info_by_remote_id: 'cibri-%s'
         content_locations: 'cl-%s'
+        content_reverse_relations_count: 'crrc-%s'
         content_version_info: 'cvi-%s'
         content_version_list: 'c-%s-vl'
         content_version: 'c-%%s-v-%%s'
@@ -141,6 +143,7 @@ parameters:
         notification_count: 'nc-%s'
         notification_pending_count: 'npc-%s'
         policy: 'p-%s'
+        relation: 're-%s'
         role: 'r-%s'
         role_assignment: 'ra-%s'
         role_assignment_group_list: 'ragl-%s'