chore(poc): add unit tests

Author: AntoineSmagghe

composer.lock

@@ -11,9 +11,11 @@
 
 final class ImportEudonetParisRegulationCommand implements CommandInterface
 {
+    /**
+     * @param SaveMeasureCommand[] $measureCommands
+     */
     public function __construct(
         public readonly SaveRegulationGeneralInfoCommand $generalInfoCommand,
-        /** @var SaveMeasureCommand[] */
         public readonly array $measureCommands,
     ) {
         $generalInfoCommand->source = RegulationOrderRecordSourceEnum::EUDONET_PARIS->value;

src/Application/Integration/EudonetParis/Command/ImportEudonetParisRegulationCommand.php

@@ -11,9 +11,9 @@
 
 final class ImportLitteralisRegulationCommand implements CommandInterface
 {
+    /** @param SaveMeasureCommand[] $measureCommands */
     public function __construct(
         public SaveRegulationGeneralInfoCommand $generalInfoCommand,
-        /** @var SaveMeasureCommand[] */
         public readonly array $measureCommands,
         public readonly ?string $downloadUrl = null,
     ) {

src/Application/Integration/Litteralis/Command/ImportLitteralisRegulationCommand.php

@@ -5,7 +5,6 @@
 namespace App\Application\Regulation\Command;
 
 use App\Application\CommandBusInterface;
-use App\Application\Regulation\DatexGeneratorInterface;
 use App\Domain\Regulation\Enum\ActionTypeEnum;
 use App\Domain\Regulation\Enum\RegulationOrderRecordStatusEnum;
 use App\Domain\Regulation\Exception\RegulationOrderRecordCannotBePublishedException;
@@ -16,7 +15,6 @@ final class PublishRegulationCommandHandler
     public function __construct(
         private CanRegulationOrderRecordBePublished $canRegulationOrderRecordBePublished,
         private CommandBusInterface $commandBus,
-        private DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -31,7 +29,5 @@ public function __invoke(PublishRegulationCommand $command): void
         $this->commandBus->handle(new CreateRegulationOrderHistoryCommand($regulationOrder, ActionTypeEnum::PUBLISH->value));
 
         $command->regulationOrderRecord->updateStatus(RegulationOrderRecordStatusEnum::PUBLISHED->value);
-
-        $this->datexGenerator->generate();
     }
 }

src/Application/Regulation/Command/PublishRegulationCommandHandler.php

@@ -8,6 +8,7 @@
 use App\Application\Organization\Command\UpdateApiClientLastUsedAtCommand;
 use App\Application\QueryBusInterface;
 use App\Application\Regulation\Command\DeleteRegulationCommand;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Application\Regulation\Query\GetRegulationOrderRecordByIdentifierQuery;
 use App\Domain\Regulation\Exception\RegulationOrderRecordCannotBeDeletedException;
 use App\Domain\Regulation\Exception\RegulationOrderRecordNotFoundException;
@@ -25,6 +26,7 @@ public function __construct(
         private readonly CommandBusInterface $commandBus,
         private readonly QueryBusInterface $queryBus,
         private readonly Security $security,
+        private readonly DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -103,6 +105,8 @@ public function __invoke(string $identifier): JsonResponse
             ], Response::HTTP_FORBIDDEN);
         }
 
+        $this->datexGenerator->generate();
+
         return new JsonResponse(null, Response::HTTP_NO_CONTENT);
     }
 }

src/Infrastructure/Controller/Api/Regulations/DeleteRegulationController.php

@@ -8,6 +8,7 @@
 use App\Application\Organization\Command\UpdateApiClientLastUsedAtCommand;
 use App\Application\QueryBusInterface;
 use App\Application\Regulation\Command\PublishRegulationCommand;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Application\Regulation\Query\GetRegulationOrderRecordByIdentifierQuery;
 use App\Domain\Regulation\Enum\RegulationOrderRecordStatusEnum;
 use App\Domain\Regulation\Exception\RegulationOrderRecordCannotBePublishedException;
@@ -26,6 +27,7 @@ public function __construct(
         private readonly CommandBusInterface $commandBus,
         private readonly QueryBusInterface $queryBus,
         private readonly Security $security,
+        private readonly DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -106,6 +108,8 @@ public function __invoke(string $identifier): JsonResponse
             ], Response::HTTP_BAD_REQUEST);
         }
 
