added: configurable Fetcher options

induxx · Nov 22, 2023 · 2f82ffe · 2f82ffe
1 parent cffa29e
commit 2f82ffe
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 7 deletions.
diff --git a/src/Component/Converter/Akeneo/Csv/Product.php b/src/Component/Converter/Akeneo/Csv/Product.php
@@ -142,13 +142,13 @@ public function revert(array $item): array
         if (isset($item['enabled'])) {
             $output['enabled'] = $item['enabled'];
         }
-        if (array_key_exists($item['family'])) {
+        if (array_key_exists('family', $item)) {
             $output['family'] = $item['family'];
         }
-        if (array_key_exists($item['categories'])) {
+        if (array_key_exists('categories', $item)) {
             $output['categories'] = $item['categories'];
         }
-        if (array_key_exists($item['parent'])) {
+        if (array_key_exists('parent', $item)) {
             $output['parent'] = $item['parent'];
         }
         $output = $this->decoder->decode($output);

diff --git a/src/Component/Item/ItemsFactoryIntoItem.php b/src/Component/Item/ItemsFactoryIntoItem.php
@@ -15,7 +15,7 @@ public static function spreadFromConfig(
             return [];
         }
 
-        $result = array_fill_keys($configuration['list'], '');
+        $result = !empty($configuration['list']) ? array_fill_keys($configuration['list'], '') : [];
         $spreadConfiguration = $configuration['spread'];
         $attributesToKeep = [];
 

diff --git a/src/Component/Parser/ItemParserFactory.php b/src/Component/Parser/ItemParserFactory.php
@@ -24,14 +24,19 @@ public function createFromConfiguration(
             'type must be filled in.'
         )->notEmpty()->string()->inArray(['xml', 'csv', 'xlsx', 'list', 'feed', 'yaml', 'buffer', 'json']);
 
+        $fetchers = [
+            'continuous' => ContinuousBufferFetcher::class,
+            'zone' => OldCachedZoneFetcher::class
+        ];
+        $classFetcher = $fetchers[strtolower($configuration['fetcher'] ?? 'zone')];
+
         if (isset($configuration['join'])) {
             $joins = $configuration['join'];
             unset($configuration['join']);
             $mainParser = $this->createFromConfiguration($configuration, $manager);
 
             foreach ($joins as $join) {
-                $fetcher = clone new OldCachedZoneFetcher($this->createFromConfiguration($join, $manager), $join['link_join'], $join['allow_fileindex_removal'] ?? false);
-                ##$fetcher = clone new ContinuousBufferFetcher($this->createFromConfiguration($join, $manager), $join['link_join'], $join['allow_fileindex_removal'] ?? false);
+                $fetcher = clone new $classFetcher($this->createFromConfiguration($join, $manager), $join['link_join'], $join['allow_fileindex_removal'] ?? false);
                 $mainParser = new FunctionalCursor($mainParser, function ($row) use ($fetcher, $join) {
                     $masterID = $row[$join['link']];
                     $item = $fetcher->get($masterID) ?? [];

diff --git a/src/Component/Parser/XlsxParser.php b/src/Component/Parser/XlsxParser.php
@@ -39,7 +39,8 @@ private function init(): void
 
     public function current(): mixed
     {
-        if ($this->cursor === null) {
+        if (false === $this->cursor->valid()) {
+            return false;
         }
 
         $current = $this->cursor->current();