IBX-2000: Added URL Wildcard Query with Criterion and Sort

eZ/Publish/API/Repository/URLWildcardService.php

@@ -11,6 +11,8 @@
 use eZ\Publish\API\Repository\Values\Content\URLWildcard;
 use eZ\Publish\API\Repository\Values\Content\URLWildcardTranslationResult;
 use eZ\Publish\API\Repository\Values\Content\URLWildcardUpdateStruct;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\SearchResult;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\URLWildcardQuery;
 
 /**
  * URLAlias service.
@@ -84,6 +86,13 @@ public function load(int $id): UrlWildcard;
      */
     public function loadAll(int $offset = 0, int $limit = -1): iterable;
 
+    /**
+     * Find URLWildcards.
+     *
+     * @throws \eZ\Publish\API\Repository\Exceptions\UnauthorizedException
+     */
+    public function findUrlWildcards(URLWildcardQuery $query): SearchResult;
+
     /**
      * Translates an url to an existing uri resource based on the
      * source/destination patterns of the url wildcard.

eZ/Publish/Core/Persistence/Cache/UrlWildcardHandler.php

@@ -10,6 +10,7 @@
 use eZ\Publish\Core\Base\Exceptions\NotFoundException;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard\Handler as UrlWildcardHandlerInterface;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\URLWildcardQuery;
 
 class UrlWildcardHandler extends AbstractHandler implements UrlWildcardHandlerInterface
 {
@@ -132,6 +133,16 @@ public function loadAll($offset = 0, $limit = -1)
         return $this->persistenceHandler->urlWildcardHandler()->loadAll($offset, $limit);
     }
 
+    /**
+     * @see \eZ\Publish\SPI\Persistence\Content\UrlWildcard\Handler::find
+     */
+    public function find(URLWildcardQuery $query): array
+    {
+        $this->logger->logCall(__METHOD__, ['query' => $query]);
+
+        return $this->persistenceHandler->urlWildcardHandler()->find($query);
+    }
+
     /**
      * @see \eZ\Publish\SPI\Persistence\Content\UrlWildcard\Handler::lookup
      */

eZ/Publish/Core/Persistence/Legacy/Content/UrlWildcard/Gateway.php

@@ -9,6 +9,7 @@
 namespace eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard;
 
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\Query\Criterion;
 
 /**
  * UrlWildcard Gateway.
@@ -50,6 +51,19 @@ abstract public function loadUrlWildcardData(int $id): array;
      */
     abstract public function loadUrlWildcardsData(int $offset = 0, int $limit = -1): array;
 
+    /**
+     * Selects URLWildcards matching specified criteria.
+     *
+     * @return array{
+     *     "rows": mixed,
+     *     "count": int|null,
+     * }
+     *
+     * @throws \eZ\Publish\API\Repository\Exceptions\InvalidArgumentException
+     * @throws \eZ\Publish\API\Repository\Exceptions\NotImplementedException if Criterion is not applicable to its target
+     */
+    abstract public function find(Criterion $criterion, int $offset, int $limit, array $sortClauses = [], bool $doCount = true): array;
+
     /**
      * Load the UrlWildcard by source url $sourceUrl.
      */

eZ/Publish/Core/Persistence/Legacy/Content/UrlWildcard/Gateway/DoctrineDatabase.php

@@ -12,8 +12,13 @@
 use Doctrine\DBAL\FetchMode;
 use Doctrine\DBAL\ParameterType;
 use Doctrine\DBAL\Query\QueryBuilder;
+use eZ\Publish\Core\Base\Exceptions\InvalidArgumentException;
 use eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\Query\Criterion;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\Query\SortClause;
+use Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter;
+use RuntimeException;
 
 /**
  * URL wildcard gateway implementation using the Doctrine database.
@@ -33,9 +38,22 @@ final class DoctrineDatabase extends Gateway
     /** @var \Doctrine\DBAL\Connection */
     private $connection;
 
-    public function __construct(Connection $connection)
+    /**
+     * Criteria converter.
+     *
+     * @var \Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter
+     */
+    protected $criteriaConverter;
+
+    public const SORT_DIRECTION_MAP = [
+        SortClause::SORT_ASC => 'ASC',
+        SortClause::SORT_DESC => 'DESC',
+    ];
+
+    public function __construct(Connection $connection, CriteriaConverter $criteriaConverter)
     {
         $this->connection = $connection;
+        $this->criteriaConverter = $criteriaConverter;
     }
 
     public function insertUrlWildcard(UrlWildcard $urlWildcard): int
@@ -159,6 +177,39 @@ public function loadUrlWildcardsData(int $offset = 0, int $limit = -1): array
         return $stmt->fetchAll(FetchMode::ASSOCIATIVE);
     }
 
