Check maintenance mode

Author: tatevikg1

src/Domain/Configuration/Service/Manager/ConfigManager.php

@@ -17,6 +17,12 @@ public function __construct(ConfigRepository $configRepository)
         $this->configRepository = $configRepository;
     }
 
+    public function inMaintenanceMode(): bool
+    {
+        $config = $this->getByItem('maintenancemode');
+        return $config?->getValue() === '1';
+    }
+
     /**
      * Get a configuration item by its key
      */

src/Domain/Messaging/Command/ProcessQueueCommand.php

@@ -5,6 +5,7 @@
 namespace PhpList\Core\Domain\Messaging\Command;
 
 use DateTimeImmutable;
+use PhpList\Core\Domain\Configuration\Service\Manager\ConfigManager;
 use PhpList\Core\Domain\Messaging\Model\Message\MessageStatus;
 use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
 use PhpList\Core\Domain\Messaging\Service\MessageProcessingPreparator;
@@ -26,18 +27,21 @@ class ProcessQueueCommand extends Command
     private LockFactory $lockFactory;
     private MessageProcessingPreparator $messagePreparator;
     private CampaignProcessor $campaignProcessor;
+    private ConfigManager $configManager;
 
     public function __construct(
         MessageRepository $messageRepository,
         LockFactory $lockFactory,
         MessageProcessingPreparator $messagePreparator,
         CampaignProcessor $campaignProcessor,
+        ConfigManager $configManager
     ) {
         parent::__construct();
         $this->messageRepository = $messageRepository;
         $this->lockFactory = $lockFactory;
         $this->messagePreparator = $messagePreparator;
         $this->campaignProcessor = $campaignProcessor;
+        $this->configManager = $configManager;
     }
 
     /**
@@ -52,6 +56,12 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             return Command::FAILURE;
         }
 
+        if ($this->configManager->inMaintenanceMode()) {
+            $output->writeln('The system is in maintenance mode, stopping. Try again later.');
+
+            return Command::FAILURE;
+        }
+
         try {
             $this->messagePreparator->ensureSubscribersHaveUuid($output);
             $this->messagePreparator->ensureCampaignsHaveUuid($output);

tests/Unit/Domain/Messaging/Command/ProcessQueueCommandTest.php

@@ -5,6 +5,7 @@
 namespace PhpList\Core\Tests\Unit\Domain\Messaging\Command;
 
 use Exception;
+use PhpList\Core\Domain\Configuration\Service\Manager\ConfigManager;
 use PhpList\Core\Domain\Messaging\Command\ProcessQueueCommand;
 use PhpList\Core\Domain\Messaging\Model\Message;
 use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
@@ -41,7 +42,8 @@ protected function setUp(): void
             $this->messageRepository,
             $lockFactory,
             $this->messageProcessingPreparator,
-            $this->campaignProcessor
+            $this->campaignProcessor,
+            $this->createMock(ConfigManager::class),
         );
 
         $application = new Application();