feat (#1247): Speakers Expenses Files CleanCommand (#1288)

* feat (#1247): Speakers Expenses Files  CleanCommand

* feat (#1247): Ajout dans la crontab

* feat (#1247): code review

---------

Co-authored-by: Stakovicz <[email protected]>

Author: stakovicz

app/config/services.yml

@@ -247,9 +247,11 @@ services:
             $legacyBasePath: "%kernel.project_dir%/../htdocs"
 
     AppBundle\SpeakerInfos\SpeakersExpensesStorage:
+        autowire: true
+        autoconfigure: true
+        public: false
         arguments:
-            - "%kernel.project_dir%/../htdocs/uploads/speaker_expenses"
-            - "/uploads/speaker_expenses"
+            $basePath: "%kernel.project_dir%/../htdocs/uploads/speaker_expenses"
 
     Twig_Extensions_Extension_Intl:
         class: Twig_Extensions_Extension_Intl

clevercloud/cron.json

@@ -11,5 +11,6 @@
   "55 15 * * * $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod slack-member-notification",
   "0 * * * * $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod update-user-state",
   "32 * * * * $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod update-company-member-state",
-  "0 13 * * 2,4 $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod videos:run-notifier"
+  "0 13 * * 2,4 $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod videos:run-notifier",
+  "17 10 1 * * $ROOT/clevercloud/scripts/deduplicate_cron.sh /usr/bin/php $ROOT/bin/console --env=prod speaker:expenses-files-clean"
 ]

sources/AppBundle/Command/SpeakersExpensesFilesCleanCommand.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace AppBundle\Command;
+
+use AppBundle\SpeakerInfos\SpeakersExpensesStorage;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+#[AsCommand(name: 'speaker:expenses-files-clean')]
+class SpeakersExpensesFilesCleanCommand extends Command
+{
+    public function __construct(private readonly SpeakersExpensesStorage $speakersExpensesStorage)
+    {
+        parent::__construct();
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $this->speakersExpensesStorage->cleanFiles();
+
+        return self::SUCCESS;
+    }
+}

sources/AppBundle/Event/Model/Repository/EventRepository.php

@@ -9,6 +9,8 @@
 use AppBundle\Event\Model\Ticket;
 use AppBundle\Ting\DateTimeWithTimeZoneSerializer;
 use CCMBenchmark\Ting\Driver\Mysqli\Serializer\Boolean;
+use CCMBenchmark\Ting\Exception;
+use CCMBenchmark\Ting\Query\QueryException;
 use CCMBenchmark\Ting\Repository\CollectionInterface;
 use CCMBenchmark\Ting\Repository\HydratorArray;
 use CCMBenchmark\Ting\Repository\HydratorSingleObject;
@@ -217,11 +219,10 @@ public function getLastYearEvent(Event $event): Event
     }
 
     /**
-     * @param int $eventCount
-     *
-     * @return CollectionInterface
+     * @throws QueryException
+     * @throws Exception
      */
-    public function getPreviousEvents($eventCount)
+    public function getPreviousEvents(int $eventCount): CollectionInterface
     {
         $query = $this->getQuery('SELECT * FROM afup_forum WHERE date_debut < NOW() ORDER BY date_debut DESC LIMIT :limit');
         $query->setParams(['limit' => $eventCount]);
@@ -230,11 +231,18 @@ public function getPreviousEvents($eventCount)
     }
 
     /**
-     * @param $path
-     *
-     * @return Event|null
+     * @throws QueryException
+     * @throws Exception
      */
-    public function getByPath($path)
+    public function getPreviousEventsBefore(\DateTimeInterface $beforeDatetime): CollectionInterface
+    {
+        $query = $this->getQuery('SELECT * FROM afup_forum WHERE date_debut <= :before_date ORDER BY date_debut DESC');
+        $query->setParams(['before_date' => $beforeDatetime->format('Y-m-d')]);
+
+        return $query->query($this->getCollection(new HydratorSingleObject()));
+    }
+
+    public function getByPath(string $path): ?Event
     {
         return $this->getBy(['path' => $path])->first();
     }

sources/AppBundle/SpeakerInfos/SpeakersExpensesStorage.php

@@ -5,21 +5,23 @@
 
 namespace AppBundle\SpeakerInfos;
 
+use AppBundle\Event\Model\Repository\EventRepository;
 use AppBundle\Event\Model\Speaker;
+use Psr\Log\LoggerInterface;
 use Symfony\Component\Filesystem\Exception\IOException;
 use Symfony\Component\Filesystem\Filesystem;
 use Symfony\Component\Finder\Finder;
 use Symfony\Component\HttpFoundation\File\Exception\FileException;
 use Symfony\Component\HttpFoundation\File\UploadedFile;
 
-class SpeakersExpensesStorage
+final class SpeakersExpensesStorage
 {
-    private $basePath;
     private Filesystem $filesystem;
 
-    public function __construct($basePath)
-    {
-        $this->basePath = $basePath;
+    public function __construct(private readonly string $basePath,
+                                private readonly EventRepository $eventRepository,
+                                private readonly LoggerInterface $logger
+    ) {
         $this->filesystem = new Filesystem();
     }
 
@@ -66,6 +68,26 @@ public function getFiles(Speaker $speaker): array
         return $files;
     }
 
+    public function cleanFiles($duration = 'P12M'): void
+    {
+        $beforeDate = new \DateTime();
+        $beforeDate->sub(new \DateInterval($duration));
+
+        $this->logger->info(sprintf('Speakers Expenses Storage clean before "%s"', $beforeDate->format('Y-m-d')));
+
+        $events = $this->eventRepository->getPreviousEventsBefore($beforeDate);
+        foreach ($events as $event) {
+            $this->logger->info(sprintf('Event "%s" #%d [%s]: ', $event->getTitle(), $event->getId(), $event->getDateStart()->format('Y-m-d')));
+
+            $directory = $this->basePath . '/' . $event->getId();
+
+            if ($this->filesystem->exists($directory)) {
+                $this->filesystem->remove($directory);
+                $this->logger->info(sprintf('Removing "%s" directory OK', $directory));
+            }
+        }
+    }
+
     private function createDirectory(string $directory): void
     {
         try {