Merge pull request #142 from dfeyer/task-indexnode

TASK: Add a CLI command to index a node by identifier and workspace name

Author: dfeyer

Classes/Flowpack/ElasticSearch/ContentRepositoryAdaptor/Command/NodeIndexCommandController.php

@@ -15,6 +15,8 @@
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\IndexWorkspaceTrait;
 use TYPO3\Flow\Annotations as Flow;
 use TYPO3\Flow\Cli\CommandController;
+use TYPO3\Neos\Controller\CreateContentContextTrait;
+use TYPO3\TYPO3CR\Domain\Model\Workspace;
 
 /**
  * Provides CLI features for index handling
@@ -24,6 +26,7 @@
 class NodeIndexCommandController extends CommandController
 {
     use IndexWorkspaceTrait;
+    use CreateContentContextTrait;
 
     /**
      * @Flow\Inject
@@ -125,6 +128,63 @@ public function showMappingCommand()
         }
     }
 
+    /**
+     * Index a single node by the given identifier and workspace name
+     *
+     * @param string $identifier
+     * @param string $workspace
+     * @return void
+     */
+    public function indexNodeCommand($identifier, $workspace = null)
+    {
+        if ($workspace === null && $this->settings['indexAllWorkspaces'] === false) {
+            $workspace = 'live';
+        }
+
+        $indexNode = function ($identifier, Workspace $workspace, array $dimensions) {
+            $context = $this->createContentContext($workspace->getName(), $dimensions);
+            $node = $context->getNodeByIdentifier($identifier);
+            if ($node === null) {
+                $this->outputLine('Node with the given identifier is not found.');
+                $this->quit();
+            }
+            $this->outputLine();
+            $this->outputLine('Index node "%s" (%s)', [
+                $node->getLabel(),
+                $node->getIdentifier(),
+            ]);
+            $this->outputLine('  workspace: %s', [
+                $workspace->getName()
+            ]);
+            $this->outputLine('  node type: %s', [
+                $node->getNodeType()->getName()
+            ]);
+            $this->outputLine('  dimensions: %s', [
+                json_encode($dimensions)
+            ]);
+            $this->nodeIndexer->indexNode($node);
+        };
+
+        $indexInWorkspace = function ($identifier, Workspace $workspace) use ($indexNode) {
+            $combinations = $this->contentDimensionCombinator->getAllAllowedCombinations();
+            if ($combinations === []) {
+                $indexNode($identifier, $workspace, []);
+            } else {
+                foreach ($combinations as $combination) {
+                    $indexNode($identifier, $workspace, $combination);
+                }
+            }
+        };
+
+        if ($workspace === null) {
+            foreach ($this->workspaceRepository->findAll() as $workspace) {
+                $indexInWorkspace($identifier, $workspace);
+            }
+        } else {
+            $indexInWorkspace($identifier, $workspace);
+        }
+    }
+
     /**
      * Index all nodes by creating a new index and when everything was completed, switch the index alias.
      *