feat: import export bundle

Author: erdnaxelaweb

components/ImportExportBundle/src/lib/Job/JobRunner.php

@@ -41,13 +41,15 @@ protected function run(Job $job, int $batchLimit = -1): int
         $workflow = $this->workflowRegistry->getWorkflow($job->getWorkflowIdentifier());
         $workflow->setLogger($logger);
 
-        $onWorkflowProgress = function (WorkflowEvent $event) use ($logger, $job) {
+        $proccessed = 0;
+        $onWorkflowProgress = function (WorkflowEvent $event) use (&$proccessed, $logger, $job) {
             $workflow = $event->getWorkflow();
             // Ibexa content creation trigger an entity manager clear, which mean we need to reload the entity
             $job = $this->jobRepository->findById($job->getId());
             $job->addRecords($logger->getRecords());
             $job->setProcessedItemsCount($workflow->getOffset());
             $this->jobRepository->save($job);
+            ++$proccessed;
         };
         $workflow->addEventListener(WorkflowEvent::PROGRESS, $onWorkflowProgress);
 
@@ -81,7 +83,7 @@ protected function run(Job $job, int $batchLimit = -1): int
         $job = $this->jobRepository->findById($job->getId());
         $job->addRecords($logger->getRecords());
         $job->setWriterResults($workflow->getWriterResults());
-        if (1 == $job->getProgress() || 0 === $job->getTotalItemsCount()) {
+        if (1 == $job->getProgress() || 0 === $job->getTotalItemsCount() || 0 === $proccessed) {
             $job->setStatus(Job::STATUS_COMPLETED);
             $job->setEndTime($workflow->getEndTime());
         } else {

components/ImportExportBundle/src/lib/Reader/Xml/XmlReaderIterator.php

@@ -73,8 +73,8 @@ protected function findNextNode()
 
     public function seek($offset): void
     {
-        if ($offset > 0) {
-            for ($i = 0; $i < $offset; ++$i) {
+        if ($offset > 1) {
+            for ($i = 1; $i < $offset; ++$i) {
                 $this->xmlParser->parse();
             }
         }

components/ImportExportBundle/src/lib/Workflow/AbstractWorkflow.php

@@ -82,9 +82,8 @@ public function __invoke(int $batchLimit = -1): void
             $this->dispatchEvent(new WorkflowEvent($this), WorkflowEvent::START);
 
             $limitIterator = new LimitIterator($itemsIterator, $this->offset, $batchLimit);
-            dump('Start memory Usage: '.memory_get_usage() / 1024 / 1024 .'Mo');
             foreach ($limitIterator as $index => $item) {
-                $this->logger->setItemIndex($index);
+                $this->logger->setItemIndex($index + 1);
                 $this->referenceBag->resetScope(Reference::SCOPE_ITEM);
                 try {
                     foreach ($this->configuration->getProcessors() as $processor) {
@@ -105,8 +104,6 @@ public function __invoke(int $batchLimit = -1): void
                 ++$this->offset;
                 $this->dispatchEvent(new WorkflowEvent($this), WorkflowEvent::PROGRESS);
             }
-            dump('End Usage: '.memory_get_usage() / 1024 / 1024 .'Mo');
-            dump('Peak Usage: '.memory_get_usage() / 1024 / 1024 .'Mo');
 
             foreach ($writers as $index => $writer) {
                 $writer->finish();