TMV\Messenger\Factory\Command\StopWorkersCommandFactory

Complexity

Total Complexity

3

Size/Duplication

Total Lines	16
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	14	3

<?php

declare(strict_types=1);

namespace TMV\Messenger\Factory\Command;

use Psr\Cache\CacheItemPoolInterface;
use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Command\StopWorkersCommand;
use TMV\Messenger\Exception\InvalidArgumentException;

final class StopWorkersCommandFactory
{
    public function __invoke(ContainerInterface $container): StopWorkersCommand
    {
        $config = $container->has('config') ? $container->get('config') : [];
        /** @var string|null $cachePoolForRestartSignal */
        $cachePoolForRestartSignal = $config['messenger']['cache_pool_for_restart_signal'] ?? null;

        if (null === $cachePoolForRestartSignal) {
            throw new InvalidArgumentException('Invalid cache_pool_for_restart_signal name');
        }

        /** @var CacheItemPoolInterface $cachePoolForRestartSignal */
        $cachePoolForRestartSignal = $container->get($cachePoolForRestartSignal);

$cachePoolForRestartSignal of type Psr\Cache\CacheItemPoolInterface is incompatible with the type string expected by parameter $id of Psr\Container\ContainerInterface::get().

        return new StopWorkersCommand($cachePoolForRestartSignal);
    }
}