[TASK] do not allow createing a job if one is running or waiting

Author: achimfritz

Classes/Command/JobCreatorCommand.php

@@ -16,6 +16,7 @@
 use B13\ContentSync\Domain\Model\Job;
 use B13\ContentSync\Domain\Repository\JobRepository;
 use B13\ContentSync\Domain\Validation\ConfigurationValidator;
+use B13\ContentSync\Exception;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
@@ -40,7 +41,12 @@ public function execute(InputInterface $input, OutputInterface $output): int
         $this->validator->assertValid($configuration);
         $job = new Job();
         $job->setConfiguration($configuration);
-        $this->jobRepository->add($job);
+        try {
+            $this->jobRepository->add($job);
+        } catch (Exception $e) {
+            $output->writeln($e->getMessage());
+            return Command::FAILURE;
+        }
         return 0;
     }
 }

Classes/Domain/Repository/JobRepository.php

@@ -13,6 +13,7 @@
  */
 
 use B13\ContentSync\Domain\Model\Job;
+use B13\ContentSync\Exception;
 use TYPO3\CMS\Core\Database\Connection;
 use TYPO3\CMS\Core\Database\ConnectionPool;
 
@@ -26,6 +27,14 @@ public function __construct(
 
     public function add(Job $job): void
     {
+        $waitingJob = $this->findOneWaiting();
+        if ($waitingJob !== null) {
+            throw new Exception('there is already a waiting job', 1780465898);
+        }
+        $runningJob = $this->findOneRunning();
+        if ($runningJob !== null) {
+            throw new Exception('there is already a running job', 1780465899);
+        }
         $this->connectionPool->getConnectionForTable(self::TABLE)->insert(self::TABLE, $job->toDatabaseRow());
     }