IBX-5385: Add option content-type to reindex command

eZ/Bundle/EzPublishCoreBundle/Command/ReindexCommand.php

@@ -128,23 +128,28 @@ protected function configure()
                 'since',
                 null,
                 InputOption::VALUE_OPTIONAL,
-                'Refresh changes since a time provided in any format understood by DateTime. Implies "no-purge", cannot be combined with "content-ids" or "subtree"'
+                'Refresh changes since a time provided in any format understood by DateTime. Implies "no-purge", cannot be combined with "content-ids", "subtree" or "content-type"'
             )->addOption(
                 'content-ids',
                 null,
                 InputOption::VALUE_OPTIONAL,
-                'Comma-separated list of content ID\'s to refresh (deleted/updated/added). Implies "no-purge", cannot be combined with "since" or "subtree"'
+                'Comma-separated list of content ID\'s to refresh (deleted/updated/added). Implies "no-purge", cannot be combined with "since", "subtree" or "content-type"'
             )->addOption(
                 'subtree',
                 null,
                 InputOption::VALUE_OPTIONAL,
-                'Location ID whose subtree will be indexed (including the Location itself). Implies "no-purge", cannot be combined with "since" or "content-ids"'
+                'Location ID whose subtree will be indexed (including the Location itself). Implies "no-purge", cannot be combined with "since", "content-ids" or "content-type"'
             )->addOption(
                 'processes',
                 null,
                 InputOption::VALUE_OPTIONAL,
                 'Number of child processes to run in parallel for iterations, if set to "auto" it will set to number of CPU cores -1, set to "1" or "0" to disable',
                 'auto'
+            )->addOption(
+                'content-type',
+                null,
+                InputOption::VALUE_REQUIRED,
+                'Content type identifier to refresh (deleted/updated/added). Implies "no-purge", cannot be combined with "since", "subtree" or "content-ids"'
             )->setHelp(
                 <<<EOT
                     The command <info>%command.name%</info> indexes the current configured database in the configured search engine index.
@@ -256,6 +261,10 @@ protected function indexIncrementally(
             $count = $this->gateway->countContentInSubtree($location->pathString);
             $generator = $this->gateway->getContentInSubtree($location->pathString, $iterationCount);
             $purge = false;
+        } elseif ($contentType = $input->getOption('content-type')) {
+            $count = $this->gateway->countContentWithContentTypeIdentifier($contentType);
+            $generator = $this->gateway->getContentWithContentTypeIdentifier($contentType, $iterationCount);
+            $purge = false;
         } else {
             $count = $this->gateway->countAllContent();
             $generator = $this->gateway->getAllContent($iterationCount);

eZ/Publish/Core/Search/Legacy/Content/IndexerGateway.php

@@ -63,6 +63,22 @@ public function countContentInSubtree(string $locationPath): int
         return (int)$query->execute()->fetchOne();
     }
 
+    public function getContentWithContentTypeIdentifier(string $contentTypeIdentifier, int $iterationCount): Generator
+    {
+        $query = $this->buildQueryForContentWithContentTypeIdentifier($contentTypeIdentifier);
+
+        yield from $this->fetchIteration($query->execute(), $iterationCount);
+    }
+
+    public function countContentWithContentTypeIdentifier(string $contentTypeIdentifier): int
+    {
+        $query = $this->buildCountingQuery(
+            $this->buildQueryForContentWithContentTypeIdentifier($contentTypeIdentifier)
+        );
+
+        return (int)$query->execute()->fetchOne();
+    }
+
     public function getAllContent(int $iterationCount): Generator
     {
         $query = $this->buildQueryForAllContent();
@@ -101,6 +117,18 @@ private function buildQueryForContentInSubtree(string $locationPath): QueryBuild
             ->setParameter('path', $locationPath . '%', ParameterType::STRING);
     }
 
+    private function buildQueryForContentWithContentTypeIdentifier(string $contentTypeIdentifier): QueryBuilder
+    {
+        return $this->connection->createQueryBuilder()
+            ->select('DISTINCT c.id')
+            ->from('ezcontentobject', 'c')
+            ->innerJoin('c', 'ezcontentclass', 'cc', 'cc.id = c.contentclass_id')
+            ->where('c.status = :status')
+            ->andWhere('cc.identifier LIKE :identifier')
+            ->setParameter('status', ContentInfo::STATUS_PUBLISHED, ParameterType::INTEGER)
+            ->setParameter('identifier', $contentTypeIdentifier, ParameterType::STRING);
+    }
+
     private function buildQueryForAllContent(): QueryBuilder
     {
         return $this->connection->createQueryBuilder()

eZ/Publish/SPI/Search/Content/IndexerGateway.php

@@ -40,6 +40,18 @@ public function getContentInSubtree(string $locationPath, int $iterationCount):
      */
     public function countContentInSubtree(string $locationPath): int;
 
+    /**
+     * @throws \Doctrine\DBAL\Exception
+     *
+     * @return \Generator list of Content IDs for each iteration
+     */
+    public function getContentWithContentTypeIdentifier(string $contentTypeIdentifier, int $iterationCount): Generator;
+
+    /**
+     * @throws \Doctrine\DBAL\Exception
+     */
+    public function countContentWithContentTypeIdentifier(string $contentTypeIdentifier): int;
+
     /**
      * @throws \Doctrine\DBAL\Exception
      *