+    public function find(Criterion $criterion, int $offset, int $limit, array $sortClauses = [], bool $doCount = true): array
+    {
+        $count = $doCount ? $this->doCount($criterion) : null;
+        if (!$doCount && $limit === 0) {
+            throw new RuntimeException('Invalid query. Cannot disable count and request 0 items at the same time');
+        }
+
+        if ($limit === 0 || ($count !== null && $count <= $offset)) {
+            return [
+                'count' => $count,
+                'rows' => [],
+            ];
+        }
+
+        $query = $this->buildLoadUrlWildcardDataQuery();
+        $query
+            ->where($this->criteriaConverter->convertCriteria($query, $criterion))
+            ->setMaxResults($limit > 0 ? $limit : PHP_INT_MAX)
+            ->setFirstResult($offset);
+
+        foreach ($sortClauses as $sortClause) {
+            $column = sprintf('%s', $sortClause->target);
+            $query->addOrderBy($column, $this->getQuerySortingDirection($sortClause->direction));
+        }
+
+        $statement = $query->execute();
+
+        return [
+            'count' => $count,
+            'rows' => $statement->fetchAllAssociative(),
+        ];
+    }
+
     public function loadUrlWildcardBySourceUrl(string $sourceUrl): array
     {
         $query = $this->buildLoadUrlWildcardDataQuery();
@@ -186,6 +237,35 @@ public function countAll(): int
         return (int) $query->execute()->fetchColumn();
     }
 
