src/Suez/ReportImportBundle/Service/EventSubscriber/FileRenamer.php line 72

Open in your IDE?
  1. <?php
  2. /**
  3. * Copyright (C) SUEZ Smart Solutions - All Rights Reserved
  4. * On’Connect Gateway Management, 2018
  5. * Unauthorized copying of this file, via any medium is strictly prohibited
  6. * Proprietary and confidential
  7. * For the full copyright and license information, please report to the LICENSE CONTRACT
  8. */
  10. namespace Suez\ReportImportBundle\Service\EventSubscriber;
  12. use League\Flysystem\FileExistsException;
  13. use League\Flysystem\FileNotFoundException;
  14. use League\Flysystem\Filesystem;
  15. use Symfony\Component\Console\ConsoleEvents;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. /**
  19.  * Class FileRenamer.
  20.  *
  21.  * @author Ivanis Kouamé <ivanis.kouame@smile.fr>
  22.  */
  23. class FileRenamer implements EventSubscriberInterface
  24. {
  25.     /**
  26.      * @var array
  27.      */
  28.     protected $files;
  30.     /**
  31.      * @var Filesystem
  32.      */
  33.     private $filesystem;
  35.     /**
  36.      * FileRenamer constructor.
  37.      * @param Filesystem $filesystem
  38.      */
  39.     public function __construct(Filesystem $filesystem)
  40.     {
  41.         $this->filesystem = $filesystem;
  42.         $this->files = [];
  43.     }
  45.     /**
  46.      * @param $event
  47.      */
  48.     public function collectFile($event)
  49.     {
  50.         $actionName = $event['actionName'];
  51.         $sourceName = $event['sourceName'];
  52.         $this->files = [$event['file']];
  53.     }
  55.     /**
  56.      * @return array
  57.      */
  58.     public static function getSubscribedEvents()
  59.     {
  60.         return [
  61.             'read.end.filesystem' => 'collectFiles',
  62.             'read.start.file' => 'collectFile',
  63.             'process.end' => 'renameProcessedFiles',
  64.             ConsoleEvents::EXCEPTION => 'renameErrorFiles'
  65.         ];
  66.     }
  68.     /**
  69.      * @throws FileExistsException
  70.      * @throws FileNotFoundException
  71.      */
  72.     public function renameProcessedFiles()
  73.     {
  74.         $this->renameFiles('.pcs');
  75.     }
  77.     /**
  78.      * @throws FileExistsException
  79.      * @throws FileNotFoundException
  80.      */
  81.     public function renameErrorFiles()
  82.     {
  83.         $this->renameFiles('.err');
  84.     }
  86.     /**
  87.      * @param $event
  88.      */
  89.     public function collectFiles($event)
  90.     {
  91.         /*
  92.         $actionName = $event['actionName'];
  93.         $sourceName = $event['sourceName'];
  94.          */
  95.         $this->files = $event['files'];
  96.     }
  98.     /**
  99.      * @param $extension
  100.      * @throws FileExistsException
  101.      * @throws FileNotFoundException
  102.      */
  103.     private function renameFiles($extension)
  104.     {
  105.         foreach ($this->files as $filePath) {
  106.             $this->filesystem->rename($filePath, $filePath . $extension);
  107.         }
  108.     }
  109. }