Use ConfigProvider in ProcessQueueCommand

Author: tatevikg1

src/Domain/Configuration/Model/ConfigOption.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Configuration\Model;
+
+enum ConfigOption: string
+{
+    case MaintenanceMode = 'maintenancemode';
+    case SendSubscribeMessage = 'subscribemessage';
+}

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

@@ -17,12 +17,6 @@ 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/Configuration/Service/Provider/ConfigProvider.php

@@ -0,0 +1,44 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Configuration\Service\Provider;
+
+use InvalidArgumentException;
+use PhpList\Core\Domain\Configuration\Model\ConfigOption;
+use PhpList\Core\Domain\Configuration\Repository\ConfigRepository;
+
+class ConfigProvider
+{
+    private array $booleanValues = [
+        ConfigOption::MaintenanceMode,
+    ];
+
+    private ConfigRepository $configRepository;
+
+    public function __construct(ConfigRepository $configRepository)
+    {
+        $this->configRepository = $configRepository;
+    }
+
+    public function isEnabled(ConfigOption $key): bool
+    {
+        if (!in_array($key, $this->booleanValues)) {
+            throw new InvalidArgumentException('Invalid boolean value key');
+        }
+        $config = $this->configRepository->findOneBy(['item' => $key->value]);
+
+        return $config?->getValue() === '1';
+    }
+
+    /**
+     * Get configuration value by its key
+     */
+    public function getValue(string $ikey, ?string $default = null): ?string
+    {
+        $config = $this->configRepository->findOneBy(['item' => $ikey]);
+
+        return $config?->getValue() ?? $default;
+    }
+
+}

src/Domain/Messaging/Command/ProcessQueueCommand.php

@@ -5,7 +5,8 @@
 namespace PhpList\Core\Domain\Messaging\Command;
 
 use DateTimeImmutable;
-use PhpList\Core\Domain\Configuration\Service\Manager\ConfigManager;
+use PhpList\Core\Domain\Configuration\Model\ConfigOption;
+use PhpList\Core\Domain\Configuration\Service\Provider\ConfigProvider;
 use PhpList\Core\Domain\Messaging\Model\Message\MessageStatus;
 use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
 use PhpList\Core\Domain\Messaging\Service\MessageProcessingPreparator;
@@ -28,23 +29,23 @@ class ProcessQueueCommand extends Command
     private LockFactory $lockFactory;
     private MessageProcessingPreparator $messagePreparator;
     private CampaignProcessor $campaignProcessor;
-    private ConfigManager $configManager;
+    private ConfigProvider $configProvider;
     private TranslatorInterface $translator;
 
     public function __construct(
         MessageRepository $messageRepository,
         LockFactory $lockFactory,
         MessageProcessingPreparator $messagePreparator,
         CampaignProcessor $campaignProcessor,
-        ConfigManager $configManager,
+        ConfigProvider $configProvider,
         TranslatorInterface $translator
     ) {
         parent::__construct();
         $this->messageRepository = $messageRepository;
         $this->lockFactory = $lockFactory;
         $this->messagePreparator = $messagePreparator;
         $this->campaignProcessor = $campaignProcessor;
-        $this->configManager = $configManager;
+        $this->configProvider = $configProvider;
         $this->translator = $translator;
     }
 
@@ -60,7 +61,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             return Command::FAILURE;
         }
 
-        if ($this->configManager->inMaintenanceMode()) {
+        if ($this->configProvider->isEnabled(ConfigOption::MaintenanceMode)) {
             $output->writeln(
                 $this->translator->trans('The system is in maintenance mode, stopping. Try again later.')
             );