+        $this->datexGenerator->generate();
+
         return new JsonResponse([
             'identifier' => $regulationOrderRecord->getRegulationOrder()->getIdentifier(),
             'status' => RegulationOrderRecordStatusEnum::PUBLISHED->value,

src/Infrastructure/Controller/Api/Regulations/PublishRegulationController.php

@@ -7,6 +7,7 @@
 use App\Application\CommandBusInterface;
 use App\Application\QueryBusInterface;
 use App\Application\Regulation\Command\DeleteRegulationCommand;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Application\Regulation\Query\GetRegulationOrderRecordByUuidQuery;
 use App\Domain\Regulation\Exception\RegulationOrderRecordCannotBeDeletedException;
 use App\Domain\Regulation\Exception\RegulationOrderRecordNotFoundException;
@@ -29,6 +30,7 @@ public function __construct(
         private CommandBusInterface $commandBus,
         private QueryBusInterface $queryBus,
         private Security $security,
+        private DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -62,6 +64,8 @@ public function __invoke(Request $request, string $uuid): Response
             throw new AccessDeniedHttpException();
         }
 
+        $this->datexGenerator->generate();
+
         $redirectQueryParams = $request->query->get('_redirectQueryParams')
             ? json_decode($request->query->get('_redirectQueryParams'), true)
             : [];

src/Infrastructure/Controller/Regulation/DeleteRegulationController.php

@@ -7,6 +7,7 @@
 use App\Application\CommandBusInterface;
 use App\Application\QueryBusInterface;
 use App\Application\Regulation\Command\PublishRegulationCommand;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Domain\Regulation\Exception\RegulationOrderRecordCannotBePublishedException;
 use App\Domain\Regulation\Specification\CanOrganizationAccessToRegulation;
 use App\Infrastructure\Security\Voter\RegulationOrderRecordVoter;
@@ -25,6 +26,7 @@ final class PublishRegulationController extends AbstractRegulationController
     public function __construct(
         private RouterInterface $router,
         private CommandBusInterface $commandBus,
+        private DatexGeneratorInterface $datexGenerator,
         QueryBusInterface $queryBus,
         Security $security,
         CanOrganizationAccessToRegulation $canOrganizationAccessToRegulation,
@@ -53,6 +55,8 @@ public function __invoke(Request $request, string $uuid): Response
             throw new AccessDeniedHttpException();
         }
 
+        $this->datexGenerator->generate();
+
         return new RedirectResponse(
             url: $this->router->generate('app_regulation_detail', [
                 'uuid' => $uuid,

src/Infrastructure/Controller/Regulation/PublishRegulationController.php

@@ -7,6 +7,7 @@
 use App\Application\CommandBusInterface;
 use App\Application\DateUtilsInterface;
 use App\Application\Integration\BacIdf\Exception\ImportBacIdfRegulationFailedException;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Domain\Regulation\Enum\RegulationOrderRecordSourceEnum;
 use App\Domain\Regulation\Repository\RegulationOrderRecordRepositoryInterface;
 use App\Infrastructure\Integration\BacIdf\Exception\BacIdfException;
@@ -21,6 +22,7 @@ public function __construct(
         private CommandBusInterface $commandBus,
         private RegulationOrderRecordRepositoryInterface $regulationOrderRecordRepository,
         private DateUtilsInterface $dateUtils,
+        private DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -74,6 +76,8 @@ public function execute(): void
                     }
                 }
             }
+
+            $this->datexGenerator->generate();
         } catch (\Exception $exc) {
             $this->logger->error('exception', ['exc' => $exc]);
 

src/Infrastructure/Integration/BacIdf/BacIdfExecutor.php

@@ -8,6 +8,7 @@
 use App\Application\DateUtilsInterface;
 use App\Application\Integration\EudonetParis\Exception\ImportEudonetParisRegulationFailedException;
 use App\Application\QueryBusInterface;
+use App\Application\Regulation\DatexGeneratorInterface;
 use App\Application\User\Query\GetOrganizationByUuidQuery;
 use App\Domain\Regulation\Enum\RegulationOrderRecordSourceEnum;
 use App\Domain\Regulation\Repository\RegulationOrderRecordRepositoryInterface;
@@ -26,6 +27,7 @@ public function __construct(
         private RegulationOrderRecordRepositoryInterface $regulationOrderRecordRepository,
         private string $eudonetParisOrgId,
         private DateUtilsInterface $dateUtils,
+        private DatexGeneratorInterface $datexGenerator,
     ) {
     }
 
@@ -86,6 +88,8 @@ public function execute(\DateTimeInterface $laterThanUTC): void
 
             $numberOfRegulationsInsideEudonet = $this->eudonetParisExtractor->getNumberOfRegulations();
             $numberOfMeasuresInsideEudonet = $this->eudonetParisExtractor->getNumberOfMeasures();
+
+            $this->datexGenerator->generate();
         } catch (\Exception $exc) {
             $this->logger->error($exc);