5050: Add progressbar to import jobs

Author: turegjorup

src/Command/AbstractImportCommand.php

@@ -6,6 +6,7 @@
 use App\Service\BaseImporter;
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\ProgressBar;
 use Symfony\Component\Console\Output\OutputInterface;
 
 abstract class AbstractImportCommand extends Command
@@ -22,13 +23,15 @@ public function __construct(
      *
      * @throws \Exception
      */
-    protected function import(string $type, string $src, OutputInterface $output): void
+    protected function import(string $type, string $src, OutputInterface $output, bool $progress = false): void
     {
         $success = true;
         $errorMessage = null;
 
+        $progressBar = $progress ? new ProgressBar($output) : null;
+
         try {
-            $this->importer->import($src);
+            $this->importer->import($src, $progressBar);
         } catch (\Exception $e) {
             $success = false;
             $errorMessage = $e->getMessage();

src/Command/ReportImportCommand.php

@@ -7,6 +7,7 @@
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
 
 class ReportImportCommand extends AbstractImportCommand
@@ -22,6 +23,7 @@ protected function configure(): void
             ->setName('itstyr:import:report')
             ->setDescription('Import reports from feed.')
             ->addArgument('src', InputArgument::REQUIRED, 'The src of the feed.')
+            ->addOption('progress', 'p', InputOption::VALUE_NONE, 'The src of the feed.')
         ;
     }
 
@@ -30,7 +32,7 @@ protected function configure(): void
      */
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
-        $this->import(Report::class, $input->getArgument('src'), $output);
+        $this->import(Report::class, $input->getArgument('src'), $output, $input->getOption('progress'));
 
         return 0;
     }

src/Service/ImportInterface.php

@@ -2,6 +2,8 @@
 
 namespace App\Service;
 
+use Symfony\Component\Console\Helper\ProgressBar;
+
 interface ImportInterface
 {
     /**
@@ -10,5 +12,5 @@ interface ImportInterface
      * @param string $src
      *   Path to the source
      */
-    public function import(string $src): void;
+    public function import(string $src, ProgressBar $progressBar = null): void;
 }

src/Service/ReportImporter.php

@@ -3,10 +3,11 @@
 namespace App\Service;
 
 use App\Entity\Report;
+use Symfony\Component\Console\Helper\ProgressBar;
 
 class ReportImporter extends BaseImporter
 {
-    public function import(string $src): void
+    public function import(string $src, ProgressBar $progressBar = null): void
     {
         $systemURL = getenv('SYSTEM_URL');
 
@@ -18,6 +19,8 @@ public function import(string $src): void
             return;
         }
 
+        $progressBar?->setMaxSteps(\count($entries));
+
         // List of ids from Anmeldelsesportalen.
         $sysInternalIds = [];
 
@@ -99,8 +102,12 @@ public function import(string $src): void
                     $report->setSysOwnerSub($subGroupName);
                 }
             }
+
+            $progressBar?->advance();
         }
 
+        $progressBar?->setMessage('Starting archiving ...');
+
         // Archive reports that no longer exist in anmeldelsesportalen.
         $this->reportRepository->createQueryBuilder('e')
             ->update()
@@ -112,6 +119,10 @@ public function import(string $src): void
             ->execute()
         ;
 
+        $progressBar?->setMessage('Flushing ...');
+
         $this->entityManager->flush();
+
+        $progressBar?->finish();
     }
 }

src/Service/SystemImporter.php

@@ -8,6 +8,7 @@
 use App\Repository\SelfServiceAvailableFromItemRepository;
 use App\Repository\SystemRepository;
 use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\Console\Helper\ProgressBar;
 
 class SystemImporter extends BaseImporter
 {
@@ -21,7 +22,7 @@ public function __construct(
         parent::__construct($reportRepository, $systemRepository, $groupRepository, $entityManager);
     }
 
-    public function import(string $src): void
+    public function import(string $src, ProgressBar $progressBar = null): void
     {
         $systemURL = getenv('SYSTEM_URL');
 
@@ -33,6 +34,8 @@ public function import(string $src): void
             return;
         }
 
+        $progressBar?->setMaxSteps(\count($entries));
+
         // List of ids from Systemoversigten.
         $sysInternalIds = [];
 
@@ -137,10 +140,14 @@ public function import(string $src): void
                     $system->setSysOwnerSub($subGroupName);
                 }
             }
+
+            $progressBar?->advance();
         }
 
         // Archive systems that no longer exist in Systemoversigten.
 
+        $progressBar?->setMessage('Starting archiving ...');
+
         $this->systemRepository->createQueryBuilder('e')
             ->update()
             ->set('e.archivedAt', ':now')
@@ -152,6 +159,10 @@ public function import(string $src): void
             ->execute()
         ;
 
+        $progressBar?->setMessage('Flushing ...');
+
         $this->entityManager->flush();
+
+        $progressBar?->finish();
     }
 }