B2B-2017: [AWS S3] [Integration Tests]: Investigate Test Failures in ImportExport module

Author: oshmyheliuk

dev/tests/integration/testsuite/Magento/ImportExport/Model/Export/ConsumerTest.php

@@ -9,9 +9,8 @@
 
 use Magento\Catalog\Api\Data\ProductInterface;
 use Magento\Framework\App\Filesystem\DirectoryList;
-use Magento\Framework\File\Csv;
 use Magento\Framework\Filesystem;
-use Magento\Framework\Filesystem\Directory\Write;
+use Magento\Framework\Filesystem\Directory\WriteInterface;
 use Magento\Framework\MessageQueue\MessageEncoder;
 use Magento\Framework\ObjectManagerInterface;
 use Magento\MysqlMq\Model\Driver\Queue;
@@ -40,10 +39,7 @@ class ConsumerTest extends TestCase
     /** @var Queue */
     private $queue;
 
-    /** @var Csv */
-    private $csvReader;
-
-    /** @var Write */
+    /** @var WriteInterface */
     private $directory;
 
     /** @var string */
@@ -60,8 +56,8 @@ protected function setUp(): void
         $this->queue = $this->objectManager->create(Queue::class, ['queueName' => 'export']);
         $this->messageEncoder = $this->objectManager->get(MessageEncoder::class);
         $this->consumer = $this->objectManager->get(Consumer::class);
-        $this->directory = $this->objectManager->get(Filesystem::class)->getDirectoryWrite(DirectoryList::VAR_DIR);
-        $this->csvReader = $this->objectManager->get(Csv::class);
+        $filesystem = $this->objectManager->get(Filesystem::class);
+        $this->directory = $filesystem->getDirectoryWrite(DirectoryList::VAR_IMPORT_EXPORT);
     }
 
     /**
@@ -91,7 +87,7 @@ public function testProcess(): void
         $this->consumer->process($decodedMessage);
         $this->filePath = 'export/' . $decodedMessage->getFileName();
         $this->assertTrue($this->directory->isExist($this->filePath));
-        $data = $this->csvReader->getData($this->directory->getAbsolutePath($this->filePath));
+        $data = $this->getCsvData($this->directory->getAbsolutePath($this->filePath));
         $this->assertCount(2, $data);
         $skuPosition = $this->getSkuPosition($data);
         $this->assertNotNull($skuPosition);
@@ -117,4 +113,25 @@ private function getSkuPosition(array $csvFileData): ?int
 
         return null;
     }
+
+    /**
+     * Parse csv file and return csv data as array
+     *
+     * @param string $filePath
+     * @return array
+     * @throws \Magento\Framework\Exception\FileSystemException
+     */
+    private function getCsvData(string $filePath): array
+    {
+        $driver = $this->directory->getDriver();
+        $fileResource = $driver->fileOpen($filePath, null);
+
+        $data = [];
+        while ($rowData = $driver->fileGetCsv($fileResource, 100000)) {
+            $data[] = $rowData;
+        }
+        $driver->fileClose($fileResource);
+
+        return $data;
+    }
 }