Merge pull request #26 from Flowpack/fix-indexing

kdambekalns · kdambekalns · commit 780c18a2534d · 2014-04-15T19:10:16.000+02:00
[BUGFIX] Direct indexing of nodes broken
diff --git a/Classes/Flowpack/ElasticSearch/ContentRepositoryAdaptor/Indexer/NodeIndexingManager.php b/Classes/Flowpack/ElasticSearch/ContentRepositoryAdaptor/Indexer/NodeIndexingManager.php
@@ -115,10 +115,10 @@ public function flushQueues() {
 		/** @var \TYPO3\TYPO3CR\Domain\Model\NodeInterface $nodeToBeIndexed  */
 		foreach ($this->nodesToBeIndexed as $nodeToBeIndexed) {
 			if (!isset($this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getContextPath()])) {
-				// No target workspace for indexing found
-				continue;
+				$this->nodeIndexer->indexNode($nodeToBeIndexed);
+			} else {
+				$this->nodeIndexer->indexNode($nodeToBeIndexed, $this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getWorkspace()->getName()]);
 			}
-			$this->nodeIndexer->indexNode($nodeToBeIndexed, $this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getWorkspace()->getName()]);
 		}
 
 		foreach ($this->nodesToBeRemoved as $nodeToBeRemoved) {

Original file line number	Diff line number	Diff line change
`@@ -115,10 +115,10 @@ public function flushQueues() {`
`115`	`115`	`/** @var \TYPO3\TYPO3CR\Domain\Model\NodeInterface $nodeToBeIndexed */`
`116`	`116`	`foreach ($this->nodesToBeIndexed as $nodeToBeIndexed) {`
`117`	`117`	`if (!isset($this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getContextPath()])) {`
`118`		`- // No target workspace for indexing found`
`119`		`- continue;`
	`118`	`+ $this->nodeIndexer->indexNode($nodeToBeIndexed);`
	`119`	`+ } else {`
	`120`	`+ $this->nodeIndexer->indexNode($nodeToBeIndexed, $this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getWorkspace()->getName()]);`
`120`	`121`	`}`
`121`		`- $this->nodeIndexer->indexNode($nodeToBeIndexed, $this->targetWorkspaceNamesForNodesToBeIndexed[$nodeToBeIndexed->getWorkspace()->getName()]);`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`foreach ($this->nodesToBeRemoved as $nodeToBeRemoved) {`