Antidot\Queue\Container\ContextFactory

Complexity

Total Complexity

3

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Test Coverage

Coverage

91.67%

Importance

Changes	1
Bugs	0	Features	1

1 Method

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

<?php

declare(strict_types=1);

namespace Antidot\Queue\Container;

use Antidot\Queue\Container\Config\ConfigProvider;
use Assert\Assertion;
use Enqueue\Fs\FsConnectionFactory;
use Enqueue\Null\NullContext;
use Interop\Queue\Context;
use InvalidArgumentException;
use Psr\Container\ContainerInterface;

use function sprintf;

class ContextFactory
{
    private const NULL = 'null';
    private const FILESYSTEM = 'fs';

    public function __invoke(
        ContainerInterface $container,
        string $contextName = ConfigProvider::DEFAULT_CONTEXT
    ): Context {
        $contextConfig = ConfigProvider::getContextConfig($contextName, $container->get(ConfigProvider::CONFIG_KEY));

        $contextType = $contextConfig[ConfigProvider::CONTEXTS_TYPE_KEY];
        if (self::NULL === $contextType) {
            return new NullContext();
        }

        if (self::FILESYSTEM === $contextType) {
            Assertion::classExists(
                FsConnectionFactory::class,
                'Install "enqueue/fs" package to run filesystem context.'
            );
            Assertion::keyExists($contextConfig, 'path', 'Absolute "path" is required to run filesystem context.');
            return (new FsConnectionFactory($contextConfig['path']))->createContext();
        }

        throw new InvalidArgumentException(sprintf('There is not implementation for given context %s.', $contextType));
    }
}