TASK: Report error in CLI output during the build command

Author: dfeyer

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

@@ -11,7 +11,9 @@
  * source code.
  */
 
+use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Indexer\Error\ErrorInterface;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Mapping\NodeTypeMappingBuilder;
+use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\ErrorHandlingService;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\IndexWorkspaceTrait;
 use TYPO3\Flow\Annotations as Flow;
 use TYPO3\Flow\Cli\CommandController;
@@ -25,6 +27,12 @@ class NodeIndexCommandController extends CommandController
 {
     use IndexWorkspaceTrait;
 
+    /**
+     * @Flow\Inject
+     * @var ErrorHandlingService
+     */
+    protected $errorHandlingService;
+
     /**
      * @Flow\Inject
      * @var \Flowpack\ElasticSearch\ContentRepositoryAdaptor\Indexer\NodeIndexer
@@ -165,13 +173,6 @@ public function buildCommand($limit = null, $update = false, $workspace = null,
             $workspace = 'live';
         }
 
-        $callback = function ($workspaceName, $indexedNodes, $dimensions) {
-            if ($dimensions === []) {
-                $this->outputLine('Workspace "' . $workspaceName . '" without dimensions done. (Indexed ' . $indexedNodes . ' nodes)');
-            } else {
-                $this->outputLine('Workspace "' . $workspaceName . '" and dimensions "' . json_encode($dimensions) . '" done. (Indexed ' . $indexedNodes . ' nodes)');
-            }
-        };
         if ($workspace === null) {
             foreach ($this->workspaceRepository->findAll() as $workspace) {
                 $count += $this->indexWorkspace($workspace->getName(), $limit, $callback);
@@ -182,7 +183,17 @@ public function buildCommand($limit = null, $update = false, $workspace = null,
 
         $this->nodeIndexingManager->flushQueues();
 
-        $this->logger->log('Done. (indexed ' . $count . ' nodes)', LOG_INFO);
+        if ($this->errorHandlingService->hasError()) {
+            $this->outputLine();
+            /** @var ErrorInterface $error */
+            foreach ($this->errorHandlingService as $error) {
+                $this->outputLine('<error>Error</error> ' . $error->message());
+            }
+            $this->outputLine();
+            $this->outputLine('<error>Check your logs for more informations</error>');
+        } else {
+            $this->logger->log('Done. (indexed ' . $count . ' nodes)', LOG_INFO);
+        }
         $this->nodeIndexer->getIndex()->refresh();
 
         // TODO: smoke tests