+    /**
+     * @throws \eZ\Publish\API\Repository\Exceptions\NotImplementedException
+     */
+    protected function doCount(Criterion $criterion): int
+    {
+        $query = $this->connection->createQueryBuilder();
+        $query
+            ->select('COUNT(DISTINCT url_wildcard.id)')
+            ->from(self::URL_WILDCARD_TABLE, 'url_wildcard')
+            ->where($this->criteriaConverter->convertCriteria($query, $criterion));
+
+        return (int)$query->execute()->fetchColumn();
+    }
+
+    private function getQuerySortingDirection(string $direction): string
+    {
+        if (!isset(self::SORT_DIRECTION_MAP[$direction])) {
+            throw new InvalidArgumentException(
+                '$sortClause->direction',
+                sprintf(
+                    'Unsupported "%s" sorting directions, use one of the SortClause::SORT_* constants instead',
+                    $direction
+                )
+            );
+        }
+
+        return self::SORT_DIRECTION_MAP[$direction];
+    }
+
     private function trimUrl(string $url): string
     {
         return trim($url, '/');

eZ/Publish/Core/Persistence/Legacy/Content/UrlWildcard/Gateway/ExceptionConversion.php

@@ -12,6 +12,7 @@
 use eZ\Publish\Core\Base\Exceptions\DatabaseException;
 use eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\Query\Criterion;
 use PDOException;
 
 /**
@@ -90,6 +91,15 @@ public function loadUrlWildcardsData(int $offset = 0, int $limit = -1): array
         }
     }
 
+    public function find(Criterion $criterion, int $offset, int $limit, array $sortClauses = [], bool $doCount = true): array
+    {
+        try {
+            return $this->innerGateway->find($criterion, $offset, $limit, $sortClauses, $doCount);
+        } catch (DBALException | PDOException $e) {
+            throw DatabaseException::wrap($e);
+        }
+    }
+
     public function loadUrlWildcardBySourceUrl(string $sourceUrl): array
     {
         try {

eZ/Publish/Core/Persistence/Legacy/Content/UrlWildcard/Handler.php

@@ -9,6 +9,7 @@
 use eZ\Publish\Core\Base\Exceptions\NotFoundException;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard\Handler as BaseUrlWildcardHandler;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\URLWildcardQuery;
 
 /**
  * The UrlWildcard Handler provides nice urls with wildcards management.
@@ -139,6 +140,25 @@ public function loadAll($offset = 0, $limit = -1)
         );
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function find(URLWildcardQuery $query): array
+    {
+        $results = $this->gateway->find(
+            $query->filter,
+            $query->offset,
+            $query->limit,
+            $query->sortClauses,
+            $query->performCount
+        );
+
+        return [
+            'count' => $results['count'],
+            'items' => $this->mapper->extractUrlWildcardsFromRows($results['rows']),
+        ];
+    }
+
     /**
      * Performs lookup for given URL.
      *

eZ/Publish/Core/Persistence/Legacy/Tests/Content/UrlWildcard/Gateway/DoctrineDatabaseTest.php

@@ -11,6 +11,8 @@
 use eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway\DoctrineDatabase;
 use eZ\Publish\Core\Persistence\Legacy\Tests\TestCase;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
+use Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter;
+use Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchAll;
 
 /**
  * Test case for eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway\DoctrineDatabase.
@@ -178,7 +180,8 @@ public function testDeleteUrlWildcard()
     protected function getGateway(): DoctrineDatabase
     {
         if (!isset($this->gateway)) {
-            $this->gateway = new DoctrineDatabase($this->getDatabaseConnection());
+            $criteriaConverter = new CriteriaConverter([new MatchAll()]);
+            $this->gateway = new DoctrineDatabase($this->getDatabaseConnection(), $criteriaConverter);
         }
 
         return $this->gateway;

eZ/Publish/Core/Persistence/Legacy/Tests/Content/UrlWildcard/UrlWildcardHandlerTest.php

@@ -13,6 +13,8 @@
 use eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Mapper;
 use eZ\Publish\Core\Persistence\Legacy\Tests\TestCase;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard;
+use Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter;
+use Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchAll;
 
 /**
  * Test case for UrlWildcard Handler.
@@ -245,7 +247,8 @@ public function testLoadAllWithOffsetAndLimit()
     protected function getHandler(): UrlWildcard\Handler
     {
         if (!isset($this->urlWildcardHandler)) {
-            $this->gateway = new DoctrineDatabase($this->getDatabaseConnection());
+            $criteriaConverter = new CriteriaConverter([new MatchAll()]);
+            $this->gateway = new DoctrineDatabase($this->getDatabaseConnection(), $criteriaConverter);
             $this->mapper = new Mapper();
 
             $this->urlWildcardHandler = new Handler(

eZ/Publish/Core/Repository/URLWildcardService.php

@@ -17,9 +17,12 @@
 use eZ\Publish\API\Repository\Values\Content\URLWildcardUpdateStruct;
 use eZ\Publish\Core\Base\Exceptions\ContentValidationException;
 use eZ\Publish\Core\Base\Exceptions\InvalidArgumentException;
+use eZ\Publish\Core\Base\Exceptions\InvalidArgumentValue;
 use eZ\Publish\Core\Base\Exceptions\UnauthorizedException;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard as SPIUrlWildcard;
 use eZ\Publish\SPI\Persistence\Content\UrlWildcard\Handler;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\SearchResult;
+use Ibexa\Contracts\Core\Repository\Values\Content\URLWildcard\URLWildcardQuery;
 
 /**
  * URLAlias service.
@@ -207,6 +210,32 @@ public function loadAll(int $offset = 0, int $limit = -1): iterable
         return $urlWildcards;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function findUrlWildcards(URLWildcardQuery $query): SearchResult
+    {
+        if ($query->offset !== null && !is_numeric($query->offset)) {
+            throw new InvalidArgumentValue('offset', $query->offset);
+        }
+
+        if ($query->limit !== null && !is_numeric($query->limit)) {
+            throw new InvalidArgumentValue('limit', $query->limit);
+        }
+
+        $results = $this->urlWildcardHandler->find($query);
+
+        $items = [];
+        foreach ($results['items'] as $urlWildcard) {
+            $items[] = $this->buildUrlWildcardDomainObject($urlWildcard);
+        }
+
+        return new SearchResult([
+            'totalCount' => $results['count'],
+            'items' => $items,
+        ]);
+    }
+
     /**
      * {@inheritDoc}
      */

eZ/Publish/Core/settings/storage_engines/legacy/url_wildcard.yml

@@ -3,6 +3,7 @@ services:
         class: eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway\DoctrineDatabase
         arguments:
             - '@ezpublish.api.storage_engine.legacy.connection'
+            - '@Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter'
 
     ezpublish.persistence.legacy.url_wildcard.gateway.exception_conversion:
         class: eZ\Publish\Core\Persistence\Legacy\Content\UrlWildcard\Gateway\ExceptionConversion
@@ -22,3 +23,6 @@ services:
             - "@ezpublish.persistence.legacy.url_wildcard.gateway"
             - "@ezpublish.persistence.legacy.url_wildcard.mapper"
         lazy: true
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter:
+        class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriteriaConverter

eZ/Publish/Core/settings/storage_engines/legacy/url_wildcard_criterion_handlers.yml

@@ -0,0 +1,33 @@
+services:
+    ibexa.persistence.legacy.url_wildcard.criterion_handler.base:
+        abstract: true
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalAnd:
+       parent: ibexa.persistence.legacy.url_wildcard.criterion_handler.base
+       class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalAnd
+       tags:
+           - { name: ibexa.storage.legacy.url_wildcard.criterion.handler }
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalOr:
+       parent: ibexa.persistence.legacy.url_wildcard.criterion_handler.base
+       class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalOr
+       tags:
+           - { name: ibexa.storage.legacy.url_wildcard.criterion.handler }
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalNot:
+       parent: ibexa.persistence.legacy.url_wildcard.criterion_handler.base
+       class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\LogicalNot
+       tags:
+           - { name: ibexa.storage.legacy.url_wildcard.criterion.handler }
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchAll:
+       parent: ibexa.persistence.legacy.url_wildcard.criterion_handler.base
+       class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchAll
+       tags:
+           - { name: ibexa.storage.legacy.url_wildcard.criterion.handler }
+
+    Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchNone:
+       parent: ibexa.persistence.legacy.url_wildcard.criterion_handler.base
+       class: Ibexa\Core\Persistence\Legacy\Content\URLWildcard\Query\CriterionHandler\MatchNone
+       tags:
+           - { name: ibexa.storage.legacy.url_wildcard.criterion.handler }