[task] #91. Fix IndexHandler Contract in the Implementation

magento · Oct 1, 2017 · 5b0be00 · 5b0be00
1 parent 3ae2cc3
commit 5b0be00
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/app/code/Magento/Inventory/Indexer/StockItem/IndexHandler.php b/app/code/Magento/Inventory/Indexer/StockItem/IndexHandler.php
@@ -58,22 +58,21 @@ public function __construct(
     /**
      * @inheritdoc
      */
-    public function saveIndex(IndexName $indexName, \Traversable $documents)
+    public function saveIndex(IndexName $indexName, \Traversable $documents, string $connectionName)
     {
+        $connection = $this->resourceConnection->getConnection($connectionName);
         $tableName = $this->indexNameResolver->resolveName($indexName);
 
         $columns = [IndexStructure::SKU, IndexStructure::QUANTITY];
         foreach ($this->batch->getItems($documents, $this->batchSize) as $batchDocuments) {
-            $this->resourceConnection
-                ->getConnection()
-                ->insertArray($tableName, $columns, $batchDocuments);
+            $connection->insertArray($tableName, $columns, $batchDocuments);
         }
     }
 
     /**
      * @inheritdoc
      */
-    public function cleanIndex(IndexName $indexName, \Traversable $documents, $connectionName)
+    public function cleanIndex(IndexName $indexName, \Traversable $documents, string $connectionName)
     {
         $connection = $this->resourceConnection->getConnection($connectionName);
         $tableName = $this->indexNameResolver->resolveName($indexName);