diff --git a/src/DB/Managers/ParallelRunningStateManager.php b/src/DB/Managers/ParallelRunningStateManager.php index 8e4088a..c4ecb1e 100644 --- a/src/DB/Managers/ParallelRunningStateManager.php +++ b/src/DB/Managers/ParallelRunningStateManager.php @@ -4,27 +4,26 @@ namespace Abrouter\Client\DB\Managers; +use Abrouter\Client\Config\Accessors\KvStorageConfigAccessor; use Abrouter\Client\DB\Dictionary\ParallelRunningDictionary; -use Abrouter\Client\DB\RedisConnection; use Abrouter\Client\DB\Repositories\ParallelRunningStateCachedRepository; class ParallelRunningStateManager { - private RedisConnection $redisConnection; - private ParallelRunningStateCachedRepository $parallelRunningStateCachedRepository; + private KvStorageConfigAccessor $kvStorageConfigAccessor; public function __construct( - RedisConnection $redisConnection, + KvStorageConfigAccessor $kvStorageConfigAccessor, ParallelRunningStateCachedRepository $parallelRunningStateCachedRepository ) { - $this->redisConnection = $redisConnection; + $this->kvStorageConfigAccessor = $kvStorageConfigAccessor; $this->parallelRunningStateCachedRepository = $parallelRunningStateCachedRepository; } public function setReadyToServe() { - $this->redisConnection->getConnection()->set( + $this->kvStorageConfigAccessor->getKvStorage()->put( ParallelRunningDictionary::IS_RUNNING_KEY, ParallelRunningDictionary::IS_RUNNING_VALUE_TRUE ); @@ -33,7 +32,7 @@ public function setReadyToServe() public function setStopServing() { - $this->redisConnection->getConnection()->set( + $this->kvStorageConfigAccessor->getKvStorage()->put( ParallelRunningDictionary::IS_RUNNING_KEY, ParallelRunningDictionary::IS_RUNNING_VALUE_STOPPED ); @@ -42,7 +41,7 @@ public function setStopServing() public function setInitialized() { - $this->redisConnection->getConnection()->set( + $this->kvStorageConfigAccessor->getKvStorage()->put( ParallelRunningDictionary::IS_INITIAZLIED_KEY, ParallelRunningDictionary::IS_INITIAZLIED_TRUE_VALUE ); diff --git a/src/DB/Repositories/ParallelRunningStateRepository.php b/src/DB/Repositories/ParallelRunningStateRepository.php index 880a2b8..9f90825 100644 --- a/src/DB/Repositories/ParallelRunningStateRepository.php +++ b/src/DB/Repositories/ParallelRunningStateRepository.php @@ -4,27 +4,27 @@ namespace Abrouter\Client\DB\Repositories; +use Abrouter\Client\Config\Accessors\KvStorageConfigAccessor; use Abrouter\Client\DB\Dictionary\ParallelRunningDictionary; -use Abrouter\Client\DB\RedisConnection; class ParallelRunningStateRepository { - private RedisConnection $redisConnection; + private KvStorageConfigAccessor $kvStorage; - public function __construct(RedisConnection $redisConnection) + public function __construct(KvStorageConfigAccessor $kvStorageConfigAccessor) { - $this->redisConnection = $redisConnection; + $this->kvStorage = $kvStorageConfigAccessor; } public function isInitialized(): bool { - $value = $this->redisConnection->getConnection()->get(ParallelRunningDictionary::IS_INITIAZLIED_KEY); + $value = $this->kvStorage->getKvStorage()->get(ParallelRunningDictionary::IS_INITIAZLIED_KEY); return $value === ParallelRunningDictionary::IS_INITIAZLIED_TRUE_VALUE; } public function isReady(): bool { - $value = $this->redisConnection->getConnection()->get(ParallelRunningDictionary::IS_RUNNING_KEY); + $value = $this->kvStorage->getKvStorage()->get(ParallelRunningDictionary::IS_RUNNING_KEY); return $value === ParallelRunningDictionary::IS_RUNNING_VALUE_TRUE; } } diff --git a/src/Services/ExperimentsParallelRun/ParallelRunInitializer.php b/src/Services/ExperimentsParallelRun/ParallelRunInitializer.php index 3de884c..c709877 100644 --- a/src/Services/ExperimentsParallelRun/ParallelRunInitializer.php +++ b/src/Services/ExperimentsParallelRun/ParallelRunInitializer.php @@ -5,7 +5,6 @@ namespace Abrouter\Client\Services\ExperimentsParallelRun; use Abrouter\Client\DB\Managers\ParallelRunningStateManager; -use Abrouter\Client\DB\RedisConnection; use Abrouter\Client\DB\RelatedUsersStore; use Abrouter\Client\DB\Repositories\ParallelRunningStateCachedRepository; @@ -15,24 +14,16 @@ class ParallelRunInitializer private ParallelRunningStateManager $parallelRunningStateManager; - private RedisConnection $redisConnection; - public function __construct( ParallelRunningStateCachedRepository $parallelRunningStateCachedRepository, - ParallelRunningStateManager $parallelRunningStateManager, - RedisConnection $redisConnection + ParallelRunningStateManager $parallelRunningStateManager ) { $this->parallelRunningStateCachedRepository = $parallelRunningStateCachedRepository; $this->parallelRunningStateManager = $parallelRunningStateManager; - $this->redisConnection = $redisConnection; } public function initializeIfNot(): bool { - if (!$this->redisConnection->isReady()) { - return false; - } - //if parallel running ready to serve if ($this->parallelRunningStateCachedRepository->isReady()) { return true;